//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by FernFlower decompiler)
//

package com.flow.quartz;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import com.flow.pojo.Card;
import com.flow.service.CardService;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Base64;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.Random;
import java.util.concurrent.TimeUnit;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import org.springframework.beans.factory.annotation.Autowired;

public class MyJob {
    @Autowired
    CardService cardService;

    public MyJob() {
    }

    public void execute() throws NoSuchAlgorithmException, InvalidKeyException, IOException, ParseException {
        String accessKey = "448c2cedcdce41428a290d144e81ab6e";
        String str = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
        String accessSecret = "RgoIWycMYGmQfrLwLuT2VWawAhwMO8w7P9zh2dZp";
        String nonce = "";
        Date now = new Date();
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
        String Timestamp = dateFormat.format(now);
        int length = 30;
        Random random = new Random();

        for(int i = length; i > 0; --i) {
            int index = random.nextInt(str.length());
            nonce = nonce + str.charAt(index);
        }

        String stringSignTemp = accessKey + nonce + Timestamp;
        Mac sha256Hmac = Mac.getInstance("HmacSHA256");
        SecretKeySpec secretKeySpec = new SecretKeySpec(accessSecret.getBytes(StandardCharsets.UTF_8), "HmacSHA256");
        sha256Hmac.init(secretKeySpec);
        byte[] hmacBytes = sha256Hmac.doFinal(stringSignTemp.getBytes(StandardCharsets.UTF_8));
        String sign = Base64.getEncoder().encodeToString(hmacBytes);
        String targetUrl = "https://api.spruceiot.cn/api/v1/sim/list/query?pageIndex=1&pageSize=10";
        URL url = new URL(targetUrl);
        HttpURLConnection connection = (HttpURLConnection)url.openConnection();
        connection.setRequestProperty("Accept-Charset", "UTF-8");
        connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
        connection.setRequestProperty("Access-Control-Allow-Origin", "http://localhost:8080");
        connection.setRequestProperty("AccessKey", accessKey);
        connection.setRequestProperty("Nonce", nonce);
        connection.setRequestProperty("Timestamp", Timestamp);
        connection.setRequestProperty("Sign", sign);
        connection.connect();
        BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
        StringBuilder response1 = new StringBuilder();

        String line;
        while((line = reader.readLine()) != null) {
            response1.append(line);
        }

        reader.close();
        connection.disconnect();
        JSONObject jsonObject = new JSONObject(response1);
        int code = jsonObject.getInt("code");
        String message = jsonObject.getStr("message");
        JSONObject result = jsonObject.getJSONObject("result");
        int total1 = result.getInt("total");
        JSONArray list = result.getJSONArray("list");
        System.out.println("定时器执行成功！更新数据");
        int num = total1;
        int t = 0;
        int total = 90;
        int num1 = 0;
        int numm = 0;

        int index;
        String nonce1;
        String Timestamp1;
        String stringSignTemp1;
        String line1;
        String stt1;
        while(numm < num) {
            ++num1;
            System.out.println("第" + num1 + "次调用接口从" + t + "到" + total + "结束:总条数" + num);
            List<Card> card = this.cardService.proxyfindCard();
            String stt = "";

            for(int i = t; i < total; ++i) {
                ++numm;
                if (numm == 90) {
                    stt = stt + ((Card)card.get(i)).getCardnumber();
                } else {
                    stt = stt + ((Card)card.get(i)).getCardnumber() + ",";
                }
            }

            System.out.println(stt);
            stt1 = "";

            for(int i = length; i > 0; --i) {
                index = random.nextInt(str.length());
                stt1 = stt1 + str.charAt(index);
            }

            Date now1 = new Date();
            SimpleDateFormat dateFormat1 = new SimpleDateFormat("yyyyMMddHHmmss");
            nonce1 = dateFormat1.format(now1);
            stringSignTemp1 = accessKey + stt1 + nonce1;
            System.out.println(nonce1);
            byte[] hmacBytes1 = sha256Hmac.doFinal(stringSignTemp1.getBytes(StandardCharsets.UTF_8));
            Timestamp1 = Base64.getEncoder().encodeToString(hmacBytes1);
            stringSignTemp1 = "https://api.spruceiot.cn/api/v1/sim/detail/batch/query";
            stringSignTemp1 = stringSignTemp1 + "?cNo=" + stt;
            URL url1 = new URL(stringSignTemp1);
            HttpURLConnection connection1 = (HttpURLConnection)url1.openConnection();
            connection1.setRequestProperty("Accept-Charset", "UTF-8");
            connection1.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
            connection1.setRequestProperty("Access-Control-Allow-Origin", "http://localhost:8080");
            connection1.setRequestProperty("AccessKey", accessKey);
            connection1.setRequestProperty("Nonce", stt1);
            connection1.setRequestProperty("Timestamp", nonce1);
            connection1.setRequestProperty("Sign", Timestamp1);
            connection1.connect();
            BufferedReader reader1 = new BufferedReader(new InputStreamReader(connection1.getInputStream(), "UTF-8"));
            StringBuilder response11 = new StringBuilder();


            while((line1 = reader1.readLine()) != null) {
                response11.append(line1);
            }

            reader1.close();
            connection1.disconnect();
            JSONObject jsonObject1 = new JSONObject(response11);
            int code1 = jsonObject1.getInt("code");
            line1 = jsonObject1.getStr("message");
            JSONArray resultArray = jsonObject1.getJSONArray("result");
            Calendar calendar = Calendar.getInstance();
            SimpleDateFormat date1 = new SimpleDateFormat("yyyy-MM-dd :hh:mm:ss");

            for(int i = 0; i < resultArray.size(); ++i) {
                Card cardl = new Card();
                JSONObject item1 = resultArray.getJSONObject(i);
                cardl.setCardnumber(item1.getStr("iccid"));
                cardl.setOperator(item1.getStr("operators"));
                cardl.setCarddate(item1.getStr("serviceStartDate"));
                cardl.setEnddate(item1.getStr("serviceEndDate"));
                cardl.setEnterdate(item1.getStr("serviceStartDate"));
                cardl.setZflow(item1.getInt("dataLimit"));
                cardl.setSyflow(item1.getInt("dataUsage"));
                cardl.setSyll(item1.getInt("dataLimit") - item1.getInt("dataUsage"));
                cardl.setStatus(item1.getStr("status"));
                cardl.setIccid(item1.getStr("msisdn"));
//                Date date = new Date();
//                Date endDay=date1.parse(cardl.getEnddate());//结束时间
//                Long starTime = date.getTime();
//                Long endTime=endDay.getTime();
//                Long num11=endTime-starTime;//时间戳相差的毫秒数
//                cardl.setRemainingdays(+num11/24/60/60/1000+"天");
//                cardl.setUptime(date1.format(calendar.getTime()));
                this.cardService.proxyupXinXi(cardl);
            }

            t += 90;
            total += 90;

            try {
                TimeUnit.SECONDS.sleep(12L);
            } catch (InterruptedException var59) {
                var59.printStackTrace();
            }
        }

        int sheng = num % 90;
        List<Card> card = this.cardService.proxyfindCard();
        stt1 = "";
        int i = 0;
        index = sheng - 1;

        for(int j = num - sheng; j < num - 1; ++j) {
            ++i;
            if (i == index) {
                stt1 = stt1 + ((Card)card.get(j)).getCardnumber();
            } else {
                stt1 = stt1 + ((Card)card.get(j)).getCardnumber() + ",";
            }
        }

        nonce1 = "";

        for( i = length; i > 0; --i) {
             index = random.nextInt(str.length());
            nonce1 = nonce1 + str.charAt(index);
        }

        Date now1 = new Date();
        SimpleDateFormat dateFormat1 = new SimpleDateFormat("yyyyMMddHHmmss");
        Timestamp1 = dateFormat1.format(now1);
        stringSignTemp1 = accessKey + nonce1 + Timestamp1;
        System.out.println(Timestamp1);
        byte[] hmacBytes1 = sha256Hmac.doFinal(stringSignTemp1.getBytes(StandardCharsets.UTF_8));
        String sign1 = Base64.getEncoder().encodeToString(hmacBytes1);
        String targetUrl1 = "https://api.spruceiot.cn/api/v1/sim/detail/batch/query";
        targetUrl1 = targetUrl1 + "?cNo=" + stt1;
        URL url1 = new URL(targetUrl1);
        HttpURLConnection connection1 = (HttpURLConnection)url1.openConnection();
        connection1.setRequestProperty("Accept-Charset", "UTF-8");
        connection1.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
        connection1.setRequestProperty("Access-Control-Allow-Origin", "http://localhost:8080");
        connection1.setRequestProperty("AccessKey", accessKey);
        connection1.setRequestProperty("Nonce", nonce1);
        connection1.setRequestProperty("Timestamp", Timestamp1);
        connection1.setRequestProperty("Sign", sign1);
        connection1.connect();
        BufferedReader reader1 = new BufferedReader(new InputStreamReader(connection1.getInputStream(), "UTF-8"));
        StringBuilder response11 = new StringBuilder();

        while((line1 = reader1.readLine()) != null) {
            response11.append(line1);
        }

        reader1.close();
        connection1.disconnect();
        JSONObject jsonObject1 = new JSONObject(response11);
        int code1 = jsonObject1.getInt("code");
        String message1 = jsonObject1.getStr("message");
        JSONArray resultArray = jsonObject1.getJSONArray("result");
        Calendar calendar = Calendar.getInstance();
        SimpleDateFormat date2 = new SimpleDateFormat("yyyy-MM-dd :hh:mm:ss");

        for( i = 0; i < resultArray.size(); ++i) {
            Card cardl = new Card();
            JSONObject item1 = resultArray.getJSONObject(i);
            cardl.setCardnumber(item1.getStr("iccid"));
            cardl.setOperator(item1.getStr("operators"));
            cardl.setCarddate(item1.getStr("serviceStartDate"));
            cardl.setEnddate(item1.getStr("serviceEndDate"));
            cardl.setEnterdate(item1.getStr("serviceStartDate"));
            cardl.setZflow(item1.getInt("dataLimit"));
            cardl.setSyflow(item1.getInt("dataUsage"));
            cardl.setStatus(item1.getStr("status"));
            cardl.setIccid(item1.getStr("msisdn"));
            cardl.setSyll(item1.getInt("dataLimit") - item1.getInt("dataUsage"));

//            Date date = new Date();
//            Date endDay=date2.parse(cardl.getEnddate());//结束时间
//            Long starTime = date.getTime();
//            Long endTime=endDay.getTime();
//            Long num11=endTime-starTime;//时间戳相差的毫秒数
//            cardl.setRemainingdays(+num11/24/60/60/1000+"天");
//            cardl.setUptime(date2.format(calendar.getTime()));
            this.cardService.proxyupXinXi(cardl);
        }

        System.out.println("循环结束,等待定时器触发再次调用");
    }
}