短信迁移
This commit is contained in:
@@ -68,15 +68,8 @@ public class TrainingExperienceServiceImpl extends LineFlowService implements Tr
|
||||
if (currentDate.before(request.getExperienceStartTime())) {
|
||||
leaseBaseInfoDO.setExperienceStatus(WorkflowSubStageStatusEnum.STORE_EXPERIENCE_85.getCode());
|
||||
lineInfoDO.setWorkflowSubStageStatus(WorkflowSubStageStatusEnum.STORE_EXPERIENCE_85.getCode());
|
||||
//message
|
||||
// Map<String, String> requestMap = new HashMap<>();
|
||||
// LineInfoDO byLineId = lineInfoMapper.getByLineId(request.getLineId());
|
||||
// requestMap.put("partnerUsername",byLineId.getUsername());
|
||||
// requestMap.put("partnerMobile",byLineId.getMobile());
|
||||
// requestMap.put("lineId",String.valueOf(request.getLineId()));
|
||||
// commonService.sendMessage(Collections.singletonList(byLineId.getInvestmentManager()),
|
||||
// MessageEnum.MESSAGE_32,
|
||||
// requestMap);
|
||||
LineInfoDO msgLineInfo = lineInfoMapper.getByLineId(request.getLineId());
|
||||
commonService.sendSms(msgLineInfo.getMobile(), SMSMsgEnum.SHOP_EXPERIENCE);
|
||||
} else if (currentDate.after(request.getExperienceStartTime()) || currentDate.before(request.getExperienceEndTime())) {
|
||||
leaseBaseInfoDO.setExperienceStatus(WorkflowSubStageStatusEnum.STORE_EXPERIENCE_90.getCode());
|
||||
lineInfoDO.setWorkflowSubStageStatus(WorkflowSubStageStatusEnum.STORE_EXPERIENCE_90.getCode());
|
||||
|
||||
@@ -110,12 +110,6 @@ public class XxlJobHandler {
|
||||
WorkflowSubStageStatusEnum storeExperience90 = WorkflowSubStageStatusEnum.STORE_EXPERIENCE_90;
|
||||
lineInfoMapper.toExperiencing(lineIds, storeExperience90.getCode());
|
||||
|
||||
List<LineInfoDO> lineInfos = lineInfoMapper.getByLineIds(lineIds);
|
||||
Map<Long, String> lineInfoMap = lineInfos.stream().collect(Collectors.toMap(LineInfoDO::getId, LineInfoDO::getMobile));
|
||||
leaseBaseInfoDOS.forEach(e -> {
|
||||
commonService.sendSms(lineInfoMap.get(e.getLineId()), SMSMsgEnum.SHOP_EXPERIENCE);
|
||||
});
|
||||
|
||||
log.info("------实训体验状态变更结束------");
|
||||
XxlJobHelper.handleSuccess();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user