Commit e2816f8f by yinyong

数据中心--大数据量记录分页

parent 337e0325
...@@ -66,10 +66,13 @@ public class SkuMappingSyncJob extends PointJob { ...@@ -66,10 +66,13 @@ public class SkuMappingSyncJob extends PointJob {
if (StringUtils.isNotBlank(resultStr)) { if (StringUtils.isNotBlank(resultStr)) {
SkuMappingResponse skuMappingResponse = JSONObject.parseObject(resultStr, SkuMappingResponse.class); SkuMappingResponse skuMappingResponse = JSONObject.parseObject(resultStr, SkuMappingResponse.class);
JobPointLogMapper pointLogMapper = SessionUtil.getSession().getMapper(JobPointLogMapper.class);
pointLogMapper.upsertSelective(jobPointLog);
if (skuMappingResponse.getData()!= null && skuMappingResponse.getData().size() > 0) { if (skuMappingResponse.getData()!= null && skuMappingResponse.getData().size() > 0) {
List<DcBaseSkuMapping> skuMappingInfoList = skuMappingResponse.getData(); List<DcBaseSkuMapping> skuMappingInfoList = skuMappingResponse.getData();
for(DcBaseSkuMapping dcBaseSkuMapping : skuMappingInfoList) { for(DcBaseSkuMapping dcBaseSkuMapping : skuMappingInfoList) {
log.warn("请求参数:"+map+ " 返回结果:" + dcBaseSkuMapping); log.warn("请求参数:"+map+ " 返回结果:" + dcBaseSkuMapping);
dcBaseSkuMapping.setGmtModified(LocalDateTime.now());
DcBaseSkuMappingMapper dcBaseSkuMappingMapper = SessionUtil.getSession().getMapper(DcBaseSkuMappingMapper.class); DcBaseSkuMappingMapper dcBaseSkuMappingMapper = SessionUtil.getSession().getMapper(DcBaseSkuMappingMapper.class);
dcBaseSkuMappingMapper.upsertSelective(dcBaseSkuMapping); dcBaseSkuMappingMapper.upsertSelective(dcBaseSkuMapping);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment