diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java b/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java index d23548f..826eec8 100644 --- a/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java +++ b/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java @@ -40,8 +40,11 @@ import org.dromara.sample.manage.model.dto.*; import org.dromara.sample.manage.model.entity.DeviceStreamEntity; import org.dromara.sample.manage.service.IDeviceStreamService; import org.dromara.sample.media.mapper.IFileMapper; +import org.dromara.sample.wayline.model.dto.WaylineJobDTO; +import org.dromara.sample.wayline.service.IWaylineJobService; import org.dromara.system.api.RemoteConfigService; import org.json.JSONObject; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; @@ -73,6 +76,8 @@ public class MegaphoneController { @Resource private ServicesPublish servicesPublish; + @Autowired + private IWaylineJobService waylineJobService; @Resource PropertySetPublish propertySetPublish; @@ -303,8 +308,19 @@ public class MegaphoneController { Map map = new HashMap<>(); map.put("labelEn",type); map.put("deviceSn",objectMap.get("deviceSn")); - map.put("jobId",objectMap.get("jobId")); - map.put("jobName",objectMap.get("jobName")); + if (Objects.isNull(objectMap.get("jobId"))){ + map.put("jobId",objectMap.get("jobId")); + map.put("jobName",objectMap.get("jobName")); + }else { + Optional waylineJobDTO = waylineJobService.getJobByJobInternalId(objectMap.get("jobId").toString()); + map.put("jobId",objectMap.get("jobId")); + if (!waylineJobDTO.isEmpty()){ + map.put("jobName",waylineJobDTO.get().getJobName()); + }else { + map.put("jobName",null); + } + + } StreamTypeDTO param1 = Convert.convert(StreamTypeDTO.class, map); gatewayPublish.publish(topTow,new CommonTopicRequest<>() .setData(Objects.requireNonNull(param1)),1); @@ -349,8 +365,14 @@ public class MegaphoneController { Map map = new HashMap<>(); map.put("labelEn",type); map.put("deviceSn",objectMap.get("deviceSn")); - map.put("jobId",objectMap.get("jobId")); - map.put("jobName",objectMap.get("jobName")); + if (Objects.isNull(objectMap.get("jobId"))){ + map.put("jobId",objectMap.get("jobId")); + map.put("jobName",objectMap.get("jobName")); + }else { + Optional waylineJobDTO = waylineJobService.getJobByJobInternalId(objectMap.get("jobId").toString()); + map.put("jobId",waylineJobDTO.get().getJobId()); + map.put("jobName",waylineJobDTO.get().getJobName()); + } StreamTypeDTO param1 = Convert.convert(StreamTypeDTO.class, map); gatewayPublish.publish(topTow,new CommonTopicRequest<>() .setData(Objects.requireNonNull(param1)),1);