while (!isLastPage) { // 封装请求头 ResponseEntity<String> responseEntity = restTemplate.exchange(StrUtil.format(djUrl, qssj, zzsj, page, limit), HttpMethod.GET, formEntity, String.class); JSONObject response = JSONUtil.parseObj(responseEntity.getBody()); log.info("调用登记信息查询接口返回:{}",responseEntity.getBody()); if (!"200".equals(response.getStr("code"))) { log.info("调用登记信息查询接口返回不是成功:{}_{}", response.get("code"), response.get("msg")); break; } List<BdBdcDj> djList = new ArrayList<>(); List<BdMessage> messageList = new ArrayList<>(); // 解析数据 JSONArray data = response.getJSONArray("data"); data.toList(JSONObject.class).forEach(jsonObject -> { String bsm = jsonObject.getStr("bsm"); // 如果数据库已存在本条记录,则忽略 if (bdBdcDjDao.selectByPrimaryKey(bsm) == null) { // 使用 MapperUtils.map 枚举字段设置有问题,勿改 BdBdcDj bdBdcDj = BeanUtil.mapToBean(jsonObject, BdBdcDj.class, false, null); bdBdcDj.setId(bsm); bdBdcDj.setHouseId(jsonObject.getStr("hbsm")); bdBdcDj.setDivisionCode(jsonObject.getStr("qxdm")); // 如果是转移登记则待处理 if ("C".equals(jsonObject.getStr("djlx"))) { bdBdcDj.setResolveStatus(ResolveStatusEnum.WAITING); // 如果是转移登记则如bdMessage,并推送维资 BdMessage msg = getMessageByDj(bdBdcDj); messageList.add(msg); } else { bdBdcDj.setResolveStatus(ResolveStatusEnum.NO_NEED); } djList.add(bdBdcDj); } });
时间: 2024-02-10 15:34:03 浏览: 170
Repeater控件分页例子
4星 · 用户满意度95%
看起来您的代码主要是调用接口返回数据并解析数据,然后对数据进行处理,并将数据插入数据库。
以下是一些可供优化的建议:
1.尝试将一些重复的代码封装成方法,以提高代码的重用性和可读性。
2.对于大量的数据解析和处理,可以考虑使用多线程或并发编程技术,以提高代码的运行效率。
3.在处理大量数据时,可以考虑将数据分批处理,以避免出现内存溢出等问题。
4.尽量减少对数据库的查询次数,可以通过批量插入等技术来提高代码的运行效率。
5.在处理数据时,可以使用工具类或框架来简化代码,提高开发效率和可读性。
6.优化日志输出,尽量避免在循环中不必要的日志输出,以提高代码的运行效率。
希望这些建议能够对您有所帮助。
阅读全文