PlanQuarterServiceImpl.java 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698
  1. package com.ozs.plan.service.impl;
  2. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.ozs.common.constant.Constants;
  6. import com.ozs.common.core.domain.AjaxResult;
  7. import com.ozs.common.core.domain.entity.SysDept;
  8. import com.ozs.common.core.domain.entity.SysDictData;
  9. import com.ozs.common.core.domain.entity.SysRole;
  10. import com.ozs.common.core.domain.model.LoginUser;
  11. import com.ozs.common.enums.DataIsDelete;
  12. import com.ozs.common.enums.PmProjectStatus;
  13. import com.ozs.common.enums.ProjectStatus;
  14. import com.ozs.common.enums.ProjectTypes;
  15. import com.ozs.common.enums.QuarterEnum;
  16. import com.ozs.common.enums.SysFileRefEnum;
  17. import com.ozs.common.exception.ServiceException;
  18. import com.ozs.common.utils.PageUtils;
  19. import com.ozs.common.utils.StringUtils;
  20. import com.ozs.common.utils.bean.BeanUtils;
  21. import com.ozs.plan.doman.PlanQuarter;
  22. import com.ozs.plan.doman.PlanYears;
  23. import com.ozs.plan.doman.vo.requestVo.PlanQuarterStandardVo;
  24. import com.ozs.plan.doman.vo.responseVo.PlanQuarterResponseVo;
  25. import com.ozs.plan.mapper.PlanQuarterMapper;
  26. import com.ozs.plan.mapper.PlanYearsMapper;
  27. import com.ozs.plan.service.PlanQuarterService;
  28. import com.ozs.pm.doman.PmDemand;
  29. import com.ozs.pm.mapper.PmDemandMapper;
  30. import com.ozs.system.domain.SysFileInfo;
  31. import com.ozs.system.domain.SysFileRef;
  32. import com.ozs.system.domain.vo.responseVo.SysDeptResponseVo;
  33. import com.ozs.system.mapper.SysDeptMapper;
  34. import com.ozs.system.mapper.SysFileRefMapper;
  35. import com.ozs.system.service.ISysDeptService;
  36. import com.ozs.system.service.ISysDictTypeService;
  37. import com.ozs.system.service.SysFileService;
  38. import lombok.extern.slf4j.Slf4j;
  39. import org.springframework.beans.factory.annotation.Autowired;
  40. import org.springframework.security.core.token.TokenService;
  41. import org.springframework.stereotype.Service;
  42. import org.springframework.transaction.annotation.Transactional;
  43. import org.springframework.util.ObjectUtils;
  44. import javax.annotation.Resource;
  45. import javax.servlet.http.HttpServletRequest;
  46. import javax.validation.Validator;
  47. import java.math.BigDecimal;
  48. import java.text.ParseException;
  49. import java.text.SimpleDateFormat;
  50. import java.util.ArrayList;
  51. import java.util.Date;
  52. import java.util.HashMap;
  53. import java.util.LinkedHashMap;
  54. import java.util.List;
  55. import java.util.Map;
  56. import java.util.stream.Collectors;
  57. /**
  58. * @author buzhanyi
  59. */
  60. @Service
  61. @Slf4j
  62. public class PlanQuarterServiceImpl extends ServiceImpl<PlanQuarterMapper, PlanQuarter> implements PlanQuarterService {
  63. @Autowired
  64. PlanQuarterMapper planQuarterMapper;
  65. @Autowired
  66. PlanYearsMapper planYearsMapper;
  67. @Autowired
  68. protected Validator validator;
  69. @Autowired
  70. private ISysDictTypeService dictTypeService;
  71. @Autowired
  72. private ISysDeptService deptService;
  73. @Autowired
  74. SysFileRefMapper sysFileRefMapper;
  75. @Autowired
  76. private SysDeptMapper deptMapper;
  77. @Autowired
  78. private SysFileService fileService;
  79. @Autowired
  80. private PmDemandMapper pmDemandMapper;
  81. @Override
  82. public List<PlanQuarterResponseVo> selectPlanQuarterListEXP(PlanQuarterStandardVo vo, LoginUser loginUser) {
  83. List<PlanQuarter> list = new ArrayList<>();
  84. List<PlanQuarterResponseVo> planQuarterList = new ArrayList<>();
  85. try {
  86. int num = 1;
  87. int size = 200;
  88. while (size == 200) {
  89. LambdaQueryWrapper<PlanQuarter> lw = new LambdaQueryWrapper<>();
  90. if (!ObjectUtils.isEmpty(vo.getProjectName())) {
  91. lw.like(PlanQuarter::getProjectName, vo.getProjectName());
  92. }
  93. if (!ObjectUtils.isEmpty(vo.getPurchaseServices())) {
  94. lw.eq(PlanQuarter::getPurchaseServices, vo.getPurchaseServices());
  95. }
  96. if (!ObjectUtils.isEmpty(vo.getIsExcess())) {
  97. lw.eq(PlanQuarter::getIsExcess, vo.getIsExcess());
  98. }
  99. if (!ObjectUtils.isEmpty(vo.getProjectStatus())) {
  100. lw.eq(PlanQuarter::getProjectStatus, vo.getProjectStatus());
  101. }
  102. if (!ObjectUtils.isEmpty(vo.getBeginTime())) {
  103. lw.ge(PlanQuarter::getPlanDemandSubTime, vo.getBeginTime());
  104. }
  105. if (!ObjectUtils.isEmpty(vo.getEndTime())) {
  106. lw.le(PlanQuarter::getPlanDemandSubTime, vo.getEndTime());
  107. }
  108. lw.eq(PlanQuarter::getDelFlay, DataIsDelete.DataNOTDelete.getCode());
  109. // 添加数据权限
  110. List<String> roleKeys = loginUser.getUser().getRoles().stream().map(SysRole::getRoleKey).collect(Collectors.toList());
  111. if (roleKeys.contains(Constants.DEMAND_UNIT)) {
  112. // 需求单位
  113. /*(purchase_dept_id = 当前用户deptID) */
  114. lw.eq(PlanQuarter::getPurchaseDeptId, loginUser.getDeptId());
  115. } else if (roleKeys.contains(Constants.PURCHASING_MANAGEMENT)
  116. || roleKeys.contains(Constants.PURCHASE_SERVICES)) {
  117. // 采购管理部门 或 采购办
  118. SysDept sysDept = new SysDept();
  119. sysDept.setParentId(loginUser.getDeptId());
  120. sysDept.setStatus("0");
  121. List<Long> childDeptIds = deptService.selectDeptList(sysDept)
  122. .stream()
  123. .map(SysDept::getDeptId)
  124. .collect(Collectors.toList());
  125. if (ObjectUtils.isEmpty(childDeptIds)) {
  126. lw.and((wrapper) -> {
  127. wrapper.eq(PlanQuarter::getIsExcess, 0);
  128. wrapper.eq(PlanQuarter::getPurchaseDeptId, loginUser.getDeptId());
  129. });
  130. } else {
  131. lw.and((wrapper) -> {
  132. wrapper.eq(PlanQuarter::getIsExcess, 0);
  133. wrapper.eq(PlanQuarter::getPurchaseDeptId, loginUser.getDeptId());
  134. })
  135. .or((wrapper) -> {
  136. wrapper.eq(PlanQuarter::getIsExcess, 1);
  137. wrapper.in(PlanQuarter::getPurchaseDeptId, childDeptIds);
  138. });
  139. }
  140. }
  141. Page<PlanQuarter> page = planQuarterMapper.selectPage(new Page<>(num, size, false), lw);
  142. list.addAll(page.getRecords());
  143. size = page.getRecords().size();
  144. num++;
  145. }
  146. planQuarterList = changeTo(list);
  147. } catch (Exception e) {
  148. e.printStackTrace();
  149. }
  150. return planQuarterList;
  151. }
  152. @Override
  153. public List<PlanQuarterResponseVo> selectPlanQuarterExamineListEXP(PlanQuarterStandardVo vo, LoginUser loginUser) {
  154. List<PlanQuarter> list = new ArrayList<>();
  155. List<PlanQuarterResponseVo> planQuarterList = new ArrayList<>();
  156. try {
  157. int num = 1;
  158. int size = 200;
  159. while (size == 200) {
  160. LambdaQueryWrapper<PlanQuarter> lw = new LambdaQueryWrapper<PlanQuarter>();
  161. if (!ObjectUtils.isEmpty(vo.getProjectName())) {
  162. lw.like(PlanQuarter::getProjectName, vo.getProjectName());
  163. }
  164. if (!ObjectUtils.isEmpty(vo.getPurchaseServices())) {
  165. lw.eq(PlanQuarter::getPurchaseServices, vo.getPurchaseServices());
  166. }
  167. if (!ObjectUtils.isEmpty(vo.getIsExcess())) {
  168. lw.eq(PlanQuarter::getIsExcess, vo.getIsExcess());
  169. }
  170. if (!ObjectUtils.isEmpty(vo.getProjectStatus())) {
  171. lw.eq(PlanQuarter::getProjectStatus, vo.getProjectStatus());
  172. } else {
  173. lw.in(PlanQuarter::getProjectStatus, "1,3");
  174. }
  175. if (!ObjectUtils.isEmpty(vo.getBeginTime())) {
  176. lw.ge(PlanQuarter::getPlanDemandSubTime, vo.getBeginTime());
  177. }
  178. if (!ObjectUtils.isEmpty(vo.getEndTime())) {
  179. lw.le(PlanQuarter::getPlanDemandSubTime, vo.getEndTime());
  180. }
  181. lw.eq(PlanQuarter::getDelFlay, DataIsDelete.DataNOTDelete.getCode());
  182. // 添加数据权限
  183. List<String> roleKeys = loginUser.getUser().getRoles().stream().map(SysRole::getRoleKey).collect(Collectors.toList());
  184. if (roleKeys.contains(Constants.DEMAND_UNIT)) {
  185. // 需求单位
  186. /*(purchase_dept_id = 当前用户deptID) */
  187. lw.eq(PlanQuarter::getPurchaseDeptId, loginUser.getDeptId());
  188. } else if (roleKeys.contains(Constants.PURCHASING_MANAGEMENT)
  189. || roleKeys.contains(Constants.PURCHASE_SERVICES)) {
  190. // 采购管理部门 或 采购办
  191. SysDept sysDept = new SysDept();
  192. sysDept.setParentId(loginUser.getDeptId());
  193. sysDept.setStatus("0");
  194. List<Long> childDeptIds = deptService.selectDeptList(sysDept)
  195. .stream()
  196. .map(SysDept::getDeptId)
  197. .collect(Collectors.toList());
  198. if (ObjectUtils.isEmpty(childDeptIds)) {
  199. lw.and((wrapper) -> {
  200. wrapper.eq(PlanQuarter::getIsExcess, 0);
  201. wrapper.eq(PlanQuarter::getPurchaseDeptId, loginUser.getDeptId());
  202. });
  203. } else {
  204. lw.and((wrapper) -> {
  205. wrapper.eq(PlanQuarter::getIsExcess, 0);
  206. wrapper.eq(PlanQuarter::getPurchaseDeptId, loginUser.getDeptId());
  207. })
  208. .or((wrapper) -> {
  209. wrapper.eq(PlanQuarter::getIsExcess, 1);
  210. wrapper.in(PlanQuarter::getPurchaseDeptId, childDeptIds);
  211. });
  212. }
  213. }
  214. Page<PlanQuarter> page = planQuarterMapper.selectPage(new Page<PlanQuarter>(num, size, false), lw);
  215. list.addAll(page.getRecords());
  216. size = page.getRecords().size();
  217. num++;
  218. }
  219. planQuarterList = changeTo(list);
  220. } catch (Exception e) {
  221. e.printStackTrace();
  222. }
  223. return planQuarterList;
  224. }
  225. @Transactional
  226. @Override
  227. public AjaxResult insertPlanQuarter(PlanQuarterStandardVo quarterStandardVo) {
  228. if (planQuarterMapper.countProjectName(quarterStandardVo.getProjectName()) > 0) {
  229. return AjaxResult.error("该项目名称已经存在");
  230. }
  231. PlanQuarter quarters = new PlanQuarter();
  232. try {
  233. BeanUtils.copyProperties(quarterStandardVo, quarters);
  234. } catch (Exception e) {
  235. e.printStackTrace();
  236. }
  237. //判断是否为超额计划
  238. quarters.setIsExcess(isExcessOrNo(quarters.getProjectType(), quarters.getEvaluation()));
  239. quarters.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
  240. quarters.setCreateTime(new Date());
  241. planQuarterMapper.insertPlanQuarter(quarters);
  242. log.info("id:{}", quarters.getPlanPracticalId());
  243. List<SysFileRef> sysFileRefs = quarterStandardVo.getSysFileRefs();
  244. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  245. for (SysFileRef ref : sysFileRefs) {
  246. ref.setRedId(quarters.getPlanPracticalId());
  247. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  248. ref.setCreated(quarters.getCreated());
  249. ref.setCreateTime(new Date());
  250. ref.setUpdated(quarters.getCreated());
  251. ref.setUpdateTime(new Date());
  252. sysFileRefMapper.insert(ref);
  253. }
  254. }
  255. return AjaxResult.success();
  256. }
  257. @Override
  258. public AjaxResult deletePlanQuarterByIds(Long[] planIds) {
  259. planQuarterMapper.deletePlanQuarterByIds(planIds);
  260. return AjaxResult.success();
  261. }
  262. @Override
  263. public AjaxResult deletePlanQuarterById(Long planId) {
  264. planQuarterMapper.deletePlanQuarterById(planId);
  265. return AjaxResult.success();
  266. }
  267. @Override
  268. public AjaxResult view(PlanQuarterStandardVo quarterStandardVo) {
  269. PlanQuarterResponseVo responseVo = new PlanQuarterResponseVo();
  270. PlanQuarter byId = planQuarterMapper.getById(quarterStandardVo.getPlanPracticalId());
  271. if (byId == null) {
  272. return AjaxResult.error("数据查询失败");
  273. }
  274. SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(byId.getPurchaseDeptId())).get("sysDept");
  275. byId.setPurchaseDeptName(sysDeptResponseVo.getDeptName());
  276. HashMap<String, Object> map = new HashMap<>();
  277. map.put("red_id", byId.getPlanPracticalId());
  278. map.put("type", SysFileRefEnum.PLAN_TEMPORARY.getType());
  279. List<SysFileRef> fileRefs = sysFileRefMapper.selectByMap(map);
  280. List<SysFileInfo> fileInfos = new ArrayList<>();
  281. BeanUtils.copyProperties(byId, responseVo);
  282. if (!ObjectUtils.isEmpty(fileRefs)) {
  283. for (SysFileRef ref : fileRefs) {
  284. SysFileInfo fileInfo = fileService.getById(ref.getFileId());
  285. fileInfos.add(fileInfo);
  286. }
  287. responseVo.setFileInfos(fileInfos);
  288. }
  289. return AjaxResult.success(responseVo);
  290. }
  291. @Transactional
  292. @Override
  293. public AjaxResult update(PlanQuarterStandardVo quarterStandardVo) {
  294. if (planQuarterMapper.countProjectNameOther(quarterStandardVo.getProjectName(), String.valueOf(quarterStandardVo.getPlanPracticalId())) > 0) {
  295. return AjaxResult.error("该项目名称已经存在");
  296. }
  297. PlanQuarter quarters = new PlanQuarter();
  298. try {
  299. BeanUtils.copyProperties(quarterStandardVo, quarters);
  300. } catch (Exception e) {
  301. e.printStackTrace();
  302. }
  303. quarters.setIsExcess(isExcessOrNo(quarters.getProjectType(), quarters.getEvaluation()));
  304. quarters.setUpdateTime(new Date());
  305. planQuarterMapper.updateInfoById(quarters);
  306. List<SysFileRef> sysFileRefs = quarterStandardVo.getSysFileRefs();
  307. HashMap<String, Object> map = new HashMap<>();
  308. map.put("red_id", quarters.getPlanPracticalId());
  309. map.put("type", SysFileRefEnum.PLAN_TEMPORARY.getType());
  310. sysFileRefMapper.deleteByMap(map);
  311. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  312. for (SysFileRef ref : sysFileRefs) {
  313. ref.setRedId(quarters.getPlanPracticalId());
  314. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  315. ref.setCreated(quarterStandardVo.getUpdated());
  316. ref.setCreateTime(new Date());
  317. ref.setUpdated(quarterStandardVo.getUpdated());
  318. ref.setUpdateTime(new Date());
  319. sysFileRefMapper.insert(ref);
  320. }
  321. }
  322. return AjaxResult.success();
  323. }
  324. @Override
  325. public String importPlanQuarter(List<PlanQuarterStandardVo> planQuarters, boolean isUpdateSupport, LoginUser loginUser) {
  326. if (StringUtils.isNull(planQuarters) || planQuarters.size() == 0) {
  327. throw new ServiceException("导入季度计划数据不能为空!");
  328. }
  329. List<PlanQuarter> list = new ArrayList<>();
  330. for (PlanQuarterStandardVo standardVo : planQuarters) {
  331. PlanQuarter quarter = new PlanQuarter();
  332. BeanUtils.copyProperties(standardVo, quarter);
  333. quarter.setPurchaseDeptName(standardVo.getPurchaseDeptId());
  334. list.add(quarter);
  335. }
  336. HashMap<String, HashMap<String, String>> planEnums = dictTypeService.getAboutEnums();
  337. HashMap<String, String> projectTypesMap = planEnums.get("projectTypes");
  338. HashMap<String, String> planPurchaseModesMap = planEnums.get("planPurchaseModes");
  339. HashMap<String, String> projectAttributes = planEnums.get("projectAttributes");
  340. HashMap<String, String> purchaseServices = planEnums.get("purchaseServices");
  341. int successNum = 0;
  342. int failureNum = 0;
  343. StringBuilder successMsg = new StringBuilder();
  344. StringBuilder failureMsg = new StringBuilder();
  345. //deptService
  346. for (PlanQuarter planQuarter : list) {
  347. try {
  348. //验证项目名称是否重复导入
  349. //将录入信息中的值更改为要保存的数据
  350. if (planQuarterMapper.countProjectName(planQuarter.getProjectName()) == 0) {
  351. //采购单位
  352. SysDept info = deptMapper.checkDeptNameOnlyOne(planQuarter.getPurchaseDeptName());
  353. if (!ObjectUtils.isEmpty(info)) {
  354. planQuarter.setPurchaseDeptId(String.valueOf(info.getDeptId()));
  355. } else {
  356. ++failureNum;
  357. failureMsg.append("*" + failureNum + "*采购单位“" + planQuarter.getPurchaseDeptName() + "”不存在");
  358. }
  359. planQuarter.setProjectType(projectTypesMap.get(planQuarter.getProjectType()));
  360. planQuarter.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
  361. planQuarter.setPurchaseMode(planPurchaseModesMap.get(planQuarter.getPurchaseMode()));
  362. //项目属性是多选字段
  363. StringBuilder builder = new StringBuilder();
  364. if (planQuarter.getProjectAttr().contains(",")) {
  365. String[] split = planQuarter.getProjectAttr().split(",");
  366. for (String s : split) {
  367. if (!planQuarter.getProjectAttr().endsWith(s)) {
  368. builder.append(projectAttributes.get(s) + ",");
  369. } else {
  370. builder.append(projectAttributes.get(s));
  371. }
  372. }
  373. } else {
  374. builder.append(projectAttributes.get(planQuarter.getProjectAttr()));
  375. }
  376. planQuarter.setProjectAttr(builder.toString());
  377. planQuarter.setPurchaseServices(purchaseServices.get(planQuarter.getPurchaseServices()));
  378. planQuarter.setIsExcess(isExcessOrNo(planQuarter.getProjectType(), planQuarter.getEvaluation()));
  379. planQuarter.setCreated(String.valueOf(loginUser.getUserId()));
  380. planQuarter.setCreateTime(new Date());
  381. planQuarterMapper.insertPlanQuarter(planQuarter);
  382. successNum++;
  383. successMsg.append("*" + successNum + "、项目 " + planQuarter.getProjectName() + " 导入成功!");
  384. } else {
  385. failureNum++;
  386. failureMsg.append(failureNum + "*项目 " + planQuarter.getProjectName() + " 已存在!/n");
  387. }
  388. } catch (Exception exc) {
  389. failureNum++;
  390. String msg = "*" + successNum + "*项目 " + planQuarter.getProjectName() + " 导入失败";
  391. failureMsg.append(msg + exc.getMessage());
  392. log.error(msg, exc);
  393. }
  394. }
  395. if (failureNum > 0) {
  396. failureMsg.insert(0, "导入失败!共 " + failureNum + " 条数据格式不正确:");
  397. throw new ServiceException(failureMsg.toString());
  398. } else {
  399. successMsg.insert(0, "导入成功!共 " + successNum + " 条。");
  400. }
  401. return successMsg.toString();
  402. }
  403. @Override
  404. public AjaxResult commit(PlanQuarterStandardVo quarterStandardVo) {
  405. int commit = planQuarterMapper.commit(quarterStandardVo.getPlanPracticalId());
  406. if (commit != 1) {
  407. return AjaxResult.error("项目状态数据异常");
  408. }
  409. return AjaxResult.success();
  410. }
  411. @Override
  412. @Transactional
  413. public AjaxResult reviewTo(PlanQuarterStandardVo vo) {
  414. //季度计划审核通过后同步到年度计划和项目管理
  415. PlanQuarter quarters = new PlanQuarter();
  416. PmDemand demand = new PmDemand();
  417. PlanQuarter byId = planQuarterMapper.getById(vo.getPlanPracticalId());
  418. if (ObjectUtils.isEmpty(byId.getPlanYearId())) {
  419. PlanYears ofYears = new PlanYears();
  420. BeanUtils.copyProperties(byId, ofYears);
  421. ofYears.setProjectStatus(ProjectStatus.PLANTOEXAMINE.getCode());
  422. planYearsMapper.insertPlanYears(ofYears);
  423. quarters.setPlanYearId(ofYears.getPlanYearId());
  424. }
  425. demand.setEvaluation(byId.getEvaluation().doubleValue());
  426. BeanUtils.copyProperties(byId, demand);
  427. demand.setPlanId(byId.getPlanPracticalId());
  428. demand.setPurchaseDeptId(Long.valueOf(byId.getPurchaseDeptId()));
  429. //同步到项目管理状态为需求待填制
  430. demand.setProjectStatus(PmProjectStatus.DEMAND_WAIT_FILL.getCode());
  431. demand.setCreateTime(new Date());
  432. pmDemandMapper.insert(demand);
  433. //计划附件也进行同步---查询年度计划附件后复制一份改为项目需求附件
  434. LambdaQueryWrapper<SysFileRef> sysFileRefLp = new LambdaQueryWrapper<>();
  435. sysFileRefLp.eq(SysFileRef::getType, SysFileRefEnum.PLAN_YEAR.getType());
  436. sysFileRefLp.eq(SysFileRef::getRedId, vo.getPlanYearId());
  437. List<SysFileRef> sysFileRefs = sysFileRefMapper.selectList(sysFileRefLp);
  438. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  439. for (SysFileRef ref : sysFileRefs) {
  440. ref.setRedId(demand.getDemandId());
  441. ref.setType(SysFileRefEnum.PM_DEMAND.getType());
  442. ref.setId(null);
  443. sysFileRefMapper.insert(ref);
  444. }
  445. }
  446. vo.setProjectStatus(ProjectStatus.PLANTOEXAMINE.getCode());
  447. return review(vo);
  448. }
  449. @Override
  450. @Transactional
  451. public AjaxResult reviewReturn(PlanQuarterStandardVo vo) {
  452. vo.setProjectStatus(ProjectStatus.PLANTOBACK.getCode());
  453. return review(vo);
  454. }
  455. private AjaxResult review(PlanQuarterStandardVo vo) {
  456. List<SysFileRef> sysFileRefs = vo.getSysFileRefs();
  457. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  458. for (SysFileRef ref : sysFileRefs) {
  459. ref.setRedId(vo.getPlanPracticalId());
  460. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  461. ref.setCreated(vo.getUpdated());
  462. ref.setCreateTime(new Date());
  463. ref.setUpdated(vo.getUpdated());
  464. ref.setUpdateTime(new Date());
  465. sysFileRefMapper.insert(ref);
  466. }
  467. }
  468. int review = planQuarterMapper.review(vo);
  469. if (review != 1) {
  470. return AjaxResult.error("项目状态数据异常");
  471. }
  472. return AjaxResult.success();
  473. }
  474. @Override
  475. public AjaxResult appUpdate(PlanQuarterStandardVo vo) {
  476. //如果项目管理中数据已填制,则不允许申请修改
  477. LambdaQueryWrapper<PmDemand> demandLp = new LambdaQueryWrapper<>();
  478. demandLp.eq(PmDemand::getPlanId, vo.getPlanPracticalId());
  479. PmDemand demand = pmDemandMapper.selectOne(demandLp);
  480. if (!String.valueOf(demand.getProjectStatus()).equals(PmProjectStatus.DEMAND_WAIT_FILL.getCode())) {
  481. return AjaxResult.error("项目信息已填制,不可更改");
  482. }
  483. //申请后会成为未提交的状态,可以进行修改
  484. vo.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
  485. int review = planQuarterMapper.review(vo);
  486. if (review != 1) {
  487. return AjaxResult.error("项目状态数据异常");
  488. }
  489. return AjaxResult.success();
  490. }
  491. @Override
  492. public AjaxResult sendLetter(PlanQuarterStandardVo quarterStandardVo) {
  493. int review = planQuarterMapper.sendLetter(quarterStandardVo.getPlanPracticalId());
  494. if (review != 1) {
  495. return AjaxResult.error("项目状态数据异常");
  496. }
  497. return AjaxResult.success();
  498. }
  499. @Override
  500. public AjaxResult upLoadPlanFile(PlanQuarterStandardVo quarterStandardVo) {
  501. List<SysFileRef> sysFileRefs = quarterStandardVo.getSysFileRefs();
  502. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  503. for (SysFileRef ref : sysFileRefs) {
  504. ref.setRedId(quarterStandardVo.getPlanPracticalId());
  505. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  506. sysFileRefMapper.insert(ref);
  507. }
  508. }
  509. return AjaxResult.success();
  510. }
  511. @Override
  512. public AjaxResult downLoadPlanFile(PlanQuarterStandardVo quarterStandardVo) {
  513. return AjaxResult.success();
  514. }
  515. //判断是否为超额计划
  516. public String isExcessOrNo(String projectType, BigDecimal evaluation) {
  517. BigDecimal threshold = new BigDecimal(0);
  518. //获取各个项目类型设定的概算金额阈值
  519. List<SysDictData> data = dictTypeService.selectDictDataByType("sys_over_limit_threshold");
  520. HashMap<String, String> thresholdMap = new LinkedHashMap<>();
  521. //各个类型的概算金额阈值
  522. for (SysDictData dictData : data) {
  523. // 类型----阈值
  524. thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue());
  525. }
  526. //项目类型
  527. for (ProjectTypes value : ProjectTypes.values()) {
  528. if (projectType.equals(value.getCode())) {
  529. threshold = BigDecimal.valueOf(Long.parseLong(thresholdMap.get(value.getInfo())));
  530. }
  531. break;
  532. }
  533. if (evaluation.compareTo(threshold) == 1) {
  534. //是超额计划
  535. return ("1");
  536. } else {
  537. return ("0");
  538. }
  539. }
  540. //字段赋值对应的名称
  541. public List<PlanQuarterResponseVo> changeTo(List<PlanQuarter> planQuarters) {
  542. //获取季度计划各个季度提报时间的阈值
  543. List<SysDictData> supTime = dictTypeService.selectDictDataByType("sys_quarterly_plan");
  544. HashMap<String, String> thresholdMap = new LinkedHashMap<>();
  545. //各个季度提报时间的阈值
  546. for (SysDictData dictData : supTime) {
  547. // 季度----阈值
  548. thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue());
  549. } //提前或延后*天进行提醒
  550. List<SysDictData> alertTime = dictTypeService.selectDictDataByType("alert_time_setting");
  551. HashMap<String, String> alertTimeMap = new LinkedHashMap<>();
  552. //根据时间类别设定的提醒时间
  553. for (SysDictData dictData : alertTime) {
  554. // 字段名称----阈值
  555. alertTimeMap.put(dictData.getDictLabel(), dictData.getDictValue());
  556. }
  557. //获取字典数据
  558. HashMap<String, HashMap<String, String>> planEnums = dictTypeService.getAboutEnums();
  559. HashMap<String, String> projectTypesMap = planEnums.get("projectTypes");
  560. HashMap<String, String> planPurchaseModesMap = planEnums.get("planPurchaseModes");
  561. HashMap<String, String> projectAttributes = planEnums.get("projectAttributes");
  562. HashMap<String, String> purchaseServices = planEnums.get("purchaseServices");
  563. List<PlanQuarterResponseVo> list = new ArrayList<PlanQuarterResponseVo>();
  564. for (PlanQuarter planQuarter : planQuarters) {
  565. PlanQuarterResponseVo responseVo = new PlanQuarterResponseVo();
  566. SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(planQuarter.getPurchaseDeptId())).get("sysDept");
  567. planQuarter.setPurchaseDeptName(sysDeptResponseVo.getDeptName());
  568. for (Map.Entry<String, String> entry : projectTypesMap.entrySet()) {
  569. if (planQuarter.getProjectType().equals(entry.getValue())) {
  570. planQuarter.setProjectTypeStr(entry.getKey());
  571. break;
  572. }
  573. }
  574. for (Map.Entry<String, String> entry : planPurchaseModesMap.entrySet()) {
  575. if (planQuarter.getPurchaseMode().equals(entry.getValue())) {
  576. planQuarter.setPurchaseModeStr(entry.getKey());
  577. break;
  578. }
  579. }
  580. //项目属性是拼接的
  581. if (!ObjectUtils.isEmpty(planQuarter.getProjectAttr())) {
  582. if (planQuarter.getProjectAttr().length() > 1) {
  583. StringBuilder builder = new StringBuilder();
  584. String[] split = planQuarter.getProjectAttr().split(",");
  585. for (String s : split) {
  586. for (Map.Entry<String, String> entry : projectAttributes.entrySet()) {
  587. if (s.equals(entry.getValue())) {
  588. if (!planQuarter.getProjectAttr().endsWith(s)) {
  589. builder.append(entry.getKey() + ",");
  590. } else {
  591. builder.append(entry.getKey());
  592. }
  593. break;
  594. }
  595. }
  596. }
  597. planQuarter.setProjectAttrStr(builder.toString());
  598. } else {
  599. for (Map.Entry<String, String> entry : projectAttributes.entrySet()) {
  600. if (planQuarter.getProjectAttr().equals(entry.getValue())) {
  601. planQuarter.setProjectAttrStr(entry.getKey());
  602. break;
  603. }
  604. }
  605. }
  606. }
  607. for (Map.Entry<String, String> entry : purchaseServices.entrySet()) {
  608. if (planQuarter.getPurchaseServices().equals(entry.getValue())) {
  609. planQuarter.setPurchaseServicesStr(entry.getKey());
  610. break;
  611. }
  612. }
  613. BeanUtils.copyProperties(planQuarter, responseVo);
  614. try {
  615. responseVo.setTipsMessage(planQuarterGetTips(thresholdMap, alertTimeMap));
  616. } catch (ParseException e) {
  617. e.printStackTrace();
  618. }
  619. list.add(responseVo);
  620. }
  621. return list;
  622. }
  623. /**
  624. * 根据季度计划在各个季度提报时间的阈值进行提示
  625. *
  626. * @return
  627. */
  628. public String planQuarterGetTips(HashMap<String, String> thresholdMap, HashMap<String, String> alertTimeMap) throws ParseException {
  629. //提示信息:定义距离结束时间*天内提示
  630. int alertDay = Integer.parseInt(alertTimeMap.get("计划提报时间"));
  631. //提示信息:定义距离结束时间一周内提示
  632. Integer remindTine = 1000 * 60 * 60 * 24 * alertDay; //提示语
  633. String subTips = "";
  634. //季度提报时间的结束时间阈值
  635. Date thresholdTime = null;
  636. SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  637. Date date = new Date();
  638. for (QuarterEnum val : QuarterEnum.values()) {
  639. if (val.getInfo().contains(date.getMonth() + "")) {
  640. switch (val.getCode()) {
  641. case "1":
  642. thresholdTime = dateFormat.parse(thresholdMap.get("第一季度结束时间"));
  643. case "2":
  644. thresholdTime = dateFormat.parse(thresholdMap.get("第二季度结束时间"));
  645. case "3":
  646. thresholdTime = dateFormat.parse(thresholdMap.get("第三季度结束时间"));
  647. case "4":
  648. thresholdTime = dateFormat.parse(thresholdMap.get("第四季度结束时间"));
  649. default:
  650. }
  651. break;
  652. }
  653. }
  654. thresholdTime.setYear(date.getYear());
  655. double surplus = thresholdTime.getTime() - date.getTime();
  656. //少于一周便提醒
  657. if (surplus < remindTine && surplus > 0) {
  658. //剩余天数(向上取整)
  659. int i = new Double(Math.ceil(surplus / 1000 / 60 / 60 / 24)).intValue();
  660. if (i > 0) {
  661. subTips = "距离计划提报时间不足" + i + "天";
  662. }
  663. }
  664. return subTips;
  665. }
  666. }