奈飞账号检测

netflix-dao/src/main/java/com/cyksj/mapper/AccountNetflixStateMapper.java

@@ -0,0 +1,13 @@
+package com.cyksj.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.AccountNetflixState;
+
+/**
+ * 项目名: yhlxj2
+ * 文件名: AccountNetflixStateMapper
+ * 创建者: JavaZou
+ * 创建时间:2024/11/12 18:23
+ */
+public interface AccountNetflixStateMapper extends BaseMapper<AccountNetflixState> {
+}

netflix-dao/src/main/java/com/cyksj/mapper/NetflixUserAccountStatusRecordMapper.java

@@ -0,0 +1,14 @@
+package com.cyksj.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.NetflixUserAccountStatusRecord;
+
+/**
+ * 项目名: yhlxj2
+ * 文件名: NetflixUserAccountStatusRecordMapper
+ * 创建者: JavaZou
+ * 创建时间:2024/11/12 18:18
+ */
+public interface NetflixUserAccountStatusRecordMapper extends BaseMapper<NetflixUserAccountStatusRecord> {
+}

netflix-dao/src/main/java/com/cyksj/model/entity/AccountNetflixState.java

@@ -0,0 +1,25 @@
+package com.cyksj.model.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 项目名: yhlxj2
+ * 文件名: AccountNetflixState
+ * 创建者: JavaZou
+ * 创建时间:2024/11/12 18:23
+ */
+@Getter
+@Setter
+public class AccountNetflixState extends BaseEntity{
+	private String account;
+
+	private String password;
+
+	private String taskId;
+
+	/**
+	 * 0正在执行中 1是账号正常 2是登录失败 3是被封号
+	 */
+	private Integer state;
+}

netflix-dao/src/main/java/com/cyksj/model/entity/NetflixUserAccountStatusRecord.java

@@ -0,0 +1,28 @@
+package com.cyksj.model.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 项目名: yhlxj2
+ * 文件名: NetflixUserAccountStatusRecord
+ * 创建者: JavaZou
+ * 创建时间:2024/11/12 18:17
+ */
+@Getter
+@Setter
+public class NetflixUserAccountStatusRecord extends BaseEntity{
+	private Long userId;
+
+	private Long orderId;
+
+	private Long relationId;
+
+	private String account;
+
+	private String password;
+
+	private Integer state;
+
+	private Boolean deleted;
+}

netflix-service/src/main/java/com/cyksj/service/relation/GroupRelationFrontService.java

@@ -3,6 +3,7 @@ package com.cyksj.service.relation;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.cyksj.model.entity.GoodsDonSku;
 import com.cyksj.model.entity.GroupsRelation;
+import com.cyksj.model.entity.NetflixUserAccountStatusRecord;
 import com.cyksj.model.manage.views.AccountView;
 import com.cyksj.model.request.SpecialGoodsTicketReq;
 import com.cyksj.model.request.TicketLoginReq;
@@ -73,4 +74,10 @@ public interface GroupRelationFrontService {
 	void changeTicket(long userId, Long relationId);
 
 	AccountView getTempAccount(long userId, Long relationId);
+
+	void nfErrorAccountSubmit(long userId, Long relationId);
+
+	Integer getNetflixErrorAccountStatus(long userId, Long relationId);
+
+	List<NetflixUserAccountStatusRecord> getUserNetflixSubmitRecord(long userId);
 }

netflix-service/src/main/java/com/cyksj/service/relation/impl/GroupRelationFrontServiceImpl.java

@@ -163,6 +163,10 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
 
 	private final NetflixTempAccountUserMapper netflixTempAccountUserMapper;
 
+	private final NetflixUserAccountStatusRecordMapper netflixUserAccountStatusRecordMapper;
+
+	private final AccountNetflixStateMapper accountNetflixStateMapper;
+
 	@Override
 	public SearchResult<RenewalView> getMyTicket(long userId, Boolean isLoginPopularize, String customId, String account, String orderNo) {
 		User u = userMapper.selectById(userId);
@@ -1039,6 +1043,14 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
 		if (newRelation == null) {
 			throw BusinessRuntimeException.getInstance("更换异常,请重新提交");
 		}
+
+		NetflixUserAccountStatusRecord netflixUserAccountStatusRecord = netflixUserAccountStatusRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
+				.eq(NetflixUserAccountStatusRecord::getRelationId, relationId)
+				.last("limit 1"));
+		if (netflixUserAccountStatusRecord != null) {
+			netflixUserAccountStatusRecord.setDeleted(false);
+			netflixUserAccountStatusRecordMapper.updateById(netflixUserAccountStatusRecord);
+		}
 	}
 
 	@Override
@@ -1087,6 +1099,86 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
 		return accountView;
 	}
 
+	@Override
+	public void nfErrorAccountSubmit(long userId, Long relationId) {
+		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
+		RenewalView renewalView = beanSearcher.searchFirst(RenewalView.class, MapUtils.builder()
+				.field(RenewalView::getUserId, userIdList).op(Operator.InList)
+				.field(RenewalView::getRelationId, relationId)
+				.field(RenewalView::getExpiryTime, DateTime.now()).op(Operator.GreaterThan).build());
+		if (renewalView == null) {
+			throw BusinessRuntimeException.getInstance("车票不存在");
+		}
+		if (renewalView.getGoodsId() != 1) {
+			throw BusinessRuntimeException.getInstance("只支持奈飞车票");
+		}
+		String account = renewalView.getAccount();
+		String password = renewalView.getPassword();
+
+		Integer selectCount = netflixUserAccountStatusRecordMapper.selectCount(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
+				.eq(NetflixUserAccountStatusRecord::getRelationId, relationId)
+				.eq(NetflixUserAccountStatusRecord::getUserId, userId)
+				.eq(NetflixUserAccountStatusRecord::getAccount, account));
+		if (selectCount > 0) {
+			throw BusinessRuntimeException.getInstance("该账号正在检测中");
+		}
+		AccountNetflixState accountNetflixState = accountNetflixStateMapper.selectOne(Wrappers.lambdaQuery(AccountNetflixState.class)
+				.eq(AccountNetflixState::getAccount, account)
+				.last("limit 1"));
+		Integer state = 0;
+		if (accountNetflixState != null && (accountNetflixState.getState() == 2 || accountNetflixState.getState() == 3)) {
+			state = accountNetflixState.getState();
+		}
+		NetflixUserAccountStatusRecord netflixUserAccountStatusRecord = new NetflixUserAccountStatusRecord();
+		netflixUserAccountStatusRecord.setAccount(account);
+		netflixUserAccountStatusRecord.setRelationId(relationId);
+		netflixUserAccountStatusRecord.setPassword(password);
+		netflixUserAccountStatusRecord.setUserId(renewalView.getUserId());
+		netflixUserAccountStatusRecord.setState(state);
+
+		OrderDon orderDon = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class)
+				.eq(OrderDon::getRelationId, renewalView.getRelationId())
+				.eq(OrderDon::getUserId, renewalView.getUserId())
+				.notIn(OrderDon::getStatus, Constant.noOrderAllStatus)
+				.orderByDesc(OrderDon::getId)
+				.last("limit 1"));
+		if (orderDon != null) {
+			netflixUserAccountStatusRecord.setOrderId(orderDon.getId());
+		}
+		netflixUserAccountStatusRecordMapper.insert(netflixUserAccountStatusRecord);
+	}
+
+	@Override
+	public Integer getNetflixErrorAccountStatus(long userId, Long relationId) {
+		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
+		NetflixUserAccountStatusRecord netflixUseAccountStatusRecord = netflixUserAccountStatusRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
+				.eq(NetflixUserAccountStatusRecord::getRelationId, relationId)
+				.eq(NetflixUserAccountStatusRecord::getDeleted, 1)
+				.in(NetflixUserAccountStatusRecord::getUserId, userIdList)
+				.last("limit 1"));
+		if (netflixUseAccountStatusRecord == null) {
+			throw BusinessRuntimeException.getInstance("未有提交记录");
+		}
+		Integer state = netflixUseAccountStatusRecord.getState();
+		//2是登录失败 3是被封号
+		if (state == 3 || state == 2) {
+			if (netflixUseAccountStatusRecord.getCreatedTime().compareTo(DateUtil.offsetMinute(DateTime.now(), -10)) > 0) {
+				state = 0;
+			}
+		}
+		return state;
+	}
+
+	@Override
+	public List<NetflixUserAccountStatusRecord> getUserNetflixSubmitRecord(long userId) {
+		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
+		List<NetflixUserAccountStatusRecord> netflixUseAccountStatusRecords = netflixUserAccountStatusRecordMapper.selectList(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
+				.in(NetflixUserAccountStatusRecord::getUserId, userIdList)
+				.eq(NetflixUserAccountStatusRecord::getDeleted, 1)
+				.select(NetflixUserAccountStatusRecord::getOrderId, NetflixUserAccountStatusRecord::getRelationId, NetflixUserAccountStatusRecord::getState, NetflixUserAccountStatusRecord::getCreatedTime));
+		return netflixUseAccountStatusRecords;
+	}
+
 	private DistributePosterGoodsDetailView setGoodsPoster(RenewalView ticket, User user, List<Long> userIds) {
 		DistributePosterGoodsDetailView distributePosterGoodsDetailView = beanSearcher.searchFirst(DistributePosterGoodsDetailView.class, MapUtils.flatBuilder(request.getParameterMap())
 				.field(DistributePosterGoodsFrontView::getGoodsId, ticket.getGoodsId()).build());

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

@@ -1113,4 +1113,34 @@ public class GroupRelationController {
         AccountView accountView = groupRelationFrontService.getTempAccount(userId, relationId);
         return GatewayResponse.SUCCESS.newBuilder().toResult(accountView);
     }
+
+    /**
+     * 申请提交记录
+     */
+    @GetMapping("/get/netflix/get/error/submit/record")
+    public Result<List<NetflixUserAccountStatusRecord>> getUserNetflixSubmitRecord() {
+        long userId = StpUserUtil.getLoginIdAsLong();
+        List<NetflixUserAccountStatusRecord> netflixUserAccountStatusRecords = groupRelationFrontService.getUserNetflixSubmitRecord(userId);
+        return GatewayResponse.SUCCESS.newBuilder().toResult(netflixUserAccountStatusRecords);
+    }
+
+    /**
+     * 奈飞账号异常检测提交
+     */
+    @PostMapping("/netflix/error/account/submit/{relationId}")
+    public Result<String> nfErrorAccountSubmit(@PathVariable Long relationId) {
+        long userId = StpUserUtil.getLoginIdAsLong();
+        groupRelationFrontService.nfErrorAccountSubmit(userId, relationId);
+        return GatewayResponse.SUCCESS.newBuilder().toResult();
+    }
+
+    /**
+     * 奈飞账号检测结果
+     */
+    @GetMapping("/get/netflix/error/account/status/{relationId}")
+    public Result<Integer> getNetflixErrorAccountStatus(@PathVariable Long relationId) {
+        long userId = StpUserUtil.getLoginIdAsLong();
+        Integer state = groupRelationFrontService.getNetflixErrorAccountStatus(userId, relationId);
+        return GatewayResponse.SUCCESS.newBuilder().toResult(state);
+    }
 }