public class cn.cloudwalk.elevator.handler.OpenDoorRecordEventHandler extends cn.cloudwalk.elevator.handler.AbstractEventHandler implements cn.cloudwalk.event.handler.EventHandler<cn.cloudwalk.cwos.client.event.event.OpenDoorRecordEvent> {
private static final org.slf4j.Logger LOGGER;
private cn.cloudwalk.elevator.record.service.AcsElevatorRecordService acsElevatorRecordService;
private org.springframework.data.redis.core.RedisTemplate<java.lang.String, java.lang.Object> redisTemplate;
public cn.cloudwalk.elevator.handler.OpenDoorRecordEventHandler();
Code:
aload_0
invokespecial #                  // Method cn/cloudwalk/elevator/handler/AbstractEventHandler."<init>":()V
return
public void onEvent(cn.cloudwalk.cwos.client.event.event.OpenDoorRecordEvent);
Code:
getstatic     #                  // Field LOGGER:Lorg/slf4j/Logger;
ldc           #                  // String 收到openDoorRecordEvent消息:{}
aload_1
invokestatic  #                  // Method com/alibaba/fastjson/JSON.toJSONString:(Ljava/lang/Object;)Ljava/lang/String;
invokeinterface # // InterfaceMethod org/slf4j/Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
aload_0
aload_1
invokevirtual #                  // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getBusinessId:()Ljava/lang/String;
invokevirtual #                  // Method getCloudwalkContext:(Ljava/lang/String;)Lcn/cloudwalk/cloud/context/CloudwalkCallContext;
astore_2
aload_0
aload_1
invokevirtual #                  // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getDeviceId:()Ljava/lang/String;
aload_2
invokespecial #                  // Method cn/cloudwalk/elevator/handler/AbstractEventHandler.queryDeviceResult:(Ljava/lang/String;Lcn/cloudwalk/cloud/context/CloudwalkCallContext;)Lcn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult;
astore_3
aload_0
aload_1
invokespecial #                 // Method getParam:(Lcn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent;)Lcn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam;
astore _
aload _
aload_3
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam.setDeviceResult:(Lcn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult;)V
aconst_null
astore _
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getReserveInfo:()Ljava/lang/String;
invokestatic  #                 // Method org/apache/commons/lang3/StringUtils.isNotBlank:(Ljava/lang/CharSequence;)Z
ifeq @
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getReserveInfo:()Ljava/lang/String;
invokestatic  #                 // Method com/alibaba/fastjson/JSON.parseObject:(Ljava/lang/String;)Lcom/alibaba/fastjson/JSONObject;
astore _
aload _
invokevirtual #                 // Method com/alibaba/fastjson/JSONObject.isEmpty:()Z
ifne @
aload _
ldc           #                 // String srcFloor
invokevirtual #                 // Method com/alibaba/fastjson/JSONObject.containsKey:(Ljava/lang/Object;)Z
ifeq @
aload _
ldc           #                 // class cn/cloudwalk/elevator/record/dto/AcsElevatorRecordExtraDTO
invokevirtual #                 // Method com/alibaba/fastjson/JSONObject.toJavaObject:(Ljava/lang/Class;)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/elevator/record/dto/AcsElevatorRecordExtraDTO
astore _
aload_3
ifnull @
getstatic     #                 // Field cn/cloudwalk/elevator/em/AcsDeviceIdentifyTypeEnum.BACKEND_REG:Lcn/cloudwalk/elevator/em/AcsDeviceIdentifyTypeEnum;
invokevirtual #                 // Method cn/cloudwalk/elevator/em/AcsDeviceIdentifyTypeEnum.getCode:()Ljava/lang/Integer;
aload_3
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult.getIdentifyType:()I
invokestatic  #                 // Method java/lang/Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual #                 // Method java/lang/Integer.equals:(Ljava/lang/Object;)Z
ifeq @
goto @
aload _
ifnull @
aload_0
aload _
aload _
invokespecial #                 // Method getElevatorParam:(Lcn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam;Lcn/cloudwalk/elevator/record/dto/AcsElevatorRecordExtraDTO;)Lcn/cloudwalk/elevator/record/param/AcsElevatorRecordAddParam;
astore _
aload_0
getfield      #                 // Field acsElevatorRecordService:Lcn/cloudwalk/elevator/record/service/AcsElevatorRecordService;
aload _
aload_2
invokeinterface # // InterfaceMethod cn/cloudwalk/elevator/record/service/AcsElevatorRecordService.add:(Lcn/cloudwalk/elevator/record/param/AcsElevatorRecordAddParam;Lcn/cloudwalk/cloud/context/CloudwalkCallContext;)Lcn/cloudwalk/cloud/result/CloudwalkResult;
astore _
aload _
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam.getRecordResult:()Ljava/lang/Integer;
invokevirtual #                 // Method java/lang/Integer.intValue:()I
iconst_1
if_icmpne     209
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.isSuccess:()Z
ifeq @
ldc           #                 // String 1
aload _
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/AcsElevatorRecordExtraDTO.getSrcFloor:()Ljava/lang/String;
invokevirtual #                 // Method java/lang/String.equals:(Ljava/lang/Object;)Z
ifeq @
aload_0
new           #                 // class java/util/Date
dup
invokespecial #                 // Method java/util/Date."<init>":()V
ldc           #                 // String yyyy-MM-dd
invokestatic  #                 // Method cn/cloudwalk/elevator/util/DateUtils.parseDate:(Ljava/util/Date;Ljava/lang/String;)Ljava/lang/String;
aload_1
invokevirtual #                  // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getBusinessId:()Ljava/lang/String;
invokestatic  #                 // Method cn/cloudwalk/elevator/util/AcsCacheKeyUtil.getOpenDoorCountKey:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
invokevirtual #                 // Method statisticsAddCache:(Ljava/lang/String;)V
invokestatic  #                 // Method cn/cloudwalk/elevator/config/FeignThreadLocalUtil.remove:()V
goto @
astore_2
getstatic     #                  // Field LOGGER:Lorg/slf4j/Logger;
ldc           #                 // String 消费开门记录失败，原因:
aload_2
invokeinterface # // InterfaceMethod org/slf4j/Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
invokestatic  #                 // Method cn/cloudwalk/elevator/config/FeignThreadLocalUtil.remove:()V
goto @
astore _
invokestatic  #                 // Method cn/cloudwalk/elevator/config/FeignThreadLocalUtil.remove:()V
aload _
athrow
return
Exception table:
from    to  target type
14   209   215   Class java/lang/Exception
14   209   233   any
215   227   233   any
233   235   233   any
private void cleanCache(cn.cloudwalk.cloud.context.CloudwalkCallContext, cn.cloudwalk.client.cwoscomponent.intelligent.device.result.DeviceResult, java.lang.String, java.lang.String);
Code:
aload_2
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult.getDeviceCode:()Ljava/lang/String;
aload_1
invokevirtual #                 // Method cn/cloudwalk/cloud/context/CloudwalkCallContext.getCompany:()Lcn/cloudwalk/cloud/session/company/CompanyContext;
invokevirtual #                 // Method cn/cloudwalk/cloud/session/company/CompanyContext.getCompanyId:()Ljava/lang/String;
aload _
invokestatic  #                 // Method cn/cloudwalk/elevator/util/AcsCacheKeyUtil.getBackendRegLogIdKey:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore _
aload_1
invokevirtual #                 // Method cn/cloudwalk/cloud/context/CloudwalkCallContext.getCompany:()Lcn/cloudwalk/cloud/session/company/CompanyContext;
invokevirtual #                 // Method cn/cloudwalk/cloud/session/company/CompanyContext.getCompanyId:()Ljava/lang/String;
aload_3
invokestatic  #                 // Method cn/cloudwalk/elevator/util/AcsCacheKeyUtil.getBackendRegExpireKey:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore _
aload_0
getfield      #                 // Field redisTemplate:Lorg/springframework/data/redis/core/RedisTemplate;
aload _
invokevirtual #                 // Method org/springframework/data/redis/core/RedisTemplate.delete:(Ljava/lang/Object;)V
aload_0
getfield      #                 // Field redisTemplate:Lorg/springframework/data/redis/core/RedisTemplate;
aload _
invokevirtual #                 // Method org/springframework/data/redis/core/RedisTemplate.delete:(Ljava/lang/Object;)V
return
private cn.cloudwalk.elevator.record.param.AcsOpenDoorRecordAddParam getParam(cn.cloudwalk.cwos.client.event.event.OpenDoorRecordEvent);
Code:
aload_1
ldc           #                 // class cn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam
invokestatic  #                 // Method cn/cloudwalk/cloud/utils/BeanCopyUtils.copyProperties:(Ljava/lang/Object;Ljava/lang/Class;)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam
astore_2
aload_2
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getRecordResult:()Ljava/lang/String;
invokestatic  #                 // Method java/lang/Integer.parseInt:(Ljava/lang/String;)I
invokestatic  #                 // Method java/lang/Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam.setRecordResult:(Ljava/lang/Integer;)V
aload_2
aload_1
invokevirtual #                  // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getDeviceId:()Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam.setDeviceCode:(Ljava/lang/String;)V
aload_2
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent.getOpenDoorType:()Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsOpenDoorRecordAddParam.setOpenDoorType:(Ljava/lang/String;)V
aload_2
areturn
private cn.cloudwalk.elevator.record.param.AcsElevatorRecordAddParam getElevatorParam(cn.cloudwalk.elevator.record.param.AcsOpenDoorRecordAddParam, cn.cloudwalk.elevator.record.dto.AcsElevatorRecordExtraDTO);
Code:
aload_1
ldc           #                 // class cn/cloudwalk/elevator/record/param/AcsElevatorRecordAddParam
invokestatic  #                 // Method cn/cloudwalk/cloud/utils/BeanCopyUtils.copyProperties:(Ljava/lang/Object;Ljava/lang/Class;)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/elevator/record/param/AcsElevatorRecordAddParam
astore_3
aload_2
aload_3
invokestatic  #                 // Method cn/cloudwalk/cloud/utils/BeanCopyUtils.copyProperties:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/elevator/record/param/AcsElevatorRecordAddParam
areturn
public void onEvent(cn.cloudwalk.cwos.client.event.event.BaseEvent);
Code:
aload_0
aload_1
checkcast     #                 // class cn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent
invokevirtual #                 // Method onEvent:(Lcn/cloudwalk/cwos/client/event/event/OpenDoorRecordEvent;)V
return
static {};
Code:
ldc           #                 // class cn/cloudwalk/elevator/handler/OpenDoorRecordEventHandler
invokestatic  #                 // Method org/slf4j/LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic     #                  // Field LOGGER:Lorg/slf4j/Logger;
return
}
