| | |
| | | |
| | | import com.yami.trading.admin.model.LoginModel; |
| | | import com.yami.trading.admin.model.UpdateAddressModel; |
| | | import com.yami.trading.admin.model.channelBlockchain.ChannelBlockchainUpdateModel; |
| | | import com.yami.trading.bean.model.ChannelBlockchain; |
| | | import com.yami.trading.common.domain.Result; |
| | | import com.yami.trading.common.exception.BusinessException; |
| | | import com.yami.trading.common.exception.YamiShopBindException; |
| | | import com.yami.trading.common.util.GoogleAuthenticator; |
| | | import com.yami.trading.common.util.IPHelper; |
| | | import com.yami.trading.common.util.StringUtils; |
| | | import com.yami.trading.security.common.bo.UserInfoInTokenBO; |
| | | import com.yami.trading.security.common.enums.CryptoCurrencyEnum; |
| | | import com.yami.trading.security.common.enums.SysTypeEnum; |
| | | import com.yami.trading.security.common.util.LocalKeyStorageAESUtil; |
| | | import com.yami.trading.security.common.util.SecurityUtils; |
| | | import com.yami.trading.security.common.vo.TokenInfoVO; |
| | | import com.yami.trading.service.ChannelBlockchainService; |
| | | import com.yami.trading.service.system.LogService; |
| | | import com.yami.trading.sys.model.SysUser; |
| | | import com.yami.trading.sys.service.SysUserService; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import javax.validation.Valid; |
| | |
| | | @Api(tags = "充值地址") |
| | | public class AddressController { |
| | | |
| | | |
| | | @Autowired |
| | | ChannelBlockchainService channelBlockchainService; |
| | | |
| | | @Autowired |
| | | SysUserService sysUserService; |
| | | |
| | | /** |
| | | * 地址列表 |
| | | * @return |
| | | */ |
| | | @PostMapping("/list") |
| | | public Result<?> list() { |
| | | List<CryptoCurrencyEnum> currencyEnums = CryptoCurrencyEnum.getAll(); |
| | | List<ChannelBlockchain> data = new ArrayList<>(); |
| | | currencyEnums.forEach(f->{ |
| | | //List<CryptoCurrencyEnum> currencyEnums = CryptoCurrencyEnum.getAll(); |
| | | List<ChannelBlockchain> data = channelBlockchainService.list(); |
| | | data.forEach(f->{ |
| | | try { |
| | | String address = LocalKeyStorageAESUtil.loadAndDecrypt(f.getName()); |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name(f.getChain()); |
| | | blockchain.setAddress(address); |
| | | blockchain.setCoin(f.getCoin()); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | f.setBlockchain_name(f.getBlockchainName()); |
| | | } catch (Exception e) { |
| | | e.getMessage(); |
| | | } |
| | |
| | | return Result.succeed(data); |
| | | } |
| | | |
| | | @PostMapping("/update") |
| | | /*@PostMapping("/update") |
| | | public Result<?> list(@RequestBody UpdateAddressModel model) { |
| | | String name = model.getCoin().toLowerCase()+"_"+model.getChain().toLowerCase(); |
| | | try { |
| | |
| | | e.getMessage(); |
| | | } |
| | | return Result.succeed(); |
| | | }*/ |
| | | |
| | | @ApiOperation("修改 区块链充值地址") |
| | | @PostMapping("update") |
| | | public Result update(@RequestBody @Valid ChannelBlockchainUpdateModel model) { |
| | | String id = model.getId(); |
| | | String blockchain_name = model.getBlockchainName(); |
| | | String coin = model.getCoin(); |
| | | String address = model.getAddress(); |
| | | ChannelBlockchain channelBlockchain = this.channelBlockchainService.getById(id); |
| | | /*String error = this.verif(blockchain_name, coin, address, null); |
| | | if (!StringUtils.isNullOrEmpty(error)) { |
| | | throw new BusinessException(error); |
| | | }*/ |
| | | if (!blockchain_name.isEmpty()) { |
| | | channelBlockchain.setBlockchain_name(blockchain_name); |
| | | } |
| | | if (!coin.isEmpty()) { |
| | | channelBlockchain.setCoin(coin); |
| | | } |
| | | if (!address.isEmpty()) { |
| | | channelBlockchain.setAddress(address); |
| | | } |
| | | channelBlockchainService.updateById(channelBlockchain); |
| | | return Result.succeed(); |
| | | } |
| | | |
| | | private String verif(String blockchain_name, String coin, String address, String img) { |
| | | if (StringUtils.isEmptyString(blockchain_name)) |
| | | return "请输入链名称"; |
| | | if (StringUtils.isEmptyString(coin)) |
| | | return "请输入币种"; |
| | | if (StringUtils.isEmptyString(address)) |
| | | return "请输入地址"; |
| | | return null; |
| | | } |
| | | |
| | | } |