Skip to content

W
wecloud_im_server
Commit 87d0832e by hweeeeeei
Options

1:修复除"text"文本类型外,其他类型消息不能ws通过在线推送和离线拉取问题, 

如:图片.视频.位置等扩展类型.
2:优化:"type"响应字段数据格式移出content,"im_message"表增加字段"msg_type",对客户端下发需转换成"type"进行兼容;
3.改造接收实体类型,使其支持更广泛的消息类型,集成版无法预先知道第三方应用所拓展的数据格式,用Object(hashmap)来保存应用上行参数,不能使用固定的成员变量或实体来接收;
parent ec675e7c
Showing with 467 additions and 124 deletions
core/src/main/java/com/wecloud/im/entity/ImMessage.java
......@@ -46,6 +46,10 @@ public class ImMessage extends BaseEntity {
@ApiModelProperty("发送者客户端id")
private Long sender;
/**
* 数据库字段类型为JSON格式
* 因mysql关系型数据库非MongoDB文档类型数据库,第三方应用拓展的自定义参数名和值需使用json格式落库
*/
@ApiModelProperty("内容")
private String content;
......@@ -69,4 +73,7 @@ public class ImMessage extends BaseEntity {
@ApiModelProperty("会话id")
private Long fkConversationId;
@ApiModelProperty("消息类型")
private Integer msgType;
}
core/src/main/java/com/wecloud/im/entity/ImMessageOnlineSend.java
......@@ -24,6 +24,9 @@ import java.util.HashMap;
public class ImMessageOnlineSend extends BaseEntity {
private static final long serialVersionUID = 1L;
@ApiModelProperty("消息类型")
private Integer type;
@NotNull(message = "消息id不能为空")
@ApiModelProperty("消息id")
private Long msgId;
......
core/src/main/java/com/wecloud/im/service/ImConversationService.java
......@@ -95,13 +95,13 @@ public interface ImConversationService extends BaseService<ImConversation> {
boolean updateDisplayConversation(ImConversationDisplayUpdate imConversationDisplayUpdate);
/**
* 根据ID获取查询对象
* 根据ID获取查询对象 (redis缓存)
*
* @param id
* @return
* @throws Exception
*/
ImConversationQueryVo getImConversationById(Long id);
ImConversationQueryVo getCacheImConversationById(Long id);
/**
* 删除redis中该会话的缓存
......
core/src/main/java/com/wecloud/im/service/ImMessageService.java
......@@ -10,6 +10,7 @@ import com.wecloud.im.param.add.ImMsgUpdate;
import com.wecloud.im.vo.ImMessageOfflineListVo;
import com.wecloud.im.vo.OfflineMsgDto;
import com.wecloud.im.ws.model.request.ReceiveDataVO;
import com.wecloud.im.ws.model.request.ReceiveVO;
import io.geekidea.springbootplus.framework.common.api.ApiResult;
import io.geekidea.springbootplus.framework.common.service.BaseService;
import io.geekidea.springbootplus.framework.core.pagination.Paging;
......@@ -34,7 +35,7 @@ public interface ImMessageService extends BaseService<ImMessage> {
ApiResult<Boolean> restApiImMessageSend(ImMsgSendToOnlineClient imMsgSendToOnlineClient, ImApplication imApplication);
ImMessage saveImMessage(ImApplication imApplication, ImClient imClientSender, Long toConversationId, long messageId, ReceiveDataVO content);
ImMessage saveImMessage(ImApplication imApplication, ImClient imClientSender, long messageId, ReceiveVO receiveVO, ReceiveDataVO sysParam);
/**
......
core/src/main/java/com/wecloud/im/service/impl/ImConversationServiceImpl.java
......@@ -797,7 +797,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
@Override
@Cacheable(key = "#p0")
public ImConversationQueryVo getImConversationById(Long id) {
public ImConversationQueryVo getCacheImConversationById(Long id) {
return imConversationMapper.getImConversationById(id);
}
......
core/src/main/java/com/wecloud/im/service/impl/ImMessageServiceImpl.java
......@@ -29,6 +29,7 @@ import com.wecloud.im.ws.enums.WsResponseCmdEnum;
import com.wecloud.im.ws.model.WsResponse;
import com.wecloud.im.ws.model.request.PushVO;
import com.wecloud.im.ws.model.request.ReceiveDataVO;
import com.wecloud.im.ws.model.request.ReceiveVO;
import com.wecloud.im.ws.sender.AsyncPush;
import com.wecloud.im.ws.sender.ChannelSender;
import com.wecloud.utils.JsonUtils;
......@@ -99,7 +100,6 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
}
ImApiMessageOnlineSend imApiMessageOnlineSend = new ImApiMessageOnlineSend();
imApiMessageOnlineSend.setCreateTime(new Date());
......@@ -138,20 +138,26 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
}
@Override
public ImMessage saveImMessage(ImApplication imApplication, ImClient imClientSender, Long toConversationId, long messageId, ReceiveDataVO content) {
@Transactional(rollbackFor = Exception.class)
public ImMessage saveImMessage(ImApplication imApplication, ImClient imClientSender, long messageId, ReceiveVO receiveVO, ReceiveDataVO sysParam) {
ImMessage imMessage = new ImMessage();
// 数据库字段类型为JSON格式
// 因mysql关系型数据库非MongoDB文档类型数据库,第三方应用拓展的自定义参数名和值需使用json格式落库
String contentJsonString = JsonUtils.encodeJson(receiveVO.getData());
imMessage.setContent(contentJsonString);
imMessage.setId(messageId);
imMessage.setCreateTime(new Date());
imMessage.setFkAppid(imApplication.getId());
imMessage.setSender(imClientSender.getId());
String contentStr = JsonUtils.encodeJson(content);
imMessage.setContent(contentStr);
imMessage.setWithdraw(false);
imMessage.setEvent(false);
imMessage.setSystemFlag(false);
imMessage.setSendStatus(2);
imMessage.setFkConversationId(toConversationId);
imMessage.setMsgType(sysParam.getType());
imMessage.setFkConversationId(sysParam.getToConversation());
this.save(imMessage);
return imMessage;
}
......
core/src/main/java/com/wecloud/im/vo/OfflineMsgDto.java
......@@ -16,6 +16,9 @@ import java.util.Date;
@ApiModel(value = "OfflineMsgDto")
public class OfflineMsgDto implements Serializable {
@ApiModelProperty("消息类型")
private Integer type;
@ApiModelProperty("消息id")
private Long msgId;
......
core/src/main/java/com/wecloud/im/ws/model/request/PushVO.java
......@@ -3,6 +3,7 @@ package com.wecloud.im.ws.model.request;
import lombok.Data;
import java.io.Serializable;
import java.util.HashMap;
/**
* @Description 推送model
......@@ -22,4 +23,10 @@ public class PushVO implements Serializable {
*/
private String subTitle;
/**
* 自定义系统推送内容
*/
private HashMap data;
}
core/src/main/java/com/wecloud/im/ws/model/request/ReceiveDataVO.java
......@@ -3,36 +3,26 @@ package com.wecloud.im.ws.model.request;
import lombok.Data;
import java.io.Serializable;
import java.util.HashMap;
/**
* 内部固定参数
*/
@Data
public class ReceiveDataVO implements Serializable {
/**
* push 对象
*/
private PushVO push;
private PushVO pushVO;
/**
* 自定义的值
*/
private String diyAbcd;
/**
* 发送的会话id
*/
private Long toConversation;
/**
* 发送的type
* 消息的type
*/
private Integer type;
/**
* 发送的内容文本
*/
private String text;
/**
* 自定义可扩展的发送字段和值
*/
private HashMap attrs;
}
core/src/main/java/com/wecloud/im/ws/model/request/ReceiveVO.java
......@@ -25,9 +25,10 @@ public class ReceiveVO implements Serializable {
private Integer cmd;
/**
* json数据
* 转换保存json数据
* 因集成版无法预先知道第三方应用所拓展的数据格式,所以用Object(hashmap)来保存应用上行参数,不能使用固定的成员变量或实体来接收
*/
private ReceiveDataVO data;
private HashMap data;
/**
* 请求id, 以判空是否请求成功, 服务端处理完成后 返回此id
......
core/src/main/java/com/wecloud/im/ws/strategy/AbstractImCmdStrategy.java
package com.wecloud.im.ws.strategy;
import com.wecloud.im.entity.ImApplication;
import com.wecloud.im.entity.ImClient;
import com.wecloud.im.enums.ChatTypeEnum;
......@@ -9,13 +8,16 @@ import com.wecloud.im.service.ImApplicationService;
import com.wecloud.im.service.ImClientService;
import com.wecloud.im.service.ImConversationService;
import com.wecloud.im.ws.enums.WsRequestCmdEnum;
import com.wecloud.im.ws.model.request.PushVO;
import com.wecloud.im.ws.model.request.ReceiveDataVO;
import com.wecloud.im.ws.model.request.ReceiveVO;
import com.wecloud.im.ws.utils.SpringBeanUtils;
import com.wecloud.utils.JsonUtils;
import io.geekidea.springbootplus.framework.common.exception.BusinessException;
import io.netty.channel.ChannelHandlerContext;
import lombok.extern.slf4j.Slf4j;
import java.util.HashMap;
/**
* @Description 处理Cmd请求
* 抽象类 策略设计模式
......@@ -25,20 +27,35 @@ import lombok.extern.slf4j.Slf4j;
@Slf4j
public abstract class AbstractImCmdStrategy {
private static ImCmdStrategyFactory imCmdStrategyFactory;
public static final String PUSH_KEY = "push";
private static final String TITLE = "title";
private static final String SUB_TITLE = "subTitle";
private static final String DATA = "data";
/**
* 您收到一条新消息
*/
private static final String PUSH_TITLE = "You have received a new message";
/**
* 点击查看
*/
private static final String PUSH_BODY = "Click to view";
private static final String TO_CONVERSATION_KEY = "toConversation";
private static final String MSG_TYPE = "type";
private static volatile ImCmdStrategyFactory imCmdStrategyFactory;
private static ImApplicationService imApplicationService;
private static ImClientService imClientService;
private static ImConversationService imConversationService;
public static void process(Long senderClientId, ChannelHandlerContext ctx, String data) {
if(log.isDebugEnabled()) {
if (log.isDebugEnabled()) {
log.debug("appWS收到data: {}\n senderClientId:{}, channelId:{}", data, senderClientId, ctx.channel().id().asLongText());
}
if(imCmdStrategyFactory == null) {
if (imCmdStrategyFactory == null) {
synchronized (AbstractImCmdStrategy.class) {
// 双空判断，懒汉模式下的绝对线程安全
if(imCmdStrategyFactory == null) {
if (imCmdStrategyFactory == null) {
imCmdStrategyFactory = SpringBeanUtils.getBean(ImCmdStrategyFactory.class);
imApplicationService = SpringBeanUtils.getBean(ImApplicationService.class);
imClientService = SpringBeanUtils.getBean(ImClientService.class);
......@@ -47,31 +64,41 @@ public abstract class AbstractImCmdStrategy {
}
}
// 解析jsonO
// 解析json
ReceiveVO receiveVO = JsonUtils.decodeJson(data, ReceiveVO.class);
if (null == receiveVO || null == receiveVO.getCmd()) {
throw new BusinessException("null == receiveVO || null == receiveVO.getCmd()");
}
// 获取会话id
if (receiveVO.getData() == null || receiveVO.getData().getToConversation() == null) {
log.warn("会话消息reqId: {} 不合法，缺少会话id！", receiveVO.getReqId());
// 参数判空校验
if (paramCheck(receiveVO)) {
return;
}
WsRequestCmdEnum wsRequestPathEnum = WsRequestCmdEnum.getByCode(receiveVO.getCmd());
Long toConversationId = Long.valueOf(receiveVO.getData().get(TO_CONVERSATION_KEY).toString());
Integer type = Integer.valueOf(receiveVO.getData().get(MSG_TYPE).toString());
// 移除后端固定的字段,其余字段都为第三方应用定义的,需要作为可拓展的json传入数据库
// 因mysql关系型数据库非MongoDB文档类型数据库,第三方应用拓展的参数值需要使用json格式落库
receiveVO.getData().remove(MSG_TYPE);
receiveVO.getData().remove(TO_CONVERSATION_KEY);
// 获取自定义推送字段 (可选)
HashMap<String, Object> pushMap = getPushMap(receiveVO);
// 内部固定参数model
ReceiveDataVO sysParam = new ReceiveDataVO();
sysParam.setPushVO(getPushModel(pushMap));
sysParam.setToConversation(toConversationId);
sysParam.setType(type);
//查看接收的群属性，是否万人群
ImConversationQueryVo conversation = imConversationService.getImConversationById(receiveVO.getData().getToConversation());
ImConversationQueryVo conversation = imConversationService.getCacheImConversationById(toConversationId);
if(conversation == null) {
log.warn("会话消息reqId: {} 会话id不合法！", receiveVO.getReqId());
if (conversation == null) {
log.warn("会reqId: {} ,会话id: {}db中不存在", receiveVO.getReqId(), toConversationId);
return;
}
if(ChatTypeEnum.THOUSAND_GROUP.getCode().equals(conversation.getChatType()) && WsRequestCmdEnum.NORMAL_CHAT == wsRequestPathEnum) {
WsRequestCmdEnum wsRequestPathEnum = WsRequestCmdEnum.getByCode(receiveVO.getCmd());
if (ChatTypeEnum.THOUSAND_GROUP.getCode().equals(conversation.getChatType()) && WsRequestCmdEnum.NORMAL_CHAT == wsRequestPathEnum) {
// 普通群升级为万人群
wsRequestPathEnum = WsRequestCmdEnum.THROUSAND_CHAT;
}
......@@ -92,8 +119,80 @@ public abstract class AbstractImCmdStrategy {
return;
}
cmdStrategy.process(imApplication, imClientSender, ctx, receiveVO);
cmdStrategy.process(imApplication, imClientSender, ctx, receiveVO, sysParam);
}
/**
* 封装推送实体
*
* @param pushMap
* @return
*/
private static PushVO getPushModel(HashMap<String, Object> pushMap) {
PushVO pushModel = new PushVO();
if (pushMap == null || pushMap.isEmpty()) {
pushModel.setTitle(PUSH_TITLE);
pushModel.setSubTitle(PUSH_BODY);
pushModel.setData(new HashMap<>(1));
} else {
pushModel.setTitle((String) pushMap.get(TITLE));
pushModel.setSubTitle((String) pushMap.get(SUB_TITLE));
// 自定义推送内容
HashMap hashMap = (HashMap) pushMap.get(DATA);
pushModel.setData(hashMap);
}
return pushModel;
}
/**
* 获取自定义推送字段
*
* @param receiveVO
* @return
*/
private static HashMap<String, Object> getPushMap(ReceiveVO receiveVO) {
HashMap<String, Object> pushMap = null;
if (receiveVO.getData().get(PUSH_KEY) != null) {
pushMap = (HashMap<String, Object>) receiveVO.getData().get(PUSH_KEY);
receiveVO.getData().remove(PUSH_KEY);
}
return pushMap;
}
/**
* 参数判空校验
*
* @param receiveVO
* @return
*/
private static boolean paramCheck(ReceiveVO receiveVO) {
if (receiveVO == null) {
log.warn("receiveVO == null 不合法 ");
return true;
}
if (receiveVO.getReqId() == null) {
log.warn("receiveVO.getReqId() == null 不合法");
return true;
}
if (receiveVO.getData() == null || receiveVO.getData().isEmpty()) {
log.warn("receiveVO.getData() null 不合法 reqId: {}", receiveVO.getReqId());
return true;
}
// 获取会话id(必传)
if (receiveVO.getData().get(TO_CONVERSATION_KEY) == null) {
log.warn("reqId: {} 不合法，缺少会话id！", receiveVO.getReqId());
return true;
}
// 获取消息type(必传)
if (receiveVO.getData().get(MSG_TYPE) == null) {
log.warn("reqId: {} 不合法，缺少消息type！", receiveVO.getReqId());
return true;
}
return false;
}
/**
......@@ -105,5 +204,5 @@ public abstract class AbstractImCmdStrategy {
* @param receiveVO
* @throws Exception
*/
public abstract void process(ImApplication imApplication, ImClient imSender, ChannelHandlerContext ctx, ReceiveVO receiveVO);
public abstract void process(ImApplication imApplication, ImClient imSender, ChannelHandlerContext ctx, ReceiveVO receiveVO, ReceiveDataVO receiveDataVO);
}
core/src/main/java/com/wecloud/im/ws/strategy/concrete/NormalChatStrategy.java
......@@ -16,6 +16,7 @@ import com.wecloud.im.ws.annotation.ImCmdType;
import com.wecloud.im.ws.enums.WsRequestCmdEnum;
import com.wecloud.im.ws.enums.WsResponseCmdEnum;
import com.wecloud.im.ws.model.WsResponse;
import com.wecloud.im.ws.model.request.ReceiveDataVO;
import com.wecloud.im.ws.model.request.ReceiveVO;
import com.wecloud.im.ws.sender.AsyncPush;
import com.wecloud.im.ws.sender.ChannelSender;
......@@ -65,20 +66,19 @@ public class NormalChatStrategy extends AbstractImCmdStrategy {
@Autowired
private AsyncPush systemPush;
@Override
public void process(ImApplication imApplication, ImClient imSender, ChannelHandlerContext ctx, ReceiveVO receiveVO) {
public void process(ImApplication imApplication, ImClient imSender, ChannelHandlerContext ctx, ReceiveVO receiveVO, ReceiveDataVO sysParam) {
NioSocketChannel channel = (NioSocketChannel) ctx.channel();
Long toConversationId = receiveVO.getData().getToConversation();
// 查询该会话所有成员
List<ImConversationMembers> membersList = imConversationMembersService.list(
new QueryWrapper<ImConversationMembers>().lambda()
.eq(ImConversationMembers::getFkConversationId, toConversationId)
.eq(ImConversationMembers::getFkConversationId, sysParam.getToConversation())
.notIn(ImConversationMembers::getFkClientId, imSender.getId())
);
if (membersList.isEmpty()) {
log.info("查询会话所有成员返回空，会话ID: {}", toConversationId);
log.info("查询会话所有成员返回空，会话ID: {}", sysParam.getToConversation());
return;
}
......@@ -93,7 +93,7 @@ public class NormalChatStrategy extends AbstractImCmdStrategy {
// 生成消息id
long messageId = SnowflakeUtil.getId();
// 入库 保存消息至消息表
ImMessage imMessage = imMessageService.saveImMessage(imApplication, imSender, toConversationId, messageId, receiveVO.getData());
ImMessage imMessage = imMessageService.saveImMessage(imApplication, imSender, sysParam.getToConversation(), receiveVO, sysParam);
// 封装响应的实体
ImMessageOnlineSend imMessageOnlineSend = new ImMessageOnlineSend();
......@@ -101,11 +101,12 @@ public class NormalChatStrategy extends AbstractImCmdStrategy {
imMessageOnlineSend.setSender(imSender.getClientId());
HashMap<String, Object> content = JsonUtils.decodeJson2Map(JsonUtils.encodeJson(receiveVO.getData()));
imMessageOnlineSend.setContent(content);
imMessageOnlineSend.setConversationId(toConversationId);
imMessageOnlineSend.setConversationId(sysParam.getToConversation());
imMessageOnlineSend.setCreateTime(imMessage.getCreateTime());
imMessageOnlineSend.setWithdrawTime(imMessage.getWithdrawTime());
imMessageOnlineSend.setWithdraw(imMessage.getWithdraw());
imMessageOnlineSend.setEvent(imMessage.getEvent());
imMessageOnlineSend.setType(sysParam.getType());
imMessageOnlineSend.setSystemFlag(imMessage.getSystemFlag());
imMessageOnlineSend.setAt(imMessage.getAt());
......@@ -113,7 +114,7 @@ public class NormalChatStrategy extends AbstractImCmdStrategy {
for (ImConversationMembers conversationMembers : membersList) {
// 入库 保存收件箱
long imInboxId = SnowflakeUtil.getId();
saveImInbox(imApplication, toConversationId, messageId, conversationMembers, imInboxId);
saveImInbox(imApplication, sysParam.getToConversation(), messageId, conversationMembers, imInboxId);
// 查询接收方
ImClient imClientReceiver = imClientService.getOne(new QueryWrapper<ImClient>().lambda()
......@@ -134,7 +135,7 @@ public class NormalChatStrategy extends AbstractImCmdStrategy {
channelSender.sendMsg(responseModel, imClientReceiver.getId());
// 异步推送系统通知消息
systemPush.push(receiveVO.getData().getPush(), imClientReceiver, imApplication);
systemPush.push(sysParam.getPushVO(), imClientReceiver, imApplication);
}
// 响应发送方消息id等信息
......@@ -142,6 +143,7 @@ public class NormalChatStrategy extends AbstractImCmdStrategy {
}
/**
* 入库 保存收件箱
*
......
core/src/main/java/com/wecloud/im/ws/strategy/concrete/ThousandChatStrategy.java
......@@ -17,6 +17,7 @@ import com.wecloud.im.ws.annotation.ImCmdType;
import com.wecloud.im.ws.enums.WsRequestCmdEnum;
import com.wecloud.im.ws.enums.WsResponseCmdEnum;
import com.wecloud.im.ws.model.WsResponse;
import com.wecloud.im.ws.model.request.ReceiveDataVO;
import com.wecloud.im.ws.model.request.ReceiveVO;
import com.wecloud.im.ws.sender.AsyncPush;
import com.wecloud.im.ws.sender.ChannelSender;
......@@ -70,21 +71,19 @@ public class ThousandChatStrategy extends AbstractImCmdStrategy {
private ThousandChatCacheManager thousandChatCacheManager;
@Override
public void process(ImApplication imApplication, ImClient imSender, ChannelHandlerContext ctx, ReceiveVO receiveVO) {
public void process(ImApplication imApplication, ImClient imSender, ChannelHandlerContext ctx, ReceiveVO receiveVO, ReceiveDataVO sysParam) {
NioSocketChannel channel = (NioSocketChannel) ctx.channel();
Long toConversationId = receiveVO.getData().getToConversation();
// 查询该会话所有成员
List<ImConversationMembers> membersList = imConversationMembersService.list(
new QueryWrapper<ImConversationMembers>().lambda()
.eq(ImConversationMembers::getFkConversationId, toConversationId)
.eq(ImConversationMembers::getFkConversationId, sysParam.getToConversation())
);
// 生成消息id
long messageId = SnowflakeUtil.getId();
// 入库 保存消息至消息表
ImMessage imMessage = imMessageService.saveImMessage(imApplication, imSender, toConversationId, messageId, receiveVO.getData());
ImMessage imMessage = imMessageService.saveImMessage(imApplication, imSender, sysParam.getToConversation(), receiveVO, sysParam);
// 封装响应的实体
ImMessageOnlineSend imMessageOnlineSend = new ImMessageOnlineSend();
......@@ -92,17 +91,18 @@ public class ThousandChatStrategy extends AbstractImCmdStrategy {
imMessageOnlineSend.setSender(imSender.getClientId());
HashMap<String, Object> content = JsonUtils.decodeJson2Map(JsonUtils.encodeJson(receiveVO.getData()));
imMessageOnlineSend.setContent(content);
imMessageOnlineSend.setConversationId(toConversationId);
imMessageOnlineSend.setConversationId(sysParam.getToConversation());
imMessageOnlineSend.setCreateTime(imMessage.getCreateTime());
imMessageOnlineSend.setWithdrawTime(imMessage.getWithdrawTime());
imMessageOnlineSend.setWithdraw(imMessage.getWithdraw());
imMessageOnlineSend.setEvent(imMessage.getEvent());
imMessageOnlineSend.setSystemFlag(imMessage.getSystemFlag());
imMessageOnlineSend.setType(sysParam.getType());
imMessageOnlineSend.setAt(imMessage.getAt());
// 在线用户直接发消息
Map<String /** ip **/, List<String /** client的主键ID:platform **/>> onlineIpClientMap =
thousandChatCacheManager.findOnlineHostsByThousandGroupId(toConversationId);
thousandChatCacheManager.findOnlineHostsByThousandGroupId(sysParam.getToConversation());
// 封装要推给接收方的消息
WsResponse<ImMessageOnlineSend> responseModel = new WsResponse<>();
responseModel.setCmd(WsResponseCmdEnum.ONLINE_MSG.getCmdCode());
......@@ -131,7 +131,7 @@ public class ThousandChatStrategy extends AbstractImCmdStrategy {
continue;
}
// 异步推送系统通知消息
systemPush.push(receiveVO.getData().getPush(), imClientReceiver, imApplication);
systemPush.push(sysParam.getPushVO(), imClientReceiver, imApplication);
}
// 响应发送方消息id等信息
......
core/src/main/resources/mapper/ImMessageMapper.xml
......@@ -5,7 +5,7 @@
<!-- 通用查询结果列 -->
<sql id="Base_Column_List">
id
, create_time, withdraw_time, update_date, fk_appid, sender, content, withdraw, event, system_flag, at, send_status, fk_conversation_id
, create_time, withdraw_time, update_date, fk_appid, sender, content, withdraw, event, msg_type, system_flag, at, send_status, fk_conversation_id
</sql>
<select id="getImMessageById" resultType="com.wecloud.im.param.ImMessageQueryVo">
......@@ -33,7 +33,10 @@
im_message.`at`,
im_message.send_status,
im_message.fk_conversation_id,
(SELECT COUNT(id) FROM im_inbox WHERE fk_msg_id = msgId AND read_msg_status = 0) AS not_read_count,
im_message.`msg_type` AS 'type', (SELECT COUNT(id)
FROM im_inbox
WHERE fk_msg_id = msgId
AND read_msg_status = 0) AS not_read_count,
(SELECT COUNT(id)
FROM im_inbox
WHERE fk_msg_id = msgId
......@@ -58,7 +61,7 @@
im_message.system_flag,
im_message.`at`,
im_message.send_status,
im_message.fk_conversation_id,
im_message.`msg_type` AS 'type', im_message.fk_conversation_id,
(SELECT COUNT(id) FROM im_inbox WHERE fk_msg_id = msgId AND read_msg_status = 0) AS not_read_count,
(SELECT COUNT(id)
FROM im_inbox
......@@ -81,7 +84,7 @@
im_message.`event`,
im_message.system_flag,
im_message.`at`,
im_message.send_status,
im_message.`msg_type` AS 'type', im_message.send_status,
im_message.fk_conversation_id
FROM im_inbox
INNER JOIN im_message ON im_message.id = im_inbox.fk_msg_id
......@@ -102,7 +105,7 @@
im_message.system_flag,
im_message.`at`,
im_message.send_status,
im_message.fk_conversation_id
im_message.`msg_type` AS 'type', im_message.fk_conversation_id
FROM im_message
INNER JOIN im_client AS im_client ON im_client.id = im_message.sender
WHERE im_message.fk_conversation_id = #{conversationId}
......
docs/db/feature-cluster增量.sql 0 → 100644
-- 在feature-cluster 2021年12月22日之后，需要执行的的sql增量脚本
-- 在feature-cluster 2021年12月22日之后，需要执行的的sql增量脚本
ALTER TABLE `im_conversation` CHANGE COLUMN `system` `system_flag` tinyint(1) NULL DEFAULT NULL COMMENT '可选 对话类型标志，是否是系统对话，后面会说明。' AFTER `attributes`;
ALTER TABLE `im_message` CHANGE COLUMN `system` `system_flag` tinyint(1) NULL DEFAULT 0 COMMENT '0非系统通知; 1为系统通知' AFTER `event`;
-- 在feature-cluster 2022年1月4日之后，需要执行的sql增量脚本
ALTER TABLE im_conversation `
ADD COLUMN ` member_count ` int NULL COMMENT '群成员数' AFTER ` last_message `,
ADD COLUMN ` chat_type ` tinyint NULL COMMENT '是否万人群' AFTER ` member_count `;
ALTER TABLE ` im_conversation_members ` ADD INDEX ` fk_client_id `(` fk_client_id `);
-- 在feature-cluster 2022年1月10日之后，需要执行的sql增量脚本
-- 消息最新已读寻址表
CREATE TABLE ` im_msg_read_lastest ` (
` id ` bigint NOT NULL COMMENT '收件id',
` create_time ` timestamp NULL DEFAULT NULL COMMENT '创建时间',
` update_time ` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
` read_time ` timestamp NULL DEFAULT NULL COMMENT '读取时间',
` receive_time ` timestamp NULL DEFAULT NULL COMMENT '接收时间',
` fk_appid ` bigint NOT NULL COMMENT '应用appid',
` fk_client_id ` bigint NOT NULL COMMENT '接收客户端id',
` fk_conversation_id ` bigint NOT NULL COMMENT '会话id',
` fk_receive_msg_id ` bigint DEFAULT NULL COMMENT '最后一条已接收的消息id',
` fk_read_msg_id ` bigint DEFAULT NULL COMMENT '最后一条已读的消息id',
PRIMARY KEY (` id `) USING BTREE,
UNIQUE KEY ` receiver_conversation ` (` fk_client_id `,` fk_conversation_id `) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='消息最新已读寻址表';
CREATE TABLE ` im_friend ` (
` id ` bigint NOT NULL COMMENT '主键id',
` fk_client_id ` bigint NOT NULL COMMENT '自己id',
` fk_client_id_friend ` bigint NOT NULL COMMENT '好友id',
` fk_client_id_claimer ` bigint NOT NULL COMMENT '好友申请者',
` friend_name ` varchar(255) DEFAULT NULL COMMENT '好友名称备注',
` reject_remark ` varchar(255) DEFAULT NULL COMMENT '拒绝说明',
` request_remark ` varchar(255) DEFAULT NULL COMMENT '好友请求说明',
` state ` tinyint NOT NULL DEFAULT '0' COMMENT '好友状态，1：待确定，2：已确认，3：已拒绝，4：已删除',
` create_time ` timestamp NULL DEFAULT NULL COMMENT '创建时间',
` update_time ` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
PRIMARY KEY (` id `) USING BTREE,
UNIQUE KEY ` friend_id ` (` fk_client_id `,` fk_client_id_friend `) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='好友表';
CREATE TABLE ` im_friend_recommend ` (
` id ` bigint(20) NOT NULL COMMENT '主键id',
` fk_client_id ` bigint(20) NOT NULL COMMENT '自己id',
` fk_client_id_friend ` bigint(20) NOT NULL COMMENT '好友id',
` source ` tinyint DEFAULT NULL COMMENT '推荐来源',
` del_flag ` bit(1) NOT NULL default 0 COMMENT '删除标识',
` create_time ` timestamp NULL DEFAULT NULL COMMENT '创建时间',
` update_time ` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
PRIMARY KEY (` id `) USING BTREE,
UNIQUE KEY ` friend_id ` (fk_client_id, fk_client_id_friend) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='好友表';
-- 2022年01月21日17:31:16 何威 将type参数上移一层
ALTER TABLE ` im_message `
ADD COLUMN ` msg_type ` int(2) NULL DEFAULT NULL COMMENT '消息类型' AFTER ` send_status `;
\ No newline at end of file
docs/db/wecloud_im.sql
......@@ -213,57 +213,3 @@ CREATE TABLE `im_rtc_log`
SET
FOREIGN_KEY_CHECKS = 1;
-- 在feature-cluster 2021年12月22日之后，需要执行的的sql增量脚本
ALTER TABLE `im_conversation` CHANGE COLUMN `system` `system_flag` tinyint(1) NULL DEFAULT NULL COMMENT '可选 对话类型标志，是否是系统对话，后面会说明。' AFTER `attributes`;
ALTER TABLE `im_message` CHANGE COLUMN `system` `system_flag` tinyint(1) NULL DEFAULT 0 COMMENT '0非系统通知; 1为系统通知' AFTER `event`;
-- 在feature-cluster 2022年1月4日之后，需要执行的sql增量脚本
ALTER TABLE im_conversation`
ADD COLUMN `member_count` int NULL COMMENT '群成员数' AFTER `last_message`,
ADD COLUMN `chat_type` tinyint NULL COMMENT '是否万人群' AFTER `member_count`;
ALTER TABLE `im_conversation_members` ADD INDEX `fk_client_id`(`fk_client_id`);
-- 在feature-cluster 2022年1月10日之后，需要执行的sql增量脚本
-- 消息最新已读寻址表
CREATE TABLE `im_msg_read_lastest` (
`id` bigint NOT NULL COMMENT '收件id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`read_time` timestamp NULL DEFAULT NULL COMMENT '读取时间',
`receive_time` timestamp NULL DEFAULT NULL COMMENT '接收时间',
`fk_appid` bigint NOT NULL COMMENT '应用appid',
`fk_client_id` bigint NOT NULL COMMENT '接收客户端id',
`fk_conversation_id` bigint NOT NULL COMMENT '会话id',
`fk_receive_msg_id` bigint DEFAULT NULL COMMENT '最后一条已接收的消息id',
`fk_read_msg_id` bigint DEFAULT NULL COMMENT '最后一条已读的消息id',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE KEY `receiver_conversation` (`fk_client_id`,`fk_conversation_id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='消息最新已读寻址表';
CREATE TABLE `im_friend` (
`id` bigint NOT NULL COMMENT '主键id',
`fk_client_id` bigint NOT NULL COMMENT '自己id',
`fk_client_id_friend` bigint NOT NULL COMMENT '好友id',
`fk_client_id_claimer` bigint NOT NULL COMMENT '好友申请者',
`friend_name` varchar(255) DEFAULT NULL COMMENT '好友名称备注',
`reject_remark` varchar(255) DEFAULT NULL COMMENT '拒绝说明',
`request_remark` varchar(255) DEFAULT NULL COMMENT '好友请求说明',
`state` tinyint NOT NULL DEFAULT '0' COMMENT '好友状态，1：待确定，2：已确认，3：已拒绝，4：已删除',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE KEY `friend_id` (`fk_client_id`,`fk_client_id_friend`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='好友表';
CREATE TABLE `im_friend_recommend` (
`id` bigint(20) NOT NULL COMMENT '主键id',
`fk_client_id` bigint(20) NOT NULL COMMENT '自己id',
`fk_client_id_friend` bigint(20) NOT NULL COMMENT '好友id',
`source` tinyint DEFAULT NULL COMMENT '推荐来源',
`del_flag` bit(1) NOT NULL default 0 COMMENT '删除标识',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE KEY `friend_id` (fk_client_id, fk_client_id_friend) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='好友表';
docs/db/wecloud_im_v1_4全量.sql 0 → 100644
/*
/*
Navicat Premium Data Transfer
Source Server : localhost
Source Server Type : MySQL
Source Server Version : 50730
Source Host : localhost:3306
Source Schema : wecloud_im_v1_4
Target Server Type : MySQL
Target Server Version : 50730
File Encoding : 65001
Date: 21/01/2022 17:32:02
*/
SET NAMES utf8mb4;
SET
FOREIGN_KEY_CHECKS = 0;
-- ----------------------------
-- Table structure for im_application
-- ----------------------------
DROP TABLE IF EXISTS `im_application`;
CREATE TABLE `im_application`
(
`id` bigint(20) NOT NULL COMMENT '应用appid',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`app_key` varchar(200) CHARACTER SET latin1 DEFAULT NULL COMMENT 'key',
`app_secret` varchar(500) CHARACTER SET latin1 DEFAULT NULL COMMENT '密钥',
`app_name` varchar(200) DEFAULT NULL COMMENT 'app名称',
`ios_push_channel` int(255) DEFAULT NULL COMMENT 'ios推送通道,友盟:1;firebase:2; apns原生:3',
`android_push_channel` int(255) DEFAULT NULL COMMENT '安卓推送通道,友盟:1;firebase:2; 信鸽3',
`umeng_key` varchar(500) DEFAULT NULL COMMENT '友盟推送key',
`umeng_secret` varchar(500) DEFAULT NULL COMMENT '友盟推送密钥',
`firebase_secret` varchar(500) DEFAULT NULL COMMENT 'firebase推送密钥',
`repeat_session_status` int(1) DEFAULT '0' COMMENT '是否允许创建重复会话 0不允许 1允许',
`contrast_extended_field_status` int(1) DEFAULT '0' COMMENT '创建会话时对比扩展字段 0不 1是',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE KEY `app_key` (`app_key`) USING HASH
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='第三方应用表';
-- ----------------------------
-- Table structure for im_client
-- ----------------------------
DROP TABLE IF EXISTS `im_client`;
CREATE TABLE `im_client`
(
`id` bigint(20) NOT NULL COMMENT '客户端id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`last_offline_time` timestamp NULL DEFAULT NULL COMMENT '最后离线时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`fk_appid` bigint(20) DEFAULT NULL COMMENT '应用appid',
`attributes` json DEFAULT NULL COMMENT '可选 自定义属性，供开发者扩展使用',
`client_id` varchar(200) DEFAULT NULL COMMENT '客户方提供的唯一id',
`valid` int(1) DEFAULT NULL COMMENT '设备不想收到推送提醒',
`device_type` int(1) DEFAULT NULL COMMENT '设备类型1:ios; 2:android',
`device_token` varchar(300) DEFAULT NULL COMMENT '设备推送token',
`head_portrait` varchar(1000) DEFAULT NULL COMMENT '头像',
`nickname` varchar(30) DEFAULT NULL COMMENT '主昵称',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE KEY ```fk_appid``, ``client_id``` (`fk_appid`,`client_id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='终端表';
-- ----------------------------
-- Table structure for im_client_blacklist
-- ----------------------------
DROP TABLE IF EXISTS `im_client_blacklist`;
CREATE TABLE `im_client_blacklist`
(
`id` bigint(20) NOT NULL COMMENT '客户端id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`fk_appid` bigint(20) DEFAULT NULL COMMENT '应用appid',
`fk_client_id_prevent` bigint(20) DEFAULT NULL COMMENT '拉黑者',
`fk_client_id_be_prevent` bigint(20) DEFAULT NULL COMMENT '被拉黑',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='黑名单';
-- ----------------------------
-- Table structure for im_conversation
-- ----------------------------
DROP TABLE IF EXISTS `im_conversation`;
CREATE TABLE `im_conversation`
(
`id` bigint(20) NOT NULL COMMENT '会话id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`last_message` timestamp NULL DEFAULT NULL COMMENT '对话中最后一条消息的发送或接收时间',
`fk_appid` bigint(20) NOT NULL COMMENT '应用appid',
`creator` bigint(20) NOT NULL COMMENT '创建者客户端id',
`name` varchar(255) DEFAULT NULL COMMENT '可选 对话的名字，可为群组命名。',
`attributes` json DEFAULT NULL COMMENT '可选 自定义属性，供开发者扩展使用。',
`system` tinyint(1) DEFAULT NULL COMMENT '可选 对话类型标志，是否是系统对话，后面会说明。',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='会话表';
-- ----------------------------
-- Table structure for im_conversation_members
-- ----------------------------
DROP TABLE IF EXISTS `im_conversation_members`;
CREATE TABLE `im_conversation_members`
(
`id` bigint(20) NOT NULL COMMENT '唯一id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '加入时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`fk_appid` bigint(20) NOT NULL COMMENT '应用appid',
`fk_conversation_id` bigint(20) NOT NULL COMMENT '会话表id',
`fk_client_id` bigint(20) NOT NULL COMMENT '客户端id',
`display_status` int(2) DEFAULT '1' COMMENT '单向删除(隐藏)会话, 0不显示, 1显示',
`allow_system_push_status` int(2) DEFAULT '1' COMMENT '是否允许系统推送, 0不推送, 1推送',
`attributes` json DEFAULT NULL COMMENT '可选 自定义属性，供开发者扩展使用',
`client_remark_name` varchar(255) DEFAULT NULL COMMENT '会话中client的备注名',
PRIMARY KEY (`id`) USING BTREE,
KEY `fk_conversation_id` (`fk_conversation_id`) USING HASH
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='会话成员表';
-- ----------------------------
-- Table structure for im_inbox
-- ----------------------------
DROP TABLE IF EXISTS `im_inbox`;
CREATE TABLE `im_inbox`
(
`id` bigint(20) NOT NULL COMMENT '收件id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`read_time` timestamp NULL DEFAULT NULL COMMENT '读取时间',
`receiver_time` timestamp NULL DEFAULT NULL COMMENT '接收时间',
`fk_appid` bigint(20) NOT NULL COMMENT '应用appid',
`receiver` bigint(20) NOT NULL COMMENT '接收客户端id',
`fk_msg_id` bigint(20) NOT NULL COMMENT '消息id',
`read_msg_status` int(1) DEFAULT NULL COMMENT '0未读; 1已读',
`receiver_msg_status` int(1) DEFAULT NULL COMMENT '0未接收; 1已接收',
`fk_conversation_id` bigint(20) NOT NULL COMMENT '会话id',
PRIMARY KEY (`id`) USING BTREE,
KEY `getMyOfflineMsg` (`receiver`) USING HASH
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='消息收件箱表';
-- ----------------------------
-- Table structure for im_ios_apns
-- ----------------------------
DROP TABLE IF EXISTS `im_ios_apns`;
CREATE TABLE `im_ios_apns`
(
`id` bigint(20) NOT NULL COMMENT 'id',
`fk_app_id` bigint(20) NOT NULL COMMENT '应用appid',
`apns_file_value` text CHARACTER SET latin1 COMMENT 'Base64(apns.p12)',
`env` int(255) DEFAULT NULL COMMENT '环境,正式1,测试0',
`bundle_id` varchar(500) DEFAULT NULL COMMENT 'bundle_id',
`pwd` varchar(500) DEFAULT NULL COMMENT '证书密码',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='apns配置表';
-- ----------------------------
-- Table structure for im_message
-- ----------------------------
DROP TABLE IF EXISTS `im_message`;
CREATE TABLE `im_message`
(
`id` bigint(20) NOT NULL COMMENT '消息id',
`fk_conversation_id` bigint(20) DEFAULT NULL COMMENT '会话id',
`fk_appid` bigint(20) NOT NULL COMMENT '应用appid',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`withdraw_time` timestamp NULL DEFAULT NULL COMMENT '撤回时间',
`update_date` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`sender` bigint(20) DEFAULT NULL COMMENT '发送者客户端id',
`content` json DEFAULT NULL COMMENT '内容',
`withdraw` tinyint(1) DEFAULT '0' COMMENT '0未撤回; 1已撤回',
`event` tinyint(1) DEFAULT '0' COMMENT '0非事件; 1为事件',
`system` tinyint(1) DEFAULT '0' COMMENT '0非系统通知; 1为系统通知',
`at` text COMMENT 'at他人,传入客户端id数组',
`send_status` int(2) DEFAULT NULL COMMENT '发送状态\n1AVIMMessageStatusSending（发送中）\n2AVIMMessageStatusSent（发送成功）\n3AVIMMessageStatusFailed（失败）',
PRIMARY KEY (`id`) USING BTREE,
KEY ```fk_conversation_id``` (`fk_conversation_id`) USING HASH
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='消息存储表';
-- ----------------------------
-- Table structure for im_rtc_channel
-- ----------------------------
DROP TABLE IF EXISTS `im_rtc_channel`;
CREATE TABLE `im_rtc_channel`
(
`id` bigint(20) NOT NULL COMMENT '会话id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`fk_appid` bigint(20) NOT NULL COMMENT '外键 应用appid',
`fk_conversation` bigint(20) DEFAULT NULL COMMENT '外键 会话id 可为空',
`name` varchar(255) DEFAULT NULL COMMENT '可选 对话的名字，可为群组命名。',
`attributes` json DEFAULT NULL COMMENT '可选 自定义属性，供开发者扩展使用。',
`channel_status` int(1) DEFAULT NULL COMMENT '频道状态, 1打开 , 0关闭',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='Rtc频道表';
-- ----------------------------
-- Table structure for im_rtc_log
-- ----------------------------
DROP TABLE IF EXISTS `im_rtc_log`;
CREATE TABLE `im_rtc_log`
(
`id` bigint(20) NOT NULL COMMENT 'rtc记录id',
`fk_appid` bigint(20) NOT NULL COMMENT '应用appid',
`fk_channel_id` bigint(20) DEFAULT NULL COMMENT '频道id',
`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',
`update_date` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
`fk_conversation` bigint(20) DEFAULT NULL COMMENT '外键 会话id 可为空',
`client_id` bigint(20) DEFAULT NULL COMMENT '事件主体客户端id',
`event_type` int(1) DEFAULT NULL COMMENT '事件类型 1成为房主, 2加入频道,3退出频道,4拒绝邀请 ,5上传sdp, 6上传candidate',
`remark` text COMMENT '备注',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='RTC日志记录表';
SET
FOREIGN_KEY_CHECKS = 1;
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment