From a76cec91cf4adf1feede5dda61d97d2bbf18266a Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 11 七月 2019 20:27:20 +0800
Subject: [PATCH] 加入服务绑定功能
---
UserService/src/main/java/com/java110/user/dao/impl/UserServiceDaoImpl.java | 629 ++++++++++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 554 insertions(+), 75 deletions(-)
diff --git a/UserService/src/main/java/com/java110/user/dao/impl/UserServiceDaoImpl.java b/UserService/src/main/java/com/java110/user/dao/impl/UserServiceDaoImpl.java
index 386f867..bdc4b7a 100644
--- a/UserService/src/main/java/com/java110/user/dao/impl/UserServiceDaoImpl.java
+++ b/UserService/src/main/java/com/java110/user/dao/impl/UserServiceDaoImpl.java
@@ -1,12 +1,17 @@
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.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 org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -26,79 +31,154 @@
@Transactional
public class UserServiceDaoImpl extends BaseServiceDao implements IUserServiceDao {
+ private final static Logger logger = LoggerFactory.getLogger(UserServiceDaoImpl.class);
/**
* 淇濆瓨鐢ㄦ埛鍩烘湰淇℃伅
* 鍔熻兘鍙敤涓庝繚瀛樼敤鎴峰鐞�
- * @param userInfo 鐢ㄦ埛鍩烘湰淇℃伅
+ *
+ * @param boCust 鐢ㄦ埛鍩烘湰淇℃伅
* @return
*/
@Override
- public String saveDataToBoCust(String userInfo) {
+ public int saveDataToBoCust(BoCust boCust) throws RuntimeException {
- LoggerEngine.debug("----銆怳serServiceDAOImpl.saveDataToBoCust銆戜繚瀛樻暟鎹叆鍙� : " + userInfo);
- Map<String,Object> userMap = null;
- String returnInfo = null;
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToBoCust銆戜繚瀛樻暟鎹叆鍙� : " + boCust);
+ int saveFlag = 0;
try {
- userMap = this.simpleValidateJSONReturnMap(userInfo);
- int saveFlag = sqlSessionTemplate.insert("UserServiceDAOImpl.saveDataToBoCust",userMap);
+ saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToBoCust", boCust);
- 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("----銆怳serServiceDAOImpl.saveDataToBoCust銆戜繚瀛樻暟鎹紓甯� : " ,e);
- return e.getMessage();
+ } catch (RuntimeException e) {
+ logger.error("----銆恥serServiceDaoImpl.saveDataToBoCust銆戜繚瀛樻暟鎹紓甯� : ", e);
+ return saveFlag;
+ } finally {
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToBoCust銆戜繚瀛樻暟鎹嚭鍙� : saveFlag:" + saveFlag);
+ return saveFlag;
}
- LoggerEngine.debug("----銆怳serServiceDAOImpl.saveDataToBoCust銆戜繚瀛樻暟鎹嚭鍙� : " + returnInfo);
- return returnInfo;
+
}
/**
* 淇濆瓨鐢ㄦ埛灞炴�э紙杩囩▼琛級
- * 鎵归噺淇濆瓨浼犲叆鍙傛暟蹇呴』涓�涓狫SONArray to string
+ *
* @param boCustAttr 鐢ㄦ埛灞炴��
* @return
* @throws RuntimeException
*/
@Override
- public String saveDataToBoCustAttr(String boCustAttr) throws RuntimeException {
+ public int saveDataToBoCustAttr(BoCustAttr boCustAttr) throws RuntimeException {
- LoggerEngine.debug("----銆怳serServiceDAOImpl.saveDataToBoCustAttr銆戜繚瀛樻暟鎹叆鍙� : " + boCustAttr);
- List<Map> reqList = null;
- String returnInfo = null;
- try{
- reqList = this.simpleValidateJSONArrayReturnList(boCustAttr);
- }catch (RuntimeException e){
- return e.getMessage();
- }
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToBoCustAttr銆戜繚瀛樻暟鎹叆鍙� : " + boCustAttr);
//涓轰簡淇濋櫓璧疯锛屽啀娴嬫娴媟eqList 鏄惁鏈夊��
- if(reqList == null || reqList.size() == 0){
- returnInfo = ProtocolUtil.createResultMsg(ResponseConstant.RESULT_CODE_PARAM_ERROR,"鍏ュ弬閿欒",null);
- LoggerEngine.debug("----銆怳serServiceDAOImpl.saveDataToBoCustAttr銆戜繚瀛樻暟鎹嚭閿� : " + returnInfo);
- return returnInfo;
+ if (boCustAttr == null) {
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToBoCustAttr銆戜繚瀛樻暟鎹嚭閿� : " + boCustAttr);
+ return 0;
}
- 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("----銆怳serServiceDAOImpl.saveDataToBoCustAttr銆戜繚瀛樻暟鎹紓甯� : " + boCustAttrMap.toString());
- throw new RuntimeException(CommonConstant.SAVE_DATA_ERROR+"淇濆瓨鏁版嵁澶辫触锛�"+boCustAttrMap.toString());
- }
+
+ saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToBoCustAttr", boCustAttr);
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToBoCustAttr銆戜繚瀛樻暟鎹嚭鍙� :saveFlag " + saveFlag);
+
+ return saveFlag;
+
+ }
+
+ /**
+ * 淇濆瓨瀹炰緥鏁版嵁 瀹㈡埛淇℃伅鑷矯ust琛ㄤ腑
+ *
+ * @param cust
+ * @return
+ * @throws RuntimeException
+ */
+ @Override
+ public int saveDataToCust(Cust cust) throws RuntimeException {
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToCust銆戜繚瀛樻暟鎹叆鍙� : " + cust);
+ //涓轰簡淇濋櫓璧疯锛屽啀娴嬫娴媟eqList 鏄惁鏈夊��
+ if (cust == null) {
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToCust銆戜繚瀛樻暟鎹嚭閿� : " + cust);
+ throw new IllegalArgumentException("璇锋眰鍙傛暟閿欒锛宑ust : " + cust);
}
- returnInfo = ProtocolUtil.createResultMsg(ResponseConstant.RESULT_CODE_SUCCESS,"鎴愬姛",null);
- LoggerEngine.debug("----銆怳serServiceDAOImpl.saveDataToBoCustAttr銆戜繚瀛樻暟鎹嚭鍙� : " + returnInfo);
- return returnInfo;
+ int saveFlag = 0;
+
+ saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToCust", cust);
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToCust銆戜繚瀛樻暟鎹嚭鍙� :saveFlag " + saveFlag);
+
+ return saveFlag;
+ }
+
+ /**
+ * 淇濆瓨瀹炰緥鏁版嵁 瀹㈡埛灞炴�т俊鎭嚦CustAttr琛ㄤ腑
+ *
+ * @param custAttr
+ * @return
+ * @throws RuntimeException
+ */
+ @Override
+ public int saveDataToCustAttr(CustAttr custAttr) throws RuntimeException {
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToCust銆戜繚瀛樻暟鎹叆鍙� : " + custAttr);
+ //涓轰簡淇濋櫓璧疯锛屽啀娴嬫娴媟eqList 鏄惁鏈夊��
+ if (custAttr == null) {
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToCust銆戜繚瀛樻暟鎹嚭閿� : " + custAttr);
+ throw new IllegalArgumentException("璇锋眰鍙傛暟閿欒锛宑ustAttr : " + custAttr);
+ }
+ int saveFlag = 0;
+
+ saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToCustAttr", custAttr);
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToCust銆戜繚瀛樻暟鎹嚭鍙� :saveFlag " + saveFlag);
+
+ return saveFlag;
+ }
+
+ /**
+ * 鍒犻櫎鐢ㄦ埛鍩烘湰淇℃伅锛堝疄渚嬫暟鎹級
+ *
+ * @param cust
+ * @return
+ * @throws RuntimeException
+ */
+ public int deleteDataToCust(Cust cust) throws RuntimeException {
+ logger.debug("----銆恥serServiceDaoImpl.deleteDataToCust銆戜繚瀛樻暟鎹叆鍙� : " + cust);
+ //涓轰簡淇濋櫓璧疯锛屽啀娴嬫娴媟eqList 鏄惁鏈夊��
+ if (cust == null) {
+ logger.debug("----銆恥serServiceDaoImpl.deleteDataToCust銆戜繚瀛樻暟鎹嚭閿� : " + cust);
+ throw new IllegalArgumentException("璇锋眰鍙傛暟閿欒锛宑ust : " + cust);
+ }
+ int saveFlag = 0;
+
+ saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.deleteDataToCust", cust);
+ logger.debug("----銆恥serServiceDaoImpl.deleteDataToCust銆戜繚瀛樻暟鎹嚭鍙� :saveFlag " + saveFlag);
+
+ return saveFlag;
+ }
+
+ /**
+ * 鍒犻櫎鐢ㄦ埛灞炴�э紙瀹炰緥鏁版嵁锛�
+ *
+ * @param custAttr
+ * @return
+ * @throws RuntimeException
+ */
+ public int deleteDataToCustAttr(CustAttr custAttr) throws RuntimeException {
+ logger.debug("----銆恥serServiceDaoImpl.deleteDataToCustAttr銆戜繚瀛樻暟鎹叆鍙� : " + custAttr);
+ //涓轰簡淇濋櫓璧疯锛屽啀娴嬫娴媟eqList 鏄惁鏈夊��
+ if (custAttr == null) {
+ logger.debug("----銆恥serServiceDaoImpl.deleteDataToCustAttr銆戜繚瀛樻暟鎹嚭閿� : " + custAttr);
+ throw new IllegalArgumentException("璇锋眰鍙傛暟閿欒锛宑ustAttr : " + custAttr);
+ }
+ int saveFlag = 0;
+
+ saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.deleteDataToCustAttr", custAttr);
+ logger.debug("----銆恥serServiceDaoImpl.deleteDataToCustAttr銆戜繚瀛樻暟鎹嚭鍙� :saveFlag " + saveFlag);
+
+ return saveFlag;
}
/**
* 鍚屾椂淇濆瓨瀹㈡埛鍩烘湰淇℃伅鍜屽鎴峰睘鎬�
+ * 鍏ュ弬涓猴細
+ *
* @param boCustInfo 鐢ㄦ埛淇℃伅
* @return
* @throws RuntimeException
@@ -106,32 +186,8 @@
@Override
public String saveDataToBoCustAndBoCustAttr(String boCustInfo) throws RuntimeException {
- LoggerEngine.debug("----銆怳serServiceDAOImpl.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);
- //瑙f瀽杩斿洖鍐呭
- }
+ logger.debug("----銆恥serServiceDaoImpl.saveDataToBoCustAndBoCustAttr銆戜繚瀛樻暟鎹叆鍙�" + boCustInfo);
- return null;
- }
-
- @Override
- public String saveDataToCust(String cust) throws RuntimeException {
- return null;
- }
-
- @Override
- public String saveDataToCustAttr(String custAttr) throws RuntimeException {
return null;
}
@@ -155,18 +211,441 @@
return null;
}
+ /**
+ * 鏍规嵁瀹㈡埛ID鏌ヨ瀹㈡埛淇℃伅锛屽寘鎷熀鏈俊鎭拰灞炴�т俊鎭�
+ *
+ * @param cust
+ * @return
+ * @throws RuntimeException
+ */
@Override
- public String queryDataToCust(String cust) throws RuntimeException {
- return null;
+ public Cust queryDataToCust(Cust cust) throws RuntimeException {
+ logger.debug("----銆恥serServiceDaoImpl.queryDataToCust銆戜繚瀛樻暟鎹叆鍙� : " + cust);
+ //涓轰簡淇濋櫓璧疯锛屽啀娴嬫娴媟eqList 鏄惁鏈夊��
+ if (cust == null) {
+ logger.debug("----銆恥serServiceDaoImpl.queryDataToCust銆戜繚瀛樻暟鎹嚭閿� : " + cust);
+ throw new IllegalArgumentException("璇锋眰鍙傛暟閿欒锛宑ust : " + cust);
+ }
+
+ Cust newCust = sqlSessionTemplate.selectOne("userServiceDaoImpl.queryDataToCust", cust);
+
+ logger.debug("----銆恥serServiceDaoImpl.queryDataToCust銆戜繚瀛樻暟鎹嚭鍙� :newCust " + newCust);
+
+ return newCust;
}
+ /**
+ * 鏌ヨ瀹㈡埛灞炴�т俊鎭�
+ *
+ * @param custAttr 瀵硅薄
+ * @return
+ * @throws RuntimeException
+ */
@Override
- public String queryDataToCustAttr(String custAttr) throws RuntimeException {
- return null;
+ public List<CustAttr> queryDataToCustAttr(CustAttr custAttr) throws RuntimeException {
+ logger.debug("----銆恥serServiceDaoImpl.queryDataToCustAttr銆戜繚瀛樻暟鎹叆鍙� : " + custAttr);
+ //涓轰簡淇濋櫓璧疯锛屽啀娴嬫娴媟eqList 鏄惁鏈夊��
+ if (custAttr == null) {
+ logger.debug("----銆恥serServiceDaoImpl.queryDataToCust銆戜繚瀛樻暟鎹嚭閿� : " + custAttr);
+ throw new IllegalArgumentException("璇锋眰鍙傛暟閿欒锛孋ustAttr : " + custAttr);
+ }
+
+ List<CustAttr> custAttrs = sqlSessionTemplate.selectList("userServiceDaoImpl.queryDataToCustAttr", custAttr);
+
+ logger.debug("----銆恥serServiceDaoImpl.queryDataToCust銆戜繚瀛樻暟鎹嚭鍙� :custAttrs " + custAttrs);
+
+ return custAttrs;
}
@Override
public String queryDataToCustAndCustAttr(String custInfo) throws RuntimeException {
return null;
}
+
+ /**
+ * 鏌ヨ 瀹㈡埛鍩烘湰淇℃伅锛堣繃绋嬭〃bo_cust锛�
+ *
+ * @param boCust
+ * @return
+ * @throws Exception
+ */
+ public List<BoCust> queryBoCust(BoCust boCust) throws Exception {
+ logger.debug("----銆恥serServiceDaoImpl.queryBoCustAttr銆�:" + boCust);
+
+ Assert.isNull(boCust, "鏌ヨbo_cust 鍏ュ弬涓虹┖");
+
+ return sqlSessionTemplate.selectList("userServiceDaoImpl.queryBoCust", boCust);
+ }
+
+ /**
+ * 鏌ヨ 瀹㈡埛灞炴�т俊鎭紙杩囩▼琛� bo_cust_attr锛�
+ *
+ * @param boCustAttr
+ * @return
+ * @throws Exception
+ */
+ public List<BoCustAttr> queryBoCustAttr(BoCustAttr boCustAttr) throws Exception {
+
+ logger.debug("銆恥serServiceDaoImpl.queryBoCustAttr銆�:" + boCustAttr);
+
+ Assert.isNull(boCustAttr, "鏌ヨbo_cust_attr 鍏ュ弬涓虹┖");
+
+ return sqlSessionTemplate.selectList("userServiceDaoImpl.queryBoCustAttr", boCustAttr);
+
+ }
+
+ /**
+ * 淇濆瓨鐢ㄦ埛淇℃伅
+ *
+ * @param userInfo
+ * @throws DAOException
+ */
+ @Override
+ public void saveBusinessUserInfo(Map userInfo) throws DAOException {
+ logger.debug("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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> queryUsersInfo(Map info) throws DAOException {
+ Assert.notNull(info, "queryUserInfo 鐨勫弬鏁颁笉鑳戒负绌�");
+ logger.debug("----銆恥serServiceDaoImpl.queryUserInfo銆戜繚瀛樻暟鎹叆鍙� : " + JSONObject.toJSONString(info));
+ List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryUserInfo", info);
+
+ return users;
+ }
+
+ /**
+ * 鏌ヨ鐢ㄦ埛淇℃伅
+ *
+ * @param info
+ * @return
+ * @throws DAOException
+ */
+ @Override
+ public List<Map> queryUserInfoAttrs(Map info) throws DAOException {
+ Assert.notNull(info, "queryUserInfo 鐨勫弬鏁颁笉鑳戒负绌�");
+ logger.debug("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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 浠巄usiness 涓煡鍑虹殑鏁版嵁
+ * @throws DAOException 鏁版嵁澶勭悊寮傚父
+ */
+ public void saveUserAddressInstance(Map businessUserAddress) throws DAOException {
+ logger.debug("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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 浠巄usiness 涓煡鍑虹殑鏁版嵁
+ * @throws DAOException 鏁版嵁澶勭悊寮傚父
+ */
+ public void saveUserTagInstance(Map businessUserTag) throws DAOException {
+ logger.debug("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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 浠巄usiness 涓煡鍑虹殑鏁版嵁
+ * @throws DAOException 鏁版嵁澶勭悊寮傚父
+ */
+ public void saveUserCredentialsInstance(Map businessUserCredentials) throws DAOException {
+ logger.debug("----銆恥serServiceDaoImpl.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("----銆恥serServiceDaoImpl.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));
+ }
+ }
}
--
Gitblit v1.8.0