| | |
| | | import com.java110.dto.RoomDto; |
| | | import com.java110.dto.fee.FeeAttrDto; |
| | | import com.java110.dto.fee.FeeConfigDto; |
| | | import com.java110.dto.fee.FeeDto; |
| | | import com.java110.dto.owner.OwnerDto; |
| | | import com.java110.dto.owner.OwnerRoomRelDto; |
| | | import com.java110.dto.payFeeBatch.PayFeeBatchDto; |
| | |
| | | import com.java110.intf.community.IOwnerRoomRelV1InnerServiceSMO; |
| | | import com.java110.intf.community.IOwnerV1InnerServiceSMO; |
| | | import com.java110.intf.community.IRoomInnerServiceSMO; |
| | | import com.java110.intf.community.IRoomV1InnerServiceSMO; |
| | | import com.java110.intf.fee.*; |
| | | import com.java110.intf.user.IUserInnerServiceSMO; |
| | | import com.java110.po.fee.FeeAttrPo; |
| | |
| | | import com.java110.po.owner.OwnerPo; |
| | | import com.java110.po.owner.OwnerRoomRelPo; |
| | | import com.java110.po.payFeeBatch.PayFeeBatchPo; |
| | | import com.java110.po.room.RoomPo; |
| | | import com.java110.utils.constant.CommonConstant; |
| | | import com.java110.utils.exception.CmdException; |
| | | import com.java110.utils.util.Assert; |
| | |
| | | |
| | | @Autowired |
| | | private IRoomInnerServiceSMO roomInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl; |
| | | |
| | | @Override |
| | | public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { |
| | |
| | | if (flag < 1) { |
| | | throw new CmdException("操作业主失败"); |
| | | } |
| | | |
| | | RoomPo roomPo = new RoomPo(); |
| | | roomPo.setRoomId(rooms.getJSONObject(roomIndex).getString("roomId")); |
| | | roomPo.setCommunityId(reqJson.getString("communityId")); |
| | | roomPo.setState(RoomDto.STATE_SELL); |
| | | flag = roomV1InnerServiceSMOImpl.updateRoom(roomPo); |
| | | if (flag < 1) { |
| | | throw new CmdException("操作业主失败"); |
| | | } |
| | | } |
| | | |
| | | if (!reqJson.containsKey("fees")) { |
| | |
| | | |
| | | String time = DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A); |
| | | |
| | | if (paramInJson.containsKey("endTime")) { |
| | | time = paramInJson.getString("endTime"); |
| | | } else if (paramInJson.containsKey("startTime")) { |
| | | if (paramInJson.containsKey("startTime")) { |
| | | time = paramInJson.getString("startTime"); |
| | | } |
| | | |
| | |
| | | businessUnit.put("state", "2008001"); |
| | | businessUnit.put("batchId", reqJson.getString("batchId")); |
| | | businessUnit.put("userId", "-1"); |
| | | businessUnit.put("bId","-1"); |
| | | |
| | | payFeePo = BeanConvertUtil.covertBean(businessUnit, PayFeePo.class); |
| | | |
| | |
| | | if (flag < 1) { |
| | | throw new CmdException("保存费用失败"); |
| | | } |
| | | |
| | | if (FeeDto.FEE_FLAG_ONCE.equals(businessUnit.getString("feeFlag"))) { |
| | | feeAttrPo = addFeeAttr(businessUnit, FeeAttrDto.SPEC_CD_ONCE_FEE_DEADLINE_TIME, |
| | | paramInJson.containsKey("endTime") ? paramInJson.getString("endTime") : feeConfigDtos.get(0).getEndTime()); |
| | | flag = feeAttrInnerServiceSMOImpl.saveFeeAttr(feeAttrPo); |
| | | if (flag < 1) { |
| | | throw new CmdException("保存费用失败"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |