修改华为云obs引入版本
微信jsapi支付修改使用openID
This commit is contained in:
@@ -440,7 +440,7 @@
|
||||
<dependency>
|
||||
<groupId>com.huaweicloud</groupId>
|
||||
<artifactId>esdk-obs-java</artifactId>
|
||||
<version>${huaweicloud.version}</version>
|
||||
<version>${huaweicloud-obs.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.qcloud</groupId>
|
||||
|
||||
@@ -44,7 +44,7 @@ public class HuaweiFilePlugin implements FilePlugin {
|
||||
* @return
|
||||
*/
|
||||
private ObsClient getObsClient() {
|
||||
return new ObsClient(ossSetting.getHuaweicloudOBSAccessKey(), ossSetting.getHuaweicloudOBSSecretKey(), ossSetting.getAliyunOSSEndPoint());
|
||||
return new ObsClient(ossSetting.getHuaweicloudOBSAccessKey(), ossSetting.getHuaweicloudOBSSecretKey(), ossSetting.getHuaweicloudOBSEndPoint());
|
||||
}
|
||||
|
||||
|
||||
@@ -72,14 +72,17 @@ public class HuaweiFilePlugin implements FilePlugin {
|
||||
public String inputStreamUpload(InputStream inputStream, String key) {
|
||||
ObsClient obsClient = getObsClient();
|
||||
try {
|
||||
obsClient.putObject(new PutObjectRequest(ossSetting.getHuaweicloudOBSBucketName(), key, inputStream));
|
||||
PutObjectRequest putObjectRequest=new PutObjectRequest(ossSetting.getHuaweicloudOBSBucketName(), key, inputStream);
|
||||
obsClient.putObject(putObjectRequest);
|
||||
} catch (ObsException obsException) {
|
||||
obsException.printStackTrace();
|
||||
throw new ServiceException(ResultCode.OSS_EXCEPTION_ERROR);
|
||||
} finally {
|
||||
try {
|
||||
// 关闭OBS连接
|
||||
obsClient.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
log.error("OBS关闭连接报错!" + e.getMessage());
|
||||
throw new ServiceException(ResultCode.OSS_EXCEPTION_ERROR);
|
||||
}
|
||||
|
||||
@@ -179,7 +179,7 @@ public class WechatPlugin implements Payment {
|
||||
|
||||
try {
|
||||
Connect connect = connectService.queryConnect(
|
||||
ConnectQueryDTO.builder().userId(UserContext.getCurrentUser().getId()).unionType(ConnectEnum.WECHAT.name()).build()
|
||||
ConnectQueryDTO.builder().userId(UserContext.getCurrentUser().getId()).unionType(SourceEnum.WECHAT_OFFIACCOUNT_OPEN_ID.name()).build()
|
||||
);
|
||||
if (connect == null) {
|
||||
return null;
|
||||
|
||||
Reference in New Issue
Block a user