From 10e11331cd81f2369f8b8b8722e42573e433c283 Mon Sep 17 00:00:00 2001 From: mg <maokecheng@163.com> Date: 星期四, 20 十月 2022 15:20:43 +0800 Subject: [PATCH] 添加消息状态字段查询。 --- ycl-common/src/main/java/com/ycl/service/depart/impl/UmsDepartServiceImpl.java | 95 ++++++++++++++++++++++------------------------- 1 files changed, 44 insertions(+), 51 deletions(-) diff --git a/ycl-common/src/main/java/com/ycl/service/depart/impl/UmsDepartServiceImpl.java b/ycl-common/src/main/java/com/ycl/service/depart/impl/UmsDepartServiceImpl.java index 0d55321..6d18845 100644 --- a/ycl-common/src/main/java/com/ycl/service/depart/impl/UmsDepartServiceImpl.java +++ b/ycl-common/src/main/java/com/ycl/service/depart/impl/UmsDepartServiceImpl.java @@ -7,21 +7,27 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ycl.dto.user.AdminDepartDTO; import com.ycl.entity.depart.UmsDepart; +import com.ycl.entity.dict.DataDictionary; import com.ycl.entity.user.UmsDepartManage; import com.ycl.enums.common.ResultCode; import com.ycl.exception.ApiException; import com.ycl.mapper.depart.UmsDepartMapper; +import com.ycl.mapper.dict.DataDictionaryMapper; +import com.ycl.service.depart.IDepartManagerService; import com.ycl.service.depart.UmsDepartService; -import com.ycl.service.user.UmsDepartManageService; import com.ycl.service.user.UmsAdminService; +import com.ycl.service.user.UmsDepartManageService; import com.ycl.utils.common.PojoUtils; import com.ycl.vo.depart.DepartVO; +import com.ycl.vo.depart.UmsDepartVO; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; +import java.time.LocalDateTime; +import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; @@ -41,6 +47,12 @@ private UmsDepartManageService umsAdminDepartService; @Resource private UmsAdminService umsAdminService; + @Resource + IDepartManagerService iDepartManagerService; + @Resource + UmsDepartService umsDepartService; + @Resource + DataDictionaryMapper dataDictionaryMapper; @Override @Transactional(rollbackFor = Exception.class) @@ -51,9 +63,14 @@ } UmsDepart depart = new UmsDepart(); BeanUtils.copyProperties(addDepartVO, depart); - if (sccgDepartMapper.insert(depart) != 1) { - throw new ApiException(ResultCode.RECORD_SAVE_FAIL); - } + depart.setStatus(Short.valueOf("1")); + umsDepartService.save(depart); + addDepartVO.getDepartManagerList() + .forEach(item -> { + item.setCreateTime(LocalDateTime.now()); + item.setDepartId(depart.getId()); + }); + iDepartManagerService.saveBatch(addDepartVO.getDepartManagerList()); } @Override @@ -69,27 +86,21 @@ @Transactional(rollbackFor = Exception.class) public void update(DepartVO.UpdateDepartVO updateDepartVO) { UmsDepart sccgDepart = this.queryByName(updateDepartVO.getDepartName()); - if (null != sccgDepart && sccgDepart.getId() != updateDepartVO.getId()) { + if (null != sccgDepart && !sccgDepart.getId().equals(updateDepartVO.getId())) { throw new ApiException(ResultCode.RECORD_ALREADY_EXISTS); } - UmsDepart depart = this.getById(updateDepartVO.getId()); + UmsDepart depart = new UmsDepart(); BeanUtils.copyProperties(updateDepartVO, depart); - List<Long> userIds = updateDepartVO.getUserIds(); - if (CollUtil.isNotEmpty(userIds)) { - Long departId = updateDepartVO.getId(); - List<UmsDepartManage> departList = umsAdminDepartService.queryByDepartId(departId); - if (CollUtil.isNotEmpty(departList)) { - umsAdminDepartService.deletedByDepartId(departId); - } - userIds.forEach(e -> { - UmsDepartManage adminDepart = new UmsDepartManage(); - adminDepart.setDepartId(departId); - adminDepart.setUserId(e); - umsAdminDepartService.save(adminDepart); - }); - } - if (sccgDepartMapper.updateById(depart) != 1) { - throw new ApiException(ResultCode.RECORD_UPDATE_FAIL); + umsDepartService.updateById(depart); + if (updateDepartVO.getDepartManagerList().size() > 0) { + iDepartManagerService.deleteByDepartId(depart.getId()); + + updateDepartVO.getDepartManagerList() + .forEach(item -> { + item.setCreateTime(LocalDateTime.now()); + item.setDepartId(depart.getId()); + }); + iDepartManagerService.saveBatch(updateDepartVO.getDepartManagerList()); } } @@ -105,7 +116,7 @@ @Override public List<UmsDepart> tree() { // 1.鏌ュ嚭鎵�鏈夌綉鏍� - List<UmsDepart> list = list(); + List<UmsDepart> list = baseMapper.selectDepartList(); // 2.缁勮鎴愮埗瀛愮殑鏍戝瀷缁撴瀯 // 2.1銆佹壘鍒版墍鏈夌殑涓�绾х綉鏍�:浣跨敤jdk8鐨剆tream娴佽繘琛岃繃婊� @@ -122,34 +133,16 @@ } @Override - public IPage<UmsDepart> pageDepart(DepartVO.PageDepartVO params) { - Page<UmsDepart> page = new Page<>(params.getCurrent(), params.getPageSize()); - LambdaQueryWrapper<UmsDepart> query = new LambdaQueryWrapper<>(); - if (StringUtils.isNotBlank(params.getDepartName())) { - query.like(UmsDepart::getDepartName, params.getDepartName()); - } - if (PojoUtils.Vo.isUsefulSearchParam(params.getDepartType())) { - query.like(UmsDepart::getDepartType, params.getDepartType()); - } - query.orderByDesc(UmsDepart::getCreateTime); - Page<UmsDepart> departPage = sccgDepartMapper.selectPage(page, query); - List<UmsDepart> records = departPage.getRecords(); - //璐熻矗浜� - if (CollUtil.isNotEmpty(records)) { - for (UmsDepart record : records) { - List<UmsDepartManage> umsAdminDeparts = umsAdminDepartService.queryByDepartId(record.getId()); - if (CollUtil.isNotEmpty(umsAdminDeparts)) { - List<AdminDepartDTO.UserInfoDTO> userInfoDTOS = umsAdminDeparts.stream().map(a -> { - AdminDepartDTO.UserInfoDTO userInfoDTO = new AdminDepartDTO.UserInfoDTO(); - userInfoDTO.setUserId(a.getUserId()); - userInfoDTO.setUsername(umsAdminService.getById(a.getUserId()).getUsername()); - return userInfoDTO; - }).collect(Collectors.toList()); - record.setUserInfoDTOS(userInfoDTOS); - } - } - } - return departPage; + public IPage<UmsDepartVO> pageDepart(String departName, IPage<UmsDepartVO> page) { + + List<UmsDepartVO> ls = sccgDepartMapper.selectPageByName(departName, page.offset(), page.getSize()); + LambdaQueryWrapper<UmsDepart> queryWrapper = new LambdaQueryWrapper<UmsDepart>() + .like(StringUtils.isNotEmpty(departName), UmsDepart::getDepartName, departName); + long total = this.count(queryWrapper); + + page.setRecords(ls); + page.setTotal(total); + return page; } @Override -- Gitblit v1.8.0