|
@@ -58,15 +58,6 @@ import static com.ichaoj.ams.constant.AmsConstant.WALLET_FILE_PATH;
|
|
|
@Slf4j
|
|
|
public class AmsAddressAccountServiceImpl extends SuperWhaleServiceImpl<AmsAddressAccountMapper, AmsAddressAccount> implements IAmsAddressAccountService {
|
|
|
|
|
|
- @Autowired(required = false)
|
|
|
- private AmsAddressAccountMapper baseMapper;
|
|
|
-
|
|
|
- @Resource
|
|
|
- private DiskClient diskClient;
|
|
|
-
|
|
|
- @Resource
|
|
|
- private ZipService zipService;
|
|
|
-
|
|
|
@Override
|
|
|
public List<String> batchCreateAddress(BatchAddressRequest batchAddressRequest) {
|
|
|
String userId = SuperWhaleContext.getContext(PublicUserInfo.class).getUserId();
|
|
@@ -82,16 +73,8 @@ public class AmsAddressAccountServiceImpl extends SuperWhaleServiceImpl<AmsAddre
|
|
|
wallets.forEach(wallet -> {
|
|
|
try {
|
|
|
String keystore = wallet.getKeystore();
|
|
|
-// File file = FileUtil.createTempFile(new File(keystore));
|
|
|
-// MultipartFile multipartFile = com.ichaoj.ccb.common.util.FileUtil.convertFileToMultipartFile(file);
|
|
|
- // 上传服务器
|
|
|
-// PublicResult<String> result = diskClient.uploadFile(multipartFile, "ccb_address_account", "keystore");
|
|
|
-// String fileId = result.getData();
|
|
|
// 将生成的地址存入数据库
|
|
|
AmsAddressAccount addressAccount = getAddressCountInstance(userId, wallet.getAddress(), 1);
|
|
|
-// if (result.isSuccess() && StrUtil.isNotBlank(fileId)) {
|
|
|
-// addressAccount.setKeystoreLocation(getLocation(fileId));
|
|
|
-// }
|
|
|
addressAccount.setKeystore(keystore);
|
|
|
addressAccount.setGroupName(batchAddressRequest.getGroupName());
|
|
|
this.save(addressAccount);
|
|
@@ -122,22 +105,16 @@ public class AmsAddressAccountServiceImpl extends SuperWhaleServiceImpl<AmsAddre
|
|
|
@Override
|
|
|
public PublicPage<AddressResponse> pageAddress(PageAddressRequest pageAddressRequest) {
|
|
|
LambdaQueryWrapper<AmsAddressAccount> wrapper = Wrappers.lambdaQuery();
|
|
|
- wrapper.eq(StrUtil.isNotBlank(pageAddressRequest.getGroupName()), AmsAddressAccount::getGroupName, pageAddressRequest.getGroupName())
|
|
|
+ wrapper.eq(StrUtil.isNotBlank(pageAddressRequest.getGroupName())
|
|
|
+ , AmsAddressAccount::getGroupName
|
|
|
+ , pageAddressRequest.getGroupName())
|
|
|
+ .eq(AmsAddressAccount::getUserId, SuperWhaleContext.getContext(PublicUserInfo.class).getUserId())
|
|
|
.orderByDesc(AmsAddressAccount::getCreateTime);
|
|
|
|
|
|
Page<AmsAddressAccount> result = this.page(this.buildPageObj(pageAddressRequest), wrapper);
|
|
|
return this.convertPublicPage(result, resp -> BeanUtil.copyProperties(resp, AddressResponse.class));
|
|
|
}
|
|
|
|
|
|
- private String getLocation(String fileId) {
|
|
|
- PublicResult<FileResponse> result = diskClient.getFileById(fileId);
|
|
|
- FileResponse data = result.getData();
|
|
|
- if (result.isSuccess() && data != null) {
|
|
|
- return data.getFileUrl();
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
/**
|
|
|
* 添加精品号
|
|
|
*
|
|
@@ -250,6 +227,4 @@ public class AmsAddressAccountServiceImpl extends SuperWhaleServiceImpl<AmsAddre
|
|
|
account.setUserId(userId);
|
|
|
return account;
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
}
|