xiaoyong931011
2021-02-05 44bac492a887015e83c0a89f2398eb04a14353cb
src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
@@ -20,9 +20,13 @@
import com.xcong.excoin.common.entity.FebsResponse;
import com.xcong.excoin.common.entity.QueryRequest;
import com.xcong.excoin.modules.documentary.dto.FollowTraderInfoDto;
import com.xcong.excoin.modules.documentary.entity.FollowFollowerProfitEntity;
import com.xcong.excoin.modules.documentary.entity.FollowTraderInfoEntity;
import com.xcong.excoin.modules.documentary.entity.FollowTraderLabelEntity;
import com.xcong.excoin.modules.documentary.entity.FollowTraderProfitInfoEntity;
import com.xcong.excoin.modules.documentary.mapper.FollowFollowerProfitMapper;
import com.xcong.excoin.modules.documentary.mapper.FollowTraderInfoMapper;
import com.xcong.excoin.modules.documentary.mapper.FollowTraderLabelMapper;
import com.xcong.excoin.modules.documentary.mapper.FollowTraderProfitInfoMapper;
import com.xcong.excoin.modules.documentary.service.DocumentaryService;
import com.xcong.excoin.modules.member.entity.MemberAuthenticationEntity;
@@ -41,6 +45,10 @@
public class DocumentaryServiceImpl extends ServiceImpl<FollowTraderInfoMapper, FollowTraderInfoEntity> implements DocumentaryService {
   
   private final FollowTraderInfoMapper followTraderInfoMapper;
   private final FollowFollowerProfitMapper followFollowerProfitMapper;
   private final FollowTraderLabelMapper followTraderLabelMapper;
   
   private final MemberAuthenticationMapper memberAuthenticationMapper;
   
@@ -159,12 +167,25 @@
   }
   @Override
   @Transactional
   public FebsResponse traderGetOut(@NotNull(message = "{required}") Long id) {
      FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoMapper.selectById(id);
      if(ObjectUtil.isEmpty(followTraderInfoEntity)) {
         return new FebsResponse().fail().message("交易员信息不存在");
      }
      Long memberId = followTraderInfoEntity.getMemberId();
      Map<String, Object> columnMap = new HashMap<>();
      columnMap.put("trade_member_id", memberId);
      List<FollowFollowerProfitEntity> selectByMap = followFollowerProfitMapper.selectByMap(columnMap);
      if(CollUtil.isNotEmpty(selectByMap)) {
         for(FollowFollowerProfitEntity FollowFollowerProfitEntity : selectByMap ) {
            FollowFollowerProfitEntity.setIsFollow(FollowFollowerProfitEntity.IS_FOLLOW_N);
            followFollowerProfitMapper.updateById(FollowFollowerProfitEntity);
         }
      }
      followTraderInfoEntity.setVerifyStatus(FollowTraderInfoEntity.VERIFYSTATUS_N);
      followTraderInfoMapper.updateById(followTraderInfoEntity);
      MemberEntity memberEntity = memberMapper.selectById(memberId);
      memberEntity.setIsTrader(2);
      memberMapper.updateById(memberEntity);
@@ -183,4 +204,29 @@
      return new FebsResponse().success();
   }
   @Override
   public IPage<FollowTraderLabelEntity> traderLabelList(FollowTraderLabelEntity followTraderLabelEntity,
         QueryRequest request) {
      Page<FollowTraderLabelEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<FollowTraderLabelEntity> followTraderLabelEntitys = followTraderLabelMapper.findFollowTraderLabelEntitysInPage(page, followTraderLabelEntity);
      return followTraderLabelEntitys;
   }
   @Override
   public FebsResponse traderLabelDelete(@NotNull(message = "{required}") Long id) {
      followTraderLabelMapper.deleteById(id);
      return new FebsResponse().success();
   }
   @Override
   public void followLabelSetAdd(@Valid FollowTraderLabelEntity followTraderLabelEntity) {
      followTraderLabelMapper.insert(followTraderLabelEntity);
   }
   @Override
   public void followLabelSetUpdate(@Valid FollowTraderLabelEntity followTraderLabelEntity) {
      followTraderLabelMapper.updateById(followTraderLabelEntity);
   }
}