Sfoglia il codice sorgente

优化common服务启动失败问题

java110 6 anni fa
parent
commit
264407a2ec

+ 2 - 1
CommonService/src/main/java/com/java110/common/CommonServiceApplicationStart.java

@@ -44,7 +44,8 @@ import java.nio.charset.Charset;
         basePackages = {"com.java110.common.listener"})
 @EnableFeignClients(basePackages = {
         "com.java110.core.smo.user",
-        "com.java110.core.smo.complaint"
+        "com.java110.core.smo.complaint",
+        "com.java110.core.smo.purchaseApply"
 })
 public class CommonServiceApplicationStart {
 

+ 47 - 49
StoreService/src/main/java/com/java110/store/listener/storeAttr/UpdateStoreAttrInfoListener.java

@@ -22,7 +22,7 @@ import java.util.Map;
 
 /**
  * 修改商户属性信息 侦听
- *
+ * <p>
  * 处理节点
  * 1、businessStoreAttr:{} 商户属性基本信息节点
  * 2、businessStoreAttrAttr:[{}] 商户属性属性信息节点
@@ -51,35 +51,34 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
 
     /**
      * 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 节点,或没有子节点需要处理");
+
 
         //处理 businessStoreAttr 节点
-        if(data.containsKey("businessStoreAttr")){
-            //处理 businessStoreAttr 节点
-            if(data.containsKey("businessStoreAttr")){
-                Object _obj = data.get("businessStoreAttr");
-                JSONArray businessStoreAttrs = null;
-                if(_obj instanceof JSONObject){
-                    businessStoreAttrs = new JSONArray();
-                    businessStoreAttrs.add(_obj);
-                }else {
-                    businessStoreAttrs = (JSONArray)_obj;
-                }
-                //JSONObject businessStoreAttr = data.getJSONObject("businessStoreAttr");
-                for (int _storeAttrIndex = 0; _storeAttrIndex < businessStoreAttrs.size();_storeAttrIndex++) {
-                    JSONObject businessStoreAttr = businessStoreAttrs.getJSONObject(_storeAttrIndex);
-                    doBusinessStoreAttr(business, businessStoreAttr);
-                    if(_obj instanceof JSONObject) {
-                        dataFlowContext.addParamOut("attrId", businessStoreAttr.getString("attrId"));
-                    }
+        if (data.containsKey("businessStoreAttr")) {
+            Object _obj = data.get("businessStoreAttr");
+            JSONArray businessStoreAttrs = null;
+            if (_obj instanceof JSONObject) {
+                businessStoreAttrs = new JSONArray();
+                businessStoreAttrs.add(_obj);
+            } else {
+                businessStoreAttrs = (JSONArray) _obj;
+            }
+            //JSONObject businessStoreAttr = data.getJSONObject("businessStoreAttr");
+            for (int _storeAttrIndex = 0; _storeAttrIndex < businessStoreAttrs.size(); _storeAttrIndex++) {
+                JSONObject businessStoreAttr = businessStoreAttrs.getJSONObject(_storeAttrIndex);
+                doBusinessStoreAttr(business, businessStoreAttr);
+                if (_obj instanceof JSONObject) {
+                    dataFlowContext.addParamOut("attrId", businessStoreAttr.getString("attrId"));
                 }
             }
         }
@@ -88,8 +87,9 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
 
     /**
      * business to instance 过程
+     *
      * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
+     * @param business        当前业务对象
      */
     @Override
     protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
@@ -97,17 +97,17 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
         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> businessStoreAttrInfos = storeAttrServiceDaoImpl.getBusinessStoreAttrInfo(info);
-        if( businessStoreAttrInfos != null && businessStoreAttrInfos.size() >0) {
-            for (int _storeAttrIndex = 0; _storeAttrIndex < businessStoreAttrInfos.size();_storeAttrIndex++) {
+        if (businessStoreAttrInfos != null && businessStoreAttrInfos.size() > 0) {
+            for (int _storeAttrIndex = 0; _storeAttrIndex < businessStoreAttrInfos.size(); _storeAttrIndex++) {
                 Map businessStoreAttrInfo = businessStoreAttrInfos.get(_storeAttrIndex);
-                flushBusinessStoreAttrInfo(businessStoreAttrInfo,StatusConstant.STATUS_CD_VALID);
+                flushBusinessStoreAttrInfo(businessStoreAttrInfo, StatusConstant.STATUS_CD_VALID);
                 storeAttrServiceDaoImpl.updateStoreAttrInfoInstance(businessStoreAttrInfo);
-                if(businessStoreAttrInfo.size() == 1) {
+                if (businessStoreAttrInfo.size() == 1) {
                     dataFlowContext.addParamOut("attrId", businessStoreAttrInfo.get("attr_id"));
                 }
             }
@@ -117,8 +117,9 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
 
     /**
      * 撤单
+     *
      * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
+     * @param business        当前业务对象
      */
     @Override
     protected void doRecover(DataFlowContext dataFlowContext, Business business) {
@@ -126,24 +127,24 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
         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 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> storeAttrInfo = storeAttrServiceDaoImpl.getStoreAttrInfo(info);
-        if(storeAttrInfo != null && storeAttrInfo.size() > 0){
+        if (storeAttrInfo != null && storeAttrInfo.size() > 0) {
 
             //商户属性信息
             List<Map> businessStoreAttrInfos = storeAttrServiceDaoImpl.getBusinessStoreAttrInfo(delInfo);
             //除非程序出错了,这里不会为空
-            if(businessStoreAttrInfos == null || businessStoreAttrInfos.size() == 0){
-                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败(storeAttr),程序内部异常,请检查! "+delInfo);
+            if (businessStoreAttrInfos == null || businessStoreAttrInfos.size() == 0) {
+                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR, "撤单失败(storeAttr),程序内部异常,请检查! " + delInfo);
             }
-            for (int _storeAttrIndex = 0; _storeAttrIndex < businessStoreAttrInfos.size();_storeAttrIndex++) {
+            for (int _storeAttrIndex = 0; _storeAttrIndex < businessStoreAttrInfos.size(); _storeAttrIndex++) {
                 Map businessStoreAttrInfo = businessStoreAttrInfos.get(_storeAttrIndex);
-                flushBusinessStoreAttrInfo(businessStoreAttrInfo,StatusConstant.STATUS_CD_VALID);
+                flushBusinessStoreAttrInfo(businessStoreAttrInfo, StatusConstant.STATUS_CD_VALID);
                 storeAttrServiceDaoImpl.updateStoreAttrInfoInstance(businessStoreAttrInfo);
             }
         }
@@ -151,23 +152,23 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
     }
 
 
-
     /**
      * 处理 businessStoreAttr 节点
-     * @param business 总的数据节点
+     *
+     * @param business          总的数据节点
      * @param businessStoreAttr 商户属性节点
      */
-    private void doBusinessStoreAttr(Business business,JSONObject businessStoreAttr){
+    private void doBusinessStoreAttr(Business business, JSONObject businessStoreAttr) {
 
-        Assert.jsonObjectHaveKey(businessStoreAttr,"attrId","businessStoreAttr 节点下没有包含 attrId 节点");
+        Assert.jsonObjectHaveKey(businessStoreAttr, "attrId", "businessStoreAttr 节点下没有包含 attrId 节点");
 
-        if(businessStoreAttr.getString("attrId").startsWith("-")){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"attrId 错误,不能自动生成(必须已经存在的attrId)"+businessStoreAttr);
+        if (businessStoreAttr.getString("attrId").startsWith("-")) {
+            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR, "attrId 错误,不能自动生成(必须已经存在的attrId)" + businessStoreAttr);
         }
         //自动保存DEL
-        autoSaveDelBusinessStoreAttr(business,businessStoreAttr);
+        autoSaveDelBusinessStoreAttr(business, businessStoreAttr);
 
-        businessStoreAttr.put("bId",business.getbId());
+        businessStoreAttr.put("bId", business.getbId());
         businessStoreAttr.put("operate", StatusConstant.OPERATE_ADD);
         //保存商户属性信息
         storeAttrServiceDaoImpl.saveBusinessStoreAttrInfo(businessStoreAttr);
@@ -175,8 +176,6 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
     }
 
 
-
-
     public IStoreAttrServiceDao getStoreAttrServiceDaoImpl() {
         return storeAttrServiceDaoImpl;
     }
@@ -186,5 +185,4 @@ public class UpdateStoreAttrInfoListener extends AbstractStoreAttrBusinessServic
     }
 
 
-
 }