HttpServer.cs 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data;
  4. using System.Dynamic;
  5. using System.IO;
  6. using System.Net;
  7. using System.Net.Sockets;
  8. using System.Security.Cryptography;
  9. using System.Text;
  10. using System.Text.RegularExpressions;
  11. using System.Threading;
  12. using Newtonsoft.Json;
  13. using Newtonsoft.Json.Linq;
  14. using UAS_MES_NEW.DataOperate;
  15. using UAS_MES_NEW.Entity;
  16. namespace UAS_MES_NEW.PublicMethod
  17. {
  18. public class BindItem
  19. {
  20. [JsonProperty("bindKey")]
  21. public string BindKey { get; set; }
  22. [JsonProperty("bindValue")]
  23. public string BindValue { get; set; }
  24. [JsonProperty("keyType")]
  25. public string KeyType { get; set; }
  26. [JsonProperty("keyValue")]
  27. public string KeyValue { get; set; }
  28. [JsonProperty("hashType")]
  29. public string HashType { get; set; }
  30. [JsonProperty("hashKey")]
  31. public string HashKey { get; set; }
  32. }
  33. public class RootObject
  34. {
  35. [JsonProperty("productModuleType")]
  36. public string ProductModuleType { get; set; }
  37. [JsonProperty("productMainClass")]
  38. public string ProductMainClass { get; set; }
  39. [JsonProperty("productMediumClass")]
  40. public string ProductMediumClass { get; set; }
  41. [JsonProperty("productSubClass")]
  42. public string ProductSubClass { get; set; }
  43. [JsonProperty("task")]
  44. public string Task { get; set; }
  45. [JsonProperty("processType")]
  46. public string ProcessType { get; set; }
  47. [JsonProperty("userId")]
  48. public string UserId { get; set; }
  49. [JsonProperty("bindList")]
  50. public List<BindItem> BindList { get; set; }
  51. }
  52. public class DeviceInfo
  53. {
  54. [JsonProperty("tool_name")]
  55. public string ToolName { get; set; }
  56. [JsonProperty("response")]
  57. public string Response { get; set; }
  58. [JsonProperty("status")]
  59. public int Status { get; set; }
  60. [JsonProperty("product_name")]
  61. public string ProductName { get; set; }
  62. [JsonProperty("product_mode")]
  63. public string ProductMode { get; set; }
  64. [JsonProperty("material_code")]
  65. public string MaterialCode { get; set; }
  66. [JsonProperty("batch_no")]
  67. public string BatchNo { get; set; }
  68. [JsonProperty("production_date")]
  69. public string ProductionDate { get; set; }
  70. [JsonProperty("big_box_no")]
  71. public string BigBoxNo { get; set; }
  72. [JsonProperty("box_no")]
  73. public string BoxNo { get; set; }
  74. [JsonProperty("reserve10")]
  75. public string Reserve10 { get; set; }
  76. [JsonProperty("packing_num")]
  77. public int PackingNum { get; set; }
  78. [JsonProperty("soft_version")]
  79. public string SoftVersion { get; set; }
  80. [JsonProperty("hd_version")]
  81. public string HdVersion { get; set; }
  82. [JsonProperty("voltage")]
  83. public string Voltage { get; set; }
  84. [JsonProperty("power")]
  85. public string Power { get; set; }
  86. [JsonProperty("order_no")]
  87. public string OrderNo { get; set; }
  88. // 使用字典或列表来存储序列化的数组数据
  89. public List<string> DSN { get; set; } = new List<string>();
  90. public List<string> MacStart { get; set; } = new List<string>();
  91. public List<string> MacEnd { get; set; } = new List<string>();
  92. public List<string> DeviceId { get; set; } = new List<string>();
  93. public List<string> DevEnNo { get; set; } = new List<string>();
  94. public List<string> Reserve3 { get; set; } = new List<string>();
  95. public List<string> Reserve4 { get; set; } = new List<string>();
  96. }
  97. public class DeviceInfoConverter : JsonConverter<DeviceInfo>
  98. {
  99. public override DeviceInfo ReadJson(JsonReader reader, System.Type objectType, DeviceInfo existingValue, bool hasExistingValue, JsonSerializer serializer)
  100. {
  101. JObject jsonObject = JObject.Load(reader);
  102. DeviceInfo deviceInfo = new DeviceInfo();
  103. // 解析基本字段
  104. serializer.Populate(jsonObject.CreateReader(), deviceInfo);
  105. // 解析数组字段
  106. ParseArrayFields(jsonObject, deviceInfo);
  107. return deviceInfo;
  108. }
  109. public override void WriteJson(JsonWriter writer, DeviceInfo value, JsonSerializer serializer)
  110. {
  111. throw new NotImplementedException();
  112. }
  113. private void ParseArrayFields(JObject jsonObject, DeviceInfo deviceInfo)
  114. {
  115. int index = 0;
  116. // 解析 d_sn 数组
  117. while (true)
  118. {
  119. string key = $"d_sn{index}";
  120. if (jsonObject.TryGetValue(key, out JToken value))
  121. {
  122. deviceInfo.DSN.Add(value.ToString());
  123. index++;
  124. }
  125. else
  126. {
  127. break;
  128. }
  129. }
  130. // 解析 mac_start 数组
  131. index = 0;
  132. while (true)
  133. {
  134. string key = $"mac_start{index}";
  135. if (jsonObject.TryGetValue(key, out JToken value))
  136. {
  137. deviceInfo.MacStart.Add(value.ToString());
  138. index++;
  139. }
  140. else
  141. {
  142. break;
  143. }
  144. }
  145. // 解析 mac_end 数组
  146. index = 0;
  147. while (true)
  148. {
  149. string key = $"mac_end{index}";
  150. if (jsonObject.TryGetValue(key, out JToken value))
  151. {
  152. deviceInfo.MacEnd.Add(value.ToString());
  153. index++;
  154. }
  155. else
  156. {
  157. break;
  158. }
  159. }
  160. // 解析 dev_en_no 数组
  161. index = 0;
  162. while (true)
  163. {
  164. string key = $"dev_en_no{index}";
  165. if (jsonObject.TryGetValue(key, out JToken value))
  166. {
  167. deviceInfo.DevEnNo.Add(value.ToString());
  168. index++;
  169. }
  170. else
  171. {
  172. break;
  173. }
  174. }
  175. // 解析 reserve3 数组
  176. index = 0;
  177. while (true)
  178. {
  179. string key = $"reserve3_{index}";
  180. if (jsonObject.TryGetValue(key, out JToken value))
  181. {
  182. deviceInfo.Reserve3.Add(value.ToString());
  183. index++;
  184. }
  185. else
  186. {
  187. break;
  188. }
  189. }
  190. // 解析 reserve4 数组
  191. index = 0;
  192. while (true)
  193. {
  194. string key = $"reserve4_{index}";
  195. if (jsonObject.TryGetValue(key, out JToken value))
  196. {
  197. deviceInfo.Reserve4.Add(value.ToString());
  198. index++;
  199. }
  200. else
  201. {
  202. break;
  203. }
  204. }
  205. // 解析 DeviceId 数组
  206. index = 0;
  207. while (true)
  208. {
  209. string key = $"DeviceId{index}";
  210. if (jsonObject.TryGetValue(key, out JToken value))
  211. {
  212. deviceInfo.DeviceId.Add(value.ToString());
  213. index++;
  214. }
  215. else
  216. {
  217. break;
  218. }
  219. }
  220. }
  221. }
  222. public class HttpServer
  223. {
  224. static DataHelper dh = new DataHelper();
  225. public static int SN_SERVICE_PORT = 21610;
  226. public static int MAX_BUF_SIZE = 8192;
  227. static string ComputeSha256Hash(string input)
  228. {
  229. using (SHA256 sha256 = SHA256.Create())
  230. {
  231. byte[] bytes = Encoding.UTF8.GetBytes(input);
  232. byte[] hashBytes = sha256.ComputeHash(bytes);
  233. StringBuilder builder = new StringBuilder();
  234. for (int i = 0; i < hashBytes.Length; i++)
  235. {
  236. builder.Append(hashBytes[i].ToString("x2"));
  237. }
  238. return builder.ToString().ToUpper();
  239. }
  240. }
  241. //获取SN的EN号,彩盒标机身标一个工站一起打印,需要SN单个获取
  242. public static void GetEN(string iSN)
  243. {
  244. DataTable dt = (DataTable)dh.ExecuteSql("select ma_custpo,ms_makecode,pr_prefix,PREFIX_EN_NO,PREFIX_BIG_BOX,pr_prebigxbox,pr_regcode from makeserial left join product on ms_prodcode=pr_code left join make on ma_code=ms_makecode left join ZTE_ORDER on ma_custpo=po_sn where ms_sncode ='" + iSN + "' or ms_firstsn='" + iSN + "' order by ms_id desc", "select");
  245. string prefix = "";
  246. string regcode = "";
  247. string makecode = "";
  248. string prebigxbox = "";
  249. string po = "";
  250. string ms_id = "";
  251. if (dt.Rows.Count > 0)
  252. {
  253. prefix = dt.Rows[0]["PREFIX_EN_NO"].ToString();
  254. regcode = dt.Rows[0]["pr_regcode"].ToString();
  255. makecode = dt.Rows[0]["ms_makecode"].ToString();
  256. prebigxbox = dt.Rows[0]["PREFIX_BIG_BOX"].ToString();
  257. po = dt.Rows[0]["ma_custpo"].ToString();
  258. ms_id = dt.Rows[0]["ms_id"].ToString();
  259. }
  260. dynamic obj = new ExpandoObject();
  261. obj.tool_name = "zte";
  262. obj.request = "Storage2";
  263. obj.User = "mes";
  264. obj.password = "258456";
  265. obj.po_sn = po;
  266. obj.wholeDeviceCode = iSN;
  267. obj.reg_code = regcode;
  268. obj.prefix_en_no = prefix;
  269. obj.prefix_big_box = prebigxbox;
  270. obj.packing_num = 6;
  271. obj.isn = iSN;
  272. string json = JsonConvert.SerializeObject(obj, Formatting.Indented);
  273. string returnstr = ToServerReq(json);
  274. dh.ExecuteSql("insert into EISDATA(ED_ID, ED_DATA, ED_INDATE, ED_TYPE)values(EISDATA_seq.nextval,'" + json + "',sysdate,'GETEN')", "insert");
  275. JObject deviceObj = JObject.Parse(returnstr);
  276. string WholeDeviceCode = deviceObj["WholeDeviceCode"].ToString();
  277. string SN = deviceObj["SN"].ToString();
  278. string dev_en_no = deviceObj["dev_en_no"].ToString();
  279. string mac = deviceObj["mac"].ToString();
  280. string mac_start = deviceObj["mac_start"].ToString();
  281. string mac_end = deviceObj["mac_end"].ToString();
  282. string reg_code = deviceObj["reg_code"].ToString();
  283. string reserve3 = deviceObj["reserve3"].ToString();
  284. string status = deviceObj["status"].ToString();
  285. string device_type = deviceObj["device_type"].ToString();
  286. string en_no = deviceObj["en_no"].ToString();
  287. if (dh.CheckExist("ZTEDATA", "zd_sn='" + iSN + "' and zd_makecode='" + makecode + "' and zd_type='彩盒机身标'"))
  288. {
  289. dh.ExecuteSql("delete from ZTEDATA where zd_sn='" + iSN + "' and zd_makecode='" + makecode + "' and zd_type='彩盒机身标'", "delete");
  290. }
  291. dh.ExecuteSql("update makeserial set ms_sncode='" + dev_en_no + "' where ms_id='" + ms_id + "'", "update");
  292. dh.ExecuteSql("insert into ZTEDATA(ZD_ID,ZD_D_SN,zd_WholeDeviceCode,ZD_DEV_EN_NO,ZD_SN, ZD_MAKECODE, ZD_TYPE, ZD_VALUE,zd_mac,ZD_MAC_START, ZD_MAC_END,ZD_RESERVE3,zd_enno,zd_devicetype,zd_regcode)" +
  293. "values(ZTEDATA_seq.nextval,'" + SN + "','" + WholeDeviceCode + "','" + dev_en_no + "','" + iSN + "','" + makecode + "','彩盒机身标','','" + mac + "','" + mac_start + "','" + mac_end + "','" + reserve3 + "','" + en_no + "','" + device_type + "','" + reg_code + "')", "insert");
  294. }
  295. private string HandleWebException(WebException ex)
  296. {
  297. if (ex.Response != null)
  298. {
  299. using (HttpWebResponse response = (HttpWebResponse)ex.Response)
  300. using (Stream stream = response.GetResponseStream())
  301. using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
  302. {
  303. string errorResponse = reader.ReadToEnd();
  304. Console.WriteLine($"HTTP错误状态码: {(int)response.StatusCode} {response.StatusCode}");
  305. Console.WriteLine($"错误响应: {errorResponse}");
  306. return errorResponse;
  307. }
  308. }
  309. else
  310. {
  311. string errorMsg = $"网络错误: {ex.Message}";
  312. Console.WriteLine(errorMsg);
  313. return errorMsg;
  314. }
  315. }
  316. //发送外箱号数据,打印前获取
  317. public static void SendBoxData(string iBox)
  318. {
  319. string sn = dh.getFieldDataByCondition("packagedetail", "replace(wm_concat(pd_barcode),',','-')", "pd_outboxcode='" + iBox + "'").ToString();
  320. DataTable dt = (DataTable)dh.ExecuteSql("select pr_code,pr_custmachinetype,ms_makecode from makeserial left join product on ms_prodcode=pr_code where ms_outboxcode ='" + iBox + "' order by ms_id desc", "select");
  321. string pr_custmachinetype = "";
  322. string makecode = "";
  323. string pr_code = "";
  324. if (dt.Rows.Count > 0)
  325. {
  326. pr_custmachinetype = dt.Rows[0]["pr_custmachinetype"].ToString();
  327. makecode = dt.Rows[0]["ms_makecode"].ToString();
  328. pr_code = dt.Rows[0]["pr_code"].ToString();
  329. }
  330. var root = new RootObject
  331. {
  332. ProductModuleType = "整机",
  333. ProductMainClass = "固网_CPE",
  334. ProductMediumClass = "CPE",
  335. ProductSubClass = pr_custmachinetype,
  336. Task = makecode,
  337. ProcessType = "生产过程",
  338. UserId = User.UserName,
  339. BindList = new List<BindItem>()
  340. };
  341. root.BindList.Add(new BindItem
  342. {
  343. BindKey = "cartonSn",
  344. BindValue = iBox,
  345. KeyType = "macbox",
  346. KeyValue = sn,
  347. HashType = "SHA256",
  348. HashKey = ComputeSha256Hash(sn)
  349. });
  350. dt = (DataTable)dh.ExecuteSql("select pd_barcode from packagedetail where pd_outboxcode='" + iBox + "'", "select");
  351. DataTable dt1 = (DataTable)dh.ExecuteSql("select pid_sql,pid_item,pid_value,pid_valuetype from productitem left join productitemdetail on pid_piid=pi_id where pi_prodcode='" + pr_code + "'", "select");
  352. for (int i = 0; i < dt.Rows.Count; i++)
  353. {
  354. for (int j = 0; j < dt1.Rows.Count; j++)
  355. {
  356. if (dt1.Rows[j]["pid_valuetype"].ToString() == "SHA256")
  357. {
  358. root.BindList.Add(new BindItem
  359. {
  360. BindKey = "mac",
  361. BindValue = dt.Rows[i]["pd_barcode"].ToString(),
  362. KeyType = dt1.Rows[j]["pid_item"].ToString(),
  363. KeyValue = dt1.Rows[j]["pid_item"].ToString(),
  364. HashType = "SHA256",
  365. HashKey = ComputeSha256Hash(sn),
  366. }); ;
  367. }
  368. else
  369. {
  370. string sql = dt1.Rows[j]["pid_sql"].ToString();
  371. string value = "";
  372. if (sql != "")
  373. {
  374. Regex ConnoteA = new Regex("{\\w+}");
  375. foreach (Match mch in ConnoteA.Matches(sql))
  376. {
  377. string x = mch.Value.Trim();
  378. sql = sql.Replace(x, "'" + dt.Rows[i]["pd_barcode"].ToString() + "'");
  379. }
  380. DataTable Param = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
  381. if (Param.Rows.Count > 0)
  382. {
  383. value = Param.Rows[0][0].ToString();
  384. }
  385. }
  386. else
  387. {
  388. value = dt1.Rows[j]["pid_value"].ToString();
  389. }
  390. root.BindList.Add(new BindItem
  391. {
  392. BindKey = "mac",
  393. BindValue = dt.Rows[i]["pd_barcode"].ToString(),
  394. KeyType = dt1.Rows[j]["pid_item"].ToString(),
  395. KeyValue = value,
  396. HashType = "NON-HASH",
  397. HashKey = dt1.Rows[j]["pid_item"].ToString(),
  398. });
  399. }
  400. }
  401. }
  402. string json = JsonConvert.SerializeObject(root, Formatting.Indented);
  403. string url = "https://172.30.30.10:29001/api/mds-web-outservice/v1/api/rest/mds/saveFmKeyHashcodeInfoBatch";
  404. try
  405. {
  406. // 忽略SSL证书验证
  407. ServicePointManager.ServerCertificateValidationCallback =
  408. (sender, certificate, chain, sslPolicyErrors) => true;
  409. ServicePointManager.Expect100Continue = false;
  410. using (WebClient client = new WebClient())
  411. {
  412. // 设置请求头
  413. client.Headers.Add("appcode", "91678314583d4c2bbf185bc5573ac73d");
  414. client.Headers.Add("Content-Type", "application/json; charset=utf-8");
  415. client.Encoding = Encoding.UTF8;
  416. // 发送POST请求
  417. string response = client.UploadString(url, "POST", json);
  418. Console.WriteLine($"请求成功!");
  419. Console.WriteLine($"响应内容: {response}");
  420. }
  421. }
  422. catch (Exception ex)
  423. {
  424. Console.WriteLine($"发生错误: {ex.Message}");
  425. throw;
  426. }
  427. }
  428. //获取外箱号信息
  429. public static void GetOutBoxInfo(string iBox)
  430. {
  431. dynamic obj = new ExpandoObject();
  432. var expandoDict = obj as IDictionary<string, object>;
  433. DataTable dt = (DataTable)dh.ExecuteSql("select ma_custpo,pd_barcode,pd_makecode,ZD_DEV_EN_NO from packagedetail left join ZTEDATA on zd_makecode=pd_makecode and pd_barcode=zd_sn left join make on ma_code=pd_makecode where pd_outboxcode='" + iBox + "'", "select");
  434. string makecode = "";
  435. string po = "";
  436. for (int i = 0; i < dt.Rows.Count; i++)
  437. {
  438. string enNoKey = $"en_no{i}";
  439. string enNoValue = dt.Rows[i]["ZD_DEV_EN_NO"].ToString();
  440. expandoDict[enNoKey] = enNoValue;
  441. makecode = dt.Rows[i]["pd_makecode"].ToString();
  442. po = dt.Rows[i]["ma_custpo"].ToString();
  443. }
  444. obj.request = "Q_wai_xiang";
  445. obj.packing_num = dt.Rows.Count;
  446. obj.User = "mes";
  447. obj.po_sn = po;
  448. obj.password = "258456";
  449. obj.tool_name = "zte";
  450. obj.noType = 0;
  451. string json = JsonConvert.SerializeObject(obj, Formatting.Indented);
  452. string returnstr = ToServerReq(json);
  453. dh.ExecuteSql("insert into EISDATA(ED_ID, ED_DATA, ED_INDATE, ED_TYPE)values(EISDATA_seq.nextval,'" + json + "',sysdate,'GetOutBoxInfo')", "insert");
  454. var settings = new JsonSerializerSettings
  455. {
  456. Converters = new List<JsonConverter> { new DeviceInfoConverter() }
  457. };
  458. DeviceInfo deviceInfo = JsonConvert.DeserializeObject<DeviceInfo>(returnstr, settings);
  459. for (int i = 0; i < deviceInfo.DSN.Count; i++)
  460. {
  461. Console.WriteLine($"设备 {i}:");
  462. Console.WriteLine($" 序列号: {deviceInfo.DSN[i]}");
  463. Console.WriteLine($" MAC起始: {deviceInfo.MacStart[i]}");
  464. Console.WriteLine($" MAC结束: {deviceInfo.MacEnd[i]}");
  465. Console.WriteLine($" 设备编码: {deviceInfo.DevEnNo[i]}");
  466. Console.WriteLine($" 预留3: {deviceInfo.Reserve3[i]}");
  467. }
  468. //将返回的信息存入数据库
  469. for (int i = 0; i < deviceInfo.DSN.Count; i++)
  470. {
  471. if (dh.CheckExist("ZTEDATA", "zd_sn='" + deviceInfo.DSN[i] + "' and zd_makecode='" + makecode + "' and zd_type='BOX'"))
  472. {
  473. dh.ExecuteSql("delete from ZTEDATA where zd_sn='" + deviceInfo.DSN[i] + "' and zd_makecode='" + makecode + "' and zd_type='BOX'", "delete");
  474. }
  475. dh.ExecuteSql("insert into ZTEDATA(ZD_ID,ZD_SN, ZD_MAKECODE, ZD_TYPE, ZD_VALUE,ZD_product_mode, ZD_PRODUCTNAME, ZD_MATERIAL_CODE, ZD_BATCH_NO, ZD_SOFT_VERSION, ZD_HD_VERSION, " +
  476. "ZD_VOLTAGE, ZD_POWER, ZD_ORDER_NO, ZD_BIG_BOX_NO, ZD_D_SN, ZD_DEV_EN_NO, ZD_RESERVE3, ZD_DEVICEID, ZD_MAC_START, ZD_MAC_END,zd_production_date, ZD_INDATE)" +
  477. "values(ZTEDATA_seq.nextval,'" + deviceInfo.DSN[i] + "','" + makecode + "','BOX','" + deviceInfo.DSN[i] + "','" + deviceInfo.ProductMode + "','" + deviceInfo.ProductName + "','" + deviceInfo.MaterialCode + "','" + deviceInfo.BatchNo + "','" + deviceInfo.SoftVersion + "','" + deviceInfo.HdVersion + "'," +
  478. "'" + deviceInfo.Voltage + "','" + deviceInfo.Power + "','" + deviceInfo.OrderNo + "','" + deviceInfo.BigBoxNo + "','" + deviceInfo.DSN[i] + "'," +
  479. "'" + deviceInfo.DevEnNo[i] + "', '" + deviceInfo.Reserve3[i] + "','" + deviceInfo.DeviceId[i] + "','" + deviceInfo.MacStart[i] + "','" + deviceInfo.MacEnd[i] + "','" + deviceInfo.ProductionDate + "',sysdate)", "insert");
  480. }
  481. Console.WriteLine(json);
  482. }
  483. //获取栈板信息
  484. public static void GetPalletInfo(string iBox)
  485. {
  486. DataTable dt = (DataTable)dh.ExecuteSql("select pa_outboxcode,pa_makecode from package where pa_mothercode='" + iBox + "'", "select");
  487. dynamic obj = new ExpandoObject();
  488. var expandoDict = obj as IDictionary<string, object>;
  489. string makecode = "";
  490. for (int i = 0; i < dt.Rows.Count; i++)
  491. {
  492. string enNoKey = $"big_box_no{i}";
  493. string enNoValue = dt.Rows[i]["pa_outboxcode"].ToString();
  494. expandoDict[enNoKey] = enNoValue;
  495. makecode = dt.Rows[i]["pa_makecode"].ToString();
  496. }
  497. obj.request = "pallet";
  498. obj.packing_num = dt.Rows.Count;
  499. obj.User = "mes";
  500. obj.po_sn = makecode;
  501. obj.password = "258456";
  502. obj.tool_name = "zte";
  503. string json = JsonConvert.SerializeObject(obj, Formatting.Indented);
  504. dh.ExecuteSql("insert into EISDATA(ED_ID, ED_DATA, ED_INDATE, ED_TYPE)values(EISDATA_seq.nextval,'" + json + "',sysdate,'GetPalletInfo')", "insert");
  505. string returnstr = ToServerReq(json);
  506. Console.WriteLine(returnstr);
  507. Console.WriteLine(json);
  508. }
  509. public static readonly uint PROTOCOL_FLAG = 0x4C4F4F54;
  510. public static string ToServerReq(string strJSON)
  511. {
  512. int nRet = 0;
  513. string strServerIP = "192.168.1.160";
  514. string strResp = "";
  515. IPAddress ip = IPAddress.Parse(strServerIP);
  516. Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  517. while (true)
  518. {
  519. try
  520. {
  521. clientSocket.Connect(new IPEndPoint(ip, SN_SERVICE_PORT));
  522. }
  523. catch
  524. {
  525. nRet = -13;
  526. break;
  527. }
  528. try
  529. {
  530. FACT_DATA_HEAD stHead = new FACT_DATA_HEAD(null);
  531. byte[] bytJson = Encoding.UTF8.GetBytes(strJSON); //Encoding.ASCII.GetBytes(strJSON);
  532. stHead.setDataLen(bytJson.Length);
  533. byte[] bytBuf = new byte[FACT_DATA_HEAD.MY_LEN + bytJson.Length];
  534. byte[] bytSrcHead = stHead.getBytes();
  535. Array.Copy(bytSrcHead, 0, bytBuf, 0, bytSrcHead.Length);
  536. Array.Copy(bytJson, 0, bytBuf, FACT_DATA_HEAD.MY_LEN, bytJson.Length);
  537. clientSocket.Send(bytBuf);
  538. }
  539. catch
  540. {
  541. nRet = -12;
  542. break;
  543. }
  544. //判定接口回传的flag和本地传过去的是否一致
  545. byte[] bytRecv = new byte[MAX_BUF_SIZE];
  546. int nRecvSize = 0, nSize = 0;
  547. nRecvSize = clientSocket.Receive(bytRecv, 0, FACT_DATA_HEAD.MY_LEN, SocketFlags.None);
  548. if (nRecvSize > 0)
  549. {
  550. FACT_DATA_HEAD stHead = new FACT_DATA_HEAD(bytRecv);
  551. Console.WriteLine(stHead.getFlag());
  552. Console.WriteLine(FACT_DATA_HEAD.PROTOCOL_FLAG);
  553. if (stHead.getFlag() == FACT_DATA_HEAD.PROTOCOL_FLAG)
  554. {
  555. int nPos = 0;
  556. nSize = stHead.getDatalen();
  557. while (nPos < nSize)
  558. {
  559. nRecvSize = clientSocket.Receive(bytRecv, nPos, nSize - nPos, SocketFlags.None);
  560. if (nRecvSize < 0)
  561. {
  562. nRet = -14;
  563. break;
  564. }
  565. nPos += nRecvSize;
  566. }
  567. strResp = Encoding.Default.GetString(bytRecv, 0, nSize);
  568. }
  569. else nRet = -11;
  570. }
  571. else nRet = -10;
  572. break;
  573. }
  574. if (nRet > -13) clientSocket.Shutdown(SocketShutdown.Both);
  575. clientSocket.Close();
  576. return strResp;
  577. }
  578. }
  579. }