parent: 0b6cb0ac | patch | commit | ignore whitespace
1
xiaoyong931011
2023-02-01 cdb4f45b507e52f67c235b6d4b7307ec194f02a1 
1
1 files added
3 files modified
71 ■■■■■ changed files
src/main/java/cc/mrbird/febs/mall/controller/BlockController.java 13 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/mall/dto/ApiChargeInfoDto.java 30 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/mall/service/BlockSerive.java 3 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/mall/service/impl/BlockSeriveImpl.java 25 ●●●●● patch | view | raw | blame | history 
 src/main/java/cc/mrbird/febs/mall/controller/BlockController.java


@@ -2,6 +2,8 @@




import cc.mrbird.febs.common.entity.FebsResponse;


import cc.mrbird.febs.common.utils.RedisUtils;


import cc.mrbird.febs.mall.dto.ApiChargeInfoDto;


import cc.mrbird.febs.mall.dto.ForgetPwdDto;


import cc.mrbird.febs.mall.service.BlockSerive;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiImplicitParam;


@@ -9,9 +11,8 @@


import io.swagger.annotations.ApiOperation;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.web.bind.annotation.GetMapping;


import org.springframework.web.bind.annotation.RequestMapping;


import org.springframework.web.bind.annotation.RestController;


import org.springframework.validation.annotation.Validated;


import org.springframework.web.bind.annotation.*;




@Slf4j


@Api(value = "链上钱包接口", tags = "链上钱包接口")


@@ -39,4 +40,10 @@


        return blockSerive.findAddress();


    }




    @ApiOperation(value = "填写充值信息")


    @PostMapping(value = "/setChargeInfo")


    public FebsResponse setChargeInfo(@RequestBody @Validated ApiChargeInfoDto apiChargeInfoDto) {


        return blockSerive.setChargeInfo(apiChargeInfoDto);


    }




}




 src/main/java/cc/mrbird/febs/mall/dto/ApiChargeInfoDto.java


New file


@@ -0,0 +1,30 @@


package cc.mrbird.febs.mall.dto;




import io.swagger.annotations.ApiModel;


import io.swagger.annotations.ApiModelProperty;


import lombok.Data;




import javax.validation.constraints.DecimalMin;


import javax.validation.constraints.Digits;


import javax.validation.constraints.NotBlank;


import javax.validation.constraints.NotNull;


import java.math.BigDecimal;




@Data


@ApiModel(value = "ApiChargeInfoDto", description = "忘记/修改密码参数接收类")


public class ApiChargeInfoDto {




    @NotBlank(message = "地址不能为空")


    @ApiModelProperty(value = "地址", example = "oxsfsafssd")


    private String address;




    @Digits(integer = 9, fraction=2, message = "amount格式不正确")


    @DecimalMin(value = "0.00", message = "amount格式不正确")


    @NotNull(message = "amount不为空")


    @ApiModelProperty(value = "金额", example = "3.00")


    private BigDecimal amount;




    @NotBlank(message = "HASH值不能为空")


    @ApiModelProperty(value = "HASH值", example = "sd6f456s4a5")


    private String hash;


}




 src/main/java/cc/mrbird/febs/mall/service/BlockSerive.java


@@ -1,10 +1,13 @@


package cc.mrbird.febs.mall.service;




import cc.mrbird.febs.common.entity.FebsResponse;


import cc.mrbird.febs.mall.dto.ApiChargeInfoDto;




public interface BlockSerive {




    FebsResponse findBlockAddress(String symbol, String lable);




    FebsResponse findAddress();




    FebsResponse setChargeInfo(ApiChargeInfoDto apiChargeInfoDto);


}




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


@@ -3,13 +3,17 @@


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 lombok.extern.slf4j.Slf4j;


@@ -17,6 +21,7 @@


import org.springframework.stereotype.Service;




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.util.HashMap;


import java.util.Map;




@@ -32,6 +37,9 @@




    @Resource


    private AgentProducer agentProducer;




    @Resource


    private MemberCoinChargeDao memberCoinChargeDao;




    @Resource


    private DataDictionaryCustomMapper dataDictionaryCustomMapper;


@@ -105,4 +113,21 @@


        return new FebsResponse().success().data(value);


    }




    @Override


    public FebsResponse setChargeInfo(ApiChargeInfoDto apiChargeInfoDto) {


        Long mId = LoginUserUtil.getLoginUser().getId();


        MallMember member = memberDao.selectById(mId);


        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(apiChargeInfoDto.getHash());


        memberCoinChargeDao.insert(memberCoinChargeEntity);


        return new FebsResponse().success();


    }




}