| | |
| | | import com.java110.dto.floor.FloorDto; |
| | | import com.java110.dto.room.RoomDto; |
| | | import com.java110.dto.unit.UnitDto; |
| | | import com.java110.dto.fee.FeeAttrDto; |
| | | import com.java110.dto.fee.FeeDto; |
| | | import com.java110.dto.owner.OwnerCarDto; |
| | | import com.java110.dto.owner.OwnerDto; |
| | | import com.java110.dto.owner.OwnerRoomRelDto; |
| | | import com.java110.dto.parking.ParkingSpaceDto; |
| | | import com.java110.intf.community.IFloorInnerServiceSMO; |
| | | import com.java110.intf.community.IParkingSpaceInnerServiceSMO; |
| | | import com.java110.intf.community.IRoomInnerServiceSMO; |
| | | import com.java110.intf.community.IUnitInnerServiceSMO; |
| | | import com.java110.intf.fee.IFeeAttrInnerServiceSMO; |
| | | import com.java110.intf.fee.IFeeInnerServiceSMO; |
| | | import com.java110.intf.user.IOwnerCarInnerServiceSMO; |
| | | import com.java110.intf.user.IOwnerInnerServiceSMO; |
| | | import com.java110.intf.user.IOwnerRoomRelV1InnerServiceSMO; |
| | | import com.java110.po.fee.FeeAttrPo; |
| | | import com.java110.utils.cache.MappingCache; |
| | | import com.java110.utils.exception.CmdException; |
| | | import com.java110.utils.util.*; |
| | |
| | | import org.springframework.http.ResponseEntity; |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.text.DecimalFormat; |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | |
| | | private static Logger logger = LoggerFactory.getLogger(ListFeeCmd.class); |
| | | |
| | | @Autowired |
| | | private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IFeeInnerServiceSMO feeInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IFeeAttrInnerServiceSMO feeAttrInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IComputeFeeSMO computeFeeSMOImpl; |
| | |
| | | |
| | | @Autowired |
| | | private IOwnerRoomRelV1InnerServiceSMO ownerRoomRelV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IOwnerGetDataCheck ownerGetDataCheckImpl; |
| | |
| | | |
| | | @Override |
| | | public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { |
| | | if (reqJson.containsKey("roomNum") && !StringUtil.isEmpty(reqJson.getString("roomNum"))) { |
| | | String[] roomNums = reqJson.getString("roomNum").split("-"); |
| | | if (roomNums == null || roomNums.length != 3) { |
| | | throw new IllegalArgumentException("房屋编号格式不对!"); |
| | | } |
| | | RoomDto roomDto = new RoomDto(); |
| | | roomDto.setCommunityId(reqJson.getString("communityId")); |
| | | roomDto.setFloorNum(roomNums[0]); |
| | | roomDto.setUnitNum(roomNums[1]); |
| | | roomDto.setRoomNum(roomNums[2]); |
| | | List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto); |
| | | Assert.listOnlyOne(roomDtos, "找不到房屋信息!"); |
| | | } |
| | | // todo 房屋名称 刷入 房屋ID |
| | | freshPayerObjIdByRoomNum(reqJson); |
| | | |
| | |
| | | int count = feeInnerServiceSMOImpl.queryFeesCount(feeDto); |
| | | if (count > 0) { |
| | | List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);//查询费用项目 |
| | | computeFeePrice(feeDtos);//计算费用 |
| | | //todo 计算费用 |
| | | computeFeePrice(feeDtos); |
| | | List<ApiFeeDataVo> apiFeeDataVos = BeanConvertUtil.covertBeanList(feeDtos, ApiFeeDataVo.class); |
| | | for (ApiFeeDataVo apiFeeDataVo : apiFeeDataVos) { |
| | | //获取付费对象类型 |
| | |
| | | if (!reqJson.containsKey("payerObjIds") || StringUtil.isEmpty(reqJson.getString("payerObjIds"))) { |
| | | return; |
| | | } |
| | | |
| | | String payerObjIds = reqJson.getString("payerObjIds"); |
| | | feeDto.setPayerObjIds(payerObjIds.split(",")); |
| | | } |
| | |
| | | if (!reqJson.containsKey("roomNum") || StringUtil.isEmpty(reqJson.getString("roomNum"))) { |
| | | return; |
| | | } |
| | | |
| | | String[] roomNums = reqJson.getString("roomNum").split("-", 3); |
| | | if (roomNums == null || roomNums.length != 3) { |
| | | throw new IllegalArgumentException("房屋编号格式错误!"); |
| | | } |
| | | |
| | | String floorNum = roomNums[0]; |
| | | String unitNum = roomNums[1]; |
| | | String roomNum = roomNums[2]; |
| | |
| | | floorDto.setFloorNum(floorNum); |
| | | floorDto.setCommunityId(reqJson.getString("communityId")); |
| | | List<FloorDto> floorDtos = floorInnerServiceSMOImpl.queryFloors(floorDto); |
| | | if (floorDtos == null || floorDtos.size() < 1) { |
| | | if (ListUtil.isNull(floorDtos)) { |
| | | return; |
| | | } |
| | | for (FloorDto floor : floorDtos) { |
| | |
| | | } |
| | | |
| | | private void freshFeeAttrs(List<ApiFeeDataVo> fees, List<FeeDto> feeDtos) { |
| | | String link = ""; |
| | | //todo 影响查询性能 注释 by wuxw |
| | | // for (FeeDto feeDto : feeDtos) { |
| | | // if (FeeDto.PAYER_OBJ_TYPE_ROOM.equals(feeDto.getPayerObjType())) { //房屋 |
| | | // OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto(); |
| | | // ownerRoomRelDto.setRoomId(feeDto.getPayerObjId()); |
| | | // List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelV1InnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto); |
| | | // if (ownerRoomRelDtos == null || ownerRoomRelDtos.size() < 1) { |
| | | // continue; |
| | | // } |
| | | // OwnerDto ownerDto = new OwnerDto(); |
| | | // ownerDto.setMemberId(ownerRoomRelDtos.get(0).getOwnerId()); |
| | | // List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwners(ownerDto); |
| | | // Assert.listOnlyOne(ownerDtos, "查询业主错误!"); |
| | | // link = ownerDtos.get(0).getLink(); |
| | | // } else if (FeeDto.PAYER_OBJ_TYPE_CAR.equals(feeDto.getPayerObjType())) { |
| | | // OwnerCarDto ownerCarDto = new OwnerCarDto(); |
| | | // ownerCarDto.setMemberId(feeDto.getPayerObjId()); |
| | | // List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto); |
| | | // Assert.listOnlyOne(ownerCarDtos, "查询业主车辆表错误!"); |
| | | // OwnerDto ownerDto = new OwnerDto(); |
| | | // ownerDto.setMemberId(ownerCarDtos.get(0).getOwnerId()); |
| | | // List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwners(ownerDto); |
| | | // Assert.listOnlyOne(ownerDtos, "查询业主错误!"); |
| | | // link = ownerDtos.get(0).getLink(); |
| | | // } |
| | | // FeeAttrDto feeAttrDto = new FeeAttrDto(); |
| | | // feeAttrDto.setFeeId(feeDto.getFeeId()); |
| | | // List<FeeAttrDto> feeAttrDtos = feeAttrInnerServiceSMOImpl.queryFeeAttrs(feeAttrDto); |
| | | // if (feeAttrDtos == null || feeAttrDtos.size() < 1) { |
| | | // continue; |
| | | // } |
| | | // for (FeeAttrDto feeAttr : feeAttrDtos) { |
| | | // if (!FeeAttrDto.SPEC_CD_OWNER_LINK.equals(feeAttr.getSpecCd())) { //联系方式 |
| | | // continue; |
| | | // } |
| | | // if (feeAttr.getValue().equals(link)) { |
| | | // continue; |
| | | // } |
| | | // FeeAttrPo feeAttrPo = new FeeAttrPo(); |
| | | // feeAttrPo.setAttrId(feeAttr.getAttrId()); |
| | | // feeAttrPo.setValue(link); |
| | | // int flag = feeAttrInnerServiceSMOImpl.updateFeeAttr(feeAttrPo); |
| | | // if (flag < 1) { |
| | | // throw new CmdException("更新业主联系方式失败"); |
| | | // } |
| | | // |
| | | // } |
| | | // } |
| | | for (ApiFeeDataVo apiFeeDataVo : fees) { |
| | | for (FeeDto feeDto : feeDtos) { |
| | | if (apiFeeDataVo.getFeeId().equals(feeDto.getFeeId())) { |
| | |
| | | } |
| | | |
| | | private void computeFeePrice(List<FeeDto> feeDtos) { |
| | | if (feeDtos == null || feeDtos.isEmpty()) { |
| | | if (ListUtil.isNull(feeDtos)) { |
| | | return; |
| | | } |
| | | String val = CommunitySettingFactory.getValue(feeDtos.get(0).getCommunityId(), TOTAL_FEE_PRICE); |
| | |
| | | Date targetEndDate = (Date) targetEndDateAndOweMonth.get("targetEndDate"); |
| | | double oweMonth = (double) targetEndDateAndOweMonth.get("oweMonth"); |
| | | feeDto.setCycle(feeDto.getPaymentCycle()); |
| | | //todo 这里考虑 账单模式的场景 |
| | | if (FeeDto.FEE_FLAG_ONCE.equals(feeDto.getFeeFlag())) { |
| | | feeDto.setCycle(oweMonth + ""); |
| | | } |
| | | feeDto.setDeadlineTime(targetEndDate); |
| | | //todo 算费 |
| | | doComputeFeePrice(feeDto, oweMonth); |
| | |
| | | } |
| | | //考虑租金递增 |
| | | computeFeeSMOImpl.dealRentRate(feeDto); |
| | | |
| | | } |
| | | |
| | | |
| | | } |