fix: 优化注册聊天用户逻辑

This commit is contained in:
徐俊杰 2025-06-13 10:44:25 +08:00
parent af0fefc3bd
commit a92cca188d
2 changed files with 12 additions and 4 deletions

View File

@ -9,6 +9,7 @@ package ws
import ( import (
"context" "context"
"encoding/json" "encoding/json"
"fmt"
"fonchain-fiee/api/account" "fonchain-fiee/api/account"
"fonchain-fiee/api/accountFiee" "fonchain-fiee/api/accountFiee"
"fonchain-fiee/pkg/config" "fonchain-fiee/pkg/config"
@ -47,7 +48,7 @@ func AuthorizationVerify(sourceData []byte) (userInfo *accountFiee.ChatUserData,
accountInfo.OriginId = int64(fieeJwtInfo.ID) accountInfo.OriginId = int64(fieeJwtInfo.ID)
accountInfo.Account = fieeJwtInfo.Account accountInfo.Account = fieeJwtInfo.Account
accountInfo.NickName = fieeJwtInfo.NickName accountInfo.NickName = fieeJwtInfo.NickName
case "fontree": case e.ErpDomain:
//erp token校验 //erp token校验
msg.Content.Auth, err = secret.GetJwtFromStr(msg.Content.Auth) msg.Content.Auth, err = secret.GetJwtFromStr(msg.Content.Auth)
if err != nil { if err != nil {
@ -75,19 +76,25 @@ func AuthorizationVerify(sourceData []byte) (userInfo *accountFiee.ChatUserData,
if err != nil || chatUserQuery.Total == 0 { if err != nil || chatUserQuery.Total == 0 {
//注册客服 //注册客服
var createUserRes *accountFiee.CreateChatUserResp var createUserRes *accountFiee.CreateChatUserResp
createUserRes, err = service.AccountFieeProvider.CreateChatUser(ctx, &accountFiee.ChatUserData{ var createChatUserReq = &accountFiee.ChatUserData{
NickName: accountInfo.NickName, NickName: accountInfo.NickName,
Account: accountInfo.Account, Account: accountInfo.Account,
Role: 2, Role: 1,
Origin: msg.Content.Domain, Origin: msg.Content.Domain,
OriginId: int64(accountInfo.ID), OriginId: int64(accountInfo.ID),
}) }
if msg.Content.Domain == e.ErpDomain {
createChatUserReq.Role = 2
}
fmt.Printf("注册聊天用户:%#v\n", createChatUserReq)
createUserRes, err = service.AccountFieeProvider.CreateChatUser(ctx, createChatUserReq)
if err != nil { if err != nil {
return return
} }
userInfo = createUserRes.GetData() userInfo = createUserRes.GetData()
} else { } else {
userInfo = chatUserQuery.List[0] userInfo = chatUserQuery.List[0]
fmt.Printf("获取聊天用户:%#v\n", userInfo)
} }
ok = true ok = true
return return

View File

@ -13,6 +13,7 @@ const (
const ( const (
DomainAdmin = "blockchain" DomainAdmin = "blockchain"
ErpDomain = "fontree"
) )
const ( const (