[fix]修改消息

This commit is contained in:
wangqx 2025-09-24 10:35:32 +08:00
parent 2692cd66b8
commit 1238837d62
6 changed files with 72 additions and 2 deletions

View File

@ -64,6 +64,7 @@ public class AppSearchController {
} else if (Objects.nonNull(searchBO) && Objects.nonNull(searchBO.getType()) && (SearchTypeEnum.MEMBER.type.intValue() == searchBO.getType().intValue())) {
MemberBO memberBO = new MemberBO();
memberBO.setNickname(searchBO.getTitle());
memberBO.setPhone(searchBO.getTitle());
pages = memberService.getMemberPageList(memberBO, page);
}
return R.ok(pages);

View File

@ -5,7 +5,9 @@ public enum MessageActionEnum {
SYSTEM_NOTIFY(10, "system"), // 系统->通知
SYSTEM_REPORT(13, "system"), // 系统->举报下架视频视频评论 视频评论
SYSTEM_CHECK(14, "system"), // 系统->审核结果复审驳回 通过
SYSTEM_CHECK(14, "system"), // 系统->审核结果通过
SYSTEM_VLOG_REFUSE(17, "system"), // 系统->审核结果驳回
SYSTEM_VLOG_RECHECK(18, "system"), // 系统->审核结果复审
SYSTEM_PUSH(15, "system"), //系统->推广类的
INTERACTION_COMMENT(21, "interaction"), //互动->评论
INTERACTION_AT(27, "interaction"), //互动->视频评论中的@

View File

@ -157,7 +157,9 @@ public class MQMessageHandleServiceImpl implements IMQMessageHandleService {
return content;
}
for (String key : variables.keySet()) {
content = content.replaceAll("\\$\\{" + key + "\\}", variables.get(key).toString());
if(variables.get(key)!=null){
content = content.replaceAll("\\$\\{" + key + "\\}", variables.get(key).toString());
}
}
return content;
}

View File

@ -24,6 +24,7 @@ public class ImCallbackController {
@PostMapping
public R handleCallback(
@RequestParam(value = "Sign", required = false) String sign,
@RequestParam(value = "RequestTime", required = false) String requestTime,
@RequestParam(value = "CallbackCommand", required = false) String callbackCommand,
@RequestBody Map<String, Object> requestBody) {

View File

@ -86,6 +86,7 @@ public class MemberBO extends BaseBO {
QueryWrapper<Member> qw = new QueryWrapper<>();
qw.lambda()
.like(StringUtils.isNotEmpty(this.getNickname()), Member::getNickname, this.getNickname())
// .and(wq->wq.like(StringUtils.isNotEmpty(this.getPhone()), Member::getPhoneHidden, this.getPhone()).or())
.eq(getId() != null, Member::getId, this.getId())
.eq(status != null, Member::getStatus, status)
.eq(spreadUid != null, Member::getSpreadUid, spreadUid)

63
script/sql/syncVlog.sql Normal file
View File

@ -0,0 +1,63 @@
INSERT INTO cont_vlog (
id,
member_id,
url,
cover,
title,
width,
height,
like_counts,
comments_counts,
is_private,
create_time,
update_time,
status,
reason,
city_code,
file_id,
first_frame_img,
create_by,
update_by,
del_flag
)
SELECT
-- 核心字段映射t_vlog -> cont_vlog
id,
vloger_id, -- 视频发布者ID映射为会员ID
url,
cover,
title,
width,
height,
like_counts,
comments_counts,
is_private,
created_time, -- 创建时间字段名转换
updated_time, -- 更新时间字段名转换
status,
reason,
city_code,
file_id,
first_frame_img,
vloger_id, -- 假设创建者为视频发布者
vloger_id, -- 假设更新者为视频发布者(可根据实际业务调整)
0 -- 删除标志默认为0未删除
FROM t_vlog
-- 处理重复数据若id已存在则更新指定字段
ON DUPLICATE KEY UPDATE
member_id = VALUES(member_id),
url = VALUES(url),
cover = VALUES(cover),
title = VALUES(title),
width = VALUES(width),
height = VALUES(height),
like_counts = VALUES(like_counts),
comments_counts = VALUES(comments_counts),
is_private = VALUES(is_private),
update_time = VALUES(update_time),
status = VALUES(status),
reason = VALUES(reason),
city_code = VALUES(city_code),
file_id = VALUES(file_id),
first_frame_img = VALUES(first_frame_img),
update_by = VALUES(update_by);