From 60d52f83688b0eb5b2c8bff6752a0370111a275d Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 14 Jun 2024 19:43:40 +0800
Subject: [PATCH] 同步数据,并且设置好网格及警格

---
 src/main/java/org/springblade/modules/eCallEventTwo/service/impl/EcOrderServiceImpl.java |   39 ++++++++++++++++++++++++++++++++++++++-
 1 files changed, 38 insertions(+), 1 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 3157730..7639b48 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
@@ -8,6 +8,7 @@
 import org.jetbrains.annotations.NotNull;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springblade.common.utils.SpringUtils;
 import org.springblade.core.tool.utils.BeanUtil;
 import org.springblade.modules.eCallEventTwo.dto.*;
 import org.springblade.modules.eCallEventTwo.entity.ECallEventTwoEntity;
@@ -15,6 +16,10 @@
 import org.springblade.modules.eCallEventTwo.mapper.EcOrderMapper;
 import org.springblade.modules.eCallEventTwo.service.EcOrderService;
 import org.springblade.modules.eCallEventTwo.service.IECallEventTwoService;
+import org.springblade.modules.grid.entity.GridEntity;
+import org.springblade.modules.grid.service.IGridService;
+import org.springblade.modules.police.entity.PoliceAffairsGridEntity;
+import org.springblade.modules.police.service.IPoliceAffairsGridService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -121,13 +126,45 @@
 			IPage<EcOrder> resultPage = baseMapper.selectPage(page, objectQueryWrapper);
 			List<EcOrder> records = resultPage.getRecords();
 			List<ECallEventTwoEntity> recordEntityList = BeanUtil.copy(records, ECallEventTwoEntity.class);
-			boolean b = ecOrderService.saveOrUpdateBatch(recordEntityList);
+			recordEntityList.forEach(ecOrderEntity -> {
+				// 点落面 设置警格网格信息
+				setGridInfo(ecOrderEntity);
+			});
+			boolean b = ecOrderService.saveBatch(recordEntityList);
 			System.out.println("更新第" + pageNum + "页" + b);
 		}
 	}
 
 	/**
+	 * 设置警格网格信息
+	 *
+	 * @param ecOrderEntity
+	 */
+	public void setGridInfo(ECallEventTwoEntity ecOrderEntity) {
+		if (ecOrderEntity.getSceneGeoLng() == null || ecOrderEntity.getSceneGeoLat() == null) {
+			return;
+		}
+		// 根据位置设置网格,警格编号
+		IGridService gridService = SpringUtils.getBean(IGridService.class);
+		IPoliceAffairsGridService policeAffairsGridService = SpringUtils.getBean(IPoliceAffairsGridService.class);
+		String point = "'POINT(" + ecOrderEntity.getSceneGeoLng().toString() + " " + ecOrderEntity.getSceneGeoLat().toString() + ")'";
+		// 点坐标解析网格
+		List<GridEntity> gridEntityList = gridService.spatialAnalysis(point);
+		if (gridEntityList.size() > 0) {
+			GridEntity gridEntity = gridEntityList.get(0);
+			ecOrderEntity.setGridCode(gridEntity.getGridCode());
+		}
+		// 点坐标解析警格
+		List<PoliceAffairsGridEntity> policeAffairsGridEntityList = policeAffairsGridService.spatialAnalysis(point);
+		if (policeAffairsGridEntityList.size() > 0) {
+			PoliceAffairsGridEntity policeAffairsGridEntity = policeAffairsGridEntityList.get(0);
+			ecOrderEntity.setJwGridCode(policeAffairsGridEntity.getJwGridCode());
+		}
+	}
+
+	/**
 	 * 获取单位考核指标
+	 *
 	 * @return
 	 */
 	@Override

--
Gitblit v1.9.3