bonus
/
Bonus-Cloud-Material
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'master' of http://192.168.30.2:3000/bonus/Bonus-Cloud-Material

This commit is contained in:
hongchao 2025-11-26 17:48:25 +08:00
parent 2c587b40d4 b9e55c1619
commit 915aad6e51
16 changed files with 1260 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bonus-modules/bonus-material/pom.xml
View File

@ -128,6 +128,10 @@
<artifactId>pdfbox</artifactId>
<version>2.0.27</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</dependency>
</dependencies>

30
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/controller/BallController.java Normal file
View File

@ -0,0 +1,30 @@
package com.bonus.material.basic.controller;
import com.bonus.common.core.web.domain.AjaxResult;
import com.bonus.material.basic.domain.BallGpsEntity;
import com.bonus.material.basic.video.QxVideotape;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @author 黑子
*/
@RestController
@RequestMapping("/ball/info/")
@Slf4j
public class BallController {
/**
* 新增任务
* @param puid
* @return
*/
@PostMapping("getBallGps")
public AjaxResult getBallGps(@RequestBody String puid) {
BallGpsEntity entity= QxVideotape.getBallGps(puid,null);
return AjaxResult.success(entity);
}
}

72
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/domain/BallGpsEntity.java Normal file
View File

@ -0,0 +1,72 @@
package com.bonus.material.basic.domain;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.List;
/**
* @author 蒋永旗
* @create 2022/7/13 15:03
* @Description
**/
@NoArgsConstructor
@Data
public class BallGpsEntity implements Serializable {
private List<ResDTO> res;
@NoArgsConstructor
@Data
public static class ResDTO implements Serializable {
private String puid;
private String type;
private String idx;
private GPSDTO gps;
@NoArgsConstructor
@Data
public static class GPSDTO implements Serializable {
/**
* 纬度
**/
private String latitude;
/**
* 经度
**/
private String longitude;
/**
* 方向
**/
private String bearing;
/**
* 速度
**/
private String speed;
/**
* 高度
**/
private String altitude;
/**
* 地区
**/
private String state;
/**
* 最大速度
**/
private String maxSpeed;
/**
* 最小速度
**/
private String minSpeed;
/**
* 时间
**/
private String utc;
/**
* 里程
**/
private String mileage;
}
}
}

181
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/video/HttpClientUtil.java Normal file
View File

@ -0,0 +1,181 @@
package com.bonus.material.basic.video;
import com.alibaba.fastjson2.JSONObject;
import com.bonus.common.biz.utils.StringHelper;
import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.ParseException;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.message.BasicHeader;
import org.apache.http.protocol.HTTP;
import org.apache.http.ssl.SSLContextBuilder;
import org.apache.http.ssl.TrustStrategy;
import org.apache.http.util.EntityUtils;
import javax.net.ssl.SSLContext;
import java.io.IOException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Map;
public class HttpClientUtil {
private static final String CHARSET = "utf-8";
private static final String CONTENT_TYPE_TEXT_JSON = "text/json";
/**
* Header参数
*/
private static final String Authorization = "Authorization";
private static SSLConnectionSocketFactory sslConnectionSocketFactory;
private static RequestConfig config;
/**
* 单例实现token
*/
private String accessToken = null;
public String getAccessToken() {
return accessToken;
}
public void setAccessToken(String accessToken) {
this.accessToken = accessToken;
}
public void HttpClientUtils() {
initTrustHosts();
initConfig();
}
private static void initTrustHosts() {
try {
SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
@Override
public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
return true;
}
}).build();
sslConnectionSocketFactory = new SSLConnectionSocketFactory(sslContext, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
}catch (Exception e) {
e.getStackTrace();
}
}
private static void initConfig() {
config = RequestConfig.custom().setConnectTimeout(10000000).setSocketTimeout(10000000).build();
}
public String doPost(String url,String token,Map<String,Object> params) {
// 获得Http客户端(可以理解为:你得先有一个浏览器;注意:实际上HttpClient与浏览器是不一样的)
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
HttpPost httpPost = new HttpPost(url);
// 创建json参数
JSONObject jsonObject = new JSONObject();
for (String key:params.keySet()){
jsonObject.put(key,params.get(key));
}
// 模拟表单
//UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList);
// 将user对象转换为json字符串，并放入entity中
StringEntity entity = new StringEntity(jsonObject.toJSONString(), ContentType.APPLICATION_JSON);
// post请求是将参数放在请求体里面传过去的;这里将entity放入post请求体中
httpPost.setEntity(entity);
httpPost.setHeader("Content-Type", "application/json;charset=utf8");
httpPost.setHeader(Authorization, "Bearer " + token);
// 响应模型
CloseableHttpResponse response = null;
String result = null;
try {
// 由客户端执行(发送)Post请求
response = httpClient.execute(httpPost);
// 从响应模型中获取响应实体
HttpEntity responseEntity = response.getEntity();
//System.out.println("响应状态为:" + response.getStatusLine());
if (responseEntity != null) {
result = EntityUtils.toString(responseEntity);
}
} catch (ClientProtocolException e) {
e.printStackTrace();
} catch (ParseException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
// 释放资源
if (httpClient != null) {
httpClient.close();
}
if (response != null) {
response.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
return result;
}
public static String doHttpPost(String uri, JSONObject jsonObject,String token) {
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
CloseableHttpResponse response = null;
try {
HttpPost httpPost = new HttpPost(uri);
RequestConfig config = RequestConfig.custom()
//连接超时时间
.setConnectTimeout(10*1000)
//从连接池中取的连接的最长时间
.setConnectionRequestTimeout(6000)
//数据传输的超时时间
.setSocketTimeout(2*60*1000)
.build();
//设置请求配置时间
httpPost.setConfig(config);
//装填参数
StringEntity s = new StringEntity(jsonObject.toString(), "utf-8");
s.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE, "application/json"));
//设置参数到请求对象中
httpPost.setEntity(s);
httpPost.setHeader("Content-type", "application/json");
if(StringHelper.isNotEmpty(token)){
httpPost.setHeader("token", token);
}
httpPost.setHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
response = httpClient.execute(httpPost);
int statusCode = response.getStatusLine().getStatusCode();
// System.out.println("statusCode:" +statusCode );
if (HttpStatus.SC_OK == statusCode) {
HttpEntity entity = response.getEntity();
if (null != entity) {
String resStr = EntityUtils.toString(entity, "utf-8");
return resStr;
}
}
} catch (Exception e) {
System.out.println("CloseableHttpClient-post-请求异常:" + e.getMessage()+",case" +String.valueOf(e.getStackTrace()));
} finally {
try {
if (null != response) {
EntityUtils.consume(response.getEntity());
response.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
return null;
}
}

220
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/video/HttpHelp.java Normal file
View File

@ -0,0 +1,220 @@
package com.bonus.material.basic.video;
import org.apache.commons.io.IOUtils;
import java.io.*;
import java.net.URL;
import java.net.URLConnection;
import java.util.List;
import java.util.Map;
public class HttpHelp {
/**
* 向指定URL发送GET方法的请求
*
* @param url 发送请求的URL
* @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
* @return URL 所代表远程资源的响应结果
*/
public static String sendGet(String url, String param) {
String result = "";
BufferedReader in = null;
try {
String urlNameString = url + "?" + param;
URL realUrl = new URL(urlNameString);
// 打开和URL之间的连接
URLConnection connection = realUrl.openConnection();
// 设置通用的请求属性
connection.setRequestProperty("accept", "*/*");
connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 建立实际的连接
connection.connect();
// 获取所有响应头字段
Map<String, List<String>> map = connection.getHeaderFields();
// 遍历所有的响应头字段
for (String key : map.keySet()) {
System.out.println(key + "--->" + map.get(key));
}
// 定义 BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
System.out.println("发送GET请求出现异常！" + e);
e.printStackTrace();
}
// 使用finally块来关闭输入流
finally {
try {
if (in != null) {
in.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
return result;
}
/**
* 向指定 URL 发送POST方法的请求
*
* @param url 发送请求的 URL
* @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
* @return 所代表远程资源的响应结果
*/
public static String sendPost(String url, String param) {
PrintWriter out = null;
BufferedReader in = null;
String result = "";
try {
URL realUrl = new URL(url);
// 打开和URL之间的连接
URLConnection conn = realUrl.openConnection();
// 设置通用的请求属性
conn.setRequestProperty("Charsert", "UTF-8");
conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8");//设置参数类型是json格式
conn.setRequestProperty("accept", "*/*");
conn.setRequestProperty("connection", "Keep-Alive");
conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
conn.setRequestProperty("key", "SonBianDian");
conn.setRequestProperty("secret", "38fb95ccc3483d8f8226150e011a65eb067e856a");
// 发送POST请求必须设置如下两行
conn.setDoOutput(true);
conn.setDoInput(true);
// 获取URLConnection对象对应的输出流
out = new PrintWriter(conn.getOutputStream());
// 发送请求参数
out.print(param);
// flush输出流的缓冲
out.flush();
// 定义BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
System.out.println("发送 POST 请求出现异常！" + e);
e.printStackTrace();
}
// 使用finally块来关闭输出流、输入流
finally {
try {
if (out != null) {
out.close();
}
if (in != null) {
in.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
return result;
}
/**
* 2 * 发送Http post请求 3 * 4 * @param xmlInfo 5 * json转化成的字符串 6 * @param URL 7 *
* 请求url 8 * @return 返回信息 9
*/
public static String doHttpPost(String xmlInfo, String URL) {
InputStream instr = null;
ByteArrayOutputStream out = null;
try {
// System.out.println("发起的数据:" + xmlInfo);
byte[] xmlData = xmlInfo.getBytes("UTF-8");
// String hexStr = ByteHelper.bytesToHexString(xmlData);
// System.out.println(hexStr);
URL url = new URL(URL);
URLConnection urlCon = url.openConnection();
urlCon.setDoOutput(true);
urlCon.setDoInput(true);
urlCon.setUseCaches(false);
urlCon.setRequestProperty("accept", "application/json");
urlCon.setRequestProperty("Content-Type", "application/json");
urlCon.setRequestProperty("Content-length", String.valueOf(xmlData.length));
urlCon.setRequestProperty("key", "SonBianDian");
urlCon.setRequestProperty("secret", "38fb95ccc3483d8f8226150e011a65eb067e856a");
System.out.println(String.valueOf(xmlData.length));
DataOutputStream printout = new DataOutputStream(urlCon.getOutputStream());
printout.write(xmlData);
printout.flush();
printout.close();
instr = urlCon.getInputStream();
byte[] bis = IOUtils.toByteArray(instr);
String ResponseString = new String(bis, "UTF-8");
if ((ResponseString == null) || ("".equals(ResponseString.trim()))) {
System.out.println("返回空");
}
System.out.println("返回数据为:" + ResponseString);
return ResponseString;
} catch (Exception e) {
System.out.println("发送 POST 请求出现异常！" + e);
e.printStackTrace();
return "0";
} finally {
try {
if(out!= null){
out.close();
}
if(instr!=null){
instr.close();
}
} catch (Exception ex) {
}
}
}
/**
* 2 * 发送Http post请求 3 * 4 * @param xmlInfo 5 * json转化成的字符串 6 * @param URL 7 *
* 请求url 8 * @return 返回信息 9
*/
public static String doHttpPosts( String URL,String xmlInfo) {
// System.out.println("发起的数据:" + xmlInfo);
byte[] xmlData = xmlInfo.getBytes();
InputStream instr = null;
ByteArrayOutputStream out = null;
try {
URL url = new URL(URL);
URLConnection urlCon = url.openConnection();
urlCon.setDoOutput(true);
urlCon.setDoInput(true);
urlCon.setUseCaches(false);
urlCon.setRequestProperty("content-Type", "application/json");
urlCon.setRequestProperty("charset", "utf-8");
urlCon.setRequestProperty("Content-length", String.valueOf(xmlData.length));
//System.out.println(String.valueOf(xmlData.length));
DataOutputStream printout = new DataOutputStream(urlCon.getOutputStream());
printout.write(xmlData);
printout.flush();
printout.close();
instr = urlCon.getInputStream();
byte[] bis = IOUtils.toByteArray(instr);
String ResponseString = new String(bis, "UTF-8");
if ((ResponseString == null) || ("".equals(ResponseString.trim()))) {
System.out.println("返回空");
}
// System.out.println("返回数据为:" + ResponseString);
return ResponseString;
} catch (Exception e) {
e.printStackTrace();
return null;
} finally {
try {
if(instr!=null){
instr.close();
}
} catch (Exception ex) {
}
}
}
}

81
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/video/QxVideotape.java Normal file
View File

@ -0,0 +1,81 @@
package com.bonus.material.basic.video;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.bonus.material.basic.domain.BallGpsEntity;
import com.bonus.material.basic.video.json.JacksonHelper;
import org.springframework.stereotype.Component;
import java.util.HashMap;
/**
* 清新平台数据获取
*
* @author 吕继龙
*/
@Component
public class QxVideotape {
private static final String LOGIN_URL2 = "login2";
/**
* 球机定位
*/
private static final String GPSBALLURL = "GPS/C_GS_QueryLastGPSData";
/**
* 系统登录,获取token
*
* @return token
*/
public static String login() {
String json = new JacksonHelper().jsonSerialize(TVideoConfigUtil.getMaps());
String result = HttpHelp.doHttpPosts(TVideoConfigUtil.Q2HTTP_URL + LOGIN_URL2, json);
if (result != null) {
JSONObject object = JSONObject.parseObject(result);
if (object != null) {
String token = object.getString("token");
return token;
} else {
return null;
}
}
return null;
}
/**
* 获取球机GPS
*
* @param
* @return
**/
public static BallGpsEntity getBallGps(String puid, String token) {
try{
if (token == null) {
token = login();
}
HashMap<String, Object> map = new HashMap<>(16);
StringBuilder strJson = new StringBuilder();
strJson.append("{\"puid\":\"").append(puid).append("\",\"idx\": 0,\"type\":\"ST\"},");
map.put("equipment", JSON.parse("[" + strJson.substring(0, strJson.length() - 1) + "]"));
String json = JSON.toJSONString(map);
String res = VideoHttpClient.sendPost(TVideoConfigUtil.Q2HTTP_URL + GPSBALLURL+"?token=" + token, json);
if (res.contains("Res")) {
BallGpsEntity entity = JSON.parseObject(res.toLowerCase(), BallGpsEntity.class);
return entity;
} else {
return null;
}
}catch (Exception e){
e.printStackTrace();
}
return null;
}
}

39
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/video/TVideoConfigUtil.java Normal file
View File

@ -0,0 +1,39 @@
package com.bonus.material.basic.video;
import java.util.HashMap;
import java.util.Map;
/**
* @author 黑子
*/
public class TVideoConfigUtil {
/**
* 请求地址
*/
public static String Q2HTTP_URL="http://10.138.219.3:29605/icvs2/";
// 登录平台企业ID
public static Map<String, Object> getMaps(){
Map<String, Object> params = new HashMap<>(16);
params.put("params","VB3worGsbmwch4zo0ys17PtGbfI+UuovOO59+crbPXheSNEtZehgdpPqMTKnkMIY2GXBvmNERuNMVMsZMXF2YyTqCyMc0Rn8ygoD7GGYo3tfLi9Rh9aXqSPHc4gNhJkQ");
return params;
}
/**
* 获取url
* @return
*/
public String getUrl(){
try{
return TVideoConfigUtil.Q2HTTP_URL;
}catch (Exception e){
return null;
}
}
}

390
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/video/VideoHttpClient.java Normal file
View File

@ -0,0 +1,390 @@
package com.bonus.material.basic.video;
import com.alibaba.fastjson2.JSONObject;
import com.bonus.common.biz.utils.StringHelper;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import org.apache.http.HttpResponse;
import org.apache.http.StatusLine;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author 吕继龙
* http请求类
*/
public class VideoHttpClient {
static RestTemplate restTemplate;
/**
* 生成post请求的JSON请求参数
* 请求示例:
* {
* "id":1,
* "name":"张耀烽"
* }
*
* @return
*/
private static HttpEntity<Map<String, String>> generatePostJson(Map<String, String> jsonMap, String token) {
//如果需要其它的请求头信息、都可以在这里追加
HttpHeaders httpHeaders = new HttpHeaders();
MediaType type = MediaType.parseMediaType("application/json;charset=UTF-8");
if (StringHelper.isNotEmpty(token)) {
httpHeaders.add("token", token);
}
if (jsonMap == null) {
jsonMap = new HashMap<>(16);
}
HttpEntity<Map<String, String>> httpEntity = new HttpEntity<>(jsonMap, httpHeaders);
return httpEntity;
}
/**
* post请求、请求参数为json
*
* @return
*/
public static String sendPost(String url, String token, Map<String, String> jsonMap) {
restTemplate = new RestTemplate();
ResponseEntity<String> apiResponse = restTemplate.postForEntity
(
url,
generatePostJson(jsonMap, token),
String.class
);
return apiResponse.getBody();
}
private static int nc = 0;
private static OkHttpClient client = new OkHttpClient().newBuilder().build();
/**
* 向指定URL发送GET方法的请求Authenticate
*
* @param url 发送请求的URL
* @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
* @return URL 所代表远程资源的响应结果
*/
public static String sendGetAuthenticate(String url, String param) {
String result = "";
BufferedReader in = null;
try {
String urlNameString = url;
URL realUrl = new URL(urlNameString);
// 打开和URL之间的连接
URLConnection connection = realUrl.openConnection();
// 设置通用的请求属性
connection.setRequestProperty("accept", "*/*");
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("user-agent",
"Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 建立实际的连接
connection.connect();
// 获取所有响应头字段
Map<String, List<String>> map = connection.getHeaderFields();
// 遍历所有的响应头字段
result = getAuthorization(map.get("WWW-Authenticate").get(0), param, "admin", "123456", "POST");
} catch (Exception e) {
System.out.println("发送GET请求出现异常！" + e);
e.printStackTrace();
}
// 使用finally块来关闭输入流
finally {
try {
if (in != null) {
in.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
return result;
}
/**
* 向指定 URL 发送POST方法的请求
*
* @param url 发送请求的 URL
* @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
* @return 所代表远程资源的响应结果
*/
public static String sendPost(String url, String param) {
String result = "";
okhttp3.MediaType mediaType = okhttp3.MediaType.parse("application/json");
RequestBody body = RequestBody.create(mediaType, param);
Request request = new Request.Builder()
.url(url)
.method("POST", body)
.addHeader("Content-Type", "application/json")
.addHeader("Cookie", "connect.sid=s%3AJNX6IuWZL.rdxyEj7NkC4jXU645BFGtcS98rQ0%2Bibff2nUNJKRuGg")
.build();
try {
Response response = client.newCall(request).execute();
result = response.body().string();
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
/**
* 向指定 URL 发送POST方法的请求
*
* @param url 发送请求的 URL
* @param param 请求参数
* @param authenticate 摘要信息
* @return 所代表远程资源的响应结果
*/
public static String sendPostAuthenticate(String url, String param, String authenticate) {
String result = "";
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
try {
URL realUrl = new URL(url);
HttpPost httpPost = new HttpPost(url);
// 打开和URL之间的连接
httpPost.setHeader("Connection", "keep-alive");
httpPost.setHeader("Authorization", authenticate);
//这里的“application/json” 可以更换因为本人是传的json参数所以用的这个
org.apache.http.HttpEntity entityParam = new StringEntity(param, ContentType.create("application/json", "UTF-8"));
//把参数添加到post请求
httpPost.setEntity(entityParam);
HttpResponse response = httpClient.execute(httpPost);
//获取请求对象中的响应行对象
StatusLine statusLine = response.getStatusLine();
int responseCode = statusLine.getStatusCode();
if (responseCode == 200) {
//获取响应信息
org.apache.http.HttpEntity entity = response.getEntity();
InputStream input = entity.getContent();
BufferedReader br = new BufferedReader(new InputStreamReader(input, "utf-8"));
result = br.readLine();
br.close();
input.close();
} else {
System.out.println("响应失败");
}
} catch (Exception e) {
System.out.println("发送 POST 请求出现异常！" + e);
e.printStackTrace();
}
return result;
}
/**
* @return 接口返回的json数据
* 原理：模拟form表单提交：把请求头部信息和和img 信息 写入到输出流中，
* 通过流把img写入到服务器临时目录里，然后服务器再把img移到指定的位置
* 最后通过写入流来获取post的响应信息。
* @author qimh
* @description 模拟form表单，上传图片
*/
// public static String uploadImg(String authenticate, PeopleEntity peopleEntity, String url) {
// File file = new File(CleanPathUtil.cleanString(peopleEntity.getPersonPhoto()));
// String result = "";
// RequestBody body = new MultipartBody.Builder().setType(MultipartBody.FORM)
// .addFormDataPart("image_data", file.getName(),
// RequestBody.create(okhttp3.MediaType.parse("image/jpeg"),
// file))
//
// .addFormDataPart("groupname", peopleEntity.getMacId())
// .addFormDataPart("label_index", peopleEntity.getFaceID())
// .build();
// Request request = new Request.Builder()
// .url(url)
// .method("POST", body)
// .addHeader("Authorization", authenticate)
// .build();
// try {
// Response response = client.newCall(request).execute();
// result = response.body().string();
// response.close();
// } catch (Exception e) {
// e.printStackTrace();
// }
// return result;
// }
/**
* 生成授权信息
*
* @param authorization 上一次调用返回401的WWW-Authenticate数据
* @param username 用户名
* @param password 密码
* @return 授权后的数据, 应放在http头的Authorization里
* @throws IOException 异常
*/
private static String getAuthorization(String authorization, String uri, String username, String password, String method) throws IOException {
// uri = StringUtils.isEmpty(uri) ? "/" : uri;
// String temp = authorization.replaceFirst("Digest", "").trim().replace("MD5", "\"MD5\"");
// String json = withdrawJson(authorization);
// JSONObject jsonObject = JSON.parseObject(json);
// //客户端随机数
// String cnonce = Digests.generateSalt2(8);
// //认证的次数,第一次是1，第二次是2...
// String ncstr = ("00000000" + 1).substring(Integer.toString(1).length());
// String algorithm = jsonObject.getString("algorithm");
// String qop = jsonObject.getString("qop");
// String nonce = jsonObject.getString("nonce");
// String realm = jsonObject.getString("realm");
//
// String response = Digests.http_da_calc_HA1(username, realm, DigestUtils.md5DigestAsHex(password.getBytes()),
// nonce, ncstr, cnonce, qop,
// method, uri, algorithm);
//
// //组成响应authorization
// authorization = "Digest username=\"" + username + "\"," + temp;
// authorization += ",uri=\"" + uri
// + "\",nc=\"" + ncstr
// + "\",cnonce=\"" + cnonce
// + "\",response=\"" + response + "\"";
return authorization;
}
/**
* 将返回的Authrization信息转成json
*
* @param authorization authorization info
* @return 返回authrization json格式数据 如：String json = "{ \"realm\": \"Wowza\", \" domain\": \"/\", \" nonce\": \"MTU1NzgxMTU1NzQ4MDo2NzI3MWYxZTZkYjBiMjQ2ZGRjYTQ3ZjNiOTM2YjJjZA==\", \" algorithm\": \"MD5\", \" qop\": \"auth\" }";
*/
private static String withdrawJson(String authorization) {
String temp = authorization.replaceFirst("Digest", "").trim().replaceAll("\"", "");
String[] split = temp.split(",");
Map<String, String> map = new HashMap<>(16);
Arrays.asList(split).forEach(c -> {
String c1 = c.replaceFirst("=", ":");
String[] split1 = c1.split(":");
map.put(split1[0].trim(), split1[1].trim());
});
return JSONObject.toJSONString(map);
}
/**
* 删除人员信息
* @param url 地址
* @param authorization 摘要信息
* @param param 数据体
* @return
**/
public static String postDeletePerson(String url, String authorization, String param){
String result = "";
// okhttp3.MediaType mediaType = okhttp3.MediaType.parse("application/json");
// RequestBody body = RequestBody.create(mediaType, param);
// Request request = new Request.Builder()
// .url(url)
// .method("POST", body)
// .addHeader("Authorization", authorization)
// .build();
// try {
// Response response = client.newCall(request).execute();
// result = response.body().string();
// } catch (Exception e) {
// e.printStackTrace();
// }
return result;
}
/**
* 删除人员图片
* @param url 地址
* @param authorization 摘要信息
* @param param 数据体
* @return
**/
public static String postDeleteImage(String url, String authorization, String param){
String result = "";
// okhttp3.MediaType mediaType = okhttp3.MediaType.parse("application/json");
// RequestBody body = RequestBody.create(mediaType, param);
// Request request = new Request.Builder()
// .url(url)
// .method("POST", body)
// .addHeader("Authorization", authorization)
// .build();
// try {
// Response response = client.newCall(request).execute();
// result = response.body().string();
// } catch (Exception e) {
// e.printStackTrace();
// }
return result;
}
public static String sendGet(String url,String token, String param) {
String result = "";
BufferedReader in = null;
try {
String urlNameString = url + "?" + param;
URL realUrl = new URL(urlNameString);
// 打开和URL之间的连接
URLConnection connection = realUrl.openConnection();
// 设置通用的请求属性
connection.setRequestProperty("accept", "*/*");
connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("user-agent",
"Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 建立实际的连接
connection.setRequestProperty("token", token);
connection.connect();
// 获取所有响应头字段
Map<String, List<String>> map = connection.getHeaderFields();
// 遍历所有的响应头字段
for (String key : map.keySet()) {
System.out.println(key + "--->" + map.get(key));
}
// 定义 BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(
connection.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
System.out.println("发送GET请求出现异常！" + e);
e.printStackTrace();
}
// 使用finally块来关闭输入流
finally {
try {
if (in != null) {
in.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
return result;
}
}

48
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/video/json/JacksonHelper.java Normal file
View File

@ -0,0 +1,48 @@
package com.bonus.material.basic.video.json;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.IOException;
/**
* @author 黑子
*/
public class JacksonHelper implements JsonHelper {
@Override
public String jsonSerialize(Object value) {
ObjectMapper objectMapper = new ObjectMapper();
try {
return objectMapper.writeValueAsString(value);
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
@Override
@SuppressWarnings("unchecked")
public <T> T jsonDeserialize(String value, Class<?> tClass) {
ObjectMapper objectMapper = new ObjectMapper();
try {
return (T) objectMapper.readValue(value, tClass);
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
@SuppressWarnings("unchecked")
public <T> T jsonDeserialize(String value,
TypeReference<T> typeReference) {
ObjectMapper objectMapper = new ObjectMapper();
try {
return (T) objectMapper.readValue(value, typeReference);
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
}

9
bonus-modules/bonus-material/src/main/java/com/bonus/material/basic/video/json/JsonHelper.java Normal file
View File

@ -0,0 +1,9 @@
package com.bonus.material.basic.video.json;
public interface JsonHelper {
public String jsonSerialize(Object value);
public <T> T jsonDeserialize(String value, Class<?> tClass);
}

2
bonus-modules/bonus-material/src/main/java/com/bonus/material/lease/domain/LeaseApplyDetails.java
View File

@ -212,6 +212,8 @@ public class LeaseApplyDetails extends BaseEntity {
@ApiModelProperty(value = "任务唯一标识单号")
private String keyId;
private List<String> oldTypeIdList;
@ApiModelProperty(value = "领料物资名称汇总")
private String maTypeNames;
public LeaseApplyDetails(Long id, Long parentId, Long typeId, BigDecimal preNum, BigDecimal auditNum, BigDecimal alNum, String status, Long companyId) {

7
bonus-modules/bonus-material/src/main/java/com/bonus/material/lease/mapper/LeaseApplyDetailsMapper.java
View File

@ -240,4 +240,11 @@ public interface LeaseApplyDetailsMapper {
List<LeaseApplyDetailExport> selectLeaseApplyLL(LeaseApplyInfo bean);
List<LeaseApplyDetailExport> selectLeaseApplyLY(LeaseApplyInfo bean);
/**
* 根据oldTypeId和parentId查询领用待发布数量
* @param detail
* @return
*/
LeaseApplyDetails getPublishNum(LeaseApplyDetails detail);
}

30
bonus-modules/bonus-material/src/main/java/com/bonus/material/lease/mapper/LeaseApplyInfoMapper.java
View File

@ -247,7 +247,7 @@ public interface LeaseApplyInfoMapper {
* @param leaseApplyDetails
* @return
*/
LeaseApplyDetails getPublishNum(LeaseApplyDetails leaseApplyDetails);
List<LeaseApplyDetails> getPublishNum(LeaseApplyDetails leaseApplyDetails);
/**
* 修改领用单的领用单出库数量
@ -319,4 +319,32 @@ public interface LeaseApplyInfoMapper {
* @return
*/
List<Long> selectPublishSignList(LeaseApplyInfo applyInfo);
/**
* 根据parentId及newTypeId查询发布数量
* @param leaseApplyDetails
* @return
*/
List<LeaseApplyDetails> getPublishNumTwo(LeaseApplyDetails leaseApplyDetails);
/**
* 删除该条发布数据
* @param publishDetails
* @return
*/
int deletePublish(LeaseApplyDetails publishDetails);
/**
* 减去该条发布数据
* @param publishDetails
* @return
*/
int subtractLeasePublish(LeaseApplyDetails publishDetails);
/**
* 修改该条发布数据
* @param publishDetails
* @return
*/
int updateLeaseApplyDetails(LeaseApplyDetails publishDetails);
}

95
bonus-modules/bonus-material/src/main/java/com/bonus/material/lease/service/impl/LeaseApplyInfoServiceImpl.java
View File

@ -227,6 +227,17 @@ public class LeaseApplyInfoServiceImpl implements ILeaseApplyInfoService {
LeaseApplyDetails pendingOutNum = mapper.selectPendingOutNum(detail);
detail.setPendingOutNum(pendingOutNum.getPendingOutNum());
detail.setStorageNum(pendingOutNum.getStorageNum());
if (StringUtils.isNotBlank(publishTask)) {
// 根据oldTypeId和parentId查询领用待发布数量
if (StringUtils.isNotBlank(detail.getOldTypeId())) {
List<String> oldTypeIdList = Arrays.asList(detail.getOldTypeId().split(","));
detail.setOldTypeIdList(oldTypeIdList);
}
LeaseApplyDetails applyDetails = leaseApplyDetailsMapper.getPublishNum(detail);
if (applyDetails != null) {
detail.setPendingPublishNum(applyDetails.getPendingPublishNum().add(detail.getPreNum()));
}
}
}
}
stepTimes.put("领用发布查询", System.currentTimeMillis() - step81Start);
@ -1102,23 +1113,77 @@ public class LeaseApplyInfoServiceImpl implements ILeaseApplyInfoService {
@Transactional(rollbackFor = Exception.class)
public AjaxResult updateLeaseNum(LeaseApplyDetails leaseApplyDetails) {
try {
if (leaseApplyDetails.getNewTypeId()!= null){
// 根据parentId查询发布数量
//LeaseApplyDetails applyDetails = leaseApplyInfoMapper.getPublishNum(leaseApplyDetails);
// 根据传入的值判断少了多少发布数量
leaseApplyDetails.setPublishNum(leaseApplyDetails.getPreNum());
int res = leaseApplyInfoMapper.updateLeaseNum(leaseApplyDetails);
if (res <= 0){
return AjaxResult.error("修改领用表失败");
}
res = leaseApplyInfoMapper.updateLeasePublish(leaseApplyDetails);
if (res <= 0){
return AjaxResult.error("修改领料发布表失败");
if (leaseApplyDetails.getNewTypeId()!= null) {
// 根据parentId及oldTypeIdList查询需求数量
List<LeaseApplyDetails> applyDetailsList = leaseApplyInfoMapper.getPublishNum(leaseApplyDetails);
// 根据parentId及newTypeId查询发布及待发布数量
List<LeaseApplyDetails> publishDetailsList = leaseApplyInfoMapper.getPublishNumTwo(leaseApplyDetails);
// 根据传入的值判断发布数量是增加还是减少
// 新数量
BigDecimal preNum = leaseApplyDetails.getPreNum();
// 老数量
BigDecimal publishNum = leaseApplyDetails.getPublishNum();
if (preNum.compareTo(publishNum) > 0) {
// 差值
BigDecimal subtractNum = preNum.subtract(publishNum);
for (LeaseApplyDetails applyDetails : applyDetailsList) {
// 待发布数量
BigDecimal subNum = applyDetails.getPendingNum();
if (subtractNum.compareTo(subNum) <= 0) {
applyDetails.setPendingNum(subtractNum);
leaseApplyInfoMapper.updateLeaseNum(applyDetails);
break;
} else if (subtractNum.compareTo(subNum) > 0) {
subtractNum = subtractNum.subtract(subNum);
applyDetails.setPendingNum(subtractNum);
leaseApplyInfoMapper.updateLeaseNum(applyDetails);
}
}
// 差值
BigDecimal leaseSubtractNum = preNum.subtract(publishNum);
for (LeaseApplyDetails publishDetails : publishDetailsList) {
// 待发布数量
BigDecimal pendingNum = publishDetails.getPendingNum();
if (leaseSubtractNum.compareTo(pendingNum) <= 0) {
publishDetails.setPendingNum(leaseSubtractNum);
leaseApplyInfoMapper.updateLeasePublish(publishDetails);
break;
} else if (leaseSubtractNum.compareTo(pendingNum) > 0) {
leaseSubtractNum = leaseSubtractNum.subtract(pendingNum);
publishDetails.setPendingNum(leaseSubtractNum);
leaseApplyInfoMapper.updateLeasePublish(publishDetails);
}
}
} else if (preNum.compareTo(publishNum) < 0) {
// 差值
BigDecimal leaseSubtractNum = publishNum.subtract(preNum);
for (LeaseApplyDetails publishDetails : publishDetailsList) {
// 发布数量
BigDecimal num = publishDetails.getPublishNum();
if (leaseSubtractNum.compareTo(num) == 0) {
//删除该条发布数据
leaseApplyInfoMapper.deletePublish(publishDetails);
//处理lease_apply_details表数据
leaseApplyInfoMapper.updateLeaseApplyDetails(publishDetails);
break;
} else if (leaseSubtractNum.compareTo(num) > 0) {
leaseSubtractNum = leaseSubtractNum.subtract(num);
leaseApplyInfoMapper.deletePublish(publishDetails);
//处理lease_apply_details表数据
leaseApplyInfoMapper.updateLeaseApplyDetails(publishDetails);
} else if (leaseSubtractNum.compareTo(num) < 0) {
publishDetails.setPublishNum(leaseSubtractNum);
leaseApplyInfoMapper.subtractLeasePublish(publishDetails);
//处理lease_apply_details表数据
leaseApplyInfoMapper.updateLeaseApplyDetails(publishDetails);
break;
}
}
}
} else {
int res = leaseApplyInfoMapper.updateLeaseNumTwo(leaseApplyDetails);
if (res <= 0){
return AjaxResult.error("修改领料表失败");
int result = leaseApplyInfoMapper.updateLeaseNumTwo(leaseApplyDetails);
if (result <= 0) {
throw new Exception("修改领料表失败");
}
}
return AjaxResult.success("修改成功");

17
bonus-modules/bonus-material/src/main/resources/mapper/material/lease/LeaseApplyDetailsMapper.xml
View File

@ -89,7 +89,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
lad.create_by, lad.create_time, lad.update_by, lad.update_time, lad.remark, lad.company_id,
mt4.type_id as firstId,
su.sign_url as signUrl,
su.sign_type as signType
su.sign_type as signType,
IFNULL(lad.pre_num,0) as pendingPublishNum
from
lease_apply_details lad
left join
@ -893,4 +894,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
order by lpd.id
</select>
<select id="getPublishNum" resultType="com.bonus.material.lease.domain.LeaseApplyDetails">
SELECT
parent_id as parentId,
GREATEST(SUM(IFNULL(pre_num, 0)) - SUM(IFNULL(publish_num, 0)), 0 ) AS pendingPublishNum
FROM
lease_apply_details
WHERE
parent_id = #{parentId}
AND type_id IN
<foreach item="item" collection="oldTypeIdList" open="(" separator="," close=")">
#{item}
</foreach>
</select>
</mapper>

60
bonus-modules/bonus-material/src/main/resources/mapper/material/lease/LeaseApplyInfoMapper.xml
View File

@ -279,6 +279,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
</foreach>
</delete>
<delete id="deletePublish">
delete from lease_publish_details where id = #{id}
</delete>
<select id="getTaskId" resultType="java.lang.String">
select task_id
from lease_apply_info
@ -840,9 +844,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<update id="updateLeaseNum">
update lease_apply_details
set publish_num=#{publishNum}
where parent_id = #{parentId}
AND new_type = #{newTypeId}
set publish_num = IFNULL(publish_num, 0) + #{pendingNum}
where id = #{id}
</update>
<update id="updateLeaseNumTwo">
@ -854,10 +857,21 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<update id="updateLeasePublish">
update lease_publish_details
set num = #{preNum}
set num = num + #{pendingNum}
where id = #{id}
</update>
<update id="subtractLeasePublish">
update lease_publish_details
set num = num - #{publishNum}
where id = #{id}
</update>
<update id="updateLeaseApplyDetails">
update lease_apply_details
set publish_num = IFNULL(publish_num, 0) - #{publishNum}
where parent_id = #{parentId}
AND new_type = #{newTypeId}
AND publish_task = #{publishTask}
and type_id = #{typeId}
</update>
<select id="getUserList" resultMap="LeaseApplyInfoResult">
@ -987,14 +1001,23 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
</select>
<select id="getPublishNum" resultType="com.bonus.material.lease.domain.LeaseApplyDetails">
SELECT
id AS id,
parent_id AS parentId,
type_id AS typeId,
publish_num AS publishNum
pre_num AS preNum,
publish_num AS publishNum,
pre_num - IFNULL( publish_num, 0 ) AS pendingNum
FROM
lease_apply_details
WHERE
parent_id = #{parentId}
and new_type = #{newTypeId}
AND type_id IN
<foreach item="item" collection="oldTypeIdList" open="(" separator="," close=")">
#{item}
</foreach>
GROUP BY
parent_id,
type_id
</select>
<select id="getSignPublishList" resultType="com.bonus.common.biz.domain.lease.LeaseApplyInfo">
@ -1259,4 +1282,25 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
</if>
</where>
</select>
<select id="getPublishNumTwo" resultType="com.bonus.material.lease.domain.LeaseApplyDetails">
SELECT
lpd.id as id,
lpd.parent_id as parentId,
lpd.type_id as typeId,
lpd.new_type as newTypeId,
lad.pre_num - IFNULL( lad.publish_num, 0 ) as pendingNum,
lpd.num as publishNum
FROM
lease_publish_details lpd
LEFT JOIN lease_apply_details lad ON lpd.parent_id = lad.parent_id
AND lpd.type_id = lad.type_id
WHERE
lpd.new_type = #{newTypeId}
AND lpd.parent_id = #{parentId}
AND lpd.publish_task = #{publishTask}
GROUP BY
lpd.parent_id,
lpd.type_id
</select>
</mapper>