oss 临时凭证
This commit is contained in:
wangw 2024-12-05 11:36:15 +08:00
parent d6757be84d
commit a0a732662b
2 changed files with 28 additions and 5 deletions

View File

@ -70,17 +70,17 @@ public class AliFileUploadController {
try {
com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
// 必填请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID
.setAccessKeyId("LTAI5tMmymNJatAoci3N5PVz")
// .setAccessKeyId(commonRepository.findOne(68).getValue())
// .setAccessKeyId("LTAI5tMmymNJatAoci3N5PVz")
.setAccessKeyId(commonRepository.findOne(68).getValue())
// 必填请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET
// .setAccessKeySecret(commonRepository.findOne(69).getValue());
.setAccessKeySecret("WnJ2Dng7zxSagKj0NmhjfiHgIFyOEy");
.setAccessKeySecret(commonRepository.findOne(69).getValue());
// .setAccessKeySecret("WnJ2Dng7zxSagKj0NmhjfiHgIFyOEy");
// Endpoint 请参考 https://api.aliyun.com/product/Sts
config.endpoint = "sts.cn-shanghai.aliyuncs.com";
com.aliyun.sts20150401.Client client = new com.aliyun.sts20150401.Client(config);
com.aliyun.sts20150401.models.AssumeRoleRequest assumeRoleRequest = new com.aliyun.sts20150401.models.AssumeRoleRequest();
assumeRoleRequest.setRoleArn("acs:ram::1266409170752412:role/linshi");
assumeRoleRequest.setRoleArn(commonRepository.findOne(76).getValue());
assumeRoleRequest.setRoleSessionName("test");
com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
// 复制代码运行请自行打印 API 的返回值

View File

@ -1,6 +1,7 @@
package com.sqx.modules.invite.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@ -8,6 +9,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.sqx.common.utils.DateUtils;
import com.sqx.common.utils.PageUtils;
import com.sqx.modules.app.entity.UserEntity;
import com.sqx.modules.app.entity.UserMoney;
import com.sqx.modules.app.entity.UserMoneyDetails;
import com.sqx.modules.app.entity.UserVip;
import com.sqx.modules.app.service.UserMoneyDetailsService;
@ -147,6 +149,27 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
user.setUserId(userId);
user.setInviterCode(userEntity.getInvitationCode());
userService.updateById(user);
//金豆
int money = Integer.parseInt(commonInfoService.findOne(911).getValue());
if (money > 0) {
UpdateWrapper<UserMoney> updateWrapper = new UpdateWrapper<>();
updateWrapper.eq("user_id", userEntity.getUserId())
.setSql("money = money + " + money);
userMoneyService.update(updateWrapper);
UserMoneyDetails userMoneyDetails = new UserMoneyDetails();
userMoneyDetails.setUserId(userEntity.getUserId());
userMoneyDetails.setType(1);
userMoneyDetails.setClassify(6);
userMoneyDetails.setMoney(new BigDecimal(money));
userMoneyDetails.setCreateTime(format);
userMoneyDetails.setTitle("[分享奖励金豆]");
userMoneyDetails.setContent("获取金豆:" + money);
userMoneyDetailsService.save(userMoneyDetails);
}
//助力活动
String value = commonInfoService.findOne(813).getValue();
if (!"".equals(value)) {
return 0;