| | |
| | | String apiUrl = ""; |
| | | ResponseEntity<String> responseEntity = null; |
| | | JSONObject reqJson = JSONObject.parseObject(pd.getReqData()); |
| | | apiUrl = ServiceConstant.SERVICE_API_URL + "/api/feeApi/listAllRoomOweFees" + mapToUrlParam(reqJson); |
| | | apiUrl = "/feeApi/listAllRoomOweFees" + mapToUrlParam(reqJson); |
| | | responseEntity = this.callCenterService(restTemplate, pd, "", apiUrl, HttpMethod.GET); |
| | | |
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { //跳过 保存单元信息 |
| | |
| | | |
| | | //查询催缴单二维码 |
| | | JSONObject feePrint = null; |
| | | apiUrl = ServiceConstant.SERVICE_API_URL + "/api/feePrintSpec/queryFeePrintSpec?page=1&row=1&specCd=1010&communityId=" + result.getCommunityId(); |
| | | apiUrl = "/feePrintSpec/queryFeePrintSpec?page=1&row=1&specCd=1010&communityId=" + result.getCommunityId(); |
| | | responseEntity = this.callCenterService(restTemplate, pd, "", apiUrl, HttpMethod.GET); |
| | | if (responseEntity.getStatusCode() == HttpStatus.OK) { |
| | | JSONObject feePrintResults = JSONObject.parseObject(responseEntity.getBody(), Feature.OrderedField); |
| | |
| | | private JSONArray getExistsRoomFee(IPageData pd, ComponentValidateResult result) { |
| | | String apiUrl = ""; |
| | | ResponseEntity<String> responseEntity = null; |
| | | apiUrl = ServiceConstant.SERVICE_API_URL + "/api/feeManualCollection/queryExportCollections?communityId=" + result.getCommunityId(); |
| | | apiUrl = "/feeManualCollection/queryExportCollections?communityId=" + result.getCommunityId(); |
| | | responseEntity = this.callCenterService(restTemplate, pd, "", apiUrl, HttpMethod.GET); |
| | | |
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { //跳过 保存单元信息 |
| | |
| | | this.restTemplate = restTemplate; |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | Java110ThreadPoolFactory<String> pool = Java110ThreadPoolFactory.getInstance().createThreadPool(20); |
| | | for (int i = 21; i > 0; i--) { |
| | | Integer data = i; |
| | | pool.submit(() -> { |
| | | //这个地方可以写一个函数,参数可以从外层传入 |
| | | System.out.println("网络操作开始" + data); |
| | | Thread.sleep(data * 1000); |
| | | System.out.println("网络操作结束" + data); |
| | | return data + ""; |
| | | }); |
| | | } |
| | | List<String> users = pool.get(); |
| | | for (String u : users) { |
| | | System.out.println(u); |
| | | } |
| | | pool.stop(); |
| | | } |
| | | |
| | | } |