|
|
@ -136,7 +136,7 @@ public class MediaServiceImpl extends AbstractMediaService implements IMediaServ |
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
|
notifyUploadedCount(mediaFileCount, request, jobId, device); |
|
|
|
notifyUploadedCount(mediaFileCount, request, jobId, device,deviceQrtzFileEntities); |
|
|
|
return new TopicEventsResponse<MqttReply>().setData(MqttReply.success()); |
|
|
|
} |
|
|
|
|
|
|
@ -185,7 +185,7 @@ public class MediaServiceImpl extends AbstractMediaService implements IMediaServ |
|
|
|
return fileFlag> 0; |
|
|
|
} |
|
|
|
|
|
|
|
private void notifyUploadedCount(MediaFileCountDTO mediaFileCount, TopicEventsRequest<FileUploadCallback> request, String jobId, DeviceDTO dock) { |
|
|
|
private void notifyUploadedCount(MediaFileCountDTO mediaFileCount, TopicEventsRequest<FileUploadCallback> request, String jobId, DeviceDTO dock, List<DeviceQrtzFileEntity> deviceQrtzFileEntities) { |
|
|
|
// Do not notify when files that do not belong to the route are uploaded.
|
|
|
|
//不通知不属于路由的文件被上传。
|
|
|
|
if (Objects.isNull(mediaFileCount)) { |
|
|
|