| | |
|---|
| | | 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) |
|---|
| | |
|---|
| | | 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() |
|---|
| | | { |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | Logger.Scheduler.Info($"物料信息存入实体中，总数：[{items.Count}]"); |
|---|
| | | db = Biz.Db; |
|---|
| | | |
|---|
| | | //var dbTran = db.UseTran(() => |
|---|
| | | //{ |
|---|
| | | if (items.Any()) |
|---|
