forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | ignore whitespace
zhaowenyu
2026-01-06 4e8a1c02b45f72f6377603778e8c8746ed82f374 
 ard-sample/src/main/java/com/ard/sample/storage/service/impl/StorageServiceImpl.java


@@ -1,11 +1,12 @@


package com.ard.sample.storage.service.impl;




import com.ard.common.config.OssConfiguration;


import com.ard.sample.component.mqtt.model.*;


import com.ard.sample.component.mqtt.service.IMessageSenderService;


import com.ard.common.config.OssConfiguration;


import com.ard.sample.component.oss.service.impl.OssServiceContext;


import com.ard.sample.media.model.StsCredentialsDTO;


import com.ard.oss.model.StsCredentialsDTO;


import com.ard.sample.config.DockConfiguration;


import com.ard.sample.storage.service.IStorageService;


import com.ard.oss.service.impl.OssServiceContext;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.integration.annotation.ServiceActivator;


import org.springframework.integration.mqtt.support.MqttHeaders;


@@ -29,8 +30,11 @@


    @Override


    public StsCredentialsDTO getSTSCredentials() {


        return StsCredentialsDTO.builder()


                .endpoint(OssConfiguration.endpoint)


                .bucket(OssConfiguration.bucket)


                //机场媒体库minio配置信息用代理地址，桶用机场的桶。


                //.endpoint(OssConfiguration.endpoint)


                .endpoint(DockConfiguration.endpoint)


//                .bucket(OssConfiguration.bucket)


                .bucket(DockConfiguration.bucket)


                .credentials(ossService.getCredentials())


                .provider(OssConfiguration.provider)


                .objectKeyPrefix(OssConfiguration.objectDirPrefix)


@@ -41,6 +45,7 @@


    @Override


    @ServiceActivator(inputChannel = ChannelName.INBOUND_REQUESTS_STORAGE_CONFIG_GET, outputChannel = ChannelName.OUTBOUND)


    public void replyConfigGet(CommonTopicReceiver receiver, MessageHeaders headers) {


        // 20251219 这里是获取上传临时凭证的接口，稍候分析下是否满足条件，如果可以的话就直接回复临时凭证即可


        CommonTopicResponse<RequestsReply> response = CommonTopicResponse.<RequestsReply>builder()


                .tid(receiver.getTid())


                .bid(receiver.getBid())