diff --git a/business/model/const.go b/business/model/const.go index 2df65c8fc..10d67e486 100644 --- a/business/model/const.go +++ b/business/model/const.go @@ -526,6 +526,11 @@ func IsPrinterVendorExist(vendorID int) bool { return ok && vendorID >= VendorIDPrinterBegin && vendorID <= VendorIDPrinterEnd } +func IsImVendorExist(vendorID int) bool { + _, ok := VendorNames[vendorID] + return ok && vendorID >= VendorIDPurchaseBegin && vendorID <= VendorIDPurchaseEnd +} + func IsOrderLockStatus(status int) bool { return status == OrderStatusLocked || status == OrderStatusApplyCancel } diff --git a/business/partner/im/im.go b/business/partner/im/im.go index d91943322..2baa62a17 100644 --- a/business/partner/im/im.go +++ b/business/partner/im/im.go @@ -69,6 +69,10 @@ func ReadMsgFromClient(vendorID int, elmAppID string, msg interface{}) error { UserID: utils.Int2Str(pushContent.OpenUserID), LatestMsg: pushContent.MsgContent, LatestTime: pushContent.Cts, + OrderID: "", + } + if pushContent.OrderID != 0 { + userList.OrderID = utils.Int2Str(pushContent.OrderID) } } if vendorID == VendorIDELM { @@ -127,8 +131,12 @@ func ReadMsgFromVendor(vendorID int, elmAppID string, msg []byte) error { UserID: utils.Int2Str(PushContentReq.OpenUserID), LatestMsg: PushContentReq.MsgContent, LatestTime: PushContentReq.Cts, + OrderID: "", } vendorStoreID = PushContentReq.AppPoiCode + if PushContentReq.OrderID != 0 { + userList.OrderID = utils.Int2Str(PushContentReq.OrderID) + } } if vendorID == VendorIDELM { var ElmData = ebaiapi.ImMessageSend{} diff --git a/business/partner/im/im_model.go b/business/partner/im/im_model.go index f5c9d193c..85acade5f 100644 --- a/business/partner/im/im_model.go +++ b/business/partner/im/im_model.go @@ -22,6 +22,7 @@ type JXMsg struct { type UserMessageList struct { VendorID int `json:"vendorID"` //平台品牌 1-美团 3-饿了么 UserID string `json:"userID"` //用户ID + OrderID string `json:"orderID"` //已下单才有 NewMessageNum int `json:"NewMessageNum"` //新消息数量 LatestMsg string `json:"latestMsg"` //最新一条消息 LatestTime int `json:"latestTime"` //最新一条消息发送时间 diff --git a/business/partner/partner_im.go b/business/partner/partner_im.go new file mode 100644 index 000000000..2ae3c7c6d --- /dev/null +++ b/business/partner/partner_im.go @@ -0,0 +1,35 @@ +package partner + +// +//import ( +// "fmt" +// +// "git.rosy.net.cn/jx-callback/business/model" +//) +// +//type IImHandler interface { +// GetVendorID() int +//} +// +//var ( +// ImPlatformHandlers map[int]IImHandler +//) +// +//func init() { +// ImPlatformHandlers = make(map[int]IImHandler) +//} +// +//func RegisterImPlatform(handler IImHandler) { +// vendorID := handler.GetVendorID() +// if !(model.IsImVendorExist(vendorID)) { +// panic(fmt.Sprintf("Im vendor:%d is illegal", vendorID)) +// } +// if _, ok := ImPlatformHandlers[vendorID]; ok { +// panic(fmt.Sprintf("Im vendor:%d, already exists", vendorID)) +// } +// ImPlatformHandlers[vendorID] = handler +//} +// +//func GetImPlatformFromVendorID(vendorID int) IImHandler { +// return ImPlatformHandlers[vendorID] +//}