From 93ab7329ea23a25224e8f0058ef4cebfae457f9a Mon Sep 17 00:00:00 2001
From: wujianwei <wjw@11.com>
Date: 星期二, 12 八月 2025 13:57:45 +0800
Subject: [PATCH] 新增定时任务
---
service/src/main/java/com/ruoyi/cwgl/service/impl/PendingSettlementBusinessServiceImpl.java | 44 ++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 44 insertions(+), 0 deletions(-)
diff --git a/service/src/main/java/com/ruoyi/cwgl/service/impl/PendingSettlementBusinessServiceImpl.java b/service/src/main/java/com/ruoyi/cwgl/service/impl/PendingSettlementBusinessServiceImpl.java
index 385875d..e174d1a 100644
--- a/service/src/main/java/com/ruoyi/cwgl/service/impl/PendingSettlementBusinessServiceImpl.java
+++ b/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();
+ }
}
--
Gitblit v1.8.0