package com.jsbogang.womp.health;

import android.content.Context;
import android.content.Intent;
import android.util.Log;

import androidx.localbroadcastmanager.content.LocalBroadcastManager;

import com.jsbogang.womp.ble.AlarmPrefs;
import com.jsbogang.womp.ble.DevicePrefs;
import com.jsbogang.womp.workbench.UploadPolicy;
import com.jsbogang.womp.workbench.WompApi;
import com.jsbogang.womp.workbench.WompConfig;
import com.jsbogang.womp.workbench.WompSession;

import org.json.JSONObject;

import java.util.List;

public final class HealthUploader {
    private static final HealthUploader INSTANCE = new HealthUploader();
    private static final String TAG = "HealthUploader";
    private Context app;
    private long lastAbnormalAt;
    private volatile boolean flushing;

    private HealthUploader() {}

    public static HealthUploader get() {
        return INSTANCE;
    }

    public void attach(Context context) {
        app = context.getApplicationContext();
    }

    public void flush() {
        if (app == null || flushing || !UploadPolicy.shouldUpload(app)) {
            return;
        }
        List<HealthSample> pending = AppDatabase.dao().pendingUpload();
        if (pending == null || pending.isEmpty()) {
            return;
        }
        flushing = true;
        uploadNext(pending, 0, pending.size());
    }

    private void uploadNext(List<HealthSample> list, int index, int total) {
        if (index >= list.size()) {
            flushing = false;
            if (WompConfig.DEBUG_UPLOAD_TOAST && total > 0) {
                UploadPolicy.debugToast(app, "健康数据已同步 " + total + " 条");
            }
            return;
        }
        HealthSample s = list.get(index);
        postOne(s, "周期".equals(s.dataType) ? "周期" : s.dataType, () -> {
            AppDatabase.dao().markUploaded(s.timestamp, s.deviceMac, s.dataType);
            if ("异常".equals(s.dataType)) {
                lastAbnormalAt = System.currentTimeMillis();
            } else if (AlarmPrefs.isAbnormal(app, s.heartRate, s.bpHigh, s.bpLow, s.spo2)) {
                long now = System.currentTimeMillis();
                if (now - lastAbnormalAt >= WompConfig.ABNORMAL_INTERVAL_MS) {
                    lastAbnormalAt = now;
                    postOne(s, "异常", () -> uploadNext(list, index + 1, total));
                    return;
                }
            }
            uploadNext(list, index + 1, total);
        });
    }

    private void postOne(HealthSample s, String dataType, Runnable ok) {
        try {
            JSONObject body = new JSONObject();
            body.put("sorterId", WompSession.getSorterId(app));
            body.put("uploadTime", s.timestamp);
            if (s.heartRate > 0) {
                body.put("heartRate", s.heartRate);
            }
            long dayStart = HealthSyncer.startOfDay(new java.util.Date(s.timestamp));
            body.put("stepCount", HealthSyncer.daySteps(app, s.deviceMac, dayStart, dayStart + 86400000L));
            if (s.bpHigh > 0) {
                body.put("bloodPressureHigh", s.bpHigh);
            }
            if (s.bpLow > 0) {
                body.put("bloodPressureLow", s.bpLow);
            }
            if (s.spo2 > 0) {
                body.put("bloodOxygen", s.spo2);
            }
            if (s.temperature > 0) {
                body.put("temperature", s.temperature);
            }
            body.put("dataType", dataType);
            WompApi.post("/app/push/sorter/health", body, (success, resp) -> {
                if (success) {
                    if (WompConfig.DEBUG_UPLOAD_TOAST && "异常".equals(dataType)) {
                        UploadPolicy.debugToast(app, "异常健康已同步 心率" + s.heartRate
                                + " 血压" + s.bpHigh + "/" + s.bpLow
                                + " 血氧" + (int) s.spo2);
                    }
                    ok.run();
                } else {
                    Log.w(TAG, "upload fail " + resp);
                    flushing = false;
                }
            });
        } catch (Exception e) {
            flushing = false;
        }
    }

    public int latestHeart() {
        if (app == null || !DevicePrefs.isBound(app)) {
            return 0;
        }
        long start = HealthSyncer.startOfDay(new java.util.Date());
        HealthSample s = AppDatabase.dao().latestHeart(DevicePrefs.getMac(app), start, start + 86400000L);
        return s == null ? 0 : s.heartRate;
    }

    public int todaySteps() {
        if (app == null || !DevicePrefs.isBound(app)) {
            return 0;
        }
        long start = HealthSyncer.startOfDay(new java.util.Date());
        return HealthSyncer.daySteps(app, DevicePrefs.getMac(app), start, start + 86400000L);
    }

    /**
     * 模拟手表上报一条异常测量，写入本地库并尝试上报服务端。
     * @param kind hr / bp / spo2
     */
    public void simulateAbnormal(String kind) {
        if (app == null || AppDatabase.get() == null) {
            return;
        }
        String mac = DevicePrefs.isBound(app) ? DevicePrefs.getMac(app) : "SIMULATOR";
        HealthSample s = new HealthSample();
        s.timestamp = System.currentTimeMillis();
        s.deviceMac = mac;
        s.dataType = "异常";
        s.uploaded = 0;
        s.stepValue = 0;
        s.calories = 1;
        s.wear = 1;
        if ("bp".equals(kind)) {
            s.heartRate = 88;
            s.bpHigh = 178;
            s.bpLow = 112;
            s.spo2 = 97;
        } else if ("spo2".equals(kind)) {
            s.heartRate = 76;
            s.bpHigh = 118;
            s.bpLow = 76;
            s.spo2 = 82;
        } else {
            s.heartRate = 168;
            s.bpHigh = 122;
            s.bpLow = 78;
            s.spo2 = 96;
        }
        AppDatabase.dao().upsertSample(s);
        Intent ui = new Intent(HealthSyncer.ACTION_HEALTH);
        ui.putExtra(HealthSyncer.EXTRA_MSG, "已模拟" + kindLabel(kind) + "异常");
        LocalBroadcastManager.getInstance(app).sendBroadcast(ui);
        if (!UploadPolicy.shouldUpload(app)) {
            UploadPolicy.debugToast(app, "已模拟入库，当前未在工作时段，暂不同步");
            return;
        }
        postOne(s, "异常", () -> {
            AppDatabase.dao().markUploaded(s.timestamp, s.deviceMac, s.dataType);
            UploadPolicy.debugToast(app, "已模拟" + kindLabel(kind) + "异常");
        });
    }

    private static String kindLabel(String kind) {
        if ("bp".equals(kind)) {
            return "血压";
        }
        if ("spo2".equals(kind)) {
            return "血氧";
        }
        return "心率";
    }
}