代码提交

wankeda

2025-04-25 b3afd18d58cc94bb94b8a91030d1b2fa89f637e6

 代码管理/NEWCode/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskCZService.cs

@@ -96,23 +96,23 @@
                    response.Error("浠诲姟涓嶅瓨鍦紒");
                    return Task.FromResult(response);
                }
                if (dto.Tags.Contains("姝ｆ瀬"))
                {
                    czTask.TaskZJFinishNumber += 1;
                }
                else
                {
                    czTask.TaskFJFinishNumber += 1;
                }
                if (czTask.TaskZJFinishNumber == czTask.TaskNumber || czTask.TaskFJFinishNumber == czTask.TaskNumber)
                {
                    czTask.TaskStatus = TaskInStatusEnum.InFinish.ToString();
                    czTask.TaskEndDate = DateTime.Now;
                }
                else
                {
                    czTask.TaskStatus = TaskInStatusEnum.Line_InExecuting.ToString();
                }
                //if (dto.Tags.Contains("姝ｆ瀬"))
                //{
                //    czTask.TaskZJFinishNumber += 1;
                //}
                //else
                //{
                //    czTask.TaskFJFinishNumber += 1;
                //}
                //if (czTask.TaskZJFinishNumber == czTask.TaskNumber || czTask.TaskFJFinishNumber == czTask.TaskNumber)
                //{
                //    czTask.TaskStatus = TaskInStatusEnum.InFinish.ToString();
                //    czTask.TaskEndDate = DateTime.Now;
                //}
                //else
                //{
                czTask.TaskStatus = TaskInStatusEnum.Line_InExecuting.ToString();
                //}

                var details = new DtCZTaskDetails()
                {
@@ -123,6 +123,7 @@
                    TaskName = czTask.TaskName,
                    TaskType = czTask.TaskType,
                    TaskStatus = czTask.TaskStatus,
                    TaskTaskID = czTask.TaskTaskID,
                };
                _detailsRepository.AddData(details);

@@ -175,7 +176,7 @@
            {
                string Saddress = saveModel.MainData["sourceAddress"].ToString();
                string Taddress = saveModel.MainData["targetAddress"].ToString();

                string Exception = saveModel.MainData["Exception"].ToString();
                Dt_Task task = _taskRepository.QueryFirst(x => x.SourceAddress == Saddress && x.TaskState == (int)TaskInStatusEnum.InPending && x.TargetAddress == "WaitBind");
                if (task == null)
                {
@@ -183,6 +184,7 @@
                    return Task.FromResult(webResponseContent);
                }
                task.TargetAddress = Taddress;
                task.ExceptionMessage = Exception;
                task.TaskState = (int)TaskInStatusEnum.InNew;
                var isTrue = _taskRepository.UpdateData(task);
                if (isTrue)