From fee8fbb72f73cc11075b07bf457ce2dd2a9ce19e Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 05 Jul 2024 11:15:47 +0800
Subject: [PATCH] 无诈代码优化

---
 src/main/java/org/springblade/modules/eCallEventTwo/service/impl/EcOrderServiceImpl.java |   21 +++++++++++++++------
 1 files changed, 15 insertions(+), 6 deletions(-)

diff --git a/src/main/java/org/springblade/modules/eCallEventTwo/service/impl/EcOrderServiceImpl.java b/src/main/java/org/springblade/modules/eCallEventTwo/service/impl/EcOrderServiceImpl.java
index 7639b48..6481e39 100644
--- a/src/main/java/org/springblade/modules/eCallEventTwo/service/impl/EcOrderServiceImpl.java
+++ b/src/main/java/org/springblade/modules/eCallEventTwo/service/impl/EcOrderServiceImpl.java
@@ -1,6 +1,7 @@
 package org.springblade.modules.eCallEventTwo.service.impl;
 
 import cn.hutool.core.convert.Convert;
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -22,6 +23,7 @@
 import org.springblade.modules.police.service.IPoliceAffairsGridService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
@@ -117,7 +119,11 @@
 	}
 
 	public void processPages(int pageSize, EcOrderParamDTO ecOrderParamDTO) {
-		long count = count(new QueryWrapper<>());
+		QueryWrapper<EcOrder> ecOrderQueryWrapper = new QueryWrapper<>();
+		if (ecOrderParamDTO.getStartTime() != null) {
+			ecOrderQueryWrapper.between("import_time", ecOrderParamDTO.getStartTime(), ecOrderParamDTO.getEndTime());
+		}
+		long count = count(ecOrderQueryWrapper);
 		int totalPages = (int) Math.ceil((double) count / pageSize); // 计算总页数
 
 		for (int pageNum = 1; pageNum <= totalPages; pageNum++) {
@@ -126,15 +132,18 @@
 			IPage<EcOrder> resultPage = baseMapper.selectPage(page, objectQueryWrapper);
 			List<EcOrder> records = resultPage.getRecords();
 			List<ECallEventTwoEntity> recordEntityList = BeanUtil.copy(records, ECallEventTwoEntity.class);
-			recordEntityList.forEach(ecOrderEntity -> {
-				// 点落面 设置警格网格信息
-				setGridInfo(ecOrderEntity);
-			});
-			boolean b = ecOrderService.saveBatch(recordEntityList);
+			boolean b = ecOrderService.saveOrUpdateBatch(recordEntityList);
 			System.out.println("更新第" + pageNum + "页" + b);
 		}
 	}
 
+	@Override
+	@DS("master")
+	public boolean saveEcOrder(List<ECallEventTwoEntity> recordEntityList) {
+		return false;
+	}
+
+
 	/**
 	 * 设置警格网格信息
 	 *

--
Gitblit v1.9.3