package cn.stylefeng.rest.modular.work;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.date.DateField;
|
import cn.hutool.core.date.DateUnit;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.ObjUtil;
|
import cn.stylefeng.guns.modular.business.dto.ImPushDataDTO;
|
import cn.stylefeng.guns.modular.business.entity.*;
|
import cn.stylefeng.guns.modular.business.service.*;
|
import cn.stylefeng.guns.modular.business.service.impl.ImBizService;
|
import cn.stylefeng.roses.kernel.customer.modular.entity.Customer;
|
import cn.stylefeng.roses.kernel.customer.modular.service.CustomerService;
|
import cn.stylefeng.roses.kernel.rule.enums.ImPushTypeEnum;
|
import cn.stylefeng.roses.kernel.rule.enums.ImUserTypeEnum;
|
import cn.stylefeng.roses.kernel.rule.enums.OrderStatusFlagEnum;
|
import cn.stylefeng.roses.kernel.rule.enums.PostIdEnum;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* 定时任务-订单超时取消
|
*/
|
@Slf4j
|
@Component
|
@EnableScheduling
|
public class OrderOutTimeCancelWork {
|
|
@Resource
|
IOrderConsultOneService orderConsultOneService;
|
|
@Resource
|
IMentalTestRecordService mentalTestRecordService;
|
|
@Resource
|
IMentalAppointmentService mentalAppointmentService;
|
|
@Resource
|
IOrderMentalTestService orderMentalTestService;
|
|
@Resource
|
ICourseOrderService courseOrderService;
|
|
@Resource
|
ICounsellingOrderService counsellingOrderService;
|
|
@Resource
|
ImBizService imBizService;
|
|
@Resource
|
CustomerService customerService;
|
|
@Resource
|
ICounsellingOrderReservationService counsellingOrderReservationService;
|
|
@Resource
|
ICounsellingInfoService counsellingInfoService;
|
|
@Resource
|
IImGroupService imGroupService;
|
|
@Resource
|
ICounsellingUserService counsellingUserService;
|
|
/**
|
* 固定时间延迟 @Scheduled(fixedDelay = 时间间隔(毫秒) )
|
*
|
* @Scheduled(fixedRate = 1000 * 60)
|
* Corn表达式 @Scheduled(cron = Corn表达式)
|
* @Scheduled(cron = "0 0/30 * * * *")
|
*/
|
@Scheduled(fixedRate = 1000 * 60)
|
public void autoCancelOrderConsultOne() {
|
Date date = new Date();
|
Date outTime = DateUtil.offset(date, DateField.MINUTE, -30);
|
|
// 超时未支付订单列表
|
List<OrderConsultOne> outOrderConsultOneList = orderConsultOneService.list(
|
Wrappers.<OrderConsultOne>lambdaUpdate()
|
.eq(OrderConsultOne::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.le(OrderConsultOne::getCreateTime, outTime)
|
);
|
|
for (OrderConsultOne orderConsultOne : outOrderConsultOneList) {
|
// 取消1v1咨询订单
|
boolean update = orderConsultOneService.update(
|
Wrappers.<OrderConsultOne>lambdaUpdate()
|
.set(OrderConsultOne::getStatusFlag, OrderStatusFlagEnum.CANCEL.getCode())
|
.set(OrderConsultOne::getCancelTime, date)
|
.set(OrderConsultOne::getCancelRemark, "订单未支付超时取消")
|
//.set(OrderConsultOne::getMentalAppointmentId, null)
|
.eq(OrderConsultOne::getId, orderConsultOne.getId())
|
);
|
if (update) {
|
// // 心理测试记录置空
|
// mentalTestRecordService.update(
|
// Wrappers.<MentalTestRecord>lambdaUpdate()
|
// .set(MentalTestRecord::getOrderConsultOneId, null)
|
// .set(MentalTestRecord::getMentalAppointmentId, null)
|
// .eq(MentalTestRecord::getMentalAppointmentId, orderConsultOne.getMentalAppointmentId())
|
// );
|
|
// 取消1v1咨询预约
|
mentalAppointmentService.update(
|
Wrappers.<MentalAppointment>lambdaUpdate()
|
.set(MentalAppointment::getStatusFlag, OrderStatusFlagEnum.CANCEL.getCode())
|
.eq(MentalAppointment::getId, orderConsultOne.getMentalAppointmentId())
|
);
|
}
|
}
|
|
}
|
|
@Scheduled(fixedRate = 1000 * 60)
|
public void autoCancelOrderMentalTest() {
|
Date outTime = DateUtil.offset(new Date(), DateField.MINUTE, -30);
|
// 超时订单未支付，自动取消
|
orderMentalTestService.update(
|
Wrappers.<OrderMentalTest>lambdaUpdate()
|
.set(OrderMentalTest::getStatusFlag, OrderStatusFlagEnum.CANCEL.getCode())
|
.set(OrderMentalTest::getCancelTime, new Date())
|
.set(OrderMentalTest::getCancelRemark, "订单未支付超时取消")
|
.eq(OrderMentalTest::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.le(OrderMentalTest::getCreateTime, outTime)
|
);
|
}
|
|
@Scheduled(fixedRate = 1000 * 60)
|
public void autoCancelOrderCourse() {
|
Date outTime = DateUtil.offset(new Date(), DateField.MINUTE, -30);
|
List<CourseOrder> courseOrderList = courseOrderService.list(
|
Wrappers.<CourseOrder>lambdaQuery()
|
.eq(CourseOrder::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.le(CourseOrder::getCreateTime, outTime)
|
);
|
if (CollectionUtil.isNotEmpty(courseOrderList)){
|
log.info("自动取消课程订单："+courseOrderList.size());
|
courseOrderList.parallelStream().forEach(courseOrder -> {
|
Customer customer = this.customerService.getById(courseOrder.getUserId());
|
|
// 推送消息内容
|
String pushContent = "用户:"+customer.getNickName()+"有未支付的课程订单，发起聊天。";
|
// IM推送数据json
|
ImPushDataDTO pushData = ImPushDataDTO.builder()
|
.type(ImPushTypeEnum.S_TO_W_TIP_COURSE_NOT_PAY.getCode())
|
.objId(ObjUtil.toString(courseOrder.getId()))
|
.title("通知")
|
.content(pushContent)
|
// .extra("发起聊天")
|
.data1(ObjUtil.toString(courseOrder.getUserId()))
|
.build();
|
if (courseOrder.getCourseUserId() != null){
|
imBizService.messageSendSystem(courseOrder.getUserId()+"", new String[]{courseOrder.getCourseUserId()+""}, pushData, ImUserTypeEnum.WORKER, PostIdEnum.PO_11, true);
|
}
|
|
});
|
|
// 超时订单未支付，自动取消
|
courseOrderService.update(
|
Wrappers.<CourseOrder>lambdaUpdate()
|
.set(CourseOrder::getStatusFlag, OrderStatusFlagEnum.CANCEL.getCode())
|
.set(CourseOrder::getCancelTime, new Date())
|
.set(CourseOrder::getCancelRemark, "订单未支付超时取消")
|
.eq(CourseOrder::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.le(CourseOrder::getCreateTime, outTime)
|
);
|
}
|
|
}
|
|
|
@Scheduled(fixedRate = 1000 * 60)
|
public void autNoticeOrderCourse() {
|
|
Date nowDate = new Date();
|
Date endDate = DateUtil.offset(nowDate, DateField.MINUTE, -5);
|
Date beginDate = DateUtil.offset(endDate, DateField.MINUTE, -1);
|
List<CourseOrder> courseOrderList = courseOrderService.list(
|
Wrappers.<CourseOrder>lambdaQuery()
|
.eq(CourseOrder::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.ge(CourseOrder::getCreateTime, beginDate).lt(CourseOrder::getCreateTime,endDate).eq(CourseOrder::getIsDelete,0)
|
);
|
if (CollectionUtil.isNotEmpty(courseOrderList)){
|
// log.info("自动取消课程订单："+courseOrderList.size());
|
courseOrderList.parallelStream().forEach(courseOrder -> {
|
Customer customer = this.customerService.getById(courseOrder.getUserId());
|
|
// 推送消息内容
|
String pushContent = "用户:"+customer.getNickName()+"有未支付的课程订单，发起聊天。";
|
// IM推送数据json
|
ImPushDataDTO pushData = ImPushDataDTO.builder()
|
.type(ImPushTypeEnum.S_TO_W_TIP_COURSE_NOT_PAY.getCode())
|
.objId(ObjUtil.toString(courseOrder.getId()))
|
.title("通知")
|
.content(pushContent)
|
// .extra("发起聊天")
|
.data1(ObjUtil.toString(courseOrder.getUserId()))
|
.build();
|
if (courseOrder.getCourseUserId() != null){
|
imBizService.messageSendSystem(courseOrder.getUserId()+"", new String[]{courseOrder.getCourseUserId()+""}, pushData, ImUserTypeEnum.WORKER, PostIdEnum.PO_11, true);
|
}
|
});
|
|
}
|
|
List<CounsellingOrder> counsellingOrderList = counsellingOrderService.list(
|
Wrappers.<CounsellingOrder>lambdaQuery()
|
.eq(CounsellingOrder::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.ge(CounsellingOrder::getCreateTime, beginDate).lt(CounsellingOrder::getCreateTime,endDate).eq(CounsellingOrder::getIsDelete,0)
|
);
|
if (CollectionUtil.isNotEmpty(counsellingOrderList)) {
|
|
counsellingOrderList.parallelStream().forEach(counsellingOrder -> {
|
// CustomerUpdateRequest customerUpdateRequest = JSONUtil.toBean(counsellingOrder.getUserInfoJson(), CustomerUpdateRequest.class);
|
Customer customer = this.customerService.getById(counsellingOrder.getUserId());
|
// 推送消息内容
|
String pushContent;
|
if (counsellingOrder.getOrderType().intValue() == 1) {
|
pushContent = "用户:" + customer.getNickName() + "有未支付的面诊订单，发起聊天。";
|
} else {
|
pushContent = "用户:" + customer.getNickName() + "有未支付的疗程订单，发起聊天。";
|
}
|
// IM推送数据json
|
ImPushDataDTO pushData = ImPushDataDTO.builder()
|
.type(ImPushTypeEnum.S_TO_W_TIP_CONSULT_NOT_PAY.getCode())
|
.objId(ObjUtil.toString(counsellingOrder.getId()))
|
.title("通知")
|
.content(pushContent)
|
// .extra("发起聊天")
|
.data1(ObjUtil.toString(counsellingOrder.getUserId()))
|
.build();
|
if (counsellingOrder.getConsultantUserId() != null){
|
// 发送
|
imBizService.messageSendSystem(counsellingOrder.getUserId() + "", new String[]{counsellingOrder.getConsultantUserId() + ""}, pushData, ImUserTypeEnum.WORKER, PostIdEnum.PO_21, true);
|
|
}
|
});
|
}
|
|
}
|
|
@Scheduled(fixedRate = 1000 * 60)
|
public void autoCancelOrderCounsel() {
|
Date outTime = DateUtil.offset(new Date(), DateField.MINUTE, -30);
|
List<CounsellingOrder> counsellingOrderList = counsellingOrderService.list(
|
Wrappers.<CounsellingOrder>lambdaQuery()
|
.eq(CounsellingOrder::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.le(CounsellingOrder::getCreateTime, outTime).eq(CounsellingOrder::getIsDelete,0)
|
);
|
if (CollectionUtil.isNotEmpty(counsellingOrderList)) {
|
log.info("自动取消咨询订单："+counsellingOrderList.size());
|
counsellingOrderList.parallelStream().forEach(counsellingOrder -> {
|
// CustomerUpdateRequest customerUpdateRequest = JSONUtil.toBean(counsellingOrder.getUserInfoJson(),CustomerUpdateRequest.class);
|
Customer customer = this.customerService.getById(counsellingOrder.getUserId());
|
// 推送消息内容
|
String pushContent;
|
if (counsellingOrder.getOrderType().intValue() == 1) {
|
pushContent = "用户:" + customer.getNickName() + "有未支付的面诊订单，发起聊天。";
|
} else {
|
pushContent = "用户:" + customer.getNickName() + "有未支付的疗程订单，发起聊天。";
|
}
|
// IM推送数据json
|
ImPushDataDTO pushData = ImPushDataDTO.builder()
|
.type(ImPushTypeEnum.S_TO_W_TIP_CONSULT_NOT_PAY.getCode())
|
.objId(ObjUtil.toString(counsellingOrder.getId()))
|
.title("通知")
|
.content(pushContent)
|
// .extra("发起聊天")
|
.data1(ObjUtil.toString(counsellingOrder.getUserId()))
|
.build();
|
if (counsellingOrder.getConsultantUserId() != null) {
|
// 发送
|
imBizService.messageSendSystem(counsellingOrder.getUserId() + "", new String[]{counsellingOrder.getConsultantUserId() + ""}, pushData, ImUserTypeEnum.WORKER, PostIdEnum.PO_21, true);
|
}
|
});
|
|
// 超时订单未支付，自动取消
|
counsellingOrderService.update(
|
Wrappers.<CounsellingOrder>lambdaUpdate()
|
.set(CounsellingOrder::getStatusFlag, OrderStatusFlagEnum.CANCEL.getCode())
|
.set(CounsellingOrder::getCancelTime, new Date())
|
.set(CounsellingOrder::getCancelRemark, "订单未支付超时取消")
|
.eq(CounsellingOrder::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
|
.le(CounsellingOrder::getCreateTime, outTime).eq(CounsellingOrder::getIsDelete,0)
|
);
|
}
|
|
}
|
|
|
/**
|
* 预约提醒
|
*/
|
@Scheduled(fixedRate = 1000 * 90)
|
public void orderReservationWarn() {
|
Date nowDate = new Date();
|
Date minuteEndTime = DateUtil.offsetMinute(nowDate,30);
|
Date minuteStartTime = DateUtil.offsetSecond(minuteEndTime,-90);;
|
Date endTime = DateUtil.offsetHour(nowDate,24);
|
Date startTime = DateUtil.offsetSecond(endTime,-90);
|
List<CounsellingOrderReservation> counsellingOrderReservationList = this.counsellingOrderReservationService.list(new LambdaQueryWrapper<CounsellingOrderReservation>().eq(CounsellingOrderReservation::getStauts,2)
|
.le(CounsellingOrderReservation::getReservationBeginTime,endTime).gt(CounsellingOrderReservation::getReservationBeginTime,startTime));
|
if (CollectionUtil.isNotEmpty(counsellingOrderReservationList)){
|
log.info("预约提醒："+counsellingOrderReservationList.size());
|
counsellingOrderReservationList.parallelStream().forEach(counsellingOrderReservation -> {
|
CounsellingInfo counsellingInfo = this.counsellingInfoService.getById(counsellingOrderReservation.getCounsellingInfoId());
|
|
// 推送消息内容
|
String pushContent = "你的预约("+DateUtil.formatDate(counsellingOrderReservation.getReservationBeginTime())+" "+DateUtil.format(counsellingOrderReservation.getReservationBeginTime(),"HH:mm")+"-"+DateUtil.format(counsellingOrderReservation.getReservationEndTime(),"HH:mm")+")即将开始，请按时参加";
|
// IM推送数据json
|
ImPushDataDTO pushData = ImPushDataDTO.builder()
|
.type(ImPushTypeEnum.S_TO_C_TIP_COUSULT_APPOINTMENT_UPCOMING.getCode())
|
.objId(ObjUtil.toString(counsellingOrderReservation.getId()))
|
.title("通知")
|
.content(pushContent)
|
// .extra("("+DateUtil.formatDate(counsellingOrderReservation.getReservationBeginTime())+" "+DateUtil.format(counsellingOrderReservation.getReservationBeginTime(),"HH:mm")+"-"+DateUtil.format(counsellingOrderReservation.getReservationEndTime(),"HH:mm")+")")
|
.build();
|
// 发送预约
|
imBizService.messageSendSystem(counsellingInfo.getUserId()+"", new String[]{counsellingOrderReservation.getUserId()+""}, pushData, ImUserTypeEnum.USER, null, true);
|
});
|
}
|
|
//30分钟
|
List<CounsellingOrderReservation> counsellingOrderReservationList1 = this.counsellingOrderReservationService.list(new LambdaQueryWrapper<CounsellingOrderReservation>().eq(CounsellingOrderReservation::getStauts,2)
|
.le(CounsellingOrderReservation::getReservationBeginTime,minuteEndTime).gt(CounsellingOrderReservation::getReservationBeginTime,minuteStartTime));
|
if (CollectionUtil.isNotEmpty(counsellingOrderReservationList1)){
|
counsellingOrderReservationList1.parallelStream().forEach(counsellingOrderReservation -> {
|
CounsellingInfo counsellingInfo = this.counsellingInfoService.getById(counsellingOrderReservation.getCounsellingInfoId());
|
|
// 推送消息内容
|
String pushContent = "你的预约("+DateUtil.formatDate(counsellingOrderReservation.getReservationBeginTime())+" "+DateUtil.format(counsellingOrderReservation.getReservationBeginTime(),"HH:mm")+"-"+DateUtil.format(counsellingOrderReservation.getReservationEndTime(),"HH:mm")+")即将开始，请按时参加";
|
// IM推送数据json
|
ImPushDataDTO pushData = ImPushDataDTO.builder()
|
.type(ImPushTypeEnum.S_TO_C_TIP_COUSULT_APPOINTMENT_UPCOMING.getCode())
|
.objId(ObjUtil.toString(counsellingOrderReservation.getId()))
|
.title("通知")
|
.content(pushContent)
|
// .extra("("+DateUtil.formatDate(counsellingOrderReservation.getReservationBeginTime())+" "+DateUtil.format(counsellingOrderReservation.getReservationBeginTime(),"HH:mm")+"-"+DateUtil.format(counsellingOrderReservation.getReservationEndTime(),"HH:mm")+")")
|
.build();
|
// 发送预约
|
imBizService.messageSendSystem(counsellingInfo.getUserId()+"", new String[]{counsellingOrderReservation.getUserId()+""}, pushData, ImUserTypeEnum.USER, null, true);
|
});
|
}
|
|
}
|
|
/**
|
* 过期
|
*/
|
@Scheduled(fixedRate = 1000 * 60 *5)
|
public void expireCourseAndCounselling() {
|
Date nowDate = new Date();
|
Date endDate = DateUtil.offsetMinute(nowDate,5);
|
List<CounsellingOrder> counsellingOrderList = this.counsellingOrderService.list(new LambdaQueryWrapper<CounsellingOrder>()
|
.eq(CounsellingOrder::getIsDelete,0)
|
.le(CounsellingOrder::getEffectiveEndTime,endDate).ge(CounsellingOrder::getEffectiveEndTime,nowDate)
|
.eq(CounsellingOrder::getStatusFlag,OrderStatusFlagEnum.PAY_SUCCESS.getCode()));
|
//解散群聊
|
if (CollectionUtil.isNotEmpty(counsellingOrderList)){
|
// List<Long> orderIds = counsellingOrderList.stream().map(CounsellingOrder::getId).collect(Collectors.toList());
|
// this.imGroupService.update(new LambdaUpdateWrapper<ImGroup>()
|
// .set(ImGroup::getStatusFlag,2).set(ImGroup::getDisbandDate,new Date())
|
// .in(ImGroup::getOrderId,orderIds).eq(ImGroup::getGroupType,2));
|
this.counsellingOrderService.update(new LambdaUpdateWrapper<CounsellingOrder>()
|
.set(CounsellingOrder::getStatusFlag,2).eq(CounsellingOrder::getIsDelete,0)
|
.set(CounsellingOrder::getResidueClassHours,0)
|
.le(CounsellingOrder::getEffectiveEndTime,endDate).ge(CounsellingOrder::getEffectiveEndTime,nowDate)
|
.eq(CounsellingOrder::getStatusFlag,OrderStatusFlagEnum.PAY_SUCCESS.getCode()));
|
}
|
List<CourseOrder> courseOrderList = this.courseOrderService.list(new LambdaQueryWrapper<CourseOrder>()
|
.eq(CourseOrder::getIsDelete,0)
|
.le(CourseOrder::getEffectiveEndTime,endDate).ge(CourseOrder::getEffectiveEndTime,nowDate)
|
.eq(CourseOrder::getStatusFlag,OrderStatusFlagEnum.PAY_SUCCESS.getCode()));
|
//解散群聊
|
if (CollectionUtil.isNotEmpty(courseOrderList)){
|
log.info("过期群聊提醒："+courseOrderList.size());
|
List<Long> orderIds = courseOrderList.stream().map(CourseOrder::getId).collect(Collectors.toList());
|
this.imGroupService.update(new LambdaUpdateWrapper<ImGroup>()
|
.set(ImGroup::getStatusFlag,2).set(ImGroup::getDisbandDate,new Date())
|
.in(ImGroup::getOrderId,orderIds).eq(ImGroup::getGroupType,1));
|
this.courseOrderService.update(new LambdaUpdateWrapper<CourseOrder>()
|
.set(CourseOrder::getStatusFlag,2).eq(CourseOrder::getIsDelete,0)
|
.le(CourseOrder::getEffectiveEndTime,endDate).ge(CourseOrder::getEffectiveEndTime,nowDate)
|
.eq(CourseOrder::getStatusFlag,OrderStatusFlagEnum.PAY_SUCCESS.getCode()));
|
}
|
|
}
|
|
// /**
|
// * 课程群聊提醒
|
// */
|
// @Scheduled(fixedRate = 1000 * 60 *10)
|
// public void warnCourseGroup(){
|
// Date endDate = new Date();
|
// Date startDate = DateUtil.offsetMinute(endDate,-10);
|
// endDate = DateUtil.offsetHour(endDate,-48);
|
// startDate = DateUtil.offsetHour(startDate,-48);
|
// List<ImGroup> imGroupList = this.imGroupService.list(new LambdaQueryWrapper<ImGroup>()
|
// .eq(ImGroup::getStatusFlag,1).le(ImGroup::getLastChatTime,endDate)
|
// .gt(ImGroup::getLastChatTime,startDate).eq(ImGroup::getGroupType,1));
|
// if (CollectionUtil.isNotEmpty(imGroupList)){
|
// log.info("课程群聊提醒："+imGroupList.size());
|
// imGroupList.stream().forEach(imGroup -> {
|
// CourseOrder courseOrder = this.courseOrderService.getById(imGroup.getOrderId());
|
// List<String> userIds = new ArrayList<>();
|
// if (courseOrder.getCourseUserId() != null){
|
// userIds.add(courseOrder.getCourseUserId().toString());
|
// }
|
// if (courseOrder.getTutoringUserId() != null){
|
// userIds.add(courseOrder.getTutoringUserId().toString());
|
// }
|
// if (CollectionUtil.isNotEmpty(userIds)){
|
// // 推送消息内容
|
// String pushContent = "群聊：课程咨询，已有两日未发送信息，查看聊天。";
|
// // IM推送数据json
|
// ImPushDataDTO pushData = ImPushDataDTO.builder()
|
// .type(ImPushTypeEnum.S_TO_W_TIP_COURSE_GROUP_TALK.getCode())
|
// .objId(ObjUtil.toString(imGroup.getId()))
|
// .title("通知")
|
// .content(pushContent)
|
//// .extra("查看聊天")
|
// .build();
|
// imBizService.messageSendSystem(courseOrder.getUserId()+"", userIds.toArray(new String[userIds.size()]), pushData, ImUserTypeEnum.WORKER, PostIdEnum.PO_11, true);
|
// }
|
// });
|
// }
|
// }
|
|
/**
|
* 定时自动更新预约
|
*/
|
@Scheduled(fixedRate = 1000 * 60 )
|
public void autoCounsellingReservationOrder() {
|
Date nowDate = new Date();
|
Date startTime = DateUtil.offsetMinute(nowDate,-1);
|
//查询待服务的预约
|
List<CounsellingOrderReservation> waitList = this.counsellingOrderReservationService.list(new LambdaQueryWrapper<CounsellingOrderReservation>()
|
.ge(CounsellingOrderReservation::getReservationBeginTime,startTime).le(CounsellingOrderReservation::getReservationBeginTime,nowDate)
|
.eq(CounsellingOrderReservation::getStauts,2));
|
if (CollectionUtil.isNotEmpty(waitList)){
|
//更新为待服务
|
List<Long> idList = waitList.stream().map(CounsellingOrderReservation::getId).collect(Collectors.toList());
|
log.info("自动更新待服务的咨询，ids:"+idList.toString());
|
this.counsellingOrderReservationService.update(new LambdaUpdateWrapper<CounsellingOrderReservation>().set(CounsellingOrderReservation::getStauts,3)
|
.set(CounsellingOrderReservation::getServiceBeginTime,new Date())
|
.in(CounsellingOrderReservation::getId,idList));
|
|
}
|
//查询服务中的预约
|
List<CounsellingOrderReservation> serviceList = this.counsellingOrderReservationService.list(new LambdaQueryWrapper<CounsellingOrderReservation>()
|
.ge(CounsellingOrderReservation::getReservationEndTime,startTime).le(CounsellingOrderReservation::getReservationEndTime,nowDate)
|
.eq(CounsellingOrderReservation::getStauts,3));
|
if (CollectionUtil.isNotEmpty(serviceList)){
|
log.info("自动更新服务中的咨询，ids:"+serviceList.stream().map(CounsellingOrderReservation::getId).collect(Collectors.toList()).toString());
|
serviceList.stream().forEach(counsellingOrderReservation -> {
|
counsellingOrderReservation.setStauts(4);
|
//分钟数
|
long minute = DateUtil.between(counsellingOrderReservation.getReservationBeginTime(),counsellingOrderReservation.getReservationEndTime(), DateUnit.MINUTE);
|
int ceil = (int) Math.ceil(minute / 60d);
|
counsellingOrderReservation.setConsumeCourseHour(ceil);
|
counsellingOrderReservation.setServiceEndTime(new Date());
|
counsellingOrderReservation.setServieCompleteTime(new Date());
|
this.counsellingOrderReservationService.updateById(counsellingOrderReservation);
|
CounsellingOrder counsellingOrder = this.counsellingOrderService.getById(counsellingOrderReservation.getCounsellingOrderId());
|
//更新咨询用户信息
|
CounsellingUser counsellingUser = this.counsellingUserService.getOne(new LambdaQueryWrapper<CounsellingUser>().eq(CounsellingUser::getUserId,counsellingOrder.getUserId()).eq(CounsellingUser::getCounsellingInfoId,counsellingOrder.getCounsellingInfoId()));
|
//如果是首次面诊跟新完成状态
|
if (counsellingOrderReservation.getReservationType().intValue() == 1){
|
counsellingOrder.setStatusFlag(2);
|
//更新客户是否完成首次咨询预约
|
this.customerService.update(new LambdaUpdateWrapper<Customer>().set(Customer::getIsFirstAppointment,1).eq(Customer::getCustomerId,counsellingOrder.getUserId()));
|
counsellingUser.setIsFirstAppointment(3);
|
counsellingUser.setStatusFlag(2);
|
}else {
|
//判断是否完成咨询订单服务
|
if (counsellingOrder.getResidueClassHours().intValue() - ceil <= 0 ){
|
counsellingOrder.setStatusFlag(2);
|
}
|
//扣除咨询课时
|
counsellingOrder.setResidueClassHours(counsellingOrder.getResidueClassHours().intValue() - ceil);
|
counsellingUser.setResidueClassHours(counsellingUser.getResidueClassHours().intValue() - ceil);
|
}
|
this.counsellingUserService.updateById(counsellingUser);
|
this.counsellingOrderService.updateById(counsellingOrder);
|
});
|
|
}
|
}
|
|
|
/**
|
* 过期完成咨询师服务
|
*/
|
@Scheduled(fixedRate = 1000 * 60*5 )
|
public void autoCounsellingUserCompelete(){
|
Date nowDate = new Date();
|
Date endDate = DateUtil.offsetMinute(nowDate,5);
|
List<CounsellingUser> counsellingUserList = this.counsellingUserService.list(new LambdaQueryWrapper<CounsellingUser>()
|
.eq(CounsellingUser::getIsDelete,0)
|
.le(CounsellingUser::getEffectiveEndTime,endDate).ge(CounsellingUser::getEffectiveEndTime,nowDate));
|
//解散群聊
|
if (CollectionUtil.isNotEmpty(counsellingUserList)){
|
List<Long> orderIds = counsellingUserList.stream().map(CounsellingUser::getId).collect(Collectors.toList());
|
log.info("过期用户咨询师信息ids:"+orderIds.toString());
|
this.imGroupService.update(new LambdaUpdateWrapper<ImGroup>()
|
.set(ImGroup::getStatusFlag,2).set(ImGroup::getDisbandDate,new Date())
|
.set(ImGroup::getIsDelete,1)
|
.in(ImGroup::getOrderId,orderIds).eq(ImGroup::getGroupType,2));
|
this.counsellingUserService.update(new LambdaUpdateWrapper<CounsellingUser>()
|
.set(CounsellingUser::getStatusFlag,2).eq(CounsellingUser::getIsDelete,0)
|
.set(CounsellingUser::getResidueClassHours,0)
|
.le(CounsellingUser::getEffectiveEndTime,endDate).ge(CounsellingUser::getEffectiveEndTime,nowDate)
|
.eq(CounsellingUser::getStatusFlag,OrderStatusFlagEnum.PAY_SUCCESS.getCode()));
|
}
|
}
|
|
/**
|
* 到预约时间自动取消预约
|
*/
|
@Scheduled(fixedRate = 1000 * 30)
|
public void autoCancelCounsellingReservation() {
|
Date endDate = new Date();
|
Date startDate = DateUtil.offset(endDate,DateField.SECOND,-30);
|
List<CounsellingOrderReservation> counsellingOrderReservationList = this.counsellingOrderReservationService.list(new LambdaQueryWrapper<CounsellingOrderReservation>().ge(CounsellingOrderReservation::getReservationBeginTime,startDate)
|
.le(CounsellingOrderReservation::getReservationBeginTime,endDate).eq(CounsellingOrderReservation::getStauts,1));
|
if (CollectionUtil.isNotEmpty(counsellingOrderReservationList)){
|
counsellingOrderReservationList.stream().forEach(counsellingOrderReservation -> {
|
if (counsellingOrderReservation.getReservationType().intValue() ==1){
|
this.counsellingOrderService.update(new LambdaUpdateWrapper<CounsellingOrder>().set(CounsellingOrder::getFirstAppointmentDate,null).set(CounsellingOrder::getFirstAppointmentTimes,null)
|
.eq(CounsellingOrder::getId,counsellingOrderReservation.getCounsellingOrderId()));
|
//处理用户咨询预约
|
this.counsellingUserService.update(new LambdaUpdateWrapper<CounsellingUser>().eq(CounsellingUser::getCounsellingInfoId,counsellingOrderReservation.getCounsellingInfoId())
|
.eq(CounsellingUser::getUserId,counsellingOrderReservation.getUserId()).set(CounsellingUser::getFirstAppointmentDate,null)
|
.set(CounsellingUser::getFirstAppointmentTimes,null).set(CounsellingUser::getIsFirstAppointment,1));
|
|
}
|
counsellingOrderReservation.setStauts(5);
|
counsellingOrderReservation.setCancleReason("到期时间自动取消预约");
|
this.counsellingOrderReservationService.updateById(counsellingOrderReservation);
|
});
|
}
|
}
|
|
|
/**
|
* 检查课程群聊是否两天未发送消息
|
*/
|
@Scheduled(fixedRate = 1000 * 60)
|
public void checkCourseGroup(){
|
Date endDate = new Date();
|
Date beginDate = DateUtil.offsetMinute(endDate,-1);
|
//两天前
|
endDate = DateUtil.offsetMinute(endDate,-10);
|
beginDate = DateUtil.offsetMinute(beginDate,-10);
|
List<ImGroup> imGroupList = this.imGroupService.list(new LambdaQueryWrapper<ImGroup>().eq(ImGroup::getGroupType,1).eq(ImGroup::getStatusFlag,1)
|
.ge(ImGroup::getLastChatTime,beginDate).lt(ImGroup::getLastChatTime,endDate));
|
if (CollectionUtil.isNotEmpty(imGroupList)){
|
imGroupList.stream().forEach(imGroup -> {
|
CourseOrder courseOrder = this.courseOrderService.getById(imGroup.getOrderId());
|
if (courseOrder != null && courseOrder.getCourseUserId() != null){
|
List<String> userIds = new ArrayList<>();
|
if (courseOrder.getCourseUserId() != null){
|
userIds.add(courseOrder.getCourseUserId().toString());
|
}
|
if (courseOrder.getTutoringUserId() != null){
|
userIds.add(courseOrder.getTutoringUserId().toString());
|
}
|
// 推送消息内容
|
String pushContent = "群聊:"+imGroup.getName()+",已有两日未发消息，";
|
// IM推送数据json
|
ImPushDataDTO pushData = ImPushDataDTO.builder()
|
.type(ImPushTypeEnum.S_TO_W_TIP_COURSE_GROUP_TALK.getCode())
|
.objId(ObjUtil.toString(imGroup.getId()))
|
.title("通知")
|
.content(pushContent)
|
// .extra("去查看。")
|
.build();
|
// 发送预约提示
|
imBizService.messageSendSystem(courseOrder.getUserId()+"", userIds.toArray(new String[0]), pushData, ImUserTypeEnum.WORKER, PostIdEnum.PO_11, true);
|
|
}
|
|
});
|
}
|
|
|
}
|
}
|
