|
@@ -163,7 +163,7 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
|
|
|
|
|
|
|
|
private final NetflixTempAccountUserMapper netflixTempAccountUserMapper;
|
|
private final NetflixTempAccountUserMapper netflixTempAccountUserMapper;
|
|
|
|
|
|
|
|
- private final NetflixUseAccountStatusRecordMapper netflixUseAccountStatusRecordMapper;
|
|
|
|
|
|
|
+ private final NetflixUserAccountStatusRecordMapper netflixUserAccountStatusRecordMapper;
|
|
|
|
|
|
|
|
private final AccountNetflixStateMapper accountNetflixStateMapper;
|
|
private final AccountNetflixStateMapper accountNetflixStateMapper;
|
|
|
|
|
|
|
@@ -1044,12 +1044,12 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
|
|
|
throw BusinessRuntimeException.getInstance("更换异常,请重新提交");
|
|
throw BusinessRuntimeException.getInstance("更换异常,请重新提交");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- NetflixUseAccountStatusRecord netflixUseAccountStatusRecord = netflixUseAccountStatusRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUseAccountStatusRecord.class)
|
|
|
|
|
- .eq(NetflixUseAccountStatusRecord::getRelationId, relationId)
|
|
|
|
|
|
|
+ NetflixUserAccountStatusRecord netflixUserAccountStatusRecord = netflixUserAccountStatusRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
|
|
|
|
|
+ .eq(NetflixUserAccountStatusRecord::getRelationId, relationId)
|
|
|
.last("limit 1"));
|
|
.last("limit 1"));
|
|
|
- if (netflixUseAccountStatusRecord != null) {
|
|
|
|
|
- netflixUseAccountStatusRecord.setDeleted(false);
|
|
|
|
|
- netflixUseAccountStatusRecordMapper.updateById(netflixUseAccountStatusRecord);
|
|
|
|
|
|
|
+ if (netflixUserAccountStatusRecord != null) {
|
|
|
|
|
+ netflixUserAccountStatusRecord.setDeleted(false);
|
|
|
|
|
+ netflixUserAccountStatusRecordMapper.updateById(netflixUserAccountStatusRecord);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -1115,10 +1115,10 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
|
|
|
String account = renewalView.getAccount();
|
|
String account = renewalView.getAccount();
|
|
|
String password = renewalView.getPassword();
|
|
String password = renewalView.getPassword();
|
|
|
|
|
|
|
|
- Integer selectCount = netflixUseAccountStatusRecordMapper.selectCount(Wrappers.lambdaQuery(NetflixUseAccountStatusRecord.class)
|
|
|
|
|
- .eq(NetflixUseAccountStatusRecord::getRelationId, relationId)
|
|
|
|
|
- .eq(NetflixUseAccountStatusRecord::getUserId, userId)
|
|
|
|
|
- .eq(NetflixUseAccountStatusRecord::getAccount, account));
|
|
|
|
|
|
|
+ Integer selectCount = netflixUserAccountStatusRecordMapper.selectCount(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
|
|
|
|
|
+ .eq(NetflixUserAccountStatusRecord::getRelationId, relationId)
|
|
|
|
|
+ .eq(NetflixUserAccountStatusRecord::getUserId, userId)
|
|
|
|
|
+ .eq(NetflixUserAccountStatusRecord::getAccount, account));
|
|
|
if (selectCount > 0) {
|
|
if (selectCount > 0) {
|
|
|
throw BusinessRuntimeException.getInstance("该账号正在检测中");
|
|
throw BusinessRuntimeException.getInstance("该账号正在检测中");
|
|
|
}
|
|
}
|
|
@@ -1129,22 +1129,22 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
|
|
|
if (accountNetflixState != null && (accountNetflixState.getState() == 2 || accountNetflixState.getState() == 3)) {
|
|
if (accountNetflixState != null && (accountNetflixState.getState() == 2 || accountNetflixState.getState() == 3)) {
|
|
|
state = accountNetflixState.getState();
|
|
state = accountNetflixState.getState();
|
|
|
}
|
|
}
|
|
|
- NetflixUseAccountStatusRecord netflixUseAccountStatusRecord = new NetflixUseAccountStatusRecord();
|
|
|
|
|
- netflixUseAccountStatusRecord.setAccount(account);
|
|
|
|
|
- netflixUseAccountStatusRecord.setRelationId(relationId);
|
|
|
|
|
- netflixUseAccountStatusRecord.setPassword(password);
|
|
|
|
|
- netflixUseAccountStatusRecord.setUserId(renewalView.getUserId());
|
|
|
|
|
- netflixUseAccountStatusRecord.setState(state);
|
|
|
|
|
- netflixUseAccountStatusRecordMapper.insert(netflixUseAccountStatusRecord);
|
|
|
|
|
|
|
+ NetflixUserAccountStatusRecord netflixUserAccountStatusRecord = new NetflixUserAccountStatusRecord();
|
|
|
|
|
+ netflixUserAccountStatusRecord.setAccount(account);
|
|
|
|
|
+ netflixUserAccountStatusRecord.setRelationId(relationId);
|
|
|
|
|
+ netflixUserAccountStatusRecord.setPassword(password);
|
|
|
|
|
+ netflixUserAccountStatusRecord.setUserId(renewalView.getUserId());
|
|
|
|
|
+ netflixUserAccountStatusRecord.setState(state);
|
|
|
|
|
+ netflixUserAccountStatusRecordMapper.insert(netflixUserAccountStatusRecord);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public Integer getNetflixErrorAccountStatus(long userId, Long relationId) {
|
|
public Integer getNetflixErrorAccountStatus(long userId, Long relationId) {
|
|
|
List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
|
|
List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
|
|
|
- NetflixUseAccountStatusRecord netflixUseAccountStatusRecord = netflixUseAccountStatusRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUseAccountStatusRecord.class)
|
|
|
|
|
- .eq(NetflixUseAccountStatusRecord::getRelationId, relationId)
|
|
|
|
|
- .eq(NetflixUseAccountStatusRecord::getDeleted, 1)
|
|
|
|
|
- .in(NetflixUseAccountStatusRecord::getUserId, userIdList)
|
|
|
|
|
|
|
+ NetflixUserAccountStatusRecord netflixUseAccountStatusRecord = netflixUserAccountStatusRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
|
|
|
|
|
+ .eq(NetflixUserAccountStatusRecord::getRelationId, relationId)
|
|
|
|
|
+ .eq(NetflixUserAccountStatusRecord::getDeleted, 1)
|
|
|
|
|
+ .in(NetflixUserAccountStatusRecord::getUserId, userIdList)
|
|
|
.last("limit 1"));
|
|
.last("limit 1"));
|
|
|
if (netflixUseAccountStatusRecord == null) {
|
|
if (netflixUseAccountStatusRecord == null) {
|
|
|
throw BusinessRuntimeException.getInstance("未有提交记录");
|
|
throw BusinessRuntimeException.getInstance("未有提交记录");
|
|
@@ -1160,12 +1160,12 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public List<NetflixUseAccountStatusRecord> getUserNetflixSubmitRecord(long userId) {
|
|
|
|
|
|
|
+ public List<NetflixUserAccountStatusRecord> getUserNetflixSubmitRecord(long userId) {
|
|
|
List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
|
|
List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
|
|
|
- List<NetflixUseAccountStatusRecord> netflixUseAccountStatusRecords = netflixUseAccountStatusRecordMapper.selectList(Wrappers.lambdaQuery(NetflixUseAccountStatusRecord.class)
|
|
|
|
|
- .in(NetflixUseAccountStatusRecord::getUserId, userIdList)
|
|
|
|
|
- .eq(NetflixUseAccountStatusRecord::getDeleted, 1)
|
|
|
|
|
- .select(NetflixUseAccountStatusRecord::getRelationId, NetflixUseAccountStatusRecord::getState, NetflixUseAccountStatusRecord::getCreatedTime));
|
|
|
|
|
|
|
+ List<NetflixUserAccountStatusRecord> netflixUseAccountStatusRecords = netflixUserAccountStatusRecordMapper.selectList(Wrappers.lambdaQuery(NetflixUserAccountStatusRecord.class)
|
|
|
|
|
+ .in(NetflixUserAccountStatusRecord::getUserId, userIdList)
|
|
|
|
|
+ .eq(NetflixUserAccountStatusRecord::getDeleted, 1)
|
|
|
|
|
+ .select(NetflixUserAccountStatusRecord::getRelationId, NetflixUserAccountStatusRecord::getState, NetflixUserAccountStatusRecord::getCreatedTime));
|
|
|
return netflixUseAccountStatusRecords;
|
|
return netflixUseAccountStatusRecords;
|
|
|
}
|
|
}
|
|
|
|
|
|