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;
|
using System.Net.Http;
|
|
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（主）和 MES_SUPPSCORE_DETAIL（子）表
|
/// </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 mains = new List<MesSuppSc>();
|
var details = new List<MesSuppScDetail>();
|
|
foreach (var item in data)
|
{
|
var gysmc = item["gysmc"]?.ToString();
|
var zf = item["zf"]?.ToString();
|
var xmdfStr = item["xmdf"]?.ToString();
|
|
decimal? zfDec = null;
|
if (!string.IsNullOrWhiteSpace(zf) && decimal.TryParse(zf, out var tmp))
|
zfDec = tmp;
|
|
var mainId = Guid.NewGuid();
|
mains.Add(new MesSuppSc
|
{
|
ID = mainId,
|
SuppDate = null, // 若 JSON 包含日期字段，可在此填充
|
SuppName = gysmc,
|
SuppNum = zfDec
|
});
|
|
// 解析子表 xmdf 字符串（xmdf 本身是一个 JSON 字符串）
|
if (!string.IsNullOrWhiteSpace(xmdfStr))
|
{
|
try
|
{
|
var subArr = JArray.Parse(xmdfStr);
|
foreach (var sub in subArr)
|
{
|
var xm1 = sub["xm1"]?.ToString();
|
var xm2 = sub["xm2"]?.ToString();
|
var dykhdf = sub["dykhdf"]?.ToString();
|
|
decimal? score = null;
|
if (!string.IsNullOrWhiteSpace(dykhdf) && decimal.TryParse(dykhdf, out var s))
|
score = s;
|
|
details.Add(new MesSuppScDetail
|
{
|
ID = Guid.NewGuid(),
|
PID = mainId,
|
XM1 = xm1,
|
XM2 = xm2,
|
DYKHDF = score
|
});
|
}
|
}
|
catch (Exception ex)
|
{
|
// 忽略单条解析错误，但记录异常信息
|
Console.WriteLine($"解析 xmdf 失败（供应商 {gysmc}）: {ex.Message}");
|
}
|
}
|
}
|
|
// 写入数据库：事务内先删除旧数据再插入新数据
|
var result = UseTransaction(db =>
|
{
|
// 先清子表，再清主表
|
db.Deleteable<MesSuppScDetail>().ExecuteCommand();
|
db.Deleteable<MesSuppSc>().ExecuteCommand();
|
|
var mainInserted = 0;
|
if (mains.Count > 0)
|
mainInserted = db.Insertable(mains).ExecuteCommand();
|
|
var detailInserted = 0;
|
if (details.Count > 0)
|
detailInserted = db.Insertable(details).ExecuteCommand();
|
|
return (mainInserted + detailInserted) > 0 ? 1 : 0;
|
}) > 0;
|
|
return result;
|
}
|
|
}
|
