From 5d1e6f5e960368b89e4f86b017b592b03f53bce5 Mon Sep 17 00:00:00 2001
From: bianyadong <yadong.bian@coolcollege.cn>
Date: Mon, 13 May 2024 15:38:13 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9F=B9=E8=AE=AD=E5=AE=8C=E6=88=90=E7=9F=AD?=
 =?UTF-8?q?=E4=BF=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/cool/store/enums/SMSMsgEnum.java   |  1 +
 .../com/cool/store/dao/EmployeeTrainingDAO.java |  9 +++++++++
 .../impl/EmployeeTrainingServiceImpl.java       | 17 ++++++++++++-----
 3 files changed, 22 insertions(+), 5 deletions(-)

diff --git a/coolstore-partner-common/src/main/java/com/cool/store/enums/SMSMsgEnum.java b/coolstore-partner-common/src/main/java/com/cool/store/enums/SMSMsgEnum.java
index a69838b53..d6b0980fb 100644
--- a/coolstore-partner-common/src/main/java/com/cool/store/enums/SMSMsgEnum.java
+++ b/coolstore-partner-common/src/main/java/com/cool/store/enums/SMSMsgEnum.java
@@ -30,6 +30,7 @@ public enum SMSMsgEnum {
     DECORATION_MODEL_PAY("装修款待缴费", "","SMS_465961253"),
     THREE_ACCEPTANCE_WAIT("三方验收待验收","","SMS_465961257"),
     TRAINING_REGISTER_SUCCESS("培训登记中", "", "SMS_466035101"),
+    TRAINING_ASSESSMENT_SUCCESS("员工培训已完成", "", "SMS_465901266"),
     ;
 
     private String title;
diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/dao/EmployeeTrainingDAO.java b/coolstore-partner-dao/src/main/java/com/cool/store/dao/EmployeeTrainingDAO.java
index 1515e0f93..676be0f42 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/dao/EmployeeTrainingDAO.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/dao/EmployeeTrainingDAO.java
@@ -77,4 +77,13 @@ public class EmployeeTrainingDAO {
                 .andIn("assessment_status", statusList);
         return employeeTrainingMapper.selectByExample(example);
     }
+
+    public Integer unCompleteNum() {
+        List<Integer> statusList = new ArrayList<>();
+        statusList.add(0);
+        statusList.add(1);
+        Example example = new Example(EmployeeTrainingDO.class);
+        example.createCriteria().andIn("assessment_status", statusList);
+        return employeeTrainingMapper.selectCountByExample(example);
+    }
 }
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/EmployeeTrainingServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/EmployeeTrainingServiceImpl.java
index de66cd777..5e1727c2b 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/EmployeeTrainingServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/EmployeeTrainingServiceImpl.java
@@ -9,10 +9,7 @@ import com.cool.store.dto.SmallVideoInfoDTO;
 import com.cool.store.dto.StaffExamInfoDTO;
 import com.cool.store.dto.openPreparation.PlanLineDTO;
 import com.cool.store.entity.*;
-import com.cool.store.enums.AssessmentTemplateType;
-import com.cool.store.enums.ExamStatusEnum;
-import com.cool.store.enums.MessageEnum;
-import com.cool.store.enums.UserRoleEnum;
+import com.cool.store.enums.*;
 import com.cool.store.enums.video.ResourceStatusEnum;
 import com.cool.store.enums.video.UploadTypeEnum;
 import com.cool.store.exception.ServiceException;
@@ -554,7 +551,7 @@ public class EmployeeTrainingServiceImpl implements EmployeeTrainingService {
         }
         EmployeeTrainingDO employeeTrainingDO = employeeTrainingDAO.selectById(request.getEmployeeTrainingId());
         TempUserDetailDO tempUserDetailDO = tempUserDetailDAO.selectById(employeeTrainingDO.getXfsgUserDetailId());
-
+        ShopInfoDO shopInfoDO = shopInfoDAO.getShopInfo(tempUserDetailDO.getShopId());
         Boolean pass = true;
         EnterpriseUserDO enterpriseUserDO = enterpriseUserDAO.getUserInfoByThirdOaUniqueFlag(tempUserDetailDO.getIdCard());
         String userId = enterpriseUserDO.getUserId();
@@ -613,6 +610,16 @@ public class EmployeeTrainingServiceImpl implements EmployeeTrainingService {
             employeeTrainingDO.setAssessmentStatus(CommonConstants.TWO);
         }
         employeeTrainingDAO.updateByPrimaryKeySelective(employeeTrainingDO);
+
+        //查询员工是否全部培训完成
+        Integer unCompleteNum =employeeTrainingDAO.unCompleteNum();
+        if(unCompleteNum != null && unCompleteNum == 0){
+            // 培训全部结束
+            Map<String, String> messageMap = new HashMap<>();
+            messageMap.put("storeName", shopInfoDO.getShopName());
+            LineInfoDO lineInfoDO = lineInfoDAO.getLineInfo(tempUserDetailDO.getLineId());
+            commonService.sendSms(lineInfoDO.getMobile(), SMSMsgEnum.TRAINING_ASSESSMENT_SUCCESS, messageMap);
+        }
     }
 
     private void checkVideoHandel(List<AssessmentDataDO> assessmentDataDOList) {