后台修改

xiaoyong931011

2023-03-24 491eb89ab53f47ff6c3e386c35cbc55729c47f46

 src/main/java/cc/mrbird/febs/mall/service/impl/BlockSeriveImpl.java

@@ -1,19 +1,28 @@
package cc.mrbird.febs.mall.service.impl;

import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.enumerates.DataDictionaryEnum;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.mall.chain.enums.CoinTypeEnum;
import cc.mrbird.febs.mall.chain.service.EthService;
import cc.mrbird.febs.mall.dto.ApiChargeInfoDto;
import cc.mrbird.febs.mall.entity.DataDictionaryCustom;
import cc.mrbird.febs.mall.entity.MallMember;
import cc.mrbird.febs.mall.entity.MemberCoinAddressEntity;
import cc.mrbird.febs.mall.entity.MemberCoinChargeEntity;
import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
import cc.mrbird.febs.mall.mapper.MemberCoinAddressDao;
import cc.mrbird.febs.mall.mapper.MemberCoinChargeDao;
import cc.mrbird.febs.mall.service.BlockSerive;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.util.ObjectUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;

@@ -29,6 +38,12 @@

    @Resource
    private AgentProducer agentProducer;

    @Resource
    private MemberCoinChargeDao memberCoinChargeDao;

    @Resource
    private DataDictionaryCustomMapper dataDictionaryCustomMapper;

    @Override
    public FebsResponse findBlockAddress(String symbol, String lable) {
@@ -91,4 +106,35 @@
        return result;
    }

    @Override
    public FebsResponse findAddress() {
        DataDictionaryCustom addressDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.ADDRESS.getType(), DataDictionaryEnum.ADDRESS.getCode());
        String value = addressDic.getValue();
        return new FebsResponse().success().data(value);
    }

    @Override
    public FebsResponse setChargeInfo(ApiChargeInfoDto apiChargeInfoDto) {
        Long mId = LoginUserUtil.getLoginUser().getId();
        MallMember member = memberDao.selectById(mId);

//        String hash = apiChargeInfoDto.getHash();
//        MemberCoinChargeEntity memberCoinChargeEntityExist  = memberCoinChargeDao.selectByHash(hash);
//        if(ObjectUtil.isNotEmpty(memberCoinChargeEntityExist)){
//            return new FebsResponse().fail().message("提供正确的HASH值");
//        }
        MemberCoinChargeEntity memberCoinChargeEntity = new MemberCoinChargeEntity();
        memberCoinChargeEntity.setAddress(apiChargeInfoDto.getAddress());
        memberCoinChargeEntity.setMemberId(member.getId());
        memberCoinChargeEntity.setAmount(apiChargeInfoDto.getAmount());
        memberCoinChargeEntity.setSymbol(CoinTypeEnum.USDT.name());
        memberCoinChargeEntity.setTag("ERC20");
        memberCoinChargeEntity.setStatus(1);
        memberCoinChargeEntity.setLastAmount(BigDecimal.ZERO);
//        memberCoinChargeEntity.setHash(hash);
        memberCoinChargeDao.insert(memberCoinChargeEntity);
        return new FebsResponse().success();
    }

}