From d4447ca99df2cfe978ca51790dd2891e9df0d492 Mon Sep 17 00:00:00 2001
From: rain <167982779@qq.com>
Date: Thu, 25 Jul 2024 16:19:05 +0800
Subject: [PATCH] 修改人工拍照图片保存,新增面状航线保存、修改接口,图斑文件上传格式修改

---
 src/main/java/com/dji/sample/patches/controller/PatchesController.java |  101 ++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 72 insertions(+), 29 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 4e19e8a..5ca1931 100644
--- a/src/main/java/com/dji/sample/patches/controller/PatchesController.java
+++ b/src/main/java/com/dji/sample/patches/controller/PatchesController.java
@@ -4,18 +4,20 @@
 import com.dji.sample.common.model.PaginationData;
 import com.dji.sample.common.model.ResponseResult;
 import com.dji.sample.common.util.MinioUrlUtils;
-import com.dji.sample.log.aspect.SysLogAnnotation;
 import com.dji.sample.media.model.MediaFileEntity;
+import com.dji.sample.media.service.impl.FileServiceImpl;
 import com.dji.sample.patches.model.Param.PatchesParam;
 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.service.impl.ShpToDataSourceServiceImpl;
 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.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.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
@@ -27,6 +29,8 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 import static com.dji.sample.component.AuthInterceptor.TOKEN_CLAIM;
 
@@ -40,7 +44,11 @@
     @Autowired
     private IWaylineFileService waylineFileService;
     @Autowired
+    private IWaylineJobService waylineJobService;
+    @Autowired
     private TbDkjbxxServiceImpl tbDkjbxxService;
+    @Autowired
+    private FileServiceImpl fileService;
     @Autowired
     private TimerUtil timerUtil;
 
@@ -53,7 +61,6 @@
      * @return
      */
     @GetMapping("/listPatches")
-    @SysLogAnnotation(operModul = "图斑", operType = "查询", operDesc = "查询图斑的全部信息")
     public ResponseResult<PaginationData<LotInfo>> page(@RequestParam Integer page,
                                                         @RequestParam(name = "page_size", defaultValue = "10") Integer pageSize,
                                                         @RequestParam String workspaceId,
@@ -63,6 +70,7 @@
                                                         @RequestParam(name = "xmc", required = false) String xmc,
                                                         @RequestParam(name = "investigate", required = false) Integer investigate
     ) {
+        fileService.getNoaddFile();
         //调用service分页查询
         PatchesParam param = PatchesParam.builder()
                 .page(page)
@@ -86,14 +94,15 @@
      */
     @DeleteMapping("/deletePatches")
     public ResponseResult del(String workspaceId) {
-        int count=getPatchesService.delPatches(workspaceId);
-        return ResponseResult.success("删除的图斑数量是"+count);
+        int count = getPatchesService.delPatches(workspaceId);
+        return ResponseResult.success("删除的图斑数量是" + count);
     }
+
     @DeleteMapping("/deleteOne")
-    public ResponseResult deleteOne(int id){
-        int count= getPatchesService.deleteOne(id);
-        if (count!=0){
-            return ResponseResult.success("图斑删除成功id为"+id);
+    public ResponseResult deleteOne(int id) {
+        int count = getPatchesService.deleteOne(id);
+        if (count != 0) {
+            return ResponseResult.success("图斑删除成功id为" + id);
         }
         return ResponseResult.error("图斑删除失败");
     }
@@ -103,29 +112,43 @@
         String xzq = DistrictCodeUtils.nameToCode(code);
         return ResponseResult.success(xzq);
     }
+
     @GetMapping("/getInfoById")
     public ResponseResult<LotInfo> wayAndPatchesId(@RequestParam String patchesId) {
         return ResponseResult.success(getPatchesService.getPatchesFromId(patchesId));
     }
+
     @GetMapping("/getWayline")
-    public ResponseResult getWayline(@RequestParam String waylineName, @RequestBody List<LotInfo> list){
+    public ResponseResult getWayline(@RequestParam String waylineName, @RequestBody List<LotInfo> list) {
         try {
-            MultipartFile file=timerUtil.getFile(waylineName,list);
+            MultipartFile file = timerUtil.getFile(waylineName, list, 25.8917266, 116.020940643);
             return ResponseResult.success(file);
         } catch (IOException e) {
             throw new RuntimeException(e);
         }
     }
 
+    @GetMapping("/getPoint")
+    public List<PointPO> getPoint(@RequestParam List<Integer> list,
+                                  @RequestParam Double airportLat,
+                                  @RequestParam Double airportLon) {
+        List<LotInfo> lotInfos = getPatchesService.getLotInfosByIds(list);
+        return GeoToolsUtil.getRoutePointOrder(lotInfos, airportLat, airportLon);
+    }
+
     @PostMapping("/patchesToWayline")
-    public ResponseResult patchesToWayline(@RequestBody  List<LotInfo> list,
+    public ResponseResult patchesToWayline(@RequestBody List<LotInfo> lotInfos,
                                            @RequestParam String waylineName,
                                            @RequestParam String workspaceId,
+                                           @RequestParam (required = false) String patchesId,
+                                           @RequestParam double lat,
+                                           @RequestParam double lon,
+                                           @RequestParam(defaultValue = "1",required = false) String isTemp,
                                            HttpServletRequest request) throws IOException {
-        CustomClaim customClaim = (CustomClaim)request.getAttribute(TOKEN_CLAIM);
+        CustomClaim customClaim = (CustomClaim) request.getAttribute(TOKEN_CLAIM);
         String creator = customClaim.getUsername();
-        MultipartFile file=timerUtil.getFile(waylineName,list);
-        waylineFileService.importKmzFileBack(file, workspaceId, creator);
+        MultipartFile file = timerUtil.getFile(waylineName, lotInfos, lat, lon);
+        waylineFileService.importKmzFile(file, workspaceId, creator, patchesId,isTemp);
         WaylineFileEntity entity = waylineFileService.selectByName(waylineName);
         Map<String, String> infoMap = new HashMap<>();
         URL url = null;
@@ -142,23 +165,42 @@
     @GetMapping("/useMyTask")
     public ResponseResult useMyTask() throws Exception {
         try {
-//            timerUtil.myTask();
-            timerUtil.myTask2();
-            return ResponseResult.success();
+//            TimerUtil.mytask10();
+//            timerUtil.myTask2();
+//            timerUtil.myTask3();
+//            timerUtil.mytask4();
+//            timerUtil.mytask5();
+//            timerUtil.mytask6();
+//            timerUtil.mytask7();
+
         } catch (Exception e) {
-            throw new RuntimeException("db存储发送出现异常"+e);
+            throw new RuntimeException("db存储发送出现异常" + e);
         }
+        return ResponseResult.success();
     }
-//    @GetMapping ("/tests")
-//    public ResponseResult use()  {
-//        try {
-//            TimerUtil.sendPostWithFileAndParameter("src/main/resources/tmp/20240613/205621_635148ea-0ddb-4b23-945c-8a67abd813c9.db",
-//                    "635148ea-0ddb-4b23-945c-8a67abd813c9");
-//        } catch (IOException e) {
-//            throw new RuntimeException(e);
-//        }
-//        return ResponseResult.success();
-//    }
+
+    @GetMapping("/tests")
+    public ResponseResult use() {
+        ExecutorService executor = Executors.newSingleThreadExecutor();
+        executor.execute(() -> {
+            try {
+                timerUtil.sendPostWithFileAndParameter("DB/result_db.db",
+                        "635148ea-0ddb-4b23-945c-8a67abd813c9");
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+        });
+        executor.shutdown();
+        return ResponseResult.success();
+    }
+
+    @PostMapping("/way")
+    public void getway(@RequestParam("file") MultipartFile file,
+                       @RequestParam String workspaceId,
+                       @RequestParam String waylineName,
+                       @RequestParam String username) {
+        waylineFileService.importKmzFileBack(file, workspaceId, username);
+    }
 
     /**
      * 根据图斑的地块编号获取相对应音视频
@@ -174,6 +216,7 @@
                                                                            @RequestParam(name = "page_size", defaultValue = "10") Integer pageSize,
                                                                            @RequestParam String workspaceId,
                                                                            @RequestParam String dkbh) {
+
         try {
             PatchesParam param = PatchesParam.builder()
                     .page(page)

--
Gitblit v1.9.3