From aad6f31285179bfb8c762ab07587a5886faa43aa Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 31 五月 2020 00:50:15 +0800
Subject: [PATCH] 费用优化处理
---
FeeService/src/main/java/com/java110/fee/listener/fee/SaveFeeInfoListener.java | 79 +++++++++++++++++++++------------------
1 files changed, 42 insertions(+), 37 deletions(-)
diff --git a/FeeService/src/main/java/com/java110/fee/listener/fee/SaveFeeInfoListener.java b/FeeService/src/main/java/com/java110/fee/listener/fee/SaveFeeInfoListener.java
index 4847140..7d348dd 100644
--- a/FeeService/src/main/java/com/java110/fee/listener/fee/SaveFeeInfoListener.java
+++ b/FeeService/src/main/java/com/java110/fee/listener/fee/SaveFeeInfoListener.java
@@ -2,15 +2,16 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
-import com.java110.po.fee.PayFeePo;
-import com.java110.utils.constant.BusinessTypeConstant;
-import com.java110.utils.constant.StatusConstant;
-import com.java110.utils.util.Assert;
-import com.java110.fee.dao.IFeeServiceDao;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.entity.center.Business;
+import com.java110.fee.dao.IFeeServiceDao;
+import com.java110.po.fee.FeeAttrPo;
+import com.java110.po.fee.PayFeePo;
+import com.java110.utils.constant.BusinessTypeConstant;
+import com.java110.utils.constant.StatusConstant;
+import com.java110.utils.util.Assert;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -26,7 +27,7 @@
*/
@Java110Listener("saveFeeInfoListener")
@Transactional
-public class SaveFeeInfoListener extends AbstractFeeBusinessServiceDataFlowListener{
+public class SaveFeeInfoListener extends AbstractFeeBusinessServiceDataFlowListener {
private static Logger logger = LoggerFactory.getLogger(SaveFeeInfoListener.class);
@@ -45,29 +46,30 @@
/**
* 淇濆瓨璐圭敤淇℃伅 business 琛ㄤ腑
+ *
* @param dataFlowContext 鏁版嵁瀵硅薄
- * @param business 褰撳墠涓氬姟瀵硅薄
+ * @param business 褰撳墠涓氬姟瀵硅薄
*/
@Override
protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
JSONObject data = business.getDatas();
- Assert.notEmpty(data,"娌℃湁datas 鑺傜偣锛屾垨娌℃湁瀛愯妭鐐归渶瑕佸鐞�");
+ Assert.notEmpty(data, "娌℃湁datas 鑺傜偣锛屾垨娌℃湁瀛愯妭鐐归渶瑕佸鐞�");
//澶勭悊 businessFee 鑺傜偣
- if(data.containsKey(PayFeePo.class.getSimpleName())){
+ if (data.containsKey(PayFeePo.class.getSimpleName())) {
Object bObj = data.get(PayFeePo.class.getSimpleName());
JSONArray businessFees = null;
- if(bObj instanceof JSONObject){
+ if (bObj instanceof JSONObject) {
businessFees = new JSONArray();
businessFees.add(bObj);
- }else {
- businessFees = (JSONArray)bObj;
+ } else {
+ businessFees = (JSONArray) bObj;
}
//JSONObject businessFee = data.getJSONObject("businessFee");
- for (int bFeeIndex = 0; bFeeIndex < businessFees.size();bFeeIndex++) {
+ for (int bFeeIndex = 0; bFeeIndex < businessFees.size(); bFeeIndex++) {
JSONObject businessFee = businessFees.getJSONObject(bFeeIndex);
doBusinessFee(business, businessFee);
- if(bObj instanceof JSONObject) {
+ if (bObj instanceof JSONObject) {
dataFlowContext.addParamOut("feeId", businessFee.getString("feeId"));
}
}
@@ -76,23 +78,24 @@
/**
* business 鏁版嵁杞Щ鍒� instance
+ *
* @param dataFlowContext 鏁版嵁瀵硅薄
- * @param business 褰撳墠涓氬姟瀵硅薄
+ * @param business 褰撳墠涓氬姟瀵硅薄
*/
@Override
protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
JSONObject data = business.getDatas();
Map info = new HashMap();
- info.put("bId",business.getbId());
- info.put("operate",StatusConstant.OPERATE_ADD);
+ info.put("bId", business.getbId());
+ info.put("operate", StatusConstant.OPERATE_ADD);
//璐圭敤淇℃伅
List<Map> businessFeeInfo = feeServiceDaoImpl.getBusinessFeeInfo(info);
- if( businessFeeInfo != null && businessFeeInfo.size() >0) {
+ if (businessFeeInfo != null && businessFeeInfo.size() > 0) {
reFreshShareColumn(info, businessFeeInfo.get(0));
feeServiceDaoImpl.saveFeeInfoInstance(info);
- if(businessFeeInfo.size() == 1) {
+ if (businessFeeInfo.size() == 1) {
dataFlowContext.addParamOut("feeId", businessFeeInfo.get(0).get("fee_id"));
}
}
@@ -117,49 +120,51 @@
info.put("feeId", businessInfo.get("fee_id"));
}
+
/**
* 鎾ゅ崟
+ *
* @param dataFlowContext 鏁版嵁瀵硅薄
- * @param business 褰撳墠涓氬姟瀵硅薄
+ * @param business 褰撳墠涓氬姟瀵硅薄
*/
@Override
protected void doRecover(DataFlowContext dataFlowContext, Business business) {
String bId = business.getbId();
//Assert.hasLength(bId,"璇锋眰鎶ユ枃涓病鏈夊寘鍚� bId");
Map info = new HashMap();
- info.put("bId",bId);
- info.put("statusCd",StatusConstant.STATUS_CD_VALID);
+ info.put("bId", bId);
+ info.put("statusCd", StatusConstant.STATUS_CD_VALID);
Map paramIn = new HashMap();
- paramIn.put("bId",bId);
- paramIn.put("statusCd",StatusConstant.STATUS_CD_INVALID);
+ paramIn.put("bId", bId);
+ paramIn.put("statusCd", StatusConstant.STATUS_CD_INVALID);
//璐圭敤淇℃伅
List<Map> feeInfo = feeServiceDaoImpl.getFeeInfo(info);
- if(feeInfo != null && feeInfo.size() > 0){
+ if (feeInfo != null && feeInfo.size() > 0) {
reFreshShareColumn(paramIn, feeInfo.get(0));
feeServiceDaoImpl.updateFeeInfoInstance(paramIn);
}
}
-
/**
* 澶勭悊 businessFee 鑺傜偣
- * @param business 鎬荤殑鏁版嵁鑺傜偣
+ *
+ * @param business 鎬荤殑鏁版嵁鑺傜偣
* @param businessFee 璐圭敤鑺傜偣
*/
- private void doBusinessFee(Business business,JSONObject businessFee){
+ private void doBusinessFee(Business business, JSONObject businessFee) {
- Assert.jsonObjectHaveKey(businessFee,"feeId","businessFee 鑺傜偣涓嬫病鏈夊寘鍚� feeId 鑺傜偣");
+ Assert.jsonObjectHaveKey(businessFee, "feeId", "businessFee 鑺傜偣涓嬫病鏈夊寘鍚� feeId 鑺傜偣");
- if(businessFee.getString("feeId").startsWith("-")){
+ if (businessFee.getString("feeId").startsWith("-")) {
//鍒锋柊缂撳瓨
- flushFeeId(business.getDatas());
+ flushFeeId(businessFee, business.getDatas());
//businessFee.put("feeId",GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId));
}
- businessFee.put("bId",business.getbId());
+ businessFee.put("bId", business.getbId());
businessFee.put("operate", StatusConstant.OPERATE_ADD);
//淇濆瓨璐圭敤淇℃伅
feeServiceDaoImpl.saveBusinessFeeInfo(businessFee);
@@ -170,16 +175,16 @@
/**
* 鍒锋柊 灏忓尯ID
*
- * @param data
+ * @param businessFee
*/
- private void flushFeeId(JSONObject data) {
+ private void flushFeeId(JSONObject businessFee, JSONObject data) {
String feeId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId);
- JSONObject businessFee = data.getJSONObject("businessFee");
+
businessFee.put("feeId", feeId);
//鍒疯垂鐢ㄥ睘鎬�
- if (data.containsKey("businessFeeAttr")) {
- JSONArray businessFeeAttrs = data.getJSONArray("businessFeeAttr");
+ if (data.containsKey(FeeAttrPo.class.getSimpleName())) {
+ JSONArray businessFeeAttrs = data.getJSONArray(FeeAttrPo.class.getSimpleName());
for (int businessFeeAttrIndex = 0; businessFeeAttrIndex < businessFeeAttrs.size(); businessFeeAttrIndex++) {
JSONObject businessFeeAttr = businessFeeAttrs.getJSONObject(businessFeeAttrIndex);
businessFeeAttr.put("feeId", feeId);
--
Gitblit v1.8.0