事件报告跳转智能写作协助接口

src/main/java/com/zzsn/event/controller/EventAnalysisController.java

@@ -7,6 +7,7 @@ import cn.hutool.core.date.DateUtil;
 import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.obs.services.model.PutObjectResult;
 import com.zzsn.event.constant.Constants;
 import com.zzsn.event.constant.Result;
 import com.zzsn.event.entity.EventAnalysisReport;
@@ -16,6 +17,7 @@ import com.zzsn.event.es.EsService;
 import com.zzsn.event.service.*;
 import com.zzsn.event.util.CalculateUtil;
 import com.zzsn.event.util.HttpUtil;
+import com.zzsn.event.util.ObsUtil;
 import com.zzsn.event.util.RedisUtil;
 import com.zzsn.event.vo.CountVO;
 import com.zzsn.event.vo.SubjectDataVo;
@@ -26,6 +28,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.math.RoundingMode;
 import java.util.ArrayList;
@@ -60,10 +63,57 @@ public class EventAnalysisController {
     private EsService esService;
     @Autowired
     private RedisUtil redisUtil;
+    @Autowired
+    private ObsUtil obsUtil;
 
     @Value(("${serviceProject.url:}"))
     private String SERVICE_PROJECT_URL;
 
+    private static final String prefix = "http://obs.ciglobal.cn/";
+
+    /**
+     * 商上传文件(事件报告跳转智能写作是调用)
+     *
+     * @param file 文件
+     * @author lkg
+     * @date 2024/8/16
+     */
+    @PostMapping("/uploadFile")
+    public Result<?> uploadFile(MultipartFile file){
+        String downloadUrl = null;
+        try {
+            if (file != null) {
+                String filename = file.getOriginalFilename();
+                if (StringUtils.isNotEmpty(filename)) {
+                    String[] split = filename.split("\\.");
+                    String objectKey = "event/report/" + split[0] + "_" + System.currentTimeMillis() + "." + split[1];
+                    obsUtil.uploadFile(objectKey, file.getInputStream());
+                    downloadUrl = prefix + objectKey;
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return Result.OK(downloadUrl);
+    }
+
+    /**
+     * 删除文件(研究中心智能写作保存文件后,调用接口删除平台的报告文件)
+     *
+     * @param param 参数
+     * @author lkg
+     * @date 2024/8/16
+     */
+    @PostMapping("/deleteFile")
+    public Result<?> deleteFile(@RequestBody JSONObject param){
+        if (param != null) {
+            String path = param.get("path").toString();
+            String objectKey = path.replace(prefix, "");
+            obsUtil.delFile(objectKey);
+        }
+        return Result.OK();
+    }
+
     /**
      * 3.4 总体分析
      *

src/main/java/com/zzsn/event/es/EsService.java

@@ -120,6 +120,7 @@ public class EsService {
                 } else {
                     pageNo.getAndIncrement();
                 }
+                log.info("本次循环-{}，数据量为-{}", pageNo, subjectDataVos.size());
                 return subjectDataVos;
             });
             try {

src/main/resources/application-dev.yml

@@ -98,7 +98,7 @@ spring:
         max.request.size: 5242880 #5M
     consumer:
       #用于标识此使用者所属的使用者组的唯一字符串
-      group-id: event-analysis-group
+      group-id: event-analysis-group-dev
       #当Kafka中没有初始偏移量或者服务器上不再存在当前偏移量时该怎么办，默认值为latest，表示自动将偏移重置为最新的偏移量
       #可选的值为latest, earliest, none
       auto-offset-reset: latest