From 05683f2b2bdbdbe21cf17ad523c21ab338bd1c54 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期二, 19 七月 2022 21:49:55 +0800
Subject: [PATCH] 优化添加设备 功能
---
service-community/src/main/java/com/java110/community/cmd/inspectionTask/UpdateInspectionTaskCmd.java | 82 ++++++++++++++++++++++++++++++++++++++++
1 files changed, 81 insertions(+), 1 deletions(-)
diff --git a/service-community/src/main/java/com/java110/community/cmd/inspectionTask/UpdateInspectionTaskCmd.java b/service-community/src/main/java/com/java110/community/cmd/inspectionTask/UpdateInspectionTaskCmd.java
index 69706f7..ca42d0c 100644
--- a/service-community/src/main/java/com/java110/community/cmd/inspectionTask/UpdateInspectionTaskCmd.java
+++ b/service-community/src/main/java/com/java110/community/cmd/inspectionTask/UpdateInspectionTaskCmd.java
@@ -1,4 +1,84 @@
package com.java110.community.cmd.inspectionTask;
-public class UpdateInspectionTaskCmd {
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.dto.inspectionPlan.InspectionTaskDto;
+import com.java110.intf.common.IFileInnerServiceSMO;
+import com.java110.intf.community.IInspectionTaskInnerServiceSMO;
+import com.java110.intf.community.IInspectionTaskV1InnerServiceSMO;
+import com.java110.po.inspection.InspectionTaskPo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.StringUtil;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+
+import java.util.List;
+
+@Java110Cmd(serviceCode = "inspectionTask.updateInspectionTask")
+public class UpdateInspectionTaskCmd extends Cmd {
+
+ @Autowired
+ private IFileInnerServiceSMO fileInnerServiceSMOImpl;
+
+ @Autowired
+ private IInspectionTaskInnerServiceSMO inspectionTaskInnerServiceSMOImpl;
+
+ @Autowired
+ private IInspectionTaskV1InnerServiceSMO inspectionTaskV1InnerServiceSMOImpl;
+
+ @Override
+ public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
+ Assert.hasKeyAndValue(reqJson, "taskId", "璇锋眰鎶ユ枃涓湭鍖呭惈taskId");
+ Assert.hasKeyAndValue(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈communityId");
+ Assert.hasKeyAndValue(reqJson, "inspectionPlanId", "璇锋眰鎶ユ枃涓湭鍖呭惈inspectionPlanId");
+ }
+
+ @Override
+ public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
+ InspectionTaskDto inspectionTaskDto1 = new InspectionTaskDto();
+ inspectionTaskDto1.setCommunityId(reqJson.getString("communityId"));
+ inspectionTaskDto1.setTaskId(reqJson.getString("taskId"));
+ List<InspectionTaskDto> inspectionTaskDtoList = inspectionTaskInnerServiceSMOImpl.queryInspectionTasks(inspectionTaskDto1);
+ if (inspectionTaskDtoList.size()!= 1) {
+ ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_BUSINESS_VERIFICATION, "鏈壘鍒板贰妫�浠诲姟淇℃伅鎴栨壘鍒板鏉★紒");
+ context.setResponseEntity(responseEntity);
+ return;
+ }
+
+ InspectionTaskDto inspectionTaskDto = new InspectionTaskDto();
+ inspectionTaskDto.setTaskId(reqJson.getString("taskId"));
+ inspectionTaskDto.setCommunityId(reqJson.getString("communityId"));
+ List<InspectionTaskDto> inspectionTaskDtos = inspectionTaskInnerServiceSMOImpl.queryInspectionTasks(inspectionTaskDto);
+
+ Assert.listOnlyOne(inspectionTaskDtos, "鏈壘鍒伴渶瑕佷慨鏀圭殑宸℃浠诲姟 鎴栧鏉℃暟鎹�");
+
+ JSONObject businessInspectionTask = new JSONObject();
+ businessInspectionTask.putAll(BeanConvertUtil.beanCovertMap(inspectionTaskDtos.get(0)));
+
+ InspectionTaskPo inspectionTaskPo = BeanConvertUtil.covertBean(businessInspectionTask, InspectionTaskPo.class);
+ inspectionTaskPo.setActInsTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+ inspectionTaskPo.setActUserId(reqJson.getString("userId"));
+ inspectionTaskPo.setActUserName(reqJson.getString("userName"));
+ inspectionTaskPo.setState(reqJson.getString("state"));
+ if(!StringUtil.isEmpty(reqJson.getString("taskType")) && reqJson.getString("taskType").equals("2000") ){
+// inspectionTaskPo.setOriginalPlanUserId(inspectionTaskPo.getPlanUserId());
+// inspectionTaskPo.setOriginalPlanUserName(inspectionTaskPo.getPlanUserName());
+ inspectionTaskPo.setPlanUserId(reqJson.getString("staffId"));
+ inspectionTaskPo.setPlanUserName(reqJson.getString("staffName"));
+ inspectionTaskPo.setTaskType(reqJson.getString("taskType"));
+ inspectionTaskPo.setTransferDesc(reqJson.getString("transferDesc"));
+ }
+
+ int flag = inspectionTaskV1InnerServiceSMOImpl.updateInspectionTask(inspectionTaskPo);
+ if (flag < 1) {
+ throw new CmdException("鍒犻櫎鏁版嵁澶辫触");
+ }
+ }
}
--
Gitblit v1.8.0