From 07214840bab55342a8c4a220f7a5d190e0fc591b Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 04 Aug 2020 11:02:12 +0800
Subject: [PATCH] 20200804
---
src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java | 47 +++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 45 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
index 7558ac8..6b9f140 100644
--- a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
@@ -1,5 +1,6 @@
package com.xcong.excoin.modules.documentary.service.impl;
+import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -7,6 +8,7 @@
import javax.validation.Valid;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -14,14 +16,19 @@
import com.xcong.excoin.common.entity.FebsResponse;
import com.xcong.excoin.common.entity.QueryRequest;
import com.xcong.excoin.modules.documentary.entity.FollowTraderInfoEntity;
+import com.xcong.excoin.modules.documentary.entity.FollowTraderProfitInfoEntity;
import com.xcong.excoin.modules.documentary.mapper.FollowTraderInfoMapper;
+import com.xcong.excoin.modules.documentary.mapper.FollowTraderProfitInfoMapper;
import com.xcong.excoin.modules.documentary.service.DocumentaryService;
import com.xcong.excoin.modules.member.entity.MemberAuthenticationEntity;
import com.xcong.excoin.modules.member.entity.MemberEntity;
import com.xcong.excoin.modules.member.mapper.MemberAuthenticationMapper;
import com.xcong.excoin.modules.member.mapper.MemberMapper;
+import com.xcong.excoin.modules.member.vo.MemberAuthenticationVo;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -35,6 +42,8 @@
private final MemberAuthenticationMapper memberAuthenticationMapper;
private final MemberMapper memberMapper;
+
+ private final FollowTraderProfitInfoMapper followTraderProfitInfoMapper;
@Override
public IPage<FollowTraderInfoEntity> findTraderListInPage(FollowTraderInfoEntity followTraderInfoEntity,
@@ -98,9 +107,43 @@
}
@Override
+ @Transactional
public FebsResponse traderConfirm(@Valid FollowTraderInfoEntity followTraderInfoEntity) {
- // TODO Auto-generated method stub
- return null;
+ Long id = followTraderInfoEntity.getId();
+ FollowTraderInfoEntity selectById = followTraderInfoMapper.selectById(id);
+ if(ObjectUtil.isEmpty(selectById)) {
+ return new FebsResponse().fail().message("交易员信息不存在");
+ }
+ String isok = followTraderInfoEntity.getIsok();
+ if("1".equals(isok)) {
+ //更新【会员信息表】数据
+ Long memberId = selectById.getMemberId();
+ MemberEntity memberEntity = memberMapper.selectById(memberId);
+ if(ObjectUtil.isEmpty(memberEntity)) {
+ return new FebsResponse().fail().message("会员信息不存在");
+ }
+ memberEntity.setIsTrader(1);
+ memberMapper.updateById(memberEntity);
+ //更新【交易员信息表】数据
+ selectById.setVerifyStatus(FollowTraderInfoEntity.VERIFYSTATUS_Y);
+ followTraderInfoMapper.updateById(selectById);
+ //新增【交易员收益信息 】数据
+ FollowTraderProfitInfoEntity followTraderProfitInfoEntity = new FollowTraderProfitInfoEntity();
+ followTraderProfitInfoEntity.setMemberId(memberId);
+ followTraderProfitInfoEntity.setTraderId(selectById.getId());
+ followTraderProfitInfoEntity.setTotalProfitRatio(BigDecimal.ZERO);
+ followTraderProfitInfoEntity.setTotalProfit(BigDecimal.ZERO);
+ followTraderProfitInfoEntity.setFollowerTotalProfit(BigDecimal.ZERO);
+ followTraderProfitInfoEntity.setWinRate(BigDecimal.ZERO);
+ followTraderProfitInfoEntity.setTotalFollowerCnt(BigDecimal.ZERO);
+ followTraderProfitInfoEntity.setTotalOrderCnt(BigDecimal.ZERO);
+ followTraderProfitInfoMapper.updateById(followTraderProfitInfoEntity);
+ }else {
+ //更新【交易员信息表】数据
+ selectById.setVerifyStatus(FollowTraderInfoEntity.VERIFYSTATUS_N);
+ followTraderInfoMapper.updateById(selectById);
+ }
+ return new FebsResponse().success();
}
}
--
Gitblit v1.9.1