NewRoleServiceImpl.java 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331
  1. package com.goafanti.permission.service.impl;
  2. import java.text.SimpleDateFormat;
  3. import java.util.ArrayList;
  4. import java.util.Arrays;
  5. import java.util.Date;
  6. import java.util.HashMap;
  7. import java.util.List;
  8. import java.util.Map;
  9. import java.util.Set;
  10. import java.util.UUID;
  11. import com.goafanti.common.bo.OrderExamineBo;
  12. import com.goafanti.common.dao.*;
  13. import com.goafanti.common.model.*;
  14. import com.goafanti.order.bo.NewOrderChangeBo;
  15. import com.goafanti.order.bo.TOrderTaskBo;
  16. import com.goafanti.order.enums.ChangeState;
  17. import com.goafanti.order.enums.NewProjectStatus;
  18. import com.goafanti.order.enums.OrderChangeProcess;
  19. import org.springframework.beans.factory.annotation.Autowired;
  20. import org.springframework.stereotype.Service;
  21. import com.goafanti.common.bo.Error;
  22. import com.goafanti.common.constant.AFTConstants;
  23. import com.goafanti.common.enums.roleResources;
  24. import com.goafanti.common.error.BusinessException;
  25. import com.goafanti.common.utils.StringUtils;
  26. import com.goafanti.core.mybatis.BaseMybatisDao;
  27. import com.goafanti.core.mybatis.page.Pagination;
  28. import com.goafanti.core.shiro.token.TokenManager;
  29. import com.goafanti.permission.bo.RoleBo;
  30. import com.goafanti.permission.bo.RolePermissionBo;
  31. import com.goafanti.permission.service.NewRoleService;
  32. @Service
  33. public class NewRoleServiceImpl extends BaseMybatisDao<RoleMapper> implements NewRoleService {
  34. @Autowired
  35. private RoleMapper roleMapper;
  36. @Autowired
  37. private UserMapper userMapper;
  38. @Autowired
  39. private UserRoleMapper userRoleMapper;
  40. @Autowired
  41. private RolePermissionMapper rolePermissionMapper;
  42. @Autowired
  43. private RoleResourcesMapper roleResourcesMapper;
  44. @Autowired
  45. private UserBusinessMapper userBusinessMapper;
  46. @Autowired
  47. private PatentNewMapper patentNewMapper;
  48. @Autowired
  49. private OrganizationContactBookMapper organizationContactBookMapper;
  50. @Autowired
  51. private TOrderTaskMapper tOrderTaskMapper;
  52. @Autowired
  53. private TOrderNewMapper tOrderNewMapper;
  54. @Autowired
  55. private TTaskLogMapper tTaskLogMapper;
  56. @Autowired
  57. private TOrderMidMapper tOrderMidMapper;
  58. @Autowired
  59. private OrderExamineMapper orderExamineMapper;
  60. @Autowired
  61. private UserTransferLogMapper userTransferLogMapper;
  62. @Autowired
  63. private AdminMapper adminMapper;
  64. @Autowired
  65. private TaskAttributionLogMapper taskAttributionLogMapper;
  66. @Autowired
  67. private TOrderLogMapper tOrderLogMapper;
  68. @Autowired
  69. private TChangeTaskMapper tChangeTaskMapper;
  70. @Autowired
  71. private NewOrderChangeMapper newOrderChangeMapper;
  72. @Autowired
  73. private OrderChangeLogMapper orderChangeLogMapper;
  74. @Override
  75. public Pagination<RoleBo> findRoles(RoleBo role, Integer pageNo, Integer pageSize) {
  76. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  77. Map<String,Object> params =disposeParams(role);
  78. @SuppressWarnings("unchecked")
  79. Pagination<RoleBo> p=(Pagination<RoleBo>)findPage("selectRoleList","selectRoleCount",params,pageNo,pageSize);
  80. @SuppressWarnings("unchecked")
  81. List<RoleBo> list=(List<RoleBo>) p.getList();
  82. for(RoleBo i:list){
  83. if(i.getCreateTime()!=null){
  84. i.setCreateTimez(sdf.format(i.getCreateTime()));
  85. }
  86. }
  87. return p;
  88. }
  89. private Map<String,Object> disposeParams(RoleBo role){
  90. Map<String,Object> params = new HashMap<String, Object>();
  91. if(StringUtils.isNotBlank(role.getRoleName())) params.put("roleName", role.getRoleName());
  92. return params;
  93. }
  94. @Override
  95. public Set<String> findRoleByUserId(String userId) {
  96. return roleMapper.findRoleByUserId(userId);
  97. }
  98. @Override
  99. public int insert(List<Role> records) {
  100. return roleMapper.insertBatch(records);
  101. }
  102. @Override
  103. public int deleteByPrimaryKeys(List<String> records) {
  104. rolePermissionMapper.deleteByRoleId(records);
  105. userRoleMapper.deleteByRoleId(records);
  106. List<String> data= userRoleMapper.findUserIdByRoleIds(records);
  107. TokenManager.clearUserAuthByUserId(data.toArray(new String[]{}));
  108. return roleMapper.deleteByPrimaryKeys(records);
  109. }
  110. @Override
  111. public int bindPermission(String rid, String pid) {
  112. TokenManager.clearUserAuthByUserId((String[]) userRoleMapper.findUserIdByRoleId(rid).toArray());
  113. return rolePermissionMapper.insert(new RolePermission(rid, pid));
  114. }
  115. @Override
  116. public int bindUser(String rid, String uid) {
  117. TokenManager.clearUserAuthByUserId(new String[] { uid });
  118. return userRoleMapper.insert(new UserRole(uid, rid));
  119. }
  120. @Override
  121. public int unbindPermission(String roleId, String permissionId) {
  122. Map<String, Object> params = new HashMap<>();
  123. params.put("rid", roleId);
  124. params.put("pid", permissionId);
  125. TokenManager.clearUserAuthByUserId((String[]) userRoleMapper.findUserIdByRoleId(roleId).toArray());
  126. return rolePermissionMapper.deleteByPrimaryKey(params);
  127. }
  128. @Override
  129. public int unbindUser(String roleId, String userId) {
  130. Map<String, Object> params = new HashMap<>();
  131. params.put("rid", roleId);
  132. params.put("uid", userId);
  133. TokenManager.clearUserAuthByUserId(new String[] { userId });
  134. return 0;
  135. }
  136. @Override
  137. public int insert(Role record, List<String> permissions) {
  138. Date now = new Date();
  139. if (record.getId() != null) {
  140. List<RolePermission> rps = new ArrayList<>();
  141. rolePermissionMapper.deleteByRid(record.getId());
  142. for (String pid : permissions) {
  143. rps.add(new RolePermission(record.getId(), pid));
  144. }
  145. if (!rps.isEmpty()) {
  146. rolePermissionMapper.insertBatch(rps);
  147. }
  148. List<String> ids = userRoleMapper.findUserIdByRoleId(record.getId());
  149. TokenManager.clearUserAuthByUserId(ids.toArray(new String[ids.size()]));
  150. }else {
  151. record.setId(UUID.randomUUID().toString());
  152. }
  153. record.getId();
  154. record.setCreater("管理员");
  155. record.setCreateTime(now);
  156. return roleMapper.insert(record);
  157. }
  158. @Override
  159. public List<RolePermissionBo> selectRolePList(String id) {
  160. List<RolePermissionBo> list=roleMapper.selectRolePList(id);
  161. return list;
  162. }
  163. @Override
  164. public int addResources(String rid, String resources) {
  165. List<String> list = Arrays.asList(resources.split(","));
  166. RoleResources rr=new RoleResources();
  167. if (roleResourcesMapper.checkRid(rid)>0) {
  168. roleResourcesMapper.deleteResources(rid);
  169. }
  170. for (String s : list) {
  171. rr.setId(UUID.randomUUID().toString());
  172. rr.setRoleId(rid);
  173. rr.setCreateTime(new Date());
  174. try {
  175. rr.setResources(Integer.parseInt(s));
  176. } catch (NumberFormatException e) {
  177. e.printStackTrace();
  178. }
  179. roleResourcesMapper.insert(rr);
  180. }
  181. return 1;
  182. }
  183. @Override
  184. public int updatedimission(String aid, String transferId) {
  185. List<Integer> list=roleResourcesMapper.selectAdminRoleResources(aid);
  186. if (list.isEmpty()||list.get(0)==null) {
  187. throw new BusinessException(new Error("","用户角色资源不存在"));
  188. }
  189. Date date=new Date();
  190. Admin admin=adminMapper.selectAllByid(aid);
  191. Admin tadmin=adminMapper.selectAllByid(transferId);
  192. for (Integer s : list) {
  193. if (s==roleResources.YXKH.getCode()) {
  194. userTransferLogMapper.insertUserLog(aid,transferId,date);
  195. roleResourcesMapper.updateLockRelease("0",aid,transferId);//将用户锁转给指定人
  196. userBusinessMapper.updateDimissionTransfer(aid,transferId);
  197. organizationContactBookMapper.updateDimissionTransfer(aid,transferId);
  198. //所有客户转交给接受者
  199. userMapper.updateDimissionTransfer(aid,transferId);
  200. }
  201. if (s==roleResources.QDYW.getCode()) {
  202. userTransferLogMapper.insertUserLockLog(aid,transferId,date);
  203. patentNewMapper.updateAdmin(aid,transferId);
  204. roleResourcesMapper.updateLockRelease("1",aid,transferId);//将业务锁转给指定人
  205. }
  206. if (s == roleResources.YQDD.getCode()) {
  207. StringBuffer str=new StringBuffer();
  208. str.append(admin.getName()).append("离职转交到").append(tadmin.getName());
  209. tOrderLogMapper.insertOrderLog(aid,TokenManager.getAdminId(),date,str.toString());
  210. tOrderNewMapper.updateSalesmanId(aid, transferId);
  211. tOrderMidMapper.updateSalesmanId(aid, transferId);
  212. }
  213. if (s == roleResources.XMRW.getCode()) {
  214. // 获取被转角色判断修改对应任务角色
  215. pushTechTransfer(aid,transferId,date,admin,tadmin);
  216. }
  217. if (s!=roleResources.QDYW.getCode()) {
  218. roleResourcesMapper.updateDimissionTransfer(s,aid,transferId);
  219. }
  220. }
  221. return 1;
  222. }
  223. public void pushTechTransfer(String aid, String transferId,Date date,Admin admin,Admin tadmin) {
  224. //获取旧人员与新人员的角色
  225. int useType=getTech(aid);
  226. int newType=getTech(transferId);
  227. //如果不是咨询或者经理不走项目转交
  228. if(useType!=-1&&newType!=-1){
  229. //获取所有需要修改角色的变更项目
  230. List<TChangeTask> list = tOrderTaskMapper.selectByAid(aid);
  231. if ((useType==0&&newType==0)||(useType==1&&newType==1)){
  232. tOrderTaskMapper.updateDimissionTransfer(aid, transferId, useType);
  233. orderExamineMapper.updateDimissionTransfer(aid, transferId,useType);
  234. }else if (useType==0&&newType==1){//下转上 下清空
  235. tOrderTaskMapper.updateDimissionTransfer(aid, transferId, 3);
  236. orderExamineMapper.updateDimissionTransfer(aid, transferId,newType);
  237. orderExamineMapper.deleteByAidAndStatus(null,aid,useType);
  238. }else if (useType==1&&newType==0){//上转下 上清空
  239. tOrderTaskMapper.updateDimissionTransfer(aid, transferId, 4);
  240. orderExamineMapper.updateDimissionTransfer(aid, transferId,newType);
  241. orderExamineMapper.deleteByAidAndStatus(null,aid,useType);
  242. }
  243. List<Integer> clist=new ArrayList<>();
  244. for (TChangeTask tct : list) {
  245. TChangeTask nt = new TChangeTask();
  246. tct.setId(tct.getId());
  247. tct.setReceiverName(tadmin.getName());
  248. tChangeTaskMapper.updateByPrimaryKeySelective(tct);
  249. if (!clist.contains(tct.getCid()))clist.add(tct.getCid());
  250. }
  251. for (Integer i : clist) {
  252. NewOrderChangeBo changeBo = newOrderChangeMapper.selectById(i);
  253. int x=1;
  254. if (changeBo.getProcessState()== OrderChangeProcess.JSY.getCode()){
  255. x=orderExamineMapper.checkCountStatus(changeBo.getOrderNo(), 0,0);
  256. }else if (changeBo.getProcessState()==OrderChangeProcess.JSJL.getCode()){
  257. x=orderExamineMapper.checkCountStatus(changeBo.getOrderNo(), 1,0);
  258. }
  259. if (x==0){
  260. OrderChangeLog log=new OrderChangeLog();
  261. log.setChangeId(i);
  262. log.setCreateTime(date);
  263. log.setOrderNo(changeBo.getOrderNo());
  264. log.setStatus(2);
  265. log.setRemarks("离职转交自动通过");
  266. log.setAuditor("1");
  267. orderChangeLogMapper.insertSelective(log);
  268. changeBo.setProcessState(changeBo.getProcessState()+1);
  269. newOrderChangeMapper.updateByPrimaryKeySelective(changeBo);
  270. }
  271. }
  272. newOrderChangeMapper.updateTaskExamineName(aid,transferId,OrderChangeProcess.JSY.getCode());
  273. newOrderChangeMapper.updateTaskExamineName(aid,transferId,OrderChangeProcess.JSJL.getCode());
  274. taskAttributionLogMapper.insertList(aid, transferId, date);
  275. tTaskLogMapper.updateDimissionTransfer(aid, transferId);
  276. }
  277. }
  278. /**
  279. * 判断角色
  280. * @param transferId
  281. * @return 0咨询师 1经理 -1非咨询角色
  282. */
  283. private int getTech(String transferId) {
  284. List<String> l=adminMapper.getAdminRoleListByAid(transferId);
  285. for (String str : l) {
  286. if (str==null){
  287. break;
  288. }else if (str.equals(AFTConstants.TECH_MANAGER)) {
  289. return 1;
  290. }else if (str.equals(AFTConstants.TECH)){
  291. return 0;
  292. }
  293. }
  294. return -1;
  295. }
  296. @Override
  297. public List<RoleResources> ResourcesDetail(String rid) {
  298. return roleResourcesMapper.selectByRid(rid);
  299. }
  300. }