| | |
| | | } |
| | | //查询费用信息arrearsEndTime |
| | | List<RoomDto> tmpRoomDtos = new ArrayList<>(); |
| | | List<RoomDto> tempRooms = new ArrayList<>(); |
| | | //List<RoomDto> tempRooms = new ArrayList<>(); |
| | | int threadNum = Java110ThreadPoolFactory.JAVA110_DEFAULT_THREAD_NUM; |
| | | for (int roomIndex = 0; roomIndex < roomDtos.size(); roomIndex++) { |
| | | tempRooms.add(roomDtos.get(roomIndex)); |
| | | if (roomIndex % threadNum == 0 && roomIndex != 0) { |
| | | tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, threadNum)); |
| | | tempRooms = new ArrayList(); |
| | | } |
| | | } |
| | | if (tempRooms.size() > 0) { |
| | | tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, tempRooms.size())); |
| | | } |
| | | //for (int roomIndex = 0; roomIndex < roomDtos.size(); roomIndex++) { |
| | | // tempRooms.add(roomDtos.get(roomIndex)); |
| | | //if (roomIndex % threadNum == 0 && roomIndex != 0) { |
| | | // tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, threadNum)); |
| | | // tempRooms = new ArrayList(); |
| | | // } |
| | | // } |
| | | // if (tempRooms.size() > 0) { |
| | | // tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, tempRooms.size())); |
| | | // } |
| | | |
| | | tmpRoomDtos.addAll(doGetTmpRoomDto(roomDtos, feeDto, threadNum)); |
| | | |
| | | return ResultVo.createResponseEntity(tmpRoomDtos); |
| | | } |
| | |
| | | }); |
| | | } |
| | | return java110ThreadPoolFactory.get(); |
| | | }finally { |
| | | if(java110ThreadPoolFactory != null){ |
| | | } finally { |
| | | if (java110ThreadPoolFactory != null) { |
| | | java110ThreadPoolFactory.stop(); |
| | | } |
| | | } |
| | |
| | | tmpFeeDto.setState(FeeDto.STATE_DOING); |
| | | tmpFeeDto.setPayerObjId(tmpRoomDto.getRoomId()); |
| | | tmpFeeDto.setPayerObjType(FeeDto.PAYER_OBJ_TYPE_ROOM); |
| | | List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto); |
| | | List<FeeDto> feeDtos = feeInnerServiceSMOImpl.querySimpleFees(tmpFeeDto); |
| | | |
| | | if (feeDtos == null || feeDtos.size() < 1) { |
| | | return null; |