Gb1400RegisterRunner.java 2.07 KB
package com.viontech.runner;

import com.alibaba.fastjson.JSONObject;
import com.viontech.config.Gb1400Config;
import com.viontech.constant.RedisConstants;
import com.viontech.scheduled.Gb1400KeepAlive;
import com.viontech.service.Gb1400Service;
import com.viontech.utils.DateUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.util.DigestUtils;
import org.springframework.util.StringUtils;
import org.springframework.web.client.HttpClientErrorException;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

/**
 * @author vion
 **/
@Component
@Slf4j
public class Gb1400RegisterRunner implements CommandLineRunner {

    @Autowired
    private Gb1400Config gb1400Config;
    @Resource
    private Gb1400Service gb1400Service;

    @Override
    public void run(String... args) {
        if("1".equals(gb1400Config.getEnable()) && !StringUtils.isEmpty(gb1400Config.getUserIdentify())){
            log.info("准备注册平台");
            synchronized (Gb1400KeepAlive.registerLock) {
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        gb1400Service.register(gb1400Config.getUserIdentify());
                    }
                }).start();
            }
        }
    }

    public static void main(String[] args) {
        String body = "{\"ResponseStatusObject\":{\"RequestURL\":\"/VIID/System/Keepalive\",\"StatusCode\":0,\"StatusString\":\"保活成功\",\"Id\":\"41011000005038163699\",\"LocalTime\":\"20220422105631\"}}";
        JSONObject registerResult = JSONObject.parseObject(body);
        System.out.println("x");
    }
}