update meta自定义信息
This commit is contained in:
@@ -179,6 +179,8 @@ public class WeworkMessageBean {
|
||||
|
||||
//消息id(解析指令时同步)
|
||||
public String messageId;
|
||||
//meta自定义信息(解析指令时同步)
|
||||
public String meta;
|
||||
//api类型(解析指令时同步) 0=后台消息 1=API指令调用
|
||||
public Integer apiSend;
|
||||
|
||||
|
||||
@@ -28,6 +28,8 @@ class WeworkMessageListBean<T> {
|
||||
//消息id
|
||||
var messageId = TimeUtils.date2String(Date()).replace(" ", "#") + "#" + UUID.randomUUID()
|
||||
|
||||
var meta: String? = null
|
||||
|
||||
//api类型 0=后台消息 1=API指令调用
|
||||
var apiSend: Int? = null
|
||||
|
||||
@@ -40,7 +42,7 @@ class WeworkMessageListBean<T> {
|
||||
//消息加密 0不加密 1AES
|
||||
var encryptType = Constant.encryptType
|
||||
|
||||
constructor(weworkMessageBean: T, type: Int, messageId: String? = null) {
|
||||
constructor(weworkMessageBean: T, type: Int, messageId: String? = null, meta: String? = null) {
|
||||
if (encryptType == 0) {
|
||||
list.add(weworkMessageBean)
|
||||
} else if (encryptType == 1) {
|
||||
@@ -53,6 +55,7 @@ class WeworkMessageListBean<T> {
|
||||
}
|
||||
this.socketType = type
|
||||
if (messageId != null) this.messageId = messageId
|
||||
if (meta != null) this.meta = meta
|
||||
}
|
||||
|
||||
constructor(messageId: String, type: Int) {
|
||||
|
||||
@@ -230,7 +230,8 @@ fun uploadCommandResult(message: WeworkMessageBean, errorCode: Int, errorReason:
|
||||
WeworkMessageListBean(
|
||||
ExecCallbackBean(GsonUtils.toJson(message), errorCode, errorReason, startTime, (System.currentTimeMillis() - startTime) / 1000.0, successList, failList),
|
||||
WeworkMessageListBean.SOCKET_TYPE_RAW_CONFIRM,
|
||||
messageId = message.messageId
|
||||
messageId = message.messageId,
|
||||
meta = message.meta
|
||||
), true
|
||||
)
|
||||
if (errorCode != 0) {
|
||||
|
||||
@@ -119,6 +119,7 @@ object MyLooper {
|
||||
what = messageWhat
|
||||
obj = message.apply {
|
||||
messageId = messageList.messageId
|
||||
meta = messageList.meta
|
||||
apiSend = messageList.apiSend
|
||||
}
|
||||
})
|
||||
|
||||
@@ -1093,6 +1093,7 @@ object WeworkOperationImpl {
|
||||
for (weworkMessage in weworkMessageList) {
|
||||
weworkMessage.titleList = message.titleList
|
||||
weworkMessage.messageId = message.messageId
|
||||
weworkMessage.meta = message.meta
|
||||
when (weworkMessage.type) {
|
||||
WeworkMessageBean.SEND_MESSAGE -> {
|
||||
WeworkController.sendMessage(weworkMessage)
|
||||
@@ -1138,6 +1139,7 @@ object WeworkOperationImpl {
|
||||
for (weworkMessage in weworkMessageList) {
|
||||
weworkMessage.titleList = titleList
|
||||
weworkMessage.messageId = message.messageId
|
||||
weworkMessage.meta = message.meta
|
||||
when (weworkMessage.type) {
|
||||
WeworkMessageBean.SEND_MESSAGE -> {
|
||||
WeworkController.sendMessage(weworkMessage)
|
||||
|
||||
@@ -53,7 +53,7 @@ public class WebSocketManager {
|
||||
}
|
||||
|
||||
public void send(WeworkMessageBean msg) {
|
||||
send(new WeworkMessageListBean(msg, WeworkMessageListBean.SOCKET_TYPE_MESSAGE_LIST, null));
|
||||
send(new WeworkMessageListBean(msg, WeworkMessageListBean.SOCKET_TYPE_MESSAGE_LIST, null, null));
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user