zw/pkAssistant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.修改pk文章详情

Browse Source
This commit is contained in:
Ziin
2025-08-04 15:03:53 +08:00
parent ba60cfb550
commit 715e6a1b70
3 changed files with 43 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/main/java/vvpkassistant/pk/controller/PkController.java
View File

@@ -80,42 +80,7 @@ public class PkController {
//pk文章详情 //pk文章详情
@PostMapping("pkInfoDetail") @PostMapping("pkInfoDetail")
public ResponseData<Object> pkInfoDetail(@RequestBody Map<String, Integer> map) { public ResponseData<Object> pkInfoDetail(@RequestBody Map<String, Integer> map) {
Integer id = map.get("id"); return ResponseData.success(pkService.pkInfoDetail(map));
Integer userId = map.get("userId");
Integer from = map.get("from"); // 1 首页 2 聊天
PkInfoModel pkInfoModel = pkDao.selectById(id);
if (pkInfoModel == null) {
return ResponseData.error(ResponseInfo.ERROR.getCode(),"该信息不存在");
}
if (from == 1) {
if (pkInfoModel.getPkTime() > VVTools.currentTimeStamp()) {
// 判断是否是自己发布的数据 如果不是，就隐藏主播id
if (pkInfoModel.getSenderId().equals(userId)) {
pkInfoModel.setDisPlayId(pkInfoModel.getAnchorId());
} else {
// 查询是否存在未完成的pk记录
Integer isHave = pkDao.checkIfUnfinishedPKExistsWithAnchor(userId, pkInfoModel.getAnchorId());
if (isHave > 0) {
pkInfoModel.setDisPlayId(pkInfoModel.getAnchorId());
}else {
pkInfoModel.setDisPlayId(VVTools.replaceChar(pkInfoModel.getAnchorId(), '*'));
}
}
return ResponseData.success(pkInfoModel);
}else {
return ResponseData.error(ResponseInfo.ERROR.getCode(),"当前信息已无效");
}
}else{
Integer isHave = pkDao.checkIfUnfinishedPKExistsWithAnchor(userId, pkInfoModel.getAnchorId());
if (isHave > 0) {
pkInfoModel.setDisPlayId(pkInfoModel.getAnchorId());
}else {
pkInfoModel.setDisPlayId(VVTools.replaceChar(pkInfoModel.getAnchorId(), '*'));
}
return ResponseData.success(pkInfoModel);
}
} }
//删除自己的pk数据 (单个) //删除自己的pk数据 (单个)

2
src/main/java/vvpkassistant/pk/service/PKService.java
View File

@@ -19,4 +19,6 @@ public interface PKService extends IService<PkInfoModel> {
PkRecord createPKRecord(PkRecord record); PkRecord createPKRecord(PkRecord record);
List<PkInfoModel> getPKList(Map<String, Object> map); List<PkInfoModel> getPKList(Map<String, Object> map);
PkInfoModel pkInfoDetail(Map<String, Integer> map);
} }

40
src/main/java/vvpkassistant/pk/service/PKServiceImpl.java
View File

@@ -200,4 +200,44 @@ public class PKServiceImpl extends ServiceImpl<PkInfoDao, PkInfoModel> implement
} }
return pkModels; return pkModels;
} }
@Override
public PkInfoModel pkInfoDetail(Map<String, Integer> map) {
Integer id = map.get("id");
Integer userId = map.get("userId");
Integer from = map.get("from"); // 1 首页 2 聊天
PkInfoModel pkInfoModel = pkInfoDao.selectById(id);
if (pkInfoModel == null) {
throw new BusinessException(ErrorCode.SYSTEM_ERROR, "该信息不存在");
}
if (from == 1) {
if (pkInfoModel.getPkTime() > VVTools.currentTimeStamp()) {
// 判断是否是自己发布的数据 如果不是，就隐藏主播id
if (pkInfoModel.getSenderId().equals(userId)) {
pkInfoModel.setDisPlayId(pkInfoModel.getAnchorId());
} else {
// 查询是否存在未完成的pk记录
Integer isHave = pkInfoDao.checkIfUnfinishedPKExistsWithAnchor(userId, pkInfoModel.getAnchorId());
if (isHave > 0) {
pkInfoModel.setDisPlayId(pkInfoModel.getAnchorId());
} else {
pkInfoModel.setDisPlayId(VVTools.replaceChar(pkInfoModel.getAnchorId(), '*'));
}
}
return pkInfoModel;
} else {
throw new BusinessException(ErrorCode.SYSTEM_ERROR,"当前信息已无效");
}
} else {
Integer isHave = pkInfoDao.checkIfUnfinishedPKExistsWithAnchor(userId, pkInfoModel.getAnchorId());
if (isHave > 0) {
pkInfoModel.setDisPlayId(pkInfoModel.getAnchorId());
} else {
pkInfoModel.setDisPlayId(VVTools.replaceChar(pkInfoModel.getAnchorId(), '*'));
}
return pkInfoModel;
}
}
} }