1.修改绑定、解绑的实现方式

@@ -54,4 +54,11 @@ public interface MemberRepository extends JpaRepository<Member, Long>, JpaSpecif
             "`vip_expire_time` = :#{#resources.vipExpireTime} , `update_time`= now() " +
             " WHERE `id` = :#{#resources.id}", nativeQuery = true)
     Integer updateMemberVipAndVipExpireTime(@Param("resources") Member member);
+
+    @Modifying
+    @Query(value = "UPDATE `uc_member` SET `user_iptv_id` = :#{#resources.userIptvId}, " +
+            "`bind_iptv_platform_type` = :#{#resources.bindIptvPlatformType} , `bind_iptv_time` = :#{#resources.bindIptvTime} , " +
+            " `update_time`= now() " +
+            " WHERE `id` = :#{#resources.id}", nativeQuery = true)
+    Integer doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(@Param("resources") Member member);
 }

@@ -86,4 +86,6 @@ public interface MemberService {
     void updateUserIptvIdById(Long id, Long userIptvId, LocalDateTime now);
 
     void doUpdateMemberCoupon(Member member);
+
+    Integer doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(Member member);
 }

@@ -175,6 +175,12 @@ public class MemberServiceImpl implements MemberService {
 
     @Override
     @Transactional(rollbackFor = Exception.class)
+    public Integer doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(Member member) {
+       return this.memberRepository.doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(member);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
     public MemberDTO update(Member resources) {
 
         log.info("MemberServiceImpl ==>> update ==>> resources ==>> [{}]" , resources);

@@ -184,13 +184,6 @@ public class UserTvServiceImpl implements UserTvService {
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void unbindPriorityMemberCode(UserTv resources) {
-        String platformAccount = resources.getPlatformAccount();
-        if (StringUtils.isNotBlank(platformAccount)) {
-            UserTvDTO userTvDTO = this.findByPlatformAccount(platformAccount);
-            Long id = userTvDTO.getId();
-            resources.setId(id);
-            resources.setMemberId(userTvDTO.getMemberId());
-        }
         this.userTvRepository.save(resources);
     }
 

@@ -266,30 +266,26 @@ public class UserOperationServiceImpl implements UserOperationService {
 
         String platformAccount = userTvDTO.getPlatformAccount();
         UserTvDTO _userTvDTO = this.userTvService.findByPlatformAccount(platformAccount);
-        _userTvDTO.setPriorityMemberCode(userTvDTO.getPriorityMemberCode());
+        if (Objects.nonNull(_userTvDTO.getId())) {
             //
-        this.unbindPriorityMemberCode(_userTvDTO);
-
+            UserTv userTv = new UserTv();
+            userTv.setPriorityMemberCode(userTvDTO.getPriorityMemberCode());
+            userTv.setId(_userTvDTO.getId());
+            userTv.setPlatformAccount(_userTvDTO.getPlatformAccount());
+            this.userTvService.doUpdatePriorityMemberCode(userTv);
+        }
 
         String code = memberDTO.getCode();
         MemberDTO _memberDTO = this.memberService.findByCode(code);
-        this.unbindUserIpTv(_memberDTO);
-
-    }
-
-    private void unbindUserIpTv(MemberDTO memberDTO) {
-        memberDTO.setUserIptvId(null);
-        memberDTO.setBindIptvPlatformType(null);
-        memberDTO.setBindIptvTime(null);
+        if (Objects.nonNull(_memberDTO.getId())) {
             Member member = new Member();
-        BeanUtils.copyProperties(memberDTO, member);
-        this.memberService.unbindUserIpTv(member);
+            member.setId(_memberDTO.getId());
+            member.setUserIptvId(null);
+            member.setBindIptvPlatformType(null);
+            member.setBindIptvTime(null);
+            this.memberService.doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(member);
         }
 
-    private void unbindPriorityMemberCode(UserTvDTO userTvDTO) {
-        UserTv userTv = new UserTv();
-        BeanUtils.copyProperties(userTvDTO, userTv);
-        this.userTvService.unbindPriorityMemberCode(userTv);
     }
 
     @Transactional(propagation = Propagation.SUPPORTS, rollbackFor = Exception.class)