package com.example.cosmosclient.services;

import android.Manifest;
import android.app.IntentService;
import android.app.NotificationChannel;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.content.Intent;
import android.content.Context;
import android.content.pm.PackageManager;
import android.content.res.Configuration;
import android.graphics.Color;
import android.location.Location;
import android.location.LocationListener;
import android.location.LocationManager;
import android.os.Build;
import android.os.Bundle;
import android.os.IBinder;
import android.provider.Settings;
import android.support.annotation.Nullable;
import android.support.annotation.RequiresApi;
import android.support.v4.app.ActivityCompat;
import android.util.Log;
import android.widget.Toast;

import com.example.cosmosclient.R;
import com.example.cosmosclient.app.Cosmos;
import com.example.cosmosclient.entities.AreaInformation;
import com.example.cosmosclient.entities.CosmosLocation;
import com.example.cosmosclient.entities.Feature;
import com.example.cosmosclient.entities.Group;
import com.example.cosmosclient.entities.GroupListResponse;
import com.example.cosmosclient.entities.RequestList;
import com.example.cosmosclient.entities.jsons.GroupJson;
import com.example.cosmosclient.resources.GroupsRest;
import com.example.cosmosclient.resources.LocationRest;

import java.io.FileDescriptor;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.TimeZone;
import java.util.Timer;
import java.util.TimerTask;
import java.util.UUID;

import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;
import retrofit2.Retrofit;
import retrofit2.converter.jackson.JacksonConverterFactory;

import static android.app.Notification.EXTRA_NOTIFICATION_ID;


public class CosmosBackgroundService extends IntentService implements LocationListener {
    private Context context;
    private LocationManager locationManager;
    private static final int MinTime = 1000;/*最小時間間隔*/
    private static final float MinDistance = 1;/*最小距離間隔*/
    private static boolean isServiceRunning = false; //サービスが起動しているかを確認
    private String TAG = CosmosBackgroundService.class.getSimpleName();
    private List<Notification> notifications =null;
    private CosmosLocation LOC = new CosmosLocation();
    private double leftLat,leftLon,rightLat,rightLon; //ここに計算予定
    private int count = 0;
    private int areacount = 0;
    private ArrayList<Feature> Electrical = new ArrayList<>();
    private ArrayList<Feature> Home = new ArrayList<>();
    private ArrayList<Feature> Phone = new ArrayList<>();
    private ArrayList<Feature> PC = new ArrayList<>();
    private ArrayList<Feature> Convenience = new ArrayList<>();
    private ArrayList<Feature> Supermarket = new ArrayList<>();
    private AreaInformation areaInfo = null;
    private NotificationManager notificationManager;

    public CosmosBackgroundService() {
        super("CosmosBackgroundService");
        Log.d(TAG, "Constructor");
    }

    @Override
    public void setIntentRedelivery(boolean enabled) {
        Log.d(TAG, "setIntentRedelivery");
        super.setIntentRedelivery(enabled);
    }

    @Override
    public void onCreate() {
        Log.d(TAG, "onCreate");
        super.onCreate();
        context = getApplicationContext();
        // LocationManager インスタンス生成
        locationManager = (LocationManager) getSystemService(LOCATION_SERVICE);
        notificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
        int importance = NotificationManager.IMPORTANCE_HIGH;
        NotificationChannel mChannel = new NotificationChannel("cosmos", "cosmosChannel", importance);
        notificationManager.createNotificationChannel(mChannel);
    }

    @Override
    public void onStart(@Nullable Intent intent, int startId) {
        Log.d(TAG, "onStart");
        super.onStart(intent, startId);
    }

    @RequiresApi(api = Build.VERSION_CODES.O)
    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        Log.d(TAG, "onStartCommand");
        if(!isServiceRunning) {
            int requestCode = 0;
            String channelId = "default";
            String title = context.getString(R.string.app_name);
            PendingIntent pendingIntent =
                    PendingIntent.getActivity(context, requestCode,
                            intent, PendingIntent.FLAG_UPDATE_CURRENT);
            // ForegroundにするためNotificationが必要、Contextを設定
            NotificationManager notificationManager =
                    (NotificationManager) context.
                            getSystemService(Context.NOTIFICATION_SERVICE);
            // Notification　Channel 設定
            NotificationChannel channel = new NotificationChannel(
                    channelId, title, NotificationManager.IMPORTANCE_DEFAULT);
            channel.setDescription("Silent Notification");
            // 通知音を消さないと毎回通知音が出てしまう
            // この辺りの設定はcleanにしてから変更
            channel.setSound(null, null);
            // 通知ランプを消す
            channel.enableLights(false);
            channel.setLightColor(Color.BLUE);
            // 通知バイブレーション無し
            channel.enableVibration(false);
            if (notificationManager != null) {
                notificationManager.createNotificationChannel(channel);
                android.app.Notification notification = new android.app.Notification.Builder(context, channelId)
                        .setContentTitle(title)
                        // 本来なら衛星のアイコンですがandroid標準アイコンを設定
                        .setSmallIcon(android.R.drawable.btn_star)
                        .setContentText("GPS")
                        .setAutoCancel(true)
                        .setContentIntent(pendingIntent)
                        .setWhen(System.currentTimeMillis())
                        .build();

                // startForeground
                startForeground(1, notification);
            }

            startGPS();
            Timer timer = new Timer();
            TimerTask task = new TimerTask() {
                @Override
                public void run() {
                    startUpdateRequest();
                }
            };
            //timer.scheduleAtFixedRate(定期的に実行したいタスク,初回のタスク実行までの時間(ms),実行するタスクの間隔(ms));
            timer.scheduleAtFixedRate(task, 10000, 30000);
            isServiceRunning = true;
        }

        return START_NOT_STICKY;
    }

    @RequiresApi(api = Build.VERSION_CODES.O)
    @Override
    protected void onHandleIntent(Intent intent) {
        Log.d(TAG, "onHandleIntent");
    }

    protected void startGPS() {
        Log.d(TAG, "startGPS");
        final boolean gpsEnabled
                = locationManager.isProviderEnabled(LocationManager.GPS_PROVIDER);

        if (!gpsEnabled) {
            // GPSを設定するように促す
            enableLocationSettings();
        }

        if (locationManager != null) {
            try {
                if (ActivityCompat.checkSelfPermission(this,
                        Manifest.permission.ACCESS_FINE_LOCATION) !=
                        PackageManager.PERMISSION_GRANTED) {
                    return;
                }
//                Log.d(TAG, "requestLocationUpdates:");

                locationManager.requestLocationUpdates(LocationManager.GPS_PROVIDER,
                        MinTime, MinDistance, this);
            } catch (Exception e) {
//                Log.d(TAG, "Exception:");

                e.printStackTrace();
            }
        } else {
        }
    }

    @Override
    public void onDestroy() {
        Log.d(TAG, "onDestroy");
        super.onDestroy();
    }

    @Override
    public void onConfigurationChanged(Configuration newConfig) {
        Log.d(TAG, "onConfigurationChanged");
        super.onConfigurationChanged(newConfig);
    }

    @Override
    public void onLowMemory() {
        Log.d(TAG, "onLowMemory");
        super.onLowMemory();
    }

    @Override
    public void onTrimMemory(int level) {
        Log.d(TAG, "onTrimMemory");
        super.onTrimMemory(level);
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        Log.d(TAG, "onBind");
        return super.onBind(intent);
    }

    @Override
    public boolean onUnbind(Intent intent) {
        Log.d(TAG, "onUnbind");
        return super.onUnbind(intent);
    }

    @Override
    public void onRebind(Intent intent) {
        Log.d(TAG, "onRebind");
        super.onRebind(intent);
    }

    @Override
    public void onTaskRemoved(Intent rootIntent) {
        Log.d(TAG, "onTaskRemoved");
        super.onTaskRemoved(rootIntent);
    }

    @Override
    protected void dump(FileDescriptor fd, PrintWriter writer, String[] args) {
        Log.d(TAG, "dump");
        super.dump(fd, writer, args);
    }

    @Override
    public void onLocationChanged(final Location location) {
        final Cosmos cosmos = (Cosmos) getApplication();
//        Log.d(TAG, "onLocationChanged");
        Log.d(TAG, "lat:" + location.getLatitude());
        Log.d(TAG, "lon:" + location.getLongitude());

        new Thread(new Runnable() {
            private List<Notification> notifications;

            public void run() {
                updateAreaInformation(location);
                this.notifications=searchNotifications(cosmos,location);
                sendNotifications(CosmosBackgroundService.this, notifications);
            }
        }).start();

    }

    private void sendNotifications(CosmosBackgroundService cosmosBackgroundService, List<Notification> notifications) {
        for (Notification notify: notifications) {

            int notificationId = 1;
            //以下はボタンについてだよ
            Intent intent = new Intent(cosmosBackgroundService, NotificationDone.class);
            //snoozeIntent.setAction(ACTION_NOTIFICATION_OFF);
            intent.putExtra(EXTRA_NOTIFICATION_ID, 0);
            //以下2行はテスト用。本来はNotificationから取ってくる。
            intent.putExtra("gId", notify.getGroup().getgId());
            intent.putExtra("rId", notify.getRequest().getrId());
            int randamCode = (int)(Math.random()*100000);
            PendingIntent pendingIntent = PendingIntent.getBroadcast(cosmosBackgroundService, randamCode, intent, PendingIntent.FLAG_UPDATE_CURRENT);

            android.app.Notification.Action action = new android.app.Notification.Action(R.drawable.notification_icon, "買えたよボタン", pendingIntent);
            android.app.Notification notification = new android.app.Notification.Builder(cosmosBackgroundService)
                    .setContentTitle("グループ名：" + notify.getGroup().getName())
                    .setContentText("商品名：" + notify.getRequest().getProduct())
                    .setSmallIcon(R.drawable.icon_no)
                    .setChannelId("cosmos")
//                .setGroup("")
                    .addAction(action)
                    .build();
            notificationManager.notify(notificationId, notification);
        }


    }

    @Override
    public void onStatusChanged(String provider, int status, Bundle extras) {
        Log.d(TAG, "onStatusChanged");
    }

    @Override
    public void onProviderEnabled(String provider) {
        Log.d(TAG, "onProviderEnabled");
    }

    @Override
    public void onProviderDisabled(String provider) {
        Log.d(TAG, "onProviderDisabled");

    }

    private void startUpdateRequest() {
        final Cosmos app = (Cosmos) getApplication();
        if(app.getuId() != null) {
            final String uId, token;
            uId = app.getuId();
            token = app.getToken();

            //retrofitの処理
            final Retrofit retrofit = new Retrofit.Builder()
                    .baseUrl("http://nitta-lab-www.is.konan-u.ac.jp/cosmos/rest/")
                    .addConverterFactory(JacksonConverterFactory.create())
                    .build();
            //interfaceから実装を取得
            final GroupsRest getGroupsService = retrofit.create(GroupsRest.class);
            final GroupsRest getRequestsService = retrofit.create(GroupsRest.class);

            //API呼び出しのための値入力
            final Call<GroupListResponse> call = getGroupsService.getGroups(uId, token);

            //サーバからデータ受け取り
            call.enqueue(new Callback<GroupListResponse>() {
                //成功時
                @Override
                public void onResponse(Call<GroupListResponse> call, Response<GroupListResponse> response) {
                    if (response.isSuccessful()) {
                        final GroupListResponse groupListresult = response.body();
                        Log.d(TAG, "GroupListResponseグループ情報通信取得しました");

                        new Thread(new Runnable() {
                            public void run() {
                                for (GroupJson groupJson : groupListresult.getGroups()) {
                                    app.setGroup(new Group(groupJson));
                                    if (groupJson.getRequestHash() != app.getGroup(groupJson.getgId()).getRequestHash()) {
                                        //RequestList取得するための必要な情報
                                        final String gId = groupJson.getgId();
                                        final boolean detail = true;
                                        int quantity = 20;

                                        final Call<RequestList> requestsListByGidCall = getRequestsService.getRequestsListByGid(gId, token, detail, quantity);
                                        Response<RequestList> requestListResponse;
                                        try {
                                            requestListResponse = requestsListByGidCall.execute();
                                            if (requestListResponse.isSuccessful()) {
                                                TimeZone.setDefault(TimeZone.getTimeZone("Asia/Tokyo"));
                                                RequestList requestList = requestListResponse.body();
                                                app.getGroup(groupJson.getgId()).setRequestList(requestList);
                                                app.getGroup(groupJson.getgId()).setRequestHash(groupJson.getRequestHash());
                                                Log.d(TAG, groupJson.getName() + "のRequestListを取得しました");
                                            } else {
                                                // onFailure
                                                try {
                                                    System.out.println(requestListResponse.errorBody().string());
                                                } catch (IOException e) {
                                                    e.printStackTrace();
                                                }

                                                //onFailureでキャッチできないエラーの処理
                                                Log.d(TAG, groupJson.getName() + "の通信エラー");
                                            }
                                        } catch (IOException e) {
                                            e.printStackTrace();
                                            Log.d(TAG, groupJson.getName() + "のRequestListの取得失敗しました");
                                        }
                                    }
                                }
                            }
                        }).start();
                    } else {
                        //onFailureでキャッチできないエラー用
                        Log.d(TAG, "GroupListResponseグループ情報通信エラー");
                    }
                }

                //失敗時
                @Override
                public void onFailure(Call<GroupListResponse> call, Throwable t) {
                    t.printStackTrace();
                    Log.d(TAG, "GroupListResponseグループ情報取得失敗");
                }
            });
        } else {
            Log.d(TAG, "app.getuId()がnull");
        }

    }

    private void enableLocationSettings() {
        Intent settingsIntent = new Intent(Settings.ACTION_LOCATION_SOURCE_SETTINGS);
        settingsIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
        startActivity(settingsIntent);
    }

    private void updateAreaInformation(final Location location){
        Cosmos app = (Cosmos) getApplication();
        count = 0;
        LOC.setLatitude(location.getLatitude());
        LOC.setLongitude(location.getLongitude());
        if(app.AreaInfoGetKey().size() != 0) {
            for (int i = 0; i < app.AreaInfoGetKey().size(); i++) {
                if (LOC.hashCode() != app.AreaInfoGetKey().get(i)) {
                    count++;
                }
            }
        }
        if (count == 0) {
            //retrofitの処理
            final Retrofit retrofit = new Retrofit.Builder()
                    .baseUrl("http://nitta-lab-www.is.konan-u.ac.jp/cosmos/rest/")
                    .addConverterFactory(JacksonConverterFactory.create())
                    .build();
            //interfaceから実装を取得
            final LocationRest LocationService = retrofit.create(LocationRest.class);

            leftLat = Math.floor((location.getLatitude() + 0.1) * 10.0) / 10.0;
            leftLon = Math.floor(location.getLongitude() * 10.0) / 10.0;

            rightLat = Math.floor(location.getLatitude() * 10.0) / 10.0;
            rightLon = Math.floor((location.getLongitude() + 0.1) * 10.0) / 10.0;

            //API呼び出しのための値入力
            Call<ArrayList<Feature>> call = LocationService.LocationService(String.valueOf(leftLat),
                    String.valueOf(leftLon), String.valueOf(rightLat), String.valueOf(rightLon));

            Response<ArrayList<Feature>> areaInformationResponse;
            try{
                areaInformationResponse = call.execute();
                if (areaInformationResponse.isSuccessful()) {
                    areaInfo = new AreaInformation();
                    ArrayList<Feature> result = areaInformationResponse.body();
                    for(int i = 0; i < result.size(); i++){
                        switch (result.get(i).getCode()) {
                            case 203001:
                                Electrical.add(result.get(i));
                                areaInfo.setFeature(Electrical.get(0).getCode(),Electrical);
                                break;
                            case 203002:
                                Home.add(result.get(i));
                                areaInfo.setFeature(Home.get(0).getCode(),Home);
                                break;
                            case 203003:
                                Phone.add(result.get(i));
                                areaInfo.setFeature(Phone.get(0).getCode(),Phone);
                                break;
                            case 203004:
                                PC.add(result.get(i));
                                areaInfo.setFeature(PC.get(0).getCode(),PC);
                                break;
                            case 205001:
                                Convenience.add(result.get(i));
                                areaInfo.setFeature(Convenience.get(0).getCode(),Convenience);
                                break;
                            case 205002:
                                Supermarket.add(result.get(i));
                                areaInfo.setFeature(Supermarket.get(0).getCode(),Supermarket);
                                break;
                            default:
                                continue;
                        }
                    }

                    //app/Cosmosに情報保存
                    app = (Cosmos) getApplication();
                    areaInfo.setLocation(LOC);
                    app.setAreaInfo(areaInfo.getLocation().hashCode(),areaInfo);

                } else {
                    //onFailureでキャッチできないエラー用
                    Toast.makeText(CosmosBackgroundService.this,
                            "区画情報取得失敗", Toast.LENGTH_LONG).show();
                }
            }catch (IOException e){
                e.printStackTrace();
                Log.d(TAG, "区画情報を取得できていません。");
            }

            //サーバからデータ受け取り
//            call.enqueue(new Callback<ArrayList<Feature>>() {
//                //成功時
//                @Override
//                public void onResponse(Call<ArrayList<Feature>> call, Response<ArrayList<Feature>> response) {
//                    if (response.isSuccessful()) {
//                        ArrayList<Feature> result = response.body();
//                        for(int i = 0; i < result.size(); i++){
//                            switch (result.get(i).getCode()) {
//                                case 203001:
//                                    Electrical.add(result.get(i));
//                                    areaInfo.setFeature(Electrical.get(0).getCode(),Electrical);
//                                    break;
//                                case 203002:
//                                    Home.add(result.get(i));
//                                    areaInfo.setFeature(Home.get(0).getCode(),Home);
//                                    break;
//                                case 203003:
//                                    Phone.add(result.get(i));
//                                    areaInfo.setFeature(Phone.get(0).getCode(),Phone);
//                                    break;
//                                case 203004:
//                                    PC.add(result.get(i));
//                                    areaInfo.setFeature(PC.get(0).getCode(),PC);
//                                    break;
//                                case 205001:
//                                    Convenience.add(result.get(i));
//                                    areaInfo.setFeature(Convenience.get(0).getCode(),Convenience);
//                                    break;
//                                case 205002:
//                                    Supermarket.add(result.get(i));
//                                    areaInfo.setFeature(Supermarket.get(0).getCode(),Supermarket);
//                                    break;
//                                default:
//                                    continue;
//                            }
//                        }
//
//                        //app/Cosmosに情報保存
//                        Cosmos app = (Cosmos) getApplication();
//                        app.setAreaInfo(areaInfo.getLocation().hashCode(),areaInfo);
//
//                    } else {
//                        //onFailureでキャッチできないエラー用
//                        Toast.makeText(CosmosBackgroundService.this,
//                                "区画情報取得失敗", Toast.LENGTH_LONG).show();
//                    }
//                }
//
//                //失敗時
//                @Override
//                public void onFailure(Call<ArrayList<Feature>> call, Throwable t) {
//                    t.printStackTrace();
//                    Toast.makeText(CosmosBackgroundService.this,
//                            "区画情報の更新に失敗しました", Toast.LENGTH_SHORT).show();
//                }
//            });
        }
    }

    public List<Notification> searchNotifications(Cosmos cosmos, Location location){

        double NowLat =location.getLatitude();
        double NowLon =location.getLongitude();
        //業番:notification
        HashMap<Integer, ArrayList<Notification>> codeToNotification = new HashMap<>();
        //業番:feature
        HashMap<Integer, ArrayList<Feature>> codeToFeature = new HashMap<>();
        ArrayList<Group> groups = new ArrayList<>(cosmos.getGroups());
        //現在時刻取得
        Date nowDate = new Date();
        //codeToNotificationを作成。Featureはnull
        for(int i = 0 ; i < groups.size(); i++) {
            //requestのArrayListを回す
            for (int j = 0; j < groups.get(i).getRequestList().getRequests().size(); j++) {
                //codeToNotificationに格納するArrayList<Notification>を初期化
                ArrayList<Notification> notifications = new ArrayList<>();
                Date deadline = groups.get(i).getRequestList().getRequests().get(j).getDeadline();
                //期限内かつ未達成のrequestのみ取得
                if (( deadline == null || deadline.after(nowDate))&& groups.get(i).getRequestList().getRequests().get(j).isDone() == false) {
                    //notificationを作成
                    Notification notification = new Notification(groups.get(i).getRequestList().getRequests().get(j),groups.get(i),null);
                    //指定したkey(業番)を持っているHashMapがなければ作成する。
                    if(codeToNotification.get(groups.get(i).getRequestList().getRequests().get(j).getLocation())==null){
                        notifications.add(notification);
                        codeToNotification.put(groups.get(i).getRequestList().getRequests().get(j).getLocation(),notifications);
                    }else{
                        //keyをすでに持っている場合はArrayList<Notification>にnotification単体を追加していく
                        codeToNotification.get(groups.get(i).getRequestList().getRequests().get(j).getLocation()).add(notification);
                    }
                }
            }
        }
        //cosmosから区画情報から取得

        CosmosLocation cosmosLocation = new CosmosLocation();
        cosmosLocation.setLatitude(NowLat);
        cosmosLocation.setLongitude(NowLon);
        int areaInfoId = cosmosLocation.hashCode();
        codeToFeature=cosmos.getAreaInfo(areaInfoId).getFeature();
        //codeToFeatureの中の50m圏外Featureを削除していく。
        //HashMapを順番に実行
        for(HashMap.Entry<Integer, ArrayList<Feature>> e : codeToFeature.entrySet()) {
            //ArrayList<Feature>>を回していく
            for(int i=e.getValue().size() - 1; i >= 0;i--) {
                float[] distance = getDistance(NowLat, NowLon, e.getValue().get(i).getLocation().getLatitude(), e.getValue().get(i).getLocation().getLongitude());
                // distance[0] = [２点間の距離]
                //50m圏外のFeatureを削除
                if (distance[0] > 1000) {
                    e.getValue().remove(i);
                }
            }
            //codeToNotificationのkeyとcodeToFeatureのkeyが一致すれば
            //codeToFeatureのArray<Feature>をcodeToNotificationのArray<Feature>featuresに代入する
            if(codeToNotification.containsKey(e.getKey())==true){
                for(int j=0;j<codeToNotification.get(e.getKey()).size();j++) {
                    codeToNotification.get(e.getKey()).get(j).setFeatures(e.getValue());
                }
            }
        }

        ArrayList<Notification> result = new ArrayList<Notification>();

        for (ArrayList<Notification> list: codeToNotification.values()) {
            result.addAll(list);
        }

        return result;
    }
    public float[] getDistance(double x, double y, double x2, double y2) {
        // 結果を格納するための配列を生成
        float[] results = new float[3];
        // results[0] = [２点間の距離]
        // results[1] = [始点から見た方位角]
        // results[2] = [終点から見た方位角]

        // 距離計算
        Location.distanceBetween(x, y, x2, y2, results);

        return results;

    }

}