ResponsibilityServiceImpl.java 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442
  1. package com.imed.costaccount.service.impl;
  2. import cn.hutool.core.collection.CollUtil;
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  5. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  6. import com.imed.costaccount.common.exception.CostException;
  7. import com.imed.costaccount.constants.NumberConstant;
  8. import com.imed.costaccount.enums.ErrorCodeEnum;
  9. import com.imed.costaccount.mapper.ResponsibilityMapper;
  10. import com.imed.costaccount.model.Responsibility;
  11. import com.imed.costaccount.model.User;
  12. import com.imed.costaccount.model.dto.ResponsibilityEditDTO;
  13. import com.imed.costaccount.model.dto.ResponsibilitySaveDTO;
  14. import com.imed.costaccount.model.vo.*;
  15. import com.imed.costaccount.service.ResponsibilityService;
  16. import com.imed.costaccount.utils.BeanUtil;
  17. import lombok.extern.slf4j.Slf4j;
  18. import org.springframework.stereotype.Service;
  19. import org.springframework.transaction.annotation.Propagation;
  20. import org.springframework.transaction.annotation.Transactional;
  21. import org.springframework.util.CollectionUtils;
  22. import java.util.*;
  23. import java.util.stream.Collectors;
  24. @Slf4j
  25. @Service("responsibilityService")
  26. public class ResponsibilityServiceImpl extends ServiceImpl<ResponsibilityMapper, Responsibility> implements ResponsibilityService {
  27. private final CostShareLevelServiceImpl costShareLevelService;
  28. public ResponsibilityServiceImpl(CostShareLevelServiceImpl costShareLevelService) {
  29. this.costShareLevelService = costShareLevelService;
  30. }
  31. /**
  32. * 责任中心列表不分页
  33. *
  34. * @param user
  35. * @return
  36. */
  37. @Override
  38. public List<CostResponsibilityVO> getList(User user) {
  39. // 1. 获取所有的列表然后组装
  40. List<Responsibility> list = this.list(
  41. new LambdaQueryWrapper<Responsibility>()
  42. .eq(Responsibility::getHospId, user.getHospId())
  43. .orderByDesc(Responsibility::getCreateTime)
  44. );
  45. if (CollUtil.isEmpty(list)) {
  46. return Collections.emptyList();
  47. }
  48. // 拷贝组合
  49. List<CostResponsibilityVO> costResponsibilityVOS = BeanUtil.convertList(list, CostResponsibilityVO.class);
  50. List<CostResponsibilityVO> parentCostResponsibility = costResponsibilityVOS.stream()
  51. .filter(i -> i.getResponsibilityLevel().equals(1)).collect(Collectors.toList());
  52. parentCostResponsibility.forEach(i -> costResponsibilityVOS.forEach(j -> {
  53. if (j.getParentId().equals(i.getId())) {
  54. if (i.getResponsibilityLevel() == 1) {
  55. i.setShareLevel(null);
  56. }
  57. List<CostResponsibilityVO> child = i.getChild();
  58. if (CollUtil.isEmpty(child)) {
  59. child = new ArrayList<>();
  60. }
  61. child.add(j);
  62. i.setChild(child);
  63. }
  64. }));
  65. return parentCostResponsibility;
  66. }
  67. /**
  68. * 新增责任中心
  69. *
  70. * @param responsibilitySaveDTO {@link ResponsibilitySaveDTO }
  71. * @param user
  72. */
  73. @Override
  74. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  75. public void addResponsibilityCenter(ResponsibilitySaveDTO responsibilitySaveDTO, User user) {
  76. // 如果是一级分类parentId为0
  77. Long id = responsibilitySaveDTO.getId();
  78. if (Objects.isNull(id)) {
  79. id = 0L;
  80. }
  81. checkCode(responsibilitySaveDTO.getResponsibilityCode(), user.getHospId());
  82. Responsibility center = BeanUtil.convertObj(responsibilitySaveDTO, Responsibility.class);
  83. center.setCreateTime(System.currentTimeMillis()).setId(null).setParentId(id).setHospId(user.getHospId()).setResponsibilityLevel(2);
  84. if (id == 0) {
  85. center.setResponsibilityLevel(1);
  86. }
  87. // 如果是汇总中心,那么不存在分摊级别
  88. Integer isGatherCenter = responsibilitySaveDTO.getIsGatherCenter();
  89. if (isGatherCenter == 1) {
  90. center.setShareLevel(0);
  91. center.setShareName("");
  92. }
  93. // 父节点不允许为非汇总中心
  94. Responsibility byId = this.getById(id);
  95. if (Objects.nonNull(byId) && (byId.getIsGatherCenter() == 2)) {
  96. throw new CostException(500, "非汇总中心不允许添加");
  97. }
  98. if (responsibilitySaveDTO.getIsGatherCenter() == 1) {
  99. throw new CostException(500, "子层级暂不允许为非汇总中心");
  100. }
  101. this.save(center);
  102. }
  103. private void checkCode(String code, Long hospId) {
  104. // 校验责任代码唯一性
  105. Responsibility one = this.getOne(
  106. new LambdaQueryWrapper<Responsibility>().select(Responsibility::getId)
  107. .eq(Responsibility::getResponsibilityCode, code)
  108. .eq(Responsibility::getHospId, hospId).last("limit 1")
  109. );
  110. if (Objects.nonNull(one)) {
  111. throw new CostException(ErrorCodeEnum.RESPONSIBILITY_CODE_EXIST);
  112. }
  113. }
  114. /**
  115. * 编辑责任中心
  116. *
  117. * @param responsibilityEditDTO {@link ResponsibilityEditDTO}
  118. * @param user
  119. */
  120. @Override
  121. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  122. public void editResponsibility(ResponsibilityEditDTO responsibilityEditDTO, User user) {
  123. Long id = responsibilityEditDTO.getId();
  124. Responsibility center = this.getById(id);
  125. if (Objects.isNull(center)) {
  126. throw new CostException(ErrorCodeEnum.DATA_NOT_EXIST);
  127. }
  128. // 判断是否有子节点
  129. List<Responsibility> list = this.list(
  130. new LambdaQueryWrapper<Responsibility>()
  131. .eq(Responsibility::getHospId, user.getHospId())
  132. .eq(Responsibility::getParentId, id)
  133. );
  134. // 如果不存在子节点 ,修改它本身
  135. if (list.isEmpty()) {
  136. this.updateCurResp(center, responsibilityEditDTO, user);
  137. return ;
  138. }
  139. this.updateParent(responsibilityEditDTO, center, user.getHospId());
  140. // // 不管是哪个绑定到父级目录下
  141. //// if (responsibilityEditDTO.getParentId() == 0) {
  142. ////
  143. //// }
  144. ////
  145. ////
  146. //// // 如果修改父节点节点(只有两层的情况)
  147. // if (center.getResponsibilityLevel() == 1) {
  148. // this.updateParent(responsibilityEditDTO, center, user.getHospId());
  149. // return;
  150. // }
  151. // this.updateCurrent(responsibilityEditDTO, center, user.getHospId());
  152. }
  153. @Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
  154. public void updateAllResp(Responsibility center, ResponsibilityEditDTO dto, User user, List<Responsibility> list) {
  155. // 删除原有的父节点数据
  156. Long id = dto.getId();
  157. this.removeById(id);
  158. this.checkCode(dto.getResponsibilityCode(), user.getHospId());
  159. // 新增父节点数据
  160. Responsibility newResponsibility = BeanUtil.convertObj(dto, Responsibility.class);
  161. newResponsibility.setId(null).setHospId(user.getHospId()).setCreateTime(new Date().getTime()).setResponsibilityLevel(2);
  162. // 相关校验
  163. if (dto.getParentId() == 0) {
  164. newResponsibility.setResponsibilityLevel(1);
  165. }
  166. // 如果是汇总中心,那么不存在分摊级别
  167. Integer isGatherCenter = newResponsibility.getIsGatherCenter();
  168. if (isGatherCenter == 1) {
  169. newResponsibility.setShareId(null);
  170. newResponsibility.setShareLevel(0);
  171. newResponsibility.setShareName("");
  172. }
  173. if (Objects.nonNull(center) && (center.getIsGatherCenter() == 2)) {
  174. throw new CostException(500, "非汇总中心不允许添加");
  175. }
  176. }
  177. @Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
  178. public void updateCurResp(Responsibility center, ResponsibilityEditDTO dto, User user) {
  179. // 删除
  180. Long id = dto.getId();
  181. this.removeById(id);
  182. // 校验code
  183. this.checkCode(dto.getResponsibilityCode(), user.getHospId());
  184. Responsibility newResponsibility = BeanUtil.convertObj(dto, Responsibility.class);
  185. newResponsibility.setId(null)
  186. .setHospId(user.getHospId())
  187. .setCreateTime(System.currentTimeMillis())
  188. .setParentId(dto.getParentId())
  189. .setResponsibilityLevel(2);
  190. // 如果变成了汇总中心,那么变成第一层
  191. if (dto.getIsGatherCenter() == 1) {
  192. newResponsibility.setShareId(null)
  193. .setShareLevel(0)
  194. .setShareName(null)
  195. .setParentId(0L)
  196. .setResponsibilityLevel(1);
  197. }
  198. if (dto.getParentId() == 0) {
  199. newResponsibility.setResponsibilityLevel(1);
  200. // 永远为2的情况
  201. newResponsibility.setIsGatherCenter(2);
  202. }
  203. this.save(newResponsibility);
  204. }
  205. /**
  206. * 修的是父节点
  207. *
  208. * @param dto
  209. * @param responsibility
  210. * @param hospId
  211. */
  212. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  213. public void updateParent(ResponsibilityEditDTO dto, Responsibility responsibility, Long hospId) {
  214. // 删除原有的父节点数据
  215. Long id = dto.getId();
  216. this.removeById(id);
  217. List<Responsibility> child = this.list(new QueryWrapper<Responsibility>().lambda().eq(Responsibility::getParentId, id));
  218. // 如果修改是否汇总中心 从是 -> 否那么子节点直接删除
  219. if (responsibility.getIsGatherCenter() == 1 && dto.getIsGatherCenter() == 2) {
  220. this.removeByIds(child.stream().map(Responsibility::getId).collect(Collectors.toList()));
  221. // return;
  222. }
  223. this.checkCode(dto.getResponsibilityCode(), hospId);
  224. // 新增父节点数据
  225. Responsibility newResponsibility = BeanUtil.convertObj(dto, Responsibility.class);
  226. newResponsibility.setId(null).setHospId(responsibility.getHospId()).setCreateTime(new Date().getTime()).setResponsibilityLevel(2);
  227. // 相关校验
  228. if (dto.getParentId() == 0) {
  229. newResponsibility.setResponsibilityLevel(1);
  230. }
  231. // 如果是汇总中心,那么不存在分摊级别
  232. Integer isGatherCenter = newResponsibility.getIsGatherCenter();
  233. if (isGatherCenter == 1) {
  234. newResponsibility.setShareId(null);
  235. newResponsibility.setShareLevel(0);
  236. newResponsibility.setShareName("");
  237. }
  238. // 父节点不允许为非汇总中心
  239. Responsibility byId = this.getById(id);
  240. if (Objects.nonNull(byId) && (byId.getIsGatherCenter() == 2)) {
  241. throw new CostException(500, "非汇总中心不允许添加");
  242. }
  243. this.save(newResponsibility);
  244. // 将原来所有父节点下数据关联到新的父节点下
  245. child.forEach(i -> {
  246. i.setParentId(newResponsibility.getId());
  247. i.setIsGatherCenter(2);
  248. });
  249. this.updateBatchById(child);
  250. }
  251. /**
  252. * 修改当前的节点
  253. *
  254. * @param dto
  255. * @param responsibility
  256. * @param hospId
  257. */
  258. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  259. public void updateCurrent(ResponsibilityEditDTO dto, Responsibility responsibility, Long hospId) {
  260. // 删除原有的父节点数据
  261. Long id = dto.getId();
  262. this.removeById(id);
  263. this.checkCode(dto.getResponsibilityCode(), hospId);
  264. Responsibility newResponsibility = BeanUtil.convertObj(dto, Responsibility.class);
  265. newResponsibility.setId(null)
  266. .setHospId(responsibility.getHospId())
  267. .setCreateTime(System.currentTimeMillis())
  268. .setParentId(dto.getParentId())
  269. .setResponsibilityLevel(2);
  270. // 暂时先这样处理
  271. if (dto.getIsGatherCenter() == 1) {
  272. newResponsibility.setShareId(null)
  273. .setShareLevel(0)
  274. .setShareName(null)
  275. .setParentId(0L)
  276. .setResponsibilityLevel(1);
  277. }
  278. this.save(newResponsibility);
  279. }
  280. /**
  281. * 删除责任中心
  282. *
  283. * @param id
  284. */
  285. @Override
  286. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  287. public void deleteCenter(Integer id) {
  288. Responsibility center = this.getById(id);
  289. if (Objects.isNull(center)) {
  290. throw new CostException(ErrorCodeEnum.DATA_NOT_EXIST);
  291. }
  292. Long parentId = center.getParentId();
  293. if (parentId == 0) {
  294. this.deleteAllSonCenter(id);
  295. return;
  296. }
  297. this.removeById(id);
  298. }
  299. /**
  300. * 删除父节点以及所有子节点责任中心
  301. *
  302. * @param id
  303. */
  304. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  305. public void deleteAllSonCenter(Integer id) {
  306. this.removeById(id);
  307. this.remove(new LambdaQueryWrapper<Responsibility>().eq(Responsibility::getParentId, id));
  308. }
  309. /**
  310. * 获取部门树列表
  311. *
  312. * @param user
  313. * @return
  314. */
  315. @Override
  316. public List<CenterDepartmentVO> getParentSon(User user) {
  317. // 1. 获取所有的列表然后组装
  318. List<Responsibility> parentList = this.list(
  319. new LambdaQueryWrapper<Responsibility>()
  320. .eq(Responsibility::getHospId, user.getHospId())
  321. .eq(Responsibility::getParentId, 0)
  322. .orderByDesc(Responsibility::getCreateTime)
  323. );
  324. if (CollUtil.isEmpty(parentList)) {
  325. return Collections.emptyList();
  326. }
  327. List<Responsibility> sonList = this.list(
  328. new LambdaQueryWrapper<Responsibility>()
  329. .eq(Responsibility::getHospId, user.getHospId())
  330. .ne(Responsibility::getParentId, 0)
  331. );
  332. List<CenterDepartmentVO> list = new ArrayList<>();
  333. // 拷贝组合
  334. for (Responsibility parent : parentList) {
  335. CenterDepartmentVO centerDepartmentVO = new CenterDepartmentVO();
  336. centerDepartmentVO.setResponsibilityId(parent.getId());
  337. centerDepartmentVO.setIsGatherCenter(parent.getIsGatherCenter());
  338. centerDepartmentVO.setResponsibilityName(parent.getResponsibilityName());
  339. centerDepartmentVO.setIsParent(true);
  340. for (Responsibility son : sonList) {
  341. CenterDepartmentVO sonVO = new CenterDepartmentVO();
  342. if (parent.getId().equals(son.getParentId())) {
  343. sonVO.setResponsibilityId(son.getId());
  344. sonVO.setResponsibilityName(son.getResponsibilityName());
  345. sonVO.setIsParent(false);
  346. sonVO.setIsGatherCenter(son.getIsGatherCenter());
  347. List<CenterDepartmentVO> child = centerDepartmentVO.getChild();
  348. if (CollUtil.isEmpty(child)) {
  349. child = new ArrayList<>();
  350. }
  351. child.add(sonVO);
  352. centerDepartmentVO.setChild(child);
  353. }
  354. }
  355. list.add(centerDepartmentVO);
  356. }
  357. return list;
  358. }
  359. @Override
  360. public List<CommonVO> getParentList(User user) {
  361. List<Responsibility> list = this.list(
  362. new LambdaQueryWrapper<Responsibility>().select(Responsibility::getId, Responsibility::getResponsibilityName)
  363. .eq(Responsibility::getResponsibilityLevel, 1)
  364. .eq(Responsibility::getHospId, user.getHospId())
  365. );
  366. return list.stream().map(i -> {
  367. CommonVO commonVO = new CommonVO();
  368. commonVO.setId(i.getId());
  369. commonVO.setName(i.getResponsibilityName());
  370. return commonVO;
  371. }).collect(Collectors.toList());
  372. }
  373. /**
  374. * 获取可不是汇总中心列表
  375. *
  376. * @param hospId
  377. * @return
  378. */
  379. @Override
  380. public List<CostResponsibilityLevelVO> getLevelTwo(Long hospId) {
  381. List<Responsibility> responsibilities = baseMapper.selectList(new QueryWrapper<Responsibility>().lambda()
  382. .eq(Responsibility::getHospId, hospId)
  383. .eq(Responsibility::getIsGatherCenter, NumberConstant.TWO));
  384. List<CostResponsibilityLevelVO> costResponsibilityLevelVOS = BeanUtil.convertList(responsibilities, CostResponsibilityLevelVO.class);
  385. List<CostShareLevelVO> costShareLevelServiceAll = costShareLevelService.getAll(hospId);
  386. Map<Long, List<CostShareLevelVO>> listMap = costShareLevelServiceAll.stream().collect(Collectors.groupingBy(CostShareLevelVO::getId));
  387. // 设置责任中心的计算方式
  388. costResponsibilityLevelVOS.forEach(i -> {
  389. i.setResponsibilityId(i.getId());
  390. Long shareId = i.getShareId();
  391. List<CostShareLevelVO> costShareLevelVOList = listMap.get(shareId);
  392. if (!CollectionUtils.isEmpty(costShareLevelVOList)) {
  393. i.setCalcType(costShareLevelVOList.get(0).getCalcType());
  394. }
  395. });
  396. return costResponsibilityLevelVOS;
  397. }
  398. }