1
This commit is contained in:
@@ -239,7 +239,7 @@ func ReadMsgFromVendor(vendorID int, elmAppID string, msg []byte) {
|
|||||||
}
|
}
|
||||||
var (
|
var (
|
||||||
err error
|
err error
|
||||||
vendorStoreID string
|
//vendorStoreID string
|
||||||
jxMsg = &JXMsg{}
|
jxMsg = &JXMsg{}
|
||||||
userList = &UserMessageList{}
|
userList = &UserMessageList{}
|
||||||
)
|
)
|
||||||
@@ -256,7 +256,7 @@ func ReadMsgFromVendor(vendorID int, elmAppID string, msg []byte) {
|
|||||||
LatestMsg: MtSingleChat.MsgContent,
|
LatestMsg: MtSingleChat.MsgContent,
|
||||||
LatestTime: MtSingleChat.Cts,
|
LatestTime: MtSingleChat.Cts,
|
||||||
}
|
}
|
||||||
vendorStoreID = MtSingleChat.AppPoiCode
|
//vendorStoreID = MtSingleChat.AppPoiCode
|
||||||
}
|
}
|
||||||
if vendorID == VendorIDELM {
|
if vendorID == VendorIDELM {
|
||||||
var ElmData = ebaiapi.ImMessageSend{}
|
var ElmData = ebaiapi.ImMessageSend{}
|
||||||
@@ -284,7 +284,7 @@ func ReadMsgFromVendor(vendorID int, elmAppID string, msg []byte) {
|
|||||||
//return
|
//return
|
||||||
}
|
}
|
||||||
//3 cid推送新消息
|
//3 cid推送新消息
|
||||||
err = PushMsgByCid(vendorStoreID, vendorID)
|
//err = PushMsgByCid(vendorStoreID, vendorID)
|
||||||
//4 长链接通知给客户端
|
//4 长链接通知给客户端
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ToClientChan <- clientInfo{Code: SuccessCode, Msg: fmt.Sprintf("%v", err), Data: jxMsg}
|
ToClientChan <- clientInfo{Code: SuccessCode, Msg: fmt.Sprintf("%v", err), Data: jxMsg}
|
||||||
|
|||||||
Reference in New Issue
Block a user