diff --git a/src/main/java/com/sqx/modules/file/AliFileUploadController.java b/src/main/java/com/sqx/modules/file/AliFileUploadController.java index b7be7cb2..e7ba1d7f 100644 --- a/src/main/java/com/sqx/modules/file/AliFileUploadController.java +++ b/src/main/java/com/sqx/modules/file/AliFileUploadController.java @@ -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 的返回值 diff --git a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java index c2738dfe..de2c2f48 100644 --- a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java +++ b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java @@ -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 implements user.setUserId(userId); user.setInviterCode(userEntity.getInvitationCode()); userService.updateById(user); + + //金豆 + int money = Integer.parseInt(commonInfoService.findOne(911).getValue()); + if (money > 0) { + UpdateWrapper 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;