//
|
// 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 {
|
if (card.size() <= i) {
|
break;
|
} else {
|
stt = stt + ((Card) card.get(i)).getCardnumber() + ",";
|
}
|
|
}
|
}
|
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;
|
|
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.replaceAll("\\s+", "");
|
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");
|
if (resultArray!=null) {
|
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"));
|
this.cardService.proxyupXinXi(cardl);
|
}
|
t += 90;
|
total += 90;
|
try {
|
TimeUnit.SECONDS.sleep(12L);
|
} catch (InterruptedException var59) {
|
var59.printStackTrace();
|
}
|
}else{
|
break;
|
}
|
|
}
|
//
|
// 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("循环结束,等待定时器触发再次调用");
|
}
|
}
|
