ZQ/laws-sinotruk-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update ASMS定时同步

Browse Source
This commit is contained in:
liao
2023-11-09 13:32:17 +08:00
parent a3660770d1
commit ad315b3f5f
2 changed files with 22 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
+18
View File
@@ -310,6 +310,15 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
lawsAsmsOpenApi.setStatus("1"); lawsAsmsOpenApi.setStatus("1");
} else if ("3".equals(lawsAsmsOpenApi.getApiType()) && "xiaobodata/openApi/domesticLaws/list".equals(lawsAsmsOpenApi.getApiUrl())) { } else if ("3".equals(lawsAsmsOpenApi.getApiType()) && "xiaobodata/openApi/domesticLaws/list".equals(lawsAsmsOpenApi.getApiUrl())) {
// 如果是国内法规，并且url为国内法规标准检索列表 // 如果是国内法规，并且url为国内法规标准检索列表
// 法规列表
String url = "xiaobodata/openApi/domesticLaws/list";
map.put("pageNo", "1");
map.put("pageSize", "2");
Map<String, Object> totalMap = asmsPostUtil.sendGetReq2(url, map);
Integer total = (Integer) totalMap.get("total");
map.put("pageSize", total.toString());
List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(lawsAsmsOpenApi.getApiUrl(), map); List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(lawsAsmsOpenApi.getApiUrl(), map);
if (CollectionUtils.isNotEmpty(mapList)) { if (CollectionUtils.isNotEmpty(mapList)) {
List<LawsAsmsDomestic> lawsAsmsDomesticList = new ArrayList(); List<LawsAsmsDomestic> lawsAsmsDomesticList = new ArrayList();
@@ -522,6 +531,15 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
lawsAsmsOpenApi.setStatus("1"); lawsAsmsOpenApi.setStatus("1");
log.info("{}同步成功{}条数据", lawsAsmsOpenApi.getApiName(), lawsAsmsDomesticList.size()); log.info("{}同步成功{}条数据", lawsAsmsOpenApi.getApiName(), lawsAsmsDomesticList.size());
} else if ("3".equals(lawsAsmsOpenApi.getApiType()) && "xiaobodata/openApi/article/search".equals(lawsAsmsOpenApi.getApiUrl())) { } else if ("3".equals(lawsAsmsOpenApi.getApiType()) && "xiaobodata/openApi/article/search".equals(lawsAsmsOpenApi.getApiUrl())) {
// 文档拆分
String url = "xiaobodata/openApi/article/search";
map.put("pageNo", "1");
map.put("pageSize", "2");
Map<String, Object> totalMap = asmsPostUtil.sendGetReq2(url, map);
Integer total = (Integer) totalMap.get("total");
map.put("pageSize", total.toString());
// 如果是国内法规，并且url为法规条文检索国内法规列表 // 如果是国内法规，并且url为法规条文检索国内法规列表
List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(lawsAsmsOpenApi.getApiUrl(), map); List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(lawsAsmsOpenApi.getApiUrl(), map);
mapList.forEach(eMap -> { mapList.forEach(eMap -> {
laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/SynchronizationAsmsService.java
+4 -4
View File
@@ -109,8 +109,8 @@ public class SynchronizationAsmsService {
paramMap.put("pageNo", "1"); paramMap.put("pageNo", "1");
paramMap.put("pageSize", "2"); paramMap.put("pageSize", "2");
Map<String, Object> totalMap = asmsPostUtil.sendGetReq2(url, paramMap); Map<String, Object> totalMap = asmsPostUtil.sendGetReq2(url, paramMap);
String total = (String) totalMap.get("total"); Integer total = (Integer) totalMap.get("total");
paramMap.put("pageSize", total); paramMap.put("pageSize", total.toString());
List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(url, paramMap); List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(url, paramMap);
if (Objects.isNull(mapList)) { if (Objects.isNull(mapList)) {
@@ -295,8 +295,8 @@ public class SynchronizationAsmsService {
paramMap.put("pageNo", "1"); paramMap.put("pageNo", "1");
paramMap.put("pageSize", "2"); paramMap.put("pageSize", "2");
Map<String, Object> totalMap = asmsPostUtil.sendGetReq2(url, paramMap); Map<String, Object> totalMap = asmsPostUtil.sendGetReq2(url, paramMap);
String total = (String) totalMap.get("total"); Integer total = (Integer) totalMap.get("total");
paramMap.put("pageSize", total); paramMap.put("pageSize", total.toString());
List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(url, paramMap); List<Map<String, String>> mapList = asmsPostUtil.sendGetReq(url, paramMap);
if (Objects.isNull(mapList)) { if (Objects.isNull(mapList)) {