From 3e9a6da99aae968123ee7bca352fc08becd7f1f2 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期四, 29 八月 2024 17:29:21 +0800
Subject: [PATCH] 工单过程图接口更换

---
 ycl-server/src/main/java/com/ycl/platform/service/impl/CheckScoreServiceImpl.java |  265 +++++++++++++++++++++++++++++++---------------------
 1 files changed, 159 insertions(+), 106 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/CheckScoreServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/CheckScoreServiceImpl.java
index b1568b9..decb126 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/impl/CheckScoreServiceImpl.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/CheckScoreServiceImpl.java
@@ -1,10 +1,11 @@
 package com.ycl.platform.service.impl;
 
+import annotation.DataScope;
+import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ycl.platform.base.BaseSelect;
-import com.ycl.platform.base.CheckIndex;
 import com.ycl.platform.domain.dto.CheckScoreDTO;
 import com.ycl.platform.domain.dto.CheckScoreIndexDTO;
+import com.ycl.platform.domain.dto.ScoreIndexDTO;
 import com.ycl.platform.domain.entity.*;
 import com.ycl.platform.domain.vo.CheckScoreDetailVO;
 import com.ycl.platform.mapper.CheckRuleMapper;
@@ -15,14 +16,11 @@
 import com.ycl.platform.service.ICheckIndexFaceService;
 import com.ycl.platform.service.ICheckIndexVideoService;
 import com.ycl.platform.service.ICheckScoreService;
-import com.ycl.system.Result;
 import com.ycl.system.entity.SysRole;
 import com.ycl.system.service.ISysDeptService;
+import com.ycl.utils.DateUtils;
 import com.ycl.utils.SecurityUtils;
 import com.ycl.utils.StringUtils;
-import com.ycl.utils.poi.ExcelUtil;
-import constant.CheckConstants;
-import enumeration.general.CheckScoreType;
 import enumeration.general.PublishType;
 import jakarta.servlet.http.HttpServletResponse;
 import lombok.extern.slf4j.Slf4j;
@@ -30,20 +28,17 @@
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 import pojo.ExcelExp;
-import utils.DateUtils;
 import utils.poi.ExcelUtilManySheet;
 
 import java.io.IOException;
 import java.text.SimpleDateFormat;
-import java.time.LocalDate;
-import java.time.format.DateTimeFormatter;
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 /**
  * 鑰冩牳绉垎鏄庣粏Service涓氬姟灞傚鐞�
- * 
+ *
  * @author ruoyi
  * @date 2024-04-22
  */
@@ -68,12 +63,13 @@
     @Autowired
     private ISysDeptService deptService;
     /**
-     * 鏌ヨ鑰冩牳绉垎
-     * 
+     * 鏌ヨ鑰冩牳绉垎鎸囨爣
+     *
      * @param id 鑰冩牳绉垎涓婚敭
      * @return 鑰冩牳绉垎
      */
     @Override
+    @DataScope(deptAlias = "d",userAlias = "u")
     public CheckScoreDetailVO selectCheckScoreById(CheckScoreIndexDTO checkScoreIndexDTO)
     {
         Long checkScoreId = checkScoreIndexDTO.getId();
@@ -96,15 +92,23 @@
         Short examineCategory = checkScore.getExamineCategory();
         String[] indexTableArr ={"","t_check_index_video","t_check_index_car","t_check_index_face"};
         String tableName = indexTableArr[examineCategory];
+
+        ScoreIndexDTO scoreIndexDTO = new ScoreIndexDTO()
+                .setTableName(tableName)
+                .setDeptId(checkScore.getDeptId())
+                .setDate(checkScoreIndexDTO.getDate())
+                .setQuarter(checkScoreIndexDTO.getQuarter());
+        scoreIndexDTO.setParams(checkScoreIndexDTO.getParams());
+
         //鑾峰綋鏈堜唤
-        String date = checkScoreIndexDTO.getDate();
-        if(StringUtils.isEmpty(date)){
+        if(StringUtils.isEmpty(scoreIndexDTO.getDate()) && CollectionUtils.isEmpty(checkScoreIndexDTO.getQuarter())){
             //濡傛灉鏌ヨ鏉′欢涓嶅惈鍙傛暟锛屾煡璇㈢Н鍒嗗搴斿垱寤烘椂闂�
             Date createTime = checkScore.getCreateTime();
             SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM");
-            date = formatter.format(createTime);
+            scoreIndexDTO.setDate(formatter.format(createTime));
         }
-        List<Map> map = scoreMapper.selectScoreIndex(tableName,checkScore.getDeptId(),date);
+
+        List<Map> map = scoreMapper.selectScoreIndex(scoreIndexDTO);
 
         scoreMap.put("tableData",checkRules);
         scoreMap.put("dataMap",map);
@@ -117,14 +121,66 @@
 
     /**
      * 鏌ヨ鑰冩牳绉垎鍗$墖鍒楄〃
-     * 
+     *
      * @param checkScore 鑰冩牳绉垎
      * @return 鑰冩牳绉垎
      */
     @Override
+    @DataScope(deptAlias = "d",userAlias = "u")
     public Map<Long, List<CheckScore>> selectCheckScoreList(CheckScore checkScore)
     {
-        //TODO:鏁版嵁鏉冮檺
+        //鍖哄幙鍙兘鐪嬪凡鍙戝竷
+        roleControl(checkScore);
+
+        // 鑾峰彇鏁版嵁鏃ユ湡鏃堕棿
+        Calendar calendar = Calendar.getInstance();
+        getCheckScore(checkScore, calendar);
+
+        // 涓�鍙锋煡璇箣鍓嶇殑鏁版嵁
+        if (LocalDateTime.now().getDayOfMonth() == 1) { calendar.add(Calendar.DAY_OF_MONTH, -1); }
+
+        List<CheckScore> checkScores = scoreMapper.selectCheckScoreMap(checkScore);
+        // 濡傛灉鏁版嵁涓虹┖锛屽垯鏌ヨ涔嬪墠鐨勬暟鎹�
+        if (checkScores.isEmpty()) {
+            CheckScore one = new LambdaQueryChainWrapper<>(baseMapper).select(CheckScore::getCreateTime).last("order by create_time desc limit 1").one();
+            if (Objects.nonNull(one)) {
+                calendar.setTime(one.getCreateTime());
+                getCheckScore(checkScore, calendar);
+                checkScores = scoreMapper.selectCheckScoreMap(checkScore);
+            }
+        }
+        return checkScores.stream().collect(Collectors.groupingBy(CheckScore::getDeptId));
+    }
+
+    private void getCheckScore(CheckScore checkScore, Calendar calendar)
+    {
+        // 0 鐪佸巺鏈堝害 1 甯傚眬鏈堝害 2 鐪佸巺瀛e害 3 甯傚眬瀛e害
+        switch (checkScore.getExamineTag()) {
+            case 0, 1:
+                checkScore.setEndDate(calendar.getTime());
+                calendar.set(Calendar.DAY_OF_MONTH, 1);
+                checkScore.setStartDate(calendar.getTime());
+                break;
+            case 2, 3:
+                checkScore.setStartDate(DateUtils.getQuarterStart(calendar).getTime());
+                checkScore.setEndDate(DateUtils.getQuarterEnd(calendar).getTime());
+                checkScore.setExamineTag(checkScore.getExamineTag() == 2 ? 0 : 1);
+                break;
+        }
+    }
+
+    /**
+     * 鏌ヨ鑰冩牳绉垎鍗$墖鍒楄〃
+     *
+     * @param checkScore 鑰冩牳绉垎
+     * @return 鑰冩牳绉垎
+     */
+    @Override
+    @DataScope(deptAlias = "d",userAlias = "u")
+    public Map<Long, List<CheckScore>> selectCheckScoreChart(CheckScore checkScore)
+    {
+        //鍖哄幙鍙兘鐪嬪凡鍙戝竷
+        roleControl(checkScore);
 
         //鏌ヨ鎴愮哗
         String date = checkScore.getDate();
@@ -132,16 +188,16 @@
             //濡傛灉涓虹┖鏌ユ湰鏈堢殑鏁版嵁
             Calendar now = Calendar.getInstance();
             //鍙栨槰澶�
-            now.add(Calendar.DATE, -1);
+            // now.add(Calendar.DATE, -1);
             Date yesterday = now.getTime();
             SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM");
             date = simpleDateFormat.format(yesterday);
             checkScore.setDate(date);
         }
         List<CheckScore> checkScores = scoreMapper.selectCheckScoreList(checkScore);
-        Map<Long, List<CheckScore>> deptMap = checkScores.stream().collect(Collectors.groupingBy(CheckScore::getDeptId));
-        return deptMap;
+        return checkScores.stream().collect(Collectors.groupingBy(CheckScore::getDeptId));
     }
+
     /**
      * 鍖哄幙璇︽儏
      *
@@ -149,61 +205,13 @@
      * @return 鑰冩牳绉垎
      */
     @Override
+    @DataScope(deptAlias = "d",userAlias = "u")
     public List<CheckScore> page(CheckScore checkScore) {
-        //TODO:鏁版嵁鏉冮檺
+        //鍖哄幙鍙兘鐪嬪凡鍙戝竷
+        roleControl(checkScore);
         return scoreMapper.selectCheckScoreList(checkScore);
     }
 
-
-    /**
-     * 鏂板鑰冩牳绉垎
-     * 
-     * @param checkScore 鑰冩牳绉垎
-     * @return 缁撴灉
-     */
-    @Override
-    public int insertCheckScore(CheckScore checkScore)
-    {
-        checkScore.setCreateTime(DateUtils.getNowDate());
-        return scoreMapper.insertCheckScore(checkScore);
-    }
-
-    /**
-     * 淇敼鑰冩牳鏄庣粏
-     * 
-     * @param checkScore 鑰冩牳绉垎鏄庣粏
-     * @return 缁撴灉
-     */
-    @Override
-    public int updateCheckScore(CheckScore checkScore)
-    {
-
-        return scoreMapper.updateCheckScore(checkScore);
-    }
-
-    /**
-     * 鎵归噺鍒犻櫎鑰冩牳绉垎
-     * 
-     * @param ids 闇�瑕佸垹闄ょ殑鑰冩牳绉垎涓婚敭
-     * @return 缁撴灉
-     */
-    @Override
-    public int deleteCheckScoreByIds(Long[] ids)
-    {
-        return scoreMapper.deleteCheckScoreByIds(ids);
-    }
-
-    /**
-     * 鍒犻櫎鑰冩牳绉垎淇℃伅
-     * 
-     * @param id 鑰冩牳绉垎涓婚敭
-     * @return 缁撴灉
-     */
-    @Override
-    public int deleteCheckScoreById(Long id)
-    {
-        return scoreMapper.deleteCheckScoreById(id);
-    }
     /**
      * 鍙戝竷鑰冩牳绉垎淇℃伅
      *
@@ -237,27 +245,30 @@
     public void exportIndex(HttpServletResponse response,CheckScore checkScoreDTO) throws IOException {
         String date = checkScoreDTO.getDate();
         //濡傛灉璇锋眰鍙傛暟鏃堕棿涓虹┖锛屾煡杩欐潯璁板綍鐨勬椂闂�
-        if(StringUtils.isEmpty(date)) {
+        if(StringUtils.isEmpty(checkScoreDTO.getDate()) && CollectionUtils.isEmpty(checkScoreDTO.getQuarter())){
             CheckScore checkScore = getById(checkScoreDTO.getId());
             Date createTime = checkScore.getCreateTime();
-            SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM");
-            date = simpleDateFormat.format(createTime);
+            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM");
+            date = formatter.format(createTime);
         }
 
         /** 瀵间笁寮爏heet */
         //杞﹁締
         CheckIndexCar checkIndexCar = new CheckIndexCar();
         checkIndexCar.setDate(date);
+        checkIndexCar.setQuarter(checkScoreDTO.getQuarter());
         List<CheckIndexCar> checkIndexCars = indexCarService.selectCheckIndexCarList(checkIndexCar);
         ExcelExp e1 = new ExcelExp("杞﹁締鑰冩牳鎸囨爣鏁版嵁",checkIndexCars,CheckIndexCar.class);
         //浜鸿劯
         CheckIndexFace checkIndexFace = new CheckIndexFace();
         checkIndexFace.setDate(date);
+        checkIndexFace.setQuarter(checkScoreDTO.getQuarter());
         List<CheckIndexFace> checkIndexFaces = indexFaceService.selectCheckIndexFaceList(checkIndexFace);
         ExcelExp e2 = new ExcelExp("浜鸿劯鑰冩牳鎸囨爣鏁版嵁",checkIndexFaces,CheckIndexFace.class);
         //瑙嗛
         CheckIndexVideo checkIndexVideo = new CheckIndexVideo();
         checkIndexVideo.setDate(date);
+        checkIndexVideo.setQuarter(checkScoreDTO.getQuarter());
         List<CheckIndexVideo> checkIndexVideos = indexVideoService.selectCheckIndexVideoList(checkIndexVideo);
         ExcelExp e3 = new ExcelExp("瑙嗛鑰冩牳鎸囨爣鏁版嵁",checkIndexVideos,CheckIndexVideo.class);
 
@@ -268,37 +279,79 @@
         ExcelUtilManySheet<List<ExcelExp>> util = new ExcelUtilManySheet<>(mysheet);
         util.exportExcelManySheet(response,mysheet);
 
-        //瀵煎崟sheet鐨勬柟寮�
-//        switch (CheckScoreType.fromValue(examineCategory)){
-//            case CHECK_SCORE_TYPE_CAR:
-//                //鏌ヨ溅杈�
-//                List<CheckIndexCar> checkIndexCars = indexCarService.selectCheckIndexCarList(new CheckIndexCar());
-//                export(response, depts, checkIndexCars,CheckIndexCar.class);
-//                break;
-//            case CHECK_SCORE_TYPE_FACE:
-//                // 鏌ヤ汉鑴�
-//                List<CheckIndexFace> checkIndexFaces = indexFaceService.selectCheckIndexFaceList(new CheckIndexFace());
-//                export(response, depts, checkIndexFaces,CheckIndexFace.class);
-//                break;
-//            case CHECK_SCORE_TYPE_VIDEO:
-//                // 鏌ヨ棰�
-//                List<CheckIndexVideo> checkIndexVideos = indexVideoService.selectCheckIndexVideoList(new CheckIndexVideo());
-//                export(response, depts, checkIndexVideos,CheckIndexVideo.class);
-//                break;
-//        }
     }
 
-    private <T extends CheckIndex> void export(HttpServletResponse response, List<BaseSelect> depts, List<T> checkIndexes,Class<T> checkIndexClass) {
-        //鏆傛椂娌$敤锛屽鏋滄暟鎹繃澶э紝鍦╯erver灞傜炕璇戯紝閬垮厤杩炶〃
-        checkIndexes.forEach(checkIndex->{
-            Optional<BaseSelect> first = depts.stream().filter(baseSelect -> checkIndex.getDeptId().equals(Long.valueOf(baseSelect.getId()+""))).findFirst();
-            if(first.isPresent()){
-                checkIndex.setDeptName(first.get().getValue());
-            }
-        });
-
-        ExcelUtil<T> util = new ExcelUtil<T>(checkIndexClass);
-        util.exportExcel(response, checkIndexes, "鑰冩牳绉垎鏄庣粏鏁版嵁");
-
+    private void roleControl(CheckScore checkScore) {
+        List<SysRole> roles = SecurityUtils.getLoginUser().getUser().getRoles();
+        SysRole sysRole = roles.get(0);
+        if("zg_province".equals(sysRole.getRoleKey())){
+            Map<String, Object> params = checkScore.getParams();
+            params.put("publish",PublishType.PUBLISHED.getCode());
+        }
     }
+
+    @Override
+    public List<Map<String, Object>> home() {
+        return baseMapper.home();
+    }
+
+
+    @Override
+    public List<Map<String, Object>> calculate(String category) {
+        Calendar calendar = Calendar.getInstance();
+        Date endDate = calendar.getTime();
+        calendar.set(Calendar.DAY_OF_MONTH, 1);
+        Date startDate = calendar.getTime();
+        return scoreMapper.calculate(startDate, endDate, category);
+    }
+
+    //    /**
+//     * 鏂板鑰冩牳绉垎
+//     *
+//     * @param checkScore 鑰冩牳绉垎
+//     * @return 缁撴灉
+//     */
+//    @Override
+//    public int insertCheckScore(CheckScore checkScore)
+//    {
+//        checkScore.setCreateTime(DateUtils.getNowDate());
+//        return scoreMapper.insertCheckScore(checkScore);
+//    }
+//
+//    /**
+//     * 淇敼鑰冩牳鏄庣粏
+//     *
+//     * @param checkScore 鑰冩牳绉垎鏄庣粏
+//     * @return 缁撴灉
+//     */
+//    @Override
+//    public int updateCheckScore(CheckScore checkScore)
+//    {
+//
+//        return scoreMapper.updateCheckScore(checkScore);
+//    }
+//
+//    /**
+//     * 鎵归噺鍒犻櫎鑰冩牳绉垎
+//     *
+//     * @param ids 闇�瑕佸垹闄ょ殑鑰冩牳绉垎涓婚敭
+//     * @return 缁撴灉
+//     */
+//    @Override
+//    public int deleteCheckScoreByIds(Long[] ids)
+//    {
+//        return scoreMapper.deleteCheckScoreByIds(ids);
+//    }
+//
+//    /**
+//     * 鍒犻櫎鑰冩牳绉垎淇℃伅
+//     *
+//     * @param id 鑰冩牳绉垎涓婚敭
+//     * @return 缁撴灉
+//     */
+//    @Override
+//    public int deleteCheckScoreById(Long id)
+//    {
+//        return scoreMapper.deleteCheckScoreById(id);
+//    }
 }

--
Gitblit v1.8.0