From b933bf8cfb7e0b3d231e7bc721b749fae54e911a Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期二, 23 四月 2019 18:03:24 +0800
Subject: [PATCH] 删除feign工程
---
UserService/src/main/java/com/java110/user/smo/impl/UserServiceSMOImpl.java | 771 ++--------------------------------------------------------
1 files changed, 34 insertions(+), 737 deletions(-)
diff --git a/UserService/src/main/java/com/java110/user/smo/impl/UserServiceSMOImpl.java b/UserService/src/main/java/com/java110/user/smo/impl/UserServiceSMOImpl.java
index 0e14431..6a169c9 100644
--- a/UserService/src/main/java/com/java110/user/smo/impl/UserServiceSMOImpl.java
+++ b/UserService/src/main/java/com/java110/user/smo/impl/UserServiceSMOImpl.java
@@ -16,9 +16,7 @@
import com.java110.common.util.ProtocolUtil;
import com.java110.core.base.smo.BaseServiceSMO;
import com.java110.core.context.BusinessServiceDataFlow;
-import com.java110.core.context.DataFlow;
import com.java110.core.factory.DataFlowFactory;
-import com.java110.core.factory.DataTransactionFactory;
import com.java110.entity.center.DataFlowLinksCost;
import com.java110.entity.center.DataFlowLog;
import com.java110.entity.order.BusiOrder;
@@ -27,7 +25,6 @@
import com.java110.entity.user.Cust;
import com.java110.entity.user.CustAttr;
import com.java110.event.service.BusinessServiceDataFlowEventPublishing;
-import com.java110.feign.base.IPrimaryKeyService;
import com.java110.user.dao.IUserServiceDao;
import com.java110.user.smo.IUserServiceSMO;
import org.apache.commons.lang3.StringUtils;
@@ -38,7 +35,11 @@
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.ObjectUtils;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
/**
* 鐢ㄦ埛鏈嶅姟淇℃伅绠＄悊涓氬姟淇℃伅瀹炵幇
@@ -48,733 +49,34 @@
@Transactional
public class UserServiceSMOImpl extends BaseServiceSMO implements IUserServiceSMO {
- private final static Logger logger = LoggerFactory.getLogger(UserServiceSMOImpl.class);
+ private static Logger logger = LoggerFactory.getLogger(UserServiceSMOImpl.class);
- //@Autowired
- IPrimaryKeyService iPrimaryKeyService;
@Autowired
IUserServiceDao iUserServiceDao;
//鏂板鐢ㄦ埛
- private final static String USER_ACTION_ADD = "ADD";
+ private static final String USER_ACTION_ADD = "ADD";
//鏂板鐢ㄦ埛
- private final static String USER_ACTION_KIP = "KIP";
+ private static final String USER_ACTION_KIP = "KIP";
//鏂板鐢ㄦ埛
- private final static String USER_ACTION_DEL = "DEL";
-
- /**
- * 淇濆瓨鐢ㄦ埛淇℃伅
- *
- * @param userInfoJson 鍏ュ弬涓虹敤鎴蜂俊鎭痡son浼�
- * @return
- */
- public String saveUser(String userInfoJson) throws Exception{
-
- JSONObject reqUserJSON = null;
- try {
- reqUserJSON = this.simpleValidateJSON(userInfoJson);
- //boCust澧炲姞Action (鍔ㄤ綔)
- if (reqUserJSON.containsKey("boCust")) {
- JSONObject boCust = reqUserJSON.getJSONObject("boCust");
- boCust.put("state", USER_ACTION_ADD);
- }
- //boCustAttr澧炲姞Action锛堝姩浣滐級
- if (reqUserJSON.containsKey("boCustAttr")) {
- JSONArray boCustAttrs = reqUserJSON.getJSONArray("boCustAttr");
-
- for (int attrIndex = 0; attrIndex < boCustAttrs.size(); attrIndex++) {
- JSONObject boCustAttr = boCustAttrs.getJSONObject(attrIndex);
- boCustAttr.put("state", USER_ACTION_ADD);
- }
- }
- } catch (RuntimeException e) {
- //杩斿洖寮傚父淇℃伅
- return e.getMessage();
- }
- return soUserService(reqUserJSON);
- }
-
-
- /**
- * 鎵�鏈夋湇鍔″鐞嗙被
- * {
- *
- * 'boCust':[{}],
- * 'boCustAttr':[{}]
- * }
- *
- * 杩斿洖鎶ユ枃锛�
- *
- * {'RESULT_CODE':'0000','RESULT_MSG':'鎴愬姛','RESULT_INFO':{'custId':'7000123,718881991'}}
- * @param userInfoJson
- * @return
- */
- public String soUserService(JSONObject userInfoJson) throws Exception{
- LoggerEngine.debug("鐢ㄦ埛鏈嶅姟鎿嶄綔瀹㈡埛鍏ュ弬锛�" + userInfoJson);
- JSONObject paramJson = new JSONObject();
-
- JSONObject resultInfo = null;
-
- //瀛樻斁鐢熸垚鐨刢ustId 涓婚敭涓� custId-1 71000010100
- Map custIdKey = new HashMap();
-
- if (userInfoJson == null){
- throw new IllegalArgumentException("soUserService 鍏ュ弬 涓虹┖"+userInfoJson);
- }
-
- // 瀹㈡埛淇℃伅澶勭悊 澶勭悊boCust鑺傜偣
- doProcessBoCust(userInfoJson, paramJson, custIdKey, resultInfo);
-
- //瀹㈡埛灞炴�т俊鎭鐞� 澶勭悊boCustAttr鑺傜偣
- doProcessBoCustAttr(userInfoJson, paramJson, custIdKey, resultInfo);
-
- return ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_SUCCESS,"鎴愬姛",resultInfo);
-
- }
-
- /**
- *
- * 璇锋眰鎶ユ枃涓猴細
- *
- * {
- "data": [
- {
- "actionTypeCd": "C1",
- "boCust": [{},{}],
- "boCustAttr": [{ }, {}]
- },
- {
- "actionTypeCd": "C1",
- "boCust": [{},{}],
- "boCustAttr": [{ }, {}]
- }
- ]
- }
-
- 杩斿洖鎶ユ枃 锛�
-
- { 'RESULT_CODE': '0000', 'RESULT_MSG': '鎴愬姛', 'RESULT_INFO': {'cust':[{'oldCustId':'-1','custId':'12345678'},{'oldCustId':'-2','custId':'12345678'}]} }
- * @param userInfoJson
- * @return
- * @throws Exception
- */
- @Override
- public String soUserServiceForOrderService(JSONObject userInfoJson) throws Exception {
-
- Assert.isNotNull(userInfoJson,"data","璇锋眰鎶ユ枃缂哄皯 data 鑺傜偣锛岃妫�鏌�");
-
- JSONArray custInfos = userInfoJson.getJSONArray("data");
-
- Assert.isNull(custInfos,"璇锋眰鎶ユ枃涓璬ata鑺傜偣锛屾病鏈夊瓙鑺傜偣锛宒ata瀛愯妭鐐瑰簲璇ヤ负JSONArray,custInfos="+custInfos);
-
- JSONObject custInfoJ = new JSONObject();
- JSONArray resultCustIdArray = new JSONArray();
- for(int custInfoIndex = 0 ;custInfoIndex < custInfos.size();custInfoIndex ++){
- JSONObject custInfoJson = custInfos.getJSONObject(custInfoIndex);
- String soUserServiceResult = this.soUserService(custInfoJson);
- JSONObject resultInfo = new JSONObject();
-
- if(!ProtocolUtil.validateReturnJson(soUserServiceResult,resultInfo)){
- throw new RuntimeException("瀹㈡埛淇℃伅鍙楃悊澶辫触锛屽師鍥犱负锛�"+resultInfo.getString(ProtocolUtil.RESULT_MSG));
- }
- if(resultInfo.getJSONObject(ProtocolUtil.RESULT_INFO) != null
- && resultInfo.getJSONObject(ProtocolUtil.RESULT_INFO).containsKey("custId")) {
-
- String custIds = custInfoJ.getString("custId");
-// custIds += "," + resultInfo.getJSONObject(ProtocolUtil.RESULT_INFO).getString("custId");
-
-// custIds = custIds.startsWith(",") && custIds.length()>1 ? custIds.substring(1,custIds.length()):custIds;
- //custInfoJ.put("custId", custIds);
- JSONArray boCusts = custInfoJson.getJSONArray("boCust");
-
- Object custIdObj = JSONPath.eval(custInfoJson,"$.boCust[custId < '0'][0].custId");
- if(StringUtils.isNotBlank(custIds) && !ObjectUtils.isEmpty(custIdObj)) {
-
- String[] allNewCustIds = custIds.split(",");
- JSONObject newCustIdJson = null;
- for (String custId : allNewCustIds) {
- newCustIdJson = new JSONObject();
- newCustIdJson.put("oldCustId",custIdObj);
- newCustIdJson.put("custId",custId);
- resultCustIdArray.add(newCustIdJson);
- }
-
- }
- }
-
- }
-
- custInfoJ.put("cust",resultCustIdArray);
-
- return ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_SUCCESS,"鎴愬姛",custInfoJ);
- }
-
- /**
- * {
- * boCust:[{},{}]
- * }
- * 瀹㈡埛淇″績澶勭悊
- *
- *
- * @param boCusts
- * @return 鎴愬姛 浼氬甫涓婂鐞嗗鎴风殑瀹㈡埛ID
- * {'RESULT_CODE':'0000','RESULT_MSG':'鎴愬姛','RESULT_INFO':{'custId':'7000123,718881991'}}
- * @throws Exception
- */
- public String soBoCust(String boCusts) throws Exception{
- return soBoCust(boCusts,null);
- }
-
- /**
- * 灏嗙敓鎴愮殑custId 灏佽鍦╩ap涓繑鍥�
- * ...
- * custIdKey.put("custId-1","710020404040");
- *
- * ...
- *
- * key 涓� custId 鍔犲師鍓嶇殑鍊�
- *
- * custIdKey 濡傛灉涓虹┖涓嶅仛澶勭悊
- * @param boCusts 瀹㈡埛淇℃伅
- * @param custIdKey custIdKeymap
- * @return
- * @throws Exception
- */
- public String soBoCust(String boCusts,Map custIdKey) throws Exception{
- // 灏� jsonArray 杞负list<BoCust> 瀵硅薄
- JSONObject jsonObject = JSONObject.parseObject(boCusts);
-
- JSONObject resultInfo = new JSONObject();
-
- String custIds = "";
-
- List<BoCust> boCustList = JSONObject.parseArray(jsonObject.getJSONArray("boCust").toJSONString(), BoCust.class);
-
- Collections.sort(boCustList);
- //淇濆瓨鏁版嵁
-
- for(BoCust boCust : boCustList){
-// for(int boCustIndex = 0 ; boCustIndex < boCustList.size();boCustIndex++){
-// BoCust boCust = boCustList.get(boCustIndex);
- String custId = boCust.getBoId();
- //濡傛灉瀹㈡埛ID灏忎簬0 锛屽垯鑷繁鐢熸垚瀹㈡埛ID,杩欎釜鍙湁鍦ㄦ湁 涓婚敭鐢熸垚鏈嶅姟鏃朵娇鐢紝鍚﹀垯涓轰簡闃叉鍑洪敊锛岄渶瑕佸墠娈佃皟鐢ㄦ椂闇�瑕佺敓鎴恈ustId
- if(StringUtils.isBlank(custId) || custId.startsWith("-") ){
- /*JSONObject data = new JSONObject();
- data.put("type","CUST_ID");
- //瑕佹眰鎺ュ彛杩斿洖 {"RESULT_CODE":"0000","RESULT_INFO":{"user_id":"7020170411000041"},"RESULT_MSG":"鎴愬姛"}
- String custIdJSONStr = iPrimaryKeyService.queryPrimaryKey(data.toJSONString());
- JSONObject custIdJSONTmp = JSONObject.parseObject(custIdJSONStr);
- if(custIdJSONTmp.containsKey("RESULT_CODE")
- && ProtocolUtil.RETURN_MSG_SUCCESS.equals(custIdJSONTmp.getString("RESULT_CODE"))
- && custIdJSONTmp.containsKey("RESULT_INFO")){
- //浠庢帴鍙ｇ敓鎴恈ustId
- custId = NumberUtils.toInt(custIdJSONTmp.getJSONObject("RESULT_INFO").getString("CUST_ID"),-1);
- }*/
-
- custId = this.queryPrimaryKey(iPrimaryKeyService,"CUST_ID");
-
- //灏� 鏂扮敓鎴愮殑custId淇濆瓨鑷� map涓� custId-1 custId-2 涓婚敭鏂瑰紡瀛樺叆
- if(custIdKey != null){
- custIdKey.put("custId"+boCust.getCustId(),custId);
- }
- }
-
- boCust.setCustId(custId);
-
- //淇濆瓨鏁版嵁鑷� bo_cust 琛ㄤ腑
- int saveBoCustFlag = iUserServiceDao.saveDataToBoCust(boCust);
-
- if(saveBoCustFlag < 1){ // 濡傛灉娌℃湁淇濆瓨鎴愬姛锛屾姏鍑哄紓甯革紝鏈変簨鐗� 鍥為��浜嬬墿
- throw new RuntimeException("淇濆瓨杩囩▼[bo_cust]鏁版嵁澶辫触,鍗拌薄璁板綍鏁颁负"+saveBoCustFlag+"锛宐oCust : "+boCust);
- }
- //寤烘。 澶勭悊 瀹炰緥鏁版嵁
- int saveCustFlag = 0;
- if("ADD".equals(boCust.getState())){
- /* List<BoCust> boCustsTmp = boCustList;
- //鍦ㄥ鍔犱箣闂撮鍏堣鍒ゆ柇鏄惁鏈夌浉搴斿垹鐨勫姩浣�
-// for(BoCust boCustTmp : boCustsTmp){
- for(int boCustTmpIndex = boCustIndex+1;boCustTmpIndex < boCustsTmp.size();boCustTmpIndex++){
- BoCust boCustTmp = boCustsTmp.get(boCustTmpIndex);
- if(StringUtils.isNotBlank(boCust.getCustId())
- && boCust.getCustId().equals(boCustTmp.getCustId())
- &&"DEL".equals(boCustTmp.getState())){
- //鍏堣皟鐢ㄥ垹闄ゅ鎴蜂俊鎭�
- saveCustFlag = iUserServiceDao.deleteDataToCust(boCust.convert());
-
- if(saveCustFlag < 1){
- throw new RuntimeException("鍒犻櫎瀹炰緥[cust]鏁版嵁澶辫触锛屽奖鍝嶈褰曟暟涓�"+saveCustFlag+", cust : "+boCust.convert());
- }
-
- //鍒欐妸宸茬粡鍒犻櫎杩囩殑浠巐ist涓垹闄わ紝浠ラ槻閲嶅鍒犻櫎
- boCustList.remove(boCustTmp);
-
- }
- }*/
-
- saveCustFlag = iUserServiceDao.saveDataToCust(boCust.convert());
- }else if("DEL".equals(boCust.getState())){
- saveCustFlag = iUserServiceDao.deleteDataToCust(boCust.convert());
- }else if("KIP".equals(boCust.getState())){
- //鎸夌悊杩欓噷鍒颁笉浜嗭紝KIP琛ㄧず瀹炰緥鏁版嵁涓嶅彉锛屾墍浠ヨ繖閲岄粯璁ゅ啓鎴�1 璁や负鏄垚鍔�
- saveCustFlag = 1;
- }else{
- //杩欓噷鍗曠嫭鎶涘嚭寮傚父锛屼笉璧颁笅闈㈢粺涓�寮傚父鎶涘嚭锛屾槸涓轰簡璇存槑鏇村叿浣撶偣
- throw new RuntimeException("鍏ュ弬閿欒boCust 鐨� state 鐩墠鍙敮鎸� [ADD,DEL,KIP] , boCust : " +boCust);
- }
-
-
- if(saveCustFlag < 1){
- throw new RuntimeException("淇濆瓨瀹炰緥[cust]鏁版嵁澶辫触锛屽奖鍝嶈褰曟暟涓�"+saveCustFlag+", cust : "+boCust.convert());
- }
-
- custIds +=","+custId;
-
- }
-
- //鍘婚櫎绗竴涓�楀彿
- if (custIds.length()>0){
- custIds = custIds.substring(1);
- }
-
- resultInfo.put("custId",custIds);
-
- return ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_SUCCESS,"鎴愬姛",resultInfo);
- }
-
- /**
- * 娉ㄦ剰鍦ㄨ皟鐢ㄨ繖涓帴鍙ｆ椂锛岀浉搴旂殑瀹㈡埛淇℃伅蹇呴』瀛樺湪
- *
- *
- * 瀹㈡埛淇℃伅灞炴�у鐞�
- * 鍗忚锛�
- *{
- * boCustAttr:[{},{}]
- * }
- * @param boCustAttrs
- * @return
- * @throws Exception
- */
- @Override
- public String soBoCustAttr(String boCustAttrs) throws Exception {
-
- //杩欓噷鍙互鍔犲叆鍩烘湰瀹㈡埛淇℃伅鏄惁瀛樺湪鐨勬牎楠岋紝鏆傛椂娌℃湁蹇呰瀹炵幇
-
- // 灏� jsonArray 杞负list<BoCust> 瀵硅薄
- JSONObject jsonObject = JSONObject.parseObject(boCustAttrs);
-
- List<BoCustAttr> boCustAttrList = JSONObject.parseArray(jsonObject.getJSONArray("boCustAttr").toJSONString(), BoCustAttr.class);
-
- //鍏堟媿涓簭 鍏堝鐞咲EL 鍐嶅鐞咥DD
- Collections.sort(boCustAttrList);
- //淇濆瓨鏁版嵁
-
- for(BoCustAttr boCustAttr : boCustAttrList) {
-
- //淇濆瓨鏁版嵁鑷� bo_cust_attr 琛ㄤ腑
- int saveBoCustAttrFlag = iUserServiceDao.saveDataToBoCustAttr(boCustAttr);
-
- if(saveBoCustAttrFlag < 1){ // 濡傛灉娌℃湁淇濆瓨鎴愬姛锛屾姏鍑哄紓甯革紝鏈変簨鐗� 鍥為��浜嬬墿
- throw new RuntimeException("淇濆瓨杩囩▼[bo_cust_attr]鏁版嵁澶辫触,鍗拌薄璁板綍鏁颁负"+saveBoCustAttrFlag+"锛宐oCustAttr : "+boCustAttr);
- }
-
- //寤烘。 澶勭悊 瀹炰緥鏁版嵁
- int saveCustAttrFlag = 0;
- if("ADD".equals(boCustAttr.getState())){
- saveCustAttrFlag = iUserServiceDao.saveDataToCustAttr(boCustAttr.convert());
- }else if("DEL".equals(boCustAttr.getState())){
- saveCustAttrFlag = iUserServiceDao.deleteDataToCustAttr(boCustAttr.convert());
- }else if("KIP".equals(boCustAttr.getState())){
- //鎸夌悊杩欓噷鍒颁笉浜嗭紝KIP琛ㄧず瀹炰緥鏁版嵁涓嶅彉锛屾墍浠ヨ繖閲岄粯璁ゅ啓鎴�1 璁や负鏄垚鍔�
- saveCustAttrFlag = 1;
- }else{
- //杩欓噷鍗曠嫭鎶涘嚭寮傚父锛屼笉璧颁笅闈㈢粺涓�寮傚父鎶涘嚭锛屾槸涓轰簡璇存槑鏇村叿浣撶偣
- throw new RuntimeException("鍏ュ弬閿欒boCustAttr 鐨� state 鐩墠鍙敮鎸� [ADD,DEL,KIP] , boCust : " +boCustAttr);
- }
-
- if(saveCustAttrFlag < 1){
- throw new RuntimeException("淇濆瓨瀹炰緥[cust_attr]鏁版嵁澶辫触锛屽奖鍝嶈褰曟暟涓�"+saveCustAttrFlag+", cust : "+boCustAttr.convert());
- }
- }
-
- return ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_SUCCESS,"鎴愬姛",null);
- }
-
- /**
- * 浣滃簾瀹㈡埛淇℃伅
- * [{},{},{}]
- *
- * @param datas
- * @return
- * @throws Exception
- */
- @Override
- public String soDeleteCustInfo(JSONArray datas) throws Exception {
-
- Assert.isNull(datas,"浼犲叆鐨刣ata鑺傜偣涓嬫病鏈変换浣曞唴瀹�");
-
- for(int boIdIndex = 0 ; boIdIndex < datas.size(); boIdIndex++){
- JSONObject data = datas.getJSONObject(boIdIndex);
-
- Assert.isNotNull(data,"boId","褰撳墠鑺傜偣涓病鏈夊寘鍚玝oId鑺傜偣鏍煎紡閿欒"+data);
-
- // 澶嶅師Cust
- doDeleteBoCust(data);
-
- // 澶嶅師CustAttr
- doDeleteBoCustAttr(data);
-
- }
-
-
- return null;
- }
-
-
- /**
- * 鏌ヨ瀹㈡埛淇℃伅
- * 鍖呮嫭 鍩烘湰淇℃伅cust 鍜� 灞炴�т俊鎭� custAttr
- * @param cust
- * @return
- * @throws Exception
- */
- public String queryCust(Cust cust) throws Exception{
- LoggerEngine.debug("瀹㈡埛淇℃伅鏌ヨ鍏ュ弬锛�" + cust);
- if(cust == null || StringUtils.isBlank(cust.getCustId()) ){
- throw new IllegalArgumentException("瀹㈡埛淇℃伅鏌ヨ鍏ュ弬涓虹┖锛宑ustId 涓虹┖ "+cust);
- }
- Cust newCust = iUserServiceDao.queryDataToCust(cust);
-
- if(newCust == null){
- return ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"鏈壘鍒扮敤鎴蜂俊鎭�",null);
- }
-
- return ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_SUCCESS,"鎴愬姛",JSONObject.parseObject(JSONObject.toJSONString(newCust)));
- }
-
- /**
- * 鏍规嵁olID鏌ヨ瀹㈡埛淇℃伅
- * @param busiOrderStr
- * @return
- * @throws Exception
- */
- public String queryCustInfoByOlId(String busiOrderStr) throws Exception{
- return doQueryCustInfoByOlId(busiOrderStr,false);
- }
-
- /**
- * 鏍规嵁olID鏌ヨ瀹㈡埛淇℃伅 闇�瑕佷綔搴熺殑鍙戣捣鐨勬姤鏂�
- * @param busiOrderStr
- * @return
- * @throws Exception
- */
- public String queryNeedDeleteCustInfoByOlId(String busiOrderStr) throws Exception{
- return doQueryCustInfoByOlId(busiOrderStr,true);
- }
-
- /**
- * 鏌ヨ瀹㈡埛璁㈠崟淇℃伅
- * @param busiOrderStr 璁㈠崟椤逛俊鎭�
- * @param isNeedDelete 鏄惁鏄挙鍗曟姤鏂� true 鏌ヨ鎾ゅ崟鎶ユ枃 false
- * @return
- * @throws Exception
- */
- private String doQueryCustInfoByOlId(String busiOrderStr,Boolean isNeedDelete) throws Exception{
- BusiOrder busiOrder = JSONObject.parseObject(busiOrderStr, BusiOrder.class);
-
- if(busiOrder == null || "".equals(busiOrder.getOlId())){
- throw new IllegalArgumentException("瀹㈡埛淇℃伅鏌ヨ鍏ュ弬涓虹┖锛宱lId 涓虹┖ "+busiOrderStr);
- }
-
- Cust cust = new Cust();
- cust.setVersionId(busiOrder.getOlId());
- //鏍规嵁鐗堟湰ID鏌ヨ瀹炰緥鏁版嵁
- Cust newCust = iUserServiceDao.queryDataToCust(cust);
- JSONObject returnJson = JSONObject.parseObject("{'data':{}}");
- if(newCust == null){
- return returnJson.toJSONString();
- }
-
- BoCust boCust = new BoCust();
-
- boCust.setBoId(busiOrder.getBoId());
- boCust.setCustId(newCust.getCustId());
- boCust.setVersionId(busiOrder.getOlId());
-
- List<BoCust> boCusts = iUserServiceDao.queryBoCust(boCust);
-
-
- //涓�鑸儏鍐典笅娌℃湁杩欑鎯呭喌瀛樺湪锛岄櫎闈� 浜哄伐 鏀逛簡鏁版嵁锛屾垨娌℃寜娴佺▼瀹屾垚鏁版嵁澶勭悊
- if(boCusts == null || boCusts.size() == 0){
- return returnJson.toJSONString();
- }
-
-
- JSONArray boCustArray = new JSONArray();
- //鍗曠函鐨勫垹闄� 鍜屽崟绾� 澧炲姞
- for(int boCustIndex = 0 ; boCustIndex < boCusts.size();boCustIndex++) {
- BoCust newBoCust = boCusts.get(boCustIndex);
- if(isNeedDelete) {
- if (StateConstant.STATE_DEL.equals(newBoCust.getState())) {
- newBoCust.setBoId("");
- newBoCust.setState(StateConstant.STATE_ADD);
- } else if (StateConstant.STATE_ADD.equals(newBoCust.getState())) {
- newBoCust.setState(StateConstant.STATE_DEL);
- } else {
- newBoCust.setState(StateConstant.STATE_KIP);
- }
- }
- boCustArray.add(newBoCust);
- }
- returnJson.getJSONObject("data").put("boCust",JSONObject.toJSONString(boCustArray));
-
-
- //灞炴�у鐞�
- CustAttr oldCustAttr = new CustAttr();
- oldCustAttr.setCustId(newCust.getCustId());
- oldCustAttr.setVersionId(busiOrder.getOlId());
- List<CustAttr> custAttrs = iUserServiceDao.queryDataToCustAttr(oldCustAttr);
- if(custAttrs == null || custAttrs.size() == 0){
- return returnJson.toJSONString();
- }
- /**
- * 鏌ヨ瀹㈡埛鏌ヨ鐨勮繃绋嬫暟鎹�
- */
- BoCustAttr boCustAttr = new BoCustAttr();
- boCustAttr.setCustId(newCust.getCustId());
- boCustAttr.setVersionId(busiOrder.getOlId());
- List<BoCustAttr> boCustAttrs = iUserServiceDao.queryBoCustAttr(boCustAttr);
-
-
- //涓�鑸儏鍐典笅娌℃湁杩欑鎯呭喌瀛樺湪锛岄櫎闈� 浜哄伐 鏀逛簡鏁版嵁锛屾垨娌℃寜娴佺▼瀹屾垚鏁版嵁澶勭悊
- if(boCustAttrs == null || boCustAttrs.size() == 0){
- return returnJson.toJSONString();
- }
-
-
- JSONArray boCustAttrArray = new JSONArray();
- //鍗曠函鐨勫垹闄� 鍜屽崟绾� 澧炲姞
- for(BoCustAttr newBoCustAttr : boCustAttrs) {
- if(isNeedDelete) {
- if (StateConstant.STATE_DEL.equals(newBoCustAttr.getState())) {
- newBoCustAttr.setBoId("");
- newBoCustAttr.setState(StateConstant.STATE_ADD);
- } else if (StateConstant.STATE_ADD.equals(newBoCustAttr.getState())) {
- newBoCustAttr.setState(StateConstant.STATE_DEL);
- } else {
- newBoCustAttr.setState(StateConstant.STATE_KIP);
- }
- }
- boCustAttrArray.add(newBoCustAttr);
- }
-
- returnJson.getJSONObject("data").put("boCustAttr",JSONObject.toJSONString(boCustAttrArray));
-
- return returnJson.toJSONString();
-
- }
- /**
- * 澶勭悊boCust 鑺傜偣
- * @throws Exception
- */
- public void doProcessBoCust(JSONObject userInfoJson,JSONObject paramJson,Map custIdKey, JSONObject resultInfo) throws Exception{
-
- if(userInfoJson.containsKey("boCust")){
- JSONArray boCusts = userInfoJson.getJSONArray("boCust");
- JSONObject boCustObj = new JSONObject();
- boCustObj.put("boCust",boCusts);
- String returnSaveBoCust = this.soBoCust(boCustObj.toJSONString(),custIdKey);
-
- if(!ProtocolUtil.validateReturnJson(returnSaveBoCust,paramJson)){
-
- throw new RuntimeException("淇濆瓨 bo_cust 澶辫触锛�"+boCustObj+(paramJson != null
- && paramJson.containsKey("RESULT_MSG")?paramJson.getString("RESULT_MSG"):"鏈煡寮傚父"));
- }
-
- resultInfo = paramJson.getJSONObject("RESULT_INFO");
- }
- }
-
- /**
- * 澶勭悊boCustAttr 鑺傜偣
- * @param userInfoJson
- * @param paramJson
- * @param custIdKey
- * @param resultInfo
- */
- public void doProcessBoCustAttr(JSONObject userInfoJson,JSONObject paramJson,Map custIdKey, JSONObject resultInfo) throws Exception{
- if(userInfoJson.containsKey("boCustAttr")){
-
- JSONArray boCustAttrs = userInfoJson.getJSONArray("boCustAttr");
- //棣栧厛瀵筩ustId 杩涜澶勭悊
- if(custIdKey != null && custIdKey.size() > 0 ){
- for(int boCustAttrIndex = 0 ; boCustAttrIndex < boCustAttrs.size();boCustAttrIndex++){
- JSONObject boCustAttr = boCustAttrs.getJSONObject(boCustAttrIndex);
- boCustAttr.put("custId",custIdKey.get("custId"+boCustAttr.getString("custId")));
- }
- }
- JSONObject boCustAttrObj = new JSONObject();
- boCustAttrObj.put("boCustAttr",boCustAttrs);
- String returnSaveBoCustAttr = soBoCustAttr(boCustAttrObj.toJSONString());
-
- if(!ProtocolUtil.validateReturnJson(returnSaveBoCustAttr,paramJson)){
-
- throw new RuntimeException("淇濆瓨 bo_cust 澶辫触锛�"+boCustAttrObj+(paramJson != null
- && paramJson.containsKey("RESULT_MSG")?paramJson.getString("RESULT_MSG"):"鏈煡寮傚父"));
- }
- }
- }
-
- /**
- * 浣滃簾 boCust 淇℃伅
- * @param data
- * @throws Exception
- */
- public void doDeleteBoCust(JSONObject data) throws Exception{
-
-
- Cust deleteCust = null;
- //鏍规嵁boId 鏌ヨbo_cust 琛紝鏄惁鏈夋暟鎹紝娌℃暟鎹洿鎺ヨ繑鍥�
- BoCust boCust = new BoCust();
-
- boCust.setBoId(data.getString("boId"));
-
- List<BoCust> boCusts = iUserServiceDao.queryBoCust(boCust);
-
- //Assert.isOne(boCusts,"鍦ㄨ〃bo_cust涓湭鎵惧埌boId 涓篬"+data.getString("boId")+"]鐨勬暟鎹� 鎴栨湁澶氭潯鏁版嵁锛岃妫�鏌�");
- if(boCusts == null || boCusts.size() < 1){
- LoggerEngine.error("褰撳墠娌℃湁鏌ュ埌鏁颁负 "+data+"璇锋鏌ユ暟鎹�");
- return;
- }
- //鍦ㄨ繃绋嬭〃涓ˉ涓�鏉′綔搴熺殑鏁版嵁锛岀劧鍚庢牴鎹産oId鐨勫姩浣滃瀹炰緥鏁版嵁杩涜澶勭悊
-
- boCust.setCustId(boCusts.get(0).getCustId());
- boCust.setBoId("");
- //鏌ヨ鍑烘墍鏈塩ustId 涓�鏍风殑鏁版嵁
- List<BoCust> boCustAll = iUserServiceDao.queryBoCust(boCust);
-
- Assert.isNull(boCustAll,"褰撳墠娌℃湁鏌ュ埌custId 涓� "+boCusts.get(0).getCustId()+"璇锋鏌ユ暟鎹�");
-
- boCust = boCusts.get(0);
-
- BoCust newBoCust = new BoCust();
- newBoCust.setBoId(data.getString("newBoId"));
- newBoCust.setCustId(boCust.getCustId());
- newBoCust.setState("DEL");
- int saveBoCustFlag = iUserServiceDao.saveDataToBoCust(newBoCust);
-
- if(saveBoCustFlag < 1){
- throw new RuntimeException("鍚慴o_cust琛ㄤ腑淇濆瓨鏁版嵁澶辫触锛宐oCust="+JSONObject.toJSONString(newBoCust));
- }
-
- //棣栧厛鍒犻櫎瀹炰緥鏁版嵁
- deleteCust = new Cust();
- deleteCust.setCustId(boCust.getCustId());
- if(iUserServiceDao.deleteDataToCust(deleteCust) < 1){
- throw new RuntimeException("鍒犻櫎cust瀹炰緥鏁版嵁澶辫触"+JSONObject.toJSONString(deleteCust));
- }
- //濡傛灉鏈夊鏉℃暟鎹紝鍒欐仮澶� 鍓嶄竴鏉℃暟鎹俊鎭紝杩欒竟瀛樺湪bug 濡傛灉涓婁竴鏉＄殑鏁版嵁娌℃湁鍒嗚浠ュ墠鏁版嵁鐨勬儏鍐典笅浼氭湁闂锛�
- // 鎵�浠ユ垜浠殑鍘熷垯鏄啀鏇存柊鎴栧垹闄ゆ暟鎹椂涓�瀹氳鍦ㄨ繃绋嬭〃涓繚瀛樺畬鏁存槸瀹炰緥鏁版嵁淇℃伅
- if(boCustAll.size() > 1){
- Cust oldCust = boCustAll.get(1).convert();
- if(iUserServiceDao.saveDataToCust(oldCust)<1 ){
- throw new RuntimeException("cust 琛ㄦ仮澶嶈�佹暟鎹俊鎭け璐ワ紝cust 涓猴細"+JSONObject.toJSONString(oldCust));
- }
- }
- }
-
- /**
- * 鍒犻櫎 bo_cust_attr
- * @param data
- * @throws Exception
- */
- public void doDeleteBoCustAttr(JSONObject data) throws Exception{
-
- BoCustAttr boCustAttrTmp = new BoCustAttr();
-
- boCustAttrTmp.setBoId(data.getString("boId"));
-
- List<BoCustAttr> boCustAttrs = iUserServiceDao.queryBoCustAttr(boCustAttrTmp);
-
- if(boCustAttrs == null || boCustAttrs.size() < 1){
- LoggerEngine.error("褰撳墠娌℃湁鏌ュ埌鏁颁负 "+data+"璇锋鏌ユ暟鎹�");
- return;
- }
-
- boCustAttrTmp.setBoId("");
- boCustAttrTmp.setCustId(boCustAttrs.get(0).getCustId());
-
- List<BoCustAttr> boCustAttrsTmps = iUserServiceDao.queryBoCustAttr(boCustAttrTmp);
-
- Assert.isNull(boCustAttrsTmps,"褰撳墠娌℃湁鏌ュ埌custId 涓� "+boCustAttrs.get(0).getCustId()+"璇锋鏌ユ暟鎹�");
-
- //鑾峰彇涓婁竴娆℃墍鏈夌殑灞炴��
-
- List<BoCustAttr> preBoCustAttrTmps = getPreBoCustAttrs(boCustAttrsTmps);
-
- //淇濆瓨杩囩▼琛�
- for(BoCustAttr boCustAttr : boCustAttrs){
- boCustAttr.setBoId("newBoId");
- boCustAttr.setState("DEL");
- if(iUserServiceDao.saveDataToBoCustAttr(boCustAttr) < 1){
- throw new RuntimeException("淇濆瓨鏁版嵁澶辫触锛屼繚瀛樻暟鎹负boCustAttr = "+ JSONObject.toJSONString(boCustAttr));
- }
- }
-
- //鍒犻櫎瀹炰緥鏁版嵁 杩欓噷鎬濊矾鏄紝鍒犻櫎瀹炰緥鏁版嵁涓暟鎹紝灏嗕笂涓�娆DD鏁版嵁閲嶆柊鍐欎竴閬�
- CustAttr custAttrTmp = new CustAttr();
- custAttrTmp.setCustId(boCustAttrs.get(0).getCustId());
- if(iUserServiceDao.deleteDataToCustAttr(custAttrTmp) < 1){
- throw new RuntimeException("鍒犻櫎CustAttr 瀹炰緥鏁版嵁澶辫触,鏁版嵁涓猴細"+JSONObject.toJSONString(custAttrTmp));
- }
-
- for(BoCustAttr boCustAttr : preBoCustAttrTmps){
- if("ADD".equals(boCustAttr.getState())){
- if(iUserServiceDao.deleteDataToCustAttr(boCustAttr.convert()) < 1){
- throw new RuntimeException("澶嶅師鍘熷鏁版嵁澶辫触锛屾暟鎹负锛�" + JSONObject.toJSONString(boCustAttr));
- }
- }
- }
-
- }
-
- /**
- * 鑾峰彇涓婁笂涓�娆＄殑鎿嶄綔
- * @param boCustAttrs
- * @return
- */
- private List<BoCustAttr> getPreBoCustAttrs(List<BoCustAttr> boCustAttrs){
-
- String firstBoId = boCustAttrs.get(0).getBoId();
- String preBoId = "";
- List<BoCustAttr> preBoCustAttrs = new ArrayList<BoCustAttr>();
- for(BoCustAttr boCustAttr : boCustAttrs){
- if(!firstBoId.equals(boCustAttr.getBoId())){
- if(!preBoId.equals(boCustAttr.getBoId()) && !"".equals(preBoId)){
- break;
- }
- preBoId = boCustAttr.getBoId();
- preBoCustAttrs.add(boCustAttr);
- }
- }
- return preBoCustAttrs;
- }
+ private static final String USER_ACTION_DEL = "DEL";
@Override
public JSONObject service(BusinessServiceDataFlow businessServiceDataFlow) throws SMOException {
try {
- Assert.hasLength(businessServiceDataFlow.getbId(),"bId 涓嶈兘涓虹┖");
+ Assert.hasLength(businessServiceDataFlow.getbId(), "bId 涓嶈兘涓虹┖");
BusinessServiceDataFlowEventPublishing.multicastEvent(businessServiceDataFlow);
- Assert.notEmpty(businessServiceDataFlow.getResJson(),"鐢ㄦ埛鏈嶅姟["+businessServiceDataFlow.getCurrentBusiness().getServiceCode()+"]娌℃湁杩斿洖鍐呭");
+ Assert.notEmpty(businessServiceDataFlow.getResJson(), "鐢ㄦ埛鏈嶅姟[" + businessServiceDataFlow.getCurrentBusiness().getServiceCode() + "]娌℃湁杩斿洖鍐呭");
} catch (Exception e) {
- logger.error("鐢ㄦ埛淇℃伅澶勭悊寮傚父",e);
- throw new SMOException(ResponseConstant.RESULT_PARAM_ERROR,"鐢ㄦ埛淇℃伅澶勭悊寮傚父"+e.getMessage());
- }finally {
- if(businessServiceDataFlow == null){
+ logger.error("鐢ㄦ埛淇℃伅澶勭悊寮傚父", e);
+ throw new SMOException(ResponseConstant.RESULT_PARAM_ERROR, "鐢ㄦ埛淇℃伅澶勭悊寮傚父" + e.getMessage());
+ } finally {
+ if (businessServiceDataFlow == null) {
return null;
}
@@ -796,54 +98,49 @@
/**
* 淇濆瓨鏃ュ織淇℃伅
- * @param businessServiceDataFlow
+ *
+ * @param businessServiceDataFlow 涓氬姟鏃ュ織瀵硅薄
*/
- private void saveLogMessage(BusinessServiceDataFlow businessServiceDataFlow){
+ private void saveLogMessage(BusinessServiceDataFlow businessServiceDataFlow) {
- try{
- if(MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.KEY_LOG_ON_OFF))){
- for(DataFlowLog dataFlowLog :businessServiceDataFlow.getLogDatas()) {
+ try {
+ if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.KEY_LOG_ON_OFF))) {
+ for (DataFlowLog dataFlowLog : businessServiceDataFlow.getLogDatas()) {
KafkaFactory.sendKafkaMessage(KafkaConstant.TOPIC_LOG_NAME, "", JSONObject.toJSONString(dataFlowLog));
}
}
- }catch (Exception e){
- logger.error("鎶ラ敊鏃ュ織鍑洪敊浜嗭紝",e);
+ } catch (Exception e) {
+ logger.error("鎶ラ敊鏃ュ織鍑洪敊浜嗭紝", e);
}
}
/**
* 淇濆瓨鑰楁椂淇℃伅
+ *
* @param businessServiceDataFlow
*/
- private void saveCostTimeLogMessage(BusinessServiceDataFlow businessServiceDataFlow){
- try{
- if(MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.KEY_COST_TIME_ON_OFF))){
+ private void saveCostTimeLogMessage(BusinessServiceDataFlow businessServiceDataFlow) {
+ try {
+ if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.KEY_COST_TIME_ON_OFF))) {
List<DataFlowLinksCost> dataFlowLinksCosts = businessServiceDataFlow.getLinksCostDates();
JSONObject costDate = new JSONObject();
JSONArray costDates = new JSONArray();
JSONObject newObj = null;
- for(DataFlowLinksCost dataFlowLinksCost : dataFlowLinksCosts){
+ for (DataFlowLinksCost dataFlowLinksCost : dataFlowLinksCosts) {
newObj = JSONObject.parseObject(JSONObject.toJSONString(dataFlowLinksCost));
- newObj.put("dataFlowId",businessServiceDataFlow.getDataFlowId());
- newObj.put("transactionId",businessServiceDataFlow.getTransactionId());
+ newObj.put("dataFlowId", businessServiceDataFlow.getDataFlowId());
+ newObj.put("transactionId", businessServiceDataFlow.getTransactionId());
costDates.add(newObj);
}
- costDate.put("costDates",costDates);
+ costDate.put("costDates", costDates);
- KafkaFactory.sendKafkaMessage(KafkaConstant.TOPIC_COST_TIME_LOG_NAME,"",costDate.toJSONString());
+ KafkaFactory.sendKafkaMessage(KafkaConstant.TOPIC_COST_TIME_LOG_NAME, "", costDate.toJSONString());
}
- }catch (Exception e){
- logger.error("鎶ラ敊鏃ュ織鍑洪敊浜嗭紝",e);
+ } catch (Exception e) {
+ logger.error("鎶ラ敊鏃ュ織鍑洪敊浜嗭紝", e);
}
}
- public IPrimaryKeyService getiPrimaryKeyService() {
- return iPrimaryKeyService;
- }
-
- public void setiPrimaryKeyService(IPrimaryKeyService iPrimaryKeyService) {
- this.iPrimaryKeyService = iPrimaryKeyService;
- }
public IUserServiceDao getiUserServiceDao() {
return iUserServiceDao;
--
Gitblit v1.8.0