在线编辑文件无法被有效区分

2023-06-20 13:24:02 +08:00
parent 24d44f8eef
commit 896e1a6448
3 changed files with 82 additions and 3 deletions
@@ -6,11 +6,17 @@ import com.adc.da.slrs.OnlineFileLog.service.OnlineFileLogService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.amqp.rabbit.annotation.Exchange;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.QueueBinding;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;

+import java.util.*;
+
@RestController
@RequestMapping("/${restPath}/lawss/OnlineFileLog")
@Api(description = "|OnlineFileLog|")
@@ -29,4 +35,26 @@ public class OnlineFileLogController {
            return Result.error("转换失败");
        }
    }
+
+    @RabbitListener(bindings = @QueueBinding(
+            value = @Queue(value = "createBussMQ_onlineId_MQ_file", durable = "true"),
+            exchange = @Exchange(value = "create-onlineId_MQ_file", ignoreDeclarationExceptions = "true"),
+            key = "create-key_onlineId_MQ_file"))
+    public List<Object> createonlineIdMQ(Map<String,String> bussMap) throws Exception{
+         List<Object> obj = new ArrayList<>();
+        String onlineid = bussMap.get("ONLINEID");
+        if(StringUtils.isNotBlank(onlineid)){
+            String attFileIds = onlineFileLogService.selectOnlineFile(onlineid);
+            if(StringUtils.isNotBlank(attFileIds)){
+                String[] split = attFileIds.split(",");
+                if(split != null) {
+                     List<String> asList = Arrays.asList(split);
+                     for (String data : asList){
+                         obj.add(data);
+                     }
+                }
+            }
+        }
+        return obj;
+    }
 }