UserServiceDaoImpl.java 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652
  1. package com.java110.user.dao.impl;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.java110.common.constant.ResponseConstant;
  4. import com.java110.common.exception.DAOException;
  5. import com.java110.common.util.Assert;
  6. import com.java110.core.base.dao.BaseServiceDao;
  7. import com.java110.entity.user.BoCust;
  8. import com.java110.entity.user.BoCustAttr;
  9. import com.java110.entity.user.Cust;
  10. import com.java110.entity.user.CustAttr;
  11. import com.java110.user.dao.IUserServiceDao;
  12. import org.slf4j.Logger;
  13. import org.slf4j.LoggerFactory;
  14. import org.springframework.stereotype.Service;
  15. import org.springframework.transaction.annotation.Transactional;
  16. import java.util.List;
  17. import java.util.Map;
  18. /**
  19. * 用户服务 与数据库交互
  20. * Created by wuxw on 2017/4/5.
  21. */
  22. /**
  23. * 用户信息实现工程
  24. * Created by wuxw on 2016/12/27.
  25. */
  26. @Service("userServiceDaoImpl")
  27. @Transactional
  28. public class UserServiceDaoImpl extends BaseServiceDao implements IUserServiceDao {
  29. private final static Logger logger = LoggerFactory.getLogger(UserServiceDaoImpl.class);
  30. /**
  31. * 保存用户基本信息
  32. * 功能只用与保存用户处理
  33. *
  34. * @param boCust 用户基本信息
  35. * @return
  36. */
  37. @Override
  38. public int saveDataToBoCust(BoCust boCust) throws RuntimeException {
  39. logger.debug("----【userServiceDaoImpl.saveDataToBoCust】保存数据入参 : " + boCust);
  40. int saveFlag = 0;
  41. try {
  42. saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToBoCust", boCust);
  43. } catch (RuntimeException e) {
  44. logger.error("----【userServiceDaoImpl.saveDataToBoCust】保存数据异常 : ", e);
  45. return saveFlag;
  46. } finally {
  47. logger.debug("----【userServiceDaoImpl.saveDataToBoCust】保存数据出参 : saveFlag:" + saveFlag);
  48. return saveFlag;
  49. }
  50. }
  51. /**
  52. * 保存用户属性(过程表)
  53. *
  54. * @param boCustAttr 用户属性
  55. * @return
  56. * @throws RuntimeException
  57. */
  58. @Override
  59. public int saveDataToBoCustAttr(BoCustAttr boCustAttr) throws RuntimeException {
  60. logger.debug("----【userServiceDaoImpl.saveDataToBoCustAttr】保存数据入参 : " + boCustAttr);
  61. //为了保险起见,再测检测reqList 是否有值
  62. if (boCustAttr == null) {
  63. logger.debug("----【userServiceDaoImpl.saveDataToBoCustAttr】保存数据出错 : " + boCustAttr);
  64. return 0;
  65. }
  66. int saveFlag = 0;
  67. saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToBoCustAttr", boCustAttr);
  68. logger.debug("----【userServiceDaoImpl.saveDataToBoCustAttr】保存数据出参 :saveFlag " + saveFlag);
  69. return saveFlag;
  70. }
  71. /**
  72. * 保存实例数据 客户信息至Cust表中
  73. *
  74. * @param cust
  75. * @return
  76. * @throws RuntimeException
  77. */
  78. @Override
  79. public int saveDataToCust(Cust cust) throws RuntimeException {
  80. logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据入参 : " + cust);
  81. //为了保险起见,再测检测reqList 是否有值
  82. if (cust == null) {
  83. logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出错 : " + cust);
  84. throw new IllegalArgumentException("请求参数错误,cust : " + cust);
  85. }
  86. int saveFlag = 0;
  87. saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToCust", cust);
  88. logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag);
  89. return saveFlag;
  90. }
  91. /**
  92. * 保存实例数据 客户属性信息至CustAttr表中
  93. *
  94. * @param custAttr
  95. * @return
  96. * @throws RuntimeException
  97. */
  98. @Override
  99. public int saveDataToCustAttr(CustAttr custAttr) throws RuntimeException {
  100. logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据入参 : " + custAttr);
  101. //为了保险起见,再测检测reqList 是否有值
  102. if (custAttr == null) {
  103. logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出错 : " + custAttr);
  104. throw new IllegalArgumentException("请求参数错误,custAttr : " + custAttr);
  105. }
  106. int saveFlag = 0;
  107. saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveDataToCustAttr", custAttr);
  108. logger.debug("----【userServiceDaoImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag);
  109. return saveFlag;
  110. }
  111. /**
  112. * 删除用户基本信息(实例数据)
  113. *
  114. * @param cust
  115. * @return
  116. * @throws RuntimeException
  117. */
  118. public int deleteDataToCust(Cust cust) throws RuntimeException {
  119. logger.debug("----【userServiceDaoImpl.deleteDataToCust】保存数据入参 : " + cust);
  120. //为了保险起见,再测检测reqList 是否有值
  121. if (cust == null) {
  122. logger.debug("----【userServiceDaoImpl.deleteDataToCust】保存数据出错 : " + cust);
  123. throw new IllegalArgumentException("请求参数错误,cust : " + cust);
  124. }
  125. int saveFlag = 0;
  126. saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.deleteDataToCust", cust);
  127. logger.debug("----【userServiceDaoImpl.deleteDataToCust】保存数据出参 :saveFlag " + saveFlag);
  128. return saveFlag;
  129. }
  130. /**
  131. * 删除用户属性(实例数据)
  132. *
  133. * @param custAttr
  134. * @return
  135. * @throws RuntimeException
  136. */
  137. public int deleteDataToCustAttr(CustAttr custAttr) throws RuntimeException {
  138. logger.debug("----【userServiceDaoImpl.deleteDataToCustAttr】保存数据入参 : " + custAttr);
  139. //为了保险起见,再测检测reqList 是否有值
  140. if (custAttr == null) {
  141. logger.debug("----【userServiceDaoImpl.deleteDataToCustAttr】保存数据出错 : " + custAttr);
  142. throw new IllegalArgumentException("请求参数错误,custAttr : " + custAttr);
  143. }
  144. int saveFlag = 0;
  145. saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.deleteDataToCustAttr", custAttr);
  146. logger.debug("----【userServiceDaoImpl.deleteDataToCustAttr】保存数据出参 :saveFlag " + saveFlag);
  147. return saveFlag;
  148. }
  149. /**
  150. * 同时保存客户基本信息和客户属性
  151. * 入参为:
  152. *
  153. * @param boCustInfo 用户信息
  154. * @return
  155. * @throws RuntimeException
  156. */
  157. @Override
  158. public String saveDataToBoCustAndBoCustAttr(String boCustInfo) throws RuntimeException {
  159. logger.debug("----【userServiceDaoImpl.saveDataToBoCustAndBoCustAttr】保存数据入参" + boCustInfo);
  160. return null;
  161. }
  162. @Override
  163. public String saveDataToCustAndCustAttr(String custInfo) throws RuntimeException {
  164. return null;
  165. }
  166. @Override
  167. public String updateDataToCust(String cust) throws RuntimeException {
  168. return null;
  169. }
  170. @Override
  171. public String updateDataToCustAttr(String custAttr) throws RuntimeException {
  172. return null;
  173. }
  174. @Override
  175. public String updateDataToCustAndCustAttr(String custInfo) throws RuntimeException {
  176. return null;
  177. }
  178. /**
  179. * 根据客户ID查询客户信息,包括基本信息和属性信息
  180. *
  181. * @param cust
  182. * @return
  183. * @throws RuntimeException
  184. */
  185. @Override
  186. public Cust queryDataToCust(Cust cust) throws RuntimeException {
  187. logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据入参 : " + cust);
  188. //为了保险起见,再测检测reqList 是否有值
  189. if (cust == null) {
  190. logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出错 : " + cust);
  191. throw new IllegalArgumentException("请求参数错误,cust : " + cust);
  192. }
  193. Cust newCust = sqlSessionTemplate.selectOne("userServiceDaoImpl.queryDataToCust", cust);
  194. logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出参 :newCust " + newCust);
  195. return newCust;
  196. }
  197. /**
  198. * 查询客户属性信息
  199. *
  200. * @param custAttr 对象
  201. * @return
  202. * @throws RuntimeException
  203. */
  204. @Override
  205. public List<CustAttr> queryDataToCustAttr(CustAttr custAttr) throws RuntimeException {
  206. logger.debug("----【userServiceDaoImpl.queryDataToCustAttr】保存数据入参 : " + custAttr);
  207. //为了保险起见,再测检测reqList 是否有值
  208. if (custAttr == null) {
  209. logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出错 : " + custAttr);
  210. throw new IllegalArgumentException("请求参数错误,CustAttr : " + custAttr);
  211. }
  212. List<CustAttr> custAttrs = sqlSessionTemplate.selectList("userServiceDaoImpl.queryDataToCustAttr", custAttr);
  213. logger.debug("----【userServiceDaoImpl.queryDataToCust】保存数据出参 :custAttrs " + custAttrs);
  214. return custAttrs;
  215. }
  216. @Override
  217. public String queryDataToCustAndCustAttr(String custInfo) throws RuntimeException {
  218. return null;
  219. }
  220. /**
  221. * 查询 客户基本信息(过程表bo_cust)
  222. *
  223. * @param boCust
  224. * @return
  225. * @throws Exception
  226. */
  227. public List<BoCust> queryBoCust(BoCust boCust) throws Exception {
  228. logger.debug("----【userServiceDaoImpl.queryBoCustAttr】:" + boCust);
  229. Assert.isNull(boCust, "查询bo_cust 入参为空");
  230. return sqlSessionTemplate.selectList("userServiceDaoImpl.queryBoCust", boCust);
  231. }
  232. /**
  233. * 查询 客户属性信息(过程表 bo_cust_attr)
  234. *
  235. * @param boCustAttr
  236. * @return
  237. * @throws Exception
  238. */
  239. public List<BoCustAttr> queryBoCustAttr(BoCustAttr boCustAttr) throws Exception {
  240. logger.debug("【userServiceDaoImpl.queryBoCustAttr】:" + boCustAttr);
  241. Assert.isNull(boCustAttr, "查询bo_cust_attr 入参为空");
  242. return sqlSessionTemplate.selectList("userServiceDaoImpl.queryBoCustAttr", boCustAttr);
  243. }
  244. /**
  245. * 保存用户信息
  246. *
  247. * @param userInfo
  248. * @throws DAOException
  249. */
  250. @Override
  251. public void saveBusinessUserInfo(Map userInfo) throws DAOException {
  252. logger.debug("----【userServiceDaoImpl.saveBusinessUserInfo】保存数据入参 : " + JSONObject.toJSONString(userInfo));
  253. // 查询business_user 数据是否已经存在
  254. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserInfo", userInfo);
  255. if (saveFlag < 1) {
  256. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户数据失败:" + JSONObject.toJSONString(userInfo));
  257. }
  258. }
  259. /**
  260. * 保存用户属性
  261. *
  262. * @param userAttr
  263. * @throws DAOException
  264. */
  265. @Override
  266. public void saveBusinessUserAttr(Map userAttr) throws DAOException {
  267. logger.debug("----【userServiceDaoImpl.saveBusinessUserAttr】保存数据入参 : " + JSONObject.toJSONString(userAttr));
  268. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserAttr", userAttr);
  269. if (saveFlag < 1) {
  270. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户属性数据失败:" + JSONObject.toJSONString(userAttr));
  271. }
  272. }
  273. @Override
  274. public void saveUserInfoInstance(Map businessUser) {
  275. logger.debug("----【userServiceDaoImpl.saveUserInfoInstance】保存数据入参 : " + JSONObject.toJSONString(businessUser));
  276. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserInfoInstance", businessUser);
  277. if (saveFlag < 1) {
  278. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户Instance数据失败:" + JSONObject.toJSONString(businessUser));
  279. }
  280. }
  281. @Override
  282. public void saveUserAttrInstance(Map attrInstance) {
  283. logger.debug("----【userServiceDaoImpl.saveUserAttrInstance】保存数据入参 : " + JSONObject.toJSONString(attrInstance));
  284. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserAttrInstance", attrInstance);
  285. if (saveFlag < 1) {
  286. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户Instance数据失败:" + JSONObject.toJSONString(attrInstance));
  287. }
  288. }
  289. @Override
  290. public void updateUserInfoInstance(Map businessUser) {
  291. logger.debug("----【userServiceDaoImpl.updateUserInfoInstance】保存数据入参 : " + JSONObject.toJSONString(businessUser));
  292. int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserInfoInstance", businessUser);
  293. if (saveFlag < 1) {
  294. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "修改用户Instance数据失败:" + JSONObject.toJSONString(businessUser));
  295. }
  296. }
  297. @Override
  298. public void updateUserAttrInstance(Map attrInstance) {
  299. logger.debug("----【userServiceDaoImpl.updateUserAttrInstance】保存数据入参 : " + JSONObject.toJSONString(attrInstance));
  300. int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserAttrInstance", attrInstance);
  301. if (saveFlag < 1) {
  302. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "修改用户Instance数据失败:" + JSONObject.toJSONString(attrInstance));
  303. }
  304. }
  305. /**
  306. * 查询用户信息
  307. *
  308. * @param info
  309. * @return
  310. * @throws DAOException
  311. */
  312. public Map queryBusinessUserInfo(Map info) throws DAOException {
  313. Assert.notNull(info, "queryBusinessUserInfo 的参数不能为空");
  314. logger.debug("----【userServiceDaoImpl.queryBusinessUserInfo】保存数据入参 : " + JSONObject.toJSONString(info));
  315. List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserInfo", info);
  316. if (users == null || users.size() == 0) {
  317. return null;
  318. }
  319. return users.get(0);
  320. }
  321. /**
  322. * 查询用户信息
  323. *
  324. * @param info
  325. * @return
  326. * @throws DAOException
  327. */
  328. public List<Map> queryBusinessUserInfoAttrs(Map info) throws DAOException {
  329. Assert.notNull(info, "queryBusinessUserInfoAttrs 的参数不能为空");
  330. logger.debug("----【userServiceDaoImpl.queryBusinessUserInfoAttrs】保存数据入参 : " + JSONObject.toJSONString(info));
  331. List<Map> userAttrs = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserInfoAttrs", info);
  332. return userAttrs;
  333. }
  334. /**
  335. * 查询用户信息
  336. *
  337. * @param info
  338. * @return
  339. * @throws DAOException
  340. */
  341. @Override
  342. public Map queryUserInfo(Map info) throws DAOException {
  343. Assert.notNull(info, "queryUserInfo 的参数不能为空");
  344. logger.debug("----【userServiceDaoImpl.queryUserInfo】保存数据入参 : " + JSONObject.toJSONString(info));
  345. List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryUserInfo", info);
  346. if (users == null || users.size() == 0) {
  347. return null;
  348. }
  349. return users.get(0);
  350. }
  351. /**
  352. * 查询用户信息
  353. *
  354. * @param info
  355. * @return
  356. * @throws DAOException
  357. */
  358. @Override
  359. public List<Map> queryUsersInfo(Map info) throws DAOException {
  360. Assert.notNull(info, "queryUserInfo 的参数不能为空");
  361. logger.debug("----【userServiceDaoImpl.queryUserInfo】保存数据入参 : " + JSONObject.toJSONString(info));
  362. List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryUserInfo", info);
  363. return users;
  364. }
  365. /**
  366. * 查询用户信息
  367. *
  368. * @param info
  369. * @return
  370. * @throws DAOException
  371. */
  372. @Override
  373. public List<Map> queryUserInfoAttrs(Map info) throws DAOException {
  374. Assert.notNull(info, "queryUserInfo 的参数不能为空");
  375. logger.debug("----【userServiceDaoImpl.updateUserAttrInstance】保存数据入参 : " + JSONObject.toJSONString(info));
  376. List<Map> userAttrs = sqlSessionTemplate.selectList("userServiceDaoImpl.queryUserInfoAttrs", info);
  377. return userAttrs;
  378. }
  379. /**
  380. * 保存用户地址信息
  381. * Business 过程
  382. *
  383. * @param userAddress 用户地址信息
  384. * @throws DAOException
  385. */
  386. public void saveBusinessUserAddress(Map userAddress) throws DAOException {
  387. logger.debug("----【userServiceDaoImpl.saveBusinessUserAddress】保存数据入参 : " + JSONObject.toJSONString(userAddress));
  388. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserAddress", userAddress);
  389. if (saveFlag < 1) {
  390. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户地址数据失败:" + JSONObject.toJSONString(userAddress));
  391. }
  392. }
  393. /**
  394. * 查询用户地址信息
  395. * business 过程
  396. *
  397. * @param info b_id
  398. * @return 查询到的用户地址信息
  399. * @throws DAOException
  400. */
  401. public Map queryBusinessUserAddress(Map info) throws DAOException {
  402. Assert.notNull(info, "queryBusinessUserAddress 的参数不能为空");
  403. logger.debug("----【userServiceDaoImpl.queryBusinessUserAddress】保存数据入参 : " + JSONObject.toJSONString(info));
  404. List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserAddress", info);
  405. if (users == null || users.size() == 0) {
  406. return null;
  407. }
  408. return users.get(0);
  409. }
  410. /**
  411. * 保存用户地址 Business 数据到 Instance
  412. *
  413. * @param businessUserAddress 从business 中查出的数据
  414. * @throws DAOException 数据处理异常
  415. */
  416. public void saveUserAddressInstance(Map businessUserAddress) throws DAOException {
  417. logger.debug("----【userServiceDaoImpl.saveUserAddressInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserAddress));
  418. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserAddressInstance", businessUserAddress);
  419. if (saveFlag < 1) {
  420. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户地址Instance数据失败:" + JSONObject.toJSONString(businessUserAddress));
  421. }
  422. }
  423. /**
  424. * 作废用户地址信息数据
  425. *
  426. * @param businessUserAddress 用户地址信息 b_id
  427. * @throws DAOException 数据处理异常
  428. */
  429. public void updateUserAddressInstance(Map businessUserAddress) throws DAOException {
  430. logger.debug("----【userServiceDaoImpl.updateUserAddressInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserAddress));
  431. int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserAddressInstance", businessUserAddress);
  432. if (saveFlag < 1) {
  433. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "修改用户Instance数据失败:" + JSONObject.toJSONString(businessUserAddress));
  434. }
  435. }
  436. /**
  437. * 保存用户打标信息
  438. * Business 过程
  439. *
  440. * @param userTag 用户打标信息
  441. * @throws DAOException
  442. */
  443. public void saveBusinessUserTag(Map userTag) throws DAOException {
  444. logger.debug("----【userServiceDaoImpl.saveBusinessUserTag】保存数据入参 : " + JSONObject.toJSONString(userTag));
  445. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserTag", userTag);
  446. if (saveFlag < 1) {
  447. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户打标数据失败:" + JSONObject.toJSONString(userTag));
  448. }
  449. }
  450. /**
  451. * 查询用户打标信息
  452. * business 过程
  453. *
  454. * @param info b_id
  455. * @return 查询到的用户打标信息
  456. * @throws DAOException
  457. */
  458. public Map queryBusinessUserTag(Map info) throws DAOException {
  459. Assert.notNull(info, "queryBusinessUserTag 的参数不能为空");
  460. logger.debug("----【userServiceDaoImpl.queryBusinessUserTag】保存数据入参 : " + JSONObject.toJSONString(info));
  461. List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserTag", info);
  462. if (users == null || users.size() == 0) {
  463. return null;
  464. }
  465. return users.get(0);
  466. }
  467. /**
  468. * 保存Business 数据到 Instance
  469. *
  470. * @param businessUserTag 从business 中查出的数据
  471. * @throws DAOException 数据处理异常
  472. */
  473. public void saveUserTagInstance(Map businessUserTag) throws DAOException {
  474. logger.debug("----【userServiceDaoImpl.saveUserTagInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserTag));
  475. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserTagInstance", businessUserTag);
  476. if (saveFlag < 1) {
  477. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户打标Instance数据失败:" + JSONObject.toJSONString(businessUserTag));
  478. }
  479. }
  480. /**
  481. * 作废用户打标数据
  482. *
  483. * @param businessUserTag 用户地址信息 b_id
  484. * @throws DAOException 数据处理异常
  485. */
  486. public void updateUserTagInstance(Map businessUserTag) throws DAOException {
  487. logger.debug("----【userServiceDaoImpl.updateUserTagInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserTag));
  488. int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserTagInstance", businessUserTag);
  489. if (saveFlag < 1) {
  490. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "修改用户Instance数据失败:" + JSONObject.toJSONString(businessUserTag));
  491. }
  492. }
  493. /**
  494. * 保存用户证件信息
  495. * Business 过程
  496. *
  497. * @param userCredentials 用户证件信息
  498. * @throws DAOException
  499. */
  500. public void saveBusinessUserCredentials(Map userCredentials) throws DAOException {
  501. logger.debug("----【userServiceDaoImpl.saveBusinessUserCredentials】保存数据入参 : " + JSONObject.toJSONString(userCredentials));
  502. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveBusinessUserCredentials", userCredentials);
  503. if (saveFlag < 1) {
  504. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户打标数据失败:" + JSONObject.toJSONString(userCredentials));
  505. }
  506. }
  507. /**
  508. * 查询用户证件信息
  509. * business 过程
  510. *
  511. * @param info b_id
  512. * @return 查询到的用户打标信息
  513. * @throws DAOException
  514. */
  515. public Map queryBusinessUserCredentials(Map info) throws DAOException {
  516. Assert.notNull(info, "queryBusinessUserCredentials 的参数不能为空");
  517. logger.debug("----【userServiceDaoImpl.queryBusinessUserCredentials】保存数据入参 : " + JSONObject.toJSONString(info));
  518. List<Map> users = sqlSessionTemplate.selectList("userServiceDaoImpl.queryBusinessUserCredentials", info);
  519. if (users == null || users.size() == 0) {
  520. return null;
  521. }
  522. return users.get(0);
  523. }
  524. /**
  525. * 保存Business 数据到 Instance
  526. *
  527. * @param businessUserCredentials 从business 中查出的数据
  528. * @throws DAOException 数据处理异常
  529. */
  530. public void saveUserCredentialsInstance(Map businessUserCredentials) throws DAOException {
  531. logger.debug("----【userServiceDaoImpl.saveUserCredentialsInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserCredentials));
  532. int saveFlag = sqlSessionTemplate.insert("userServiceDaoImpl.saveUserCredentialsInstance", businessUserCredentials);
  533. if (saveFlag < 1) {
  534. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存用户打标Instance数据失败:" + JSONObject.toJSONString(businessUserCredentials));
  535. }
  536. }
  537. /**
  538. * 作废用户证件数据
  539. *
  540. * @param businessUserCredentials 用户地址信息 b_id
  541. * @throws DAOException 数据处理异常
  542. */
  543. public void updateUserCredentialsInstance(Map businessUserCredentials) throws DAOException {
  544. logger.debug("----【userServiceDaoImpl.updateUserCredentialsInstance】保存数据入参 : " + JSONObject.toJSONString(businessUserCredentials));
  545. int saveFlag = sqlSessionTemplate.update("userServiceDaoImpl.updateUserCredentialsInstance", businessUserCredentials);
  546. if (saveFlag < 1) {
  547. throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "修改用户Instance数据失败:" + JSONObject.toJSONString(businessUserCredentials));
  548. }
  549. }
  550. }