From dbecdea3ad1768d1c7f8e88a2d3b64193c62352a Mon Sep 17 00:00:00 2001
From: rain <167982779@qq.com>
Date: Mon, 12 Aug 2024 13:34:52 +0800
Subject: [PATCH] 国土调查的任务下发、更新、取消,成果上传

---
 src/main/java/com/dji/sample/patches/controller/PatchesController.java |   49 +++++++++++++++++++++++++++++++++++++------------
 1 files changed, 37 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/dji/sample/patches/controller/PatchesController.java b/src/main/java/com/dji/sample/patches/controller/PatchesController.java
index e20ce42..39b65e6 100644
--- a/src/main/java/com/dji/sample/patches/controller/PatchesController.java
+++ b/src/main/java/com/dji/sample/patches/controller/PatchesController.java
@@ -10,19 +10,21 @@
 import com.dji.sample.patches.model.entity.LotInfo;
 import com.dji.sample.patches.service.GetPatchesService;
 import com.dji.sample.patches.service.ShpToDataSourceService;
-import com.dji.sample.patches.utils.DistrictCodeUtils;
-import com.dji.sample.patches.utils.GeoToolsUtil;
-import com.dji.sample.patches.utils.PointPO;
-import com.dji.sample.patches.utils.TimerUtil;
+import com.dji.sample.patches.utils.*;
 import com.dji.sample.territory.service.impl.TbDkjbxxServiceImpl;
 import com.dji.sample.wayline.model.entity.WaylineFileEntity;
 import com.dji.sample.wayline.service.IWaylineFileService;
 import com.dji.sample.wayline.service.IWaylineJobService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletRequest;
+import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.net.URL;
 import java.sql.SQLException;
@@ -68,9 +70,10 @@
                                                         @RequestParam(name = "xzqdm", required = false) String xzqdm,
                                                         @RequestParam(name = "bsm", required = false) String bsm,
                                                         @RequestParam(name = "xmc", required = false) String xmc,
-                                                        @RequestParam(name = "investigate", required = false) Integer investigate
-    ) {
-        fileService.getNoaddFile();
+                                                        @RequestParam(name = "investigate", required = false) Integer investigate,
+                                                        @RequestParam(name = "dkmj", required = false) Double dkmj,
+                                                        @RequestParam(name = "isPush",required = false) Integer isPush
+                                                        ) {
         //调用service分页查询
         PatchesParam param = PatchesParam.builder()
                 .page(page)
@@ -81,6 +84,8 @@
                 .bsm(bsm)
                 .xmc(xmc)
                 .investigate(investigate)
+                .dkmj(dkmj)
+                .isPush(isPush)
                 .build();
         PaginationData<LotInfo> data = getPatchesService.limitGet(param);
         return ResponseResult.success(data);
@@ -140,15 +145,15 @@
     public ResponseResult patchesToWayline(@RequestBody List<LotInfo> lotInfos,
                                            @RequestParam String waylineName,
                                            @RequestParam String workspaceId,
-                                           @RequestParam (required = false) String patchesId,
+                                           @RequestParam(required = false) String patchesId,
                                            @RequestParam double lat,
                                            @RequestParam double lon,
-                                           @RequestParam(defaultValue = "1",required = false) String isTemp,
+                                           @RequestParam(defaultValue = "1", required = false) String isTemp,
                                            HttpServletRequest request) throws IOException {
         CustomClaim customClaim = (CustomClaim) request.getAttribute(TOKEN_CLAIM);
         String creator = customClaim.getUsername();
         MultipartFile file = timerUtil.getFile(waylineName, lotInfos, lat, lon);
-        waylineFileService.importKmzFile(file, workspaceId, creator, patchesId,isTemp);
+        waylineFileService.importKmzFile(file, workspaceId, creator, patchesId, isTemp);
         WaylineFileEntity entity = waylineFileService.selectByName(waylineName);
         Map<String, String> infoMap = new HashMap<>();
         URL url = null;
@@ -172,7 +177,7 @@
 //            timerUtil.mytask5();
 //            timerUtil.mytask6();
 //            timerUtil.mytask7();
-
+            timerUtil.GtdbOperation();
         } catch (Exception e) {
             throw new RuntimeException("db存储发送出现异常" + e);
         }
@@ -251,7 +256,7 @@
                                  HttpServletRequest request) throws Exception {
         CustomClaim customClaim = (CustomClaim) request.getAttribute(TOKEN_CLAIM);
         String creator = customClaim.getUsername();
-        MultipartFile multipartFile = shpToDataSourceService.insertGeo(file, workspaceId, waylineName, airportLat, airportLon,creator);
+        MultipartFile multipartFile = shpToDataSourceService.insertGeo(file, workspaceId, waylineName, airportLat, airportLon, creator);
         waylineFileService.importKmzFileBack(multipartFile, workspaceId, creator);
         WaylineFileEntity entity = waylineFileService.selectByName(waylineName);
         Map<String, String> infoMap = new HashMap<>();
@@ -265,4 +270,24 @@
         }
         return ResponseResult.success(infoMap);
     }
+
+    @GetMapping("/getExcel")
+    public ResponseEntity<byte[]> exportExcel(@RequestParam String workspaceId) {
+        List<LotInfo> lotInfos = getPatchesService.listLotinfo(workspaceId);
+        try {
+            ByteArrayInputStream excelStream = ExcelUtil.exportLotInfoToExcel(lotInfos);
+            byte[] excelData = excelStream.readAllBytes();
+            excelStream.close();
+
+            HttpHeaders headers = new HttpHeaders();
+            headers.add(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=lot_info_data.xlsx");
+            headers.add(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_OCTET_STREAM_VALUE);
+            headers.setContentLength(excelData.length);
+
+            return new ResponseEntity<>(excelData, headers, HttpStatus.OK);
+        } catch (IOException e) {
+            e.printStackTrace();
+            return new ResponseEntity<>(("Failed to generate Excel file.").getBytes(), HttpStatus.INTERNAL_SERVER_ERROR);
+        }
+    }
 }

--
Gitblit v1.9.3