华星智控IOT管理平台
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
fei.wang
2024-03-21 ab64b09ce3020b376af1e6ee0326ea71330d34ad 
 src/main/java/com/flow/quartz/MyJob.java


@@ -9,6 +9,7 @@


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;


@@ -28,6 +29,7 @@


import java.util.concurrent.TimeUnit;


import javax.crypto.Mac;


import javax.crypto.spec.SecretKeySpec;




import org.springframework.beans.factory.annotation.Autowired;




public class MyJob {


@@ -87,7 +89,7 @@


        int total1 = result.getInt("total");


        JSONArray list = result.getJSONArray("list");


        System.out.println("定时器执行成功！更新数据");


        int num = total1;


        int num = total1;  //第三方所有卡号


        int t = 0;


        int total = 90;


        int num1 = 0;


@@ -103,18 +105,21 @@


            ++num1;


            System.out.println("第" + num1 + "次调用接口从" + t + "到" + total + "结束:总条数" + num);


            List<Card> card = this.cardService.proxyfindCard();


            String stt = "";


            String stt = ""; //从数据库查询的卡号




            for(int i = t; i < total; ++i) {


                ++numm;


                if (numm == 90) {


                    stt = stt + ((Card)card.get(i)).getCardnumber();


                } else {


                    if (card.size() <= i) {


                        break;


                    } else {


                    stt = stt + ((Card)card.get(i)).getCardnumber() + ",";


                }


            }




            System.out.println(stt);


                }


            }


            stt1 = "";




            for(int i = length; i > 0; --i) {


@@ -126,11 +131,11 @@


            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;


            stringSignTemp1 = stringSignTemp1 + "?cNo=" + stt.replaceAll("\\s+", "");


            URL url1 = new URL(stringSignTemp1);


            HttpURLConnection connection1 = (HttpURLConnection)url1.openConnection();


            connection1.setRequestProperty("Accept-Charset", "UTF-8");


@@ -157,7 +162,7 @@


            JSONArray resultArray = jsonObject1.getJSONArray("result");


            Calendar calendar = Calendar.getInstance();


            SimpleDateFormat date1 = new SimpleDateFormat("yyyy-MM-dd :hh:mm:ss");




            if (resultArray!=null) {


            for(int i = 0; i < resultArray.size(); ++i) {


                Card cardl = new Card();


                JSONObject item1 = resultArray.getJSONObject(i);


@@ -171,106 +176,100 @@


                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() + ",";


            }


                break;


        }




        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);


        }


//


//        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;


//        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.replaceAll("\\s+", "");


//        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("循环结束,等待定时器触发再次调用");


    }