From 9ceec267ba036ad81caadace7cec9dc6f338a239 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期六, 07 十月 2023 17:28:05 +0800
Subject: [PATCH] 修改地块同步数据功能

---
 src/main/java/com/smartearth/poiexcel/controller/DkController.java |   56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 56 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/smartearth/poiexcel/controller/DkController.java b/src/main/java/com/smartearth/poiexcel/controller/DkController.java
index a3a00b2..e976452 100644
--- a/src/main/java/com/smartearth/poiexcel/controller/DkController.java
+++ b/src/main/java/com/smartearth/poiexcel/controller/DkController.java
@@ -7,6 +7,7 @@
 import com.smartearth.poiexcel.entity.DkEntity;
 import com.smartearth.poiexcel.entity.ResponseMsg;
 import com.smartearth.poiexcel.mapper.DkMapper;
+import com.smartearth.poiexcel.service.DkService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -30,6 +31,9 @@
 public class DkController extends BaseController {
     @Resource
     DkMapper dkMapper;
+
+    @Resource
+    DkService dkService;
 
     @ApiOperation(value = "鍒嗛〉鏌ヨ鍦板潡")
     @ApiImplicitParams({
@@ -60,4 +64,56 @@
             return fail(ex, -1);
         }
     }
+
+    @ApiOperation(value = "鏍规嵁缂栧彿鏇存柊")
+    @GetMapping(value = "/updateByBh")
+    public ResponseMsg<Object> updateByBh() {
+        try {
+            QueryWrapper<DkEntity> wrapper = new QueryWrapper<>();
+            wrapper.apply("length(dikuaibianhao) > 0");
+
+            List<DkEntity> list = dkMapper.selectList(wrapper);
+            if (null == list || list.isEmpty()) {
+                return success("娌¢渶瑕佹洿鏂扮殑鍦板潡", 0);
+            }
+
+            int rows = 0;
+            for (DkEntity dk : list) {
+                boolean flag = dkService.updateByBh(dk);
+                if (flag) {
+                    rows += dkMapper.updateById(dk);
+                }
+            }
+
+            return success(rows);
+        } catch (Exception ex) {
+            return fail(ex, -1);
+        }
+    }
+
+    @ApiOperation(value = "鏍规嵁鍧愭爣鏇存柊")
+    @GetMapping(value = "/updateByCoord")
+    public ResponseMsg<Object> updateByCoord() {
+        try {
+            QueryWrapper<DkEntity> wrapper = new QueryWrapper<>();
+            wrapper.apply("point_area is null and lng is not null and lat is not null");
+
+            List<DkEntity> list = dkMapper.selectList(wrapper);
+            if (null == list || list.isEmpty()) {
+                return success("娌¢渶瑕佹洿鏂扮殑鍦板潡", 0);
+            }
+
+            int rows = 0;
+            for (DkEntity dk : list) {
+                boolean flag = dkService.updateByCoord(dk);
+                if (flag) {
+                    rows += dkMapper.updateById(dk);
+                }
+            }
+
+            return success(rows);
+        } catch (Exception ex) {
+            return fail(ex, -1);
+        }
+    }
 }

--
Gitblit v1.9.3