| | |
|---|
| | | private void doImportData(AssetImportLogDetailDto assetImportLogDetailDto) { |
|---|
| | | JSONObject data = JSONObject.parseObject(assetImportLogDetailDto.getContent()); |
|---|
| | | MeterWaterPo po = BeanConvertUtil.covertBean(data, MeterWaterPo.class); |
|---|
| | | if (po.getCommunityId() == null) { |
|---|
| | | throw new IllegalArgumentException("未查询到小区：" + po.getCommunityCode() + po.getCommunityName()); |
|---|
| | | } |
|---|
| | | validateRoom(po, assetImportLogDetailDto); |
|---|
| | | addFee(po, data, assetImportLogDetailDto.getLogId(), assetImportLogDetailDto); |
|---|
| | | int i = 1; |
|---|
| | | try { |
|---|
| | | Thread.sleep(100); |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void addFee(MeterWaterPo po, JSONObject reqJson, String batchId, AssetImportLogDetailDto assetImportLogDetailDto) { |
|---|
| | |
|---|
| | | // } |
|---|
| | | // po.setObjId(importOwnerRoomDto.getRoomId()); |
|---|
| | | } else if (roomDtos.size() > 1) { |
|---|
| | | throw new IllegalArgumentException("存在重复的房屋：" + po.getObjName()); |
|---|
| | | po.setObjId("1"); |
|---|
| | | po.setRemark3("\n\n房屋：" + |
|---|
| | | roomDto.getCommunityId() + "-" + roomDto.getRoadName() + "-" + roomDto.getFloorNum() + "-" + roomDto.getUnitNum() + "-" + |
|---|
| | | roomDto.getRoomNum() + "不存在，该费用存入公司账户"); |
|---|
| | | } else { |
|---|
| | | po.setObjId(roomDtos.get(0).getRoomId()); |
|---|
| | | } |
|---|
