using MES.Service.Models;
|
using Microsoft.IdentityModel.Tokens;
|
using MySqlConnector;
|
using NewPdaSqlServer.Controllers;
|
using NewPdaSqlServer.DB;
|
using NewPdaSqlServer.Dto.service;
|
using NewPdaSqlServer.entity;
|
using NewPdaSqlServer.service.@base;
|
using NewPdaSqlServer.util;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using System.Collections;
|
using System.Data;
|
using System.Net;
|
using System.Net.Http.Headers;
|
using System.Security.Cryptography;
|
using System.Text;
|
using static Azure.Core.HttpHeader;
|
using static Microsoft.EntityFrameworkCore.DbLoggerCategory;
|
using static NewPdaSqlServer.Controllers.Warehouse.MesXkyController;
|
|
namespace NewPdaSqlServer.service.QC;
|
|
public class MesXkyService : RepositoryNoEntity
|
{
|
public dynamic XKY_GET_DHD(XKYGetDhdRequest entity)
|
{
|
try
|
{
|
string ErrorMsg = "";
|
ApiCommonParam Apiparam = ApiCommonParam.NewApiCommon();
|
|
//string data_inserted = "{\r\n \"startDate\": 1746759300000,\r\n \"endDate\": 1746762300000,\r\n \"erpCode\": \"GXF001\"\r\n}";
|
string sendJson = JsonConvert.SerializeObject(entity);
|
ArrayList SQLStringList = new ArrayList();
|
// var client = new HttpClient();
|
var url = "https://openapi.xiekeyun.com/delivery/getNoList.json";
|
HttpClient httpClient = new HttpClient();
|
httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
|
|
string json = "{\"commonParam\":" + JsonConvert.SerializeObject(Apiparam) + ",\"body\":" + sendJson + "}";
|
byte[] postData = Encoding.UTF8.GetBytes(json);
|
|
// 创建请求对象
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create("https://openapi.xiekeyun.com/delivery/getNoList.json");
|
request.Method = "POST";
|
request.ContentType = "application/json";
|
request.ContentLength = postData.Length;
|
|
// 发送请求数据
|
using (Stream stream = request.GetRequestStream())
|
{
|
stream.Write(postData, 0, postData.Length);
|
}
|
dynamic responseJson;
|
// 发送请求并获取响应
|
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
|
using (Stream stream = response.GetResponseStream())
|
using (StreamReader reader = new StreamReader(stream))
|
{
|
string result2 = reader.ReadToEnd();
|
|
responseJson = JsonConvert.DeserializeObject(result2);
|
}
|
|
if (responseJson.result != 1)
|
throw new ApplicationException(responseJson.errorMsg);
|
|
var result = 0;
|
// 新增数据存储逻辑
|
List<DeliveryNotice> noticeList = JsonConvert.DeserializeObject<List<DeliveryNotice>>(responseJson.dataList.ToString());
|
noticeList.ForEach(n => n.Id = Guid.NewGuid()); // 新增GUID赋值
|
Db.Ado.UseTran(() =>
|
{
|
result = Db.Insertable(noticeList).ExecuteCommand();
|
}, ex =>
|
{
|
throw new Exception($"数据库插入失败：{ex.Message}\n{ex.InnerException?.Message}");
|
});
|
|
return responseJson;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
|
}
|
|
|
public dynamic GetXkyDHD(XKYGetDhdRequest entity)
|
{
|
|
return XKY_GET_DHD(entity);
|
|
}
|
|
}
|
