| | |
| | | import com.java110.core.smo.order.IOrderInnerServiceSMO; |
| | | import com.java110.core.smo.owner.IOwnerInnerServiceSMO; |
| | | import com.java110.core.smo.room.IRoomInnerServiceSMO; |
| | | import com.java110.dto.OwnerDto; |
| | | import com.java110.dto.owner.OwnerDto; |
| | | import com.java110.dto.RoomDto; |
| | | import com.java110.dto.hardwareAdapation.MachineDto; |
| | | import com.java110.dto.order.OrderDto; |
| | |
| | | import org.slf4j.LoggerFactory; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | |
| | | */ |
| | | public class TranslateOwnerToMachineChangeMachine implements Runnable { |
| | | Logger logger = LoggerFactory.getLogger(TranslateOwnerToMachineChangeMachine.class); |
| | | public static final long DEFAULT_WAIT_SECOND = 5000 * 6; // 默认30秒执行一次 |
| | | public static final long DEFAULT_WAIT_SECOND = 1000 * 60; // 默认30秒执行一次 |
| | | public static boolean TRANSLATE_STATE = false; |
| | | |
| | | private IOrderInnerServiceSMO orderInnerServiceSMOImpl; |
| | |
| | | OrderDto orderDto = new OrderDto(); |
| | | List<OrderDto> orderDtos = orderInnerServiceSMOImpl.queryMachineOrders(orderDto); |
| | | for (OrderDto tmpOrderDto : orderDtos) { |
| | | logger.debug("开始处理订单" + JSONObject.toJSONString(tmpOrderDto)); |
| | | try { |
| | | //根据bId 查询硬件信息 |
| | | machineDto = new MachineDto(); |
| | |
| | | logger.debug("没有数据数据直接刷为C1" + JSONObject.toJSONString(tmpOrderDto)); |
| | | continue; |
| | | } |
| | | dealData(tmpOrderDto, machineDtos.get(0)); |
| | | if (!"9996".equals(machineDtos.get(0).getMachineTypeCd())) { |
| | | dealData(tmpOrderDto, machineDtos.get(0)); |
| | | } |
| | | |
| | | //刷新 状态为C1 |
| | | orderInnerServiceSMOImpl.updateBusinessStatusCd(tmpOrderDto); |
| | | } catch (Exception e) { |
| | |
| | | //先根据单元门ID 查询 房屋 |
| | | RoomDto roomDto = new RoomDto(); |
| | | roomDto.setUnitId(machineDto.getLocationObjId()); |
| | | roomDto.setCommunityId(machineDto.getCommunityId()); |
| | | List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto); |
| | | if (roomDtos == null || roomDtos.size() == 0) { // 单元下没有房屋 |
| | | return; |
| | | } |
| | | ownerDto.setRoomIds(getRoomIds(roomDtos)); |
| | | ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto); |
| | | } else if ("3000".equals(locationTypeCd)) {// 3000 房屋门 |
| | |
| | | return; |
| | | } |
| | | for (OwnerDto tmpOwnerDto : ownerDtos) { |
| | | if (BusinessTypeConstant.BUSINESS_TYPE_SAVE_MACHINE.equals(tmpOrderDto.getBusinessTypeCd())) { |
| | | if (BusinessTypeConstant.BUSINESS_TYPE_SAVE_MACHINE.equals(tmpOrderDto.getBusinessTypeCd()) |
| | | || BusinessTypeConstant.BUSINESS_TYPE_UPDATE_MACHINE.equals(tmpOrderDto.getBusinessTypeCd())) { |
| | | saveMachineTranslate(machineDto, tmpOwnerDto); |
| | | } else if (BusinessTypeConstant.BUSINESS_TYPE_UPDATE_MACHINE.equals(tmpOrderDto.getBusinessTypeCd())) { |
| | | updateMachineTranslate(machineDto, tmpOwnerDto); |
| | | // } else if (BusinessTypeConstant.BUSINESS_TYPE_UPDATE_MACHINE.equals(tmpOrderDto.getBusinessTypeCd())) { |
| | | // updateMachineTranslate(machineDto, tmpOwnerDto); |
| | | } else if (BusinessTypeConstant.BUSINESS_TYPE_DELETE_MACHINE.equals(tmpOrderDto.getBusinessTypeCd())) { |
| | | deleteMachineTranslate(machineDto, tmpOwnerDto); |
| | | } else { |
| | |
| | | info.put("objId", ownerDto.getMemberId()); |
| | | info.put("state", "10000"); |
| | | info.put("communityId", ownerDto.getCommunityId()); |
| | | info.put("updateTime", new Date()); |
| | | machineTranslateServiceDaoImpl.updateMachineTranslate(info); |
| | | |
| | | |
| | | } |
| | | |
| | |
| | | info.put("objId", ownerDto.getMemberId()); |
| | | info.put("statusCd", StatusConstant.STATUS_CD_INVALID); |
| | | info.put("communityId", ownerDto.getCommunityId()); |
| | | info.put("updateTime", new Date()); |
| | | |
| | | machineTranslateServiceDaoImpl.updateMachineTranslate(info); |
| | | |
| | | } |