public class cn.cloudwalk.elevator.handler.PersonRecordEventHandler extends cn.cloudwalk.elevator.handler.AbstractEventHandler implements cn.cloudwalk.event.handler.EventHandler<cn.cloudwalk.cwos.client.event.event.PersonRecordUploadEvent> {
private static final org.slf4j.Logger LOGGER;
private cn.cloudwalk.elevator.record.service.AcsRecogRecordService acsRecogRecordService;
public cn.cloudwalk.elevator.handler.PersonRecordEventHandler();
Code:
aload_0
invokespecial #                  // Method cn/cloudwalk/elevator/handler/AbstractEventHandler."<init>":()V
return
public void onEvent(cn.cloudwalk.cwos.client.event.event.PersonRecordUploadEvent);
Code:
getstatic     #                  // Field LOGGER:Lorg/slf4j/Logger;
ldc           #                  // String 收到personRecordUploadEvent消息:{}
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/PersonRecordUploadEvent.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/PersonRecordUploadEvent.getDeviceId:()Ljava/lang/String;
aload_2
invokevirtual #                  // Method queryDeviceResult:(Ljava/lang/String;Lcn/cloudwalk/cloud/context/CloudwalkCallContext;)Lcn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult;
astore_3
aload_0
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent.getSubDeviceId:()Ljava/lang/String;
aload_2
invokevirtual #                  // Method queryDeviceResult:(Ljava/lang/String;Lcn/cloudwalk/cloud/context/CloudwalkCallContext;)Lcn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult;
astore _
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent.getFaces:()Ljava/util/List;
invokeinterface # // InterfaceMethod java/util/List.stream:()Ljava/util/stream/Stream;
invokedynamic # // InvokeDynamic #:apply:()Ljava/util/function/Function;
invokestatic  #                 // Method java/util/stream/Collectors.groupingBy:(Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface # // InterfaceMethod java/util/stream/Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast     #                 // class java/util/Map
astore _
aload _
invokeinterface # // InterfaceMethod java/util/Map.keySet:()Ljava/util/Set;
invokeinterface # // InterfaceMethod java/util/Set.iterator:()Ljava/util/Iterator;
astore _
aload _
invokeinterface # // InterfaceMethod java/util/Iterator.hasNext:()Z
ifeq @
aload _
invokeinterface # // InterfaceMethod java/util/Iterator.next:()Ljava/lang/Object;
checkcast     #                 // class java/lang/String
astore _
aload _
aload _
invokeinterface # // InterfaceMethod java/util/Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast     #                 // class java/util/List
iconst_0
invokeinterface # // InterfaceMethod java/util/List.get:(I)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/cwos/client/event/event/mode/Face
astore _
aload_0
aload_1
aload _
invokespecial #                 // Method getParam:(Lcn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent;Lcn/cloudwalk/cwos/client/event/event/mode/Face;)Lcn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam;
astore _
aload _
aload_3
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setDeviceResult:(Lcn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult;)V
aload _
aload _
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setSubDeviceResult:(Lcn/cloudwalk/client/cwoscomponent/intelligent/device/result/DeviceResult;)V
aload_0
getfield      #                 // Field acsRecogRecordService:Lcn/cloudwalk/elevator/record/service/AcsRecogRecordService;
aload _
aload_2
invokeinterface # // InterfaceMethod cn/cloudwalk/elevator/record/service/AcsRecogRecordService.add:(Lcn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam;Lcn/cloudwalk/cloud/context/CloudwalkCallContext;)Lcn/cloudwalk/cloud/result/CloudwalkResult;
pop
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/PersonRecordUploadEvent.getBusinessId:()Ljava/lang/String;
invokestatic  #                 // Method cn/cloudwalk/elevator/util/AcsCacheKeyUtil.getRecogCountKey:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
invokevirtual #                 // Method statisticsAddCache:(Ljava/lang/String;)V
goto @
astore _
getstatic     #                  // Field LOGGER:Lorg/slf4j/Logger;
ldc           #                 // String 保存人员识别记录失败，faceId：{}，原因：
aload _
aload _
invokeinterface # // InterfaceMethod org/slf4j/Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
goto @
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
107   188   191   Class java/lang/Exception
14   210   216   Class java/lang/Exception
14   210   234   any
216   228   234   any
234   236   234   any
private cn.cloudwalk.elevator.record.param.AcsRecogRecordAddParam getParam(cn.cloudwalk.cwos.client.event.event.PersonRecordUploadEvent, cn.cloudwalk.cwos.client.event.event.mode.Face);
Code:
aload_1
ldc           #                 // class cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam
invokestatic  #                 // Method cn/cloudwalk/cloud/utils/BeanCopyUtils.copyProperties:(Ljava/lang/Object;Ljava/lang/Class;)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam
astore_3
aload_2
aload_3
invokestatic  #                 // Method cn/cloudwalk/cloud/utils/BeanCopyUtils.copyProperties:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent.getPanoramaData:()Lcn/cloudwalk/cwos/client/event/event/mode/Panorama;
ifnull @
aload_3
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent.getPanoramaData:()Lcn/cloudwalk/cwos/client/event/event/mode/Panorama;
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/mode/Panorama.getPanoramaImagePath:()Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setPanoramaImagePath:(Ljava/lang/String;)V
aload_3
aload_1
invokevirtual #                  // Method cn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent.getDeviceId:()Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setDeviceCode:(Ljava/lang/String;)V
aload_3
aload_1
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent.getThreshold:()F
f2d
invokestatic  #                 // Method java/math/BigDecimal.valueOf:(D)Ljava/math/BigDecimal;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setThreshold:(Ljava/math/BigDecimal;)V
aload_3
aload_2
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/mode/Face.getScore:()Ljava/lang/Float;
invokevirtual #                 // Method java/lang/Float.floatValue:()F
f2d
invokestatic  #                 // Method java/math/BigDecimal.valueOf:(D)Ljava/math/BigDecimal;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setScore:(Ljava/math/BigDecimal;)V
aload_3
aload_2
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/mode/Face.getQualityScore:()Ljava/lang/Float;
invokevirtual #                 // Method java/lang/Float.floatValue:()F
f2d
invokestatic  #                 // Method java/math/BigDecimal.valueOf:(D)Ljava/math/BigDecimal;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setQualityScore:(Ljava/math/BigDecimal;)V
aload_2
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/mode/Face.getMaskScore:()Ljava/lang/Float;
ifnull @
aload_3
aload_2
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/mode/Face.getMaskScore:()Ljava/lang/Float;
invokevirtual #                 // Method java/lang/Float.floatValue:()F
f2d
invokestatic  #                 // Method java/math/BigDecimal.valueOf:(D)Ljava/math/BigDecimal;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setMaskScore:(Ljava/math/BigDecimal;)V
aload_2
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/mode/Face.getTempScore:()Ljava/lang/Float;
ifnull @
aload_3
aload_2
invokevirtual #                 // Method cn/cloudwalk/cwos/client/event/event/mode/Face.getTempScore:()Ljava/lang/Float;
invokevirtual #                 // Method java/lang/Float.floatValue:()F
f2d
invokestatic  #                 // Method java/math/BigDecimal.valueOf:(D)Ljava/math/BigDecimal;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setTempScore:(Ljava/math/BigDecimal;)V
aload_3
getstatic     #                 // Field cn/cloudwalk/elevator/em/CompareTypeEnum.RECOG:Lcn/cloudwalk/elevator/em/CompareTypeEnum;
invokevirtual #                 // Method cn/cloudwalk/elevator/em/CompareTypeEnum.getCode:()Ljava/lang/Integer;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/AcsRecogRecordAddParam.setCompareType:(Ljava/lang/Integer;)V
aload_3
areturn
public void onEvent(cn.cloudwalk.cwos.client.event.event.BaseEvent);
Code:
aload_0
aload_1
checkcast     #                 // class cn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent
invokevirtual #                 // Method onEvent:(Lcn/cloudwalk/cwos/client/event/event/PersonRecordUploadEvent;)V
return
static {};
Code:
ldc           #                 // class cn/cloudwalk/elevator/handler/PersonRecordEventHandler
invokestatic  #                 // Method org/slf4j/LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic     #                  // Field LOGGER:Lorg/slf4j/Logger;
return
}
