From 3abec4126963b02a1dca0f49e5ec203b7198d240 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E7=AB=B9=E7=BA=A2?= <zhuhong.su@coolcollege.cn>
Date: Mon, 8 Apr 2024 19:28:11 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E7=9B=9F=E5=95=86=E7=BC=96=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/cool/store/dao/LineInfoDAO.java  | 10 ++++++
 .../com/cool/store/mapper/LineInfoMapper.java | 12 +++++++
 .../main/resources/mapper/LineInfoMapper.xml  | 13 +++++++
 .../com/cool/store/dto/PendingCountDTO.java   | 35 +++++++++++++++++++
 .../com/cool/store/service/DeskService.java   |  8 +++++
 .../store/service/impl/DeskServiceImpl.java   |  7 ++++
 .../store/controller/webb/DeskController.java |  9 ++++-
 7 files changed, 93 insertions(+), 1 deletion(-)
 create mode 100644 coolstore-partner-model/src/main/java/com/cool/store/dto/PendingCountDTO.java

diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java b/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java
index 5dbf479d2..54b373b8f 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java
@@ -1,5 +1,6 @@
 package com.cool.store.dao;
 
+import com.cool.store.dto.PendingCountDTO;
 import com.cool.store.entity.LineInfoDO;
 import com.cool.store.enums.ErrorCodeEnum;
 import com.cool.store.enums.WorkflowStageEnum;
@@ -130,4 +131,13 @@ public class LineInfoDAO {
     public List<LineInfoDO> getLineListByDevelopmentManager(String developmentManager) {
         return Lists.newArrayList();
     }
+
+
+    public PendingCountDTO pendingCount(String userId) {
+        if (StringUtils.isBlank(userId)){
+            return null;
+        }
+        PendingCountDTO pendingCount = lineInfoMapper.pendingCount(userId);
+        return pendingCount;
+    }
 }
diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java
index b07bf3652..2d9cae0fd 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java
@@ -1,5 +1,6 @@
 package com.cool.store.mapper;
 
+import com.cool.store.dto.PendingCountDTO;
 import com.cool.store.entity.LineInfoDO;
 import com.cool.store.enums.WorkflowSubStageStatusEnum;
 import com.cool.store.request.LineListRequest;
@@ -63,5 +64,16 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
     void toExperiencing(@Param("lineIds") List<Long> lineIds,
                         @Param("code") Integer code);
 
+    /**
+     * 待处理数据
+     * @param userId
+     * @return
+     */
+    PendingCountDTO pendingCount(@Param("userId") String userId);
+
+
+
+
+
     Integer batchUpdateInterviewWorkflowStage(@Param("lineIds") List<Long> lineIds, @Param("workflowSubStage")Integer workflowSubStage, @Param("workflowSubStageStatus")Integer workflowSubStageStatus);
 }
\ No newline at end of file
diff --git a/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml
index 2279265c7..9e394fa1d 100644
--- a/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml
+++ b/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml
@@ -335,6 +335,19 @@
   </select>
 
 
+  <select id="pendingCount" resultType="com.cool.store.dto.PendingCountDTO">
+    SELECT
+    sum( IF ( investment_manager = #{userId} AND workflow_sub_stage_status = 5, 1, 0 ) ) AS intendPendingCount,
+    sum( IF ( investment_manager = #{userId} AND workflow_sub_stage_status = 20, 1, 0 ) ) AS interviewPendingCount,
+    sum( IF ( first_interviewer = #{userId} AND workflow_sub_stage_status IN ( 30, 35, 40 ), 1, 0 ) ) AS firstInterviewPendingCount,
+    sum( IF ( investment_manager = #{userId} AND workflow_sub_stage_status = 50, 1, 0 ) ) AS payStagePendingCount,
+    sum( IF ( investment_manager = #{userId} AND workflow_sub_stage_status IN ( 63, 70, 80 ), 1, 0 ) ) AS signingPendingCount,
+    sum( IF ( investment_manager = #{userId} AND workflow_sub_stage_status IN ( 85, 90 ), 1, 0 ) ) AS storeExperiencePendingCount,
+    sum( IF ( second_interviewer = #{userId} AND workflow_sub_stage_status IN ( 105, 110, 115 ), 1, 0 ) ) AS secondInterviewPendingCount
+    FROM
+    xfsg_line_info where deleted = 0
+  </select>
+
   <select id="lineList" resultMap="BaseResultMap">
     select * from xfsg_line_info a
     left join xfsg_open_area_info b on a.want_shop_area_id = b.id
diff --git a/coolstore-partner-model/src/main/java/com/cool/store/dto/PendingCountDTO.java b/coolstore-partner-model/src/main/java/com/cool/store/dto/PendingCountDTO.java
new file mode 100644
index 000000000..979b78c72
--- /dev/null
+++ b/coolstore-partner-model/src/main/java/com/cool/store/dto/PendingCountDTO.java
@@ -0,0 +1,35 @@
+package com.cool.store.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @Author suzhuhong
+ * @Date 2024/4/8 19:12
+ * @Version 1.0
+ */
+@Data
+public class PendingCountDTO {
+
+    @ApiModelProperty("加盟申请待处理")
+    private Integer intendPendingCount;
+    @ApiModelProperty("邀约面谈待处理数据")
+    private Integer interviewPendingCount;
+    @ApiModelProperty("一审面试待处理数据")
+    private Integer firstInterviewPendingCount;
+    @ApiModelProperty("支付待处理数据")
+    private Integer payStagePendingCount;
+    @ApiModelProperty("意向签约待处理数据")
+    private Integer signingPendingCount;
+    @ApiModelProperty("门店实训待处理数量")
+    private Integer storeExperiencePendingCount;
+    @ApiModelProperty("二审面试待处理数据")
+    private Integer secondInterviewPendingCount;
+    @ApiModelProperty("总数")
+    private Integer totalCount;
+
+    public Integer getTotalCount() {
+        totalCount = intendPendingCount + interviewPendingCount + firstInterviewPendingCount + payStagePendingCount + signingPendingCount + storeExperiencePendingCount + secondInterviewPendingCount;
+        return totalCount;
+    }
+}
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/DeskService.java b/coolstore-partner-service/src/main/java/com/cool/store/service/DeskService.java
index 0ac223a35..e2b2d4f1a 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/DeskService.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/DeskService.java
@@ -1,6 +1,7 @@
 package com.cool.store.service;
 
 import com.cool.store.context.LoginUserInfo;
+import com.cool.store.dto.PendingCountDTO;
 import com.cool.store.entity.HyPartnerLabelDO;
 import com.cool.store.entity.LineInfoDO;
 import com.cool.store.vo.BaseInfoVO;
@@ -98,4 +99,11 @@ public interface DeskService {
      */
     Map<Long, HyPartnerLabelDO> getUserPortraitMap(List<LineInfoDO> lineInfoDOList);
 
+    /**
+     * 待处理数据
+     * @param user
+     * @return
+     */
+    PendingCountDTO  getPendingCount(LoginUserInfo user);
+
 }
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/DeskServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/DeskServiceImpl.java
index 6d9b63c60..8c5fd7261 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/DeskServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/DeskServiceImpl.java
@@ -3,6 +3,7 @@ package com.cool.store.service.impl;
 import cn.hutool.core.bean.BeanUtil;
 import com.cool.store.context.LoginUserInfo;
 import com.cool.store.dao.*;
+import com.cool.store.dto.PendingCountDTO;
 import com.cool.store.entity.*;
 import com.cool.store.enums.InterviewTypeEnum;
 import com.cool.store.enums.WorkflowSubStageStatusEnum;
@@ -295,4 +296,10 @@ public class DeskServiceImpl implements DeskService {
         return hyPartnerLabelDOS.stream().collect(Collectors.toMap(HyPartnerLabelDO::getId, x -> x));
     }
 
+    @Override
+    public PendingCountDTO getPendingCount(LoginUserInfo user) {
+        PendingCountDTO pendingCount = lineInfoDAO.pendingCount(user.getUserId());
+        return pendingCount;
+    }
+
 }
diff --git a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/DeskController.java b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/DeskController.java
index 38124b621..9848043a7 100644
--- a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/DeskController.java
+++ b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/DeskController.java
@@ -2,6 +2,7 @@ package com.cool.store.controller.webb;
 
 import com.cool.store.context.CurrentUserHolder;
 import com.cool.store.context.LoginUserInfo;
+import com.cool.store.dto.PendingCountDTO;
 import com.cool.store.response.ResponseResult;
 import com.cool.store.service.DeskService;
 import com.cool.store.vo.desk.*;
@@ -87,7 +88,13 @@ public class DeskController {
     }
 
 
-
+    @ApiOperation("待处理-数据")
+    @GetMapping("/getPendingCount")
+    public ResponseResult<PendingCountDTO> getPendingCount(@RequestParam(value = "pageNumber",required = true,defaultValue = "1")Integer pageNumber,
+                                                              @RequestParam(value = "pageSize",required = true,defaultValue = "10")Integer pageSize) {
+        LoginUserInfo userInfo = CurrentUserHolder.getUser();
+        return ResponseResult.success(deskService.getPendingCount(userInfo));
+    }
 
 
 }