SysCompanyServiceImpl.java 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324
  1. package com.dgtly.system.service.impl;
  2. import java.util.ArrayList;
  3. import java.util.Date;
  4. import java.util.List;
  5. import com.dgtly.common.constant.UserConstants;
  6. import com.dgtly.common.core.domain.Ztree;
  7. import com.dgtly.common.exception.BusinessException;
  8. import com.dgtly.common.utils.DateUtils;
  9. import com.dgtly.common.utils.ShiroSaltUtil;
  10. import com.dgtly.common.utils.security.EncryptPassWordClass;
  11. import com.dgtly.companyext.domain.CompanyExamine;
  12. import com.dgtly.companyext.domain.CompanyReviewed;
  13. import com.dgtly.companyext.mapper.CompanyExamineMapper;
  14. import com.dgtly.companyext.mapper.CompanyReviewedMapper;
  15. import com.dgtly.system.domain.SysDept;
  16. import com.dgtly.system.domain.SysUser;
  17. import com.dgtly.system.service.ISysConfigService;
  18. import com.dgtly.system.service.ISysDeptService;
  19. import com.dgtly.system.service.ISysUserService;
  20. import org.springframework.beans.factory.annotation.Autowired;
  21. import org.springframework.stereotype.Service;
  22. import com.dgtly.system.mapper.SysCompanyMapper;
  23. import com.dgtly.system.domain.SysCompany;
  24. import com.dgtly.system.service.ISysCompanyService;
  25. import com.dgtly.common.core.text.Convert;
  26. import org.springframework.transaction.annotation.Transactional;
  27. /**
  28. * 公司表Service业务层处理
  29. *
  30. * @author dgtly
  31. * @date 2020-01-08
  32. */
  33. @Service
  34. public class SysCompanyServiceImpl implements ISysCompanyService
  35. {
  36. @Autowired
  37. private SysCompanyMapper sysCompanyMapper;
  38. @Autowired
  39. private ISysUserService sysUserService;
  40. @Autowired
  41. private ISysDeptService sysDeptService;
  42. @Autowired
  43. private ISysConfigService sysConfigService;
  44. @Autowired
  45. private CompanyReviewedMapper companyReviewedMapper;
  46. @Autowired
  47. private CompanyExamineMapper companyExamineMapper;
  48. /**
  49. * 查询公司表
  50. *
  51. * @param id 公司表ID
  52. * @return 公司表
  53. */
  54. @Override
  55. public SysCompany selectSysCompanyById(Long id)
  56. {
  57. return sysCompanyMapper.selectSysCompanyById(id);
  58. }
  59. /**
  60. * 查询公司表列表
  61. *
  62. * @param sysCompany 公司表
  63. * @return 公司表
  64. */
  65. @Override
  66. public List<SysCompany> selectSysCompanyList(SysCompany sysCompany)
  67. {
  68. return sysCompanyMapper.selectSysCompanyList(sysCompany);
  69. }
  70. /**
  71. * 新增公司表
  72. *
  73. * @param sysCompany 公司表
  74. * @return 结果
  75. */
  76. @Override
  77. public int insertSysCompany(SysCompany sysCompany)
  78. {
  79. sysCompany.setCreateTime(DateUtils.getNowDate());
  80. return sysCompanyMapper.insertSysCompany(sysCompany);
  81. }
  82. /**
  83. * 修改公司表
  84. *
  85. * @param sysCompany 公司表
  86. * @return 结果
  87. */
  88. @Override
  89. public int updateSysCompany(SysCompany sysCompany)
  90. {
  91. sysCompany.setUpdateTime(DateUtils.getNowDate());
  92. return sysCompanyMapper.updateSysCompany(sysCompany);
  93. }
  94. /**
  95. * 删除公司表对象
  96. *
  97. * @param ids 需要删除的数据ID
  98. * @return 结果
  99. */
  100. @Override
  101. public int deleteSysCompanyByIds(String ids)
  102. {
  103. return sysCompanyMapper.deleteSysCompanyByIds(Convert.toStrArray(ids));
  104. }
  105. /**
  106. * 删除公司表信息
  107. *
  108. * @param id 公司表ID
  109. * @return 结果
  110. */
  111. @Override
  112. public int deleteSysCompanyById(Long id)
  113. {
  114. return sysCompanyMapper.deleteSysCompanyById(id);
  115. }
  116. @Override
  117. @Transactional
  118. public int addCompany(SysCompany sysCompany,SysUser user){
  119. if (UserConstants.USER_NAME_NOT_UNIQUE.equals(sysUserService.checkLoginNameUnique(user.getLoginName())))
  120. {
  121. throw new BusinessException("新增用户'" + user.getLoginName() + "'失败,登录账号已存在");
  122. }else if (user.getPassword().length() < UserConstants.PASSWORD_MIN_LENGTH
  123. || user.getPassword().length() > UserConstants.PASSWORD_MAX_LENGTH)
  124. {
  125. throw new BusinessException("密码长度为6-19,请重新设置!!");
  126. }
  127. sysCompanyMapper.insertSysCompany(sysCompany);
  128. //创建公司主体部门
  129. SysDept dept = new SysDept();
  130. dept.setCompanyId(sysCompany.getId());
  131. dept.setDeptName(sysCompany.getCompanyName());
  132. /*父节点为100 总体结构*/
  133. dept.setParentId(Long.parseLong(sysConfigService.selectConfigByKey("sys.dept.parentId")));
  134. dept.setCreateBy(sysCompany.getCreateBy());
  135. sysDeptService.insertDept(dept);
  136. //创建管理员账号
  137. user.setSex("1");
  138. Long[] roles = {Long.parseLong(sysConfigService.selectConfigByKey("company.manager.roleId"))};
  139. user.setRoleIds(roles);
  140. user.setDeptId(dept.getDeptId());
  141. user.setCompanyId(sysCompany.getId());
  142. user.setSalt(ShiroSaltUtil.randomSalt());
  143. user.setPassword(EncryptPassWordClass.encryptPassword(user.getLoginName(), user.getPassword(), user.getSalt()));
  144. user.setCreateBy(sysCompany.getCreateBy());
  145. int rows = sysUserService.insertUser(user);
  146. return rows;
  147. }
  148. @Override
  149. public List<Ztree> selectSysCompanyTree(SysCompany sysCompany) {
  150. List<SysCompany> companies=sysCompanyMapper.selectSysCompanyList(sysCompany);
  151. return initZtree(companies);
  152. }
  153. /**
  154. * 查询热门商家列表
  155. * @param
  156. * @return
  157. */
  158. @Override
  159. public List<SysCompany> selectCompanyHotList() {
  160. return sysCompanyMapper.selectCompanyHotList();
  161. }
  162. /**
  163. * 查询公司表排除根目录公司
  164. * @param:
  165. * @return:
  166. * @auther: qxp
  167. * @date: 2020-2-25
  168. */
  169. @Override
  170. public List<SysCompany> selectSysCompanyListExRoot(SysCompany sysCompany) {
  171. return sysCompanyMapper.selectSysCompanyListExRoot(sysCompany);
  172. }
  173. /**
  174. * @descption: 树形结构初始化
  175. * @param:
  176. * @return:
  177. * @auther: qxp
  178. * @date: 2020-2-25
  179. */
  180. public List<Ztree> initZtree(List<SysCompany> companies) {
  181. List<Ztree> ztrees = new ArrayList<Ztree>();
  182. for (SysCompany company : companies)
  183. {
  184. if (UserConstants.DEPT_NORMAL.equals(company.getStatus().toString())&&company.getId()!=1L)
  185. {
  186. Ztree ztree = new Ztree();
  187. ztree.setId(company.getId());
  188. ztree.setpId(0L);
  189. ztree.setName(company.getCompanyName());
  190. ztree.setTitle(company.getCompanyName());
  191. ztrees.add(ztree);
  192. }
  193. }
  194. return ztrees;
  195. }
  196. /**
  197. * 审核入驻申请通过
  198. * @param:
  199. * @return:
  200. * @auther: qxp
  201. * @date: 2020-2-25
  202. */
  203. @Override
  204. @Transactional
  205. public int allowEnter(CompanyExamine companyExamine) {
  206. /*1.查询公司信息创建SysCompany*/
  207. /*2.创建部门*/
  208. /*3.创建管理员*/
  209. /*4.修改审核信息状态*/
  210. /*5.插入审核信息*/
  211. int i = 0;
  212. CompanyReviewed cr = companyReviewedMapper.selectCompanyReviewedById(companyExamine.getCompanyReviewedId());
  213. if(cr==null){
  214. throw new RuntimeException("创建公司实体时出错!");
  215. }
  216. SysCompany company = reviewedTocompany(cr);
  217. SysUser user= new SysUser();
  218. user.setLoginName(cr.getLoginName());
  219. user.setUserName("商户管理员");
  220. user.setPassword(cr.getPassword());
  221. user.setPhonenumber(cr.getContactNumber());
  222. if(addCompany(company,user)>0){
  223. CompanyReviewed upCr = new CompanyReviewed();
  224. upCr.setId(cr.getId());
  225. upCr.setCompanyId(company.getId());
  226. upCr.setStatus("1");
  227. upCr.setUpdateBy(companyExamine.getCreateBy());
  228. i = companyReviewedMapper.updateCompanyReviewed(upCr);
  229. i +=companyExamineMapper.insertCompanyExamine(companyExamine);
  230. }
  231. if(i==2){
  232. return 1;
  233. }else{
  234. throw new RuntimeException("创建公司实体时出错!");
  235. }
  236. }
  237. /**
  238. * 修改商户信息申请通过
  239. * @param:
  240. * @return:
  241. * @auther: qxp
  242. * @date: 2020-2-25
  243. */
  244. @Override
  245. @Transactional
  246. public int allowEdit(CompanyExamine companyExamine) {
  247. /*1.修改公司信息SysCompany*/
  248. /*2.修改审核信息状态*/
  249. /*3.插入审核信息*/
  250. int i = 0;
  251. CompanyReviewed cr = companyReviewedMapper.selectCompanyReviewedById(companyExamine.getCompanyReviewedId());
  252. if(cr==null){
  253. throw new RuntimeException("创建公司实体时出错!");
  254. }
  255. SysCompany company = reviewedTocompany(cr);
  256. company.setId(cr.getCompanyId());
  257. company.setUpdateBy(cr.getCreateBy());
  258. company.setUpdateTime(new Date());
  259. i = sysCompanyMapper.updateSysCompany(company);
  260. if(i>0){
  261. CompanyReviewed upCr = new CompanyReviewed();
  262. upCr.setId(cr.getId());
  263. upCr.setCompanyId(cr.getCompanyId());
  264. upCr.setStatus("1");
  265. i = companyReviewedMapper.updateCompanyReviewed(upCr);
  266. i +=companyExamineMapper.insertCompanyExamine(companyExamine);
  267. }
  268. if(i==2){
  269. return 1;
  270. }else{
  271. throw new RuntimeException("创建公司实体时出错!");
  272. }
  273. }
  274. public SysCompany reviewedTocompany (CompanyReviewed cr) {
  275. SysCompany result = new SysCompany();
  276. result.setCompanyName(cr.getCompanyName());
  277. result.setStatus(0);
  278. result.setCompanyType(cr.getCompanyType());
  279. result.setDetailAddress(cr.getDetailAddress());
  280. result.setLongitude(cr.getLongitude());
  281. result.setLatitude(cr.getLatitude());
  282. result.setLegalPerson(cr.getLegalPerson());
  283. result.setContactNumber(cr.getContactNumber());
  284. result.setEstablishDate(cr.getEstablishDate());
  285. result.setUnifiedSocialCreditCode(cr.getUnifiedSocialCreditCode());
  286. result.setBusinessLicenseUrl(cr.getBusinessLicenseUrl());
  287. result.setDefaultImgUrl(cr.getDefaultImgUrl());
  288. result.setPropagandaImgUrl(cr.getPropagandaImgUrl());
  289. result.setCompanyIntroduce(cr.getCompanyIntroduce());
  290. result.setRemark(cr.getRemark());
  291. result.setPrimaryBusiness(cr.getPrimaryBusiness());
  292. return result;
  293. }
  294. }