批量审核和图片保存bug

zhanghua

2025-04-14 1cad14bca191807e18705c3a5526eda8151be439

 ycl-platform/src/main/java/com/ycl/timer/GetDingToken.java

@@ -6,8 +6,11 @@
import com.alibaba.xxpt.gateway.shared.client.http.GetClient;
import com.alibaba.xxpt.gateway.shared.client.http.PostClient;
import com.ycl.config.DingConfig;
import com.ycl.util.DingUtil;
import com.ycl.util.VideoUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.data.redis.core.StringRedisTemplate;
@@ -35,19 +38,20 @@

    @Resource
    private DingConfig dingConfig;
    @Autowired
    private DingUtil dingUtil;


    private  String getToken() {
    private String getToken() {
        //调用API
        getTokenClient = executableClient.newGetClient(GET_TOKEN);
        //设置参数
        getTokenClient.addParameter("appkey",  dingConfig.getAppKey());
        getTokenClient.addParameter("appkey", dingConfig.getAppKey());
        getTokenClient.addParameter("appsecret", dingConfig.getAppSecret());
        String apiResult = getTokenClient.get();
        return parsingResult(apiResult);
    }

    private  String getTiker(String accToken) {
    private String getTiker(String accToken) {
        //调用API
        PostClient postClient = executableClient.newPostClient(GET_TIKER);
        //设置参数
@@ -91,16 +95,24 @@
//            runAction();
        }
    }
//    @Scheduled(cron ="0 0/2 * * * ? ")

    @Value("${spring.profiles.active}")
    private String env;

        @Scheduled(cron ="0 0/2 * * * ?")
//    @Scheduled(cron = "0/1 * * * * ?")   // 每秒执行
    public void runAction() {
         //gettoken
         String getToken = getToken();
         //jsApi
         String jsapiToken = getTiker(getToken);
         //存储到redis
         JSONObject dingObj = new JSONObject();
         dingObj.put("token", getToken);
         dingObj.put("jsApiTiker", jsapiToken);
         redisTemplate.opsForValue().set("ding", dingObj.toJSONString(), 2L, TimeUnit.HOURS);
//        System.out.println("环境：" + env);
        if ("online".equals(env)) {
            //gettoken
            String getToken = dingUtil.getToken();
            //jsApi
            String jsapiToken = dingUtil.getTiker(getToken);
            //存储到redis
            JSONObject dingObj = new JSONObject();
            dingObj.put("token", getToken);
            dingObj.put("jsApiTiker", jsapiToken);
            redisTemplate.opsForValue().set("ding", dingObj.toJSONString(), 2L, TimeUnit.HOURS);
        }
    }
}