Commit 8ff8da3d by wutong

修复同步SKU降序查漏最大页数的问题

parent 3e6b8c55
...@@ -99,7 +99,7 @@ public class SkuJsonHandle { ...@@ -99,7 +99,7 @@ public class SkuJsonHandle {
} }
//如果是0, 则保存总页数, 降序查 //如果是0, 则保存总页数, 降序查
if (jobPointLog.getPageIndex().equals(0)) { if (jobPointLog.getPageIndex().equals(0)) {
jobPointLog.setPageIndex(jsonObject1.getIntValue("TotalPages")); jobPointLog.setPageIndex(jsonObject1.getIntValue("TotalPages") + 1);
} }
/* /*
* 转化JSON, * 转化JSON,
...@@ -117,13 +117,11 @@ public class SkuJsonHandle { ...@@ -117,13 +117,11 @@ public class SkuJsonHandle {
throw new RuntimeException("调用同步SKU信息接口失败"); throw new RuntimeException("调用同步SKU信息接口失败");
} }
jobPointLog.setPageIndex(jobPointLog.getPageIndex() - 1); jobPointLog.setPageIndex(jobPointLog.getPageIndex() - 1);
if (jobPointLog.getPageIndex() % 10 == 0) { if (jobPointLog.getPageIndex() % 5 == 0) {
try { try {
JobPointLogMapper jobPointLogMapper = SessionUtil.getSession().getMapper(JobPointLogMapper.class); JobPointLogMapper jobPointLogMapper = SessionUtil.getSession().getMapper(JobPointLogMapper.class);
jobPointLogMapper.upsertSelective(jobPointLog); jobPointLogMapper.upsertSelective(jobPointLog);
SessionUtil.getSession().commit();
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
throw new RuntimeException("MYBATIS操作DB失败", e); throw new RuntimeException("MYBATIS操作DB失败", e);
} finally { } finally {
SessionUtil.closeSession(); SessionUtil.closeSession();
...@@ -143,8 +141,7 @@ public class SkuJsonHandle { ...@@ -143,8 +141,7 @@ public class SkuJsonHandle {
try { try {
BeanUtils.copyProperties(dcBaseSku, skuProductInfo); BeanUtils.copyProperties(dcBaseSku, skuProductInfo);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); throw new RuntimeException("BeanUtils.copyProperties失败");
throw new RuntimeException();
} }
if (StringUtils.isNotBlank(dcBaseSku.getWarehouseCode())) { if (StringUtils.isNotBlank(dcBaseSku.getWarehouseCode())) {
DcBaseWarehouseMapper dcBaseWarehouseMapper = SessionUtil.getSession().getMapper(DcBaseWarehouseMapper.class); DcBaseWarehouseMapper dcBaseWarehouseMapper = SessionUtil.getSession().getMapper(DcBaseWarehouseMapper.class);
...@@ -167,7 +164,6 @@ public class SkuJsonHandle { ...@@ -167,7 +164,6 @@ public class SkuJsonHandle {
} }
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
throw new RuntimeException("MYBATIS操作DB失败", e); throw new RuntimeException("MYBATIS操作DB失败", e);
} finally { } finally {
SessionUtil.closeSession(); SessionUtil.closeSession();
......
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