AsyncUtils.java 26 KB

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