fix 奈飞下架车队，存在账号检测直接改为异常状态

netflix-web/src/main/java/com/cyksj/web/controller/manage/group/CmsGroupController.java

@@ -13,16 +13,14 @@ import com.baomidou.mybatisplus.core.toolkit.Assert;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.cyksj.common.annotation.Log;
 import com.cyksj.common.annotation.NoSubmit;
+import com.cyksj.common.constant.Constant;
 import com.cyksj.common.exception.BusinessRuntimeException;
 import com.cyksj.common.util.GoogleGenerator;
 import com.cyksj.common.util.Jsons;
 import com.cyksj.dto.Result;
 import com.cyksj.enums.BusinessType;
 import com.cyksj.enums.GatewayResponse;
-import com.cyksj.mapper.GroupsRelationAlertMapper;
-import com.cyksj.mapper.GroupsRelationMapper;
-import com.cyksj.mapper.OrderDonMapper;
-import com.cyksj.mapper.UserMapper;
+import com.cyksj.mapper.*;
 import com.cyksj.model.entity.*;
 import com.cyksj.model.excel.ExcelGroupRelationData;
 import com.cyksj.model.request.AccountGroupsReq;
@@ -50,6 +48,7 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 
 /**
  * @author chan
@@ -79,6 +78,12 @@ public class CmsGroupController {
 
     private final OrderDonMapper orderDonMapper;
 
+    private final GroupsRelationMapper groupsRelationMapper;
+
+    private final GoodsDonSkuMapper goodsDonSkuMapper;
+
+    private final NetflixUserAccountStatusRecordMapper netflixUserAccountStatusRecordMapper;
+
     @GetMapping("/get")
     @SaCheckPermission("group:view")
     public Result<SearchResult<GroupsTrips>> get(String account, Long userId, String showId, String nickName, String submitAccount, Boolean isEmpty, String orderNo) {
@@ -314,6 +319,17 @@ public class CmsGroupController {
         }
         if (status == GroupsTrips.Status.validity) {
             groupsTrips.setStatus(GroupsTrips.Status.down);
+            //奈飞车队下架 是否存在在检测的用户
+            Long skuId = groupsTrips.getSkuId();
+            if (skuId != null) {
+                GoodsDonSku sku = goodsDonSkuMapper.selectById(skuId);
+                if (sku != null && sku.getGoodsId() == Constant.NETFLIX_GID) {
+                    List<Long> relationIds = groupsRelationMapper.selectList(Wrappers.lambdaUpdate(GroupsRelation.class).eq(GroupsRelation::getGroupsId, groupsTrips.getId())).stream().map(GroupsRelation::getId).collect(Collectors.toList());
+                    netflixUserAccountStatusRecordMapper.update(null, Wrappers.lambdaUpdate(NetflixUserAccountStatusRecord.class)
+                            .set(NetflixUserAccountStatusRecord::getState, 3)
+                            .in(NetflixUserAccountStatusRecord::getRelationId, relationIds));
+                }
+            }
         }
         if (status == GroupsTrips.Status.down) {
             groupsTrips.setStatus(GroupsTrips.Status.validity);