package com.java110.user.dao.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.user.dao.IUserServiceDao;
|
import com.java110.common.log.LoggerEngine;
|
import com.java110.common.constant.CommonConstant;
|
import com.java110.common.constant.ResponseConstant;
|
import com.java110.common.util.ProtocolUtil;
|
import com.java110.core.base.dao.BaseServiceDao;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 用户服务 与数据库交互
|
* Created by wuxw on 2017/4/5.
|
*/
|
|
/**
|
* 用户信息实现工程
|
* Created by wuxw on 2016/12/27.
|
*/
|
@Service("userServiceDaoImpl")
|
@Transactional
|
public class UserServiceDaoImpl extends BaseServiceDao implements IUserServiceDao {
|
|
|
|
/**
|
* 保存用户基本信息
|
* 功能只用与保存用户处理
|
* @param userInfo 用户基本信息
|
* @return
|
*/
|
@Override
|
public String saveDataToBoCust(String userInfo) {
|
|
LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCust】保存数据入参 : " + userInfo);
|
Map<String,Object> userMap = null;
|
String returnInfo = null;
|
try {
|
userMap = this.simpleValidateJSONReturnMap(userInfo);
|
|
int saveFlag = sqlSessionTemplate.insert("UserServiceDAOImpl.saveDataToBoCust",userMap);
|
|
if(saveFlag > 0){
|
returnInfo = ProtocolUtil.createResultMsg(ResponseConstant.RESULT_CODE_SUCCESS,"成功",null);
|
}else{
|
returnInfo = ProtocolUtil.createResultMsg(ResponseConstant.RESULT_CODE_ERROR,"失败",null);
|
}
|
}catch(RuntimeException e){
|
LoggerEngine.error("----【UserServiceDAOImpl.saveDataToBoCust】保存数据异常 : " ,e);
|
return e.getMessage();
|
}
|
LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCust】保存数据出参 : " + returnInfo);
|
return returnInfo;
|
}
|
|
/**
|
* 保存用户属性（过程表）
|
* 批量保存传入参数必须一个JSONArray to string
|
* @param boCustAttr 用户属性
|
* @return
|
* @throws RuntimeException
|
*/
|
@Override
|
public String saveDataToBoCustAttr(String boCustAttr) throws RuntimeException {
|
|
LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据入参 : " + boCustAttr);
|
List<Map> reqList = null;
|
String returnInfo = null;
|
try{
|
reqList = this.simpleValidateJSONArrayReturnList(boCustAttr);
|
}catch (RuntimeException e){
|
return e.getMessage();
|
}
|
//为了保险起见，再测检测reqList 是否有值
|
if(reqList == null || reqList.size() == 0){
|
returnInfo = ProtocolUtil.createResultMsg(ResponseConstant.RESULT_CODE_PARAM_ERROR,"入参错误",null);
|
LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据出错 : " + returnInfo);
|
return returnInfo;
|
}
|
Map boCustAttrMap = null;
|
int saveFlag = 0;
|
for(int attrIndex = 0 ; attrIndex < reqList.size();attrIndex++){
|
boCustAttrMap = reqList.get(attrIndex);
|
saveFlag = sqlSessionTemplate.insert("UserServiceDAOImpl.saveDataToBoCustAttr",boCustAttrMap);
|
if(saveFlag < 1){ //只要一个保存失败，抛异常回退
|
LoggerEngine.error("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据异常 : " + boCustAttrMap.toString());
|
throw new RuntimeException(CommonConstant.SAVE_DATA_ERROR+"保存数据失败："+boCustAttrMap.toString());
|
}
|
}
|
returnInfo = ProtocolUtil.createResultMsg(ResponseConstant.RESULT_CODE_SUCCESS,"成功",null);
|
LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据出参 : " + returnInfo);
|
return returnInfo;
|
}
|
|
/**
|
* 同时保存客户基本信息和客户属性
|
* @param boCustInfo 用户信息
|
* @return
|
* @throws RuntimeException
|
*/
|
@Override
|
public String saveDataToBoCustAndBoCustAttr(String boCustInfo) throws RuntimeException {
|
|
LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAndBoCustAttr】保存数据入参"+boCustInfo);
|
JSONObject reqJson = null ;
|
String returnInfo = null;
|
//报文校验是否符合要求
|
try{
|
reqJson = this.simpleValidateJSON(boCustInfo);
|
}catch (RuntimeException e){
|
return e.getMessage();
|
}
|
//保存用户基本信息
|
if(reqJson!= null && reqJson.containsKey("boCust")){
|
String boCustJSON = reqJson.getJSONObject("boCust").toJSONString();
|
returnInfo = this.saveDataToBoCust(boCustJSON);
|
//解析返回内容
|
}
|
|
return null;
|
}
|
|
@Override
|
public String saveDataToCust(String cust) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String saveDataToCustAttr(String custAttr) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String saveDataToCustAndCustAttr(String custInfo) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String updateDataToCust(String cust) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String updateDataToCustAttr(String custAttr) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String updateDataToCustAndCustAttr(String custInfo) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String queryDataToCust(String cust) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String queryDataToCustAttr(String custAttr) throws RuntimeException {
|
return null;
|
}
|
|
@Override
|
public String queryDataToCustAndCustAttr(String custInfo) throws RuntimeException {
|
return null;
|
}
|
}
|
