From bdcb64f0293f27e2dfb3de12a60f6e8412cb962b Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期四, 26 五月 2022 01:45:22 +0800
Subject: [PATCH] 退费修改为 从证书地址中获取

---
 service-fee/src/main/java/com/java110/fee/cmd/feeCombo/SaveFeeComboCmd.java |   31 ++++++++++++++++++++++++++++---
 1 files changed, 28 insertions(+), 3 deletions(-)

diff --git a/service-fee/src/main/java/com/java110/fee/cmd/feeCombo/SaveFeeComboCmd.java b/service-fee/src/main/java/com/java110/fee/cmd/feeCombo/SaveFeeComboCmd.java
index 162e278..f9055d2 100644
--- a/service-fee/src/main/java/com/java110/fee/cmd/feeCombo/SaveFeeComboCmd.java
+++ b/service-fee/src/main/java/com/java110/fee/cmd/feeCombo/SaveFeeComboCmd.java
@@ -15,6 +15,7 @@
  */
 package com.java110.fee.cmd.feeCombo;
 
+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,10 @@
 import com.java110.core.event.cmd.AbstractServiceCmdListener;
 import com.java110.core.event.cmd.CmdEvent;
 import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.intf.fee.IFeeComboMemberV1InnerServiceSMO;
 import com.java110.intf.fee.IFeeComboV1InnerServiceSMO;
 import com.java110.po.feeCombo.FeeComboPo;
+import com.java110.po.feeComboMember.FeeComboMemberPo;
 import com.java110.utils.exception.CmdException;
 import com.java110.utils.util.Assert;
 import com.java110.utils.util.BeanConvertUtil;
@@ -51,11 +54,13 @@
 
     @Autowired
     private IFeeComboV1InnerServiceSMO feeComboV1InnerServiceSMOImpl;
+    @Autowired
+    private IFeeComboMemberV1InnerServiceSMO feeComboMemberV1InnerServiceSMOImpl;
 
     @Override
     public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
         Assert.hasKeyAndValue(reqJson, "comboName", "璇锋眰鎶ユ枃涓湭鍖呭惈comboName");
-Assert.hasKeyAndValue(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈communityId");
+        Assert.hasKeyAndValue(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈communityId");
 
     }
 
@@ -63,14 +68,34 @@
     @Java110Transactional
     public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
 
-       FeeComboPo feeComboPo = BeanConvertUtil.covertBean(reqJson, FeeComboPo.class);
+        FeeComboPo feeComboPo = BeanConvertUtil.covertBean(reqJson, FeeComboPo.class);
         feeComboPo.setComboId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
         int flag = feeComboV1InnerServiceSMOImpl.saveFeeCombo(feeComboPo);
 
         if (flag < 1) {
             throw new CmdException("淇濆瓨鏁版嵁澶辫触");
         }
-
         cmdDataFlowContext.setResponseEntity(ResultVo.success());
+
+        if(!reqJson.containsKey("configIds")){
+            return ;
+        }
+
+        JSONArray configIds = reqJson.getJSONArray("configIds");
+        FeeComboMemberPo feeComboMemberPo = null;
+        for(int configIndex = 0; configIndex < configIds.size() ; configIndex ++){
+            feeComboMemberPo = new FeeComboMemberPo();
+            feeComboMemberPo.setComboId(feeComboPo.getComboId());
+            feeComboMemberPo.setCommunityId(reqJson.getString("communityId"));
+            feeComboMemberPo.setConfigId(configIds.getString(configIndex));
+            feeComboMemberPo.setMemberId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+
+            flag = feeComboMemberV1InnerServiceSMOImpl.saveFeeComboMember(feeComboMemberPo);
+            if (flag < 1) {
+                throw new CmdException("淇濆瓨鏁版嵁澶辫触");
+            }
+        }
+
+
     }
 }

--
Gitblit v1.8.0