优化转赠

mall-server-front/src/main/java/com/fzm/mall/server/front/asset/service/impl/UserAssetTransferRecordServiceImpl.java

@@ -96,7 +96,7 @@ public class UserAssetTransferRecordServiceImpl extends ServiceImpl<UserAssetTra
             /**
              * 链上转账
              */
-            transferInChain(user.getAddress(), record.getCoin(), record.getToAddress(), record.getNum(), record.getTransferRecordId(), hash, tokenId);
+            transferInChain(user.getAddress(), record.getCoin(), record.getToAddress(), record.getNum(), record.getTransferRecordId(), hash, tokenId, sku.getCoinName());
         }
     }
 
@@ -127,7 +127,7 @@ public class UserAssetTransferRecordServiceImpl extends ServiceImpl<UserAssetTra
      * @param toAddress
      * @param num
      */
-    private void transferInChain(String fromAddress, String coin, String toAddress, Integer num, String transferRecordId, String hash, Long tokenId) {
+    private void transferInChain(String fromAddress, String coin, String toAddress, Integer num, String transferRecordId, String hash, Long tokenId, String goodsCoin) {
         /**
          * 如果配置为不走链，则不操作链上资产
          */
@@ -144,6 +144,7 @@ public class UserAssetTransferRecordServiceImpl extends ServiceImpl<UserAssetTra
         tranDto.setTableType(TranDto.USER_ASSET_TRANSFER);
         tranDto.setHash(hash);
         tranDto.setTokenId(tokenId);
+        tranDto.setGoodsCoin(goodsCoin);
         producer.sendTTL(JSON.toJSONString(tranDto), QueueTTLTypeEnum.MALL_USER_ASSET_TRANSFER_TTL, 5 * 1000);
     }
 

mall-server-front/src/main/java/com/fzm/mall/server/front/mq/consumer/UserAssetTransferConsumer.java

@@ -141,7 +141,7 @@ public class UserAssetTransferConsumer {
          * 成功：增加接收方的资产
          * 失败：不做任何操作
          */
-        updateReciverAsset(transferRecord, successed);
+        updateReciverAsset(transferRecord, successed, tranDto.getGoodsCoin());
 
         /**
          * 转赠流水记录
@@ -217,7 +217,7 @@ public class UserAssetTransferConsumer {
         }
     }
 
-    private void updateReciverAsset(UserAssetTransferRecord transferRecord, boolean successed) {
+    private void updateReciverAsset(UserAssetTransferRecord transferRecord, boolean successed, String goodsCoin) {
         if (!successed) {
             return;
         }
@@ -232,6 +232,7 @@ public class UserAssetTransferConsumer {
             receiveAsset.setUid(transferRecord.getToUid());
             receiveAsset.setType(1);
             receiveAsset.setAmount(reNumber);
+            receiveAsset.setGoodsCoin(goodsCoin);
             boolean reSave = userAssetService.save(receiveAsset);
             if (!reSave) {
                 log.error("save asset fail, uid:" + receiveAsset.getUid() + "coin:" + receiveAsset.getCoin());

mall-server-front/src/main/java/com/fzm/mall/server/front/order/model/po/TranDto.java

@@ -58,4 +58,9 @@ public class TranDto {
 	 * 1.外部nft;2.内部nft；3.内部普通
 	 */
 	private Integer coinType;
+
+	/**
+	 * 复制的nft商品币前缀（原外部NFT）
+	 */
+	private String goodsCoin;
 }