优化代码结构，改进打印和计划处理逻辑

Ben Lin

2025-01-03 9e70e03376aa1d7b86baef15e2ddfe3641fc0cb8

 Tiger.Business.MES/iERP/U9C_MES.cs

@@ -86,8 +86,8 @@
            }
            Logger.Scheduler.Info($"物料信息存入实体中，总数：[{items.Count}]");
            db = Biz.Db;
            var dbTran = db.UseTran(() =>
            {
            //var dbTran = db.UseTran(() =>
            //{
                if (items.Any())
                {
                    if (items.Count > 100)
@@ -131,12 +131,12 @@
                        s.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                    }
                }
            });
            if (!dbTran.IsSuccess)
            {
                action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
                Logger.Scheduler.Error(action.Message);
            }
            //});
            //if (!dbTran.IsSuccess)
            //{
            //    action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
            //    Logger.Scheduler.Error(action.Message);
            //}
            Logger.Scheduler.Info($"物料信息存入数据库，总数：[{items.Count}]");
            action.Message = $"物料信息存入数据库，总数：[{items.Count}]";
            return action;
@@ -340,8 +340,8 @@
            }
            Logger.Scheduler.Info($"客户信息存入实体中，总数：[{items.Count}]");
            db = Biz.Db;
            var dbTran = db.UseTran(() =>
                {
            //var dbTran = db.UseTran(() =>
            //    {
                    if (items.Any())
                    {
                        if (items.Count > 100)
@@ -365,12 +365,12 @@
                        }
                    }

                });
            if (!dbTran.IsSuccess)
            {
                action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
                Logger.Scheduler.Error(action.Message);
            }
            //    });
            //if (!dbTran.IsSuccess)
            //{
            //    action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
            //    Logger.Scheduler.Error(action.Message);
            //}
            Logger.Scheduler.Info($"客户信息存入数据库，总数：[{items.Count}]");
            action.Message = $"客户信息存入数据库，总数：[{items.Count}]";
            return action;
@@ -414,9 +414,9 @@
            }
            Logger.Scheduler.Info($"供应商信息存入实体中，总数：[{items.Count}]");
            db = Biz.Db;
            var dbTran = db.UseTran(() =>
            {
                if (items.Any())
            //var dbTran = db.UseTran(() =>
            // {
            if (items.Any())
                {
                    if (items.Count > 100)
                    {
@@ -439,12 +439,12 @@
                    }
                }

            });
            if (!dbTran.IsSuccess)
            {
                action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
                Logger.Scheduler.Error(action.Message);
            }
            //});
            //if (!dbTran.IsSuccess)
            //{
            //    action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
            //    Logger.Scheduler.Error(action.Message);
            //}
            Logger.Scheduler.Info($"供应商信息存入数据库，总数：[{items.Count}]");
            action.Message = $"供应商信息存入数据库，总数：[{items.Count}]";
            return action;
@@ -493,8 +493,8 @@
            }
            Logger.Scheduler.Info($"客户条码信息存入实体中，总数：[{items.Count}]");
            db = Biz.Db;
            var dbTran = db.UseTran(() =>
            {
            //var dbTran = db.UseTran(() =>
            //{
                if (items.Any())
                {
                    if (items.Count > 100)
@@ -505,7 +505,7 @@
                                   .WhereColumns(t => new { t.CUST_SN, t.GHOST_ROW })
                                   .ToStorage();
                            y.AsInsertable.ExecuteCommand();
                            y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                            y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.CUST_CODE,q.WORK_ORDER,q.CUST_SN,q.FLOW_SN,q.ITEM_CODE,q.CREATE_TIME,q.UPDATE_TIME,q.UPDATE_USER,q.AUTH_ORG}).ExecuteCommand();
                        });
                    }
                    else
@@ -514,16 +514,16 @@
                               .WhereColumns(t => new { t.CUST_SN, t.GHOST_ROW })
                               .ToStorage();
                        s.AsInsertable.ExecuteCommand();
                        s.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                        s.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.CUST_CODE, q.WORK_ORDER, q.CUST_SN, q.FLOW_SN, q.ITEM_CODE, q.CREATE_TIME, q.UPDATE_TIME, q.UPDATE_USER, q.AUTH_ORG }).ExecuteCommand();
                    }
                }

            });
            if (!dbTran.IsSuccess)
            {
                action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
                Logger.Scheduler.Error(action.Message);
            }
            //});
            //if (!dbTran.IsSuccess)
            //{
            //    action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
            //    Logger.Scheduler.Error(action.Message);
            //}
            Logger.Scheduler.Info($"客户条码信息存入数据库，总数：[{items.Count}]");
            action.Message = $"客户条码信息存入数据库，总数：[{items.Count}]";
            return action;
@@ -583,8 +583,8 @@
            }
            Logger.Scheduler.Info($"工单信息存入实体中，总数：[{items.Count}]");
            db = Biz.Db;
            var dbTran = db.UseTran(() =>
            {
            //var dbTran = db.UseTran(() =>
            //{
                if (items.Any())
                {
                    if (items.Count > 100)
@@ -608,12 +608,12 @@
                    }
                }

            });
            if (!dbTran.IsSuccess)
            {
                action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
                Logger.Scheduler.Error(action.Message);
            }
            //});
            //if (!dbTran.IsSuccess)
            //{
            //    action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
            //    Logger.Scheduler.Error(action.Message);
            //}
            action.Message = $"工单信息存入数据库，总数：[{items.Count}]";
            Logger.Scheduler.Info($"{action.Message}");
            if (action.IsSuccessed && items.Count > 0)