服务端的TigerApi 框架,基于.NET6 2024 版本
Rodney Chen
9 天以前 7e73e5df14dce74742abf50383bb8ac37b38012e
Tiger.Business.MES/iERP/U9C_MES.cs
@@ -31,11 +31,11 @@
        public ApiAction GetBasItem(U9C_Base_Input input)
        {
            var action = new ApiAction();
            var db = Biz.Db;
            Logger.Scheduler.Info($"物料信息开始同步。。。数据检查进行中。。。");
            Logger.Scheduler.Info($"{input.triggerDetail}");
            DbClient db = Biz.DataSource["YadaU9C"].Client;
            var list = db.Queryable<dynamic>().AS("mes_ItemMaster").Where("ModifiedOn > @startTime And ModifiedOn < @endTime", new { startTime = input.startTime, endTime = input.endTime }).ToList();
            var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
            var list = Biz.DataSource["YadaU9C"].Client.Queryable<dynamic>().AS("mes_ItemMaster").Where("ModifiedOn > @startTime And ModifiedOn < @endTime", new { startTime = input.startTime, endTime = input.endTime }).ToList();
            var orgs = db.Queryable<SYS_ORGANIZATION>().ToList();
            List<BAS_ITEM> items = new();
            var itemExts = new List<BAS_ITEM_EXT>();
            if (list != null && list.Count > 0)
@@ -67,6 +67,13 @@
                            RULE_CODE = di["BarRule"] == null ? "" : di["BarRule"].ToString(),
                            DEFAULT_LOCATION = di["BinCode"] == null ? "" : di["BinCode"].ToString(),
                        };
                        var whUnit = db.Queryable<V_WH_UNIT>().Where(t => t.LOCATION_CODE == basItem.DEFAULT_LOCATION && t.AUTH_ORG == basItem.AUTH_ORG).First();
                        if (!whUnit.IsNullOrEmpty())
                        {
                            basItem.DEFAULT_WH = whUnit.WH_CODE;
                            basItem.DEFAULT_REGION = whUnit.REGION_CODE;
                            basItem.DEFAULT_SHELF = whUnit.SHELF_CODE;
                        }
                        items.Add(basItem);
                        var extInfo = new BAS_ITEM_EXT()
                        {
@@ -88,7 +95,7 @@
                }
            }
            Logger.Scheduler.Info($"物料信息存入实体中,总数:[{items.Count}]");
            db = Biz.Db;
            //var dbTran = db.UseTran(() =>
            //{
            if (items.Any())