From e23023b93f34286f5a807b0b85e9a0619a297ed7 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: 星期二, 21 二月 2023 23:25:34 +0800
Subject: [PATCH] Merge branch 'master' of http://git.homecommunity.cn/supervip/MicroCommunity

---
 service-common/src/main/java/com/java110/common/cmd/itemRelease/UpdateItemReleaseCmd.java |   86 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 85 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 7ca782b..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;
@@ -23,8 +24,16 @@
 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;
@@ -33,6 +42,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.ArrayList;
+import java.util.List;
 
 
 @Java110CmdDoc(title = "淇敼鐗╁搧鏀捐",
@@ -85,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