TaskDetailsServiceImpl.java 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445
  1. package com.goafanti.techproject.service.impl;
  2. import com.goafanti.common.bo.Result;
  3. import com.goafanti.common.dao.*;
  4. import com.goafanti.common.model.*;
  5. import com.goafanti.common.utils.excel.NewExcelUtil;
  6. import com.goafanti.core.mybatis.BaseMybatisDao;
  7. import com.goafanti.core.mybatis.page.Pagination;
  8. import com.goafanti.core.shiro.token.TokenManager;
  9. import com.goafanti.order.bo.TOrderTaskBo;
  10. import com.goafanti.techproject.bo.OutTaskDetailsBo;
  11. import com.goafanti.techproject.bo.TaskDetailsBo;
  12. import com.goafanti.techproject.service.TaskDetailsService;
  13. import org.springframework.beans.BeanUtils;
  14. import org.springframework.beans.factory.annotation.Value;
  15. import org.springframework.stereotype.Service;
  16. import javax.annotation.Resource;
  17. import java.math.BigDecimal;
  18. import java.math.RoundingMode;
  19. import java.util.*;
  20. import java.util.stream.Collectors;
  21. /**
  22. * 项目申报详情(TaskDetails)表服务实现类
  23. *
  24. * @author makejava
  25. * @since 2024-12-26 17:11:50
  26. */
  27. @Service("taskDetailsService")
  28. public class TaskDetailsServiceImpl extends BaseMybatisDao<TaskDetailsMapper> implements TaskDetailsService {
  29. @Resource
  30. private TaskDetailsMapper taskDetailsMapper;
  31. @Resource
  32. private TaskDetailsLogMapper taskDetailsLogMapper;
  33. @Resource
  34. private TOrderNewMapper tOrderNewMapper;
  35. @Resource
  36. private TOrderMidMapper tOrderMidMapper;
  37. @Resource
  38. private TOrderTaskMapper tOrderTaskMapper;
  39. @Resource
  40. private TaskFeatureMapper taskFeatureMapper;
  41. @Resource
  42. private TaskFeatureLogMapper taskFeatureLogMapper;
  43. @Value(value = "${upload.path}")
  44. private final String uploadPath = null;
  45. @Override
  46. public Pagination<TaskDetails> list(TaskDetails taskDetails, Integer pageNo, Integer pageSize) {
  47. Map<String, Object> params = new HashMap<>();
  48. params.put("in", taskDetails);
  49. return (Pagination<TaskDetails>) findPage("findTaskDetailsList",
  50. "findTaskDetailsCount", params, pageNo, pageSize);
  51. }
  52. @Override
  53. public TaskDetailsBo pushByTid(Integer id) {
  54. TaskDetailsBo res = new TaskDetailsBo();
  55. TOrderNew tOrderNew = tOrderNewMapper.selectByTid(id);
  56. TOrderTask tOrderTask = tOrderTaskMapper.queryById(id);
  57. TOrderMid mid = tOrderMidMapper.selectByOrderNo(tOrderNew.getOrderNo());
  58. List<Map<String,Object >> list=new ArrayList<>();
  59. TaskDetails taskDetails=null;
  60. //获取项目服务年份算出平均值
  61. List<TOrderTaskBo> tOrderTaskBos = tOrderTaskMapper.selectOrderTaskAll(tOrderNew.getOrderNo(), null);
  62. List<TOrderTaskBo> collect = tOrderTaskBos.stream().filter(e -> e.getSplitStatus() == 1).collect(Collectors.toList());
  63. List<TOrderTaskBo> collect2 = tOrderTaskBos.stream().filter(e -> e.getSplitStatus() == 0||e.getSplitStatus() == 2).collect(Collectors.toList());
  64. int yearSum=1;
  65. for (TOrderTaskBo e : collect) {
  66. if (e.getYearSum()>yearSum){
  67. yearSum=e.getYearSum();
  68. }
  69. }
  70. if (tOrderTask.getProgressTid()==null){
  71. taskDetails=taskDetailsMapper.selectByTid(id);
  72. //首先直接查找,找不到的情况下找订单
  73. //如果是会员
  74. TOrderTaskBo thisTask = null;
  75. for (TOrderTaskBo e : collect2) {
  76. if (e.getId().equals(id)){
  77. thisTask=e;
  78. break;
  79. }
  80. }
  81. String serviceYear = thisTask.getServiceYear();
  82. if (serviceYear.contains("(赠)")){
  83. serviceYear=serviceYear.replace("(赠)", "");
  84. }
  85. Integer tid=null;
  86. for (TOrderTaskBo e : collect2) {
  87. e.getServiceLife();
  88. if (e.getServiceYear().equals(serviceYear)){
  89. Map<String,Object> map=new HashMap<>();
  90. map.put("serviceYear", e.getServiceYear());
  91. map.put("taskName", e.getCommodityName());
  92. map.put("id",e.getId());
  93. //如果没有项目进度,查询同年份的项目进度
  94. if (taskDetails==null&&!e.getId().equals(id)&&e.getcSort()==6){
  95. taskDetails=taskDetailsMapper.selectByTid(e.getId());
  96. tid=e.getId();
  97. }
  98. list.add(map);
  99. }
  100. }
  101. if (taskDetails !=null){
  102. BeanUtils.copyProperties(taskDetails, res);
  103. }
  104. res.setUserName(mid.getBuyerName());
  105. res.setOrderNo(tOrderNew.getOrderNo());
  106. res.setContractNo(tOrderNew.getContractNo());
  107. res.setMemberStatus(mid.getProjectType());
  108. res.setTaskList(list);
  109. BigDecimal totalAmount = tOrderNew.getTotalAmount().divide(new BigDecimal(yearSum), 2, RoundingMode.HALF_UP);
  110. String lvl=null;
  111. if (totalAmount.compareTo(new BigDecimal("3"))<0){
  112. lvl="A";
  113. }else if (totalAmount.compareTo(new BigDecimal("8"))<1){
  114. lvl="AA";
  115. }else if (totalAmount.compareTo(new BigDecimal("8"))>0){
  116. lvl="AAA";
  117. }
  118. res.setMemberLvl(lvl);
  119. res.setTaskList(list);
  120. res.setFeatureList(taskFeatureMapper.selectByTdId(id));
  121. if (tid==null){
  122. tid=taskDetails.getTid();
  123. TOrderTask update =new TOrderTask();
  124. update.setId(id);
  125. update.setProgressTid(tid);
  126. tOrderTaskMapper.update(update);
  127. }
  128. }else {
  129. taskDetails=taskDetailsMapper.selectByTid(tOrderTask.getProgressTid());
  130. //如果是会员
  131. TOrderTaskBo thisTask = null;
  132. for (TOrderTaskBo e : collect2) {
  133. if (e.getId().equals(id)){
  134. thisTask=e;
  135. break;
  136. }
  137. }
  138. String serviceYear = thisTask.getServiceYear();
  139. if (serviceYear.contains("(赠)")){
  140. serviceYear=serviceYear.replace("(赠)", "");
  141. }
  142. Integer tid=null;
  143. for (TOrderTaskBo e : collect2) {
  144. if (e.getServiceYear().equals(serviceYear)){
  145. Map<String,Object> map=new HashMap<>();
  146. map.put("serviceYear", e.getServiceYear());
  147. map.put("taskName", e.getCommodityName());
  148. map.put("id",e.getId());
  149. list.add(map);
  150. }
  151. }
  152. if (taskDetails !=null){
  153. BeanUtils.copyProperties(taskDetails, res);
  154. }
  155. res.setUserName(mid.getBuyerName());
  156. res.setOrderNo(tOrderNew.getOrderNo());
  157. res.setContractNo(tOrderNew.getContractNo());
  158. res.setMemberStatus(mid.getProjectType());
  159. res.setTaskList(list);
  160. BigDecimal totalAmount = tOrderNew.getTotalAmount().divide(new BigDecimal(yearSum), 2, RoundingMode.HALF_UP);
  161. String lvl=null;
  162. if (totalAmount.compareTo(new BigDecimal("3"))<0){
  163. lvl="A";
  164. }else if (totalAmount.compareTo(new BigDecimal("8"))<1){
  165. lvl="AA";
  166. }else if (totalAmount.compareTo(new BigDecimal("8"))>0){
  167. lvl="AAA";
  168. }
  169. res.setMemberLvl(lvl);
  170. res.setTaskList(list);
  171. res.setFeatureList(taskFeatureMapper.selectByTdId(id));
  172. }
  173. return res;
  174. }
  175. /**
  176. * 通过ID查询单条数据
  177. *
  178. * @param id 主键
  179. * @return 实例对象
  180. */
  181. @Override
  182. public TaskDetails queryById(Integer id) {
  183. return this.taskDetailsMapper.selectById(id);
  184. }
  185. /**
  186. * 新增数据
  187. *
  188. * @param taskDetails 实例对象
  189. * @return 实例对象
  190. */
  191. @Override
  192. public TaskDetails insert(TaskDetails taskDetails,Integer type) {
  193. if (type ==null)type=0;
  194. Date date = new Date();
  195. TOrderNew tOrderNew =tOrderNewMapper.selectByTid(taskDetails.getTid());
  196. taskDetails.setUid(tOrderNew.getBuyerId());
  197. taskDetails.setCreateTime(date);
  198. taskDetails.setUpdateTime(date);
  199. //数据计算
  200. countTaskDetails(taskDetails);
  201. this.taskDetailsMapper.insert(taskDetails);
  202. //新增日志数据
  203. if (type==1){
  204. addTaskDetailsLog(taskDetails);
  205. }
  206. return taskDetails;
  207. }
  208. /**
  209. *新增的时候特殊数据可以是单传输,修改的时候可以多传
  210. *
  211. * @param taskDetails 项目进度数据
  212. *
  213. */
  214. private void addTaskDetailsLog(TaskDetails taskDetails) {
  215. Admin adminToken = TokenManager.getAdminToken();
  216. TaskDetailsLog log=new TaskDetailsLog();
  217. BeanUtils.copyProperties(taskDetails, log);
  218. log.setTdid(taskDetails.getId());
  219. log.setId(null);
  220. log.setAid(adminToken.getId());
  221. log.setAname(adminToken.getName());
  222. taskDetailsLogMapper.insert(log);
  223. List<TaskFeature> list = taskFeatureMapper.selectByTdId(taskDetails.getId());
  224. for (TaskFeature feature : list) {
  225. TaskFeatureLog tfLog = new TaskFeatureLog();
  226. BeanUtils.copyProperties(feature, tfLog);
  227. tfLog.setTdlId(log.getId());
  228. tfLog.setId(null);
  229. tfLog.setAid(adminToken.getId());
  230. tfLog.setAname(adminToken.getName());
  231. taskFeatureLogMapper.insert(tfLog);
  232. }
  233. }
  234. private void countTaskDetails(TaskDetails taskDetails) {
  235. //计算人员占比
  236. if (taskDetails.getWorkersNumber()!=null||
  237. taskDetails.getTechnologyNumber()!=null){
  238. BigDecimal wn = BigDecimal.valueOf(taskDetails.getWorkersNumber());
  239. BigDecimal tn = BigDecimal.valueOf(taskDetails.getTechnologyNumber());
  240. BigDecimal res = tn.divide(wn,4, RoundingMode.HALF_UP).multiply(new BigDecimal(100));
  241. taskDetails.setWorkersRate(res.doubleValue());
  242. }
  243. //计算研发预算完成进度 已归集研发费用总额÷年度研发预算总额X100%
  244. if (taskDetails.getActualRdAmount()!=null &&taskDetails.getRdBudget()!=null){
  245. BigDecimal multiply = taskDetails.getActualRdAmount().divide(taskDetails.getRdBudget(), 4, RoundingMode.HALF_UP).multiply(new BigDecimal(100));
  246. taskDetails.setRdCompletionProgress(multiply.doubleValue());
  247. }
  248. //计算年度研发占比
  249. //计算三年度的研发占比
  250. if (taskDetails.getRdBudget() != null && taskDetails.getRdSalesAmount() != null){
  251. BigDecimal rdBudget = taskDetails.getRdBudget();
  252. BigDecimal rdSalesAmount = taskDetails.getRdSalesAmount();
  253. BigDecimal res = rdBudget.divide(rdSalesAmount, 4, RoundingMode.HALF_UP).multiply(new BigDecimal(100));
  254. taskDetails.setRdBudgetRate(res.doubleValue());
  255. //计算三年度的研发占比
  256. if (taskDetails.getLastRdSalesAmount()!=null && taskDetails.getLastRdBudget()!=null&&
  257. taskDetails.getBeforeLastRdSalesAmount()!=null && taskDetails.getBeforeLastRdBudget()!=null){
  258. BigDecimal res2 = getBigDecimal(rdSalesAmount, rdBudget, taskDetails);
  259. taskDetails.setThreeYearsRdBudgetRate(res2.doubleValue());
  260. }
  261. }
  262. //计算实际研发占比
  263. if(taskDetails.getActualRdNumber() !=null &&
  264. taskDetails.getActualRdAmount() !=null){
  265. BigDecimal actualRdNumber = BigDecimal.valueOf(taskDetails.getActualRdNumber());
  266. BigDecimal actualRdAmount = taskDetails.getActualRdAmount();
  267. BigDecimal res3 = actualRdNumber.divide(actualRdAmount, 4, RoundingMode.HALF_UP).multiply(new BigDecimal(100));
  268. taskDetails.setActualRdRate(res3.doubleValue());
  269. if (taskDetails.getLastRdSalesAmount()!=null && taskDetails.getLastRdBudget()!=null&&
  270. taskDetails.getBeforeLastRdSalesAmount()!=null && taskDetails.getBeforeLastRdBudget()!=null){
  271. BigDecimal res4 = getBigDecimal(actualRdAmount, actualRdNumber, taskDetails);
  272. taskDetails.setThreeYearsActualRdRate(res4.doubleValue());
  273. }
  274. }
  275. //计算立项资料占比
  276. if (taskDetails.getProjectApprovalWriteNumber()!=null){
  277. BigDecimal projectApprovalWriteNumber = BigDecimal.valueOf(taskDetails.getProjectApprovalWriteNumber());
  278. BigDecimal res5 = projectApprovalWriteNumber.divide(new BigDecimal(taskDetails.getProjectApprovalNumber()), 4, RoundingMode.HALF_UP).multiply(new BigDecimal(100));
  279. taskDetails.setProjectApprovalWriteRate(res5.doubleValue());
  280. }
  281. }
  282. private BigDecimal getBigDecimal(BigDecimal rdSalesAmount, BigDecimal rdBudget, TaskDetails taskDetails) {
  283. BigDecimal threeYearsRdSalesAmount = rdSalesAmount;
  284. BigDecimal threeYearsRdBudget = rdBudget;
  285. threeYearsRdSalesAmount = threeYearsRdSalesAmount.add(taskDetails.getLastRdSalesAmount()).add(taskDetails.getBeforeLastRdSalesAmount());
  286. threeYearsRdBudget = threeYearsRdBudget.add(taskDetails.getLastRdBudget()).add(taskDetails.getBeforeLastRdBudget());
  287. return threeYearsRdBudget.divide(threeYearsRdSalesAmount, 4, RoundingMode.HALF_UP).multiply(new BigDecimal(100));
  288. }
  289. /**
  290. * 修改数据
  291. *
  292. * @param taskDetails 实例对象
  293. * @return 实例对象
  294. */
  295. @Override
  296. public TaskDetails update(TaskDetails taskDetails) {
  297. taskDetails.setUpdateTime(new Date());
  298. countTaskDetails(taskDetails);
  299. this.taskDetailsMapper.update(taskDetails);
  300. TaskDetails res = this.queryById(taskDetails.getId());
  301. addTaskDetailsLog(res);
  302. return res;
  303. }
  304. /**
  305. * 通过主键删除数据
  306. *
  307. * @param id 主键
  308. * @return 是否成功
  309. */
  310. @Override
  311. public boolean deleteById(Integer id) {
  312. this.taskDetailsMapper.deleteById(id);
  313. return true;
  314. }
  315. @Override
  316. public Result export(Integer id) {
  317. OutTaskDetailsBo res = new OutTaskDetailsBo();
  318. NewExcelUtil<OutTaskDetailsBo> excel=new NewExcelUtil<>(OutTaskDetailsBo.class);
  319. TaskDetailsBo byTid = pushByTid(id);
  320. BeanUtils.copyProperties(byTid,res);
  321. StringBuffer sb = new StringBuffer();
  322. byTid.getTaskList().forEach(e->{
  323. if (res.getServiceyear()==null){
  324. res.setServiceyear((String) e.get("serviceYear"));
  325. }
  326. sb.append(e.get("taskName")).append("; ");
  327. });
  328. res.setServiceProject(sb.toString());
  329. return excel.exportTaskDetailsExcel(res,"项目进度表",uploadPath);
  330. }
  331. @Override
  332. public boolean checkTid(TaskDetails taskDetails) {
  333. TaskDetails res = taskDetailsMapper.selectByTid(taskDetails.getTid());
  334. return res != null;
  335. }
  336. @Override
  337. public TaskFeature addFeature(TaskFeature in) {
  338. in.setCreateTime(new Date());
  339. taskFeatureMapper.insert(in);
  340. return in;
  341. }
  342. @Override
  343. public TaskFeature updateFeature(TaskFeature in) {
  344. taskFeatureMapper.update(in);
  345. return taskFeatureMapper.selectById(in.getId());
  346. }
  347. @Override
  348. public Object logList(Integer id) {
  349. return taskDetailsLogMapper.selectByTid(id);
  350. }
  351. @Override
  352. public Object logDetails(Integer id) {
  353. TaskDetailsLog log = taskDetailsLogMapper.selectById(id);
  354. TaskDetails taskDetails = taskDetailsMapper.selectById(log.getTdid());
  355. Integer tid = taskDetails.getTid();
  356. TaskDetailsBo res = new TaskDetailsBo();
  357. TOrderNew tOrderNew = tOrderNewMapper.selectByTid(tid);
  358. TOrderMid mid = tOrderMidMapper.selectByOrderNo(tOrderNew.getOrderNo());
  359. List<Map<String,Object >> list=new ArrayList<>();
  360. List<TOrderTaskBo> tOrderTaskBos = tOrderTaskMapper.selectOrderTaskAll(tOrderNew.getOrderNo(), 4);
  361. //如果是会员
  362. TOrderTaskBo thisTask = null;
  363. for (TOrderTaskBo e : tOrderTaskBos) {
  364. if (e.getId().equals(id)){
  365. thisTask=e;
  366. break;
  367. }
  368. }
  369. String serviceYear = thisTask.getServiceYear();
  370. if (serviceYear.contains("(赠)")){
  371. serviceYear=serviceYear.replace("(赠)", "");
  372. }
  373. for (TOrderTaskBo e : tOrderTaskBos) {
  374. if (e.getServiceYear().equals(serviceYear)){
  375. Map<String,Object> map=new HashMap<>();
  376. map.put("serviceYear", e.getServiceYear());
  377. map.put("taskName", e.getCommodityName());
  378. map.put("id",e.getId());
  379. list.add(map);
  380. }
  381. }
  382. if (taskDetails !=null){
  383. BeanUtils.copyProperties(log, res);
  384. }
  385. res.setUserName(mid.getBuyerName());
  386. res.setOrderNo(tOrderNew.getOrderNo());
  387. res.setContractNo(tOrderNew.getContractNo());
  388. res.setMemberStatus(mid.getProjectType());
  389. res.setTaskList(list);
  390. BigDecimal totalAmount = tOrderNew.getTotalAmount();
  391. String lvl=null;
  392. if (totalAmount.compareTo(new BigDecimal("3"))<0){
  393. lvl="A";
  394. }else if (totalAmount.compareTo(new BigDecimal("8"))<1){
  395. lvl="AA";
  396. }else if (totalAmount.compareTo(new BigDecimal("8"))>0){
  397. lvl="AAA";
  398. }
  399. res.setMemberLvl(lvl);
  400. res.setTaskList(list);
  401. res.setFeatureList(taskFeatureMapper.selectByTdId(id));
  402. return res;
  403. }
  404. @Override
  405. public Object deleteTaskFeature(Integer id) {
  406. return taskFeatureMapper.deleteById(id);
  407. }
  408. }