TigerClouds-Tech/Server/TigerApi6_2024.git

			@@ -78,12 +78,14 @@
			Accuracy = (di["Accuracy"] ?? "").ToString(),
			Remark = (di["Remark"] ?? "").ToString(),
			Packaging = (di["Packaging"] ?? "").ToString(),
			SapCode = (di["Code1"] ?? "").ToString(),
			};
			itemExts.Add(extInfo);
			}
			}
			}
			Logger.Scheduler.Info($"物料信息存入实体中，总数：[{items.Count}]");
			db = Biz.Db;
			var dbTran = db.UseTran(() =>
			{
			if (items.Any())
			@@ -117,7 +119,7 @@
			.WhereColumns(t => new { t.ITEM_ID, t.GHOST_ROW })
			.ToStorage();
			y.AsInsertable.ExecuteCommand();
			y.AsUpdateable.ExecuteCommand();
			y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
			});
			}
			else
			@@ -136,6 +138,7 @@
			Logger.Scheduler.Error(action.Message);
			}
			Logger.Scheduler.Info($"物料信息存入数据库，总数：[{items.Count}]");
			action.Message = $"物料信息存入数据库，总数：[{items.Count}]";
			return action;
			}

			@@ -205,15 +208,15 @@
			db.Storageable(LastRun, "U9C_MES_GetWo").ExecuteCommand();
			if (items.Any())
			{
			if (items.Count > 150)
			if (items.Count > 100)
			{
			db.Utilities.PageEach(items, 1000, pageList =>
			db.Utilities.PageEach(items, 100, pageList =>
			{
			var y = db.Storageable(pageList, "U9C")
			.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
			.ToStorage();
			y.BulkCopy();
			y.BulkUpdate();
			y.AsInsertable.ExecuteCommand();
			y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
			});
			}
			else
			@@ -282,11 +285,7 @@
			{
			if (woList.Any())
			{
			var s = _db.Storageable(woList, "U9C")
			.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
			.ToStorage();
			s.AsInsertable.ExecuteCommand();
			s.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(x => new { x.ROUTE_STATUS}).ExecuteCommand();
			_db.Updateable(woList, "U9C").UpdateColumns(x => new { x.ROUTE_STATUS }).ExecuteCommand();
			}

			});
			@@ -340,6 +339,7 @@
			}
			}
			Logger.Scheduler.Info($"客户信息存入实体中，总数：[{items.Count}]");
			db = Biz.Db;
			var dbTran = db.UseTran(() =>
			{
			if (items.Any())
			@@ -372,6 +372,7 @@
			Logger.Scheduler.Error(action.Message);
			}
			Logger.Scheduler.Info($"客户信息存入数据库，总数：[{items.Count}]");
			action.Message = $"客户信息存入数据库，总数：[{items.Count}]";
			return action;
			}

			@@ -412,6 +413,7 @@
			}
			}
			Logger.Scheduler.Info($"供应商信息存入实体中，总数：[{items.Count}]");
			db = Biz.Db;
			var dbTran = db.UseTran(() =>
			{
			if (items.Any())
			@@ -444,6 +446,7 @@
			Logger.Scheduler.Error(action.Message);
			}
			Logger.Scheduler.Info($"供应商信息存入数据库，总数：[{items.Count}]");
			action.Message = $"供应商信息存入数据库，总数：[{items.Count}]";
			return action;
			}

			@@ -489,6 +492,7 @@
			}
			}
			Logger.Scheduler.Info($"客户条码信息存入实体中，总数：[{items.Count}]");
			db = Biz.Db;
			var dbTran = db.UseTran(() =>
			{
			if (items.Any())
			@@ -521,6 +525,7 @@
			Logger.Scheduler.Error(action.Message);
			}
			Logger.Scheduler.Info($"客户条码信息存入数据库，总数：[{items.Count}]");
			action.Message = $"客户条码信息存入数据库，总数：[{items.Count}]";
			return action;
			}

			@@ -564,7 +569,7 @@
			CUST_PREFIX = di["OutBarHead"] == null ? "" : di["OutBarHead"].ToString(),
			SALES_CONTRACT = di["Contracts"] == null ? "" : di["Contracts"].ToString(),
			};
			if (!Biz.Db.Queryable<BIZ_MES_WO>().Any(x => x.ORDER_NO == woItem.ORDER_NO && (x.STATUS > BIZ_MES_WO.STATUSs.Init.GetValue() \|\| x.ROUTE_STATUS > BIZ_MES_WO.ROUTE_STATUSs.WaitSet.GetValue())))
			if (!Biz.Db.Queryable<BIZ_MES_WO>().Any(x => x.ORDER_NO == woItem.ORDER_NO && x.STATUS > BIZ_MES_WO.STATUSs.Imported.GetValue()))
			{
			items.Add(woItem);
			}