修改内嵌的服务项目保存

8 months ago · d178c8e2a3
parent 03277b5c12
commit d178c8e2a3
1 changed files with 28 additions and 25 deletions
--- a/Myshipping.Application/Service/TrackingSystem/ServiceWorkFlowManageService.cs
+++ b/Myshipping.Application/Service/TrackingSystem/ServiceWorkFlowManageService.cs
@ -236,36 +236,39 @@ namespace Myshipping.Application
                        }
                        else if (tsk.OperType == "Update")
                        {
-                            var runInfo = _serviceWorkFlowRunInfoRepository.AsQueryable()
+                            var runInfo = _serviceWorkFlowRunInfoRepository.AsQueryable().Filter(null, true)
                                 .First(a => a.PK_ID == tsk.Run.PK_ID);

-                            runInfo.IS_YIELD = 1;
-                            runInfo.ACT_DATE = nowDate;
-                            runInfo.UpdatedTime = nowDate;
-                            runInfo.UpdatedUserId = long.Parse(info.Main.OperUserId);
-                            runInfo.UpdatedUserName = info.Main.OperUserName;
-
-                            await _serviceWorkFlowRunInfoRepository.AsUpdateable(runInfo).UpdateColumns(it => new
+                            if (runInfo != null)
                            {
-                                it.ACT_DATE,
-                                it.IS_YIELD,
-                                it.UpdatedTime,
-                                it.UpdatedUserId,
-                                it.UpdatedUserName
-                            }).ExecuteCommandAsync();
+                                runInfo.IS_YIELD = 1;
+                                runInfo.ACT_DATE = nowDate;
+                                runInfo.UpdatedTime = nowDate;
+                                runInfo.UpdatedUserId = long.Parse(info.Main.OperUserId);
+                                runInfo.UpdatedUserName = info.Main.OperUserName;

-                            #region 写入运行日志
-                            var runLog = runInfo.Adapt<ServiceWorkFlowRunLogInfo>();
-                            runLog.PK_ID = IDGen.NextID().ToString();
-                            runLog.RUN_ID = runInfo.PK_ID;
-                            runLog.BATCH_NO = batchNo;
-                            runLog.OPER_TYPE = TrackingRunOperTypeEnum.PUSH_PROJECT.ToString();
-                            runLog.EXEC_RESULT = "SUCC";
-                            runLog.EXEC_NOTE = "Update";
-                            runLog.SOURCE_TYPE = info.Main.SourceType.ToString();
+                                await _serviceWorkFlowRunInfoRepository.AsUpdateable(runInfo).UpdateColumns(it => new
+                                {
+                                    it.ACT_DATE,
+                                    it.IS_YIELD,
+                                    it.UpdatedTime,
+                                    it.UpdatedUserId,
+                                    it.UpdatedUserName
+                                }).ExecuteCommandAsync();

-                            await _serviceWorkFlowRunLogInfoRepository.InsertAsync(runLog);
-                            #endregion
+                                #region 写入运行日志
+                                var runLog = runInfo.Adapt<ServiceWorkFlowRunLogInfo>();
+                                runLog.PK_ID = IDGen.NextID().ToString();
+                                runLog.RUN_ID = runInfo.PK_ID;
+                                runLog.BATCH_NO = batchNo;
+                                runLog.OPER_TYPE = TrackingRunOperTypeEnum.PUSH_PROJECT.ToString();
+                                runLog.EXEC_RESULT = "SUCC";
+                                runLog.EXEC_NOTE = "Update";
+                                runLog.SOURCE_TYPE = info.Main.SourceType.ToString();
+
+                                await _serviceWorkFlowRunLogInfoRepository.InsertAsync(runLog);
+                                #endregion
+                            }
                        }
                    });