debug

joying-common/src/main/java/com/fzm/common/entity/vo/CopyrightStateVo.java

@@ -17,7 +17,7 @@ public class CopyrightStateVo {
     public CopyrightStateVo(CopyrightApplyState stateEnum, String rejectReason) {
         this.code = stateEnum.getCode();
         this.value = stateEnum.getValue();
-        if (stateEnum.equals(CopyrightApplyState.REJECTED)) {
+        if (stateEnum.equals(CopyrightApplyState.REJECTED) || stateEnum.equals(CopyrightApplyState.FAILED)) {
             this.msg = rejectReason;
         } else {
             this.msg = stateEnum.getMsg();

joying-common/src/main/java/com/fzm/common/service/CopyrightApplyService.java

@@ -122,8 +122,17 @@ public interface CopyrightApplyService extends IService<CopyrightApply> {
 
     /**
      * 查看证书
+     *
      * @param id
      * @return
      */
     CopyrightCertificateVo getCertificate(Integer id);
+
+    /**
+     * 判断当前nft是否申请过版权
+     *
+     * @param nftHash
+     * @return
+     */
+    Boolean existsByNftHash(String nftHash);
 }

joying-common/src/main/java/com/fzm/common/service/impl/CopyrightApplyServiceImpl.java

@@ -390,6 +390,7 @@ public class CopyrightApplyServiceImpl extends ServiceImpl<CopyrightApplyMapper,
     public CopyrightVo getByNftHash(String nftHash) throws ExecutionException, InterruptedException {
         QueryWrapper<CopyrightApply> wrapper = new QueryWrapper<>();
         wrapper.eq("nft_hash", nftHash);
+        wrapper.eq("register_state", CopyrightApplyState.SUCCEEDED.getCode());
         CopyrightApply copyrightApply = this.getOne(wrapper);
         if (copyrightApply == null) {
             return null;
@@ -411,4 +412,11 @@ public class CopyrightApplyServiceImpl extends ServiceImpl<CopyrightApplyMapper,
         return new CopyrightCertificateVo(copyrightApply, user.getNickname(), category.getValue());
     }
 
+    @Override
+    public Boolean existsByNftHash(String nftHash) {
+        QueryWrapper<CopyrightApply> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("nft_hash", nftHash);
+        return count(queryWrapper) > 0;
+    }
+
 }

joying-common/src/main/java/com/fzm/common/service/impl/NftServiceImpl.java

@@ -206,6 +206,10 @@ public class NftServiceImpl extends ServiceImpl<NftMapper, Nft> implements NftSe
         }
         // 校验接收人的个人信息
         User receiveUser = userService.getUserByWallet(param.getReceiveWallet());
+        // 如果此nft已经申请版权的话,那么就不允许在一幕影链平台内部转让
+        if (receiveUser != null && copyrightApplyService.existsByNftHash(nft.getNftHash())) {
+            throw GlobalException.newException(ResultCode.TRANSFER_ERROR, "此nft已申请版权,不支持在一幕影链平台内部流转");
+        }
         // 修改nft的拥有者用户id
         Nft transferNft = new Nft().
                 setUserId(receiveUser != null ? receiveUser.getId() : 0).

joying-common/src/main/resources/mapper/NftMapper.xml

@@ -99,7 +99,7 @@
         FROM tb_nft a
         WHERE a.user_id = #{userId}
             AND a.nft_hash != ''
-	        AND nft_hash NOT IN ( SELECT nft_hash FROM tb_copyright_apply WHERE user_id = #{userId} )
+	        AND nft_hash NOT IN ( SELECT nft_hash FROM tb_copyright_apply)
     </select>
 
 </mapper>
\ No newline at end of file