package com.java110.user.smo.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.JSONPath;
|
import com.java110.common.cache.MappingCache;
|
import com.java110.common.constant.KafkaConstant;
|
import com.java110.common.constant.MappingConstant;
|
import com.java110.common.constant.ResponseConstant;
|
import com.java110.common.constant.StateConstant;
|
import com.java110.common.exception.SMOException;
|
import com.java110.common.kafka.KafkaFactory;
|
import com.java110.common.log.LoggerEngine;
|
import com.java110.common.util.Assert;
|
import com.java110.common.util.DateUtil;
|
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;
|
import com.java110.entity.user.BoCust;
|
import com.java110.entity.user.BoCustAttr;
|
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;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.ObjectUtils;
|
|
import java.util.*;
|
|
/**
|
* 用户服务信息管理业务信息实现
|
* Created by wuxw on 2017/4/5.
|
*/
|
@Service("userServiceSMOImpl")
|
@Transactional
|
public class UserServiceSMOImpl extends BaseServiceSMO implements IUserServiceSMO {
|
|
//@Autowired
|
IPrimaryKeyService iPrimaryKeyService;
|
|
@Autowired
|
IUserServiceDao iUserServiceDao;
|
|
//新增用户
|
private final static String USER_ACTION_ADD = "ADD";
|
|
//新增用户
|
private final static String USER_ACTION_KIP = "KIP";
|
|
//新增用户
|
private final static String USER_ACTION_DEL = "DEL";
|
|
/**
|
* 保存用户信息
|
*
|
* @param userInfoJson 入参为用户信息json传
|
* @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;
|
|
//存放生成的custId 主键为 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,"请求报文中data节点，没有子节点，data子节点应该为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 封装在map中返回
|
* ...
|
* 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,这个只有在有 主键生成服务时使用，否则为了防止出错，需要前段调用时需要生成custId
|
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")){
|
//从接口生成custId
|
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+"，boCust : "+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());
|
}
|
|
//则把已经删除过的从list中删除，以防重复删除
|
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);
|
|
//先拍个序 先处理DEL 再处理ADD
|
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+"，boCustAttr : "+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,"传入的data节点下没有任何内容");
|
|
for(int boIdIndex = 0 ; boIdIndex < datas.size(); boIdIndex++){
|
JSONObject data = datas.getJSONObject(boIdIndex);
|
|
Assert.isNotNull(data,"boId","当前节点中没有包含boId节点格式错误"+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("客户信息查询入参为空，custId 为空 "+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("客户信息查询入参为空，olId 为空 "+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");
|
//首先对custId 进行处理
|
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;
|
}
|
//在过程表中补一条作废的数据，然后根据boId的动作对实例数据进行处理
|
|
boCust.setCustId(boCusts.get(0).getCustId());
|
boCust.setBoId("");
|
//查询出所有custId 一样的数据
|
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("向bo_cust表中保存数据失败，boCust="+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));
|
}
|
}
|
|
//删除实例数据 这里思路是，删除实例数据中数据，将上一次ADD数据重新写一遍
|
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;
|
}
|
|
|
@Override
|
public JSONObject service(BusinessServiceDataFlow businessServiceDataFlow) throws SMOException {
|
try {
|
Assert.hasLength(businessServiceDataFlow.getbId(),"bId 不能为空");
|
|
BusinessServiceDataFlowEventPublishing.multicastEvent(businessServiceDataFlow);
|
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){
|
return null;
|
}
|
|
//这里记录日志
|
Date endDate = DateUtil.getCurrentDate();
|
|
businessServiceDataFlow.setEndDate(endDate);
|
//添加耗时
|
DataFlowFactory.addCostTime(businessServiceDataFlow, "service", "业务处理总耗时",
|
businessServiceDataFlow.getStartDate(), businessServiceDataFlow.getEndDate());
|
//保存耗时
|
saveCostTimeLogMessage(businessServiceDataFlow);
|
//保存日志
|
saveLogMessage(businessServiceDataFlow);
|
}
|
return businessServiceDataFlow.getResJson();
|
}
|
|
|
/**
|
* 保存日志信息
|
* @param businessServiceDataFlow
|
*/
|
private void saveLogMessage(BusinessServiceDataFlow businessServiceDataFlow){
|
|
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);
|
}
|
}
|
|
/**
|
* 保存耗时信息
|
* @param businessServiceDataFlow
|
*/
|
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){
|
newObj = JSONObject.parseObject(JSONObject.toJSONString(dataFlowLinksCost));
|
newObj.put("dataFlowId",businessServiceDataFlow.getDataFlowId());
|
newObj.put("transactionId",businessServiceDataFlow.getTransactionId());
|
costDates.add(newObj);
|
}
|
costDate.put("costDates",costDates);
|
|
KafkaFactory.sendKafkaMessage(KafkaConstant.TOPIC_COST_TIME_LOG_NAME,"",costDate.toJSONString());
|
}
|
}catch (Exception e){
|
logger.error("报错日志出错了，",e);
|
}
|
}
|
|
public IPrimaryKeyService getiPrimaryKeyService() {
|
return iPrimaryKeyService;
|
}
|
|
public void setiPrimaryKeyService(IPrimaryKeyService iPrimaryKeyService) {
|
this.iPrimaryKeyService = iPrimaryKeyService;
|
}
|
|
public IUserServiceDao getiUserServiceDao() {
|
return iUserServiceDao;
|
}
|
|
public void setiUserServiceDao(IUserServiceDao iUserServiceDao) {
|
this.iUserServiceDao = iUserServiceDao;
|
}
|
}
|
