public class cn.cloudwalk.elevator.task.ElevatorRecordSendTask {
private org.slf4j.Logger logger;
private java.lang.String sendRecordIp;
private java.lang.String corpId;
private java.lang.String appKey;
private java.lang.String appSecret;
private java.lang.Boolean sendBoolean;
private static final long EXPIRE_TIME;
private cn.cloudwalk.elevator.record.dao.AcsElevatorRecordDao acsElevatorRecordDao;
private cn.cloudwalk.elevator.record.dao.SendRecordTimeDao sendRecordTimeDao;
private cn.cloudwalk.client.cwoscomponent.intelligent.record.service.AcsRecordThreeSendService acsRecordThreeSendService;
public cn.cloudwalk.elevator.task.ElevatorRecordSendTask();
Code:
aload_0
invokespecial #                  // Method java/lang/Object."<init>":()V
aload_0
ldc           #                  // class cn/cloudwalk/elevator/task/ElevatorRecordSendTask
invokestatic  #                  // Method org/slf4j/LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putfield      #                  // Field logger:Lorg/slf4j/Logger;
return
public void execute();
Code:
aload_0
getfield      #                  // Field sendBoolean:Ljava/lang/Boolean;
invokevirtual #                  // Method java/lang/Boolean.booleanValue:()Z
ifne @
return
aload_0
getfield      #                  // Field sendRecordTimeDao:Lcn/cloudwalk/elevator/record/dao/SendRecordTimeDao;
iconst_2
invokestatic  #                  // Method java/lang/Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface # // InterfaceMethod cn/cloudwalk/elevator/record/dao/SendRecordTimeDao.getByType:(Ljava/lang/Integer;)Lcn/cloudwalk/elevator/record/dto/SendRecordTimeResultDTO;
astore_1
invokestatic  #                 // Method java/lang/System.currentTimeMillis:()J
invokestatic  #                 // Method java/lang/Long.valueOf:(J)Ljava/lang/Long;
astore_2
aload_1
invokestatic  #                 // Method org/springframework/util/ObjectUtils.isEmpty:(Ljava/lang/Object;)Z
ifne @
aload_2
invokevirtual #                 // Method java/lang/Long.longValue:()J
aload_1
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeResultDTO.getTime:()Ljava/lang/Long;
invokevirtual #                 // Method java/lang/Long.longValue:()J
lsub
ldc2_w        #                 // long 3600000l
lcmp
ifge @
return
aload_1
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeResultDTO.getTime:()Ljava/lang/Long;
astore_2
goto @
new           #                 // class cn/cloudwalk/elevator/record/dto/SendRecordTimeAddDTO
dup
invokespecial #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeAddDTO."<init>":()V
astore_3
aload_3
aload_2
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeAddDTO.setTime:(Ljava/lang/Long;)V
aload_3
iconst_2
invokestatic  #                  // Method java/lang/Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeAddDTO.setType:(Ljava/lang/Integer;)V
aload_0
getfield      #                  // Field sendRecordTimeDao:Lcn/cloudwalk/elevator/record/dao/SendRecordTimeDao;
aload_3
invokeinterface # // InterfaceMethod cn/cloudwalk/elevator/record/dao/SendRecordTimeDao.add:(Lcn/cloudwalk/elevator/record/dto/SendRecordTimeAddDTO;)Ljava/lang/Integer;
pop
new           #                 // class cn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO
dup
invokespecial #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO."<init>":()V
astore_3
aload_3
iconst_2
invokestatic  #                  // Method java/lang/Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO.setType:(Ljava/lang/Integer;)V
aload_3
aload_2
invokevirtual #                 // Method java/lang/Long.longValue:()J
ldc2_w        #                 // long 10000l
ladd
invokestatic  #                 // Method java/lang/Long.valueOf:(J)Ljava/lang/Long;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO.setTime:(Ljava/lang/Long;)V
new           #                 // class cn/cloudwalk/client/cwoscomponent/intelligent/record/param/AcsRecordThreeSendParam
dup
invokespecial #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/record/param/AcsRecordThreeSendParam."<init>":()V
astore _
aload _
aload_2
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/record/param/AcsRecordThreeSendParam.setStartTime:(Ljava/lang/Long;)V
aload_0
getfield      #                 // Field acsRecordThreeSendService:Lcn/cloudwalk/client/cwoscomponent/intelligent/record/service/AcsRecordThreeSendService;
aload _
invokeinterface # // InterfaceMethod cn/cloudwalk/client/cwoscomponent/intelligent/record/service/AcsRecordThreeSendService.listByTime:(Lcn/cloudwalk/client/cwoscomponent/intelligent/record/param/AcsRecordThreeSendParam;)Lcn/cloudwalk/cloud/result/CloudwalkResult;
astore _
aload_0
getfield      #                  // Field logger:Lorg/slf4j/Logger;
ldc           #                 // String 查询时间戳为：{}，获取的门禁记录数据为：{}
aload_2
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.getData:()Ljava/lang/Object;
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;Ljava/lang/Object;)V
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.getData:()Ljava/lang/Object;
checkcast     #                 // class java/util/Collection
invokestatic  #                 // Method org/springframework/util/CollectionUtils.isEmpty:(Ljava/util/Collection;)Z
ifne @
aload_3
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.getData:()Ljava/lang/Object;
checkcast     #                 // class java/util/List
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.getData:()Ljava/lang/Object;
checkcast     #                 // class java/util/List
invokeinterface # // InterfaceMethod java/util/List.size:()I
iconst_1
isub
invokeinterface # // InterfaceMethod java/util/List.get:(I)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/client/cwoscomponent/intelligent/record/result/AcsRecordThreeSendResult
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/record/result/AcsRecordThreeSendResult.getRecognitionTime:()J
invokestatic  #                 // Method java/lang/Long.valueOf:(J)Ljava/lang/Long;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO.setTime:(Ljava/lang/Long;)V
aload_3
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO.getTime:()Ljava/lang/Long;
aload_2
invokevirtual #                 // Method java/lang/Long.equals:(Ljava/lang/Object;)Z
ifeq @
aload_3
aload_2
invokevirtual #                 // Method java/lang/Long.longValue:()J
ldc2_w        #                 // long 10l
ladd
invokestatic  #                 // Method java/lang/Long.valueOf:(J)Ljava/lang/Long;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO.setTime:(Ljava/lang/Long;)V
new           #                 // class java/util/ArrayList
dup
invokespecial #                 // Method java/util/ArrayList."<init>":()V
astore _
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.getData:()Ljava/lang/Object;
checkcast     #                 // class java/util/List
invokeinterface # // InterfaceMethod java/util/List.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 cn/cloudwalk/client/cwoscomponent/intelligent/record/result/AcsRecordThreeSendResult
astore _
aload _
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/record/result/AcsRecordThreeSendResult.getPersonCode:()Ljava/lang/String;
invokestatic  #                 // Method org/springframework/util/ObjectUtils.isEmpty:(Ljava/lang/Object;)Z
ifne @
new           #                 // class cn/cloudwalk/elevator/record/param/SendRecordSendInfoParam
dup
invokespecial #                 // Method cn/cloudwalk/elevator/record/param/SendRecordSendInfoParam."<init>":()V
astore _
aload _
aload _
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/record/result/AcsRecordThreeSendResult.getPersonCode:()Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/SendRecordSendInfoParam.setEmployeeCode:(Ljava/lang/String;)V
aload _
new           #                 // class java/util/Date
dup
aload _
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/record/result/AcsRecordThreeSendResult.getRecognitionTime:()J
invokespecial #                 // Method java/util/Date."<init>":(J)V
ldc           #                 // String yyyy-MM-dd HH:mm:ss
invokestatic  #                 // Method cn/cloudwalk/elevator/util/DateUtils.parseDate:(Ljava/util/Date;Ljava/lang/String;)Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/SendRecordSendInfoParam.setSignTime:(Ljava/lang/String;)V
aload _
aload _
invokevirtual #                 // Method cn/cloudwalk/client/cwoscomponent/intelligent/record/result/AcsRecordThreeSendResult.getDeviceName:()Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/SendRecordSendInfoParam.setDeviceName:(Ljava/lang/String;)V
aload _
aload _
invokeinterface # // InterfaceMethod java/util/List.add:(Ljava/lang/Object;)Z
pop
goto @
aload _
invokestatic  #                 // Method org/springframework/util/CollectionUtils.isEmpty:(Ljava/util/Collection;)Z
ifne @
new           #                 // class cn/cloudwalk/elevator/record/param/SendRecordTokenParam
dup
invokespecial #                 // Method cn/cloudwalk/elevator/record/param/SendRecordTokenParam."<init>":()V
astore _
aload _
aload_0
getfield      #                 // Field corpId:Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/SendRecordTokenParam.setCorpId:(Ljava/lang/String;)V
aload _
aload_0
getfield      #                 // Field appKey:Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/SendRecordTokenParam.setAppKey:(Ljava/lang/String;)V
aload _
aload_0
getfield      #                 // Field appSecret:Ljava/lang/String;
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/SendRecordTokenParam.setAppSecret:(Ljava/lang/String;)V
aload_0
ldc           #                 // String forward_webfront/api/pti-oapi/token/get
aconst_null
invokespecial #                 // Method combineAuthClientURI:(Ljava/lang/String;Lorg/springframework/util/MultiValueMap;)Ljava/net/URI;
astore _
aload _
aload _
aconst_null
new           #                 // class cn/cloudwalk/elevator/task/ElevatorRecordSendTask$1
dup
aload_0
invokespecial #                 // Method cn/cloudwalk/elevator/task/ElevatorRecordSendTask$1."<init>":(Lcn/cloudwalk/elevator/task/ElevatorRecordSendTask;)V
invokestatic  #                 // Method cn/cloudwalk/elevator/util/RestTemplateUtil.post:(Ljava/net/URI;Ljava/lang/Object;Lorg/springframework/http/HttpHeaders;Lcom/fasterxml/jackson/core/type/TypeReference;)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/cloud/result/CloudwalkResult
astore _
new           #                 // class org/springframework/util/LinkedMultiValueMap
dup
invokespecial #                 // Method org/springframework/util/LinkedMultiValueMap."<init>":()V
astore _
aload _
ldc           #                 // String token
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.getData:()Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/elevator/record/result/SendRecordTokenResult
invokevirtual #                 // Method cn/cloudwalk/elevator/record/result/SendRecordTokenResult.getToken:()Ljava/lang/String;
invokevirtual #                 // Method org/springframework/util/LinkedMultiValueMap.add:(Ljava/lang/Object;Ljava/lang/Object;)V
aload_0
ldc           #                 // String /forward_webfront/api/pti-oapi/v2/api/starriver/device/sign-third-import
aload _
invokespecial #                 // Method combineAuthClientURI:(Ljava/lang/String;Lorg/springframework/util/MultiValueMap;)Ljava/net/URI;
astore _
new           #                 // class org/springframework/http/HttpHeaders
dup
invokespecial #                 // Method org/springframework/http/HttpHeaders."<init>":()V
astore _
aload _
ldc           #                 // String token
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.getData:()Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/elevator/record/result/SendRecordTokenResult
invokevirtual #                 // Method cn/cloudwalk/elevator/record/result/SendRecordTokenResult.getToken:()Ljava/lang/String;
invokevirtual #                 // Method org/springframework/http/HttpHeaders.set:(Ljava/lang/String;Ljava/lang/String;)V
new           #                 // class cn/cloudwalk/elevator/record/param/SendRecordSendParam
dup
invokespecial #                 // Method cn/cloudwalk/elevator/record/param/SendRecordSendParam."<init>":()V
astore _
aload _
aload _
invokevirtual #                 // Method cn/cloudwalk/elevator/record/param/SendRecordSendParam.setRecords:(Ljava/util/List;)V
aload_0
getfield      #                  // Field logger:Lorg/slf4j/Logger;
ldc           #                 // String 推送通行记录数据为：{}
aload _
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 _
aload _
aload _
new           #                 // class cn/cloudwalk/elevator/task/ElevatorRecordSendTask$2
dup
aload_0
invokespecial #                 // Method cn/cloudwalk/elevator/task/ElevatorRecordSendTask$2."<init>":(Lcn/cloudwalk/elevator/task/ElevatorRecordSendTask;)V
invokestatic  #                 // Method cn/cloudwalk/elevator/util/RestTemplateUtil.post:(Ljava/net/URI;Ljava/lang/Object;Lorg/springframework/http/HttpHeaders;Lcom/fasterxml/jackson/core/type/TypeReference;)Ljava/lang/Object;
checkcast     #                 // class cn/cloudwalk/cloud/result/CloudwalkResult
astore _
aload_0
getfield      #                  // Field logger:Lorg/slf4j/Logger;
ldc           #                 // String 调用第三方接口发送通行记录数据结束，返回结果为：{}
aload _
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
getfield      #                  // Field sendRecordTimeDao:Lcn/cloudwalk/elevator/record/dao/SendRecordTimeDao;
aload_3
invokeinterface # // InterfaceMethod cn/cloudwalk/elevator/record/dao/SendRecordTimeDao.update:(Lcn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO;)Ljava/lang/Integer;
pop
goto @
aload _
invokevirtual #                 // Method cn/cloudwalk/cloud/result/CloudwalkResult.isSuccess:()Z
ifeq @
aload_0
getfield      #                  // Field sendRecordTimeDao:Lcn/cloudwalk/elevator/record/dao/SendRecordTimeDao;
aload_3
invokeinterface # // InterfaceMethod cn/cloudwalk/elevator/record/dao/SendRecordTimeDao.update:(Lcn/cloudwalk/elevator/record/dto/SendRecordTimeEditDTO;)Ljava/lang/Integer;
pop
goto @
astore_1
aload_0
getfield      #                  // Field logger:Lorg/slf4j/Logger;
ldc           #                // String 派梯记录推送失败，失败原因是：{}
aload_1
invokeinterface # // InterfaceMethod org/slf4j/Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
return
Exception table:
from    to  target type
11    58   624   Class java/lang/Exception
59   621   624   Class java/lang/Exception
private java.net.URI combineAuthClientURI(java.lang.String, org.springframework.util.MultiValueMap<java.lang.String, java.lang.String>);
Code:
new           #                // class java/lang/StringBuilder
dup
invokespecial #                // Method java/lang/StringBuilder."<init>":()V
ldc           #                // String http://
invokevirtual #                // Method java/lang/StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload_0
getfield      #                // Field sendRecordIp:Ljava/lang/String;
invokevirtual #                // Method java/lang/StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual #                // Method java/lang/StringBuilder.toString:()Ljava/lang/String;
invokestatic  #                // Method org/springframework/web/util/UriComponentsBuilder.fromUriString:(Ljava/lang/String;)Lorg/springframework/web/util/UriComponentsBuilder;
aload_1
invokevirtual #                // Method org/springframework/web/util/UriComponentsBuilder.path:(Ljava/lang/String;)Lorg/springframework/web/util/UriComponentsBuilder;
aload_2
invokevirtual #                // Method org/springframework/web/util/UriComponentsBuilder.queryParams:(Lorg/springframework/util/MultiValueMap;)Lorg/springframework/web/util/UriComponentsBuilder;
invokevirtual #                // Method org/springframework/web/util/UriComponentsBuilder.build:()Lorg/springframework/web/util/UriComponents;
invokevirtual #                // Method org/springframework/web/util/UriComponents.toUri:()Ljava/net/URI;
areturn
}
