//package com.sandu.ximon.admin.service;
|
//
|
//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
//import com.google.gson.Gson;
|
//import com.google.gson.GsonBuilder;
|
//import com.sandu.common.service.impl.BaseServiceImpl;
|
//import com.sandu.ximon.admin.config.RealtimeServerBean;
|
//import com.sandu.ximon.admin.config.XiXunConfig;
|
//import com.sandu.ximon.admin.entity.*;
|
//import com.sandu.ximon.admin.security.SecurityUtils;
|
//import com.sandu.ximon.admin.utils.JsonUtil;
|
//import com.sandu.ximon.admin.utils.LightemitUtils;
|
//import com.sandu.ximon.dao.domain.PoleLightemitEntity;
|
//import com.sandu.ximon.dao.domain.PoleXixunPlayerEntity;
|
//import com.sandu.ximon.dao.mapper.PoleXixunPlayerEntityMapper;
|
//import lombok.AllArgsConstructor;
|
//import org.springframework.stereotype.Service;
|
//
|
//import java.text.SimpleDateFormat;
|
//import java.util.*;
|
//
|
//@Service
|
//@AllArgsConstructor
|
//public class XiXunPlayerService extends BaseServiceImpl<PoleXixunPlayerEntityMapper, PoleXixunPlayerEntity> {
|
//
|
// private final PoleXixunPlayerEntityMapper poleXixunPlayerEntityMapper;
|
// private final XiXunConfig config;
|
// private final LightemitUtils lightemitUtils;
|
// private final RealtimeServerBean realtimeServerBean;
|
//
|
//
|
// public void insert(ProgramPro programPro, Long userId) {
|
// SimpleDateFormat sdf=new SimpleDateFormat("yy-MM-dd HH:mm:ss");
|
// Date date = new Date();
|
//// Program program = new Program();
|
//// try {
|
//// program = JsonUtil.convertJsonStringToObject(json,Program.class);
|
//// } catch (Exception e) {
|
//// e.printStackTrace();
|
//// }
|
// String json = JsonUtil.jsonObj2Sting(programPro);
|
// PoleXixunPlayerEntity poleXixunPlayer = new PoleXixunPlayerEntity();
|
// poleXixunPlayer.setProgramCode(programPro.get_id());
|
// poleXixunPlayer.setProgramName(programPro.getName());
|
// poleXixunPlayer.setHeight(programPro.getHeight());
|
// poleXixunPlayer.setWidth(programPro.getWidth());
|
// poleXixunPlayer.setTotalSize((float) programPro.getTotalSize()/1000000+"MB");
|
// poleXixunPlayer.setRequestBody(json);
|
// poleXixunPlayer.setCreatTime(sdf.format(date));
|
// poleXixunPlayer.setCreateUserId(SecurityUtils.getClientId());
|
//
|
// this.save(poleXixunPlayer);
|
// }
|
//
|
// public void videoXixunPlayer(long programId,Long[] lightemitIds) {
|
//
|
// ProgramPro pro = new ProgramPro();
|
// ItemPro items = new ItemPro();
|
// TaskPro taskPro = new TaskPro();
|
// CommandPro command = new CommandPro();
|
// XixunPlayerPro xixun = new XixunPlayerPro();
|
// PoleXixunPlayerEntity poleXixunPlayerEntity = new PoleXixunPlayerEntity();
|
// items.set_id(UUID.randomUUID().toString());
|
// QueryWrapper<PoleXixunPlayerEntity> queryWrapper = new QueryWrapper<>();
|
// queryWrapper.eq("program_id",programId);
|
// poleXixunPlayerEntity = this.getOne(queryWrapper);
|
// String json = poleXixunPlayerEntity.getRequestBody();
|
// try {
|
// pro = JsonUtil.convertJsonStringToObject(json, ProgramPro.class);
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// items.set_program(pro);
|
// items.setRepeatTimes(1);
|
// items.setSchedulePros(null);//定时段，不做定时可为null
|
// taskPro.set_id(UUID.randomUUID().toString());
|
// taskPro.setName(poleXixunPlayerEntity.getProgramName());
|
// List<ItemPro> list2=new ArrayList<ItemPro>();
|
// list2.add(items);
|
// taskPro.setItems(list2);
|
// command.setId(UUID.randomUUID().toString());
|
// //这里是下方的post回调地址，需要修改IP地址
|
// command.setNotificationURL("http://" + config.getIp() + ":" + config.getPort() + "/machine-fast/serv/download/getJSON");
|
// //资源下载链接的请求头
|
// command.setPreDownloadURL("http://" + config.getIp() + ":" + config.getPort() + "/machine-fast/serv/download/downliadFileById/");
|
// command.setTask(taskPro);
|
// xixun.set_id(UUID.randomUUID().toString());
|
// xixun.setCommand(command);
|
// xixun.setType("commandXixunPlayer"); //命令固定类型，不可更改
|
//
|
//
|
// Gson gson = new GsonBuilder().disableHtmlEscaping().create();
|
//// String jsondata = JSON.toJSONString(xixun);
|
// String jsondata = gson.toJson(xixun);
|
//
|
//// Collection<PoleLightemitEntity> poleLightemitEntities = poleLightemitService.listByIds(Arrays.asList(lightemitIds));
|
////
|
//// if(poleLightemitEntities != null){
|
//// for (PoleLightemitEntity entity: poleLightemitEntities) {
|
//// lightemitUtils.clear(entity.getLightemitControlCode());
|
//// poleLightemitService.updateRequestBody(entity.getLightemitControlCode(), jsondata);
|
//// lightemitUtils.post(realtimeServerBean.getCommand() + entity.getLightemitControlCode(), jsondata);
|
//// }
|
//// }
|
// }
|
//
|
//}
|
