package com.java110.rule.rest;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.utils.constant.RuleDomain;
|
import com.java110.utils.log.LoggerEngine;
|
import com.java110.utils.util.CodeMapUtil;
|
import com.java110.utils.util.RuleUtil;
|
import com.java110.core.base.controller.BaseController;
|
import com.java110.rule.smo.IRuleServiceSMO;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
/**
|
* 规则服务
|
* Created by wuxw on 2017/7/22.
|
*/
|
@RestController
|
public class RuleServiceRest extends BaseController {
|
private final static Logger logger = LoggerFactory.getLogger(RuleServiceRest.class);
|
|
|
@Autowired
|
IRuleServiceSMO ruleServiceSMOImpl;
|
|
/**
|
* 规则校验方法
|
* 请求报文协议：
|
*
|
* {
|
"ContractRoot": {
|
"TcpCont": { -- 请求头部
|
"RuleType":"RULE0001", -- 用来区分走那个规则组
|
"ServiceCode": "SVC0001", -- 用来判断走那些规则
|
"TransactionID": "1001000101201603081234567890", -- 交易流水
|
"ReqTime": "20130817200202123",--请求时间
|
},
|
"SvcCont": { -- 请求体 这里面的结构可以随便定
|
"AccNbr": "",
|
"ProductNbr":"",
|
"RegionCode":"863000"
|
}
|
}
|
}
|
*
|
* @param validateInfo
|
* @return
|
*/
|
@RequestMapping("/ruleService/validate")
|
@ResponseBody
|
public String validate(@RequestParam("validateInfo") String validateInfo){
|
String resultInfo = "";
|
logger.debug("----------[RuleServiceRest.validate]-----------请求报文：" + validateInfo);
|
try{
|
resultInfo = ruleServiceSMOImpl.validate(validateInfo);
|
}catch (Exception e){
|
LoggerEngine.error("----------[RuleServiceRest.validate]-----------出现异常，请求报文为["+validateInfo+"]" ,e);
|
try {
|
//XStream转换出错，默认返回成功，后台记录错误日志
|
JSONObject jsonObject = JSONObject.parseObject(validateInfo);
|
String transactionID = jsonObject.containsKey("TcpCont") ?
|
(jsonObject.getJSONObject("TcpCont").containsKey("TransactionID")?jsonObject.getJSONObject("TcpCont").getString("TransactionID"):"-1")
|
:"-1";
|
String error = e.toString();
|
//记录错误日志
|
//recordRuleLog(transactionID,error,"LTE4G全量校验报文转换环节异常");
|
//动态常量DEP_PRVNC_RULE_ERROR_RET，不配置或配置不是1，则程序异常默认返回成功，其他返回具体异常信息
|
String depPrvncSaopRuleErrorRet = CodeMapUtil.getDynamicConstantValue("DEP_PRVNC_RULE_ERROR_RET");
|
if(StringUtils.isEmpty(depPrvncSaopRuleErrorRet) || !depPrvncSaopRuleErrorRet.equals("1")){
|
resultInfo = RuleUtil.ruleReturnJson(transactionID,RuleDomain.RULE_COND_RETURN_0000,"成功","");
|
}else{
|
resultInfo = RuleUtil.ruleReturnJson(transactionID,RuleDomain.RULE_COND_RETURN_1999,e.getMessage(),"");
|
}
|
} catch (Exception e1) {
|
LoggerEngine.error("----------[RuleServiceRest.validate]-----------出现异常，请求报文为["+validateInfo+"]" ,e);
|
resultInfo = RuleUtil.ruleReturnJson("-1",RuleDomain.RULE_COND_RETURN_1999,e.getMessage(),"");
|
}
|
}finally {
|
//这里需要记录日志报文
|
logger.debug("----------[RuleServiceRest.validate]-----------返回报文：" + resultInfo);
|
return resultInfo;
|
}
|
}
|
|
|
public IRuleServiceSMO getRuleServiceSMOImpl() {
|
return ruleServiceSMOImpl;
|
}
|
|
public void setRuleServiceSMOImpl(IRuleServiceSMO ruleServiceSMOImpl) {
|
this.ruleServiceSMOImpl = ruleServiceSMOImpl;
|
}
|
}
|
