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 909279423..ca95ad682 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 @@ -59,4 +59,7 @@ public interface LineInfoMapper extends Mapper { * @param lineInfoParam */ void insertOrUpdate(@Param("param") LineInfoDO lineInfoParam); + + void toExperiencing(@Param("lineIds") List lineIds, + @Param("code") Integer code); } \ No newline at end of file diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/TrainingExperienceMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/TrainingExperienceMapper.java index 520ebba24..7fb05c033 100644 --- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/TrainingExperienceMapper.java +++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/TrainingExperienceMapper.java @@ -19,4 +19,11 @@ public interface TrainingExperienceMapper { LeaseBaseInfoDO selectByLineId(@Param("lineId") Long lineId); List selectByLineIds(@Param("lineIds") List lineIds); + + /** + * 查询当日的门店体验数据 + * @return + */ + List selectESTime(); + } diff --git a/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml index 4b246c390..4b182ef9d 100644 --- a/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml +++ b/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml @@ -280,6 +280,20 @@ + + UPDATE + xfsg_line_info + SET workflow_sub_stage_status = #{code} + WHERE + deleted = 0 + AND workflow_sub_stage_status = 85 + AND id in + + #{lineId} + + + + + \ No newline at end of file diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/TrainingExperienceServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/TrainingExperienceServiceImpl.java index bb5e677a4..8fa6c2449 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/TrainingExperienceServiceImpl.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/TrainingExperienceServiceImpl.java @@ -48,6 +48,7 @@ public class TrainingExperienceServiceImpl extends LineFlowService implements Tr trainingExperienceMapper.insert(leaseBaseInfoDO); LineInfoDO lineInfoDO = new LineInfoDO(); lineInfoDO.setWorkflowSubStage(WorkflowSubStageEnum.STORE_EXPERIENCE.getCode()); + lineInfoDO.setWorkflowSubStageStatus(WorkflowSubStageStatusEnum.STORE_EXPERIENCE_85.getCode()); lineInfoDO.setId(request.getLineId()); lineInfoMapper.updateByPrimaryKeySelective(lineInfoDO); return true; 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 5aa794b42..c079b9d2b 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 @@ -1,20 +1,49 @@ package com.cool.store.job; +import com.cool.store.entity.LeaseBaseInfoDO; +import com.cool.store.enums.WorkflowSubStageStatusEnum; +import com.cool.store.mapper.LineInfoMapper; +import com.cool.store.mapper.TrainingExperienceMapper; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import java.util.stream.Collectors; + @Slf4j @Service public class XxlJobHandler { - @XxlJob("A") - public void A(){ + @Resource + TrainingExperienceMapper trainingExperienceMapper; + @Resource + LineInfoMapper lineInfoMapper; - log.info("A结束"); + /** + * 每天都将待体验门店信息变更到体验中 + */ + @XxlJob("updateStoreExperience") + public void updateStoreExperience() { + log.info("------实训体验状态变更------"); + String param = XxlJobHelper.getJobParam(); + String enterpriseId = param; + //查出数据并更新为体验中 + List leaseBaseInfoDOS = trainingExperienceMapper.selectESTime(); + if (CollectionUtils.isEmpty(leaseBaseInfoDOS)) { + log.info("------今日没有待更新数据------"); + return; + } + //线索ids + List lineIds = leaseBaseInfoDOS.stream().map(LeaseBaseInfoDO::getLineId).collect(Collectors.toList()); + WorkflowSubStageStatusEnum storeExperience90 = WorkflowSubStageStatusEnum.STORE_EXPERIENCE_90; + lineInfoMapper.toExperiencing(lineIds, storeExperience90.getCode()); + log.info("------实训体验状态变更结束------"); XxlJobHelper.handleSuccess(); } }