From d692bf007ca683c7fb46d2e3aef3714944da35fb Mon Sep 17 00:00:00 2001
From: liao <liao@syxysoft.com>
Date: Mon, 23 Oct 2023 18:20:28 +0800
Subject: [PATCH] =?UTF-8?q?add=20=E8=BF=9C=E7=A8=8B=E8=B0=83=E7=94=A8?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6=E4=B8=8B=E8=BD=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/LawsAsmsOpenApiServiceImpl.java    | 13 +++++++++++++
 .../modules/docking/asms/util/AsmsPostUtil.java     |  9 +++++++++
 2 files changed, 22 insertions(+)

diff --git a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
index bdc1cb14..339b5366 100644
--- a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
+++ b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.jero.common.util.MinioUtil;
 import com.jero.modules.docking.asms.entity.LawsAsmsDomestic;
 import com.jero.modules.docking.asms.entity.LawsAsmsOpenApi;
 import com.jero.modules.docking.asms.mapper.LawsAsmsOpenApiMapper;
@@ -459,6 +460,18 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
 				// 状态设置为已同步
 				lawsAsmsOpenApi.setStatus("1");
 				log.info("{}同步成功{}条数据", lawsAsmsOpenApi.getApiName(), lawsDomesticStandardList.size());
+			} else if ("3".equals(lawsAsmsOpenApi.getApiType()) && "xiaobodata/openApi/domesticLaws/getFile".equals(lawsAsmsOpenApi.getApiUrl())) {
+				// 国内法规相关文档
+				LambdaQueryWrapper<LawsAsmsDomestic> queryWrapper = new LambdaQueryWrapper<>();
+				queryWrapper.orderByAsc(LawsAsmsDomestic::getId);
+				List<LawsAsmsDomestic> lawsAsmsDomesticList = lawsAsmsDomesticService.list(queryWrapper);
+				lawsAsmsDomesticList.forEach(lawsAsmsDomestic -> {
+					Map<String, String> paramMap = new HashMap<>();
+					paramMap.put("lawCode", lawsAsmsDomestic.getCode());
+					List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(lawsAsmsOpenApi.getApiUrl(), paramMap);
+					Map<String, String> eMap = mapList.get(0);
+					//MinioUtil.upload();
+				});
 			}
 		});
 		// 同步接口的状态
diff --git a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/util/AsmsPostUtil.java b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/util/AsmsPostUtil.java
index 146712a1..31669c24 100644
--- a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/util/AsmsPostUtil.java
+++ b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/util/AsmsPostUtil.java
@@ -15,6 +15,9 @@ import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
 import org.springframework.web.client.RestTemplate;
 
+import java.io.File;
+import java.io.IOException;
+import java.nio.file.Files;
 import java.util.*;
 
 /**
@@ -125,4 +128,10 @@ public class AsmsPostUtil {
         return mapList;
     }
 
+    public byte[] getFileByteArray(String fileUrl) {
+        // 执行GET请求
+        ResponseEntity<byte[]> response = restTemplate.getForEntity(host + fileUrl, byte[].class);
+        return response.getBody();
+    }
+
 }