| | |
| | | private Api1112Rep api1112Rep; |
| | | @Autowired |
| | | private Api1113Rep api1113Rep; |
| | | @Autowired |
| | | private Api1501Rep api1501Rep; |
| | | @Autowired |
| | | private Api1502Rep api1502Rep; |
| | | @Autowired |
| | | private Api1503Rep api1503Rep; |
| | | |
| | | /** |
| | | * 1101 单位信息 |
| | | */ |
| | |
| | | |
| | | if (responseDto.getSuccess() == 0) { |
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
| | | api1102Rep.updateStatus(data.getDwdm(), Constant.CZBZ_U); |
| | | api1102Rep.updateStatus(data.getKqdm(), Constant.CZBZ_U); |
| | | } |
| | | } |
| | | } |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 财务报表 |
| | | * @param apiRemoteService |
| | | * @param param |
| | | */ |
| | | public void pushData1114(ApiRemoteService apiRemoteService, ApiParam param) { |
| | | this.pushData1501(apiRemoteService, param); |
| | | this.pushData1502(apiRemoteService, param); |
| | | this.pushData1503(apiRemoteService, param); |
| | | |
| | | } |
| | | /** |
| | | * 1501 财务报表-资产负债--单条上传 |
| | | */ |
| | | public void pushData1501(ApiRemoteService apiRemoteService, ApiParam param) { |
| | | //获取财务报表-资产负债 |
| | | List<Api1501> list = api1501Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
| | | |
| | | if (null == list || list.isEmpty()) { |
| | | log.error("-----未获取到资产负债信息,不推送-----"); |
| | | return; |
| | | } |
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
| | | param.setInteId(Constant.API_CODE_1114_1501); |
| | | ResponseDto responseDto; |
| | | for (Api1501 data : list) { |
| | | responseDto = apiRemoteService.pushData(param, data); |
| | | if (responseDto.getSuccess() == 0) { |
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
| | | |
| | | data.setCzbz(Constant.CZBZ_U); |
| | | //更新状态 |
| | | api1501Rep.save(data); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 1502 财务报表-现金流 |
| | | */ |
| | | public void pushData1502(ApiRemoteService apiRemoteService, ApiParam param) { |
| | | //获取财务报表-资产负债 |
| | | List<Api1502> list = api1502Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
| | | |
| | | if (null == list || list.isEmpty()) { |
| | | log.error("-----未获取到现金流信息,不推送-----"); |
| | | return; |
| | | } |
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
| | | param.setInteId(Constant.API_CODE_1114_1502); |
| | | ResponseDto responseDto; |
| | | for (Api1502 data : list) { |
| | | responseDto = apiRemoteService.pushData(param, data); |
| | | if (responseDto.getSuccess() == 0) { |
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
| | | |
| | | data.setCzbz(Constant.CZBZ_U); |
| | | //更新状态 |
| | | api1502Rep.save(data); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 1503 财务报表-利润信息 |
| | | */ |
| | | public void pushData1503(ApiRemoteService apiRemoteService, ApiParam param) { |
| | | //获取财务报表-资产负债 |
| | | List<Api1503> list = api1503Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
| | | |
| | | if (null == list || list.isEmpty()) { |
| | | log.error("-----未获取到利润信息,不推送-----"); |
| | | return; |
| | | } |
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
| | | param.setInteId(Constant.API_CODE_1114_1503); |
| | | ResponseDto responseDto; |
| | | Api1503 d; |
| | | for (Api1503 data : list) { |
| | | responseDto = apiRemoteService.pushData(param, data); |
| | | if (responseDto.getSuccess() == 0) { |
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
| | | |
| | | data.setCzbz(Constant.CZBZ_U); |
| | | //更新状态 |
| | | api1503Rep.save(data); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |