package com.ruoyi.task; import com.mashape.unirest.http.HttpResponse; import com.mashape.unirest.http.Unirest; import com.mashape.unirest.http.exceptions.UnirestException; import com.ruoyi.aibrain.domain.AiCamera; import com.ruoyi.common.config.RuoYiConfig; import okhttp3.*; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.TrustSelfSignedStrategy; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.ssl.SSLContexts; import org.springframework.stereotype.Component; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLSocketFactory; import javax.net.ssl.TrustManager; import javax.net.ssl.X509TrustManager; import java.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.security.KeyManagementException; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.text.ParseException; import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; /** * 定时任务调度测试 * * @author ruoyi */ @Component("sjcsDlTask") public class SjcsDlTask { //10秒执行一次 public void indexDlTask() { DataAssembleUtil.AssembleCDSSSJ();//实时数据 DataAssembleUtil.AssembleCDYCSJ();//异常数据 } //5分钟执行一次 public void indexCameraTask() { CameraAssembleUtil.cameraSatus();//实时状态 } //执行一次 public void indexCameraAiError() throws ParseException { CameraAssembleUtil.cameraAiError();//摄像头报警传输 } //1分钟执行一次 public void indexCameraAiReturn() { AiCamera aiCamera=new AiCamera(); aiCamera.setCameraNum("1060101"); //CameraAssembleUtil.cameraAiError(aiCamera);//模拟 } public void fileCameraTask() throws UnirestException, KeyStoreException, NoSuchAlgorithmException, KeyManagementException, IOException { //请求地址 String url = "https://192.168.100.89:4200/spjr000/api/open/v1/ai/channel/general/push/"; //String参数 Map params = new HashMap(); params.put("company", RuoYiConfig.getMkbm());//煤矿企业编码 params.put("biz","1060101");//摄像头编码 params.put("channel","0030001");//分析类型编码 params.put("pdt","1705303253");//数据上报时间 params.put("data","");//扩展参数 System.out.println(1111); String boundary = "------WebKitFormBoundary7MA4YWxkTrZu0gW--"; // 设置boundary字符串，用于标识参数和附件的边界 final TrustManager[] trustAllCerts = new TrustManager[]{ new X509TrustManager() { @Override public void checkClientTrusted(java.security.cert.X509Certificate[] chain, String authType) { } @Override public void checkServerTrusted(java.security.cert.X509Certificate[] chain, String authType) { } @Override public java.security.cert.X509Certificate[] getAcceptedIssuers() { return new java.security.cert.X509Certificate[]{}; } } }; final SSLContext sslContext = SSLContext.getInstance("SSL"); sslContext.init(null, trustAllCerts, new java.security.SecureRandom()); final javax.net.ssl.SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory(); OkHttpClient client = new OkHttpClient.Builder() .connectTimeout(30, TimeUnit.SECONDS) .readTimeout(30, TimeUnit.SECONDS) .sslSocketFactory(sslSocketFactory, (X509TrustManager) trustAllCerts[0]) .hostnameVerifier((hostname, session) -> true) // 信任所有主机名 .build(); File file = new File("D:\\AI\\aibrain\\upload\\2024\\01\\15\\2201810148791060101003000120240115152044.mp4"); RequestBody body = new MultipartBody.Builder() .setType(MultipartBody.FORM) .addFormDataPart("company", params.get("company")) .addFormDataPart("biz", params.get("biz")) .addFormDataPart("channel", params.get("channel")) .addFormDataPart("pdt", params.get("pdt")) .addFormDataPart("data", params.get("data")) .addFormDataPart("file", "2201810148791060101003000120240115152044.mp4", RequestBody.create(MediaType.parse("application/octet-stream"), file)) .build(); Request request = new Request.Builder() .url(url) .header("Content-Type", "multipart/form-data; boundary=" + boundary) .post(body) .build(); Response response = client.newCall(request).execute(); if (response.isSuccessful()) { System.out.println("File uploaded successfully1111."+response.body().toString()); System.out.println("File uploaded successfully."+response.toString()); } else { System.out.println("Failed to upload file. Response code: " + response.code()); } } public void fileCameraTaskls() throws UnirestException, KeyStoreException, NoSuchAlgorithmException, KeyManagementException, FileNotFoundException { //请求地址 String url = "https://192.168.100.89:4200/spjr000/api/open/v1/ai/channel/general/push/"; SSLContext sslcontext = SSLContexts.custom() .loadTrustMaterial(null, new TrustSelfSignedStrategy()) .build(); SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext,SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); CloseableHttpClient httpclient = HttpClients.custom() .setSSLSocketFactory(sslsf) .build(); Unirest.setHttpClient(httpclient); //String参数 Map params = new HashMap(); params.put("company", RuoYiConfig.getMkbm());//煤矿企业编码 params.put("biz","1060101");//摄像头编码 params.put("channel","0030001");//分析类型编码 params.put("pdt","1699529835");//数据上报时间 params.put("data","");//扩展参数 System.out.println(1111); String boundary = "------WebKitFormBoundary7MA4YWxkTrZu0gW--"; // 设置boundary File file = new File("D:\\AI\\aibrain\\upload\\2023\\11\\09\\2201810148791060101003000120231109161143.mp4"); /* MultipartBodyRequestBuilder requestBuilder = Unirest.post(url) .header("Content-Type", "multipart/form-data; boundary=" + boundary) .body(MultipartBody.fromFile(file, "file"));*/ HttpResponse response = Unirest.post(url) .header("User-Agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)") .header("Accept", "*/*") .header("Host", "192.168.100.89:4200") .header("Connection", "keep-alive") .header("Content-Type", "multipart/form-data;boundary=" + boundary) //携带的参数 .field("company", params.get("company")) .field("biz", params.get("biz")) .field("channel", params.get("channel")) .field("pdt", params.get("pdt")) .field("data", params.get("data")) .field("file",file) .asString(); System.out.println(2222); System.out.println(response.getBody()); } }