| | |
| | | package com.java110.user.dao.impl; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.java110.common.constant.ResponseConstant; |
| | | import com.java110.common.exception.DAOException; |
| | | import com.java110.common.util.Assert; |
| | | import com.java110.core.base.dao.BaseServiceDao; |
| | | 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.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.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.logging.Logger; |
| | | |
| | | /** |
| | | * 用户服务 与数据库交互 |
| | |
| | | @Transactional |
| | | public class UserServiceDaoImpl extends BaseServiceDao implements IUserServiceDao { |
| | | |
| | | private final static Logger logger = LoggerFactory.getLogger(UserServiceDaoImpl.class); |
| | | |
| | | |
| | | /** |
| | |
| | | @Override |
| | | public int saveDataToBoCust(BoCust boCust) throws RuntimeException{ |
| | | |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCust】保存数据入参 : " + boCust); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToBoCust】保存数据入参 : " + boCust); |
| | | int saveFlag = 0; |
| | | try { |
| | | |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToBoCust",boCust); |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToBoCust",boCust); |
| | | |
| | | }catch(RuntimeException e){ |
| | | LoggerEngine.error("----【UserServiceDAOImpl.saveDataToBoCust】保存数据异常 : " ,e); |
| | | logger.error("----【userServiceDaoImpl.saveDataToBoCust】保存数据异常 : " ,e); |
| | | return saveFlag; |
| | | }finally { |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCust】保存数据出参 : saveFlag:" + saveFlag); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToBoCust】保存数据出参 : saveFlag:" + saveFlag); |
| | | return saveFlag; |
| | | } |
| | | |
| | |
| | | @Override |
| | | public int saveDataToBoCustAttr(BoCustAttr boCustAttr) throws RuntimeException { |
| | | |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据入参 : " + boCustAttr); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToBoCustAttr】保存数据入参 : " + boCustAttr); |
| | | //为了保险起见,再测检测reqList 是否有值 |
| | | if(boCustAttr == null){ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据出错 : " + boCustAttr); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToBoCustAttr】保存数据出错 : " + boCustAttr); |
| | | return 0; |
| | | } |
| | | int saveFlag = 0; |
| | | |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToBoCustAttr",boCustAttr); |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据出参 :saveFlag " + saveFlag); |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToBoCustAttr",boCustAttr); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToBoCustAttr】保存数据出参 :saveFlag " + saveFlag); |
| | | |
| | | return saveFlag; |
| | | |
| | |
| | | */ |
| | | @Override |
| | | public int saveDataToCust(Cust cust) throws RuntimeException { |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据入参 : " + cust); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据入参 : " + cust); |
| | | //为了保险起见,再测检测reqList 是否有值 |
| | | if(cust == null){ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出错 : " + cust); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出错 : " + cust); |
| | | throw new IllegalArgumentException("请求参数错误,cust : " + cust); |
| | | } |
| | | int saveFlag = 0; |
| | | |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToCust",cust); |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag); |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToCust",cust); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag); |
| | | |
| | | return saveFlag; |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public int saveDataToCustAttr(CustAttr custAttr) throws RuntimeException { |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据入参 : " + custAttr); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据入参 : " + custAttr); |
| | | //为了保险起见,再测检测reqList 是否有值 |
| | | if(custAttr == null){ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出错 : " + custAttr); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出错 : " + custAttr); |
| | | throw new IllegalArgumentException("请求参数错误,custAttr : " + custAttr); |
| | | } |
| | | int saveFlag = 0; |
| | | |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToCustAttr",custAttr); |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag); |
| | | saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToCustAttr",custAttr); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag); |
| | | |
| | | return saveFlag; |
| | | } |
| | |
| | | * @throws RuntimeException |
| | | */ |
| | | public int deleteDataToCust(Cust cust) throws RuntimeException{ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCust】保存数据入参 : " + cust); |
| | | logger.debug("----【userServiceDaoImpl.deleteDataToCust】保存数据入参 : " + cust); |
| | | //为了保险起见,再测检测reqList 是否有值 |
| | | if(cust == null){ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCust】保存数据出错 : " + cust); |
| | | logger.debug("----【userServiceDaoImpl.deleteDataToCust】保存数据出错 : " + cust); |
| | | throw new IllegalArgumentException("请求参数错误,cust : " + cust); |
| | | } |
| | | int saveFlag = 0; |
| | | |
| | | saveFlag = sqlSessionTemplate.update("userServiceDAOImpl.deleteDataToCust",cust); |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCust】保存数据出参 :saveFlag " + saveFlag); |
| | | saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.deleteDataToCust",cust); |
| | | logger.debug("----【userServiceDaoImpl.deleteDataToCust】保存数据出参 :saveFlag " + saveFlag); |
| | | |
| | | return saveFlag; |
| | | } |
| | |
| | | * @throws RuntimeException |
| | | */ |
| | | public int deleteDataToCustAttr(CustAttr custAttr) throws RuntimeException{ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCustAttr】保存数据入参 : " + custAttr); |
| | | logger.debug("----【userServiceDaoImpl.deleteDataToCustAttr】保存数据入参 : " + custAttr); |
| | | //为了保险起见,再测检测reqList 是否有值 |
| | | if(custAttr == null){ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCustAttr】保存数据出错 : " + custAttr); |
| | | logger.debug("----【userServiceDaoImpl.deleteDataToCustAttr】保存数据出错 : " + custAttr); |
| | | throw new IllegalArgumentException("请求参数错误,custAttr : " + custAttr); |
| | | } |
| | | int saveFlag = 0; |
| | | |
| | | saveFlag = sqlSessionTemplate.update("userServiceDAOImpl.deleteDataToCustAttr",custAttr); |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCustAttr】保存数据出参 :saveFlag " + saveFlag); |
| | | saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.deleteDataToCustAttr",custAttr); |
| | | logger.debug("----【userServiceDaoImpl.deleteDataToCustAttr】保存数据出参 :saveFlag " + saveFlag); |
| | | |
| | | return saveFlag; |
| | | } |
| | |
| | | @Override |
| | | public String saveDataToBoCustAndBoCustAttr(String boCustInfo) throws RuntimeException { |
| | | |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAndBoCustAttr】保存数据入参"+boCustInfo); |
| | | logger.debug("----【userServiceDaoImpl.saveDataToBoCustAndBoCustAttr】保存数据入参"+boCustInfo); |
| | | |
| | | return null; |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public Cust queryDataToCust(Cust cust) throws RuntimeException { |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据入参 : " + cust); |
| | | logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据入参 : " + cust); |
| | | //为了保险起见,再测检测reqList 是否有值 |
| | | if(cust == null){ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据出错 : " + cust); |
| | | logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出错 : " + cust); |
| | | throw new IllegalArgumentException("请求参数错误,cust : " + cust); |
| | | } |
| | | |
| | | Cust newCust = sqlSessionTemplate.selectOne("userServiceDAOImpl.queryDataToCust",cust); |
| | | Cust newCust = sqlSessionTemplate.selectOne("userServiceDaoImpl.queryDataToCust",cust); |
| | | |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据出参 :newCust " + newCust); |
| | | logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出参 :newCust " + newCust); |
| | | |
| | | return newCust; |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public List<CustAttr> queryDataToCustAttr(CustAttr custAttr) throws RuntimeException { |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCustAttr】保存数据入参 : " + custAttr); |
| | | logger.debug("----【userServiceDaoImpl.queryDataToCustAttr】保存数据入参 : " + custAttr); |
| | | //为了保险起见,再测检测reqList 是否有值 |
| | | if(custAttr == null){ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据出错 : " + custAttr); |
| | | logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出错 : " + custAttr); |
| | | throw new IllegalArgumentException("请求参数错误,CustAttr : " + custAttr); |
| | | } |
| | | |
| | | List<CustAttr> custAttrs = sqlSessionTemplate.selectList("userServiceDAOImpl.queryDataToCustAttr",custAttr); |
| | | List<CustAttr> custAttrs = sqlSessionTemplate.selectList("userServiceDaoImpl.queryDataToCustAttr",custAttr); |
| | | |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据出参 :custAttrs " + custAttrs); |
| | | logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出参 :custAttrs " + custAttrs); |
| | | |
| | | return custAttrs; |
| | | } |
| | |
| | | * @throws Exception |
| | | */ |
| | | public List<BoCust> queryBoCust(BoCust boCust) throws Exception{ |
| | | LoggerEngine.debug("----【UserServiceDAOImpl.queryBoCustAttr】:"+boCust); |
| | | logger.debug("----【userServiceDaoImpl.queryBoCustAttr】:"+boCust); |
| | | |
| | | Assert.isNull(boCust,"查询bo_cust 入参为空"); |
| | | |
| | | return sqlSessionTemplate.selectList("userServiceDAOImpl.queryBoCust",boCust); |
| | | return sqlSessionTemplate.selectList("userServiceDaoImpl.queryBoCust",boCust); |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | public List<BoCustAttr> queryBoCustAttr(BoCustAttr boCustAttr) throws Exception{ |
| | | |
| | | LoggerEngine.debug("【userServiceDAOImpl.queryBoCustAttr】:"+boCustAttr); |
| | | logger.debug("【userServiceDaoImpl.queryBoCustAttr】:"+boCustAttr); |
| | | |
| | | Assert.isNull(boCustAttr,"查询bo_cust_attr 入参为空"); |
| | | |
| | | return sqlSessionTemplate.selectList("userServiceDAOImpl.queryBoCustAttr",boCustAttr); |
| | | return sqlSessionTemplate.selectList("userServiceDaoImpl.queryBoCustAttr",boCustAttr); |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 保存用户信息 |
| | | * @param userInfo |
| | | * @throws DAOException |
| | | */ |
| | | @Override |
| | | public void saveBusinessUserInfo(Map userInfo) throws DAOException { |
| | | logger.debug("----【userServiceDaoImpl.saveBusinessUserInfo】保存数据入参 : " + JSONObject.toJSONString(userInfo)); |
| | | |
| | | // 查询business_user 数据是否已经存在 |
| | | |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserInfo",userInfo); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户数据失败:"+JSONObject.toJSONString(userInfo)); |
| | | } |
| | | } |
| | | /** |
| | | * 保存用户属性 |
| | | * @param userAttr |
| | | * @throws DAOException |
| | | */ |
| | | @Override |
| | | public void saveBusinessUserAttr(Map userAttr) throws DAOException { |
| | | logger.debug("----【userServiceDaoImpl.saveBusinessUserAttr】保存数据入参 : " + JSONObject.toJSONString(userAttr)); |
| | | |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserAttr",userAttr); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户属性数据失败:"+JSONObject.toJSONString(userAttr)); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void saveUserInfoInstance(Map businessUser) { |
| | | logger.debug("----【userServiceDaoImpl.saveUserInfoInstance】保存数据入参 : " + JSONObject.toJSONString(businessUser)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserInfoInstance",businessUser); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户Instance数据失败:"+JSONObject.toJSONString(businessUser)); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void saveUserAttrInstance(Map attrInstance) { |
| | | logger.debug("----【userServiceDaoImpl.saveUserAttrInstance】保存数据入参 : " + JSONObject.toJSONString(attrInstance)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserAttrInstance",attrInstance); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户Instance数据失败:"+JSONObject.toJSONString(attrInstance)); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void updateUserInfoInstance(Map businessUser) { |
| | | logger.debug("----【userServiceDaoImpl.updateUserInfoInstance】保存数据入参 : " + JSONObject.toJSONString(businessUser)); |
| | | int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserInfoInstance",businessUser); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改用户Instance数据失败:"+JSONObject.toJSONString(businessUser)); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void updateUserAttrInstance(Map attrInstance) { |
| | | logger.debug("----【userServiceDaoImpl.updateUserAttrInstance】保存数据入参 : " + JSONObject.toJSONString(attrInstance)); |
| | | int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserAttrInstance",attrInstance); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改用户Instance数据失败:"+JSONObject.toJSONString(attrInstance)); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 查询用户信息 |
| | | * @param info |
| | | * @return |
| | | * @throws DAOException |
| | | */ |
| | | public Map queryBusinessUserInfo(Map info) throws DAOException{ |
| | | Assert.notNull(info,"queryBusinessUserInfo 的参数不能为空"); |
| | | logger.debug("----【userServiceDaoImpl.queryBusinessUserInfo】保存数据入参 : " + JSONObject.toJSONString(info)); |
| | | List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserInfo",info); |
| | | if(users == null || users.size() == 0){ |
| | | return null; |
| | | } |
| | | return users.get(0); |
| | | } |
| | | |
| | | /** |
| | | * 查询用户信息 |
| | | * @param info |
| | | * @return |
| | | * @throws DAOException |
| | | */ |
| | | public List<Map> queryBusinessUserInfoAttrs(Map info) throws DAOException{ |
| | | Assert.notNull(info,"queryBusinessUserInfoAttrs 的参数不能为空"); |
| | | logger.debug("----【userServiceDaoImpl.queryBusinessUserInfoAttrs】保存数据入参 : " + JSONObject.toJSONString(info)); |
| | | List<Map> userAttrs = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserInfoAttrs",info); |
| | | return userAttrs; |
| | | } |
| | | |
| | | /** |
| | | * 查询用户信息 |
| | | * @param info |
| | | * @return |
| | | * @throws DAOException |
| | | */ |
| | | @Override |
| | | public Map queryUserInfo(Map info) throws DAOException{ |
| | | Assert.notNull(info,"queryUserInfo 的参数不能为空"); |
| | | logger.debug("----【userServiceDaoImpl.queryUserInfo】保存数据入参 : " + JSONObject.toJSONString(info)); |
| | | List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryUserInfo",info); |
| | | if(users == null || users.size() == 0){ |
| | | return null; |
| | | } |
| | | return users.get(0); |
| | | } |
| | | |
| | | /** |
| | | * 查询用户信息 |
| | | * @param info |
| | | * @return |
| | | * @throws DAOException |
| | | */ |
| | | @Override |
| | | public List<Map> queryUserInfoAttrs(Map info) throws DAOException{ |
| | | Assert.notNull(info,"queryUserInfo 的参数不能为空"); |
| | | logger.debug("----【userServiceDaoImpl.updateUserAttrInstance】保存数据入参 : " + JSONObject.toJSONString(info)); |
| | | List<Map> userAttrs = sqlSessionTemplate.selectList("userServiceDaoImpl.queryUserInfoAttrs",info); |
| | | return userAttrs; |
| | | } |
| | | |
| | | /** |
| | | * 保存用户地址信息 |
| | | * Business 过程 |
| | | * @param userAddress 用户地址信息 |
| | | * @throws DAOException |
| | | */ |
| | | public void saveBusinessUserAddress(Map userAddress) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.saveBusinessUserAddress】保存数据入参 : " + JSONObject.toJSONString(userAddress)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserAddress",userAddress); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户地址数据失败:"+JSONObject.toJSONString(userAddress)); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 查询用户地址信息 |
| | | * business 过程 |
| | | * @param info b_id |
| | | * @return 查询到的用户地址信息 |
| | | * @throws DAOException |
| | | */ |
| | | public Map queryBusinessUserAddress(Map info) throws DAOException{ |
| | | Assert.notNull(info,"queryBusinessUserAddress 的参数不能为空"); |
| | | logger.debug("----【userServiceDaoImpl.queryBusinessUserAddress】保存数据入参 : " + JSONObject.toJSONString(info)); |
| | | List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserAddress",info); |
| | | if(users == null || users.size() == 0){ |
| | | return null; |
| | | } |
| | | return users.get(0); |
| | | } |
| | | |
| | | /** |
| | | * 保存用户地址 Business 数据到 Instance |
| | | * @param businessUserAddress 从business 中查出的数据 |
| | | * @throws DAOException 数据处理异常 |
| | | */ |
| | | public void saveUserAddressInstance(Map businessUserAddress) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.saveUserAddressInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserAddress)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserAddressInstance",businessUserAddress); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户地址Instance数据失败:"+JSONObject.toJSONString(businessUserAddress)); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 作废用户地址信息数据 |
| | | * @param businessUserAddress 用户地址信息 b_id |
| | | * @throws DAOException 数据处理异常 |
| | | */ |
| | | public void updateUserAddressInstance(Map businessUserAddress) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.updateUserAddressInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserAddress)); |
| | | int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserAddressInstance",businessUserAddress); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改用户Instance数据失败:"+JSONObject.toJSONString(businessUserAddress)); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 保存用户打标信息 |
| | | * Business 过程 |
| | | * @param userTag 用户打标信息 |
| | | * @throws DAOException |
| | | */ |
| | | public void saveBusinessUserTag(Map userTag) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.saveBusinessUserTag】保存数据入参 : " + JSONObject.toJSONString(userTag)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserTag",userTag); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户打标数据失败:"+JSONObject.toJSONString(userTag)); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 查询用户打标信息 |
| | | * business 过程 |
| | | * @param info b_id |
| | | * @return 查询到的用户打标信息 |
| | | * @throws DAOException |
| | | */ |
| | | public Map queryBusinessUserTag(Map info) throws DAOException{ |
| | | Assert.notNull(info,"queryBusinessUserTag 的参数不能为空"); |
| | | logger.debug("----【userServiceDaoImpl.queryBusinessUserTag】保存数据入参 : " + JSONObject.toJSONString(info)); |
| | | List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserTag",info); |
| | | if(users == null || users.size() == 0){ |
| | | return null; |
| | | } |
| | | return users.get(0); |
| | | } |
| | | |
| | | /** |
| | | * 保存Business 数据到 Instance |
| | | * @param businessUserTag 从business 中查出的数据 |
| | | * @throws DAOException 数据处理异常 |
| | | */ |
| | | public void saveUserTagInstance(Map businessUserTag) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.saveUserTagInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserTag)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserTagInstance",businessUserTag); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户打标Instance数据失败:"+JSONObject.toJSONString(businessUserTag)); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 作废用户打标数据 |
| | | * @param businessUserTag 用户地址信息 b_id |
| | | * @throws DAOException 数据处理异常 |
| | | */ |
| | | public void updateUserTagInstance(Map businessUserTag) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.updateUserTagInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserTag)); |
| | | int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserTagInstance",businessUserTag); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改用户Instance数据失败:"+JSONObject.toJSONString(businessUserTag)); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 保存用户证件信息 |
| | | * Business 过程 |
| | | * @param userCredentials 用户证件信息 |
| | | * @throws DAOException |
| | | */ |
| | | public void saveBusinessUserCredentials(Map userCredentials) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.saveBusinessUserCredentials】保存数据入参 : " + JSONObject.toJSONString(userCredentials)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserCredentials",userCredentials); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户打标数据失败:"+JSONObject.toJSONString(userCredentials)); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 查询用户证件信息 |
| | | * business 过程 |
| | | * @param info b_id |
| | | * @return 查询到的用户打标信息 |
| | | * @throws DAOException |
| | | */ |
| | | public Map queryBusinessUserCredentials(Map info) throws DAOException{ |
| | | Assert.notNull(info,"queryBusinessUserCredentials 的参数不能为空"); |
| | | logger.debug("----【userServiceDaoImpl.queryBusinessUserCredentials】保存数据入参 : " + JSONObject.toJSONString(info)); |
| | | List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserCredentials",info); |
| | | if(users == null || users.size() == 0){ |
| | | return null; |
| | | } |
| | | return users.get(0); |
| | | } |
| | | |
| | | /** |
| | | * 保存Business 数据到 Instance |
| | | * @param businessUserCredentials 从business 中查出的数据 |
| | | * @throws DAOException 数据处理异常 |
| | | */ |
| | | public void saveUserCredentialsInstance(Map businessUserCredentials) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.saveUserCredentialsInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserCredentials)); |
| | | int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserCredentialsInstance",businessUserCredentials); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存用户打标Instance数据失败:"+JSONObject.toJSONString(businessUserCredentials)); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 作废用户证件数据 |
| | | * @param businessUserCredentials 用户地址信息 b_id |
| | | * @throws DAOException 数据处理异常 |
| | | */ |
| | | public void updateUserCredentialsInstance(Map businessUserCredentials) throws DAOException{ |
| | | logger.debug("----【userServiceDaoImpl.updateUserCredentialsInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserCredentials)); |
| | | int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserCredentialsInstance",businessUserCredentials); |
| | | |
| | | if(saveFlag < 1){ |
| | | throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改用户Instance数据失败:"+JSONObject.toJSONString(businessUserCredentials)); |
| | | } |
| | | } |
| | | } |