| | |
|---|
| | | addFee(po, data, assetImportLogDetailDto.getLogId(), assetImportLogDetailDto); |
|---|
| | | int i = 1; |
|---|
| | | try { |
|---|
| | | Thread.sleep(1000); |
|---|
| | | Thread.sleep(200); |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
| | |
|---|
| | | private void addFee(MeterWaterPo po, JSONObject reqJson, String batchId, AssetImportLogDetailDto assetImportLogDetailDto) { |
|---|
| | | PayFeePo payFeePo = BeanConvertUtil.covertBean(reqJson, PayFeePo.class); |
|---|
| | | payFeePo.setAmount(po.getUnitPrice()); |
|---|
| | | if (payFeePo.getAmount().equals("")){ |
|---|
| | | if (payFeePo.getAmount() == null){ |
|---|
| | | payFeePo.setAmount("-1"); |
|---|
| | | } |
|---|
| | | // payFeePo.setSecondaryFeeTypeCd("888800010190"); |
|---|
| | |
|---|
| | | feeAttrPo.setFeeId(payFeePo.getFeeId()); |
|---|
| | | feeAttrPo.setAttrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId)); |
|---|
| | | meterWaterInnerServiceSMOImpl.saveMeterWaters(meterWaterPos); |
|---|
| | | |
|---|
| | | payFeePo.setTest("导入信息，先不处理离散月"); |
|---|
| | | int flag = payFeeV1InnerServiceSMOImpl.savePayFee(payFeePo); |
|---|
| | | |
|---|
| | | if (flag < 1) { |
|---|
| | | throw new CmdException("保存数据失败"); |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | OwnerDto ownerDto = new OwnerDto(); |
|---|
| | | ownerDto.setCommunityId(reqJson.getString("communityId")); |
|---|
| | | ownerDto.setRoomId(reqJson.getString("objId")); |
|---|
| | | // ownerDto.setCommunityId(reqJson.getString("communityId")); |
|---|
| | | ownerDto.setRoomId(po.getObjId()); |
|---|
| | | List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwnersByRoom(ownerDto); |
|---|
| | | |
|---|
| | | if (ownerDtos != null && ownerDtos.size() > 0) { |
|---|
