| | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.java110.core.annotation.Java110Cmd; |
| | | import com.java110.core.context.ICmdDataFlowContext; |
| | | import com.java110.core.event.cmd.AbstractServiceCmdListener; |
| | | import com.java110.core.event.cmd.Cmd; |
| | | import com.java110.core.event.cmd.CmdEvent; |
| | | import com.java110.core.factory.GenerateCodeFactory; |
| | | import com.java110.dto.RoomDto; |
| | |
| | | import java.util.List; |
| | | |
| | | @Java110Cmd(serviceCode = "fee.saveRoomCreateFee") |
| | | public class SaveRoomCreateFeeCmd extends AbstractServiceCmdListener { |
| | | public class SaveRoomCreateFeeCmd extends Cmd { |
| | | |
| | | private static final int DEFAULT_ADD_FEE_COUNT = 200; |
| | | |
| | |
| | | int saveFlag = 0; |
| | | for (int roomIndex = 0; roomIndex < roomDtos.size(); roomIndex++) { |
| | | curFailRoomCount++; |
| | | //businesses.add(); |
| | | |
| | | //加入 房屋费用 |
| | | feePos.add(BeanConvertUtil.covertBean(feeBMOImpl.addRoomFee(roomDtos.get(roomIndex), reqJson, context), PayFeePo.class)); |
| | | if (!StringUtil.isEmpty(roomDtos.get(roomIndex).getOwnerId())) { |
| | |
| | | feeAttrsPos.add(feeBMOImpl.addFeeAttr(reqJson, context, FeeAttrDto.SPEC_CD_OWNER_ID, roomDtos.get(roomIndex).getOwnerId())); |
| | | feeAttrsPos.add(feeBMOImpl.addFeeAttr(reqJson, context, FeeAttrDto.SPEC_CD_OWNER_LINK, roomDtos.get(roomIndex).getLink())); |
| | | feeAttrsPos.add(feeBMOImpl.addFeeAttr(reqJson, context, FeeAttrDto.SPEC_CD_OWNER_NAME, roomDtos.get(roomIndex).getOwnerName())); |
| | | //付费对象名称 |
| | | feeAttrsPos.add(feeBMOImpl.addFeeAttr(reqJson, context, FeeAttrDto.SPEC_CD_PAY_OBJECT_NAME, |
| | | roomDtos.get(roomIndex).getFloorNum() + "-" + roomDtos.get(0).getUnitNum() + "-" + roomDtos.get(0).getRoomNum())); |
| | | |
| | | } |
| | | //付费对象名称 |
| | | feeAttrsPos.add(feeBMOImpl.addFeeAttr(reqJson, context, FeeAttrDto.SPEC_CD_PAY_OBJECT_NAME, |
| | | roomDtos.get(roomIndex).getFloorNum() + "-" + roomDtos.get(roomIndex).getUnitNum() + "-" + roomDtos.get(roomIndex).getRoomNum())); |
| | | |
| | | if (roomIndex % DEFAULT_ADD_FEE_COUNT == 0 && roomIndex != 0) { |
| | | saveFlag = saveFeeAndAttrs(feePos, feeAttrsPos); |
| | | feePos = new ArrayList<>(); |
| | | feeAttrsPos = new ArrayList<>(); |
| | | if (saveFlag == 0) { |
| | | if (saveFlag < 1) { |
| | | failRooms += curFailRoomCount; |
| | | } else { |
| | | curFailRoomCount = 0; |
| | |
| | | } |
| | | if (feePos != null && feePos.size() > 0) { |
| | | saveFlag = saveFeeAndAttrs(feePos, feeAttrsPos); |
| | | if (saveFlag > 0) { |
| | | if (saveFlag < 1) { |
| | | failRooms += curFailRoomCount; |
| | | } |
| | | } |
| | |
| | | |
| | | return flag; |
| | | } |
| | | |
| | | |
| | | } |