using Kingdee.CDP.WebApi.SDK;
using MES.Service.Models;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Filters;
using NewPdaSqlServer.DB;
using NewPdaSqlServer.Dto;
using NewPdaSqlServer.entity;
using NewPdaSqlServer.util;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using SqlSugar;
using System.Text;

namespace MES.Service.service.Warehouse;


public class MesSuppScManager : Repository<MesSuppSc>
{
    private const string SourceUrl = "https://qixizhaopin.modaniot.com:8443/wetchat/ToGSMesServlet?password=gsmes";

    /// <summary>
    /// 从指定网址读取 JSON 数据并保存到 MES_SUPPSCORE 表
    /// </summary>
    public bool FetchAndSaveFromUrl()
    {
        string json;
        try
        {
            using var http = new HttpClient();
            // 可根据需要设置超时
            http.Timeout = TimeSpan.FromSeconds(30);
            json = http.GetStringAsync(SourceUrl).Result;
        }
        catch (Exception ex)
        {
            throw new Exception($"获取远程数据失败: {ex.Message}", ex);
        }

        if (string.IsNullOrWhiteSpace(json))
            throw new Exception("远程返回内容为空");

        JToken root;
        try
        {
            root = JToken.Parse(json);
        }
        catch (Exception ex)
        {
            throw new Exception($"解析 JSON 失败: {ex.Message}");
        }

        var data = root["data"] as JArray;
        if (data == null || data.Count == 0)
            throw new Exception("JSON 中未包含 data 或 data 为空");

        var list = new List<MesSuppSc>();
        foreach (var item in data)
        {
            var rq = item["rq"]?.ToString();
            var gysmc = item["gysmc"]?.ToString();
            var zf = item["zf"]?.ToString();

            decimal? zfDec = null;
            if (!string.IsNullOrWhiteSpace(zf) && decimal.TryParse(zf, out var tmp))
                zfDec = tmp;

            list.Add(new MesSuppSc
            {
                ID = Guid.NewGuid(),
                SuppDate = rq,
                SuppName = gysmc,
                SuppNum = zfDec
            });
        }

        // 写入数据库：先清空表再插入（按原逻辑）
        var result = UseTransaction(db =>
        {
            // 注意：这里使用传入的 db（SqlSugarScope）执行原子操作
            db.Deleteable<MesSuppSc>().ExecuteCommand();
            var inserted = db.Insertable(list).ExecuteCommand();
            return inserted > 0 ? 1 : 0;
        }) > 0;

        return result;
    }
}