package com.sandu.ximon.admin.utils;
|
|
import cn.hutool.core.lang.Snowflake;
|
import com.alibaba.fastjson.JSONObject;
|
import com.google.gson.Gson;
|
import com.sandu.common.file.FileUploadDto;
|
import com.sandu.ximon.admin.config.RealtimeServerBean;
|
import com.sandu.ximon.admin.service.PoleLightemitService;
|
import com.sandu.ximon.admin.utils.request.*;
|
import com.sandu.ximon.dao.domain.PoleLightemitEntity;
|
import com.squareup.okhttp.*;
|
import org.apache.commons.lang.StringEscapeUtils;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.stereotype.Component;
|
|
import java.io.IOException;
|
|
/**
|
* 熙讯屏幕控制
|
*/
|
|
@Component
|
public class LightemitUtils {
|
@Autowired
|
RealtimeServerBean realtimeServerBean;
|
|
@Autowired
|
PoleLightemitService poleLightemitService;
|
@Autowired
|
ApplicationContext applicationContext;
|
//body封装编码
|
private final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
|
|
private OkHttpClient client = new OkHttpClient();
|
|
@Autowired
|
private Snowflake snowflake;
|
|
|
public void init() {
|
//重新获取单例
|
poleLightemitService = applicationContext.getBean(PoleLightemitService.class);
|
}
|
|
/**
|
* post请求封装方法
|
*
|
* @param url url
|
* @param json body
|
* @return
|
*/
|
public String post(String url, String json) {
|
RequestBody body = RequestBody.create(JSON, json);
|
Request request = new Request.Builder()
|
.url(url)
|
.post(body)
|
.build();
|
try {
|
Response response = client.newCall(request).execute();
|
return response.body().string();
|
} catch (IOException e) {
|
LogUtils.error(e.getMessage());
|
return "";
|
}
|
}
|
|
/**
|
* 获取led屏宽度
|
*
|
* @param ledCode led屏编号
|
* @return
|
*/
|
public String getScreenWidth(String ledCode) {
|
String postBody = new Gson().toJson(new GetScreenWidth());
|
//请求地址
|
String url = realtimeServerBean.getCommand() + ledCode;
|
//请求
|
String result = post(url, postBody);
|
if (StringUtils.isNotBlank(result)) {
|
try {
|
return JSONObject.parseObject(result).get("result").toString();
|
} catch (Exception e) {
|
return "64";
|
}
|
} else {
|
return "64";
|
}
|
}
|
|
/**
|
* 获取led屏高度
|
*
|
* @param ledCode led屏编号
|
* @return
|
*/
|
public String getScreenHeight(String ledCode) {
|
String postBody = new Gson().toJson(new GetScreenHeight());
|
//请求地址
|
String url = realtimeServerBean.getCommand() + ledCode;
|
//请求
|
String result = post(url, postBody);
|
if (StringUtils.isNotBlank(result)) {
|
try {
|
return JSONObject.parseObject(result).get("result").toString();
|
} catch (Exception e) {
|
return "64";
|
}
|
} else {
|
return "64";
|
}
|
}
|
|
/**
|
* 清屏操作
|
*
|
* @param ledCode
|
*/
|
public String clear(String ledCode) {
|
String postBody = new Gson().toJson(new Clear());
|
//请求地址
|
String url = realtimeServerBean.getCommand() + ledCode;
|
//请求
|
String result = post(url, postBody);
|
LogUtils.error("清屏结果:" + result);
|
return result;
|
}
|
|
/**
|
* html传输至led屏
|
*
|
* @param ledCode
|
* @param username
|
*/
|
public void postHtml(String ledCode, String username) {
|
//html网页内容
|
PostHtml postHtml = new PostHtml(realtimeServerBean.getUrl() + username + "_" + ledCode + ".html");
|
String postBody = new Gson().toJson(postHtml);
|
//请求地址
|
String url = realtimeServerBean.getCommand() + ledCode;
|
//保存led数据
|
poleLightemitService.updateRequestBody(ledCode, postBody);
|
//请求
|
String result = post(url, postBody);
|
}
|
|
|
/**
|
* 视频传输至led屏
|
*
|
* @param screenWidth
|
* @param screenHeight
|
* @param ledCode
|
*/
|
public String postFile(String screenWidth, String screenHeight, String ledCode, FileUploadDto fileUploadDto) {
|
|
String fileUrl = fileUploadDto.getFileUrl();
|
String[] split = fileUrl.split("/");
|
String id = split[split.length - 1];
|
|
|
//led开发板下载视频请求body
|
DownloadFileToLocal downloadFileToLocal = new DownloadFileToLocal();
|
downloadFileToLocal.url = realtimeServerBean.getUrl() + "https://ximonsmart.oss-cn-shanghai.aliyuncs.com/" + id;
|
downloadFileToLocal.path += fileUrl;
|
|
//led开发板下载视频请求
|
this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(downloadFileToLocal));
|
|
//led开发板视频列表请求body
|
SetPlayList setPlayList = new SetPlayList();
|
setPlayList.list[0] = fileUrl;
|
setPlayList.pathList[0] = ledCode;
|
try {
|
setPlayList.width = Integer.valueOf(screenWidth);
|
setPlayList.height = Integer.valueOf(screenHeight);
|
} catch (Exception e) {
|
return "推送失败";
|
}
|
String postBody = new Gson().toJson(setPlayList);
|
|
//led开发板视频列表请求
|
String post = this.post(realtimeServerBean.getCommand() + ledCode, postBody);
|
LogUtils.error("视频上传结果:----" + post);
|
if (post.contains("does not exist")) {
|
return "推送失败";
|
} else {
|
//{"_type":"success","_id":"ce8dc3ff-dc88-43b7-8f55-60abd8700f1a","timestamp":1653555160535}
|
if (post.startsWith("{") && post.endsWith("}") && post.contains("_type\":\"success")) {
|
//保存led数据
|
poleLightemitService.updateRequestBody(ledCode, postBody);
|
return "推送成功";
|
} else {
|
return "推送失败";
|
}
|
}
|
}
|
|
|
/**
|
* led屏字幕设置
|
*
|
* @param subTitleSet
|
* @param ledCode
|
*/
|
public void subTitleSet(SubTitleSet subTitleSet, String ledCode, Boolean isSave) {
|
String postBody = new Gson().toJson(subTitleSet);
|
if (isSave == true) {
|
poleLightemitService.updateRequestBody(ledCode, postBody);
|
}
|
this.post(realtimeServerBean.getCommand() + ledCode, postBody);
|
}
|
|
/**
|
* 清除播放列表
|
*
|
* @param ledCode
|
*/
|
public void clearVideoPlay(String ledCode) {
|
this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(new ClearVideoPlay()));
|
}
|
|
/**
|
* 清除节目列表
|
*
|
* @param ledCode
|
*/
|
public void clearPlayerTask(String ledCode) {
|
this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(new ClearPlayerTask()));
|
}
|
|
/**
|
* 发送最新的数据
|
*
|
* @param lightemitControlCode
|
*/
|
public void sendLastCommand(String lightemitControlCode) {
|
PoleLightemitEntity poleLightemitEntity = poleLightemitService.getLedByLightControlCode(lightemitControlCode);
|
if (poleLightemitEntity == null || StringUtils.isBlank(poleLightemitEntity.getRequestBody())) {
|
return;
|
}
|
this.post(realtimeServerBean.getCommand() + lightemitControlCode, poleLightemitEntity.getRequestBody());
|
}
|
|
/**
|
* 获取led屏画面
|
*
|
* @param ledCode
|
*/
|
public String getPicture(String ledCode) {
|
String result = this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(new GetPicture()));
|
//获取base64图片数据
|
if (StringUtils.isBlank(result)) {
|
return "";
|
}
|
String re;
|
try {
|
re = JSONObject.parseObject(result).get("result").toString();
|
} catch (Exception e) {
|
re = "0";
|
}
|
|
if (StringUtils.isBlank(re)) {
|
return "";
|
}
|
//去除换行符
|
re.replaceAll("\r|\n*", "");
|
return re;
|
}
|
|
/**
|
* 判断led屏是否开启
|
*
|
* @param ledCode
|
* @return
|
*/
|
public String getIsScreenOpen(String ledCode) {
|
//发送屏幕是否开启的指令
|
String result = this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(new IsScreenOpen()));
|
if (StringUtils.isNotBlank(result)) {
|
String re;
|
try {
|
re = JSONObject.parseObject(result).get("result").toString();
|
} catch (Exception e) {
|
re = "false";
|
}
|
return re;
|
} else {
|
return "";
|
}
|
}
|
|
|
public boolean getLedOnLine(String ledCode) {
|
//通过屏幕是否开启指令获取屏幕是否在线
|
String result = this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(new IsScreenOpen()));
|
result = result.trim();
|
return result.startsWith("{") && result.endsWith("}");
|
}
|
|
|
/**
|
* 控制屏幕开关
|
*/
|
public String setScreenOpen(String ledCode, Boolean bool) {
|
String result = this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(new setScreenOpen(bool)));
|
if (StringUtils.isNotBlank(result)) {
|
String re = "";
|
try {
|
re = JSONObject.parseObject(result).get("result").toString();
|
} catch (Exception e) {
|
re = "false";
|
}
|
return re;
|
} else {
|
return "";
|
}
|
}
|
|
// //发送最新的数据
|
// public void sendLastCommand(String lightemitControlCode) {
|
// PoleLightemitEntity poleLightemitEntity = poleLightemitService.selectByLightemitControlCode(lightemitControlCode);
|
// if(poleLightemitEntity == null || StringUtils.isBlank(poleLightemitEntity.getRequestBody())){
|
// return;
|
// }
|
// this.post(realtimeServerBean.getCommand() + lightemitControlCode, poleLightemitEntity.getRequestBody());
|
// }
|
|
/**
|
* 设置led音量
|
*/
|
public void setVoiume(String ledCode, Integer volume) {
|
|
SetVolume setVolume = new SetVolume();
|
setVolume.arg1 = volume;
|
String postBody = new Gson().toJson(setVolume);
|
|
//请求
|
String result = post(realtimeServerBean.getCommand() + ledCode, postBody);
|
LogUtils.error("设置结果:-------------------" + result);
|
}
|
|
|
/**
|
* 设置led亮度
|
*/
|
public void setBrightness(String ledCode, Integer brightness) {
|
|
SetBrightness setBrightness = new SetBrightness();
|
setBrightness.arg1 = brightness;
|
String postBody = new Gson().toJson(setBrightness);
|
|
//请求
|
String result = post(realtimeServerBean.getCommand() + ledCode, postBody);
|
LogUtils.error("设置结果:-------------------" + result);
|
}
|
|
// 获取led音量
|
public String getVoiume(String ledCode) {
|
GetVolume getVolume = new GetVolume();
|
String postBody = new Gson().toJson(getVolume);
|
|
//请求
|
String result = post(realtimeServerBean.getCommand() + ledCode, postBody);
|
//请求
|
if (StringUtils.isNotBlank(result)) {
|
try {
|
return JSONObject.parseObject(result).get("result").toString();
|
} catch (Exception e) {
|
return "0";
|
}
|
} else {
|
return "0";
|
}
|
}
|
|
/**
|
* 查询定时
|
*
|
* @param ledCode
|
* @return
|
*/
|
public String getTimeSchedule(String ledCode) {
|
String result = this.post(realtimeServerBean.getCommand() + ledCode, new Gson().toJson(new GetTimeSchedule()));
|
//获取定时json数据
|
// Map map = new Gson().fromJson(result,Map.class);
|
// Gson gson = new Gson();
|
// Task task =gson.fromJson((String)gson.fromJson(result,Map.class).get("task"),Task.class);
|
// Schedules schedules =gson.fromJson((String)gson.fromJson(result,Map.class).get("schedule"),Schedules.class);
|
if (StringUtils.isBlank(result)) {
|
return "";
|
}
|
String re;
|
|
//去除字符串中的\
|
re = StringEscapeUtils.unescapeJavaScript(result);
|
//去除字符串中的}"
|
re = re.replace("}\"", "}");
|
//去除字符串中"{
|
re = re.replace("\"{", "{");
|
re = re.replace("\"null\"", "{}");
|
if (StringUtils.isBlank(re)) {
|
return "";
|
}
|
return re;
|
}
|
}
|
