From d23645e976981bc9b670eea1d469fe8a36be309c Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Wed, 17 Apr 2024 17:19:53 +0800
Subject: [PATCH] 55测试环境
---
src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 103 +++++++++++++++++++++++++++++++++++++++++----------
1 files changed, 82 insertions(+), 21 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
index 19fdafd..34ce5af 100644
--- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
@@ -5,6 +5,7 @@
import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.SecureUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xcong.excoin.common.LoginUserUtils;
import com.xcong.excoin.common.contants.AppContants;
@@ -13,6 +14,14 @@
import com.xcong.excoin.common.response.Result;
import com.xcong.excoin.common.system.dto.RegisterDto;
import com.xcong.excoin.common.system.service.CommonService;
+import com.xcong.excoin.modules.activity.dao.ActivityMainDao;
+import com.xcong.excoin.modules.activity.dao.ActivityMemberDetailDao;
+import com.xcong.excoin.modules.activity.dao.ActivityReceiveRecordDao;
+import com.xcong.excoin.modules.activity.dao.ActivitySubDao;
+import com.xcong.excoin.modules.activity.entity.ActivityMain;
+import com.xcong.excoin.modules.activity.entity.ActivityMemberDetail;
+import com.xcong.excoin.modules.activity.entity.ActivityReceiveRecord;
+import com.xcong.excoin.modules.activity.entity.ActivitySub;
import com.xcong.excoin.modules.coin.dao.MemberAccountMoneyChangeDao;
import com.xcong.excoin.modules.coin.entity.MemberAccountMoneyChange;
import com.xcong.excoin.modules.contract.entity.ContractEntrustOrderEntity;
@@ -31,12 +40,14 @@
import com.xcong.excoin.utils.ThreadPoolUtils;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.Put;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal;
import java.util.ArrayList;
+import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -99,6 +110,16 @@
@Resource
AppVersionDao appVersionDao;
+
+ @Resource
+ ActivityMainDao activityMainDao;
+ @Resource
+ ActivityMemberDetailDao activityMemberDetailDao;
+ @Resource
+ ActivityReceiveRecordDao activityReceiveRecordDao;
+ @Resource
+ ActivitySubDao activitySubDao;
+
@Resource
private MemberSettingDao memberSettingDao;
@@ -153,9 +174,9 @@
memberDao.insert(member);
MemberSettingEntity memberSettingEntity = new MemberSettingEntity();
- memberSettingEntity.setSpread(BigDecimal.ONE);
- memberSettingEntity.setClosingSpread(BigDecimal.valueOf(5));
- memberSettingEntity.setForceParam(BigDecimal.valueOf(0.0055));
+ memberSettingEntity.setSpread(BigDecimal.valueOf(0.5));
+ memberSettingEntity.setClosingSpread(BigDecimal.valueOf(2));
+ memberSettingEntity.setForceParam(BigDecimal.valueOf(0.0085));
memberSettingEntity.setMemberId(member.getId());
memberSettingDao.insert(memberSettingEntity);
@@ -222,6 +243,42 @@
levelRate.setMemberId(member.getId());
levelRate.setSymbol(symbolEnum.getValue());
memberLevelRateDao.insert(levelRate);
+ }
+ /**
+ * 初始化活动信息
+ */
+ //获取开始中的活动
+ ActivityMain activityMain = activityMainDao.selectById(1);
+ if(ObjectUtil.isNotEmpty(activityMain)) {
+ if(ActivityMain.STATE_START == activityMain.getState()) {
+ //新增【活动记录表】信息
+ ActivityReceiveRecord activityReceiveRecord = new ActivityReceiveRecord();
+ activityReceiveRecord.setMemberId(member.getId());
+ activityReceiveRecord.setMainId(activityMain.getId());
+ activityReceiveRecord.setReceiveCoinAmount(BigDecimal.ZERO);
+ activityReceiveRecord.setReceiveState(ActivityReceiveRecord.RECEIVESTATE_TWO);
+ Date startTime = new Date();
+ Date date = new Date(startTime.getTime() + ActivityReceiveRecord.DAYS*24*60*60*1000);
+ activityReceiveRecord.setInvalidTime(date);
+ Map<String, Object> activitySubMap = new HashMap<>();
+ activitySubMap.put("main_id", activityMain.getId());
+ List<ActivitySub> activitySubs = activitySubDao.selectByMap(activitySubMap );
+ if(CollUtil.isNotEmpty(activitySubs)) {
+ for(ActivitySub ActivitySub : activitySubs) {
+ Long subId = ActivitySub.getId();
+ activityReceiveRecord.setSubId(subId);
+ activityReceiveRecordDao.insert(activityReceiveRecord);
+ }
+ }
+ //新增【活动个人详情表】信息
+ ActivityMemberDetail activityMemberDetail = new ActivityMemberDetail();
+ activityMemberDetail.setMainId(activityMain.getId());
+ activityMemberDetail.setBurstUsdt(BigDecimal.ZERO);
+ activityMemberDetail.setReceivedUsdt(BigDecimal.ZERO);
+ activityMemberDetail.setSurplusUsdt(activityMain.getAmount());
+ activityMemberDetail.setMemberId(member.getId());
+ activityMemberDetailDao.insert(activityMemberDetail);
+ }
}
return Result.ok(MessageSourceUtils.getString("home_service_0009"));
@@ -815,7 +872,7 @@
}
@Override
- public Result memberAvivableCoinInfo(String symbol) {
+ public Result memberAvivableCoinInfo(String symbol,String lable) {
//获取用户ID
Long memberId = LoginUserUtils.getAppLoginUser().getId();
MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, symbol);
@@ -826,7 +883,7 @@
List<MemberAvivableCoinInfoVo> arrayList = new ArrayList<>();
- List<PlatformFeeSettingEntity> feeSettingByTypeAndSymbolLable = platformFeeSettingDao.getFeeSettingsByTypeAndSymbol(2, symbol);
+ List<PlatformFeeSettingEntity> feeSettingByTypeAndSymbolLable = platformFeeSettingDao.getFeeSettingsByTypeAndSymbol(2, symbol,lable);
if (CollUtil.isEmpty(feeSettingByTypeAndSymbolLable)) {
return Result.fail(MessageSourceUtils.getString("member_service_0087"));
}
@@ -959,7 +1016,7 @@
@Override
public Result getAppVersionInfo() {
- MemberEntity memberEntity = LoginUserUtils.getAppLoginUser();
+// MemberEntity memberEntity = LoginUserUtils.getAppLoginUser();
Map<String, Object> columnMap = new HashMap<>();
List<AppVersionEntity> selectByMap = appVersionDao.selectByMap(columnMap);
@@ -967,15 +1024,16 @@
if (CollUtil.isNotEmpty(selectByMap)) {
for (AppVersionEntity appVersionEntity : selectByMap) {
AppVersionVo appVersionVo = new AppVersionVo();
- if ("37059551".equals(memberEntity.getInviteId())) {
- appVersionVo.setAddress("www.baidu.com");
- appVersionVo.setType(appVersionEntity.getType());
- appVersionVo.setVersion(appVersionEntity.getVersion());
- } else {
- appVersionVo.setAddress(appVersionEntity.getAddress());
- appVersionVo.setType(appVersionEntity.getType());
- appVersionVo.setVersion(appVersionEntity.getVersion());
- }
+// if ("37059551".equals(memberEntity.getInviteId())) {
+// appVersionVo.setAddress("www.baidu.com");
+// appVersionVo.setType(appVersionEntity.getType());
+// appVersionVo.setVersion(appVersionEntity.getVersion());
+// } else {
+//
+// }
+ appVersionVo.setAddress(appVersionEntity.getAddress());
+ appVersionVo.setType(appVersionEntity.getType());
+ appVersionVo.setVersion(appVersionEntity.getVersion());
arrayList.add(appVersionVo);
}
}
@@ -1028,16 +1086,19 @@
}
Long memberInfoId = selectMemberInfoByAccount.getId();
String symbol = memberSubmitCoinApplyInDto.getSymbol();
-
+
+ String addressIn = "";
Map<String, Object> columnMapAddress = new HashMap<>();
columnMapAddress.put("member_id", memberInfoId);
columnMapAddress.put("symbol", symbol);
- List<MemberCoinAddressEntity> selectByMap2 = memberCoinAddressDao.selectByMap(columnMapAddress );
+ List<MemberCoinAddressEntity> selectByMap2 = memberCoinAddressDao.selectByMap(columnMapAddress);
if(CollUtil.isEmpty(selectByMap2)) {
- return Result.fail(MessageSourceUtils.getString("member_service_0087"));
- }
- MemberCoinAddressEntity memberCoinAddressEntity = selectByMap2.get(0);
- String addressIn = memberCoinAddressEntity.getAddress();
+// return Result.fail(MessageSourceUtils.getString("member_service_0087"));
+ addressIn = address;
+ } else {
+ MemberCoinAddressEntity memberCoinAddressEntity = selectByMap2.get(0);
+ addressIn = memberCoinAddressEntity.getAddress();
+ }
MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, memberSubmitCoinApplyInDto.getSymbol());
BigDecimal availableBalance = walletCoin.getAvailableBalance();
--
Gitblit v1.9.1