新增lms渠道拉取的服务

AutoTurnOver.DB/ApiUtility.cs

@@ -325,6 +325,33 @@ namespace AutoTurnOver.DB
                 throw new Exception("供应商 list 接口异常： " + ex.StackTrace);
             }
         }
+        /// <summary>
+        /// 抓取物流商列表
+        /// </summary>
+        /// <returns></returns>
+        public static List<dc_base_lms_channel> getChannelList()
+        {
+            try
+            {
+                //查询采购建议明细 
+                string url = ConfigHelper.GetValue("lms-sys:channel");
+                string resultStr = HttpHelper.Request(url, RequestType.GET, timeout: 1000 * 60 * 60 * 24);
+                var result = resultStr.ToObj<api_channel_dto>();
+                if (result == null)
+                {
+                    return new List<dc_base_lms_channel>();
+                }
+                else
+                {
+                    return result.data;
+                }
+            }
+            catch (Exception ex)
+            {
+                throw new Exception("lms list 接口异常： " + ex.Message);
+                throw new Exception("lms list 接口异常： " + ex.StackTrace);
+            }
+        }
 
         /// <summary>
         /// 提货单推送无库系统

AutoTurnOver.DB/dc_base_supplier_dao.cs

@@ -83,5 +83,64 @@ namespace AutoTurnOver.DB
             conn.Update(new_task_synchro_log);
         }
 
+
+        public static void SynchroBailunLmsChannel()
+        {
+            var task_name = "SynchroBailunLmsChannel";
+            var conn = _connection;
+            // 查询最后一次成功抓取的记录
+            var last_task_synchro_log = conn.QuerySingleOrDefault<task_synchro_log>(" select  * from task_synchro_log where task_name=@task_name and status=1 order by end_time desc limit 1 ", new { task_name = task_name });
+
+            var new_task_synchro_log = new task_synchro_log
+            {
+                create_date = DateTime.Now,
+                end_time = DateTime.Now,
+                status = 0,
+                task_name = task_name
+            };
+
+            if (last_task_synchro_log != null)
+            {
+                new_task_synchro_log.start_time = last_task_synchro_log.end_time.AddMinutes(-1);
+            }
+            else
+            {
+                new_task_synchro_log.start_time = new DateTime(2001, 05, 14);
+            }
+
+            new_task_synchro_log.id = conn.Insert(new_task_synchro_log) ?? 0;
+            int count = 0;
+
+
+            var page = 1;
+            //while (true)
+            {
+                var datas = ApiUtility.getChannelList();
+
+                page++;
+
+                foreach (var item in datas)
+                {
+                    item.lms_id = item.id;
+
+
+                    item.id = conn.QueryFirstOrDefault<int?>(" select id from dc_base_lms_channel where `lms_id`=@lms_id ", new { lms_id = item.lms_id }) ?? 0;
+                    if (item.id > 0)
+                    {
+                        conn.Update(item);
+                    }
+                    else
+                    {
+                        conn.Insert(item);
+                    }
+                    count++;
+                }
+            }
+
+
+            new_task_synchro_log.count = count;
+            new_task_synchro_log.status = 1;
+            conn.Update(new_task_synchro_log);
+        }
     }
 }

AutoTurnOver.Models/ApiDto/api_supplier_dto.cs

@@ -38,4 +38,14 @@ namespace AutoTurnOver.Models.ApiDto
         }
         
     }
+
+    public class api_channel_dto
+    {
+        public bool success { get; set; }
+        public string msg { get; set; }
+
+        public List<dc_base_lms_channel> data { get; set; }
+      
+
+    }
 }

ResetOutofstock/Program.cs

@@ -16,10 +16,11 @@ namespace ResetOutofstock
             try
             {
                 
-                var now = DateTime.Now; 
-               //dc_auto_turnover.CopyForecast();
+                var now = DateTime.Now;
+                //dc_auto_turnover.CopyForecast();
                 //report.GenerateWeekTagStockDatas();
                 //dc_base_transfer_extend_dao.SynchroLmsTransferOrder();
+                dc_base_supplier_dao.SynchroBailunLmsChannel();
             }
             catch (Exception ex)
             {

ResetOutofstock/StockBackgrounService.cs

@@ -64,6 +64,12 @@ namespace ResetOutofstock
                 dc_auto_pick_up_goods_order_dao.GenerateOrder(DateTime.Now.AddDays(-1), DateTime.Now);
                 Console.WriteLine($"结束 刷新jit安全库存，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
             }
+            if (now.Hour == 02 && now.Minute == 2)
+            {
+                Console.WriteLine($"开始 拉取lms的渠道数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                dc_base_supplier_dao.SynchroBailunSupplier();
+                Console.WriteLine($"结束 拉取lms的渠道数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+            }
 
             if (now.DayOfWeek == DayOfWeek.Monday)
             {

ResetOutofstock/appsettings.dev.json

@@ -34,7 +34,8 @@
     "order": "http://mjzz.bailuntec.com/api/ApiOrderList"
   },
   "lms-sys": {
-    "transfer-node": "http://lms.bailuntec.com/api/order/transfer/ApiOrderTransferSkuCurrentNode"
+    "transfer-node": "http://lms.bailuntec.com/api/order/transfer/ApiOrderTransferSkuCurrentNode",
+    "channel": "http://lms.bailuntec.com/api/order/transfer/ApiChannelList"
   },
   "Order": {
     "Bailun_TransferLog": "http://api.wms.bailuntec.com/api/services/app/AllotOrderService/SearchOrderSkuRecord"

ResetOutofstock/appsettings.json

@@ -35,7 +35,8 @@
     "order": "http://mjzz.bailuntec.com/api/ApiOrderList"
   },
   "lms-sys": {
-    "transfer-node": "http://lms.bailuntec.com/api/order/transfer/ApiOrderTransferSkuCurrentNode"
+    "transfer-node": "http://lms.bailuntec.com/api/order/transfer/ApiOrderTransferSkuCurrentNode",
+    "channel": "http://lms.bailuntec.com/api/order/transfer/ApiChannelList"
   },
   "Order": {
     "Bailun_TransferLog": "http://api.wms.bailuntec.com/api/services/app/AllotOrderService/SearchOrderSkuRecord"

ResetOutofstock/appsettings.prod.json

@@ -34,7 +34,8 @@
     "order": "http://mjzz.bailuntec.com/api/ApiOrderList"
   },
   "lms-sys": {
-    "transfer-node": "http://lms.bailuntec.com/api/order/transfer/ApiOrderTransferSkuCurrentNode"
+    "transfer-node": "http://lms.bailuntec.com/api/order/transfer/ApiOrderTransferSkuCurrentNode",
+    "channel": "http://lms.bailuntec.com/api/order/transfer/ApiChannelList"
   },
   "Order": {
     "Bailun_TransferLog": "http://api.wms.bailuntec.com/api/services/app/AllotOrderService/SearchOrderSkuRecord"