修改了任务进行中修改参数的接口

notes-job/src/main/java/com/zjty/tynotes/job/basic/controller/WorkController.java

@@ -113,7 +113,7 @@ public class WorkController {
     @ApiOperation(value = "修改任务的组员.", notes = "修改任务的组员.")
     public ResponseEntity<JobResponse> update(@RequestBody UpdateCrew updateCrew) {
 
-        workService.updateWorkCrew(updateCrew.getWorkId(),updateCrew.getUsers());
+        workService.updateWorkCrew(updateCrew.getWorkId(),updateCrew.getUsers(),updateCrew.getWorkload());
         businessTreeManagement.saveAction(updateCrew.getUserid(),updateCrew.getWorkId(),Action.UPDATE_WORK_CREW,new Date(),updateCrew.getMsg());
         return ok(new JobResponse(updateCrew.getWorkId()));
     }

notes-job/src/main/java/com/zjty/tynotes/job/basic/entity/database/Work.java

@@ -135,7 +135,7 @@ public class Work {
      */
     @NotNull
     @ApiModelProperty(value = "工作量",example = "30")
-    private int workload;
+    private Integer workload;
 
     /**
      * 工作状态

notes-job/src/main/java/com/zjty/tynotes/job/basic/entity/request/UpdateCrew.java

@@ -6,6 +6,7 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
 
 import java.util.List;
 
@@ -23,6 +24,9 @@ public class UpdateCrew {
     @ApiModelProperty(value = "组员id", example = "users")
     private List<String> users;
 
+    @ApiModelProperty(value = "任务工作量", example = "workId")
+    private Integer workload;
+
     @ApiModelProperty(value = "说明", example = "msg")
     private String msg;
 

notes-job/src/main/java/com/zjty/tynotes/job/basic/repository/ScoreCoefficientRepository.java

@@ -10,4 +10,6 @@ import java.util.List;
 public interface ScoreCoefficientRepository extends MongoRepository<ScoreCoefficient, String> {
   List<ScoreCoefficient> findByWordId(String workId);
 
+  List<ScoreCoefficient> findByScore2IsNot();
+
 }

notes-job/src/main/java/com/zjty/tynotes/job/basic/repository/WorkRepository.java

@@ -2,8 +2,10 @@ package com.zjty.tynotes.job.basic.repository;
 
 import com.zjty.tynotes.job.basic.entity.database.Work;
 import org.springframework.data.mongodb.repository.MongoRepository;
+import org.springframework.data.mongodb.repository.Query;
 import org.springframework.stereotype.Repository;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -27,4 +29,7 @@ public interface WorkRepository extends MongoRepository<Work, String> {
      */
     List<Work> findAllByExecutorIn(List<String> ids);
 
+
+    List<Work> findByAuditTimeBefore(Date auditTime);
+
 }

notes-job/src/main/java/com/zjty/tynotes/job/basic/service/ScoreCoefficientService.java

@@ -2,6 +2,8 @@ package com.zjty.tynotes.job.basic.service;
 
 import com.zjty.tynotes.job.basic.entity.database.ScoreCoefficient;
 
+import java.util.List;
+
 
 public interface ScoreCoefficientService {
     /**
@@ -23,7 +25,7 @@ public interface ScoreCoefficientService {
     String modify(ScoreCoefficient scoreCoefficient);
 
     /**
-     * 指定id的Work是否存在
+     * 指定id的考评是否存在是否存在
      *
      * @param Id 指定id
      * @return 是否存在
@@ -41,5 +43,9 @@ public interface ScoreCoefficientService {
     ScoreCoefficient findById(String id);
 
 
+    /**
+     * 查询所有发布者为考评的考评对象
+     */
 
+    List<ScoreCoefficient> selectSorct2IsNull();
 }

notes-job/src/main/java/com/zjty/tynotes/job/basic/service/WorkService.java

@@ -111,7 +111,8 @@ public interface WorkService {
      *
      * @param crews 组员名单
      */
-    void updateWorkCrew(String taskId, List<String> crews);
+
+    void updateWorkCrew(String taskId, List<String> crews, Integer workload);
 
     /**
      * 修改任务 组员
@@ -132,11 +133,20 @@ public interface WorkService {
      * 根据任务id 查看任务剩余工作量
      */
     int findBySuperoirIdCount(String SuperoirId);
+
 //    /**
 //     * 查看正在进行中的任务
 //     */
 //    List<Work> selectTimeWork();
 
+    /**
+     * 根据用户id查看其部门所有的任务
+     * @param userId 用户id
+     * @return 返回所有任务
+     */
      WorkVoMapping selectUserIdsWork(String userId);
 
+
+
+
 }

notes-job/src/main/java/com/zjty/tynotes/job/basic/service/impl/ScoreCoefficientServiceImpl.java

@@ -70,4 +70,10 @@ public class ScoreCoefficientServiceImpl implements ScoreCoefficientService {
       }
 
     }
+
+    @Override
+    public List<ScoreCoefficient> selectSorct2IsNull() {
+
+        return scoreCoefficientRepository.findByScore2IsNot();
+    }
 }

notes-job/src/main/java/com/zjty/tynotes/job/basic/service/impl/WorkServiceImpl.java

@@ -27,6 +27,9 @@ import org.springframework.stereotype.Service;
 
 import java.text.DecimalFormat;
 import java.text.ParseException;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -253,9 +256,10 @@ return 0.0f;
     }
 
     @Override
-    public void updateWorkCrew(String taskId, List<String> crews) {
+    public void updateWorkCrew(String taskId, List<String> crews,Integer workload) {
         Work ob = workRepository.findById(taskId).get();
         ob.setCrewList(crews);
+        ob.setWorkload(workload);
         workRepository.save(ob);
     }
 

notes-job/src/main/java/com/zjty/tynotes/job/common/exception/WorkAttribution1.java

@@ -7,8 +7,9 @@ package com.zjty.tynotes.job.common.exception;
 public interface WorkAttribution1 {
 
 
-
-    //我的相关任务
+    /**
+     * 我的相关任务
+     */
     int ME_RELATED_WORK = 1;
 
     /**

notes-job/src/main/java/com/zjty/tynotes/job/task/Task.java

+package com.zjty.tynotes.job.task;
+
+import com.zjty.tynotes.job.basic.entity.database.Work;
+import com.zjty.tynotes.job.basic.service.ScoreCoefficientService;
+import com.zjty.tynotes.job.basic.service.WorkService;
+import com.zjty.tynotes.job.common.Action;
+import com.zjty.tynotes.job.common.constant.WorkStatus;
+import com.zjty.tynotes.job.status.service.BusinessTreeManagement;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.util.Date;
+
+@Slf4j
+@Service
+public class Task {
+    @Autowired
+    ScoreCoefficientService scoreCoefficientService;
+    @Autowired
+    WorkService workService;
+    @Autowired
+    BusinessTreeManagement businessTreeManagement;
+
+    @Scheduled(cron ="0 0 0 * * ?")
+    public void task() {
+
+        long time=LocalDateTime.now().minusDays(7)
+                .withHour(0)
+                .withMinute(0)
+                .withSecond(0)
+                .withNano(0)
+                .atOffset(ZoneOffset.ofHours(8))
+                .toEpochSecond();
+
+        scoreCoefficientService.selectSorct2IsNull()
+                               .forEach(
+                                       sc->{
+                                          Work work= workService.findById(sc.getWordId());
+                                          if (work.getAuditTime().getTime()<time){
+                                              sc.setScore2(sc.getScore1());
+                                              scoreCoefficientService.modify(sc);
+                                              businessTreeManagement.saveAction(work.getPublisher(),sc.getWordId(),Action.APPRAISAL_WORD,new Date(),"");
+
+                                              workService.alterTaskStatus(sc.getWordId(),WorkStatus.FINISHED,work.getPublisher());
+                                              businessTreeManagement.saveAction(work.getPublisher(), sc.getWordId(), Action.FINISHED_WORK, new Date(), "");
+                                          }
+
+                                       }
+                               );
+    }
+}

notes-pas/src/main/java/com/zjty/tynotes/pas/config/SecurityConfig.java

@@ -89,8 +89,7 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
                 .and()
                 .addFilterAt(myFilter(), UsernamePasswordAuthenticationFilter.class)
                 .addFilterBefore(corsFilter(), ChannelProcessingFilter.class)
-                .csrf().csrfTokenRepository(CookieCsrfTokenRepository.withHttpOnlyFalse()).disable().sessionManagement().maximumSessions(1).expiredUrl("/userLogout").sessionRegistry(sessionRegistry())
-        ;
+                .csrf().csrfTokenRepository(CookieCsrfTokenRepository.withHttpOnlyFalse()).disable().sessionManagement().maximumSessions(1).expiredUrl("/userLogout").sessionRegistry(sessionRegistry());
     }
 
     @Override

notes-union/src/main/java/com/zjty/tynotes/union/UnionApplication.java

@@ -5,7 +5,9 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
 import org.springframework.boot.web.servlet.server.ServletWebServerFactory;
+import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.context.annotation.Bean;
+import org.springframework.scheduling.annotation.EnableScheduling;
 import springfox.documentation.swagger2.annotations.EnableSwagger2;
 
 /**
@@ -14,7 +16,7 @@ import springfox.documentation.swagger2.annotations.EnableSwagger2;
  */
 @EnableSwagger2
 @SpringBootApplication(scanBasePackages = {
-       "com.zjty.tynotes.pas",
+        "com.zjty.tynotes.pas",
         "com.zjty.tynotes.fs",
         "com.zjty.tynotes.job",
         "com.zjty.tynotes.search",
@@ -23,6 +25,8 @@ import springfox.documentation.swagger2.annotations.EnableSwagger2;
         "com.zjty.tynotes.misc",
         "com.zjty.tynotes.union"
 })
+@EnableCaching
+@EnableScheduling
 public class UnionApplication {
     public static void main(String[] args) {
         SpringApplication.run(UnionApplication.class, args);