fix 后台记录删除账号用户车票信息

netflix-service/src/main/java/com/cyksj/service/mange/group/CmsGroupServiceImpl.java

@@ -114,31 +114,33 @@ public class CmsGroupServiceImpl extends ServiceImpl<GroupsMapper,GroupsTrips> i
         //可强制删除
         //后台记录
         if (count > 0) {
-            TASK_EXECUTOR.execute(() -> {
-                if (redisService.setNx(String.format("%s-%s", groupId, groupsTrips.getAccount()), groupId, 10l)) {
-                    Account account = accountMapper.selectById(groupsTrips.getAccountId());
-                    List<GroupsRelation> groupsRelations = relationMapper.selectList(Wrappers.lambdaQuery(GroupsRelation.class)
-                            .eq(GroupsRelation::getGroupsId, groupId)
-                            .in(GroupsRelation::getStatus, List.of(GroupsRelation.Status.locking, GroupsRelation.Status.validity)));
-                    groupsRelations.forEach(data -> {
-                        DelGroupsTripsRecord delGroupsTripsRecord = new DelGroupsTripsRecord();
-                        delGroupsTripsRecord.setGroupsId(groupId);
-                        delGroupsTripsRecord.setGroupsStatus(groupsTrips.getStatus().name());
-                        if (account != null) {
-                            delGroupsTripsRecord.setAccount(account.getAccount());
-                            delGroupsTripsRecord.setPassword(account.getPassword());
-                        }
-                        delGroupsTripsRecord.setRelationId(data.getId());
-                        delGroupsTripsRecord.setSkuId(groupsTrips.getSkuId());
-                        delGroupsTripsRecord.setUserId(data.getUserId());
-                        delGroupsTripsRecord.setStartTime(data.getStartTime());
-                        delGroupsTripsRecord.setExpiryTime(data.getExpiryTime());
-                        delGroupsTripsRecord.setRelationStatus(data.getStatus().name());
-                        delGroupsTripsRecord.setType("delete");
-                        delGroupsTripsRecordMapper.insert(delGroupsTripsRecord);
-                    });
-                }
-            });
+            List<GroupsRelation> groupsRelations = relationMapper.selectList(Wrappers.lambdaQuery(GroupsRelation.class)
+                    .eq(GroupsRelation::getGroupsId, groupId)
+                    .in(GroupsRelation::getStatus, List.of(GroupsRelation.Status.locking, GroupsRelation.Status.validity)));
+            if (groupsRelations.size() > 0) {
+                Account account = accountMapper.selectById(groupsTrips.getAccountId());
+                TASK_EXECUTOR.execute(() -> {
+                    if (redisService.setNx(String.format("%s-%s", groupId, groupsTrips.getAccount()), groupId, 10l)) {
+                        groupsRelations.forEach(data -> {
+                            DelGroupsTripsRecord delGroupsTripsRecord = new DelGroupsTripsRecord();
+                            delGroupsTripsRecord.setGroupsId(groupId);
+                            delGroupsTripsRecord.setGroupsStatus(groupsTrips.getStatus().name());
+                            if (account != null) {
+                                delGroupsTripsRecord.setAccount(account.getAccount());
+                                delGroupsTripsRecord.setPassword(account.getPassword());
+                            }
+                            delGroupsTripsRecord.setRelationId(data.getId());
+                            delGroupsTripsRecord.setSkuId(groupsTrips.getSkuId());
+                            delGroupsTripsRecord.setUserId(data.getUserId());
+                            delGroupsTripsRecord.setStartTime(data.getStartTime());
+                            delGroupsTripsRecord.setExpiryTime(data.getExpiryTime());
+                            delGroupsTripsRecord.setRelationStatus(data.getStatus().name());
+                            delGroupsTripsRecord.setType("delete");
+                            delGroupsTripsRecordMapper.insert(delGroupsTripsRecord);
+                        });
+                    }
+                });
+            }
         }
         relationMapper.delete(Wrappers.lambdaQuery(GroupsRelation.class).eq(GroupsRelation::getGroupsId,groupId));
         this.removeById(groupId);