diff --git a/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbChsHttpClient.java b/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbChsHttpClient.java index d486b7d..ba336fc 100644 --- a/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbChsHttpClient.java +++ b/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbChsHttpClient.java @@ -58,7 +58,7 @@ public class ChsYbChsHttpClient { params.put("sord", "asc"); params.put("specificationCode", "C"); try { - Thread.sleep(20000); + Thread.sleep(15000); } catch (InterruptedException e) { e.printStackTrace(); } @@ -78,7 +78,7 @@ public class ChsYbChsHttpClient { params.put("sord", "asc"); params.put("specificationCode", specificationCode); try { - Thread.sleep(15000); + Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } diff --git a/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxGgService.java b/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxGgService.java index 57e3c11..7879283 100644 --- a/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxGgService.java +++ b/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxGgService.java @@ -39,6 +39,7 @@ public class ChsYbHcxxGgService extends ServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.select("specificationCode"); +// queryWrapper.ge("specificationCode","C0314010870100110845"); queryWrapper.orderByAsc("specificationCode"); ybHcxxMapper.selectPage(page, queryWrapper); @@ -54,6 +55,7 @@ public class ChsYbHcxxGgService extends ServiceImpl records2 = page.getRecords(); records2.forEach( x->{ @@ -76,11 +78,12 @@ public class ChsYbHcxxGgService extends ServiceImplpageNum){ for (int i = 2; i <= total ; i++) { - System.out.println("更新数据库的YbHcxxGg列表数据"+ i); + System.out.println("更新数据库的YbHcxxGg列表数据:"+specificationCode + "第"+ i+"页"); processUpdates(ybChsHttpClient.getYbHcxxGgList(specificationCode,i, pageSize)); } } @@ -94,6 +97,7 @@ public class ChsYbHcxxGgService extends ServiceImpl list = ybHcxxGgResponse.getRows(); List ybHcxxGgEntities = BeanUtil.copyToList(list, YbHcxxGgEntity.class); + if (CollectionUtil.isNotEmpty(ybHcxxGgEntities)) ybHcxxGgMapper.batchSaveOrUpdateBySpecificationCode(ybHcxxGgEntities); } diff --git a/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxService.java b/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxService.java index 053783e..49202a6 100644 --- a/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxService.java +++ b/src/main/java/com/glxp/udidl/admin/service/chsapi/ChsYbHcxxService.java @@ -33,7 +33,7 @@ public class ChsYbHcxxService extends ServiceImpl { processUpdates(ybHcxxResponse); //处理后续数据 if (total>pageNum){ - for (int i = 2; i <= total ; i++) { + for (int i = 2 ; i <= total ; i++) { System.out.println("更新数据库的YbHcxx列表数据"+ i); processUpdates(ybChsHttpClient.getYbHcxxList(i, pageSize)); }