| | |
| | | private DingConfig dingConfig; |
| | | |
| | | |
| | | 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); |
| | | //设置参数 |
| | |
| | | // 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 = 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); |
| | | } |
| | | } |
| | | } |