AdminServiceImpl.java 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790
  1. package com.goafanti.admin.service.impl;
  2. import com.goafanti.admin.bo.*;
  3. import com.goafanti.admin.service.AdminService;
  4. import com.goafanti.admin.service.DepartmentService;
  5. import com.goafanti.admin.service.NewAdminService;
  6. import com.goafanti.common.bo.Result;
  7. import com.goafanti.common.constant.AFTConstants;
  8. import com.goafanti.common.dao.*;
  9. import com.goafanti.common.error.BusinessException;
  10. import com.goafanti.common.model.*;
  11. import com.goafanti.common.utils.LoggerUtils;
  12. import com.goafanti.common.utils.PasswordUtil;
  13. import com.goafanti.common.utils.StringUtils;
  14. import com.goafanti.common.utils.excel.NewExcelUtil;
  15. import com.goafanti.core.mybatis.BaseMybatisDao;
  16. import com.goafanti.core.mybatis.page.Pagination;
  17. import com.goafanti.core.shiro.token.TokenManager;
  18. import com.goafanti.customer.bo.BusinessListBo;
  19. import com.goafanti.organization.bo.OrganizationListOut;
  20. import org.springframework.beans.BeanUtils;
  21. import org.springframework.beans.factory.annotation.Autowired;
  22. import org.springframework.beans.factory.annotation.Value;
  23. import org.springframework.stereotype.Service;
  24. import javax.annotation.Resource;
  25. import java.util.*;
  26. @Service
  27. public class AdminServiceImpl extends BaseMybatisDao<AdminMapper> implements AdminService {
  28. @Autowired
  29. private AdminMapper adminMapper;
  30. @Autowired
  31. private UserRoleMapper userRoleMapper;
  32. @Autowired
  33. private AdminLocationMapper adminLocationMapper;
  34. @Autowired
  35. private UserLockReleaseMapper userLockReleaseMapper;
  36. @Autowired
  37. private UserBusinessMapper userBusinessMapper;
  38. @Autowired
  39. private UserMapper userMapper;
  40. @Autowired
  41. private DepartmentMapper departmentMapper;
  42. @Autowired
  43. private DepartmentService departmentService;
  44. @Resource(name = "passwordUtil")
  45. private PasswordUtil passwordUtil;
  46. @Autowired
  47. private NewAdminService newAdminService;
  48. @Autowired
  49. private AdminUserCountMapper adminUserCountMapper;
  50. @Autowired
  51. private TOrderNewMapper TOrderNewMapper;
  52. @Autowired
  53. private ExpenseAccountMapper expenseAccountMapper;
  54. @Autowired
  55. private TOrderInvoiceMapper tOrderInvoiceMapper;
  56. @Autowired
  57. private TTaskMemberMapper tTaskMemberMapper;
  58. @Autowired
  59. private TOrderPaymentMapper tOrderPaymentMapper;
  60. @Autowired
  61. private FinanceCountMapper financeCountMapper;
  62. @Value(value = "${upload.path}")
  63. private String uploadPath = null;
  64. @Override
  65. public List<Admin> selectAllAdmin() {
  66. return adminMapper.selectAllAdmin(null);
  67. }
  68. @Override
  69. public Admin selectByMobile(String mobile) {
  70. return adminMapper.selectByMobile(mobile);
  71. }
  72. @Override
  73. public Admin selectByPrimaryKey(String key) {
  74. return adminMapper.selectByPrimaryKey(key);
  75. }
  76. @SuppressWarnings("unchecked")
  77. @Override
  78. public Pagination<AdminListBo> listAdmin(Integer province, Integer number, String mobile, String name,String roleName,Integer seniorStaff,
  79. Integer pageNo, Integer pageSize) {
  80. Map<String, Object> params = new HashMap<>();
  81. if (StringUtils.isNotBlank(roleName))params.put("roleName", roleName);
  82. if (StringUtils.isNotBlank(mobile))params.put("mobile", mobile);
  83. if (StringUtils.isNotBlank(name))params.put("name", name);
  84. if (null != number)params.put("number", number);
  85. if (null != seniorStaff)params.put("seniorStaff", seniorStaff);
  86. if (pageNo == null || pageNo < 0)pageNo = 1;
  87. if (pageSize == null || pageSize < 0 || pageSize > 10)pageSize = 10;
  88. if (province != null) params.put("province", province);
  89. return (Pagination<AdminListBo>) findPage("findAdminListByPage", "findAdminCount", params, pageNo,
  90. pageSize);
  91. }
  92. @Override
  93. public int insert(Admin ad) {
  94. return adminMapper.insert(ad);
  95. }
  96. @Override
  97. public int updateByPrimaryKeySelective(Admin ad, List<String> roleIds) {
  98. Map<String, Object> params = new HashMap<>();
  99. params.put("uid", ad.getId());
  100. params.put("roles", roleIds);
  101. if (ad.getId() != "1") {
  102. userRoleMapper.deleteByUserId(ad.getId());
  103. if (!roleIds.isEmpty()) {
  104. userRoleMapper.insertBatch(params);
  105. }
  106. TokenManager.clearUserAuthByUserId(ad.getId());
  107. }
  108. return adminMapper.updateByPrimaryKeySelective(ad);
  109. }
  110. @Override
  111. public int updateByPrimaryKey(Admin a) {
  112. return adminMapper.updateByPrimaryKeySelective(a);
  113. }
  114. @Override
  115. public AdminDetail selectAdminDetail(String id) {
  116. Admin a = adminMapper.selectByPrimaryKey(id);
  117. if (null == a) {
  118. return null;
  119. }
  120. AdminDetail ad = new AdminDetail();
  121. BeanUtils.copyProperties(a, ad);
  122. ad.setRoles(adminMapper.selectRolesByPrimaryKey(id));
  123. return null;
  124. }
  125. @Override
  126. public List<Admin> selectCognizanceConsultant() {
  127. return adminMapper.selectCognizanceConsultant();
  128. }
  129. @Override
  130. public List<Admin> selectPatentAuthor() {
  131. return adminMapper.selectPatentAuthor();
  132. }
  133. @Override
  134. public List<Admin> selectPatentPrincipal() {
  135. return adminMapper.selectPatentPrincipal();
  136. }
  137. @Override
  138. public List<Admin> selectCopyrightConsultant() {
  139. return adminMapper.selectCopyrightConsultant();
  140. }
  141. @Override
  142. public List<Admin> selectCognizancePrincipal() {
  143. return adminMapper.selectCognizancePrincipal();
  144. }
  145. @Override
  146. public List<Admin> selectCopyrightPrincipal() {
  147. return adminMapper.selectCopyrightPrincipal();
  148. }
  149. @Override
  150. public List<Admin> selectTechprojectConsultant() {
  151. return adminMapper.selectTechprojectConsultant();
  152. }
  153. @Override
  154. public List<Admin> selectTechprojectPrincipal() {
  155. return adminMapper.selectTechprojectPrincipal();
  156. }
  157. @Override
  158. public List<String> selectRoleByPrimaryKey(String uid) {
  159. return adminMapper.selectRoleByPrimaryKey(uid);
  160. }
  161. @Override
  162. public List<String> listAuditor() {
  163. return userRoleMapper.listAuditor();
  164. }
  165. @Override
  166. public Map<String, String> selectAccoutManager() {
  167. return disposeAdminList(adminMapper.selectAccoutManager());
  168. }
  169. @Override
  170. public Map<String, String> selectTechnician() {
  171. return disposeAdminList(adminMapper.selectTechnician());
  172. }
  173. @Override
  174. public Map<String, String> selectSalesman() {
  175. return disposeAdminList(adminMapper.selectSalesman());
  176. }
  177. @Override
  178. public Map<String, String> selectContractManager() {
  179. return disposeAdminList(adminMapper.selectContractManager());
  180. }
  181. @Override
  182. public Map<String, String> selectTechBroder() {
  183. return disposeAdminList(adminMapper.selectTechBroder());
  184. }
  185. @Override
  186. public int insertNewAdmin(Admin ad) {
  187. return adminMapper.insert(ad);
  188. }
  189. @Override
  190. public Map<String, String> listAdminSelect() {
  191. if (TokenManager.hasRole(AFTConstants.SUPERADMIN)) {
  192. return disposeAdminList(adminMapper.listAdminSelectBySuperAdmin());
  193. } else if (TokenManager.hasRole(AFTConstants.AREAADMIN)) {
  194. List<Integer> provinceList = adminLocationMapper
  195. .selectProvinceWhereCityIsNullByAdminId(TokenManager.getAdminId());
  196. List<Integer> cityList = adminLocationMapper.selectCityByAdminId(TokenManager.getAdminId());
  197. provinceList.addAll(cityList);
  198. return disposeAdminList(adminMapper.listAdminSelectByAreaAdmin(provinceList, cityList));
  199. }
  200. return null;
  201. }
  202. private Map<String, String> disposeAdminList(List<Admin> list) {
  203. Map<String, String> map = new TreeMap<String, String>();
  204. for (Admin o : list) {
  205. map.put(o.getId(), o.getName());
  206. }
  207. return map;
  208. }
  209. @Override
  210. public List<Admin> listAdminByName(String name,Integer status) {
  211. if(status==null)status=0;
  212. return adminMapper.listAdminByName(name,status);
  213. }
  214. @Override
  215. public List<AdminListBo> selectDepartmentStaff(String departmentId, String name) {
  216. return adminMapper.selectDepartmentStaff( departmentId, name);
  217. }
  218. @Override
  219. public int updateLockAdmin() {
  220. int count=0;
  221. List<Admin> list=adminMapper.selectAllAdmin(null);//获取所有用户
  222. List<List<Admin>>aList=groupList(list);//拆分成多个
  223. String lockIds = "";
  224. for(List<Admin> al:aList){
  225. for (Admin a : al) {
  226. String pwd=a.getPassword();
  227. a.setPassword("123456");
  228. String pwd2=passwordUtil.getEncryptPwd(a);
  229. if (pwd.equals(pwd2)) {
  230. lockIds += a.getId() + ",";
  231. }
  232. }
  233. if(lockIds.length()>0){
  234. try {
  235. lockIds = "'" + lockIds.substring(0,lockIds.length()-1).replace(",", "','") + "'";
  236. count+= adminMapper.updateLockIds(lockIds);
  237. lockIds = "";
  238. Thread.sleep(1000);
  239. } catch (InterruptedException e) {
  240. LoggerUtils.error(getClass(), "未修改管理员锁定失败", e);
  241. }
  242. }
  243. }
  244. return count;
  245. }
  246. /*
  247. * List分割
  248. */
  249. public List<List<Admin>> groupList(List<Admin> list) {
  250. List<List<Admin>> listGroup = new ArrayList<List<Admin>>();
  251. int listSize = list.size();
  252. //子集合的长度
  253. int toIndex = 100;
  254. for (int i = 0; i < list.size(); i += toIndex) {
  255. if (i + toIndex > listSize) {
  256. toIndex = listSize - i;
  257. }
  258. List<Admin> newList = list.subList(i, i + toIndex);
  259. listGroup.add(newList);
  260. }
  261. return listGroup;
  262. }
  263. @Override
  264. public List<Admin> getListDefaultPassword(String depId) {
  265. List<Admin> list=adminMapper.selectAllAdmin(depId);
  266. List<Admin> list2=new ArrayList<>();
  267. for (Admin a : list) {
  268. String pwd=a.getPassword();
  269. a.setPassword("123456");
  270. String pwd2=passwordUtil.getEncryptPwd(a);
  271. if (pwd.equals(pwd2)) {
  272. list2.add(a);
  273. }
  274. }
  275. return list2;
  276. }
  277. @Override
  278. public List<Admin> getAdminRoleList(String roleName) {
  279. return adminMapper.getAdminRoleNameList(roleName);
  280. }
  281. @Override
  282. public int addFrequentContacts(String id) {
  283. String []ss=id.split(",");
  284. List<String> list=adminMapper.getaidFrequentContacts(TokenManager.getAdminId()==null?"1":TokenManager.getAdminId());
  285. for (String s : ss) {
  286. boolean flag=true;
  287. for (String s2 : list) {
  288. if (s.equals(s2)) {
  289. flag=false;
  290. }
  291. }
  292. if (flag) {
  293. AdminContacts a=new AdminContacts();
  294. a.setId(UUID.randomUUID().toString());
  295. a.setAid(TokenManager.getAdminId()==null?"1":TokenManager.getAdminId());
  296. a.setContactsId(s);
  297. adminMapper.addAdminContacts(a);
  298. }
  299. }
  300. return 1;
  301. }
  302. @SuppressWarnings("unchecked")
  303. @Override
  304. public Pagination<AdminListBo> frequentContactsList(String deps, String name,String roleName, Integer pageSize, Integer pageNo) {
  305. Map<String, Object> params = new HashMap<String, Object>();
  306. if(pageSize==null||pageSize<0)pageSize=10;
  307. if(pageNo==null||pageNo<0)pageNo=1;
  308. if (StringUtils.isNotBlank(deps)){
  309. params.put("depId", departmentService.parseArray(deps));
  310. }
  311. if (StringUtils.isNotBlank(name)) params.put("name", name);
  312. if (StringUtils.isNotBlank(roleName)) params.put("roleName", roleName);
  313. params.put("aid", TokenManager.getAdminId()==null?"1":TokenManager.getAdminId());
  314. Pagination<AdminListBo> p = (Pagination<AdminListBo>)findPage("frequentContactsList", "frequentContactsCount", params, pageNo, pageSize);
  315. List<AdminListBo> list=(List<AdminListBo>)p.getList();
  316. for(AdminListBo i:list){
  317. newAdminService.pushRolesName(i);
  318. }
  319. return p;
  320. }
  321. @Override
  322. public int deleteFrequentContacts(String id) {
  323. return adminMapper.deleteFrequentContacts(id);
  324. }
  325. @SuppressWarnings("unchecked")
  326. @Override
  327. public Pagination<AdminCustomerBo> selectAdminCustomerStatistics(String depId, String startTime, String endTime, Integer pageSize, Integer pageNo) {
  328. Map<String, Object> params = new HashMap<String, Object>();
  329. if(pageSize==null||pageSize<0)pageSize=10;
  330. if(pageNo==null||pageNo<0)pageNo=1;
  331. if (StringUtils.isNotBlank(depId)) params.put("depId", depId);
  332. if (StringUtils.isNotBlank(startTime)) params.put("startTime", startTime);
  333. if (StringUtils.isNotBlank(endTime)) params.put("endTime", endTime+" 23:59:59");
  334. return (Pagination<AdminCustomerBo>)findPage("selectAdminCustomerList", "selectAdminCustomerCount", params, pageNo, pageSize);
  335. }
  336. @Override
  337. public DepCountBo selectAllUser(String depId, String startTime, String endTime,String aName) {
  338. DepCountBo acb=new DepCountBo();
  339. if (endTime!=null)endTime=endTime+" 23:59:59";
  340. List<DepCountBo >deps=new ArrayList<>();
  341. List<Department> depIds=new ArrayList<>();
  342. //总裁助力不查看老员工
  343. Integer seniorstaff = null;
  344. if (TokenManager.hasRole(AFTConstants.CED_ASSISTANT)){
  345. seniorstaff=0;
  346. }
  347. if (depId==null) {
  348. acb.setName("科德集团");
  349. deps=departmentMapper.selectBysuperName("科德集团");
  350. }else {
  351. OrganizationListOut oo=departmentMapper.selectAllById(depId);
  352. acb.setName(oo.getName());
  353. acb.setId(depId);
  354. if(TokenManager.hasRole(AFTConstants.OPERATION_MANAGER)){
  355. List<String> myShiroDep = departmentService.selectMyDeps();
  356. if (!myShiroDep.contains(depId))throw new BusinessException("无权查看此部门信息");
  357. }
  358. depIds =departmentService.selectSubordinateDeps(depId);
  359. Department department = new Department();
  360. department.setId(depId);
  361. depIds.add(department);
  362. deps=departmentMapper.selectBysuperId(oo.getId());
  363. }
  364. List<AdminCustomerBo> list =null;
  365. //原sql计算
  366. // list=departmentMapper.AlldepCount(depIds,startTime, endTime);
  367. //新java计算
  368. list=AllDepCount(depIds,startTime,endTime,seniorstaff);
  369. for (AdminCustomerBo ad : list) {
  370. if (acb.getId().equals(ad.getDepId())){
  371. acb.getaList().add(ad);
  372. }
  373. }
  374. for (DepCountBo dep : deps) {
  375. dep.setList(iterationDeps(dep.getId(),list));
  376. for (AdminCustomerBo ad : list) {
  377. if (dep.getId().equals(ad.getDepId())){
  378. dep.getaList().add(ad);
  379. }
  380. sumCount(dep);
  381. }
  382. }
  383. acb.setList(deps);
  384. sumCount(acb);
  385. return acb;
  386. }
  387. private List<AdminCustomerBo> AllDepCount(List<Department> depIds, String startTime, String endTime,Integer seniorStaff) {
  388. List<AdminCustomerBo> admins = adminMapper.selectByDeps(depIds,seniorStaff);
  389. if(!admins.isEmpty()){
  390. List<AdminCustomerBo> users = userMapper.selectNoChannelByaids(admins,startTime,endTime);
  391. List<AdminCustomerBo> users2 = userMapper.selectChannelByaids(admins,startTime,endTime);
  392. for (AdminCustomerBo admin : admins) {
  393. for (AdminCustomerBo user : users) {
  394. if (admin.getAid().equals(user.getAid())){
  395. admin.setUserCount(user.getUserCount());
  396. admin.setChannelCount(user.getChannelCount());
  397. admin.setSignCount(user.getSignCount());
  398. admin.setNewCount(user.getNewCount());
  399. admin.setChannelNewCount(user.getChannelNewCount());
  400. admin.setReceiveCount(user.getReceiveCount());
  401. admin.setTransferCount(user.getTransferCount());
  402. admin.setIntentionCount(user.getIntentionCount());
  403. admin.setKeynoteCount(user.getKeynoteCount());
  404. admin.setGeneralCount(user.getGeneralCount());
  405. break;
  406. }
  407. }
  408. for (AdminCustomerBo user : users2) {
  409. if (admin.getAid().equals(user.getAid())){
  410. admin.setCompleteCount(user.getCompleteCount());
  411. admin.setChannelCompleteCount(user.getChannelCompleteCount());
  412. break;
  413. }
  414. }
  415. pushAdminCount(admin);
  416. }
  417. }
  418. return admins;
  419. }
  420. private void pushAdminCount(AdminCustomerBo admin) {
  421. if (admin.getUserCount()==null) admin.setUserCount(0);
  422. if (admin.getChannelCount()==null) admin.setChannelCount(0);
  423. if (admin.getSignCount()==null) admin.setSignCount(0);
  424. if (admin.getNewCount()==null) admin.setNewCount(0);
  425. if (admin.getChannelNewCount()==null) admin.setChannelNewCount(0);
  426. if (admin.getReceiveCount()==null) admin.setReceiveCount(0);
  427. if (admin.getCompleteCount()==null) admin.setCompleteCount(0);
  428. if (admin.getChannelCompleteCount()==null) admin.setChannelCompleteCount(0);
  429. if (admin.getTransferCount()==null)admin.setTransferCount(0);
  430. if (admin.getIntentionCount()==null)admin.setIntentionCount(0);
  431. if (admin.getKeynoteCount()==null)admin.setKeynoteCount(0);
  432. if (admin.getGeneralCount()==null)admin.setGeneralCount(0);
  433. }
  434. //迭代获取所有部门与部门员工并计算出部门数量
  435. public List<DepCountBo> iterationDeps(String id,List<AdminCustomerBo> list) {
  436. List<DepCountBo> deps =departmentMapper.selectBysuperId(id);
  437. for (DepCountBo dep : deps) {
  438. dep.setList(iterationDeps(dep.getId(),list));
  439. for (AdminCustomerBo ad : list) {
  440. if (dep.getId().equals(ad.getDepId())){
  441. dep.getaList().add(ad);
  442. }
  443. }
  444. sumCount(dep);
  445. }
  446. return deps;
  447. }
  448. /**
  449. *
  450. * @param ab
  451. */
  452. public void sumCount(DepCountBo ab) {
  453. int completeCount=0,receiveCount=0,userCount=0,signCount=0,channelCount=0,newCount=0,channelNewCount=0,
  454. channelCompleteCount=0,transferCount=0,intentionCount=0,keynoteCount=0,generalCount=0;
  455. if (ab.getList()!=null&&!ab.getList().isEmpty()) {
  456. for (DepCountBo a : ab.getList()) {
  457. if (a.getCompleteCount()!=null&& a.getCompleteCount()!=0) completeCount+=a.getCompleteCount();
  458. if (a.getReceiveCount()!=null&& a.getReceiveCount()!=0) receiveCount+=a.getReceiveCount();
  459. if (a.getUserCount()!=null&& a.getUserCount()!=0) userCount+=a.getUserCount();
  460. if (a.getSignCount()!=null&& a.getSignCount()!=0) signCount+=a.getSignCount();
  461. if (a.getChannelCount()!=null&& a.getChannelCount()!=0) channelCount+=a.getChannelCount();
  462. if (a.getNewCount()!=null&& a.getNewCount()!=0) newCount+=a.getNewCount();
  463. if (a.getChannelNewCount()!=null&& a.getChannelNewCount()!=0) channelNewCount+=a.getChannelNewCount();
  464. if (a.getChannelCompleteCount()!=null&& a.getChannelCompleteCount()!=0) channelCompleteCount+=a.getChannelCompleteCount();
  465. if (a.getTransferCount()!=null&& a.getTransferCount()!=0)transferCount+=a.getTransferCount();
  466. if (a.getIntentionCount()!=null&& a.getIntentionCount()!=0) intentionCount+=a.getIntentionCount();
  467. if (a.getKeynoteCount()!=null&& a.getKeynoteCount()!=0) keynoteCount+=a.getKeynoteCount();
  468. if (a.getGeneralCount()!=null&& a.getGeneralCount()!=0) generalCount=a.getGeneralCount();
  469. }
  470. }
  471. if (ab.getaList()!=null&&!ab.getaList().isEmpty()) {
  472. for (AdminCustomerBo a : ab.getaList()) {
  473. if (a.getCompleteCount()!=null&& a.getCompleteCount()!=0) completeCount+=a.getCompleteCount();
  474. if (a.getReceiveCount()!=null&& a.getReceiveCount()!=0) receiveCount+=a.getReceiveCount();
  475. if (a.getUserCount()!=null&& a.getUserCount()!=0) userCount+=a.getUserCount();
  476. if (a.getSignCount()!=null&& a.getSignCount()!=0) signCount+=a.getSignCount();
  477. if (a.getChannelCount()!=null&& a.getChannelCount()!=0) channelCount+=a.getChannelCount();
  478. if (a.getNewCount()!=null&& a.getNewCount()!=0) newCount+=a.getNewCount();
  479. if (a.getChannelNewCount()!=null&& a.getChannelNewCount()!=0) channelNewCount+=a.getChannelNewCount();
  480. if (a.getChannelCompleteCount()!=null&& a.getChannelCompleteCount()!=0) channelCompleteCount+=a.getChannelCompleteCount();
  481. if (a.getTransferCount()!=null&& a.getTransferCount()!=0)transferCount+=a.getTransferCount();
  482. if (a.getIntentionCount()!=null&& a.getIntentionCount()!=0) intentionCount+=a.getIntentionCount();
  483. if (a.getKeynoteCount()!=null&& a.getKeynoteCount()!=0) keynoteCount+=a.getKeynoteCount();
  484. if (a.getGeneralCount()!=null&& a.getGeneralCount()!=0) generalCount=a.getGeneralCount();
  485. }
  486. }
  487. ab.setCompleteCount(completeCount);
  488. ab.setReceiveCount(receiveCount);
  489. ab.setUserCount(userCount);
  490. ab.setSignCount(signCount);
  491. ab.setChannelCount(channelCount);
  492. ab.setNewCount(newCount);
  493. ab.setChannelNewCount(channelNewCount);
  494. ab.setChannelCompleteCount(channelCompleteCount);
  495. ab.setTransferCount(transferCount);
  496. ab.setIntentionCount(intentionCount);
  497. ab.setKeynoteCount(keynoteCount);
  498. ab.setGeneralCount(generalCount);
  499. }
  500. @SuppressWarnings("unchecked")
  501. @Override
  502. public Pagination<AdminCustomerDetailBo> selectAdminCustomerList(String aid, String startTime, String endTime,Integer type,
  503. Integer pageSize, Integer pageNo) {
  504. Map<String, Object> params = new HashMap<String, Object>();
  505. if(pageSize==null||pageSize<0)pageSize=10;
  506. if(pageNo==null||pageNo<0)pageNo=1;
  507. if (StringUtils.isNotBlank(aid)) params.put("aid", aid);
  508. if (type==null) params.put("type", 0);
  509. else params.put("type", type);
  510. if (StringUtils.isNotBlank(startTime)) params.put("startTime", startTime);
  511. if (StringUtils.isNotBlank(endTime)) params.put("endTime", endTime+" 23:59:59");
  512. Pagination<AdminCustomerDetailBo> p =(Pagination<AdminCustomerDetailBo>)findPage("selectAdminCustomerDetailList", "selectAdminCustomerDetailCount", params, pageNo, pageSize);
  513. if (type == 2&& !TokenManager.hasRole(AFTConstants.SUPERADMIN)) {
  514. List<AdminCustomerDetailBo> list = (List<AdminCustomerDetailBo>) p.getList();
  515. for (AdminCustomerDetailBo out : list) {
  516. out.setContacts("***");
  517. out.setContactMobile("***");
  518. }
  519. }
  520. return p;
  521. }
  522. @Override
  523. public int updatePrivateBusinessTransfer(String inputId, String uid, String pid) {
  524. String aid=TokenManager.getAdminId();
  525. int i=userLockReleaseMapper.updatePrivateBusinessTransfer( inputId, uid, pid,aid);
  526. if (i>0) {
  527. List<BusinessListBo> l=userBusinessMapper.selectBusinessProjectByUAPid(uid, inputId, pid);
  528. if (l.isEmpty()) {
  529. UserBusiness ub=new UserBusiness();
  530. ub.setId(UUID.randomUUID().toString());
  531. ub.setAid(inputId);
  532. ub.setUid(uid);
  533. ub.setBusinessProjectId(pid);
  534. ub.setCustomerStatus(4);
  535. ub.setFollowSituation(5);
  536. ub.setRemarks("转交客户业务触发");
  537. userBusinessMapper.insertSelective(ub);
  538. }
  539. }
  540. return i;
  541. }
  542. @Override
  543. public Object pushStatistics() {
  544. //营销统计处理
  545. // List<String> roles=new ArrayList<>();
  546. // roles.add(AFTConstants.SALESMAN);
  547. // roles.add(AFTConstants.SALESMAN_MANAGER);
  548. // List<Admin> adminList = adminMapper.getAdminRoleTypesList(roles);
  549. // for (Admin admin : adminList) {
  550. // List<AdminUserCount> list =adminMapper.selectAdminPublicRelease(admin.getId());
  551. // List<AdminUserCount> list2 =adminMapper.selectAdminUserFollow(admin.getId());
  552. // List<AdminUserCount> list3 =adminMapper.selectAdminOrder(admin.getId());
  553. // if (list.isEmpty())list=new ArrayList<>();
  554. // if (!list.isEmpty())list.addAll(list2);
  555. // if (!list.isEmpty())list.addAll(list3);
  556. // publiAdminUserCount(list);
  557. // System.out.println("list="+list.size());
  558. // }
  559. //咨询师统计处理
  560. // List<TOrderTask> allTimeRecord = taskTimeMapper.getAllTimeRecord();
  561. // List<TaskTime> list=new ArrayList<>();
  562. // for (TOrderTask e : allTimeRecord) {
  563. // String timeRecord = e.getTimeRecord();
  564. // System.out.println(e.getTimeRecord());
  565. // if (StringUtils.isNotBlank(e.getTimeRecord())){
  566. // Map<String,Object> map = JSON.parseObject(timeRecord, Map.class);
  567. // for (String s : map.keySet()) {
  568. // if (s.equals("2")||s.equals("3")||s.equals("29")||s.equals("19")||(s.equals("27"))){
  569. // JSONObject js = JSON.parseObject(map.get(s).toString());
  570. // Object date = js.get("date");
  571. // Object suspendImg = js.get("suspendImg") ;
  572. // Object title = js.get("title") ;
  573. // Object certificateNumber = js.get("certificateNumber") ;
  574. // Object setUpAmount = js.get("setUpAmount") ;
  575. // Object appropriation = js.get("appropriation") ;
  576. // TaskTime tt=new TaskTime();
  577. // tt.setTid(e.getId());
  578. // tt.setProjectStatus(Integer.parseInt(s));
  579. // if (!Objects.isNull(date)){
  580. // String dates=date.toString();
  581. // if (StringUtils.isNotBlank(dates)){
  582. // Date date1 = DateUtils.StringToDate(dates, AFTConstants.YYYYMMDD);
  583. // tt.setDateTime(date1);
  584. // }
  585. // }
  586. // if (!Objects.isNull(setUpAmount))tt.setSetUpAmount(setUpAmount.toString());
  587. // if (!Objects.isNull(suspendImg))tt.setSuspendImg(suspendImg.toString());
  588. // if (!Objects.isNull(title))tt.setTitle(title.toString());
  589. // if (!Objects.isNull(certificateNumber))tt.setCertificateNumber(certificateNumber.toString());
  590. // if (!Objects.isNull(appropriation))tt.setAppropriation(appropriation.toString());
  591. // list.add(tt);
  592. //// taskTimeMapper.insertSelective(tt);
  593. // }
  594. // }
  595. // }
  596. // }
  597. // List<TaskTime> addList = new ArrayList<>();
  598. // for (int i = 0; i <list.size(); i++) {
  599. // addList.add(list.get(i));
  600. // if (addList.size()==50|| i==list.size() -1){
  601. // taskTimeMapper.insertBatch(addList);
  602. // try {
  603. // addList.clear();
  604. // Thread.sleep(500);
  605. // } catch (InterruptedException exception) {
  606. // exception.printStackTrace();
  607. // }
  608. // }
  609. // }
  610. List<String> roles=new ArrayList<>();
  611. roles.add(AFTConstants.FINANCE);
  612. roles.add(AFTConstants.FINANCE_MANAGER);
  613. List<Admin> admins = adminMapper.selectAdminByRoleTypes(roles);
  614. List<FinanceCount> list=new ArrayList<>();
  615. for (Admin admin : admins){
  616. List<FinanceCount> aList=new ArrayList<>();
  617. List<FinanceCount> orderList = TOrderNewMapper.selectCountByFinance(admin.getId());
  618. if (!orderList.isEmpty()){
  619. aList.addAll(orderList);
  620. }
  621. List<FinanceCount> expenseList = expenseAccountMapper.selectCountByFinance(admin.getId());
  622. pushFinanceList(aList, expenseList,0);
  623. List<FinanceCount> invoiceList =tOrderInvoiceMapper.selectCountByFinance(admin.getId());
  624. pushFinanceList(aList, invoiceList,1);
  625. List<FinanceCount> memberList =tTaskMemberMapper.selectCountByFinance(admin.getId());
  626. pushFinanceList(aList, memberList,2);
  627. List<FinanceCount> paymentList =tOrderPaymentMapper.selectCountByFinance(admin.getId());
  628. pushFinanceList(aList, paymentList,3);
  629. if (!aList.isEmpty()){
  630. for (FinanceCount financeCount : aList) {
  631. if (financeCount.getExpenseCount()!=null&&financeCount.getExpenseCount()>0){
  632. financeCount.toString();
  633. }
  634. }
  635. }
  636. list.addAll(aList);
  637. }
  638. List<FinanceCount> addList=new ArrayList<>();
  639. for (int i = 0; i <list.size(); i++) {
  640. FinanceCount financeCount = list.get(i);
  641. FinanceCount newFc=FinanceCount.initialization(financeCount);
  642. addList.add(newFc);
  643. if (addList.size()==50||i==list.size()-1){
  644. financeCountMapper.insetBatch(addList);
  645. addList.clear();
  646. try {
  647. Thread.sleep(500);
  648. } catch (InterruptedException exception) {
  649. exception.printStackTrace();
  650. }
  651. }
  652. }
  653. return 1;
  654. }
  655. @Override
  656. public Result selectAllUserExport(String depId, String startTime, String endTime, String aName) {
  657. if (endTime!=null)endTime=endTime+" 23:59:59";
  658. List<Department> depIds=new ArrayList<>();
  659. //总裁助力不查看老员工
  660. Integer seniorstaff = null;
  661. if (TokenManager.hasRole(AFTConstants.CED_ASSISTANT)){
  662. seniorstaff=0;
  663. }
  664. OrganizationListOut oo=departmentMapper.selectAllById(depId);
  665. if(TokenManager.hasRole(AFTConstants.OPERATION_MANAGER)){
  666. List<String> myShiroDep = departmentService.selectMyDeps();
  667. if (!myShiroDep.contains(depId))throw new BusinessException("无权查看此部门信息");
  668. }
  669. depIds =departmentService.selectSubordinateDeps(depId);
  670. Department department = new Department();
  671. department.setId(depId);
  672. depIds.add(department);
  673. List<AdminCustomerBo> list =null;
  674. //原sql计算
  675. // list=departmentMapper.AlldepCount(depIds,startTime, endTime);
  676. //新java计算
  677. list=AllDepCount(depIds,startTime,endTime,seniorstaff);
  678. NewExcelUtil excel=new NewExcelUtil(AdminCustomerBo.class);
  679. return excel.exportExcel(list,"部门统计表",uploadPath);
  680. }
  681. /**
  682. *
  683. * @param list
  684. * @param minList
  685. * @param type
  686. */
  687. private void pushFinanceList(List<FinanceCount> list, List<FinanceCount> minList,Integer type) {
  688. if (!minList.isEmpty()){
  689. for (FinanceCount expense : minList) {
  690. boolean flag=true;
  691. for (FinanceCount e : list) {
  692. if (e.getDateTime().getTime()==expense.getDateTime().getTime()){
  693. if (type==0){
  694. e.setExpenseCount(expense.getExpenseCount());
  695. e.setExpenseUnauditedCount(expense.getExpenseUnauditedCount());
  696. }else if (type==1){
  697. e.setInvoiceCount(expense.getInvoiceCount());
  698. e.setInvoiceUnauditedCount(expense.getInvoiceUnauditedCount());
  699. }else if (type==2){
  700. e.setMemberCount(expense.getMemberCount());
  701. e.setMemberUnauditedCount(expense.getMemberUnauditedCount());
  702. }else if (type==3){
  703. e.setPaymentCount(expense.getPaymentCount());
  704. e.setPaymentUnauditedCount(expense.getPaymentUnauditedCount());
  705. }
  706. flag=false;
  707. }
  708. }
  709. if (flag){
  710. list.add(expense);
  711. }
  712. }
  713. }
  714. }
  715. private void publiAdminUserCount(List<AdminUserCount> list) {
  716. for (AdminUserCount e : list) {
  717. int i=adminUserCountMapper.updateByAidAndDateSelective(e);
  718. if (i==0){
  719. adminUserCountMapper.insertSelective(e);
  720. }
  721. }
  722. }
  723. }