PlanQuarterServiceImpl.java 29 KB

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