计划任务更新

Ben Lin

2024-10-28 20a0c7b19c248617fb1852a63834bb668831f86e

 Tiger.Business.MES/iERP/U9C_MES.cs

@@ -26,7 +26,7 @@
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction> GetBasItem(GetBasItemInput input)
        public ApiAction GetBasItem(U9C_MES_Input input)
        {
            var action = new ApiAction();
            Logger.Scheduler.Info($"物料信息开始同步。。。数据检查进行中。。。");
@@ -83,12 +83,8 @@
                }
            }
            Logger.Scheduler.Info($"物料信息存入实体中，总数：[{items.Count}]");
            db = Biz.Db;
            var LastRun = await db.Queryable<SYS_PARAM>().Where(q => q.PRMG_CODE == "Interface_LastRun" && q.PARAM_CODE == "GetItem_LastRun").SingleAsync();
            LastRun.PARAM_VALUE = (input.endTime.ToDateTime() - DateTime.Now).TotalMinutes > 0 ? LastRun.PARAM_VALUE : input.endTime;
            var dbTran = db.UseTran(() =>
            {
                db.Storageable(LastRun, "U9C_MES_GetItem").ExecuteCommand();
                if (items.Any())
                {
                    if (items.Count > 150)
@@ -309,14 +305,14 @@
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public async Task<ApiAction> GetCustomer(GetCustomerInput input)
        public ApiAction GetCustomer(U9C_MES_Input input)
        {
            var action = new ApiAction();
            Logger.Scheduler.Info($"客户信息开始同步。。。数据检查进行中。。。");
            Logger.Scheduler.Info($"{input.triggerDetail}");
            DbClient db = Biz.DataSource["YadaU9C"].Client;
            var list = db.Queryable<dynamic>().AS("mes_Customer").Where("ModifiedOn > @startTime And ModifiedOn < @endTime", new { startTime = input.startTime, endTime = input.endTime }).ToList();
            var orgs = await Biz.Db.Queryable<SYS_ORGANIZATION>().ToListAsync();
            var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
            List<BAS_CUSTOMER> items = new();
            if (list != null && list.Count > 0)
            {
@@ -388,14 +384,14 @@
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction> GetSupplier(GetSupplierInput input)
        public ApiAction GetSupplier(U9C_MES_Input input)
        {
            var action = new ApiAction();
            Logger.Scheduler.Info($"供应商信息开始同步。。。数据检查进行中。。。");
            Logger.Scheduler.Info($"{input.triggerDetail}");
            DbClient db = Biz.DataSource["YadaU9C"].Client;
            var list = db.Queryable<dynamic>().AS("mes_Supplier").Where("ModifiedOn > @startTime And ModifiedOn < @endTime", new { startTime = input.startTime, endTime = input.endTime }).ToList();
            var orgs = await Biz.Db.Queryable<SYS_ORGANIZATION>().ToListAsync();
            var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
            List<BAS_SUPPLIER> items = new();
            if (list != null && list.Count > 0)
            {
@@ -464,7 +460,7 @@
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction> GetCustBarCode(GetCustBarcodeInput input)
        public ApiAction GetCustBarCode(U9C_MES_Input input)
        {
            var action = new ApiAction();
            Logger.Scheduler.Info($"客户条码信息开始同步。。。数据检查进行中。。。");
@@ -483,7 +479,7 @@
                    {
                        if (di["MoDoc"] != null)
                        {
                            var _MES_WO = await Biz.Db.Queryable<BIZ_MES_WO>().Where(x => x.ORDER_NO == di["MoDoc"].ToString()).FirstAsync();
                            var _MES_WO = Biz.Db.Queryable<BIZ_MES_WO>().Where(x => x.ORDER_NO == di["MoDoc"].ToString()).First();
                            MES_CUST_SN snItem = new()
                            {
                                CUST_CODE = _MES_WO?.CUST_CODE ?? "",
@@ -540,7 +536,7 @@
            return action;
        }

        public ApiAction GetU9CBasWo(GetWoInput input)
        public ApiAction GetU9CBasWo(U9C_MES_Input input)
        {
            var action = new ApiAction();
            Logger.Scheduler.Info($"工单信息开始同步。。。数据检查进行中。。。");
@@ -594,11 +590,8 @@
            }
            Logger.Scheduler.Info($"工单信息存入实体中，总数：[{items.Count}]");
            db = Biz.Db;
            var LastRun = db.Queryable<SYS_PARAM>().Where(q => q.PRMG_CODE == "Interface_LastRun" && q.PARAM_CODE == "GetWo_LastRun").Single();
            LastRun.PARAM_VALUE = (input.endTime.ToDateTime() - DateTime.Now).TotalMinutes > 0 ? LastRun.PARAM_VALUE : input.endTime;
            var dbTran = db.UseTran(() =>
            {
                db.Storageable(LastRun, "U9C_MES_GetWo").ExecuteCommand();
                if (items.Any())
                {
                    if (items.Count > 150)