|
|
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
+import com.xxl.job.core.context.XxlJobHelper;
|
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@@ -38,8 +39,10 @@ public class LawyerOrderJob {
|
|
|
*/
|
|
|
@XxlJob("acceptOrderStatus")
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public void acceptOrderStatus(String param) {
|
|
|
+ public void acceptOrderStatus() {
|
|
|
+ String param = XxlJobHelper.getJobParam();
|
|
|
if (StringUtils.isNotEmpty(param)) {
|
|
|
+ log.info("开始执行测试待接单订单超时处理任务");
|
|
|
LambdaQueryWrapper<LawyerConsultationOrder> lambdaQueryWrapper = new LambdaQueryWrapper<LawyerConsultationOrder>()
|
|
|
.eq(LawyerConsultationOrder::getOrderStatus, 2)
|
|
|
.eq(LawyerConsultationOrder::getDeleteFlag, 0);
|
|
|
@@ -50,6 +53,7 @@ public class LawyerOrderJob {
|
|
|
lawyerConsultationOrderLambdaUpdateWrapper.set(LawyerConsultationOrder::getOrderStatus, 3)
|
|
|
.in(LawyerConsultationOrder::getId, collect);
|
|
|
lawyerConsultationOrderMapper.update(null, lawyerConsultationOrderLambdaUpdateWrapper);
|
|
|
+ log.info("待接单订单超时处理完成，处理数量：{}", collect.size());
|
|
|
}
|
|
|
} else {
|
|
|
log.info("开始执行待接单订单超时处理任务");
|
jyc