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);

    }

}