KPI / fw-morax

Blame view

fw-morax-server/src/main/java/cn/fw/morax/server/controller/erp/EvalTaskController.java 3.98 KB
Edit Raw Normal View History
936e630c   姜超   feature(*): 门店奖惩分配 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
  package cn.fw.morax.server.controller.erp;
  
  import cn.fw.approval.sdk.mq.ApprovalResult;
  import cn.fw.common.web.annotation.ControllerMethod;
  import cn.fw.data.base.domain.common.Message;
  import cn.fw.morax.common.utils.DateUtil;
  import cn.fw.morax.common.utils.PublicUtil;
  import cn.fw.morax.domain.dto.query.KpiGroupStaffQueryDTO;
  import cn.fw.morax.rpc.ehr.EhrRpcService;
  import cn.fw.morax.rpc.ehr.dto.PerformanceStaffDTO;
  import cn.fw.morax.server.consumer.FlowConsumer;
  import cn.fw.morax.server.task.*;
  import cn.fw.security.auth.client.annotation.Authorization;
  import cn.fw.security.auth.client.enums.AuthType;
  import lombok.RequiredArgsConstructor;
  import lombok.extern.slf4j.Slf4j;
  import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
  import org.springframework.validation.annotation.Validated;
  import org.springframework.web.bind.annotation.*;
  
  import java.util.Date;
  import java.util.List;
  
  import static cn.fw.common.web.util.ResultBuilder.success;
  
  /**
   * @author : kurisu
   * @version : 1.0
   * @className : DebugController
   * @description : 绩效通用调试控制器
   * @date : 2022-04-11 10:45
   * @ignore
   */
  @Slf4j
  @RestController
  @Authorization(AuthType.NONE)
  @RequiredArgsConstructor
  @Validated
  @RequestMapping("/debug/task/eval")
  @ConditionalOnProperty(prefix = "task", name = "switch", havingValue = "on")
  public class EvalTaskController {
      private final EvalCalcTask evalCalcTask;
      private final EvalGroupTask evalGroupTask;
      private final EvalGroupUserTask evalGroupUserTask;
  
      @GetMapping("/group-user")
      @ControllerMethod("考评组人员")
      public Message<Void> processEvalUser() {
          evalGroupUserTask.processEvalUser();
          return success();
      }
936e630c   姜超   feature(*): 门店奖惩分配 
53
 
      @GetMapping("/calc-cache")
da42a3d8   姜超   feature(*): 计算考评代码优化 
54
 
      @ControllerMethod("缓存要计算的考评")
936e630c   姜超   feature(*): 门店奖惩分配 
55
56
57
58
59
60
61
62
63
64
65
66
 
      public Message<Void> cacheCalculableEvalGroup() {
          evalCalcTask.cacheCalculableEvalGroup();
          return success();
      }
  
      @GetMapping("/calc")
      @ControllerMethod("计算考评")
      public Message<Void> calculateCacheEvalGroup() {
          evalCalcTask.calculateCacheEvalGroup();
          return success();
      }
a33a5f4c   姜超   feature(*): 考评数据抽取修改 
67
68
69
70
71
72
73
74
75
76
77
78
79
 
      @GetMapping("/calc-cache-rank")
      @ControllerMethod("缓存要计算的考评排名")
      public Message<Void> cacheCalculableEvalGroupRank() {
          evalCalcTask.cacheCalculableEvalGroupRank();
          return success();
      }
  
      @GetMapping("/calc-rank")
      @ControllerMethod("计算考评排名")
      public Message<Void> calcEvalGroupRank() {
          evalCalcTask.calcEvalGroupRank();
          return success();
      }
da42a3d8   姜超   feature(*): 计算考评代码优化 
80
81
82
83
 
  
      @GetMapping("/cache-reward")
      @ControllerMethod("缓存分配奖惩的考评池")
      public Message<Void> cacheDistEvalShopPoolIds() {
edc57409   姜超   feature(*): 考评奖惩分配 
84
 
          evalCalcTask.cacheDistEvalShopPoolIds();
da42a3d8   姜超   feature(*): 计算考评代码优化 
85
86
87
 
          return success();
      }
5a834c50   姜超   feature(*): 考评模板导出 
88
89
90
91
92
93
94
 
      @GetMapping("/dist-reward")
      @ControllerMethod("分配奖惩")
      public Message<Void> distributionEvalReward() {
          evalCalcTask.distributionEvalReward();
          return success();
      }
936e630c   姜超   feature(*): 门店奖惩分配 
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
      @GetMapping("/cache-report")
      @ControllerMethod("缓存需要上报的考评指标")
      public Message<Void> cacheReportEvalIndicator() {
          evalCalcTask.cacheReportEvalIndicator();
          return success();
      }
  
      @GetMapping("/persist-report")
      @ControllerMethod("持久化需要上报的考评指标")
      public Message<Void> kpiReport() {
          evalCalcTask.persistenceReportTodo();
          return success();
      }
  
      @GetMapping("/push-report")
      @ControllerMethod("每5分钟检查待办推送")
      public Message<Void> salaryReport() {
          evalCalcTask.pushReportTodo();
          return success();
      }
bc484bc4   姜超   feature(*): 定时任务发送修改 
116
117
118
119
120
121
 
      @GetMapping("/send-notice")
      @ControllerMethod("发送业务上报mq通知")
      public Message<Void> sendNotice() {
          evalGroupTask.sendNotice();
          return success();
      }
936e630c   姜超   feature(*): 门店奖惩分配 
122
c285665c   姜超   feature(*): 考评阶段指标上报 
123
124
125
126
127
128
 
  //    @GetMapping("/eval-group")
  //    @ControllerMethod("处理考评组")
  //    public Message<Void> processCurMonthEffectEvals() {
  //        evalGroupTask.processCurMonthEffectEvals();
  //        return success();
  //    }
936e630c   姜超   feature(*): 门店奖惩分配 
129
130
131
132
133
 
  
  
  
  
  }