| | |
| | | package com.sandu.ximon.admin.service; |
| | | |
| | | import cn.hutool.json.JSONUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | |
| | | layerPro.getSources().forEach(sourcePro -> { |
| | | long fileId = Long.parseLong(sourcePro.getId()); |
| | | LedSFile file = xiXunFileService.getById(fileId); |
| | | if(file != null){ |
| | | if (file != null) { |
| | | String fileUrl = file.getFileUrl(); |
| | | String[] split = fileUrl.split("/"); |
| | | sourcePro.setId(split[split.length - 1]); |
| | |
| | | |
| | | Gson gson = new GsonBuilder().disableHtmlEscaping().create(); |
| | | String jsondata = gson.toJson(xixun); |
| | | System.out.println("推送内容" + JSONUtil.toJsonStr(jsondata)); |
| | | |
| | | |
| | | Collection<PoleLightemitEntity> poleLightemitEntities = poleLightemitService.listByIds(lightemitIds); |
| | | |
| | |
| | | lightemitUtils.clearPlayerTask(lightemitControlCode); |
| | | //推送最后命令 |
| | | lightemitUtils.sendLastCommand(lightemitControlCode); |
| | | |
| | | /** |
| | | * 熙汛大气数据推送日志记录开始 |
| | | // */ |
| | | // String content = "{设备code:" + lightemitControlCode |
| | | // + ", 推送内容:" + body |
| | | // + " }"; |
| | | // List<String> listCode = new ArrayList<>(); |
| | | // listCode.add(lightemitControlCode); |
| | | // StoreOperationRecordsUtils.storeOperationData(listCode, null, "熙汛大气数据推送", content); |
| | | /** |
| | | * 熙汛大气数据推送日志记录结束 |
| | | */ |
| | | } |
| | | }, 60 * 1000); |
| | | } |