package com.java110.user.rest;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.common.log.LoggerEngine;
|
import com.java110.common.util.ProtocolUtil;
|
import com.java110.core.base.controller.BaseController;
|
import com.java110.user.smo.IUserServiceSMO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
/**
|
* 用户服务提供类
|
* Created by wuxw on 2017/4/5.
|
*/
|
@RestController
|
public class UserServiceRest extends BaseController {
|
|
@Autowired
|
IUserServiceSMO iUserServiceSMO;
|
|
/**
|
* 通过User对象中数据查询用户信息
|
* 如,用户ID，名称
|
* @param userJson
|
* @return
|
*/
|
@RequestMapping("/userService/queryUserInfo")
|
public String queryUserInfo(@RequestParam("userJson") String userJson){
|
return null;
|
}
|
|
|
/**
|
* 用户服务信息受理
|
* 协议：
|
* {
|
* 'boCust':[{}],
|
* 'boCustAttr':[{}]
|
* }
|
* @param data
|
* @return
|
*/
|
@RequestMapping("/userService/soUserService")
|
public String soUserService(@RequestParam("data") String data){
|
|
LoggerEngine.debug("soUserService入参：" + data);
|
|
String resultUserInfo = null;
|
|
JSONObject reqUserJSON = null;
|
try {
|
reqUserJSON = this.simpleValidateJSON(data);
|
//1.0规则校验，报文是否合法
|
|
// 客户信息处理
|
if(reqUserJSON.containsKey("boCust")){
|
JSONArray boCusts = reqUserJSON.getJSONArray("boCust");
|
JSONObject boCustObj = new JSONObject();
|
boCustObj.put("boCust",boCusts);
|
iUserServiceSMO.soBoCust(boCustObj.toJSONString());
|
}
|
|
//客户属性信息处理
|
if(reqUserJSON.containsKey("boCustAttr")){
|
|
JSONArray boCustAttrs = reqUserJSON.getJSONArray("boCustAttr");
|
JSONObject boCustAttrObj = new JSONObject();
|
boCustAttrObj.put("boCustAttr",boCustAttrs);
|
iUserServiceSMO.soBoCustAttr(boCustAttrObj.toJSONString());
|
}
|
|
resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_SUCCESS,"受理成功",null);
|
|
//2.0
|
} catch (Exception e) {
|
LoggerEngine.error("服务处理出现异常：", e);
|
resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"服务处理出现异常"+e,null);
|
} finally {
|
LoggerEngine.debug("用户服务操作客户出参：" + resultUserInfo);
|
return resultUserInfo;
|
}
|
}
|
|
|
/**
|
* 客户信息处理
|
* 协议：
|
*{
|
* boCust:[{},{}]
|
* }
|
* @param data
|
* @return
|
* @throws Exception
|
*/
|
@RequestMapping("/userService/soBoCust")
|
public String soBoCust(@RequestParam("data") String data ) {
|
LoggerEngine.debug("soBoCust入参：" + data);
|
|
String resultUserInfo = null;
|
|
JSONObject reqUserJSON = null;
|
try {
|
reqUserJSON = this.simpleValidateJSON(data);
|
resultUserInfo = iUserServiceSMO.soBoCust(data);
|
}catch (Exception e){
|
LoggerEngine.error("服务处理出现异常：", e);
|
resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"服务处理出现异常"+e,null);
|
} finally {
|
LoggerEngine.debug("用户服务操作客户出参：" + resultUserInfo);
|
return resultUserInfo;
|
}
|
}
|
|
/**
|
* 客户信息属性处理
|
* 协议：
|
*{
|
* boCustAttr:[{},{}]
|
* }
|
* @param data
|
* @return
|
* @throws Exception
|
*/
|
@RequestMapping("/userService/soBoCustAttr")
|
public String soBoCustAttr(@RequestParam("data") String data) {
|
LoggerEngine.debug("soBoCustAttr入参：" + data);
|
|
String resultUserInfo = null;
|
|
JSONObject reqUserJSON = null;
|
try {
|
reqUserJSON = this.simpleValidateJSON(data);
|
resultUserInfo = iUserServiceSMO.soBoCustAttr(data);
|
}catch (Exception e){
|
LoggerEngine.error("服务处理出现异常：", e);
|
resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"服务处理出现异常"+e,null);
|
} finally {
|
LoggerEngine.debug("用户服务操作客户出参：" + resultUserInfo);
|
return resultUserInfo;
|
}
|
}
|
|
|
public IUserServiceSMO getiUserServiceSMO() {
|
return iUserServiceSMO;
|
}
|
|
public void setiUserServiceSMO(IUserServiceSMO iUserServiceSMO) {
|
this.iUserServiceSMO = iUserServiceSMO;
|
}
|
}
|
