From 5fc2fc57afc63a906ec5567e91aeab72d20aab7d Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: 星期一, 16 一月 2023 23:17:50 +0800
Subject: [PATCH] 优化代码
---
service-common/src/main/java/com/java110/common/cmd/itemRelease/UpdateItemReleaseCmd.java | 119 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 118 insertions(+), 1 deletions(-)
diff --git a/service-common/src/main/java/com/java110/common/cmd/itemRelease/UpdateItemReleaseCmd.java b/service-common/src/main/java/com/java110/common/cmd/itemRelease/UpdateItemReleaseCmd.java
index 826d973..0870c49 100644
--- a/service-common/src/main/java/com/java110/common/cmd/itemRelease/UpdateItemReleaseCmd.java
+++ b/service-common/src/main/java/com/java110/common/cmd/itemRelease/UpdateItemReleaseCmd.java
@@ -15,6 +15,7 @@
*/
package com.java110.common.cmd.itemRelease;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
@@ -22,8 +23,17 @@
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.doc.annotation.*;
+import com.java110.dto.itemReleaseType.ItemReleaseTypeDto;
+import com.java110.dto.user.UserDto;
+import com.java110.intf.common.IItemReleaseResV1InnerServiceSMO;
+import com.java110.intf.common.IItemReleaseTypeV1InnerServiceSMO;
import com.java110.intf.common.IItemReleaseV1InnerServiceSMO;
+import com.java110.intf.common.IOaWorkflowActivitiInnerServiceSMO;
+import com.java110.intf.oa.IOaWorkflowInnerServiceSMO;
+import com.java110.intf.user.IUserInnerServiceSMO;
import com.java110.po.itemRelease.ItemReleasePo;
+import com.java110.po.itemReleaseRes.ItemReleaseResPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
@@ -32,7 +42,41 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.util.ArrayList;
+import java.util.List;
+
+@Java110CmdDoc(title = "淇敼鐗╁搧鏀捐",
+ description = "淇敼鐗╁搧鏀捐",
+ httpMethod = "post",
+ url = "http://{ip}:{port}/app/itemRelease.updateItemRelease",
+ resource = "commonDoc",
+ author = "鍚村鏂�",
+ serviceCode = "itemRelease.updateItemRelease"
+)
+
+@Java110ParamsDoc(params = {
+ @Java110ParamDoc(name = "communityId", length = 30, remark = "鏀捐灏忓尯"),
+ @Java110ParamDoc(name = "irId", length = 30, remark = "鏀捐ID"),
+ @Java110ParamDoc(name = "applyCompany", length = 30, remark = "鐢宠鍗曚綅"),
+ @Java110ParamDoc(name = "applyPerson", length = 30, remark = "鐢宠浜�"),
+ @Java110ParamDoc(name = "idCard", length = 30, remark = "韬唤璇�"),
+ @Java110ParamDoc(name = "applyTel", length = 30, remark = "鐢宠鐢佃瘽"),
+ @Java110ParamDoc(name = "passTime", length = 30, remark = "閫氫俊鏃堕棿"),
+ @Java110ParamDoc(name = "amount", length = 30, remark = "鏁伴噺"),
+})
+
+@Java110ResponseDoc(
+ params = {
+ @Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "杩斿洖缂栧彿锛�0 鎴愬姛 鍏朵粬澶辫触"),
+ @Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "鎴愬姛", remark = "鎻忚堪"),
+ }
+)
+
+@Java110ExampleDoc(
+ reqBody="{'irId':'123','typeId':'123','communityId':'123','applyCompany':'123','applyPerson':'123','idCard':'123','applyTel':'123','passTime':'123','amount':'123'}",
+ resBody="{'code':0,'msg':'鎴愬姛'}"
+)
/**
* 绫昏〃杩帮細鏇存柊
* 鏈嶅姟缂栫爜锛歩temRelease.updateItemRelease
@@ -52,24 +96,97 @@
@Autowired
private IItemReleaseV1InnerServiceSMO itemReleaseV1InnerServiceSMOImpl;
+
+
+ @Autowired
+ private IItemReleaseResV1InnerServiceSMO itemReleaseResV1InnerServiceSMOImpl;
+
+ @Autowired
+ private IItemReleaseTypeV1InnerServiceSMO itemReleaseTypeV1InnerServiceSMOImpl;
+
+ @Autowired
+ private IOaWorkflowInnerServiceSMO oaWorkflowInnerServiceSMOImpl;
+
+ @Autowired
+ private IUserInnerServiceSMO userInnerServiceSMOImpl;
+
+ @Autowired
+ private IOaWorkflowActivitiInnerServiceSMO oaWorkflowUserInnerServiceSMOImpl;
+
+ public static final String CODE_PREFIX_ID = "10";
+
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "irId", "irId涓嶈兘涓虹┖");
Assert.hasKeyAndValue(reqJson, "communityId", "communityId涓嶈兘涓虹┖");
+ //鏍￠獙鐗╁搧鏄惁瀛樺湪
+ if(!reqJson.containsKey("resNames")){
+ throw new CmdException("鏈寘鍚墿鍝�");
+ }
+ JSONArray resNames = reqJson.getJSONArray("resNames");
+ if(resNames == null || resNames.size() < 1){
+ throw new CmdException("鏈寘鍚墿鍝�");
+ }
}
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+ String userId = cmdDataFlowContext.getReqHeaders().get("user-id");
+
+ ItemReleaseTypeDto itemReleaseTypeDto = new ItemReleaseTypeDto();
+ itemReleaseTypeDto.setTypeId(reqJson.getString("typeId"));
+ itemReleaseTypeDto.setCommunityId(reqJson.getString("communityId"));
+ List<ItemReleaseTypeDto> itemReleaseTypeDtos = itemReleaseTypeV1InnerServiceSMOImpl.queryItemReleaseTypes(itemReleaseTypeDto);
+ Assert.listOnlyOne(itemReleaseTypeDtos,"鏈寘鍚斁琛岀被鍨�");
+
+ //鏌ヨ鐢ㄦ埛鍚嶇О
+ UserDto userDto = new UserDto();
+ userDto.setUserId(userId);
+ List<UserDto> userDtos = userInnerServiceSMOImpl.getUsers(userDto);
+ Assert.listOnlyOne(userDtos, "鐢ㄦ埛涓嶅瓨鍦�");
+
ItemReleasePo itemReleasePo = BeanConvertUtil.covertBean(reqJson, ItemReleasePo.class);
+ itemReleasePo.setState("");
int flag = itemReleaseV1InnerServiceSMOImpl.updateItemRelease(itemReleasePo);
if (flag < 1) {
- throw new CmdException("鏇存柊鏁版嵁澶辫触");
+ throw new CmdException("淇敼鏁版嵁澶辫触");
}
+ ItemReleaseResPo itemReleaseResPo = null;
+ itemReleaseResPo = new ItemReleaseResPo();
+ itemReleaseResPo.setIrId(itemReleasePo.getIrId());
+ itemReleaseResPo.setCommunityId(itemReleasePo.getCommunityId());
+ flag = itemReleaseResV1InnerServiceSMOImpl.deleteItemReleaseRes(itemReleaseResPo);
+ if (flag < 1) {
+ throw new CmdException("淇敼鏁版嵁澶辫触");
+ }
+
+ JSONArray resNames = reqJson.getJSONArray("resNames");
+ JSONObject resNameObj = null;
+
+ List<ItemReleaseResPo> itemReleaseResPos = new ArrayList<>();
+ for(int resNameIndex = 0; resNameIndex< resNames.size(); resNameIndex++){
+ resNameObj = resNames.getJSONObject(resNameIndex);
+ itemReleaseResPo = new ItemReleaseResPo();
+ itemReleaseResPo.setAmount(resNameObj.getString("amount"));
+ itemReleaseResPo.setResName(resNameObj.getString("resName"));
+ itemReleaseResPo.setResId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+ itemReleaseResPo.setIrId(itemReleasePo.getIrId());
+ itemReleaseResPo.setCommunityId(itemReleasePo.getCommunityId());
+ itemReleaseResPos.add(itemReleaseResPo);
+ }
+
+ flag = itemReleaseResV1InnerServiceSMOImpl.saveItemReleaseReses(itemReleaseResPos);
+
+ if (flag < 1) {
+ throw new CmdException("淇濆瓨鏁版嵁澶辫触");
+ }
+
+
cmdDataFlowContext.setResponseEntity(ResultVo.success());
}
}
--
Gitblit v1.8.0