From f7b32b8f0143ea03f81ff5a54a5fd1fd208b921b Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期四, 28 五月 2020 15:33:50 +0800
Subject: [PATCH] 优化完成巡检计划
---
FeeService/src/main/java/com/java110/fee/listener/fee/DeleteFeeInfoListener.java | 92 +++++++++++++++++++++++----------------------
1 files changed, 47 insertions(+), 45 deletions(-)
diff --git a/FeeService/src/main/java/com/java110/fee/listener/fee/DeleteFeeInfoListener.java b/FeeService/src/main/java/com/java110/fee/listener/fee/DeleteFeeInfoListener.java
index bd3c9df..9dcbd14 100644
--- a/FeeService/src/main/java/com/java110/fee/listener/fee/DeleteFeeInfoListener.java
+++ b/FeeService/src/main/java/com/java110/fee/listener/fee/DeleteFeeInfoListener.java
@@ -22,7 +22,7 @@
/**
* 鍒犻櫎璐圭敤淇℃伅 渚﹀惉
- *
+ * <p>
* 澶勭悊鑺傜偣
* 1銆乥usinessFee:{} 璐圭敤鍩烘湰淇℃伅鑺傜偣
* 2銆乥usinessFeeAttr:[{}] 璐圭敤灞炴�т俊鎭妭鐐�
@@ -51,36 +51,36 @@
/**
* 鏍规嵁鍒犻櫎淇℃伅 鏌ュ嚭Instance琛ㄤ腑鏁版嵁 淇濆瓨鑷砨usiness琛� 锛堢姸鎬佸啓DEL锛� 鏂逛究鎾ゅ崟鏃剁洿鎺ユ洿鏂板洖鍘�
+ *
* @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("businessFee")){
- //澶勭悊 businessFee 鑺傜偣
- if(data.containsKey("businessFee")){
- Object _obj = data.get("businessFee");
- JSONArray businessFees = null;
- if(_obj instanceof JSONObject){
- businessFees = new JSONArray();
- businessFees.add(_obj);
- }else {
- businessFees = (JSONArray)_obj;
- }
- //JSONObject businessFee = data.getJSONObject("businessFee");
- for (int _feeIndex = 0; _feeIndex < businessFees.size();_feeIndex++) {
- JSONObject businessFee = businessFees.getJSONObject(_feeIndex);
- doBusinessFee(business, businessFee);
- if(_obj instanceof JSONObject) {
- dataFlowContext.addParamOut("feeId", businessFee.getString("feeId"));
- }
+ if (data.containsKey(BusinessTypeConstant.BUSINESS_TYPE_DELETE_FEE_INFO)) {
+ Object _obj = data.get(BusinessTypeConstant.BUSINESS_TYPE_DELETE_FEE_INFO);
+ JSONArray businessFees = null;
+ if (_obj instanceof JSONObject) {
+ businessFees = new JSONArray();
+ businessFees.add(_obj);
+ } else {
+ businessFees = (JSONArray) _obj;
+ }
+ //JSONObject businessFee = data.getJSONObject("businessFee");
+ for (int _feeIndex = 0; _feeIndex < businessFees.size(); _feeIndex++) {
+ JSONObject businessFee = businessFees.getJSONObject(_feeIndex);
+ doBusinessFee(business, businessFee);
+ if (_obj instanceof JSONObject) {
+ dataFlowContext.addParamOut("feeId", businessFee.getString("feeId"));
}
}
+
}
@@ -88,8 +88,9 @@
/**
* 鍒犻櫎 instance鏁版嵁
+ *
* @param dataFlowContext 鏁版嵁瀵硅薄
- * @param business 褰撳墠涓氬姟瀵硅薄
+ * @param business 褰撳墠涓氬姟瀵硅薄
*/
@Override
protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
@@ -98,17 +99,17 @@
//璐圭敤淇℃伅
Map info = new HashMap();
- info.put("bId",business.getbId());
- info.put("operate",StatusConstant.OPERATE_DEL);
+ info.put("bId", business.getbId());
+ info.put("operate", StatusConstant.OPERATE_DEL);
//璐圭敤淇℃伅
List<Map> businessFeeInfos = feeServiceDaoImpl.getBusinessFeeInfo(info);
- if( businessFeeInfos != null && businessFeeInfos.size() >0) {
- for (int _feeIndex = 0; _feeIndex < businessFeeInfos.size();_feeIndex++) {
+ if (businessFeeInfos != null && businessFeeInfos.size() > 0) {
+ for (int _feeIndex = 0; _feeIndex < businessFeeInfos.size(); _feeIndex++) {
Map businessFeeInfo = businessFeeInfos.get(_feeIndex);
- flushBusinessFeeInfo(businessFeeInfo,StatusConstant.STATUS_CD_INVALID);
+ flushBusinessFeeInfo(businessFeeInfo, StatusConstant.STATUS_CD_INVALID);
feeServiceDaoImpl.updateFeeInfoInstance(businessFeeInfo);
- dataFlowContext.addParamOut("feeId",businessFeeInfo.get("fee_id"));
+ dataFlowContext.addParamOut("feeId", businessFeeInfo.get("fee_id"));
}
}
@@ -117,54 +118,55 @@
/**
* 鎾ゅ崟
* 浠巄usiness琛ㄤ腑鏌ヨ鍒癉EL鐨勬暟鎹� 灏唅nstance涓殑鏁版嵁鏇存柊鍥炴潵
+ *
* @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_INVALID);
+ info.put("bId", bId);
+ info.put("statusCd", StatusConstant.STATUS_CD_INVALID);
Map delInfo = new HashMap();
- delInfo.put("bId",business.getbId());
- delInfo.put("operate",StatusConstant.OPERATE_DEL);
+ delInfo.put("bId", business.getbId());
+ delInfo.put("operate", StatusConstant.OPERATE_DEL);
//璐圭敤淇℃伅
List<Map> feeInfo = feeServiceDaoImpl.getFeeInfo(info);
- if(feeInfo != null && feeInfo.size() > 0){
+ if (feeInfo != null && feeInfo.size() > 0) {
//璐圭敤淇℃伅
List<Map> businessFeeInfos = feeServiceDaoImpl.getBusinessFeeInfo(delInfo);
//闄ら潪绋嬪簭鍑洪敊浜嗭紝杩欓噷涓嶄細涓虹┖
- if(businessFeeInfos == null || businessFeeInfos.size() == 0){
- throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"鎾ゅ崟澶辫触锛坒ee锛夛紝绋嬪簭鍐呴儴寮傚父,璇锋鏌ワ紒 "+delInfo);
+ if (businessFeeInfos == null || businessFeeInfos.size() == 0) {
+ throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR, "鎾ゅ崟澶辫触锛坒ee锛夛紝绋嬪簭鍐呴儴寮傚父,璇锋鏌ワ紒 " + delInfo);
}
- for (int _feeIndex = 0; _feeIndex < businessFeeInfos.size();_feeIndex++) {
+ for (int _feeIndex = 0; _feeIndex < businessFeeInfos.size(); _feeIndex++) {
Map businessFeeInfo = businessFeeInfos.get(_feeIndex);
- flushBusinessFeeInfo(businessFeeInfo,StatusConstant.STATUS_CD_VALID);
+ flushBusinessFeeInfo(businessFeeInfo, StatusConstant.STATUS_CD_VALID);
feeServiceDaoImpl.updateFeeInfoInstance(businessFeeInfo);
}
}
}
-
/**
* 澶勭悊 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("-")){
- throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"feeId 閿欒锛屼笉鑳借嚜鍔ㄧ敓鎴愶紙蹇呴』宸茬粡瀛樺湪鐨刦eeId锛�"+businessFee);
+ if (businessFee.getString("feeId").startsWith("-")) {
+ throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR, "feeId 閿欒锛屼笉鑳借嚜鍔ㄧ敓鎴愶紙蹇呴』宸茬粡瀛樺湪鐨刦eeId锛�" + businessFee);
}
//鑷姩鎻掑叆DEL
- autoSaveDelBusinessFee(business,businessFee);
+ autoSaveDelBusinessFee(business, businessFee);
}
public IFeeServiceDao getFeeServiceDaoImpl() {
--
Gitblit v1.8.0