修改错误

src/main/java/com/chinaunicom/zyhy/ebtp/supplier/coscoEvaluate/controller/ScheduledTasksController.java

@@ -16,6 +16,9 @@ public class ScheduledTasksController {
     public void checkTask() {
         scheduledTasksService.checkTask();
     }
-
+    @RequestMapping("/closeTask")
+    public void close() {
+        scheduledTasksService.closeTask();
+    }
 
 }

src/main/java/com/chinaunicom/zyhy/ebtp/supplier/coscoEvaluate/dao/CoscoEvaluateTaskDeptWeightMapper.java

@@ -1,6 +1,7 @@
 package com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.dao;
 
 import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.entity.CoscoEvaluateTaskDeptWeight;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -72,5 +73,5 @@ public interface CoscoEvaluateTaskDeptWeightMapper {
      * @param taskIds
      * @return
      */
-    List<CoscoEvaluateTaskDeptWeight> selectByTaskId(List<String> taskIds);
+    List<CoscoEvaluateTaskDeptWeight> selectByTaskId(@Param("taskIds")List<String> taskIds);
 }

src/main/java/com/chinaunicom/zyhy/ebtp/supplier/coscoEvaluate/service/impl/ScheduledTasksServiceImpl.java

@@ -19,12 +19,10 @@ import com.chinaunicom.zyhy.ebtp.supplier.coscosupplier.entity.CoscoMessage;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 @Service
@@ -69,6 +67,7 @@ public class ScheduledTasksServiceImpl implements ScheduledTasksService {
      */
     @Scheduled(cron = "0 0 2 * * ?")
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void closeTask() {
         //查询小于当前时间 未关闭任务
         //获取当前时间指标信息
@@ -100,7 +99,10 @@ public class ScheduledTasksServiceImpl implements ScheduledTasksService {
                 //获取人员信息
                 List<UserVo> user = userService.getUser(new SelectUserVo());
                 //给人员添加部门信息
-                Map<String, String> userMap = user.stream().collect(Collectors.toMap(UserVo::getUserId, UserVo::getUserDeptId));
+                Map<String, String> userMap=new HashMap<>();
+                user.forEach(userVo -> {
+                    System.out.println(userVo.getUserId());
+                    userMap.put(userVo.getUserId(), userVo.getUserDeptId());});
                 calculateAndObtainScoresVos.forEach(vos -> {
                     vos.setDeptId(userMap.get(vos.getUserId()));
                 });

src/main/java/com/chinaunicom/zyhy/ebtp/supplier/coscoEvaluate/vo/SupplierDimensionVo.java

@@ -78,7 +78,7 @@ public class SupplierDimensionVo implements Serializable {
     /**
      * 分数
      */
-    private String suscore;
+    private Integer suScore;
 
     private String categoryName;