1

src/main/java/com/hxjt/dataupload/controller/UploadController.java

@@ -0,0 +1,130 @@
+package com.hxjt.dataupload.controller;
+
+import com.hxjt.dataupload.service.FxfxdxService;
+import com.hxjt.dataupload.task.AsyncTask;
+import com.hxjt.dataupload.utils.JsonData;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.nio.file.StandardCopyOption;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+
+/**
+ * liwenxuan
+ */
+
+@RestController
+@RequestMapping("dataupload/api/v1")
+public class UploadController {
+
+@Autowired
+private AsyncTask asyncTask;
+
+@Autowired
+private FxfxdxService fxfxdxService;
+
+    @RequestMapping("list")
+    public Object list(){
+
+        Map<String,String > map = new HashMap<>();
+        map.put("1","asdfdsa");
+        map.put("2","S6543465");
+
+        return map;
+
+    }
+    @GetMapping("async")
+    public JsonData testAsync(){
+        long begin = System.currentTimeMillis();
+        /*asyncTask.task1();
+        asyncTask.task2();
+        asyncTask.task3();*/
+        Future<String> task4 = asyncTask.task4();
+        Future<String> task5 = asyncTask.task5();
+        for(;;){
+            if(task4.isDone() && task5.isDone()){
+                try {
+                    String task4Result = task4.get();
+                    System.out.println(task4Result);
+
+                    String task5Result = task5.get();
+                    System.out.println(task5Result);
+
+
+                }catch (InterruptedException e){
+                    e.printStackTrace();
+                }catch (ExecutionException e){
+                    e.printStackTrace();
+                }finally {
+                    break;
+                }
+
+            }
+        }
+
+        long end =  System.currentTimeMillis();
+        return JsonData.buildSuccess(end-begin);
+    }
+
+    /*获取用户有权限的启用状态的表单列表树形结构*/
+    @RequestMapping(value = "/getOTBILLIDById")
+    public JsonData getCustomerFormList(@RequestBody Map<String,String> requestBody) {
+        //System.out.println(requestBody.get("id"));
+        if(!StringUtils.isBlank(requestBody.get("id"))){
+            String result = fxfxdxService.getOTBILLIDById(requestBody.get("id"));
+            return JsonData.buildSuccess(result);
+        }else{
+            return JsonData.buildError("请先输入id");
+        }
+    }
+
+    @PostMapping("/uploadPDF")
+    public ResponseEntity<String> uploadPdf(@RequestParam("file") MultipartFile file) {
+        String uploadDir = "F://dataUpload/zypPdfs/";
+        // 1. 验证文件类型和大小
+        if (file.isEmpty()) {
+            return ResponseEntity.badRequest().body("文件不能为空");
+        }
+        if (!file.getContentType().equals("application/pdf")) {
+            return ResponseEntity.badRequest().body("仅支持PDF格式");
+        }
+        if (file.getSize() > 10 * 1024 * 1024) { // 限制10MB
+            return ResponseEntity.badRequest().body("文件大小超过限制");
+        }
+
+        try {
+            // 确保目录存在
+            File targetDir = new File(uploadDir);
+            if (!targetDir.exists()) {
+                targetDir.mkdirs(); // 自动创建多级目录
+            }
+
+            // 生成唯一文件名（可选，避免重复覆盖）
+            String fileName = UUID.randomUUID() + "_" + file.getOriginalFilename();
+
+            // 构建目标文件的绝对路径
+            File targetFile = new File(targetDir.getAbsolutePath() + File.separator + fileName);
+
+            // 保存文件到磁盘
+            file.transferTo(targetFile);
+            return ResponseEntity.ok("上传成功");
+        } catch (IOException e) {
+            return ResponseEntity.internalServerError().body("文件存储失败：" + e.getMessage());
+        }
+    }
+}
+

src/main/java/com/hxjt/dataupload/controller/VideoController.java

@@ -1,69 +0,0 @@
-package com.hxjt.dataupload.controller;
-
-import com.hxjt.dataupload.task.AsyncTask;
-import com.hxjt.dataupload.utils.JsonData;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.*;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Future;
-
-/**
- * liwenxuan
- */
-
-@RestController
-@RequestMapping("/api/v1/video")
-public class VideoController {
-
-@Autowired
-private AsyncTask asyncTask;
-
-    @RequestMapping("list")
-    public Object list(){
-
-        Map<String,String > map = new HashMap<>();
-        map.put("1","asdfdsa");
-        map.put("2","S6543465");
-
-        return map;
-
-    }
-    @GetMapping("async")
-    public JsonData testAsync(){
-        long begin = System.currentTimeMillis();
-        /*asyncTask.task1();
-        asyncTask.task2();
-        asyncTask.task3();*/
-        Future<String> task4 = asyncTask.task4();
-        Future<String> task5 = asyncTask.task5();
-        for(;;){
-            if(task4.isDone() && task5.isDone()){
-                try {
-                    String task4Result = task4.get();
-                    System.out.println(task4Result);
-
-                    String task5Result = task5.get();
-                    System.out.println(task5Result);
-
-
-                }catch (InterruptedException e){
-                    e.printStackTrace();
-                }catch (ExecutionException e){
-                    e.printStackTrace();
-                }finally {
-                    break;
-                }
-
-            }
-        }
-
-        long end =  System.currentTimeMillis();
-        return JsonData.buildSuccess(end-begin);
-    }
-
-
-}

src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java

@@ -46,4 +46,6 @@ public interface FxfxdxMapper {
     List<Dtzy> getOneDtzysPage(@Param("isSingleDay")String isSingleDay);
 
     List<Dlzy> getOneDlzysPage(@Param("isSingleDay")String isSingleDay);
+
+    String getOTBILLIDById(@Param("id")String id);
 }

src/main/java/com/hxjt/dataupload/service/FxfxdxService.java

@@ -48,4 +48,6 @@ public interface FxfxdxService {
     List<Dtzy> getOneDtzysPage(String isSingleDay);
     //断路作业
     List<Dlzy> getOneDlzysPage(String isSingleDay);
+
+    String getOTBILLIDById(String id);
 }

src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java

@@ -104,4 +104,9 @@ public class FxfxdxServiceImpl implements FxfxdxService {
     public List<Dlzy> getOneDlzysPage(String isSingleDay) {
         return fxfxdxMapper.getOneDlzysPage(isSingleDay);
     }
+
+    @Override
+    public String getOTBILLIDById(String id) {
+        return fxfxdxMapper.getOTBILLIDById(id);
+    }
 }

src/main/resources/application-dev.yml

@@ -92,3 +92,4 @@ xxl:
       logpath: ./data/logs/xxl-job/executor
       #执行器日志保存天数
       logretentiondays: 30
+

src/main/resources/mapper/FxfxdxMapper.xml

@@ -3,6 +3,10 @@
 <mapper namespace="com.hxjt.dataupload.mapper.FxfxdxMapper">
 
 
+	<select id="getOTBILLIDById" parameterType="string" resultType="String">
+		select OTBILLID from OTM_OPERATICK where id = #{id}
+	</select>
+
     <select id="getFxfxdxs" resultType="com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx">
 
         select