|
@@ -3,9 +3,11 @@ package com.leromro.core.ttl;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.leromro.common.enums.UserPointChangeTypeEnum;
|
|
|
import com.leromro.core.domain.*;
|
|
|
+import com.leromro.core.service.impl.MainOrderServiceImpl;
|
|
|
import com.leromro.system.domain.dto.UserUnfreezePointDTO;
|
|
|
import com.leromro.core.mapper.*;
|
|
|
import com.leromro.core.service.ISecondOrderService;
|
|
@@ -39,6 +41,8 @@ public class Monitor {
|
|
|
private IUserPointChangeService iUserPointChangeService;
|
|
|
@Autowired
|
|
|
private ISysUserService iSysUserService;
|
|
|
+ @Autowired
|
|
|
+ private MainOrderServiceImpl mainOrderService;
|
|
|
|
|
|
/**
|
|
|
* 定时任务定时调用的任务
|
|
@@ -66,8 +70,9 @@ public class Monitor {
|
|
|
UpdateWrapper<OrderFrozenFunds> updateFrozenWrapper = new UpdateWrapper<OrderFrozenFunds>().in("order_frozen_funds_id", orderFrozenFundsIdList).set("status", 1);
|
|
|
orderFrozenFundsMapper.update(null, updateFrozenWrapper);
|
|
|
//志愿者订单表 已完成订单 默认评价
|
|
|
- UpdateWrapper<SecondOrder> updateSecondOrderWrapper = new UpdateWrapper<SecondOrder>().eq("order_status", "4").in("second_order_id", seconderOrderIdList).set("score", 1).setSql("remark = CASE WHEN score IS NULL OR score = '' THEN '用户未评价,系统默认一星' ELSE remark END");
|
|
|
+ UpdateWrapper<SecondOrder> updateSecondOrderWrapper = new UpdateWrapper<SecondOrder>().eq("order_status", "4").eq("score",null).in("second_order_id", seconderOrderIdList).set("score", 1).setSql("remark = CASE WHEN score IS NULL OR score = '' THEN '用户未评价,系统默认一星' ELSE remark END");
|
|
|
secondOrdersMapper.update(null, updateSecondOrderWrapper);
|
|
|
+
|
|
|
//解冻后,向平台流水表中添加数据
|
|
|
// 1.先添加志愿者变更金额
|
|
|
List<PlatformFinance> volunteerPlatformList = needThawMoneyList.stream().map(orderFrozenFunds -> new PlatformFinance(null, orderFrozenFunds.getVolunteerMoney(), 1, 2, 3, orderFrozenFunds.getSecondOrderId(), orderFrozenFunds.getVolunteerId())).collect(Collectors.toList());
|
|
@@ -78,6 +83,13 @@ public class Monitor {
|
|
|
//查出所有已分配服务中心的需要解冻的小订单
|
|
|
List<SecondOrder> secondOrderList = secondOrdersMapper.selectList(new LambdaQueryWrapper<SecondOrder>().in(SecondOrder::getSecondOrderId, seconderOrderIdList));
|
|
|
|
|
|
+ //根据主订单查到小订单,看看是否是全部完成
|
|
|
+ List<Long> mainOrderIdList = secondOrderList.stream().map(SecondOrder::getMainOrderId).distinct().collect(Collectors.toList());
|
|
|
+ List<Long> mainOrdersIdList = mainOrderService.list(new LambdaQueryWrapper<MainOrders>().eq(MainOrders::getOrderStatus, "4").in(MainOrders::getMainOrderId,mainOrderIdList)).stream().map(MainOrders::getMainOrderId).collect(Collectors.toList());
|
|
|
+
|
|
|
+ mainOrderService.autoCommentOrderScore(mainOrdersIdList);
|
|
|
+
|
|
|
+
|
|
|
// 构建map 拿到secondOrderId 和 金额
|
|
|
Map<Long, BigDecimal> brokerageMap = platformPlatformList.stream() .collect(Collectors.toMap(PlatformFinance::getSecondOrderId, PlatformFinance::getChangeMoney));
|
|
|
|