liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
richboo111
2024-01-24 18:07:37 +08:00
parent ff551904e0
commit 15462347cf
1 changed files with 22 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
business/partner/im/im.go
View File

@@ -528,7 +528,7 @@ func CheckAndReply(req *JXMsg, elmAppID string) (err error) {
errList errlist.ErrList errList errlist.ErrList
apply *AutoReply apply *AutoReply
jxMsg = &JXMsg{} jxMsg = &JXMsg{}
userList = &UserMessageList{} //userList = &UserMessageList{}
) )
if req.SendType == SendTypeMt { if req.SendType == SendTypeMt {
vendorID = VendorIDMT vendorID = VendorIDMT
@@ -568,22 +568,22 @@ func CheckAndReply(req *JXMsg, elmAppID string) (err error) {
SendType: SendTypeJx, SendType: SendTypeJx,
MsgContent: temp, MsgContent: temp,
} }
userList = &UserMessageList{ //userList = &UserMessageList{
VendorID: VendorIDMT, // VendorID: VendorIDMT,
UserID: utils.Int2Str(mt.OpenUserID), // UserID: utils.Int2Str(mt.OpenUserID),
LatestMsg: mt.MsgContent, // LatestMsg: mt.MsgContent,
LatestTime: mt.Cts, // LatestTime: mt.Cts,
OrderID: "", // OrderID: "",
} //}
//1 存储详细聊天记录list //1 存储详细聊天记录
if err = SetMessageDetail(jxMsg, vendorID, elmAppID); err != nil { if err = SetMessageDetail(jxMsg, vendorID, elmAppID); err != nil {
errList.AddErr(fmt.Errorf("自动回复：存储详细聊天记录错误：%v", err)) errList.AddErr(fmt.Errorf("自动回复：存储详细聊天记录错误：%v", err))
} }
//2 存储展示列表时单条数据 //2 存储展示列表时单条数据
if err = SetUserList(jxMsg, userList, vendorID, elmAppID); err != nil { //if err = SetUserList(jxMsg, userList, vendorID, elmAppID); err != nil {
errList.AddErr(fmt.Errorf("自动回复：存储STU聊天记录错误：%v", err)) // errList.AddErr(fmt.Errorf("自动回复：存储STU聊天记录错误：%v", err))
} //}
} }
//3 记录自动回复状态 //3 记录自动回复状态
if err = RecordAutoStatus(key, apply); err != nil { if err = RecordAutoStatus(key, apply); err != nil {
@@ -646,21 +646,21 @@ func CheckAndReply(req *JXMsg, elmAppID string) (err error) {
SendType: SendTypeJx, SendType: SendTypeJx,
MsgContent: param, MsgContent: param,
} }
userList = &UserMessageList{ //userList = &UserMessageList{
VendorID: VendorIDELM, // VendorID: VendorIDELM,
UserID: elm.PayLoad.SenderID, // UserID: elm.PayLoad.SenderID,
LatestMsg: elm.PayLoad.Content, // LatestMsg: elm.PayLoad.Content,
LatestTime: elm.PayLoad.CreateTime, // LatestTime: elm.PayLoad.CreateTime,
OrderID: "", // OrderID: "",
} //}
//1 存储详细聊天记录list //1 存储详细聊天记录list
if err = SetMessageDetail(jxMsg, vendorID, elmAppID); err != nil { if err = SetMessageDetail(jxMsg, vendorID, elmAppID); err != nil {
errList.AddErr(fmt.Errorf("自动回复：存储详细聊天记录错误：%v", err)) errList.AddErr(fmt.Errorf("自动回复：存储详细聊天记录错误：%v", err))
} }
//2 存储展示列表时单条数据 //2 存储展示列表时单条数据
if err = SetUserList(jxMsg, userList, vendorID, elmAppID); err != nil { //if err = SetUserList(jxMsg, userList, vendorID, elmAppID); err != nil {
errList.AddErr(fmt.Errorf("自动回复：存储STU聊天记录错误：%v", err)) // errList.AddErr(fmt.Errorf("自动回复：存储STU聊天记录错误：%v", err))
} //}
} }
//3 记录自动回复状态 //3 记录自动回复状态
if err = RecordAutoStatus(key, apply); err != nil { if err = RecordAutoStatus(key, apply); err != nil {
@@ -669,24 +669,6 @@ func CheckAndReply(req *JXMsg, elmAppID string) (err error) {
} }
} }
//if jxMsg != nil {
// //1 存储详细聊天记录list
// if err = SetMessageDetail(jxMsg, vendorID, elmAppID); err != nil {
// errList.AddErr(fmt.Errorf("自动回复：存储详细聊天记录错误：%v", err))
// }
// //2 存储展示列表时单条数据
// if err = SetUserList(jxMsg, userList, vendorID, elmAppID); err != nil {
// errList.AddErr(fmt.Errorf("自动回复：存储STU聊天记录错误：%v", err))
// }
//}
//
//if apply != nil {
// //3 记录自动回复状态
// if err = RecordAutoStatus(key, apply); err != nil {
// errList.AddErr(fmt.Errorf("自动回复：记录自动回复状态错误：%v", err))
// }
//}
if errList.GetErrListAsOne() != nil { if errList.GetErrListAsOne() != nil {
return fmt.Errorf("CheckAndReply err=%v", errList.GetErrListAsOne()) return fmt.Errorf("CheckAndReply err=%v", errList.GetErrListAsOne())
} }