From d015cc0b48ca51a2b93b6c60c91dc352a104b1e7 Mon Sep 17 00:00:00 2001 From: kongzy <kongzy> Date: 星期一, 23 九月 2024 10:41:50 +0800 Subject: [PATCH] 删除密码加密 --- goal-manage/goal-manage-service/src/main/java/com/gkhy/safePlatform/targetDuty/service/impl/TargetMngServiceImpl.java | 181 ++++++++++++++++++++++++++++++++++++--------- 1 files changed, 145 insertions(+), 36 deletions(-) diff --git a/goal-manage/goal-manage-service/src/main/java/com/gkhy/safePlatform/targetDuty/service/impl/TargetMngServiceImpl.java b/goal-manage/goal-manage-service/src/main/java/com/gkhy/safePlatform/targetDuty/service/impl/TargetMngServiceImpl.java index 9f750da..19ecf01 100644 --- a/goal-manage/goal-manage-service/src/main/java/com/gkhy/safePlatform/targetDuty/service/impl/TargetMngServiceImpl.java +++ b/goal-manage/goal-manage-service/src/main/java/com/gkhy/safePlatform/targetDuty/service/impl/TargetMngServiceImpl.java @@ -1,36 +1,42 @@ package com.gkhy.safePlatform.targetDuty.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; -import com.baomidou.mybatisplus.core.toolkit.BeanUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.safePlatform.commons.enums.ResultCodes; import com.gkhy.safePlatform.commons.query.PageQuery; import com.gkhy.safePlatform.commons.utils.BeanCopyUtils; +import com.gkhy.safePlatform.commons.utils.PageUtils; import com.gkhy.safePlatform.commons.vo.ResultVO; import com.gkhy.safePlatform.commons.vo.SearchResultVO; import com.gkhy.safePlatform.targetDuty.entity.*; +import com.gkhy.safePlatform.targetDuty.excepiton.TargetDutyException; import com.gkhy.safePlatform.targetDuty.model.dto.req.TargetCheckAndSubmitQueryCriteria; import com.gkhy.safePlatform.targetDuty.model.dto.req.TargetDivideDetailQueryCriteria; +import com.gkhy.safePlatform.targetDuty.model.dto.req.TargetMngImportExcel; import com.gkhy.safePlatform.targetDuty.model.dto.req.TargetMngQueryCriteria; import com.gkhy.safePlatform.targetDuty.model.dto.resp.TargetCheckAndSubmitDto; import com.gkhy.safePlatform.targetDuty.model.dto.resp.TargetDivideDetailDto; import com.gkhy.safePlatform.targetDuty.model.dto.resp.TargetMngDto; -import com.gkhy.safePlatform.targetDuty.repository.*; +import com.gkhy.safePlatform.targetDuty.model.dto.resp.TargetMngExcel; import com.gkhy.safePlatform.targetDuty.service.CommonService; -import com.gkhy.safePlatform.targetDuty.service.TargetDivideDetailService; import com.gkhy.safePlatform.targetDuty.service.TargetMngService; -import com.gkhy.safePlatform.targetDuty.utils.BeanToMapUtil; +import com.gkhy.safePlatform.targetDuty.service.baseService.*; +import com.gkhy.safePlatform.targetDuty.utils.DateUtils; import com.gkhy.safePlatform.targetDuty.utils.QueryHelpPlus; +import com.gkhy.safePlatform.targetDuty.utils.poihelper.ExcelLogs; +import com.gkhy.safePlatform.targetDuty.utils.poihelper.ExcelUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; +import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; -import java.beans.IntrospectionException; +import javax.servlet.http.HttpServletResponse; +import java.io.IOException; import java.io.Serializable; -import java.lang.reflect.InvocationTargetException; +import java.net.URLEncoder; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; @@ -42,43 +48,51 @@ * @since 2022-07-20 11:49:22 */ @Service("targetMngService") -public class TargetMngServiceImpl extends ServiceImpl<TargetMngRepository, TargetMng> implements TargetMngService { +public class TargetMngServiceImpl implements TargetMngService { @Autowired - private TargetMngRepository targetMngRepository; + private TargetMngBaseService targetMngBaseService; @Resource - private TargetDivideDetailService targetDivideDetailService; - - @Autowired - private TargetDivideDetailRepository targetDivideDetailRepository; + private TargetDivideDetailBaseService targetDivideDetailBaseService; @Resource - private TargetDutyWorkApproveRepository targetDutyWorkApproveRepository; + private TargetDutyWorkApproveBaseService targetDutyWorkApproveBaseService; @Resource private CommonService commonService; @Autowired - private TargetTypeRepository targetTypeRepository; + private TargetTypeBaseService targetTypeBaseService; @Autowired - private TargetExamineRepository targetExamineRepository; + private TargetExamineBaseService targetExamineBaseService; + + @Autowired + public HttpServletResponse response; + @Override public ResultVO queryAll(PageQuery<TargetMngQueryCriteria> pageQuery) { + if(pageQuery.getSearchParams().getTargetType() == null){ + return new ResultVO<>(ResultCodes.CLIENT_PARAM_ILLEGAL,"缺少targetType"); + } + PageUtils.checkCheck(pageQuery); Long pageIndex = pageQuery.getPageIndex(); Long pageSize = pageQuery.getPageSize(); IPage<TargetMng> page = new Page<>(pageIndex, pageSize); - page = baseMapper.selectPage(page, + page = targetMngBaseService.selectPage(page, QueryHelpPlus.getPredicate(TargetMng.class, pageQuery.getSearchParams())); List<TargetMngDto> respList = BeanCopyUtils.copyBeanList(page.getRecords(), TargetMngDto.class); respList.forEach(dto->{ + // --------------------------- 获取部门信息----------------------- + dto.setMakerDepartmentName(commonService.getDepName(dto.getMakerDepartmentId())); + //查询关联分解信息 TargetDivideDetailQueryCriteria criteria = new TargetDivideDetailQueryCriteria(); criteria.setTargetId(dto.getId()); - List<TargetDivideDetailDto> respList1 = BeanCopyUtils.copyBeanList(targetDivideDetailService.queryAll(criteria), TargetDivideDetailDto.class); + List<TargetDivideDetailDto> respList1 = BeanCopyUtils.copyBeanList(targetDivideDetailBaseService.queryAll(criteria), TargetDivideDetailDto.class); // --------------------------- 获取部门信息----------------------- //收集所用到的部门ID @@ -88,7 +102,7 @@ collectDepIdSet.add(f.getMakerDepartmentId()); }); //获取部门名集合 - Map<Long,String> depNameMap = commonService.getDepName(collectDepIdSet); + Map<Long, String> depNameMap = commonService.getDepName(collectDepIdSet); respList1.forEach(f->{ f.setDutyDepartmentName(depNameMap.get(f.getDutyDepartmentId())); @@ -104,8 +118,8 @@ }); //获取目标分类名集合 if(!collectTypeSet.isEmpty()){ - List<TargetType> typeList = targetTypeRepository.selectBatchIds(collectTypeSet); // TODO - Map<Long,String> typeNameMap = typeList.stream() + List<TargetType> typeList = targetTypeBaseService.selectBatchIds(collectTypeSet); + Map<Long, String> typeNameMap = typeList.stream() .collect(Collectors.toMap(TargetType::getId, TargetType::getTypeName,(k1, k2)->k1)); respList1.forEach(f->{ @@ -129,21 +143,23 @@ @Override public List<TargetMng> queryAll(TargetMngQueryCriteria criteria) { - return baseMapper.selectList(QueryHelpPlus.getPredicate(TargetMng.class, criteria)); + return targetMngBaseService.queryAll( criteria); } @Override public Object selectOne(Serializable id) { - TargetMng targetMng = baseMapper.selectById(id); + TargetMng targetMng = targetMngBaseService.getById(id); if(targetMng == null){ return null; } TargetMngDto targetMngDto = BeanCopyUtils.copyBean(targetMng, TargetMngDto.class); + // --------------------------- 获取部门信息----------------------- + targetMngDto.setMakerDepartmentName(commonService.getDepName(targetMngDto.getMakerDepartmentId())); //查询关联分解信息 TargetDivideDetailQueryCriteria criteria = new TargetDivideDetailQueryCriteria(); criteria.setTargetId(targetMng.getId()); - List<TargetDivideDetailDto> respList = BeanCopyUtils.copyBeanList(targetDivideDetailService.queryAll(criteria), TargetDivideDetailDto.class); + List<TargetDivideDetailDto> respList = BeanCopyUtils.copyBeanList(targetDivideDetailBaseService.queryAll(criteria), TargetDivideDetailDto.class); // --------------------------- 获取部门信息----------------------- //收集所用到的部门ID @@ -153,7 +169,7 @@ collectDepIdSet.add(f.getMakerDepartmentId()); }); //获取部门名集合 - Map<Long,String> depNameMap = commonService.getDepName(collectDepIdSet); + Map<Long, String> depNameMap = commonService.getDepName(collectDepIdSet); respList.forEach(f->{ f.setDutyDepartmentName(depNameMap.get(f.getDutyDepartmentId())); @@ -171,8 +187,8 @@ }); //获取核结果集合 if(!collectExamResultSet.isEmpty()){ - List<TargetExamine> typeList = targetExamineRepository.selectList(new QueryWrapper<TargetExamine>().in("target_divide_detail_id",collectExamResultSet)); - Map<Long,TargetExamine> examResultMap = typeList.stream() + List<TargetExamine> typeList = targetExamineBaseService.selectList(new QueryWrapper<TargetExamine>().in("target_divide_detail_id",collectExamResultSet)); + Map<Long, TargetExamine> examResultMap = typeList.stream() .collect(Collectors.toMap(TargetExamine::getTargetDivideDetailId, Function.identity(),(k1, k2)->k1)); respList.forEach(f->{ @@ -195,15 +211,15 @@ public ResultVO queryAll(Long uid, PageQuery<TargetCheckAndSubmitQueryCriteria> pageQuery) { Long pageIndex = pageQuery.getPageIndex(); Long pageSize = pageQuery.getPageSize(); - Page<TargetMng> page = new Page<>(pageIndex, pageSize); + IPage<TargetMng> page = new Page<>(pageIndex, pageSize); - page = baseMapper.selectPage(page, + page = targetMngBaseService.selectPage(page, QueryHelpPlus.getPredicate(TargetMng.class, pageQuery.getSearchParams())); List<TargetCheckAndSubmitDto> respList = BeanCopyUtils.copyBeanList(page.getRecords(), TargetCheckAndSubmitDto.class); // 判断审批人 respList.forEach(dto->{ - List<TargetDutyWorkApprove> list = targetDutyWorkApproveRepository.selectList( + List<TargetDutyWorkApprove> list = targetDutyWorkApproveBaseService.selectList( new QueryWrapper<TargetDutyWorkApprove>().eq("del_flag",0) .eq("relate_type",pageQuery.getSearchParams().getRelateType()) .eq("relate_id",dto.getId()) @@ -232,14 +248,14 @@ @Override public Object statistics(TargetMngQueryCriteria criteria) { - Map<String,String> map = new HashMap<>(); + Map<String, String> map = new HashMap<>(); // 查询总数 Integer total = 0; - // 未完成数量 + // 完成数量 Integer complete=0; // 查询目标已分解且事件类型对一个的目标 - List<TargetMng> targetMngList = targetMngRepository.selectList( + List<TargetMng> targetMngList = targetMngBaseService.selectList( new QueryWrapper<TargetMng>() .eq("target_type",criteria.getTargetType()) .eq("divide_status",1) @@ -249,14 +265,14 @@ // 查询目标下的所有分解项 for (TargetMng targetMng : targetMngList){ Boolean completeFlag = true; - List<TargetDivideDetail> targetDivideDetailList = targetDivideDetailRepository.selectList( + List<TargetDivideDetail> targetDivideDetailList = targetDivideDetailBaseService.selectList( new QueryWrapper<TargetDivideDetail>() .eq("target_id",targetMng.getId()) ); if (!targetDivideDetailList.isEmpty()){ // 查询分解项 是否已经审核通过 for (TargetDivideDetail targetDivideDetail :targetDivideDetailList){ - List<TargetExamine> targetExamineList = targetExamineRepository.selectList( + List<TargetExamine> targetExamineList = targetExamineBaseService.selectList( new QueryWrapper<TargetExamine>() .eq("target_divide_detail_id",targetDivideDetail.getId()) .eq("examine_result",1) @@ -272,7 +288,7 @@ } } } - //已完成数 + //未完成数 int noComplete = total-complete; map.put("total",total+""); map.put("noComplete",noComplete+""); @@ -280,6 +296,99 @@ return map; } + @Override + public void delete(Long[] ids) { + if(ids == null){ + throw new TargetDutyException(ResultCodes.CLIENT_PARAM_ILLEGAL); + } + List<Long> idList = Arrays.asList(ids); + + //删除关联表数据 + UpdateWrapper<TargetDivideDetail> updateWrapper = new UpdateWrapper<>(); + updateWrapper.in("target_id",idList); + TargetDivideDetail detail = new TargetDivideDetail(); + detail.setDelFlag(1); + this.targetDivideDetailBaseService.update(detail,updateWrapper); + + List<TargetMng> delList = new ArrayList<>(); + idList.forEach(f->{ + TargetMng info = new TargetMng(); + info.setDelFlag(1); + info.setId(f); + delList.add(info); + }); + targetMngBaseService.updateBatchById(delList); + } + + @Override + public void importData(MultipartFile file) throws IOException { + String contentType = file.getContentType(); + if(!"application/vnd.ms-excel".equals(contentType) + && !"application/vnd.openxmlformats-officedocument.spreadsheetml.sheet".equals(contentType)) { + throw new TargetDutyException("上传的excel格式错误"); + } + + Collection<TargetMngImportExcel> importExcel = ExcelUtil.importExcel(TargetMngImportExcel.class, file.getInputStream(), "yyyy-MM-dd HH:mm:ss", new ExcelLogs() , 0); + + if (CollectionUtils.isEmpty(importExcel)) { + return; + } + + List<TargetMng> respList = BeanCopyUtils.copyBeanList((List<TargetMngImportExcel>)importExcel, TargetMng.class); + + targetMngBaseService.saveBatch(respList); + } + + @Override + public void exportTemplate() throws IOException { + Map<String,String> map = new LinkedHashMap<>(); + map.put("1","安全目标指标"); + map.put("2","目标指标编号"); + map.put("3","指标类型 1:年指标 2:月指标 3:半年 4:季度"); + map.put("4","年度"); + map.put("5","指标值"); + map.put("6","指标级别 1:公司级 2:部门分厂级 3:工段班组级"); + map.put("7","完成期限(yyyy-MM-dd HH:mm:ss)"); + map.put("8","备注信息"); + + String fileName = URLEncoder.encode("目标设置数据导入模板.xls", "UTF-8"); + response.setContentType("application/vnd.ms-excel"); + response.setHeader("Content-Disposition", "attachment;filename=" + fileName + ".xlsx"); + response.setHeader("Access-Control-Expose-Headers", "Content-Disposition"); + + ExcelUtil.exportExcel(map,new ArrayList<>() , response.getOutputStream()); + response.getOutputStream().close(); + } + + @Override + public void exportData(TargetMngQueryCriteria queryCriteria) throws IOException { + Map<String,String> map = new LinkedHashMap<>(); + map.put("1","安全目标指标"); + map.put("2","目标指标编号"); + map.put("3","年度"); + map.put("4","指标值"); + map.put("5","指标级别"); + map.put("6","指标类型"); + map.put("7","完成期限"); + map.put("8","状态"); + map.put("9","备注信息"); + + String key = DateUtils.date2String(new Date(), DateUtils.PATTERN_ALLTIME_NOSIGN) ; + String fileName = URLEncoder.encode("目标设置"+key+".xls", "UTF-8"); + response.setContentType("application/vnd.ms-excel"); + response.setHeader("Content-Disposition", "attachment;filename=" + fileName + ".xlsx"); + response.setHeader("Access-Control-Expose-Headers", "Content-Disposition"); + + + List<TargetMngExcel> respList = BeanCopyUtils.copyBeanList(this.queryAll(queryCriteria), TargetMngExcel.class); + + ExcelUtil.exportExcel(map,respList , response.getOutputStream(),DateUtils.PATTERN_STANDARD); + response.getOutputStream().close(); + } + + public void checkEnum(){ + + } } -- Gitblit v1.9.2