killapp/Assets/Scripts/Managers/DataManager.cs

using System;
using System.Collections;
using System.Collections.Generic;
using System.Threading.Tasks;
using Kill.Network;
using Kill.Managers.ResponseModels;
using Kill.UI.Components;
using UnityEngine;
namespace Kill.Managers
{
    public class DataManager : MonoBehaviour
    {
        public string selectedDeviceMac="";
        public static DataManager Instance { get; private set; }
        public DeviceInfo selectedDevice;
        public List<DeviceInfo> OwnedDevices = new List<DeviceInfo>();
        public List<DeviceInfo> SharedDevices  = new List<DeviceInfo>();
        public bool isOwner;
        public bool hasWifi;
        public bool hasBluetooth;
        public FingerprintListResponseData fingerprintListData = new FingerprintListResponseData();
        public List<FingerprintUserData> fingerprintUserDatas = new List<FingerprintUserData>();
        public List<ScheduleTaskData> scheduleTaskDatas = new List<ScheduleTaskData>();
        
        private void Awake()
        {
            Instance = this;
        }
        public async Task Init()
        {
          InitUser();
          GetSelectedDeviceMac();   
        }
        public string token = "";
        public UserInfo userInfo = new UserInfo();
        public void SetToken(string token,UserInfo userInfo)
        {
            this.token = token;
            this.userInfo = userInfo;
            string userData =JsonUtility.ToJson(userInfo);
            Debug.Log(userData);
            PlayerPrefs.SetString("token", token);
            PlayerPrefs.SetString("userData", userData);
            NetworkCtrl.Instance.RemoveGlobalHeader("token");
            NetworkCtrl.Instance.AddGlobalHeader("token", token);
        }
        public void SavaSelectedDeviceMac(string mac)
        {
            selectedDeviceMac=mac;
            PlayerPrefs.SetString("selectedDeviceMac", selectedDeviceMac);
        }
        public void GetSelectedDeviceMac()
        {
            selectedDeviceMac=PlayerPrefs.GetString("selectedDeviceMac", "");
        }
        public void InitUser()
        {
            token = PlayerPrefs.GetString("token", "");
            string userData = PlayerPrefs.GetString("userData", "");
            userInfo = JsonUtility.FromJson<UserInfo>(userData);
            NetworkCtrl.Instance.RemoveGlobalHeader("token");
            NetworkCtrl.Instance.AddGlobalHeader("token",token);
            Debug.Log(token);
        }
        public void ClearInfo()
        {
            token = "";
            userInfo = new UserInfo();
            PlayerPrefs.DeleteKey("token");
            PlayerPrefs.DeleteKey("userData");
        }
        public async Task<bool> TokenLogin()
        {
            LoadingUI.Show();

            try
            {
                // 获取用户详情
                var response = await NetworkCtrl.Instance.Post<LoginResponse>("/api/v1/auth/token-login");
                LoadingUI.Hide();
                if(response.Data.code==200)
                {
                    SetToken(response.Data.data.token,response.Data.data.user);
                    return true;
                }
                else
                {
                    ClearInfo();
                    return false;
                }

            }
            catch (Exception ex)
            {
                LoadingUI.Hide();
                Debug.LogError($"TokenLogin 异常: {ex.Message}");
                return false;
            }
        }
        public DeviceConfig deviceConfig;
        #region 设备配置

        /// <summary>
        /// 获取设备配置
        /// </summary>
        public async Task GetDeviceConfig(string deviceSn)
        {
            var response = await NetworkCtrl.Instance.Get<DeviceConfigResponse>(
                "/api/v1/device/config",
                new Dictionary<string, string> { { "device_sn", deviceSn } }
            );

            DeviceConfig result = null;
            ResponseCodeHandler.HandleResponse(response,
                onSuccess: (data) =>
                {
                    result = data.data;
                    deviceConfig=result;
                },
                onError: (code, msg) =>
                {
                    Debug.LogError($"[DataManager] 获取设备配置失败: {msg}");
                }
            );
        }

        /// <summary>
        /// 修改设备配置（空值字段不会被修改）
        /// </summary>
        public async Task<bool> UpdateDeviceConfig(string deviceSn, DeviceConfig config)
        {
            config.device_sn = deviceSn;

            // 构建JSON，跳过null值字段
            string json = BuildDeviceConfigJson(config);

            var response = await NetworkCtrl.Instance.Post<NoDataResponse>("/api/v1/device/config", json);

            bool success = false;
            ResponseCodeHandler.HandleResponse(response,
                onSuccess: (data) =>
                {
                    success = true;
                },
                onError: (code, msg) =>
                {
                    Debug.LogError($"[DataManager] 修改设备配置失败: {msg}");
                }
            );

            return success;
        }

        /// <summary>
        /// 构建设备配置JSON（只包含非null字段）
        /// </summary>
        private string BuildDeviceConfigJson(DeviceConfig config)
        {
            var sb = new System.Text.StringBuilder();
            sb.Append("{");

            AppendField(sb, "device_sn", config.device_sn);
            AppendField(sb, "language", config.language);
            AppendField(sb, "is_locked", config.is_locked);
            AppendField(sb, "fov_angle", config.fov_angle);
            AppendField(sb, "detection_distance", config.detection_distance);
            AppendField(sb, "aim_distance", config.aim_distance);
            AppendField(sb, "work_mode", config.work_mode);
            AppendField(sb, "fill_light_enable", config.fill_light_enable);
            AppendField(sb, "fill_light_type", config.fill_light_type);
            AppendField(sb, "fill_light_intensity", config.fill_light_intensity);
            AppendField(sb, "laser_visible_enable", config.laser_visible_enable);
            AppendField(sb, "visual_detect_enable", config.visual_detect_enable);
            AppendField(sb, "visual_sensitivity", config.visual_sensitivity);
            AppendField(sb, "radar_enable", config.radar_enable);
            AppendField(sb, "radar_sensitivity", config.radar_sensitivity);
            AppendField(sb, "radar_safe_distance", config.radar_safe_distance);
            AppendField(sb, "rgb_enable", config.rgb_enable);
            AppendField(sb, "rgb_red", config.rgb_red);
            AppendField(sb, "rgb_green", config.rgb_green);
            AppendField(sb, "rgb_blue", config.rgb_blue);
            AppendField(sb, "rgb_effect", config.rgb_effect);
            AppendField(sb, "lcd_auto_brightness", config.lcd_auto_brightness);
            AppendField(sb, "lcd_brightness", config.lcd_brightness);
            AppendField(sb, "lcd_sleep_enable", config.lcd_sleep_enable);
            AppendField(sb, "lcd_sleep_time", config.lcd_sleep_time);
            AppendField(sb, "wifi_enable", config.wifi_enable);
            AppendField(sb, "wifi_ssid", config.wifi_ssid);
            AppendField(sb, "wifi_password", config.wifi_password);
            AppendField(sb, "video_record_enable", config.video_record_enable);
            AppendField(sb, "record_duration", config.record_duration);
            AppendField(sb, "sound_enable", config.sound_enable);
            AppendField(sb, "sound_type", config.sound_type);
            AppendField(sb, "volume", config.volume);

            // 移除末尾逗号
            if (sb[sb.Length - 1] == ',')
                sb.Length--;

            sb.Append("}");
            return sb.ToString();
        }

        private void AppendField(System.Text.StringBuilder sb, string key, object value)
        {
            if (value == null) return;

            sb.Append("\"");
            sb.Append(key);
            sb.Append("\":");

            if (value is string s)
            {
                sb.Append("\"");
                sb.Append(s);
                sb.Append("\"");
            }
            else if (value is bool b)
            {
                sb.Append(b ? "true" : "false");
            }
            else
            {
                sb.Append(value.ToString());
            }

            sb.Append(",");
        }

        #endregion

        /// <summary>
        /// 通过WiFi获取指纹列表
        /// </summary>
        public async Task GetFingerprints()
        {
            var response = await NetworkCtrl.Instance.Get<FingerprintListResponse>(
                "/api/v1/device/fingerprints",
                new Dictionary<string, string> { { "device_sn", selectedDevice.device_sn } }
            );

            ResponseCodeHandler.HandleResponse(response,
                onSuccess: (data) =>
                {
                    fingerprintUserDatas.Clear();
                    if (data.data?.list != null)
                    {
                        fingerprintUserDatas.AddRange(data.data.list);
                    }
                    Debug.Log($"[DataManager] 获取到 {fingerprintUserDatas.Count} 条指纹记录");
                },
                onError: (code, msg) =>
                {
                    Debug.LogError($"[DataManager] 获取指纹列表失败: {msg}");
                }
            );
        }

        /// <summary>
        /// 通过WiFi获取定时任务列表
        /// </summary>
        public async Task GetScheduleTasks(string deviceSn)
        {
            var response = await NetworkCtrl.Instance.Get<ScheduleTaskListDataResponse>(
                "/api/v1/device/schedule-tasks",
                new Dictionary<string, string> { { "device_sn", deviceSn } }
            );

            ResponseCodeHandler.HandleResponse(response,
                onSuccess: (data) =>
                {
                    scheduleTaskDatas.Clear();
                    Debug.Log($"[DataManager] 定时任务API返回: total={data.data?.total}, list count={data.data?.list?.Count ?? 0}");
                    if (data.data?.list != null)
                    {
                        scheduleTaskDatas.AddRange(data.data.list);
                        foreach (var d in scheduleTaskDatas)
                        {
                            Debug.Log($"[DataManager] 任务 ID={d.task_id}, enabled={d.enabled}, start={d.start_hour}:{d.start_minute:D2}, end={d.end_hour}:{d.end_minute:D2}, mode={d.mode}, repeat={d.repeat_mask}");
                        }
                    }
                    Debug.Log($"[DataManager] 获取到 {scheduleTaskDatas.Count} 条定时任务");
                },
                onError: (code, msg) =>
                {
                    Debug.LogError($"[DataManager] 获取定时任务列表失败: {msg}");
                }
            );
        }
    }

    /// <summary>
    /// 指纹用户数据（从服务器获取）
    /// </summary>
    [System.Serializable]
    public class FingerprintUserData
    {
        public string username;
        public int fingerprint_id;
        public bool has_fingerprint;
    }
}

// 响应模型
namespace Kill.Managers.ResponseModels
{
    [System.Serializable]
    public class FingerprintListResponse
    {
        public int code;
        public string message;
        public FingerprintListResponseData data;
    }

    [System.Serializable]
    public class FingerprintListResponseData
    {
        public int total;
        public int pages;
        public int limit;
        public int page;
        public List<FingerprintUserData> list;
    }

    [System.Serializable]
    public class ScheduleTaskListDataResponse
    {
        public int code;
        public string message;
        public ScheduleTaskListData data;
    }

    [System.Serializable]
    public class ScheduleTaskListData
    {
        public int total;
        public int pages;
        public int limit;
        public int page;
        public List<ScheduleTaskData> list;
    }

    [System.Serializable]
    public class ScheduleTaskData
    {
        public byte task_id;
        public bool enabled;
        public byte start_hour;
        public byte start_minute;
        public byte end_hour;
        public byte end_minute;
        public string mode;
        public byte repeat_mask;
    }
}