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