feign日志

fuliqi

2024-08-08 7b3e1399955666b183608b6d0fcf53d7cdeee919

feign日志

 ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/MonitorQualifyParam.java

New file
@@ -0,0 +1,7 @@
package com.ycl.platform.domain.param.UY;

import lombok.Data;

@Data
public class MonitorQualifyParam {
}

 ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/QueryVqdParam.java

@@ -133,4 +133,7 @@
     * 是否需要分页返回结果，当为true时pageSize和pageNum参数失效
     */
    private Boolean withOutPaging;

    private String apikey;
    private String accesskey;
}

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/MonitorQualifyResult.java

New file
@@ -0,0 +1,17 @@
package com.ycl.platform.domain.result.UY;

import lombok.Data;

@Data
public class MonitorQualifyResult {
    private QualifyResult civilCode;


    @Data
    public static class QualifyResult {
        private Boolean error;
        private String errorMessage;
        private String showValue;
        private String value;
    }
}

 ycl-server/src/main/java/com/ycl/feign/UYClient.java

@@ -45,7 +45,7 @@
     * @return 查询满足条件的录像汇总信息
     */
    @PostMapping("/videomon/report/recordMetaDSum/list")
    JSONObject recordMetaDSumList(@RequestBody RecordMetaDSumParam recordMetaDSumParam);
    JSONObject recordMetaDSumList( RecordMetaDSumParam recordMetaDSumParam);

    /**
     * osd标注信息
@@ -60,7 +60,7 @@
     * @param param
     * @return
     */
    @GetMapping("/videomon/openapi/v1/vqdMonitor/queryVqdResult")
    @GetMapping("/openapi/v1/vqdMonitor/queryVqdResult")
    JSONObject queryVqdResult(@SpringQueryMap QueryVqdParam param);

    /**
@@ -73,6 +73,15 @@
    JSONObject videoQuality(@SpringQueryMap VideoQualityParam param);

    /**
     * 一机一档合格率
     *
     * @param param
     * @return
     */
    @GetMapping("/iotdiscovery/api/v1/app/camera/precision/stat/detail")
    JSONObject monitorQualify(@SpringQueryMap MonitorQualifyParam param);

    /**
     * 优云获取token接口
     *
     * @param param

 ycl-server/src/main/java/com/ycl/feign/UYFeignConfig.java

@@ -2,6 +2,7 @@

import com.ycl.feign.FeignErrorDecoder;
import com.ycl.interceptor.YYFeignInterceptor;
import feign.Logger;
import feign.RequestInterceptor;
import feign.codec.ErrorDecoder;
import org.springframework.context.annotation.Bean;
@@ -28,4 +29,9 @@
    public ErrorDecoder errorDecoder() {
        return new FeignErrorDecoder();
    }

    @Bean
    Logger.Level feignLoggerLevel(){
        return Logger.Level.FULL;
    }
}

 ycl-server/src/main/java/com/ycl/interceptor/YYFeignInterceptor.java

@@ -40,7 +40,7 @@
            if (uyToken == null) {
                uyToken = getToken();
            }
            requestTemplate.header("Cookie", "token" + uyToken);
            requestTemplate.header("Cookie", "token=" + uyToken);
        }
    }


 ycl-server/src/main/java/com/ycl/task/UYTask.java

@@ -45,6 +45,10 @@
    private ITMonitorService monitorService;
    @Value("${youYun.tenantId}")
    private String tenantId;
    @Value("${youYun.apikey}")
    private String apikey;
    @Value("${youYun.accesskey}")
    private String accesskey;
    @Value("${youYun.email}")
    private String email;
    @Value("${youYun.passwd}")
@@ -82,6 +86,39 @@
        log.info("结束执行一机一档数据同步");
    }

    //一机一档合格率
    public void monitorQualifyTask() {
        //一机一档合格率
        log.info("开始执行一机一档合格率数据同步");
        OneMachineFileParam param = new OneMachineFileParam();
        JSONObject jsonObject = uyClient.oneMachineFile(param);
        if (jsonObject != null) {
            log.info("数据格式" + jsonObject);
            String code = jsonObject.getString("code");
            if (ApiConstants.UYSuccessCodeStr.equals(code)) {
                JSONObject data = jsonObject.getJSONObject("data");
                if (data != null) {
                    List<OneMachineFileResult> records = data.getList("records", OneMachineFileResult.class);
                    if (!CollectionUtils.isEmpty(records)) {
                        //如果今天存在之前的数据先删除
                        Query query = new Query(Criteria
                                .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
                        DeleteResult result = mongoTemplate.remove(query, OneMachineFileResult.class);
                        //存放在mongo中
                        mongoTemplate.insertAll(records);
                    } else {
                        log.error("一机一档合格率数据为空{}", data);
                    }
                }
            } else {
                log.error("一机一档合格率数据为空{}", jsonObject);
            }
        } else {
            log.error("一机一档合格率数据为空");
        }
        log.info("结束一机一档合格率数据同步");
    }

    //图像监测诊断结果
    public void queryVqdResultTask() {
        //点位在线率
@@ -89,6 +126,8 @@
        log.info("开始执行图像监测诊断结果数据同步");
        QueryVqdParam param = new QueryVqdParam();
        param.setTenantId(tenantId);
        param.setApikey(apikey);
        param.setAccesskey(accesskey);
        JSONObject jsonObject = uyClient.queryVqdResult(param);
        if (jsonObject != null) {
            log.info("数据格式" + jsonObject);

 ycl-server/src/main/resources/application-dev.yml

@@ -137,3 +137,5 @@
  tenantId: 11
  email: 11
  passwd: 11
  apikey: 11
  accesskey: 11

 ycl-server/src/main/resources/application-prod.yml

@@ -139,4 +139,5 @@
  tenantId: e10adc3949ba59abbe56e057f2gg88dd
  email: 11
  passwd: 11
  apikey: 11