22 changed files with 264 additions and 12 deletions
@ -0,0 +1,50 @@ |
|||
package com.qs.serve.task; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|||
import com.qs.serve.common.model.AmountDTO; |
|||
import com.qs.serve.modules.pay.entity.PayPayment; |
|||
import com.qs.serve.modules.pay.mapper.PayPaymentItemMapper; |
|||
import com.qs.serve.modules.pay.service.PayPaymentService; |
|||
import com.qs.serve.modules.tbs.entity.TbsCostApply; |
|||
import com.qs.serve.modules.tbs.service.TbsCostApplyService; |
|||
import lombok.AllArgsConstructor; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.stereotype.Component; |
|||
import java.util.List; |
|||
import java.util.stream.Collectors; |
|||
|
|||
/** |
|||
* @author YenHex |
|||
* @since 2023/11/7 |
|||
*/ |
|||
@Slf4j |
|||
@Component |
|||
@AllArgsConstructor |
|||
public class PayTask { |
|||
|
|||
private final PayPaymentService payPaymentService; |
|||
private final TbsCostApplyService costApplyService; |
|||
private final PayPaymentItemMapper payPaymentItemMapper; |
|||
|
|||
/** |
|||
* 同步支付 |
|||
*/ |
|||
public void syncCostPayStatus(){ |
|||
LambdaQueryWrapper<TbsCostApply> costLqw = new LambdaQueryWrapper<>(); |
|||
costLqw.select( |
|||
TbsCostApply::getId, |
|||
TbsCostApply::getTotalActivityAmount |
|||
); |
|||
costLqw.ne(TbsCostApply::getPayStatus,2); |
|||
costLqw.apply(" limit 2000"); |
|||
List<TbsCostApply> costApplyList = costApplyService.list(costLqw); |
|||
List<String> costIds = costApplyList.stream().map(a->a.toString()).collect(Collectors.toList()); |
|||
|
|||
List<AmountDTO> amountDTOList = payPaymentItemMapper.selectCostTotal(costIds); |
|||
for (TbsCostApply costApply : costApplyList) { |
|||
|
|||
} |
|||
|
|||
} |
|||
|
|||
} |
Loading…
Reference in new issue