This commit is contained in:
richboo111
2023-09-26 11:19:32 +08:00
parent 5f8c6380c8
commit 75260a3879

View File

@@ -8,7 +8,7 @@ import (
"strings"
"time"
"git.rosy.net.cn/jx-callback/business/partner/purchase/mtwm"
"git.rosy.net.cn/jx-callback/globals/api"
"git.rosy.net.cn/jx-callback/business/model"
@@ -28,7 +28,8 @@ func SendVendorV2(data SendData, vendorOrgCode string) (err error) {
dataStr, _ := json.Marshal(data.Data)
temp := string(dataStr)
globals.SugarLogger.Debugf("SendVendorV2 temp=%s", temp)
if err = mtwm.MsgSend(vendorOrgCode, string(dataStr)); err != nil {
if _, err = api.MtwmAPI.MsgSend(string(dataStr)); err != nil {
//if err = mtwm.MsgSend(vendorOrgCode, string(dataStr)); err != nil {
return err
}
}
@@ -43,15 +44,16 @@ func SendVendorV2(data SendData, vendorOrgCode string) (err error) {
}
// GetPoiIMStatus 查询门店IM单聊开关状态
func GetPoiIMStatus(vendorID int, vendorStoreID, vendorOrgCode string) (retVal interface{}, err error) {
switch vendorID {
case model.VendorIDMTWM:
retVal, err = mtwm.GetPoiIMStatus(vendorStoreID, vendorOrgCode)
case model.VendorIDEBAI:
//retVal,err=
}
return nil, nil
}
//func GetPoiIMStatus(vendorID int, vendorStoreID, vendorOrgCode string) (retVal interface{}, err error) {
// switch vendorID {
// case model.VendorIDMTWM:
// //retVal, err = mtwm.GetPoiIMStatus(vendorStoreID, vendorOrgCode)
// retVal, err = api.MtwmAPI.GetPoiIMStatus(vendorStoreID, vendorOrgCode)
// case model.VendorIDEBAI:
// //retVal,err=
// }
// return nil, nil
//}
// ReadMsgFromClient 存储客户端发送的消息
func ReadMsgFromClient(vendorID int, elmAppID string, msg interface{}) error {