1.添加批量修改会员分组接口

@@ -10,6 +10,7 @@ import org.springframework.data.repository.query.Param;
 import java.time.LocalDateTime;
 import java.time.LocalDateTime;
 import java.util.List;
 import java.util.List;
 import java.util.Optional;
 import java.util.Optional;
+import java.util.Set;
 
 
 /**
 /**
  * @author XiangHan
  * @author XiangHan
@@ -61,4 +62,8 @@ public interface MemberRepository extends JpaRepository<Member, Long>, JpaSpecif
             " `update_time`= now() " +
             " `update_time`= now() " +
             " WHERE `id` = :#{#resources.id}", nativeQuery = true)
             " WHERE `id` = :#{#resources.id}", nativeQuery = true)
     Integer doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(@Param("resources") Member member);
     Integer doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(@Param("resources") Member member);
+
+    @Modifying
+    @Query(value = "UPDATE `uc_member` SET `groups` = ?1, `update_time` = now() WHERE `code` IN ?2 ", nativeQuery = true)
+    Integer doUpdateGroupsBatch(String groups, Set<String> codes);
 }
 }

@@ -88,4 +88,6 @@ public interface MemberService {
     void doUpdateMemberCoupon(Member member);
     void doUpdateMemberCoupon(Member member);
 
 
     Integer doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(Member member);
     Integer doUpdateMemberUserIptvIdAndBindPlatformTypeAndBingTime(Member member);
+
+    Integer asyncDoUpdateGroupsBatch(List<Member> resources);
 }
 }

@@ -23,7 +23,10 @@ import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.annotation.Transactional;
 
 
 import java.time.LocalDateTime;
 import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Objects;
 import java.util.Objects;
+import java.util.Set;
+import java.util.stream.Collectors;
 
 
 /**
 /**
  * @author XiangHan
  * @author XiangHan
@@ -180,6 +183,12 @@ public class MemberServiceImpl implements MemberService {
     }
     }
 
 
     @Override
     @Override
+    public Integer asyncDoUpdateGroupsBatch(List<Member> resources) {
+        Set<String> codes = resources.stream().map(t -> t.getCode()).collect(Collectors.toSet());
+        return this.memberRepository.doUpdateGroupsBatch( resources.get(0).getGroups(), codes);
+    }
+
+    @Override
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     public MemberDTO update(Member resources) {
     public MemberDTO update(Member resources) {
 
 

@@ -22,6 +22,7 @@ import org.springframework.util.Assert;
 
 
 import java.time.LocalDateTime;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
 import java.time.ZoneOffset;
+import java.util.List;
 import java.util.Objects;
 import java.util.Objects;
 
 
 @Service
 @Service
@@ -40,6 +41,10 @@ public class MemberOperationServiceImpl implements MemberOperationService {
     @Autowired
     @Autowired
     private ThreadPoolTaskExecutor threadPoolTaskExecutor;
     private ThreadPoolTaskExecutor threadPoolTaskExecutor;
 
 
+    public void asyncDoUpdateGroupsBatch(List<Member> resources) {
+        this.memberService.asyncDoUpdateGroupsBatch(resources);
+    }
+
     public void asyncUpdateMemberVipAndVipExpireTime(MemberDTO resource) {
     public void asyncUpdateMemberVipAndVipExpireTime(MemberDTO resource) {
         log.info("修改会员vip，参数==>>{}", resource);
         log.info("修改会员vip，参数==>>{}", resource);