重新抓取生产订单数据

AutoTurnOver.DB/dc_base_prod_order_dao.cs

@@ -10,7 +10,7 @@ namespace AutoTurnOver.DB
     {
         public static void SynchroData()
         {
-            var task_name = "SynchroProdData_v2";
+            var task_name = "SynchroProdData_v3";
             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 });
@@ -110,33 +110,7 @@ namespace AutoTurnOver.DB
                         }
                     }
 
-                    if (db_data.order_quantity <= db_data.prod_quantity)
-                    {
-                        db_data.status = "生产完成";
-                    }
-                    else
-                    {
-                        var status = "";
-
-                        if (db_data.order_quantity <= db_data.distribution_quantity)
-                        {
-                            status += " 完全分配 ";
-                        }
-                        else if (db_data.distribution_quantity > 0)
-                        {
-                            status += " 部分分配 ";
-                        }
-                        else
-                        {
-                            status += " 未分配 ";
-                        }
-
-                        if (db_data.prod_quantity > 0)
-                        {
-                            status += " 部分生产 ";
-                        }
-                        db_data.status = status;
-                    }
+                   
                     if (string.IsNullOrWhiteSpace(db_data.bailun_sku))
                     {
                         continue;
@@ -151,12 +125,19 @@ namespace AutoTurnOver.DB
                         db_data.distribution_quantity = Math.Min(db_data.distribution_quantity, old_data.distribution_quantity);
                         db_data.prod_quantity = Math.Min(db_data.prod_quantity, old_data.prod_quantity);
                         db_data.id = old_data.id;
+                        SetStatus(db_data);
                         conn.Update(db_data);
                     }
                     else
                     {
+                        SetStatus(db_data);
                         conn.Insert(db_data);
                     }
+
+                    #region 计算状态
+                   
+                    #endregion
+
                     count++;
                 }
 
@@ -167,5 +148,36 @@ namespace AutoTurnOver.DB
             new_task_synchro_log.status = 1;
             conn.Update(new_task_synchro_log);
         }
+
+        public static void SetStatus(dc_base_prod_order db_data)
+        {
+            if (db_data.order_quantity <= db_data.prod_quantity)
+            {
+                db_data.status = "生产完成";
+            }
+            else
+            {
+                var status = "";
+
+                if (db_data.order_quantity <= db_data.distribution_quantity)
+                {
+                    status += " 完全分配 ";
+                }
+                else if (db_data.distribution_quantity > 0)
+                {
+                    status += " 部分分配 ";
+                }
+                else
+                {
+                    status += " 未分配 ";
+                }
+
+                if (db_data.prod_quantity > 0)
+                {
+                    status += " 部分生产 ";
+                }
+                db_data.status = status;
+            }
+        }
     }
 }