oss 新增cdn
This commit is contained in:
@@ -4,11 +4,15 @@ import com.cool.store.constants.CommonConstants;
|
|||||||
import com.cool.store.entity.RegionDO;
|
import com.cool.store.entity.RegionDO;
|
||||||
import com.cool.store.mapper.RegionMapper;
|
import com.cool.store.mapper.RegionMapper;
|
||||||
import com.google.common.collect.Lists;
|
import com.google.common.collect.Lists;
|
||||||
|
import com.google.common.collect.Maps;
|
||||||
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.collections4.CollectionUtils;
|
||||||
|
import org.apache.commons.collections4.ListUtils;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
import javax.annotation.Resource;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author zhangchenbiao
|
* @author zhangchenbiao
|
||||||
@@ -49,4 +53,12 @@ public class RegionDAO {
|
|||||||
return regionMapper.getRegionBaseInfoList();
|
return regionMapper.getRegionBaseInfoList();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public Map<String, String> getRegionMap(List<String> regionIds){
|
||||||
|
if(CollectionUtils.isEmpty(regionIds)){
|
||||||
|
return Maps.newHashMap();
|
||||||
|
}
|
||||||
|
List<RegionDO> regionList = regionMapper.getRegionNameByRegionIds(regionIds);
|
||||||
|
return ListUtils.emptyIfNull(regionList).stream().collect(Collectors.toMap(RegionDO::getRegionId, RegionDO::getName));
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -39,6 +39,13 @@ public interface RegionMapper {
|
|||||||
*/
|
*/
|
||||||
List<RegionDO> getRegionByRegionIds(@Param("regionIds")List<String> regionIds);
|
List<RegionDO> getRegionByRegionIds(@Param("regionIds")List<String> regionIds);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 根据区域id获取名称
|
||||||
|
* @param regionIds
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
List<RegionDO> getRegionNameByRegionIds(@Param("regionIds")List<String> regionIds);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取区域基本信息
|
* 获取区域基本信息
|
||||||
* @return
|
* @return
|
||||||
|
|||||||
@@ -169,6 +169,16 @@
|
|||||||
|
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
|
<select id="getRegionNameByRegionIds" resultMap="BaseResultMap">
|
||||||
|
select
|
||||||
|
region_id, name
|
||||||
|
from
|
||||||
|
region
|
||||||
|
where
|
||||||
|
deleted = 0 and region_id in <foreach collection="regionIds" item="regionId" separator="," open="(" close=")">#{regionId}</foreach>
|
||||||
|
|
||||||
|
</select>
|
||||||
|
|
||||||
<select id="getRegionBaseInfoList" resultMap="BaseResultMap">
|
<select id="getRegionBaseInfoList" resultMap="BaseResultMap">
|
||||||
select
|
select
|
||||||
region_id, name, parent_id
|
region_id, name, parent_id
|
||||||
|
|||||||
@@ -30,13 +30,17 @@ public class OssUploadConfigVO {
|
|||||||
@ApiModelProperty("上传策略Policy失效时间")
|
@ApiModelProperty("上传策略Policy失效时间")
|
||||||
private String expire;
|
private String expire;
|
||||||
|
|
||||||
public OssUploadConfigVO(String accessKeyId, String policy, String signature, String dir, String host, String expire) {
|
@ApiModelProperty("cdn地址")
|
||||||
|
private String cdnUrl;
|
||||||
|
|
||||||
|
public OssUploadConfigVO(String accessKeyId, String policy, String signature, String dir, String host, String expire, String cdnUrl) {
|
||||||
this.accessKeyId = accessKeyId;
|
this.accessKeyId = accessKeyId;
|
||||||
this.policy = policy;
|
this.policy = policy;
|
||||||
this.signature = signature;
|
this.signature = signature;
|
||||||
this.dir = dir;
|
this.dir = dir;
|
||||||
this.host = host;
|
this.host = host;
|
||||||
this.expire = expire;
|
this.expire = expire;
|
||||||
|
this.cdnUrl = cdnUrl;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -53,7 +53,6 @@ public class XxlJobConfig {
|
|||||||
xxlJobSpringExecutor.setAccessToken(accessToken);
|
xxlJobSpringExecutor.setAccessToken(accessToken);
|
||||||
xxlJobSpringExecutor.setLogPath(logPath);
|
xxlJobSpringExecutor.setLogPath(logPath);
|
||||||
xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
|
xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
|
||||||
logger.info(">>>>>>>>>>> xxl-job config finish,adminAddresses:{},appName:{}", adminAddresses, appName);
|
|
||||||
return xxlJobSpringExecutor;
|
return xxlJobSpringExecutor;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -40,6 +40,8 @@ public class OssClientController {
|
|||||||
private String bucket;
|
private String bucket;
|
||||||
@Value("${corp.id:null}")
|
@Value("${corp.id:null}")
|
||||||
private String corpId;
|
private String corpId;
|
||||||
|
@Value("${cdn.url:null}")
|
||||||
|
private String cdnUrl;
|
||||||
|
|
||||||
@GetMapping("/getUploadFileConfig")
|
@GetMapping("/getUploadFileConfig")
|
||||||
public ResponseResult getUploadFileConfig(){
|
public ResponseResult getUploadFileConfig(){
|
||||||
@@ -60,7 +62,7 @@ public class OssClientController {
|
|||||||
byte[] binaryData = postPolicy.getBytes("utf-8");
|
byte[] binaryData = postPolicy.getBytes("utf-8");
|
||||||
String encodedPolicy = BinaryUtil.toBase64String(binaryData);
|
String encodedPolicy = BinaryUtil.toBase64String(binaryData);
|
||||||
String signature = client.calculatePostSignature(postPolicy);
|
String signature = client.calculatePostSignature(postPolicy);
|
||||||
OssUploadConfigVO result = new OssUploadConfigVO(accessKeyId, encodedPolicy, signature, dir, host, String.valueOf(expireEndTime / 1000));
|
OssUploadConfigVO result = new OssUploadConfigVO(accessKeyId, encodedPolicy, signature, dir, host, String.valueOf(expireEndTime / 1000), cdnUrl);
|
||||||
return ResponseResult.success(result);
|
return ResponseResult.success(result);
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
log.info("exception", e);
|
log.info("exception", e);
|
||||||
|
|||||||
@@ -46,7 +46,11 @@ oss.accessKeyId=LTAI5tRSXy2MrqaaBJ6gReur
|
|||||||
oss.accessKeySecret=FFsl8d9batprJ0vXr0k4Y8ada40Wm2
|
oss.accessKeySecret=FFsl8d9batprJ0vXr0k4Y8ada40Wm2
|
||||||
oss.endpoint=oss-cn-hangzhou.aliyuncs.com
|
oss.endpoint=oss-cn-hangzhou.aliyuncs.com
|
||||||
oss.bucket=cool-store-hsay
|
oss.bucket=cool-store-hsay
|
||||||
|
|
||||||
|
#企业corpId
|
||||||
corp.id = 171cddee76471740
|
corp.id = 171cddee76471740
|
||||||
|
#cdn地址
|
||||||
|
cdn.url=https://testhsaypic.coolstore.cn
|
||||||
|
|
||||||
#TRTC
|
#TRTC
|
||||||
trtc.sdkAppId=1400811820
|
trtc.sdkAppId=1400811820
|
||||||
|
|||||||
@@ -49,7 +49,11 @@ oss.accessKeyId=LTAI5tRSXy2MrqaaBJ6gReur
|
|||||||
oss.accessKeySecret=FFsl8d9batprJ0vXr0k4Y8ada40Wm2
|
oss.accessKeySecret=FFsl8d9batprJ0vXr0k4Y8ada40Wm2
|
||||||
oss.endpoint=oss-cn-hangzhou.aliyuncs.com
|
oss.endpoint=oss-cn-hangzhou.aliyuncs.com
|
||||||
oss.bucket=vec-coolstore
|
oss.bucket=vec-coolstore
|
||||||
|
|
||||||
|
#企业corpId
|
||||||
corp.id = 171cddee76471740
|
corp.id = 171cddee76471740
|
||||||
|
#cdn地址
|
||||||
|
cdn.url=https://testhsaypic.coolstore.cn
|
||||||
|
|
||||||
#TRTC
|
#TRTC
|
||||||
trtc.sdkAppId=1400811820
|
trtc.sdkAppId=1400811820
|
||||||
|
|||||||
@@ -37,6 +37,8 @@ public class OssClientController {
|
|||||||
private String bucket;
|
private String bucket;
|
||||||
@Value("${corp.id:null}")
|
@Value("${corp.id:null}")
|
||||||
private String corpId;
|
private String corpId;
|
||||||
|
@Value("${cdn.url:null}")
|
||||||
|
private String cdnUrl;
|
||||||
|
|
||||||
@GetMapping("/getUploadFileConfig")
|
@GetMapping("/getUploadFileConfig")
|
||||||
public ResponseResult getUploadFileConfig(){
|
public ResponseResult getUploadFileConfig(){
|
||||||
@@ -57,7 +59,7 @@ public class OssClientController {
|
|||||||
byte[] binaryData = postPolicy.getBytes("utf-8");
|
byte[] binaryData = postPolicy.getBytes("utf-8");
|
||||||
String encodedPolicy = BinaryUtil.toBase64String(binaryData);
|
String encodedPolicy = BinaryUtil.toBase64String(binaryData);
|
||||||
String signature = client.calculatePostSignature(postPolicy);
|
String signature = client.calculatePostSignature(postPolicy);
|
||||||
OssUploadConfigVO result = new OssUploadConfigVO(accessKeyId, encodedPolicy, signature, dir, host, String.valueOf(expireEndTime / 1000));
|
OssUploadConfigVO result = new OssUploadConfigVO(accessKeyId, encodedPolicy, signature, dir, host, String.valueOf(expireEndTime / 1000), cdnUrl);
|
||||||
return ResponseResult.success(result);
|
return ResponseResult.success(result);
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
log.info("exception", e);
|
log.info("exception", e);
|
||||||
|
|||||||
@@ -46,7 +46,11 @@ oss.accessKeyId=LTAI5tRSXy2MrqaaBJ6gReur
|
|||||||
oss.accessKeySecret=FFsl8d9batprJ0vXr0k4Y8ada40Wm2
|
oss.accessKeySecret=FFsl8d9batprJ0vXr0k4Y8ada40Wm2
|
||||||
oss.endpoint=oss-cn-hangzhou.aliyuncs.com
|
oss.endpoint=oss-cn-hangzhou.aliyuncs.com
|
||||||
oss.bucket=cool-store-hsay
|
oss.bucket=cool-store-hsay
|
||||||
|
|
||||||
|
#企业corpId
|
||||||
corp.id = 171cddee76471740
|
corp.id = 171cddee76471740
|
||||||
|
#cdn地址
|
||||||
|
cdn.url=https://testhsaypic.coolstore.cn
|
||||||
|
|
||||||
#TRTC
|
#TRTC
|
||||||
trtc.sdkAppId=1400811820
|
trtc.sdkAppId=1400811820
|
||||||
|
|||||||
@@ -50,7 +50,11 @@ oss.accessKeyId=LTAI5tKSnAbkEbmT6CeBwNN3
|
|||||||
oss.accessKeySecret=PbXOzUFwAvZ2K5zIawwa7NAJE2pFXS
|
oss.accessKeySecret=PbXOzUFwAvZ2K5zIawwa7NAJE2pFXS
|
||||||
oss.endpoint=oss-cn-shanghai.aliyuncs.com
|
oss.endpoint=oss-cn-shanghai.aliyuncs.com
|
||||||
oss.bucket=vec-coolstore
|
oss.bucket=vec-coolstore
|
||||||
|
|
||||||
|
#企业corpId
|
||||||
corp.id = 171cddee76471740
|
corp.id = 171cddee76471740
|
||||||
|
#cdn地址
|
||||||
|
cdn.url=https://testhsaypic.coolstore.cn
|
||||||
|
|
||||||
#TRTC
|
#TRTC
|
||||||
trtc.sdkAppId=1400811820
|
trtc.sdkAppId=1400811820
|
||||||
|
|||||||
Reference in New Issue
Block a user