XMPoleManager.git

			@@ -1,107 +1,132 @@
			//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();
			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.execption.BusinessException;
			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.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;
			private final PoleLightemitService poleLightemitService;


			public boolean insert(ProgramPro programPro) {
			// SimpleDateFormat sdf=new SimpleDateFormat("yy-MM-dd HH:mm:ss");
			// Date date = new Date();
			// Program program = new Program();
			// try {
			// pro = JsonUtil.convertJsonStringToObject(json, ProgramPro.class);
			// program = JsonUtil.convertJsonStringToObject(json,Program.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);
			//// }
			//// }
			// }
			//
			//}
			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());

			return this.save(poleXixunPlayer);
			}

			public boolean deleteProgram(Long pid) {
			PoleXixunPlayerEntity byId = getById(pid);
			if (byId == null) {
			throw new BusinessException("未找到该节目");
			}
			return removeById(pid);
			}

			public Object getByPid(Long pid) {
			PoleXixunPlayerEntity byId = getById(pid);
			if (byId == null) {
			throw new BusinessException("未找到该节目");
			}
			String json = byId.getRequestBody();
			ProgramPro programPro = new ProgramPro();
			try {
			programPro = JsonUtil.convertJsonStringToObject(json, ProgramPro.class);
			} catch (Exception e) {
			e.printStackTrace();
			}
			return programPro;
			}

			public void videoXixunPlayer(long programId, List<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<>();
			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(lightemitIds);

			if(poleLightemitEntities != null){
			for (PoleLightemitEntity entity: poleLightemitEntities) {
			lightemitUtils.clear(entity.getLightemitControlCode());
			poleLightemitService.updateRequestBody(entity.getLightemitControlCode(), jsondata);
			lightemitUtils.post(realtimeServerBean.getCommand() + entity.getLightemitControlCode(), jsondata);
			}
			}
			}


			}