add 远程调用文件下载

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();
+				});
 			}
 		});
 		// 同步接口的状态

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();
+    }
+
 }