PlanQuarterServiceImpl.java 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665
  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) {
  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. Page<PlanQuarter> page = planQuarterMapper.selectPage(new Page<PlanQuarter>(num, size, false), lw);
  183. list.addAll(page.getRecords());
  184. size = page.getRecords().size();
  185. num++;
  186. }
  187. planQuarterList = changeTo(list);
  188. } catch (Exception e) {
  189. e.printStackTrace();
  190. }
  191. return planQuarterList;
  192. }
  193. @Transactional
  194. @Override
  195. public AjaxResult insertPlanQuarter(PlanQuarterStandardVo quarterStandardVo) {
  196. if (planQuarterMapper.countProjectName(quarterStandardVo.getProjectName()) > 0) {
  197. return AjaxResult.error("该项目名称已经存在");
  198. }
  199. PlanQuarter quarters = new PlanQuarter();
  200. try {
  201. BeanUtils.copyProperties(quarterStandardVo, quarters);
  202. } catch (Exception e) {
  203. e.printStackTrace();
  204. }
  205. //判断是否为超额计划
  206. quarters.setIsExcess(isExcessOrNo(quarters.getProjectType(), quarters.getEvaluation()));
  207. quarters.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
  208. quarters.setCreateTime(new Date());
  209. planQuarterMapper.insertPlanQuarter(quarters);
  210. log.info("id:{}", quarters.getPlanPracticalId());
  211. List<SysFileRef> sysFileRefs = quarterStandardVo.getSysFileRefs();
  212. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  213. for (SysFileRef ref : sysFileRefs) {
  214. ref.setRedId(quarters.getPlanPracticalId());
  215. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  216. ref.setCreated(quarters.getCreated());
  217. ref.setCreateTime(new Date());
  218. ref.setUpdated(quarters.getCreated());
  219. ref.setUpdateTime(new Date());
  220. sysFileRefMapper.insert(ref);
  221. }
  222. }
  223. return AjaxResult.success();
  224. }
  225. @Override
  226. public AjaxResult deletePlanQuarterByIds(Long[] planIds) {
  227. planQuarterMapper.deletePlanQuarterByIds(planIds);
  228. return AjaxResult.success();
  229. }
  230. @Override
  231. public AjaxResult deletePlanQuarterById(Long planId) {
  232. planQuarterMapper.deletePlanQuarterById(planId);
  233. return AjaxResult.success();
  234. }
  235. @Override
  236. public AjaxResult view(PlanQuarterStandardVo quarterStandardVo) {
  237. PlanQuarterResponseVo responseVo = new PlanQuarterResponseVo();
  238. PlanQuarter byId = planQuarterMapper.getById(quarterStandardVo.getPlanPracticalId());
  239. if (byId == null) {
  240. return AjaxResult.error("数据查询失败");
  241. }
  242. SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(byId.getPurchaseDeptId())).get("sysDept");
  243. byId.setPurchaseDeptName(sysDeptResponseVo.getDeptName());
  244. HashMap<String, Object> map = new HashMap<>();
  245. map.put("red_id", byId.getPlanPracticalId());
  246. map.put("type", SysFileRefEnum.PLAN_TEMPORARY.getType());
  247. List<SysFileRef> fileRefs = sysFileRefMapper.selectByMap(map);
  248. List<SysFileInfo> fileInfos = new ArrayList<>();
  249. BeanUtils.copyProperties(byId, responseVo);
  250. if (!ObjectUtils.isEmpty(fileRefs)) {
  251. for (SysFileRef ref : fileRefs) {
  252. SysFileInfo fileInfo = fileService.getById(ref.getFileId());
  253. fileInfos.add(fileInfo);
  254. }
  255. responseVo.setFileInfos(fileInfos);
  256. }
  257. return AjaxResult.success(responseVo);
  258. }
  259. @Transactional
  260. @Override
  261. public AjaxResult update(PlanQuarterStandardVo quarterStandardVo) {
  262. if (planQuarterMapper.countProjectNameOther(quarterStandardVo.getProjectName(), String.valueOf(quarterStandardVo.getPlanPracticalId())) > 0) {
  263. return AjaxResult.error("该项目名称已经存在");
  264. }
  265. PlanQuarter quarters = new PlanQuarter();
  266. try {
  267. BeanUtils.copyProperties(quarterStandardVo, quarters);
  268. } catch (Exception e) {
  269. e.printStackTrace();
  270. }
  271. quarters.setIsExcess(isExcessOrNo(quarters.getProjectType(), quarters.getEvaluation()));
  272. quarters.setUpdateTime(new Date());
  273. planQuarterMapper.updateInfoById(quarters);
  274. List<SysFileRef> sysFileRefs = quarterStandardVo.getSysFileRefs();
  275. HashMap<String, Object> map = new HashMap<>();
  276. map.put("red_id", quarters.getPlanPracticalId());
  277. map.put("type", SysFileRefEnum.PLAN_TEMPORARY.getType());
  278. sysFileRefMapper.deleteByMap(map);
  279. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  280. for (SysFileRef ref : sysFileRefs) {
  281. ref.setRedId(quarters.getPlanPracticalId());
  282. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  283. ref.setCreated(quarterStandardVo.getUpdated());
  284. ref.setCreateTime(new Date());
  285. ref.setUpdated(quarterStandardVo.getUpdated());
  286. ref.setUpdateTime(new Date());
  287. sysFileRefMapper.insert(ref);
  288. }
  289. }
  290. return AjaxResult.success();
  291. }
  292. @Override
  293. public String importPlanQuarter(List<PlanQuarterStandardVo> planQuarters, boolean isUpdateSupport, LoginUser loginUser) {
  294. if (StringUtils.isNull(planQuarters) || planQuarters.size() == 0) {
  295. throw new ServiceException("导入季度计划数据不能为空!");
  296. }
  297. List<PlanQuarter> list = new ArrayList<>();
  298. for (PlanQuarterStandardVo standardVo : planQuarters) {
  299. PlanQuarter quarter = new PlanQuarter();
  300. BeanUtils.copyProperties(standardVo, quarter);
  301. quarter.setPurchaseDeptName(standardVo.getPurchaseDeptId());
  302. list.add(quarter);
  303. }
  304. HashMap<String, HashMap<String, String>> planEnums = dictTypeService.getAboutEnums();
  305. HashMap<String, String> projectTypesMap = planEnums.get("projectTypes");
  306. HashMap<String, String> planPurchaseModesMap = planEnums.get("planPurchaseModes");
  307. HashMap<String, String> projectAttributes = planEnums.get("projectAttributes");
  308. HashMap<String, String> purchaseServices = planEnums.get("purchaseServices");
  309. int successNum = 0;
  310. int failureNum = 0;
  311. StringBuilder successMsg = new StringBuilder();
  312. StringBuilder failureMsg = new StringBuilder();
  313. //deptService
  314. for (PlanQuarter planQuarter : list) {
  315. try {
  316. //验证项目名称是否重复导入
  317. //将录入信息中的值更改为要保存的数据
  318. if (planQuarterMapper.countProjectName(planQuarter.getProjectName()) == 0) {
  319. //采购单位
  320. SysDept info = deptMapper.checkDeptNameOnlyOne(planQuarter.getPurchaseDeptName());
  321. if (!ObjectUtils.isEmpty(info)) {
  322. planQuarter.setPurchaseDeptId(String.valueOf(info.getDeptId()));
  323. } else {
  324. ++failureNum;
  325. failureMsg.append("*" + failureNum + "*采购单位“" + planQuarter.getPurchaseDeptName() + "”不存在");
  326. }
  327. planQuarter.setProjectType(projectTypesMap.get(planQuarter.getProjectType()));
  328. planQuarter.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
  329. planQuarter.setPurchaseMode(planPurchaseModesMap.get(planQuarter.getPurchaseMode()));
  330. //项目属性是多选字段
  331. StringBuilder builder = new StringBuilder();
  332. if (planQuarter.getProjectAttr().contains(",")) {
  333. String[] split = planQuarter.getProjectAttr().split(",");
  334. for (String s : split) {
  335. if (!planQuarter.getProjectAttr().endsWith(s)) {
  336. builder.append(projectAttributes.get(s) + ",");
  337. } else {
  338. builder.append(projectAttributes.get(s));
  339. }
  340. }
  341. } else {
  342. builder.append(projectAttributes.get(planQuarter.getProjectAttr()));
  343. }
  344. planQuarter.setProjectAttr(builder.toString());
  345. planQuarter.setPurchaseServices(purchaseServices.get(planQuarter.getPurchaseServices()));
  346. planQuarter.setIsExcess(isExcessOrNo(planQuarter.getProjectType(), planQuarter.getEvaluation()));
  347. planQuarter.setCreated(String.valueOf(loginUser.getUserId()));
  348. planQuarter.setCreateTime(new Date());
  349. planQuarterMapper.insertPlanQuarter(planQuarter);
  350. successNum++;
  351. successMsg.append("*" + successNum + "、项目 " + planQuarter.getProjectName() + " 导入成功!");
  352. } else {
  353. failureNum++;
  354. failureMsg.append(failureNum + "*项目 " + planQuarter.getProjectName() + " 已存在!/n");
  355. }
  356. } catch (Exception exc) {
  357. failureNum++;
  358. String msg = "*" + successNum + "*项目 " + planQuarter.getProjectName() + " 导入失败";
  359. failureMsg.append(msg + exc.getMessage());
  360. log.error(msg, exc);
  361. }
  362. }
  363. if (failureNum > 0) {
  364. failureMsg.insert(0, "导入失败!共 " + failureNum + " 条数据格式不正确:");
  365. throw new ServiceException(failureMsg.toString());
  366. } else {
  367. successMsg.insert(0, "导入成功!共 " + successNum + " 条。");
  368. }
  369. return successMsg.toString();
  370. }
  371. @Override
  372. public AjaxResult commit(PlanQuarterStandardVo quarterStandardVo) {
  373. int commit = planQuarterMapper.commit(quarterStandardVo.getPlanPracticalId());
  374. if (commit != 1) {
  375. return AjaxResult.error("项目状态数据异常");
  376. }
  377. return AjaxResult.success();
  378. }
  379. @Override
  380. @Transactional
  381. public AjaxResult reviewTo(PlanQuarterStandardVo vo) {
  382. //季度计划审核通过后同步到年度计划和项目管理
  383. PlanQuarter quarters = new PlanQuarter();
  384. PmDemand demand = new PmDemand();
  385. PlanQuarter byId = planQuarterMapper.getById(vo.getPlanPracticalId());
  386. if (ObjectUtils.isEmpty(byId.getPlanYearId())) {
  387. PlanYears ofYears = new PlanYears();
  388. BeanUtils.copyProperties(byId, ofYears);
  389. ofYears.setProjectStatus(ProjectStatus.PLANTOEXAMINE.getCode());
  390. planYearsMapper.insertPlanYears(ofYears);
  391. quarters.setPlanYearId(ofYears.getPlanYearId());
  392. }
  393. demand.setEvaluation(byId.getEvaluation().doubleValue());
  394. BeanUtils.copyProperties(byId, demand);
  395. demand.setPlanId(byId.getPlanPracticalId());
  396. demand.setPurchaseDeptId(Long.valueOf(byId.getPurchaseDeptId()));
  397. //同步到项目管理状态为需求待填制
  398. demand.setProjectStatus(PmProjectStatus.DEMAND_WAIT_FILL.getCode());
  399. demand.setCreateTime(new Date());
  400. pmDemandMapper.insert(demand);
  401. //计划附件也进行同步---查询年度计划附件后复制一份改为项目需求附件
  402. LambdaQueryWrapper<SysFileRef> sysFileRefLp = new LambdaQueryWrapper<>();
  403. sysFileRefLp.eq(SysFileRef::getType, SysFileRefEnum.PLAN_YEAR.getType());
  404. sysFileRefLp.eq(SysFileRef::getRedId, vo.getPlanYearId());
  405. List<SysFileRef> sysFileRefs = sysFileRefMapper.selectList(sysFileRefLp);
  406. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  407. for (SysFileRef ref : sysFileRefs) {
  408. ref.setRedId(demand.getDemandId());
  409. ref.setType(SysFileRefEnum.PM_DEMAND.getType());
  410. sysFileRefMapper.insert(ref);
  411. }
  412. }
  413. vo.setProjectStatus(ProjectStatus.PLANTOEXAMINE.getCode());
  414. return review(vo);
  415. }
  416. @Override
  417. @Transactional
  418. public AjaxResult reviewReturn(PlanQuarterStandardVo vo) {
  419. vo.setProjectStatus(ProjectStatus.PLANTOBACK.getCode());
  420. return review(vo);
  421. }
  422. private AjaxResult review(PlanQuarterStandardVo vo) {
  423. List<SysFileRef> sysFileRefs = vo.getSysFileRefs();
  424. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  425. for (SysFileRef ref : sysFileRefs) {
  426. ref.setRedId(vo.getPlanPracticalId());
  427. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  428. ref.setCreated(vo.getUpdated());
  429. ref.setCreateTime(new Date());
  430. ref.setUpdated(vo.getUpdated());
  431. ref.setUpdateTime(new Date());
  432. sysFileRefMapper.insert(ref);
  433. }
  434. }
  435. int review = planQuarterMapper.review(vo);
  436. if (review != 1) {
  437. return AjaxResult.error("项目状态数据异常");
  438. }
  439. return AjaxResult.success();
  440. }
  441. @Override
  442. public AjaxResult appUpdate(PlanQuarterStandardVo vo) {
  443. //如果项目管理中数据已填制,则不允许申请修改
  444. LambdaQueryWrapper<PmDemand> demandLp = new LambdaQueryWrapper<>();
  445. demandLp.eq(PmDemand::getPlanId, vo.getPlanPracticalId());
  446. PmDemand demand = pmDemandMapper.selectOne(demandLp);
  447. if (!String.valueOf(demand.getProjectStatus()).equals(PmProjectStatus.DEMAND_WAIT_FILL.getCode())) {
  448. return AjaxResult.error("项目信息已填制,不可更改");
  449. }
  450. //申请后会成为未提交的状态,可以进行修改
  451. vo.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
  452. int review = planQuarterMapper.review(vo);
  453. if (review != 1) {
  454. return AjaxResult.error("项目状态数据异常");
  455. }
  456. return AjaxResult.success();
  457. }
  458. @Override
  459. public AjaxResult sendLetter(PlanQuarterStandardVo quarterStandardVo) {
  460. int review = planQuarterMapper.sendLetter(quarterStandardVo.getPlanPracticalId());
  461. if (review != 1) {
  462. return AjaxResult.error("项目状态数据异常");
  463. }
  464. return AjaxResult.success();
  465. }
  466. @Override
  467. public AjaxResult upLoadPlanFile(PlanQuarterStandardVo quarterStandardVo) {
  468. List<SysFileRef> sysFileRefs = quarterStandardVo.getSysFileRefs();
  469. if (!ObjectUtils.isEmpty(sysFileRefs)) {
  470. for (SysFileRef ref : sysFileRefs) {
  471. ref.setRedId(quarterStandardVo.getPlanPracticalId());
  472. ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
  473. sysFileRefMapper.insert(ref);
  474. }
  475. }
  476. return AjaxResult.success();
  477. }
  478. @Override
  479. public AjaxResult downLoadPlanFile(PlanQuarterStandardVo quarterStandardVo) {
  480. return AjaxResult.success();
  481. }
  482. //判断是否为超额计划
  483. public String isExcessOrNo(String projectType, BigDecimal evaluation) {
  484. BigDecimal threshold = new BigDecimal(0);
  485. //获取各个项目类型设定的概算金额阈值
  486. List<SysDictData> data = dictTypeService.selectDictDataByType("sys_over_limit_threshold");
  487. HashMap<String, String> thresholdMap = new LinkedHashMap<>();
  488. //各个类型的概算金额阈值
  489. for (SysDictData dictData : data) {
  490. // 类型----阈值
  491. thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue());
  492. }
  493. //项目类型
  494. for (ProjectTypes value : ProjectTypes.values()) {
  495. if (projectType.equals(value.getCode())) {
  496. threshold = BigDecimal.valueOf(Long.parseLong(thresholdMap.get(value.getInfo())));
  497. }
  498. break;
  499. }
  500. if (evaluation.compareTo(threshold) == 1) {
  501. //是超额计划
  502. return ("1");
  503. } else {
  504. return ("0");
  505. }
  506. }
  507. //字段赋值对应的名称
  508. public List<PlanQuarterResponseVo> changeTo(List<PlanQuarter> planQuarters) {
  509. //获取季度计划各个季度提报时间的阈值
  510. List<SysDictData> supTime = dictTypeService.selectDictDataByType("sys_quarterly_plan");
  511. HashMap<String, String> thresholdMap = new LinkedHashMap<>();
  512. //各个季度提报时间的阈值
  513. for (SysDictData dictData : supTime) {
  514. // 季度----阈值
  515. thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue());
  516. } //提前或延后*天进行提醒
  517. List<SysDictData> alertTime = dictTypeService.selectDictDataByType("alert_time_setting");
  518. HashMap<String, String> alertTimeMap = new LinkedHashMap<>();
  519. //根据时间类别设定的提醒时间
  520. for (SysDictData dictData : alertTime) {
  521. // 字段名称----阈值
  522. alertTimeMap.put(dictData.getDictLabel(), dictData.getDictValue());
  523. }
  524. //获取字典数据
  525. HashMap<String, HashMap<String, String>> planEnums = dictTypeService.getAboutEnums();
  526. HashMap<String, String> projectTypesMap = planEnums.get("projectTypes");
  527. HashMap<String, String> planPurchaseModesMap = planEnums.get("planPurchaseModes");
  528. HashMap<String, String> projectAttributes = planEnums.get("projectAttributes");
  529. HashMap<String, String> purchaseServices = planEnums.get("purchaseServices");
  530. List<PlanQuarterResponseVo> list = new ArrayList<PlanQuarterResponseVo>();
  531. for (PlanQuarter planQuarter : planQuarters) {
  532. PlanQuarterResponseVo responseVo = new PlanQuarterResponseVo();
  533. SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(planQuarter.getPurchaseDeptId())).get("sysDept");
  534. planQuarter.setPurchaseDeptName(sysDeptResponseVo.getDeptName());
  535. for (Map.Entry<String, String> entry : projectTypesMap.entrySet()) {
  536. if (planQuarter.getProjectType().equals(entry.getValue())) {
  537. planQuarter.setProjectTypeStr(entry.getKey());
  538. break;
  539. }
  540. }
  541. for (Map.Entry<String, String> entry : planPurchaseModesMap.entrySet()) {
  542. if (planQuarter.getPurchaseMode().equals(entry.getValue())) {
  543. planQuarter.setPurchaseModeStr(entry.getKey());
  544. break;
  545. }
  546. }
  547. //项目属性是拼接的
  548. if (!ObjectUtils.isEmpty(planQuarter.getProjectAttr())) {
  549. if (planQuarter.getProjectAttr().length() > 1) {
  550. StringBuilder builder = new StringBuilder();
  551. String[] split = planQuarter.getProjectAttr().split(",");
  552. for (String s : split) {
  553. for (Map.Entry<String, String> entry : projectAttributes.entrySet()) {
  554. if (s.equals(entry.getValue())) {
  555. if (!planQuarter.getProjectAttr().endsWith(s)) {
  556. builder.append(entry.getKey() + ",");
  557. } else {
  558. builder.append(entry.getKey());
  559. }
  560. break;
  561. }
  562. }
  563. }
  564. planQuarter.setProjectAttrStr(builder.toString());
  565. } else {
  566. for (Map.Entry<String, String> entry : projectAttributes.entrySet()) {
  567. if (planQuarter.getProjectAttr().equals(entry.getValue())) {
  568. planQuarter.setProjectAttrStr(entry.getKey());
  569. break;
  570. }
  571. }
  572. }
  573. }
  574. for (Map.Entry<String, String> entry : purchaseServices.entrySet()) {
  575. if (planQuarter.getPurchaseServices().equals(entry.getValue())) {
  576. planQuarter.setPurchaseServicesStr(entry.getKey());
  577. break;
  578. }
  579. }
  580. BeanUtils.copyProperties(planQuarter, responseVo);
  581. try {
  582. responseVo.setTipsMessage(planQuarterGetTips(thresholdMap, alertTimeMap));
  583. } catch (ParseException e) {
  584. e.printStackTrace();
  585. }
  586. list.add(responseVo);
  587. }
  588. return list;
  589. }
  590. /**
  591. * 根据季度计划在各个季度提报时间的阈值进行提示
  592. *
  593. * @return
  594. */
  595. public String planQuarterGetTips(HashMap<String, String> thresholdMap, HashMap<String, String> alertTimeMap) throws ParseException {
  596. //提示信息:定义距离结束时间*天内提示
  597. int alertDay = Integer.parseInt(alertTimeMap.get("计划提报时间"));
  598. //提示信息:定义距离结束时间一周内提示
  599. Integer remindTine = 1000 * 60 * 60 * 24 * alertDay; //提示语
  600. String subTips = "";
  601. //季度提报时间的结束时间阈值
  602. Date thresholdTime = null;
  603. SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  604. Date date = new Date();
  605. for (QuarterEnum val : QuarterEnum.values()) {
  606. if (val.getInfo().contains(date.getMonth() + "")) {
  607. switch (val.getCode()) {
  608. case "1":
  609. thresholdTime = dateFormat.parse(thresholdMap.get("第一季度结束时间"));
  610. case "2":
  611. thresholdTime = dateFormat.parse(thresholdMap.get("第二季度结束时间"));
  612. case "3":
  613. thresholdTime = dateFormat.parse(thresholdMap.get("第三季度结束时间"));
  614. case "4":
  615. thresholdTime = dateFormat.parse(thresholdMap.get("第四季度结束时间"));
  616. default:
  617. }
  618. break;
  619. }
  620. }
  621. thresholdTime.setYear(date.getYear());
  622. double surplus = thresholdTime.getTime() - date.getTime();
  623. //少于一周便提醒
  624. if (surplus < remindTine && surplus > 0) {
  625. //剩余天数(向上取整)
  626. int i = new Double(Math.ceil(surplus / 1000 / 60 / 60 / 24)).intValue();
  627. if (i > 0) {
  628. subTips = "距离计划提报时间不足" + i + "天";
  629. }
  630. }
  631. return subTips;
  632. }
  633. }