package com.qs.serve.task; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.qs.serve.common.config.DevEnvironmentConfig; import com.qs.serve.common.config.properties.ProjectApisProperties; import com.qs.serve.common.model.AmountDTO; import com.qs.serve.common.util.AuthContextUtils; import com.qs.serve.common.util.HttpUtil; import com.qs.serve.modules.bir.controller.BirActivityCenterGoodsController; import com.qs.serve.modules.bir.mapper.BirTbsVtbPayJoinMapper; import com.qs.serve.modules.pay.mapper.PayPaymentItemMapper; import com.qs.serve.modules.pay.mapper.PayPaymentMapper; import com.qs.serve.modules.tbs.entity.TbsCostApply; import com.qs.serve.modules.tbs.service.TbsCostApplyService; import com.qs.serve.modules.vtb.mapper.VtbVerificationMapper; import com.qs.serve.modules.vtb.service.VtbVerificationService; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; import java.math.BigDecimal; import java.util.ArrayList; import java.util.List; import java.util.TimeZone; import java.util.stream.Collectors; /** * @author YenHex * @since 2023/11/7 */ @Slf4j @Component @AllArgsConstructor @ConditionalOnProperty(value = "project.bir-service-sync", havingValue = "true") public class BirTask { private final BirActivityCenterGoodsController birActivityCenterGoodsController; /** * 同步bir实时 * 15分钟执行一次 */ @Scheduled(cron="0 0/15 * * * ?") public void toSyncBirEcro(){ AuthContextUtils.setTenant("001"); birActivityCenterGoodsController.toSyncBirEcro(); log.warn("bir更新完成"); } /** * 移除因作废的费用申请导致的bir数据 * 每天中午13点触发 */ @Scheduled(cron="0 0 13 * * ?") public void toSyncRm(){ AuthContextUtils.setTenant("001"); birActivityCenterGoodsController.toSyncRm(); log.warn("bir更新完成 - 作废的费用"); } @PostConstruct void started() { log.warn("bir同步开启"); } }