|
|
|
@ -120,6 +120,7 @@ public class DeviceBusinessProjectService extends ServiceImpl<DeviceBusinessProj
|
|
|
|
|
while (true) {
|
|
|
|
|
query.setPage(page);
|
|
|
|
|
BaseResponse<PageSimpleResponse<DeviceBusinessProject>> baseResponse = erpBasicClient.getDeviceBusinessProject(query);
|
|
|
|
|
log.error(String.valueOf(baseResponse));
|
|
|
|
|
if (baseResponse.getCode() == 20000) {
|
|
|
|
|
List<DeviceBusinessProject> list = baseResponse.getData().getList();
|
|
|
|
|
if (CollUtil.isNotEmpty(list)) {
|
|
|
|
@ -128,11 +129,15 @@ public class DeviceBusinessProjectService extends ServiceImpl<DeviceBusinessProj
|
|
|
|
|
item.setCreateTime(new Date());
|
|
|
|
|
item.setUpdateTime(new Date());
|
|
|
|
|
// TODO: 2024/12/6 物资系统的部门编码转化 自身系统的编码和名称
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
addList.add(item);
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(addList)){
|
|
|
|
|
this.saveBatch(addList);
|
|
|
|
|
addList.clear();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (list.size() >= limit && !baseResponse.getData().getTotal().equals(-666)) {
|
|
|
|
|
page++;
|
|
|
|
|
} else {
|
|
|
|
@ -141,15 +146,6 @@ public class DeviceBusinessProjectService extends ServiceImpl<DeviceBusinessProj
|
|
|
|
|
} else {
|
|
|
|
|
throw new JsonException("下载异常中断");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (addList.size() >= 500){
|
|
|
|
|
this.saveBatch(addList);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(addList)){
|
|
|
|
|
this.saveBatch(addList);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|