AsyncUtils.java 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592
  1. package com.goafanti.common.utils;
  2. import java.io.UnsupportedEncodingException;
  3. import java.util.*;
  4. import javax.mail.MessagingException;
  5. import com.goafanti.admin.bo.AdminListBo;
  6. import com.goafanti.common.bo.OrderExamineBo;
  7. import com.goafanti.common.bo.OrderOperator;
  8. import com.goafanti.common.constant.AFTConstants;
  9. import com.goafanti.common.dao.*;
  10. import com.goafanti.common.enums.NoticeStatus;
  11. import com.goafanti.common.model.*;
  12. import com.goafanti.core.shiro.token.TokenManager;
  13. import com.goafanti.order.bo.NewOrderChangeBo;
  14. import com.goafanti.order.bo.TOrderNewBo;
  15. import com.goafanti.order.enums.OrderChangeProcess;
  16. import com.goafanti.order.enums.OrderChangeType;
  17. import com.goafanti.order.enums.ProcessStatus;
  18. import com.goafanti.organization.bo.OrganizationListOut;
  19. import org.apache.ibatis.annotations.Param;
  20. import org.springframework.beans.factory.annotation.Autowired;
  21. import org.springframework.scheduling.annotation.Async;
  22. import org.springframework.stereotype.Component;
  23. import com.goafanti.common.bo.EmailBo;
  24. import com.goafanti.common.enums.NoticeTypes;
  25. @Component
  26. @Async
  27. public class AsyncUtils {
  28. @Autowired
  29. private NoticeMapper noticeMapper;
  30. @Autowired
  31. private AdminMapper adminMapper;
  32. @Autowired
  33. private TOrderNewMapper tOrderNewMapper;
  34. @Autowired
  35. private TOrderTaskMapper tOrderTaskMapper;
  36. @Autowired
  37. private NewOrderChangeMapper newOrderChangeMapper;
  38. @Autowired
  39. private OrderExamineMapper orderExamineMapper;
  40. @Autowired
  41. private TaskAttributionLogMapper taskAttributionLogMapper;
  42. @Autowired
  43. private TTaskLogMapper tTaskLogMapper;
  44. @Autowired
  45. private DepartmentMapper departmentMapper;
  46. @Autowired
  47. private OrderChangeLogMapper orderChangeLogMapper;
  48. @Autowired
  49. private TOrderMidMapper tOrderMidMapper;
  50. @Autowired
  51. private RoleMapper roleMapper;
  52. public void patentSend(EmailBo bo) throws UnsupportedEncodingException, MessagingException {
  53. SendEmailUtil.getInstance().patentSend(bo);
  54. }
  55. public void sendList(List<EmailBo> list) throws MessagingException, UnsupportedEncodingException {
  56. for (EmailBo emailBo : list) {
  57. SendEmailUtil.getInstance().patentSend(emailBo);
  58. }
  59. }
  60. public void send(EmailBo bo){
  61. try {
  62. SendEmailUtil.getInstance().send(bo);
  63. } catch (UnsupportedEncodingException | MessagingException e) {
  64. e.printStackTrace();
  65. }
  66. }
  67. public void addNotice(Notice n ) {
  68. n.setType(NoticeTypes.getType(n.getNoticeType()));
  69. noticeMapper.insertSelective(n);
  70. }
  71. public void addNotic(Integer type, String aid,String str) {
  72. Notice n =new Notice();
  73. n.setId(UUID.randomUUID().toString());
  74. n.setAid(aid);
  75. n.setNoticeType(type);
  76. n.setContent(str);
  77. n.setReaded(0);//未读
  78. addNotice(n);
  79. }
  80. /**
  81. *
  82. * @param type NoticeStatus的类型
  83. * @param aid 接受者编号
  84. * @param str 推送信息
  85. */
  86. public void addNoticAndEmail(Integer type, String aid,String str) {
  87. Notice n =new Notice();
  88. n.setId(UUID.randomUUID().toString());
  89. n.setAid(aid);
  90. n.setNoticeType(type);
  91. n.setContent(str);
  92. n.setReaded(0);//未读
  93. addNoticAndEmail(n);
  94. }
  95. public void addNoticAndEmail(Notice n) {
  96. n.setType(NoticeTypes.getType(n.getNoticeType()));
  97. AdminListBo a = adminMapper.getDeptNameByAid(n.getAid());
  98. EmailBo bo=new EmailBo(NoticeStatus.getStatus(n.getNoticeType()).getDesc(),a.getEmail(),n.getContent()) ;
  99. noticeMapper.insertSelective(n);
  100. if (StringUtils.isNotBlank(bo.getAddress())){
  101. send(bo);
  102. }
  103. }
  104. /**
  105. *
  106. * @param aid 通知对象
  107. * @param noticeType 通知类型
  108. * @param content 通知内容
  109. */
  110. public void addNoticAndEmail(String aid,Integer noticeType,String content) {
  111. Notice n=new Notice();
  112. n.setId(UUID.randomUUID().toString());
  113. n.setAid(aid);
  114. n.setNoticeType(noticeType);
  115. n.setContent(content);
  116. n.setReaded(0);
  117. n.setType(NoticeTypes.getType(n.getNoticeType()));
  118. addNoticAndEmail(n);
  119. }
  120. public void addNoticeBatch(List<Notice> ln) {
  121. List<Notice> newList=new ArrayList<Notice>();
  122. if (ln != null && ln.size() > 0) {
  123. for (int i = 0; i < ln.size(); i++) {
  124. ln.get(i).setType(NoticeTypes.getType(ln.get(i).getNoticeType()));
  125. newList.add(ln.get(i));
  126. if (50 == newList.size() || i == ln.size() - 1) {
  127. if (newList.size() > 0) noticeMapper.insertBatch(newList);
  128. newList.clear();
  129. try {
  130. Thread.sleep(2000);
  131. } catch (InterruptedException e) {
  132. e.printStackTrace();
  133. }
  134. }
  135. }
  136. }
  137. }
  138. public void batchUpdateUnreaded(List<String> dl) {
  139. noticeMapper.batchUpdateUnreaded(dl);
  140. }
  141. /**
  142. *
  143. * @param type 发送对象 0发起营销管理员 1 完成通知所有人 2拒绝发送给营销员
  144. * @param sotpType 发送对象 类型 0=项目暂停,1=项目重启
  145. *
  146. */
  147. public void addProjectSotpNotic(Integer type, Integer sotpType, String ids, TOrderTask task) {
  148. Integer noticeType=0;
  149. if (task==null)task = tOrderTaskMapper.selectByPrimaryKey(Integer.valueOf(ids.split(",")[0]));
  150. TOrderNewBo tOrderNew = tOrderNewMapper.getOrderNewDetail(task.getOrderNo());
  151. List<Notice> notes=new ArrayList<>();
  152. StringBuffer emails=new StringBuffer();
  153. if (type==0){
  154. noticeType=sotpType==0?NoticeStatus.PROJECT_SOPT_START.getCode() :NoticeStatus.PROJECT_RENEW_START.getCode();
  155. String str=String.format("客户名称[%s]订单编号[%s]项目编号[%s],请及时审核。",tOrderNew.getUserName(),task.getOrderNo(),ids);
  156. List<Admin> admins = adminMapper.listAdminBydepIdAndRoleType(tOrderNew.getOrderDep(),AFTConstants.SALESMAN_ADMIN);
  157. for (Admin admin : admins) {
  158. addNotic( noticeType,admin.getId(), str);
  159. send(new EmailBo(NoticeStatus.getValueByCode(noticeType),admin.getEmail(),str));
  160. }
  161. }else if(type==1){
  162. String str=String.format("客户名称[%s]订单编号[%s]项目编号[%s],已%s请悉知。",tOrderNew.getUserName(),task.getOrderNo(),task.getId(),sotpType==1?"重启":"暂停");
  163. noticeType=sotpType==0?NoticeStatus.PROJECT_SOPT_YES.getCode() :NoticeStatus.PROJECT_RENEW_YES.getCode();
  164. OrderOperator orderOperator = tOrderTaskMapper.selectAidByParam(task.getId());
  165. List<String >aids=new ArrayList<>();
  166. if (orderOperator.getSalesmanId()!=null&&!aids.contains(orderOperator.getFinanceId())){
  167. aids.add(orderOperator.getSalesmanId());
  168. }
  169. if (task.getConsultantId()!=null&&!aids.contains(task.getConsultantId())){
  170. aids.add(task.getConsultantId());
  171. }
  172. if (task.getManagerId()!=null&&!aids.contains(task.getManagerId())){
  173. aids.add(task.getManagerId());
  174. }
  175. if (orderOperator.getFinanceId()!=null&&!aids.contains(orderOperator.getFinanceId())){
  176. aids.add(orderOperator.getFinanceId());
  177. }
  178. List<Admin> cwgly = adminMapper.selectAdminByRoleType(AFTConstants.FINANCE_ADMIN);
  179. for (Admin admin : cwgly) {
  180. if (!aids.contains(admin.getId())){
  181. aids.add(admin.getId());
  182. }
  183. }
  184. List<Admin> zxsgly = adminMapper.selectAdminByRoleType(AFTConstants.TECH_ADMIN);
  185. for (Admin admin : zxsgly) {
  186. if (!aids.contains(admin.getId())){
  187. aids.add(admin.getId());
  188. }
  189. }
  190. List<Admin> zc = adminMapper.selectAdminByRoleType(AFTConstants.CED);
  191. for (Admin admin : zc) {
  192. if (!aids.contains(admin.getId())){
  193. aids.add(admin.getId());
  194. }
  195. }
  196. List<Admin> dsz = adminMapper.selectAdminByRoleType(AFTConstants.APPROVAL_DECISION);
  197. for (Admin admin : dsz) {
  198. if (!aids.contains(admin.getId())){
  199. aids.add(admin.getId());
  200. }
  201. }
  202. if (!aids.isEmpty()){
  203. for (String aid : aids) {
  204. pushParam( aid, noticeType, str, notes, emails);
  205. }
  206. }
  207. noticeMapper.insertBatch(notes);
  208. send(new EmailBo(NoticeStatus.getValueByCode(noticeType),emails.substring(0,emails.length()-1),str));
  209. }else if (type==2){
  210. noticeType=sotpType==0?NoticeStatus.PROJECT_SOPT_NO.getCode() :NoticeStatus.PROJECT_RENEW_NO.getCode();
  211. String str=String.format("客户名称[%s]订单编号[%s]项目编号[%s],已经被驳回。",tOrderNew.getUserName(),task.getOrderNo(),task.getId());
  212. if (tOrderNew.getSalesmanId()!=null){
  213. Admin admin = adminMapper.selectByPrimaryKey(tOrderNew.getSalesmanId());
  214. addNotic( noticeType,admin.getId(), str);
  215. send(new EmailBo(NoticeStatus.getValueByCode(noticeType),admin.getEmail(),str));
  216. }
  217. }
  218. }
  219. private void pushParam(String id, Integer noticeType, String str, List<Notice> notes, StringBuffer emails) {
  220. Admin admin = adminMapper.selectByPrimaryKey(id);
  221. pushParam(admin,noticeType,str,notes,emails);
  222. }
  223. private void pushParam(Admin admin, Integer noticeType, String str, List<Notice> notes, StringBuffer emails) {
  224. notes.add(new Notice(UUID.randomUUID().toString(), new Date(), 0, admin.getId(),
  225. noticeType, str));
  226. if (admin!=null &&StringUtils.isNotBlank(admin.getEmail())) {
  227. if (!emails.toString().contains(admin.getEmail())){
  228. emails = emails.append(admin.getEmail()).append(",");
  229. }
  230. }
  231. }
  232. /**
  233. * @param date 日期
  234. * @param admin 原本管理员
  235. * @param tadmin 转交管理员
  236. */
  237. public void pushTechTransfer(Admin admin,Admin tadmin,Date date) {
  238. //获取旧人员与新人员的角色
  239. List<String> useType=adminMapper.getAdminRoleListByAid(admin.getId());
  240. List<String> newType=adminMapper.getAdminRoleListByAid(tadmin.getId());
  241. String aid=admin.getId();
  242. String transferId=tadmin.getId();
  243. if (useType.contains(AFTConstants.TECH)&&newType.contains(AFTConstants.TECH)){
  244. //System.out.println("同咨询师");
  245. List<Integer> list = newOrderChangeMapper.selectProcess(3, aid);
  246. tOrderTaskMapper.updateDimissionTransfer(aid, transferId, 0);
  247. orderExamineMapper.updateDimissionTransfer(aid, transferId,0,null);
  248. pushChangeProcessZXS(list);
  249. }else if (useType.contains(AFTConstants.TECH)&&newType.contains(AFTConstants.TECH_MANAGER)){
  250. // System.out.println("不同职业");
  251. List<Integer> list = newOrderChangeMapper.selectProcess(3, aid);
  252. tOrderTaskMapper.updateDimissionTransfer(aid, transferId, 3);
  253. orderExamineMapper.updateDimissionTransfer(aid, transferId,3,null);
  254. List<Integer> list2 = newOrderChangeMapper.selectProcess(4, transferId);
  255. //如果转交后订单全通过了,则变更+1
  256. pushChangeProcessZXS(list);
  257. pushChangeProcessZXSJL(list2);
  258. }
  259. if (useType.contains(AFTConstants.TECH_MANAGER)&&newType.contains(AFTConstants.TECH_MANAGER)){
  260. // System.out.println("同咨询师经理");
  261. List<Integer> list = newOrderChangeMapper.selectProcess(4, aid);
  262. tOrderTaskMapper.updateDimissionTransfer(aid, transferId, 1);
  263. tOrderTaskMapper.updateDimissionTransferManager(aid, transferId);
  264. orderExamineMapper.updateDimissionTransfer(aid, transferId,1,null);
  265. pushChangeProcessZXSJL(list);
  266. }else if (useType.contains(AFTConstants.TECH_MANAGER)&&newType.contains(AFTConstants.TECH)){
  267. // System.out.println("不同职业");
  268. //获取转交前的
  269. List<Integer> list = newOrderChangeMapper.selectProcess(4, aid);
  270. tOrderTaskMapper.updateDimissionTransfer(aid, transferId, 4);
  271. tOrderTaskMapper.updateDimissionTransferManager(aid, null);
  272. orderExamineMapper.updateDimissionTransfer(aid, transferId,4,null);
  273. List<Integer> list2 = newOrderChangeMapper.selectProcess(3, transferId);
  274. pushChangeProcessZXSJL(list);
  275. pushChangeProcessZXS(list2);
  276. }
  277. taskAttributionLogMapper.insertList(aid, transferId, date);
  278. tTaskLogMapper.updateDimissionTransfer(aid, transferId);
  279. }
  280. private void pushChangeProcessZXSJL(List<Integer> list) {
  281. if(!list.isEmpty()){
  282. Date date =new Date();
  283. for (Integer i : list) {
  284. NewOrderChangeBo changeBo = newOrderChangeMapper.selectById(i);
  285. pushZXSJL(changeBo,date,1);
  286. pushOrderCangeProcess(changeBo);
  287. newOrderChangeMapper.updateByPrimaryKeySelective(changeBo);
  288. }
  289. }
  290. }
  291. public void pushZXS(NewOrderChangeBo nb, Date date,Integer type) {
  292. int zxs=orderExamineMapper.checkCountStatus(nb.getOrderNo(),0,null);
  293. if (zxs>0){
  294. nb.setProcessState(OrderChangeProcess.JSY.getCode());
  295. }else {
  296. if(type==1){
  297. date.setTime(date.getTime()+100);
  298. addOrderChangeLog("无咨询师自动通过", 2, nb.getOrderNo(), nb.getId(), date);
  299. }
  300. pushZXSJL(nb,date,1);
  301. }
  302. }
  303. public void pushZXSJL(NewOrderChangeBo nb,Date date,Integer type) {
  304. int zxsjl=orderExamineMapper.checkCountStatus(nb.getOrderNo(),1,0);
  305. if (nb.getType()== OrderChangeType.XMJJEBG.getCode()||
  306. nb.getType()==OrderChangeType.TDTK.getCode()||
  307. nb.getType()==OrderChangeType.TDBTK.getCode()||
  308. nb.getType()==OrderChangeType.CB.getCode()||
  309. nb.getType()==OrderChangeType.JXMBG.getCode()){
  310. if (zxsjl>0){
  311. nb.setProcessState(OrderChangeProcess.JSJL.getCode());
  312. }else {
  313. if (type==1){
  314. date.setTime(date.getTime()+100);
  315. addOrderChangeLog("无咨询师经理自动通过", 2, nb.getOrderNo(), nb.getId(),date);
  316. }
  317. //重报 没有技术员跳入财务
  318. if (nb.getType()==OrderChangeType.CB.getCode()){
  319. nb.setProcessState(OrderChangeProcess.CWZY.getCode());
  320. //项目变更没有跳入技术总监
  321. }else{
  322. nb.setProcessState(OrderChangeProcess.JSZJ.getCode());
  323. }
  324. }
  325. }
  326. }
  327. private void addOrderChangeLog(String remarks, Integer status, String orderNo, Integer id,Date date) {
  328. if (date ==null)date=new Date();
  329. OrderChangeLog ocl = new OrderChangeLog();
  330. ocl.setAuditor(TokenManager.getAdminId());
  331. ocl.setOrderNo(orderNo);
  332. ocl.setRemarks(remarks);
  333. ocl.setChangeId(id);
  334. ocl.setStatus(status);
  335. ocl.setCreateTime(date);
  336. orderChangeLogMapper.insertSelective(ocl);
  337. }
  338. private void pushChangeProcessZXS(List<Integer> list) {
  339. if(!list.isEmpty()){
  340. Date date =new Date();
  341. for (Integer i : list) {
  342. NewOrderChangeBo changeBo = newOrderChangeMapper.selectById(i);
  343. pushZXS(changeBo,date,1);
  344. pushOrderCangeProcess(changeBo);
  345. newOrderChangeMapper.updateByPrimaryKeySelective(changeBo);
  346. }
  347. }
  348. }
  349. public void pushOrderCangeProcess(NewOrderChange noc) {
  350. if (noc.getProcessState()== OrderChangeProcess.YXY.getCode()){
  351. TOrderNewBo ton = tOrderNewMapper.getSaleIdByOno(noc.getOrderNo());
  352. noc.setExamineName(ton.getSalesmanName());
  353. }else if (noc.getProcessState()== OrderChangeProcess.YXJL.getCode()){
  354. TOrderNewBo ton = tOrderNewMapper.getSaleIdByOno(noc.getOrderNo());
  355. Admin saleman = adminMapper.selectByPrimaryKey(ton.getSalesmanId());
  356. Admin manager = adminMapper.selectByPrimaryKey(saleman.getManagerId());
  357. noc.setExamineName(manager.getName());
  358. }else if (noc.getProcessState()== OrderChangeProcess.YXGLY.getCode()){
  359. TOrderNewBo ton = tOrderNewMapper.getSaleIdByOno(noc.getOrderNo());
  360. StringBuffer str=new StringBuffer();
  361. List<Admin> admins = adminMapper.listAdminBydepIdAndRoleType(ton.getOrderDep(),AFTConstants.SALESMAN_ADMIN);
  362. if (admins.isEmpty()){
  363. OrganizationListOut dep = departmentMapper.selectAllById(ton.getOrderDep());
  364. admins = adminMapper.listAdminBydepIdAndRoleType(dep.getSuperId(),AFTConstants.SALESMAN_ADMIN);
  365. }
  366. for (Admin admin : admins) {
  367. if (!str.toString().contains(admin.getName()))str.append(admin.getName()).append(",");
  368. }
  369. if (str.length()>0)noc.setExamineName(str.substring(0,str.length()-1));
  370. }else if (noc.getProcessState()== OrderChangeProcess.JSY.getCode()){
  371. List<OrderExamineBo> os = orderExamineMapper.selectByOrderNo(noc.getOrderNo(), 0);
  372. StringBuffer str=new StringBuffer();
  373. for (OrderExamineBo o : os) {
  374. if (o.getStatus()==0){
  375. if (!str.toString().contains(o.getName()))str.append(o.getName()).append(",");
  376. }
  377. }
  378. if (str.length()>0)noc.setExamineName(str.substring(0,str.length()-1));
  379. }else if (noc.getProcessState()== OrderChangeProcess.JSJL.getCode()){
  380. List<OrderExamineBo> os = orderExamineMapper.selectByOrderNo(noc.getOrderNo(), 1);
  381. StringBuffer str=new StringBuffer();
  382. for (OrderExamineBo o : os) {
  383. if (o.getStatus()==0){
  384. if (!str.toString().contains(o.getName()))str.append(o.getName()).append(",");
  385. }
  386. }
  387. if (str.length()>0)noc.setExamineName(str.substring(0,str.length()-1));
  388. }else if (noc.getProcessState()== OrderChangeProcess.JSZJ.getCode()){
  389. StringBuffer str=new StringBuffer();
  390. List<Admin> admins = adminMapper.getAdminRoleTypeList(AFTConstants.TECH_ADMIN);
  391. for (Admin a : admins) {
  392. str=str.append(a.getName()).append(",");
  393. }
  394. if (str.length()>0)noc.setExamineName(str.substring(0,str.length()-1));
  395. }else if (noc.getProcessState()== OrderChangeProcess.CWZY.getCode()){
  396. TOrderNewBo ton = tOrderNewMapper.getSaleIdByOno(noc.getOrderNo());
  397. OrganizationListOut dep = departmentMapper.selectAllById(ton.getOrderDep());
  398. noc.setExamineName(dep.getFinanceName());
  399. }else if (noc.getProcessState()== OrderChangeProcess.CWZJ.getCode()){
  400. StringBuffer str=new StringBuffer();
  401. List<Admin> admins = adminMapper.getAdminRoleTypeList(AFTConstants.FINANCE_ADMIN);
  402. for (Admin a : admins) {
  403. str=str.append(a.getName()).append(",");
  404. }
  405. if (str.length()>0)noc.setExamineName(str.substring(0,str.length()-1));
  406. }else if (noc.getProcessState()== OrderChangeProcess.ZC.getCode()||noc.getProcessState()== OrderChangeProcess.DSZ.getCode()){
  407. if(noc.getStatus()==2){
  408. TOrderNewBo ton = tOrderNewMapper.getSaleIdByOno(noc.getOrderNo());
  409. OrganizationListOut dep = departmentMapper.selectAllById(ton.getOrderDep());
  410. noc.setExamineName(dep.getFinanceName());
  411. }else {
  412. noc.setExamineName("");
  413. }
  414. }
  415. }
  416. /**
  417. * 处理修改角色对于订单、变更审核人员的修改
  418. * @param ad
  419. * @param usead
  420. * @param roleIds
  421. */
  422. public void pushRoleUpdateExamine(Admin ad, Admin usead, List<String> roleIds, List<Role> useRole) {
  423. List<Role> roles = roleMapper.selectByIdList(roleIds);
  424. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.SALESMAN);
  425. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.SALESMAN_MANAGER);
  426. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.SALESMAN_ADMIN);
  427. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.TECH);
  428. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.TECH_MANAGER);
  429. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.TECH_ADMIN);
  430. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.FINANCE);
  431. updateExamineByRole(ad, usead, useRole, roles,AFTConstants.FINANCE_ADMIN);
  432. }
  433. private void updateExamineByRole(Admin ad, Admin usead, List<Role> useRole, List<Role> roles, String roleType) {
  434. boolean updateParam=false;
  435. int updatedep =0;
  436. if (!ad.getName().equals(usead.getName())){
  437. updateParam=true;
  438. }
  439. boolean newDEP=Rolescontains(roles,roleType);
  440. boolean useDep=Rolescontains(useRole,roleType);
  441. if (newDEP||useDep){
  442. if (roleType.equals(AFTConstants.SALESMAN_ADMIN)){
  443. if (ad.getDepartmentId().equals(usead.getDepartmentId())){
  444. updatedep=1;
  445. }else{
  446. updatedep=2;
  447. }
  448. if (newDEP&&useDep){
  449. //新旧为同一个,修改当前就可以了
  450. if (updatedep ==1&& updateParam){
  451. updateOrderAndChangeExamine(ad, roleType);
  452. //新旧不是同一个,俩个都要修改
  453. }else if (updatedep ==2){
  454. updateOrderAndChangeExamine(ad, roleType);
  455. updateOrderAndChangeExamine(usead, roleType);
  456. }
  457. }else if (!newDEP&&useDep){
  458. updateOrderAndChangeExamine(usead, roleType);
  459. }
  460. }else if (roleType.equals(AFTConstants.SALESMAN)){
  461. if (!ad.getManagerId().equals(usead.getManagerId())){
  462. updateOrderAndChangeExamine(ad, roleType);
  463. }
  464. }else {
  465. if (updateParam){
  466. updateOrderAndChangeExamine(ad, roleType);
  467. }
  468. }
  469. }
  470. }
  471. private boolean Rolescontains(List<Role> roles, String roleType) {
  472. for (Role role : roles) {
  473. if (role.getRoleType().equals(Integer.valueOf(roleType))){
  474. return true;
  475. }
  476. }
  477. return false;
  478. }
  479. /**
  480. *
  481. * @param ad
  482. * @param roleType
  483. */
  484. public void updateOrderAndChangeExamine(Admin ad, String roleType) {
  485. if (roleType.equals(AFTConstants.SALESMAN_ADMIN)){
  486. updateSalesmanAdminExamine(ad.getId());
  487. }else if (roleType.equals(AFTConstants.SALESMAN)){
  488. updateSalesmanExamine(ad.getManagerId());
  489. }else if (roleType.equals(AFTConstants.SALESMAN_MANAGER)){
  490. // 订单 0=营销员,1=经理,2=营销管理员,3=财务专员,4=总裁,5=技术总监,6部分分配,7全部分配
  491. // 变更 流程状态 0=营销员,1=营销经理,2=营销管理员,3=技术员,4=技术经理,5=技术总监,6=财务专员,7=财务总监,8=总裁,9=董事长
  492. updateSalesmanManagerExamine(ad);
  493. }else if (roleType.equals(AFTConstants.FINANCE)){
  494. updateFinanceExamine(ad.getId());
  495. }else if (roleType.equals(AFTConstants.TECH)) {
  496. newOrderChangeMapper.updateExamineById(ad.getId(), OrderChangeProcess.JSY.getCode());
  497. }else if (roleType.equals(AFTConstants.TECH_MANAGER)) {
  498. newOrderChangeMapper.updateExamineById(ad.getId(), OrderChangeProcess.JSJL.getCode());
  499. }else if (roleType.equals(AFTConstants.TECH_ADMIN)) {
  500. tOrderNewMapper.updateExamineById(null, ProcessStatus.YPZXSGLY.getCode());
  501. newOrderChangeMapper.updateExamineById(null, OrderChangeProcess.JSZJ.getCode());
  502. }else if (roleType.equals(AFTConstants.FINANCE_ADMIN)) {
  503. newOrderChangeMapper.updateExamineById(null, OrderChangeProcess.CWZJ.getCode());
  504. }
  505. }
  506. private void updateSalesmanExamine(String id) {
  507. tOrderNewMapper.updateExamineById(id,ProcessStatus.YPYXY.getCode());
  508. newOrderChangeMapper.updateExamineById(id,OrderChangeProcess.YXY.getCode());
  509. }
  510. private void updateSalesmanAdminExamine(String id) {
  511. tOrderNewMapper.updateExamineById(id,ProcessStatus.YPYXGLY.getCode());
  512. newOrderChangeMapper.updateExamineById(id,OrderChangeProcess.YXGLY.getCode());
  513. }
  514. private void updateSalesmanManagerExamine(Admin ad) {
  515. updateSalesmanManagerExamine(ad.getId());
  516. }
  517. private void updateSalesmanManagerExamine(String id) {
  518. tOrderNewMapper.updateExamineById(id, ProcessStatus.YPYXJL.getCode());
  519. newOrderChangeMapper.updateExamineById(id, OrderChangeProcess.YXJL.getCode());
  520. }
  521. public void updateFinanceExamine(String id) {
  522. tOrderNewMapper.updateExamineById(id,ProcessStatus.YPCWZY.getCode());
  523. newOrderChangeMapper.updateExamineById(id,OrderChangeProcess.CWZY.getCode());
  524. }
  525. public void updateFinanceExamineAndDep(String id, String financeId){
  526. updateFinanceExamine( id);
  527. tOrderMidMapper.updateFinanceId(id,financeId);
  528. }
  529. }