From b790305873e20a7f26d63c71623210964105014e Mon Sep 17 00:00:00 2001
From: yanjinhui <3306209981@qq.com>
Date: 星期三, 12 十一月 2025 18:45:08 +0800
Subject: [PATCH] 优化

---
 新建文件夹/WIDESEA_WMSServer/ClassLibrary2/MaterielInfoService.cs |  152 +++++++++++++++++++++++++++-----------------------
 1 files changed, 81 insertions(+), 71 deletions(-)

diff --git "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MaterielInfoService.cs" "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MaterielInfoService.cs"
index 5817be8..7f82787 100644
--- "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MaterielInfoService.cs"
+++ "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MaterielInfoService.cs"
@@ -1,6 +1,7 @@
 锘縰sing HslCommunication;
 using Newtonsoft.Json;
 using Quartz.Util;
+using SqlSugar;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -167,6 +168,13 @@
 
             return "鏈煡";
         }
+
+
+        /// <summary>
+        /// 鍙戠粰涓嬫父wcs鍚屾鑽搧淇℃伅 
+        /// </summary>
+        /// <returns></returns>
+        #region 鍚屾涓嬫父鐗╂枡鎺ュ彛
         public WebResponseContent ProductSynchronous()
         {
             try
@@ -222,82 +230,84 @@
                 return WebResponseContent.Instance.Error(ex.Message);
             }
         }
-        /// <summary>
-        /// 鍙戠粰涓嬫父wcs鍚屾鑽搧淇℃伅 
-        /// </summary>
-        /// <returns></returns>
-        public WebResponseContent ProductSynchronous1()
-        {
-            try
-            {
-                //鎶婂皬浠舵湭涓嬪彂鐨勭殑淇℃伅鍜岀瑙勪负0锛屾渶浣庡簱瀛樹负0鐨勮繃婊ゆ帀
-                //var list = BaseDal.Db.Queryable<Dt_MaterielInfo>().Where(x => x.GoodStatusState == "鏈笅鍙�" && x.MaterielSourceType == MaterielSourceTypeEnum.SelfMadePart).ToList();
-                var list = BaseDal.QueryData(x => x.MaterielSourceType == MaterielSourceTypeEnum.SelfMadePart && x.BoxQty > 0 && x.MinQty > 0 && x.GoodStatusState == "鏈笅鍙�").ToList();
-                if (list.Count < 1)
-                {
-                    return new WebResponseContent().OK("鏃犳湭涓嬪彂鑽搧");
-                }
-                //鎵惧埌浜嗗氨灏嗘暣涓猯ist鍙戠粰涓嬫父绯荤粺
-                foreach (var item in list)
-                {
-                    var medicineDTO = new ProductInfo
-                    {
-                        //鐢ㄦ埛code
-                        customerCode = "905",
-                        //鐗╂枡绫诲瀷
-                        materialCode = item.MaterielErpType,
-                        //浜у搧缂栫爜
-                        productCode = item.MaterielCode,
-                        //浜у搧鍚�
-                        productName = item.MaterielName,
-                        //浜у搧鏉$爜
-                        productBarCode = item.Barcode,
+        #endregion
 
-                        //鑽墏
-                        medicine = item.Dosage_form,//杩欓噷瑕佽皟鐢ㄦ柟娉曪紝杞寲鏂规硶
 
-                        //瑙勬牸
-                        productSpecifications = item.MaterielSpec,
-                        //鍗曚綅
-                        unit = item.MaterielUnit,
-                        //闀�
-                        singleProductLongNum = (item.MaterielLength ?? 0).ToString(),
-                        //瀹�
-                        singleProductWideNum = (item.MaterielWide ?? 0).ToString(),
-                        //楂�
-                        singleProductHighNum = (item.MaterielHeight ?? 0).ToString(),
-                        //閲嶉噺
-                        singleProductWeight = (item.MaterielWeight ?? 0).ToString(),
-                        //浣撶Н
-                        singleProductVolume = (item.MaterielVolume ?? 0).ToString(),
-                        //鏄惁鍙栨秷 0鏄笉鍒犻櫎锛�1鍒犻櫎
-                        isDelete = "0"
-                    };
-                    var url = "http://172.16.1.2:9357/file-admin/api/product/productSynchronous";
-                    var result = HttpHelper.Post(url, medicineDTO.ToJsonString());
-                    var resp = JsonConvert.DeserializeObject<TowcsResponse<object>>(result);
+        #region 鎵嬪姩鍏抽棴鏁版嵁搴撹繛鎺� 鍚屾涓嬫父鐗╂枡 
+        //public WebResponseContent ProductSynchronous()
+        //{
+        //    using (var db = new SqlSugarClient(new ConnectionConfig
+        //    {
+        //        ConnectionString = "Data Source=.;Initial Catalog=WIDESEA_WMSDBF_Z22;User ID=sa;Password=48PYX_h7KS@f;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
+        //        DbType = DbType.SqlServer,
+        //        IsAutoCloseConnection = true,  // 鍏抽敭閰嶇疆锛岃嚜鍔ㄥ叧闂繛鎺�
+        //        MoreSettings = new ConnMoreSettings()
+        //        {
+        //            IsAutoRemoveDataCache = true
+        //        }
+        //    }))
+        //    {
+        //        try
+        //        {
+        //            List<Dt_MaterielInfo> materielInfos = db.Queryable<Dt_MaterielInfo>().Where(x => x.MaterielSourceType == MaterielSourceTypeEnum.SelfMadePart && x.BoxQty > 0 && x.MinQty > 0 && x.GoodStatusState == "鏈笅鍙�").ToList();
+        //            if (materielInfos.Count < 1)
+        //            {
 
-                    if (resp != null && resp.code == "0")
-                    {
-                        item.GoodStatusState = "涓嬪彂瀹屾垚";
-                    }
-                    else
-                    {
-                        continue;
-                    }
+        //                return WebResponseContent.Instance.Error("鏃犳湭涓嬪彂鑽搧");
+        //            }
+        //            var url = "http://172.16.1.2:9357/file-admin/api/product/productSynchronous";
+        //            foreach (var item in materielInfos)
+        //            {
+        //                var medicineDTO = new ProductInfo
+        //                {
+        //                    //鐢ㄦ埛code
+        //                    customerCode = "905",
+        //                    //鐗╂枡绫诲瀷
+        //                    materialCode = item.MaterielErpType,
+        //                    //浜у搧缂栫爜
+        //                    productCode = item.MaterielCode,
+        //                    //浜у搧鍚�
+        //                    productName = item.MaterielName,
+        //                    //浜у搧鏉$爜
+        //                    productBarCode = item.Barcode,
 
-                }
-                BaseDal.UpdateData(list);
-                //Db.Updateable(list).ExecuteCommand();
-                return new WebResponseContent { Status = true, Message = "鎴愬姛" };
-            }
-            catch (Exception ex)
-            {
-                Console.WriteLine("ProductSynchronous 寮傚父锛�" + ex.Message);
-                return new WebResponseContent { Status = false, Message = ex.Message };
-            }
+        //                    //鑽墏
+        //                    medicine = item.Dosage_form,//杩欓噷瑕佽皟鐢ㄦ柟娉曪紝杞寲鏂规硶
 
-        }
+        //                    //瑙勬牸
+        //                    productSpecifications = item.MaterielSpec,
+        //                    //鍗曚綅
+        //                    unit = item.MaterielUnit,
+        //                    //闀�
+        //                    singleProductLongNum = (item.MaterielLength ?? 0).ToString(),
+        //                    //瀹�
+        //                    singleProductWideNum = (item.MaterielWide ?? 0).ToString(),
+        //                    //楂�
+        //                    singleProductHighNum = (item.MaterielHeight ?? 0).ToString(),
+        //                    //閲嶉噺
+        //                    singleProductWeight = (item.MaterielWeight ?? 0).ToString(),
+        //                    //浣撶Н
+        //                    singleProductVolume = (item.MaterielVolume ?? 0).ToString(),
+        //                    //鏄惁鍙栨秷 0鏄笉鍒犻櫎锛�1鍒犻櫎
+        //                    isDelete = "0"
+        //                };
+        //                var result = HttpHelper.Post(url, medicineDTO.ToJsonString());
+        //                var resp = JsonConvert.DeserializeObject<TowcsResponse<object>>(result);
+        //                if (resp != null && resp.code == "0") item.GoodStatusState = "涓嬪彂瀹屾垚";
+        //            }
+        //            db.Updateable(materielInfos).ExecuteCommand();
+
+        //            return WebResponseContent.Instance.OK();
+        //        }
+        //        catch (Exception ex)
+        //        {
+        //            Console.WriteLine("涓嬪彂WCS鐗╂枡淇℃伅寮傚父锛�" + ex.Message);
+        //            return WebResponseContent.Instance.Error(ex.Message);
+        //        }
+        //    }
+        //}
+        #endregion
+
         public override WebResponseContent DeleteData(object[] keys)
         {
             WebResponseContent content = new WebResponseContent();

--
Gitblit v1.9.3