From 32c8843bc8d35d90e4701c70be363093afd98b7f Mon Sep 17 00:00:00 2001
From: bianyadong <yadong.bian@coolcollege.cn>
Date: Sat, 11 May 2024 16:10:57 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=A5=E5=BA=97=E9=93=BA=E5=B7=B2=E5=AE=8C?=
 =?UTF-8?q?=E6=88=90=E8=AF=95=E8=BF=90=E8=90=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cool/store/dao/OpenAcceptanceInfoDAO.java  |  4 ++++
 .../store/mapper/OpenAcceptanceInfoMapper.java |  2 ++
 .../mapper/OpenAcceptanceInfoMapper.xml        | 18 +++++++++++++++++-
 .../impl/NewStoreOpeningServiceImpl.java       | 15 +++++++++++++++
 .../impl/OpenAcceptanceInfoServiceImpl.java    |  5 +++++
 .../java/com/cool/store/job/XxlJobHandler.java | 14 +++++++++++++-
 6 files changed, 56 insertions(+), 2 deletions(-)

diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/dao/OpenAcceptanceInfoDAO.java b/coolstore-partner-dao/src/main/java/com/cool/store/dao/OpenAcceptanceInfoDAO.java
index d3ed8ec3b..59ac7d335 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/dao/OpenAcceptanceInfoDAO.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/dao/OpenAcceptanceInfoDAO.java
@@ -35,4 +35,8 @@ public class OpenAcceptanceInfoDAO {
     public int updateByPrimaryKeySelective(OpenAcceptanceInfoDO acceptanceInfoDO) {
         return openAcceptanceInfoMapper.updateByPrimaryKeySelective(acceptanceInfoDO);
     }
+
+    public int shopOpenAcceptanceStatusUpdate(){
+        return openAcceptanceInfoMapper.shopOpenAcceptanceStatusUpdate();
+    }
 }
diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/OpenAcceptanceInfoMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/OpenAcceptanceInfoMapper.java
index 3f7219256..e2820cee9 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/OpenAcceptanceInfoMapper.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/OpenAcceptanceInfoMapper.java
@@ -12,4 +12,6 @@ public interface OpenAcceptanceInfoMapper extends Mapper<OpenAcceptanceInfoDO> {
 
 
     List<OpenAcceptanceInfoListVO> openAcceptanceList(@Param("openAcceptance") OpenAcceptanceRequest openAcceptanceRequest);
+
+    int shopOpenAcceptanceStatusUpdate();
 }
\ No newline at end of file
diff --git a/coolstore-partner-dao/src/main/resources/mapper/OpenAcceptanceInfoMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/OpenAcceptanceInfoMapper.xml
index d450a43a1..1f12fbb44 100644
--- a/coolstore-partner-dao/src/main/resources/mapper/OpenAcceptanceInfoMapper.xml
+++ b/coolstore-partner-dao/src/main/resources/mapper/OpenAcceptanceInfoMapper.xml
@@ -27,7 +27,23 @@
     <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
     <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
   </resultMap>
-  
+  <update id="shopOpenAcceptanceStatusUpdate">
+    UPDATE xfsg_shop_stage_info s
+    SET shop_sub_stage_status = 1710
+    WHERE
+      shop_sub_stage_status = 1700
+      AND shop_id IN (
+      SELECT
+        shop_id
+      FROM
+        xfsg_open_acceptance_info
+      WHERE
+        acceptance_status = 1
+        AND plan_open_time BETWEEN DATE_SUB( NOW( ), INTERVAL 7 DAY )
+        AND DATE_SUB( NOW( ), INTERVAL 3 DAY )
+    )
+  </update>
+
   <select id="openAcceptanceList" resultType="com.cool.store.vo.OpenAcceptanceInfoListVO">
     SELECT
       o.id AS openAcceptanceInfoId,
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/NewStoreOpeningServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/NewStoreOpeningServiceImpl.java
index 91e889b8c..35750e280 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/NewStoreOpeningServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/NewStoreOpeningServiceImpl.java
@@ -1,7 +1,12 @@
 package com.cool.store.service.impl;
 
 import com.cool.store.dao.NewStoreOpeningDAO;
+import com.cool.store.dao.ShopStageInfoDAO;
 import com.cool.store.entity.NewStoreOpeningDO;
+import com.cool.store.entity.ShopStageInfoDO;
+import com.cool.store.enums.point.ShopSubStageEnum;
+import com.cool.store.enums.point.ShopSubStageStatusEnum;
+import com.cool.store.exception.ServiceException;
 import com.cool.store.request.NewStoreOpeningRequest;
 import com.cool.store.service.NewStoreOpeningService;
 import com.cool.store.vo.NewStoreOpeningVO;
@@ -22,6 +27,9 @@ public class NewStoreOpeningServiceImpl implements NewStoreOpeningService {
     @Resource
     private NewStoreOpeningDAO newStoreOpeningDAO;
 
+    @Resource
+    private ShopStageInfoDAO shopStageInfoDAO;
+
     @Override
     public List<NewStoreOpeningVO> storeTodoList(Long shopId) {
         List<NewStoreOpeningDO> storeOpeningDOList = newStoreOpeningDAO.storeTodoList(shopId);
@@ -41,6 +49,13 @@ public class NewStoreOpeningServiceImpl implements NewStoreOpeningService {
 
     @Override
     public void addStoreTodo(NewStoreOpeningRequest newStoreOpeningRequest) {
+        // 判断是否可以添加
+        ShopStageInfoDO shopStageInfoDO = shopStageInfoDAO.getShopSubStageInfo(newStoreOpeningRequest.getShopId(), ShopSubStageEnum.SHOP_STAGE_17);
+
+        if(shopStageInfoDO != null && shopStageInfoDO.getShopSubStageStatus().equals(ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_171.getShopSubStageStatus())){
+            throw new ServiceException("该店铺已经完成试运营，不能再添加待办事项");
+        }
+
         NewStoreOpeningDO newStoreOpeningDO = new NewStoreOpeningDO();
         newStoreOpeningDO.setShopId(newStoreOpeningRequest.getShopId());
         newStoreOpeningDO.setTodoItem(newStoreOpeningRequest.getTodoItem());
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/OpenAcceptanceInfoServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/OpenAcceptanceInfoServiceImpl.java
index 8b35aa425..3611f815c 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/OpenAcceptanceInfoServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/OpenAcceptanceInfoServiceImpl.java
@@ -10,6 +10,7 @@ import com.cool.store.entity.ShopStageInfoDO;
 import com.cool.store.enums.point.ShopStageEnum;
 import com.cool.store.enums.point.ShopSubStageEnum;
 import com.cool.store.enums.point.ShopSubStageFieldEnum;
+import com.cool.store.enums.point.ShopSubStageStatusEnum;
 import com.cool.store.exception.ServiceException;
 import com.cool.store.request.OpenAcceptanceRequest;
 import com.cool.store.request.ShopAcceptanceRequest;
@@ -143,6 +144,10 @@ public class OpenAcceptanceInfoServiceImpl implements OpenAcceptanceInfoService
         shopInfoDO.setId(shopAcceptanceRequest.getShopId());
         shopInfoDO.setPlanOpenTime(shopAcceptanceRequest.getPlanOpenTime());
         shopInfoDAO.updateShopInfo(shopInfoDO);
+        //开业验收完成
+        shopStageInfoDAO.updateShopStageInfo(shopInfoDO.getId(), ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_161);
+        //新店开业试运营
+        shopStageInfoDAO.updateShopStageInfo(shopInfoDO.getId(), ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_170);
     }
 
     @Override
diff --git a/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java b/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java
index 559b8c951..33ece9b10 100644
--- a/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java
+++ b/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java
@@ -85,6 +85,8 @@ public class XxlJobHandler {
     private EnterpriseUserDAO enterpriseUserDAO;
     @Resource
     private UserAuthMappingService userAuthMappingService;
+    @Resource
+    private OpenAcceptanceInfoDAO openAcceptanceInfoDAO;
 
     /**
      * 每天都将待体验门店信息变更到体验中
@@ -416,7 +418,6 @@ public class XxlJobHandler {
             StaffExamInfoDTO staffExamInfoDTO = xfsgEhrService.getUserExamInfo(enterpriseUserDO.getJobnumber());
             if (staffExamInfoDTO != null && StringUtils.isNotBlank(staffExamInfoDTO.getExamResult())
                     && StringUtils.isNotBlank(staffExamInfoDTO.getExamScore())) {
-
                 employeeTrainingDO.setTheoreticalExamScore(StringUtils.isNotBlank(staffExamInfoDTO.getExamScore()) ? Integer.valueOf(staffExamInfoDTO.getExamScore()) : null);
                 employeeTrainingDO.setTheoreticalExamStatus(ExamStatusEnum.matchCodeByDesc(staffExamInfoDTO.getExamResult()));
                 employeeTrainingDAO.updateByPrimaryKeySelective(employeeTrainingDO);
@@ -426,4 +427,15 @@ public class XxlJobHandler {
         XxlJobHelper.handleSuccess();
     }
 
+    /**
+     * 店铺新店开业状态更新
+     */
+    @XxlJob("shopOpenAcceptanceStatusUpdate")
+    public void shopOpenAcceptanceStatusUpdate() {
+        log.info("------店铺新店开业状态更新------");
+        int num = openAcceptanceInfoDAO.shopOpenAcceptanceStatusUpdate();
+        log.info("------店铺新店开业状态更新完成num:{}------", num);
+        XxlJobHelper.handleSuccess();
+    }
+
 }