Compare commits
No commits in common. "3f77f370006c33f036b26e9195ee75a14d2e2d57" and "25c5f3466bf786d2c739f5d5dcce41d74043fdee" have entirely different histories.
3f77f37000
...
25c5f3466b
@ -152,7 +152,16 @@ public class AppVlogController {
|
|||||||
return R.ok();
|
return R.ok();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "已读视频")
|
||||||
|
@GetMapping("/read")
|
||||||
|
public R<Void> read(@RequestBody VlogBO vlogBO) {
|
||||||
|
LoginUser loginUser = LoginHelper.getLoginUser();
|
||||||
|
if (loginUser == null) {
|
||||||
|
return R.notLogin();
|
||||||
|
}
|
||||||
|
vlogService.readVlog(loginUser.getUserId(), vlogBO.getId());
|
||||||
|
return R.ok();
|
||||||
|
}
|
||||||
@Operation(summary = "删除视频")
|
@Operation(summary = "删除视频")
|
||||||
@GetMapping("/delete")
|
@GetMapping("/delete")
|
||||||
public R<Void> delete(@RequestParam String id) {
|
public R<Void> delete(@RequestParam String id) {
|
||||||
|
@ -171,5 +171,7 @@ public interface VlogMapper extends BaseMapper<Vlog> {
|
|||||||
|
|
||||||
|
|
||||||
IPage<String> getVlogForUser(Page<IndexVlogVO> page, @Param("memberId") Long memberId);
|
IPage<String> getVlogForUser(Page<IndexVlogVO> page, @Param("memberId") Long memberId);
|
||||||
|
int readVlog(@Param("memberId") Long memberId, @Param("vlogId") String vlogId);
|
||||||
|
|
||||||
|
List<IndexVlogVO> selectUserLikeVlogList(@Param("memberId") Long memberId);
|
||||||
}
|
}
|
||||||
|
@ -130,6 +130,7 @@ public interface VlogService extends IService<Vlog> {
|
|||||||
List<Map<String, Object>> getRandomVlogs(int limit);
|
List<Map<String, Object>> getRandomVlogs(int limit);
|
||||||
|
|
||||||
IPage<String> getVlogForUser(Page<IndexVlogVO> page, Long memberId);
|
IPage<String> getVlogForUser(Page<IndexVlogVO> page, Long memberId);
|
||||||
|
int readVlog(Long memberId, String vlogId);
|
||||||
|
|
||||||
List<IndexVlogVO> getIndexVlogList(VlogBO bo);
|
List<IndexVlogVO> getIndexVlogList(VlogBO bo);
|
||||||
Page<IndexVlogVO> getIndexVlogList(VlogBO bo,Page page);
|
Page<IndexVlogVO> getIndexVlogList(VlogBO bo,Page page);
|
||||||
@ -139,12 +140,4 @@ public interface VlogService extends IService<Vlog> {
|
|||||||
*/
|
*/
|
||||||
Page<IndexVlogVO> getIndexSearchVlogList(SearchBO bo, Page page);
|
Page<IndexVlogVO> getIndexSearchVlogList(SearchBO bo, Page page);
|
||||||
|
|
||||||
// /**
|
|
||||||
// * 首页搜索/搜索的vlog列表
|
|
||||||
// */
|
|
||||||
// Page<IndexVlogVO> getHotVlogList(SearchBO bo, Page page);
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -62,7 +62,6 @@ public class VlogPushServiceImpl implements IVlogPushService {
|
|||||||
//从数据库中获取差量数据
|
//从数据库中获取差量数据
|
||||||
Page<Vlog> vlogPage = new Page<>(1, count-rankSet.size());
|
Page<Vlog> vlogPage = new Page<>(1, count-rankSet.size());
|
||||||
vlogPage = vlogService.page(vlogPage, new LambdaQueryWrapper<Vlog>()
|
vlogPage = vlogService.page(vlogPage, new LambdaQueryWrapper<Vlog>()
|
||||||
.eq(Vlog::getDelFlag, "0")
|
|
||||||
.orderByDesc(Vlog::getLikeCounts));
|
.orderByDesc(Vlog::getLikeCounts));
|
||||||
Set<String> vlogIds = vlogPage.getRecords().stream().map(vlog -> vlog.getId()).collect(Collectors.toSet());
|
Set<String> vlogIds = vlogPage.getRecords().stream().map(vlog -> vlog.getId()).collect(Collectors.toSet());
|
||||||
rankSet.addAll(vlogIds);
|
rankSet.addAll(vlogIds);
|
||||||
|
@ -553,7 +553,17 @@ public class VlogServiceImpl extends ServiceImpl<VlogMapper, Vlog> implements Vl
|
|||||||
return baseMapper.getVlogForUser(page, memberId);
|
return baseMapper.getVlogForUser(page, memberId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
@Transactional(rollbackFor = Exception.class)
|
||||||
|
public int readVlog(Long memberId, String vlogId) {
|
||||||
|
//加入已读缓存列表,数量为1
|
||||||
|
if (!redisCache.zSetHasMember("vlog:read:" + memberId, vlogId)) {
|
||||||
|
redisCache.zSetAdd("vlog:read:" + memberId, vlogId, 1);
|
||||||
|
} else {
|
||||||
|
redisCache.zSetIncrement("vlog:read:" + memberId, vlogId, 1);
|
||||||
|
}
|
||||||
|
return baseMapper.readVlog(memberId, vlogId);
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<IndexVlogVO> getIndexVlogList(VlogBO bo) {
|
public List<IndexVlogVO> getIndexVlogList(VlogBO bo) {
|
||||||
|
@ -287,8 +287,8 @@
|
|||||||
v.id
|
v.id
|
||||||
FROM
|
FROM
|
||||||
cont_vlog v
|
cont_vlog v
|
||||||
WHERE v.is_private = 0 and v.first_frame_img IS NOT NULL and IFNULL(v.del_flag,0) = 0
|
WHERE
|
||||||
AND NOT EXISTS (
|
NOT EXISTS (
|
||||||
SELECT 1 FROM cont_vlog_member m
|
SELECT 1 FROM cont_vlog_member m
|
||||||
WHERE m.vlog_id = v.id AND m.member_id = ${memberId}
|
WHERE m.vlog_id = v.id AND m.member_id = ${memberId}
|
||||||
)
|
)
|
||||||
@ -329,10 +329,6 @@
|
|||||||
ums_member m ON v.member_id = m.id
|
ums_member m ON v.member_id = m.id
|
||||||
WHERE
|
WHERE
|
||||||
v.member_id = #{memberId}
|
v.member_id = #{memberId}
|
||||||
AND v.status = 1
|
|
||||||
AND v.first_frame_img IS NOT NULL
|
|
||||||
AND v.is_private = 0
|
|
||||||
and IFNULL(v.del_flag,0) = 0
|
|
||||||
ORDER BY
|
ORDER BY
|
||||||
v.create_time DESC
|
v.create_time DESC
|
||||||
</select>
|
</select>
|
||||||
|
@ -28,7 +28,7 @@
|
|||||||
ums_member m
|
ums_member m
|
||||||
ON
|
ON
|
||||||
v.member_id = m.id
|
v.member_id = m.id
|
||||||
WHERE v.first_frame_img IS NOT NULL and ifnull(v.delete_flag,0) = 0
|
WHERE v.first_frame_img IS NOT NULL
|
||||||
<if test="bo.isPrivate != null">
|
<if test="bo.isPrivate != null">
|
||||||
AND v.is_private = #{bo.isPrivate}
|
AND v.is_private = #{bo.isPrivate}
|
||||||
</if>
|
</if>
|
||||||
@ -108,38 +108,6 @@
|
|||||||
AND v.first_frame_img IS NOT NULL
|
AND v.first_frame_img IS NOT NULL
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<select id="getHotVlogList" parameterType="map" resultType="com.wzj.soopin.content.domain.vo.IndexVlogVO">
|
|
||||||
SELECT
|
|
||||||
v.id as vlogId,
|
|
||||||
v.member_id as vlogerId,
|
|
||||||
m.avatar as vlogerFace,
|
|
||||||
m.nickname as vlogerName,
|
|
||||||
v.title as content,
|
|
||||||
v.url as url,
|
|
||||||
v.cover as cover,
|
|
||||||
v.width as width,
|
|
||||||
v.height as height,
|
|
||||||
v.like_counts as likeCounts,
|
|
||||||
v.comments_counts as commentsCounts,
|
|
||||||
v.is_private as isPrivate,
|
|
||||||
v.city_code as cityCode,
|
|
||||||
v.reason as reason,
|
|
||||||
v.file_id as fileId,
|
|
||||||
v.status as status,
|
|
||||||
v.first_frame_img as firstFrameImg,
|
|
||||||
v.id as vlogId
|
|
||||||
FROM
|
|
||||||
cont_vlog v
|
|
||||||
LEFT JOIN
|
|
||||||
ums_member m
|
|
||||||
ON
|
|
||||||
v.member_id = m.id
|
|
||||||
WHERE
|
|
||||||
v.id = #{paramMap.vlogId}
|
|
||||||
AND v.status = 1
|
|
||||||
AND v.first_frame_img IS NOT NULL
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="getMyLikedVlogList" parameterType="map" resultType="com.wzj.soopin.content.domain.vo.IndexVlogVO">
|
<select id="getMyLikedVlogList" parameterType="map" resultType="com.wzj.soopin.content.domain.vo.IndexVlogVO">
|
||||||
SELECT
|
SELECT
|
||||||
v.id as vlogId,
|
v.id as vlogId,
|
||||||
@ -174,11 +142,9 @@
|
|||||||
v.member_id = m.id
|
v.member_id = m.id
|
||||||
WHERE
|
WHERE
|
||||||
mlv.member_id = #{paramMap.myId}
|
mlv.member_id = #{paramMap.myId}
|
||||||
|
|
||||||
AND v.status = 1
|
AND v.status = 1
|
||||||
AND v.first_frame_img IS NOT NULL
|
AND v.first_frame_img IS NOT NULL
|
||||||
AND v.is_private = 0
|
AND v.is_private = 0
|
||||||
and ifnull(v.del_flag,0) = 0
|
|
||||||
<if test="paramMap.blockVd != null and paramMap.blockVd.size() > 0">
|
<if test="paramMap.blockVd != null and paramMap.blockVd.size() > 0">
|
||||||
AND v.id NOT IN
|
AND v.id NOT IN
|
||||||
<foreach collection="paramMap.blockVd" item="vlogId" open="(" separator="," close=")">
|
<foreach collection="paramMap.blockVd" item="vlogId" open="(" separator="," close=")">
|
||||||
@ -226,7 +192,6 @@
|
|||||||
AND v.is_private = 0
|
AND v.is_private = 0
|
||||||
AND v.STATUS = 1
|
AND v.STATUS = 1
|
||||||
AND v.first_frame_img IS NOT NULL
|
AND v.first_frame_img IS NOT NULL
|
||||||
and ifnull(v.del_flag,0) = 0
|
|
||||||
AND
|
AND
|
||||||
f.fan_id = #{paramMap.myId}
|
f.fan_id = #{paramMap.myId}
|
||||||
ORDER BY
|
ORDER BY
|
||||||
@ -265,7 +230,6 @@
|
|||||||
AND v.first_frame_img IS NOT NULL
|
AND v.first_frame_img IS NOT NULL
|
||||||
AND f.fan_id = #{paramMap.myId}
|
AND f.fan_id = #{paramMap.myId}
|
||||||
AND f.friend_flag = 1
|
AND f.friend_flag = 1
|
||||||
and ifnull(v.del_flag,0) = 0
|
|
||||||
AND NOT EXISTS ( SELECT 1 FROM cont_vlog_member vm WHERE v.id = vm.vlog_id AND vm.member_id= #{paramMap.myId} )
|
AND NOT EXISTS ( SELECT 1 FROM cont_vlog_member vm WHERE v.id = vm.vlog_id AND vm.member_id= #{paramMap.myId} )
|
||||||
ORDER BY
|
ORDER BY
|
||||||
v.create_time DESC
|
v.create_time DESC
|
||||||
|
Loading…
x
Reference in New Issue
Block a user