新增定时任务

wujianwei

2025-08-12 93ab7329ea23a25224e8f0058ef4cebfae457f9a

 service/src/main/java/com/ruoyi/cwgl/service/impl/PendingSettlementBusinessServiceImpl.java

@@ -2,8 +2,11 @@

import java.util.List;

import cn.hutool.core.collection.CollectionUtil;
import com.ruoyi.common.utils.DateUtils;
import javax.annotation.Resource;

import com.ruoyi.cwgl.domain.ReceivableLineTruckPriceRule;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
import org.springframework.scheduling.annotation.Async;
@@ -179,4 +182,45 @@
    {
        return pendingSettlementBusinessMapper.deletePendingSettlementBusinessById(id);
    }

    @Override
    public void insertPendingSettlement(List<PendingSettlementBusiness> pendingSettlementBusinesses ) {

        if (CollectionUtil.isNotEmpty(pendingSettlementBusinesses)) {
            pendingSettlementBusinessMapper.insertPendingSettlementBusinessBatch(pendingSettlementBusinesses);

        }
        
    }

    @DataSource(DataSourceType.CWSJ)
    @Override
    public List<PendingSettlementBusiness> selectPendingSettlement2Cw() {
        List<PendingSettlementBusiness> pendingSettlementBusinesses = pendingSettlementBusinessMapper.selectPendingSettlement2Cw();
        //更新同步状态用
       /*     Integer[] ids = pendingSettlementBusinesses.stream().map(PendingSettlementBusiness::getServiceId).toArray(Integer[]::new);
            int i = pendingSettlementBusinessMapper.updeteCwData(ids);
            if (i>0){
                logger.info("同步状态更新成功");
            }*/
        return pendingSettlementBusinesses;
    }

    @DataSource(DataSourceType.CWSJ)
    @Override
    public int updateCwData(Integer[] ids) {
        return pendingSettlementBusinessMapper.updeteCwData(ids);
    }

    @DataSource(DataSourceType.CWSJ)
    @Override
    public List<ReceivableLineTruckPriceRule> selectReceivableLineTruckPriceRule() {
        return pendingSettlementBusinessMapper.selectReceivableLineTruckPriceRule();
    }

    @DataSource(DataSourceType.CWSJ)
    @Override
    public List<ReceivableLineTruckPriceRule> selectPayableLineTruckPriceRule() {
        return pendingSettlementBusinessMapper.selectPayableLineTruckPriceRule();
    }
}