mes-client/UAS_MES_HYSX/PublicMethod/HttpServer.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Dynamic;
using System.Net.Sockets;
using System.Security.Cryptography;
using System.Text;
using HslCommunication;
using System.Threading;
using Newtonsoft.Json;
using UAS_MES_NEW.DataOperate;
using System.IO;

namespace UAS_MES_NEW.PublicMethod
{

    public class BindItem
    {
        [JsonProperty("bindKey")]
        public string BindKey { get; set; }

        [JsonProperty("bindValue")]
        public string BindValue { get; set; }

        [JsonProperty("keyType")]
        public string KeyType { get; set; }

        [JsonProperty("keyValue")]
        public string KeyValue { get; set; }

        [JsonProperty("hashType")]
        public string HashType { get; set; }

        [JsonProperty("hashKey")]
        public string HashKey { get; set; }
    }

    public class RootObject
    {
        [JsonProperty("productModuleType")]
        public string ProductModuleType { get; set; }

        [JsonProperty("productMainClass")]
        public string ProductMainClass { get; set; }

        [JsonProperty("productMediumClass")]
        public string ProductMediumClass { get; set; }

        [JsonProperty("productSubClass")]
        public string ProductSubClass { get; set; }

        [JsonProperty("task")]
        public string Task { get; set; }

        [JsonProperty("processType")]
        public string ProcessType { get; set; }

        [JsonProperty("userId")]
        public string UserId { get; set; }

        [JsonProperty("bindList")]
        public List<BindItem> BindList { get; set; }
    }

    class HttpServer
    {
        static DataHelper dh = new DataHelper();
        static string ComputeSha256Hash(string input)
        {
            using (SHA256 sha256 = SHA256.Create())
            {
                byte[] bytes = Encoding.UTF8.GetBytes(input);
                byte[] hashBytes = sha256.ComputeHash(bytes);

                StringBuilder builder = new StringBuilder();
                for (int i = 0; i < hashBytes.Length; i++)
                {
                    builder.Append(hashBytes[i].ToString("x2"));
                }

                return builder.ToString().ToUpper();
            }
        }

        public static void SendBoxData(string iBox)
        {
            string sn = dh.getFieldDataByCondition("packagedetail", "replace(wm_concat(pd_barcode),',','-')", "pd_outboxcode='" + iBox + "'").ToString();
            var root = new RootObject
            {
                ProductModuleType = "整机",
                ProductMainClass = "固网_CPE",
                ProductMediumClass = "CPE",
                ProductSubClass = "ZXSLC SC50L",
                Task = "2025070006",
                ProcessType = "生产过程",
                UserId = "邓帝森",
                BindList = new List<BindItem>()
            };
            root.BindList.Add(new BindItem
            {
                BindKey = "cartonSn",
                BindValue = iBox,
                KeyType = "macbox",
                KeyValue = sn,
                HashType = "SHA256",
                HashKey = ComputeSha256Hash(sn)
            });
            DataTable dt = (DataTable)dh.ExecuteSql("select pd_barcode from packagedetail pd_outboxcode='" + iBox + "'", "select");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                root.BindList.Add(new BindItem
                {
                    BindKey = "mac",
                    BindValue = dt.Rows[i]["pd_barcode"].ToString(),
                    KeyType = "EN",
                    KeyValue = "4Y12R9300001",
                    HashType = "NON-HASH",
                    HashKey = "4Y12R9300001"
                });
                root.BindList.Add(new BindItem
                {
                    BindKey = "mac",
                    BindValue = dt.Rows[i]["pd_barcode"].ToString(),
                    KeyType = "电源条码",
                    KeyValue = "1U1Y2505100013640",
                    HashType = "NON-HASH",
                    HashKey = "1U1Y2505100013640"
                });
                root.BindList.Add(new BindItem
                {
                    BindKey = "mac",
                    BindValue = dt.Rows[i]["pd_barcode"].ToString(),
                    KeyType = "JY-License",
                    KeyValue = "Qk1K4rmuowTDl+NEtSIeHx1td6Tzzm0wDrw/AMCvJ6mrXQ5wsSgoxia+T5Cj+uH4xrGUrjGrZvh/WUQN88iDrPO7kuTA0mvo/Ay+AsFJYnn00JQYQkN9ul+a+Qh0EPBqCVa4ikllHcD1Pqq4Eubs6XXNFhKOtK7F7FMotfGzzAVg7RhKVoVRVFcK6ubSVWXW+SnGx5muH+WZPaiHLjt+kxBR8tZJuBl1LQvMWP74JSWKkcFWwcWlARnCJePvRTvKTDd5e7q9rpBpAc7Z79XYQ6Fs4eXM44O6/hA88YW/BK0TZq3AaaMxH8BpJnwZt4lIyuqXispeaB2eieFBR0JwWg==",
                    HashType = "SHA256",
                    HashKey = ComputeSha256Hash(sn),
                }); ;
            }
            string json = JsonConvert.SerializeObject(root, Formatting.Indented);
            Console.WriteLine(json);
        }

        public static void GetOutBoxInfo(string iBox)
        {
            dynamic obj = new ExpandoObject();
            obj.request = "Q_wai_xiang";
            obj.packing_num = 20;
            obj.User = "mes";
            obj.po_sn = "250908001001";
            obj.password = "258456";
            obj.tool_name = "zte";
            obj.noType = 0;

            var expandoDict = obj as IDictionary<string, object>;
            DataTable dt = (DataTable)dh.ExecuteSql("select pd_barcode from packagedetail where pd_outboxcode='" + iBox + "'", "select");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string enNoKey = $"en_no{i}";
                string enNoValue = dt.Rows[i]["pd_barcode"].ToString();
                expandoDict[enNoKey] = enNoValue;
            }

            string json = JsonConvert.SerializeObject(obj, Formatting.Indented);
            Console.WriteLine(json);
        }

        public static void GetPalletInfo(string iBox)
        {
            dynamic obj = new ExpandoObject();
            obj.request = "pallet";
            obj.packing_num = 20;
            obj.User = "mes";
            obj.po_sn = "250908001001";
            obj.password = "258456";
            obj.tool_name = "zte";

            var expandoDict = obj as IDictionary<string, object>;
            DataTable dt = (DataTable)dh.ExecuteSql("select pa_outboxcode from package where  pa_mothercode='" + iBox + "'", "select");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string enNoKey = $"big_box_no{i}";
                string enNoValue = dt.Rows[i]["pa_outboxcode"].ToString();
                expandoDict[enNoKey] = enNoValue;
            }
            string json = JsonConvert.SerializeObject(obj, Formatting.Indented);
            Console.WriteLine(json);
        }

        public static void GetEN(string iSN)
        {
            dynamic obj = new ExpandoObject();
            obj.tool_name = "zte";
            obj.request = "Storage2";
            obj.User = "mes";
            obj.password = "258456";
            obj.po_sn = "";
            obj.wholeDeviceCode = "";
            obj.reg_code = "6400-6134-3346-8166";
            obj.prefix_en_no = "4N6FH4T";
            obj.prefix_big_box = "";
            obj.packing_num = "";
            obj.isn = iSN;

            string json = JsonConvert.SerializeObject(obj, Formatting.Indented);
            Console.WriteLine(json);
        }

        public static void SendData(string json)
        {
            string serverIP = "192.168.1.160";
            int port = 21610;

            try
            {
                // 创建TCP客户端并连接到服务器
                TcpClient client = new TcpClient();
                client.Connect(serverIP, port);
                // 获取网络流
                NetworkStream stream = client.GetStream();

                // 要发送的请求报文（根据实际需求修改）
                string requestMessage = "你的请求报文内容";
                byte[] requestData = Encoding.UTF8.GetBytes(requestMessage);

                // 发送请求
                stream.Write(requestData, 0, requestData.Length);
                Console.WriteLine($"已发送请求: {requestMessage}");

                // 接收响应
                byte[] buffer = new byte[1024];
                int bytesRead = stream.Read(buffer, 0, buffer.Length);
                string responseMessage = Encoding.UTF8.GetString(buffer, 0, bytesRead);

                Console.WriteLine($"收到响应: {responseMessage}");

                // 关闭流和连接
                stream.Close();
                client.Close();
            }
            catch (SocketException ex)
            {
                Console.WriteLine($"网络错误: {ex.Message}");
            }
            catch (Exception ex)
            {
                Console.WriteLine($"错误: {ex.Message}");
            }

        }
    }
}