Browse Source

自动播放直播流

dev
吴远 3 weeks ago
parent
commit
14f7888f77
  1. 8
      dk-common/common-oss/src/main/java/org/dromara/common/oss/core/OssClient.java
  2. 2
      dk-modules/sample/src/main/java/org/dromara/sample/CloudApiSampleApplication.java
  3. 13
      dk-modules/sample/src/main/java/org/dromara/sample/job/WaylineDeviceJobExecutor.java

8
dk-common/common-oss/src/main/java/org/dromara/common/oss/core/OssClient.java

@ -397,6 +397,10 @@ public class OssClient {
return upload(inputStream, getPath(properties.getPrefix(), suffix), length, contentType);
}
public UploadResult uploadSuffixNew(InputStream inputStream, String suffix, Long length, String contentType) {
return upload(inputStream, suffix, length, contentType);
}
public UploadResult uploadSuffix(InputStream inputStream, String suffix, String fileName,Long length, String contentType) {
@ -527,6 +531,10 @@ public class OssClient {
return path + suffix;
}
public String getPathNew(String prefix, String suffix) {
return prefix + suffix;
}
public String getPath(String prefix,String fileName, String suffix) {
// 生成uuid

2
dk-modules/sample/src/main/java/org/dromara/sample/CloudApiSampleApplication.java

@ -1,5 +1,6 @@
package org.dromara.sample;
import com.aizuda.snailjob.client.starter.EnableSnailJob;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@ -12,6 +13,7 @@ import org.springframework.scheduling.annotation.EnableScheduling;
@EnableScheduling
@ComponentScan("org.dromara")
@EnableFeignClients
@EnableSnailJob
public class CloudApiSampleApplication {
public static void main(String[] args) {

13
dk-modules/sample/src/main/java/org/dromara/sample/job/WaylineDeviceJobExecutor.java

@ -1,5 +1,6 @@
package org.dromara.sample.job;
import cn.hutool.json.JSONUtil;
import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
import com.aizuda.snailjob.client.job.core.dto.JobArgs;
import com.aizuda.snailjob.client.job.core.executor.AbstractJobExecutor;
@ -34,7 +35,7 @@ public class WaylineDeviceJobExecutor {
@Autowired
private IWaylineFileService waylineFileService;
@JobExecutor(name = "mediaFileJob")
protected ExecuteResult doMediaFileJobJobExecute(JobArgs jobArgs) {
public ExecuteResult doMediaFileJobJobExecute(JobArgs jobArgs) {
WaylineDeviceJobBo waylineDeviceJobBo = JsonUtils.parseObject(jobArgs.getJobParams().toString(), WaylineDeviceJobBo.class);
List<MediaFileEntity> mediaFileEntitys = fileService.getListBywaylineDeviceJobBo(waylineDeviceJobBo);
OssClient mediafile = OssFactory.instance("mediafile");
@ -53,17 +54,17 @@ public class WaylineDeviceJobExecutor {
}
@JobExecutor(name = "waylineFileJob")
protected ExecuteResult doWaylineFileJobExecute(JobArgs jobArgs) {
public ExecuteResult doWaylineFileJobExecute(JobArgs jobArgs) {
System.out.println("狗从-------------------------》");
WaylineDeviceJobBo waylineDeviceJobBo = JsonUtils.parseObject(jobArgs.getJobParams().toString(), WaylineDeviceJobBo.class);
WaylineDeviceJobBo waylineDeviceJobBo = JSONUtil.toBean(JSONUtil.parseObj(jobArgs.getJobParams()),WaylineDeviceJobBo.class);
List<WaylineFileEntity> waylineFileEntities = waylineFileService.getListBywaylineDeviceJobBo(waylineDeviceJobBo);
OssClient waylinefile = OssFactory.instance("waylinefile");
OssClient waylinefileNW = OssFactory.instance("waylinefileNW");
for (WaylineFileEntity waylineFileEntity:waylineFileEntities){
String privateUrl = waylinefile.getPrivateUrl(waylineFileEntity.getObjectKey(), 3600);
//String privateUrl = waylinefile.getPrivateUrl(waylineFileEntity.getObjectKey(), 3600);
try {
InputStream inputStream = waylinefile.getObjectContent(privateUrl);
waylinefileNW.uploadSuffix(inputStream,waylineFileEntity.getObjectKey(), Long.getLong(String.valueOf(inputStream.available())), "kmz");
InputStream inputStream = waylinefile.getObjectContent(waylineFileEntity.getObjectKey());
waylinefileNW.uploadSuffixNew(inputStream,waylineFileEntity.getObjectKey(), Long.getLong(String.valueOf(inputStream.available())), "kmz");
} catch (IOException e) {
throw new RuntimeException(e);
}

Loading…
Cancel
Save