Compare commits

..

No commits in common. "b244f85a57c54097775ed99f2dfec93ecc84b27b" and "f41697bcf0004ea3a43fdd229b7c3fbbb795bbd7" have entirely different histories.

8 changed files with 2176 additions and 2209 deletions

22
.vscode/launch.json vendored
View File

@ -1,22 +0,0 @@
{
// 使 IntelliSense
//
// 访: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0",
"configurations": [
{
"name": "Launch file",
"type": "go",
"request": "launch",
"mode": "auto",
"env": {
"GOPATH":"C:\\Users\\lenovo\\go",// go env GOPATH
"GOOS":"windows" //
},
"cwd": "${workspaceFolder}\\cmd",//
"program": "${workspaceFolder}\\cmd\\app.go", //"${workspaceFolder}\\cmd\\app.go"
"args":[],// ["-env" , 'prod']
// "console": "integratedTerminal" //使fmt.Scanf
}
]
}

File diff suppressed because it is too large Load Diff

View File

@ -17,7 +17,7 @@
syntax = "proto3";
package accountFiee;
import "github.com/mwitkow/go-proto-validators/validator.proto";
import "github.com/mwitkow/go-proto-validators@v0.3.2/validator.proto";
option go_package = "./;accountFiee";
//protoc -I . -I C:\Users\lenovo\go\src --go_out=. --go-triple_out=. ./accountFiee.proto
@ -988,8 +988,8 @@ message ChatAutoReplyRulerData{
int64 deletedAt = 4; //
string title = 5; //
string ruler = 6; //
int32 status = 7; //: 1= 2=
string response =8; //
int32 rulerStatus = 7; //: 1= 2=
}
message CreateChatAutoReplyRulerResp{

View File

@ -1,8 +1,8 @@
// Code generated by protoc-gen-go-triple. DO NOT EDIT.
// versions:
// - protoc-gen-go-triple v1.0.8
// - protoc v4.22.0--rc2
// source: accountFiee.proto
// - protoc v4.24.0--rc1
// source: api/accountFiee/accountFiee.proto
package accountFiee
@ -35,7 +35,7 @@ type AccountFieeClient interface {
OnlineLog(ctx context.Context, in *LoginInfosByUserIdRequest, opts ...grpc_go.CallOption) (*LoginLogsResponse, common.ErrorWithAttachment)
OnlineLogById(ctx context.Context, in *OnlineLogByIdRequest, opts ...grpc_go.CallOption) (*LoginLog, common.ErrorWithAttachment)
CheckPwd(ctx context.Context, in *CheckPwdRequest, opts ...grpc_go.CallOption) (*UpdateResponse, common.ErrorWithAttachment)
// rpc RegisterOrExist (RegistRequest) returns (RequestStatus) {}
// rpc RegisterOrExist (RegistRequest) returns (RequestStatus) {}
SendMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc_go.CallOption) (*SendMsgStatusResponse, common.ErrorWithAttachment)
SendCustomMsg(ctx context.Context, in *SendCustomMsgRequest, opts ...grpc_go.CallOption) (*SendMsgStatusResponse, common.ErrorWithAttachment)
SendExCustomMsg(ctx context.Context, in *SendCustomMsgRequest, opts ...grpc_go.CallOption) (*SendMsgStatusResponse, common.ErrorWithAttachment)
@ -70,7 +70,7 @@ type AccountFieeClient interface {
VerifySliderStatus(ctx context.Context, in *VerifySliderStatusRequest, opts ...grpc_go.CallOption) (*VerifySliderStatusResponse, common.ErrorWithAttachment)
// submit info
SaveSubmitInfo(ctx context.Context, in *SubmitInfoRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
// -----------------------------客服聊天系统--------------------------------
//-----------------------------客服聊天系统--------------------------------
CreateChatUser(ctx context.Context, in *ChatUserData, opts ...grpc_go.CallOption) (*CreateChatUserResp, common.ErrorWithAttachment)
UpdateChatUser(ctx context.Context, in *ChatUserData, opts ...grpc_go.CallOption) (*CommonMsg, common.ErrorWithAttachment)
SaveChatUser(ctx context.Context, in *ChatUserData, opts ...grpc_go.CallOption) (*CommonMsg, common.ErrorWithAttachment)
@ -591,7 +591,7 @@ type AccountFieeServer interface {
OnlineLog(context.Context, *LoginInfosByUserIdRequest) (*LoginLogsResponse, error)
OnlineLogById(context.Context, *OnlineLogByIdRequest) (*LoginLog, error)
CheckPwd(context.Context, *CheckPwdRequest) (*UpdateResponse, error)
// rpc RegisterOrExist (RegistRequest) returns (RequestStatus) {}
// rpc RegisterOrExist (RegistRequest) returns (RequestStatus) {}
SendMsg(context.Context, *SendMsgRequest) (*SendMsgStatusResponse, error)
SendCustomMsg(context.Context, *SendCustomMsgRequest) (*SendMsgStatusResponse, error)
SendExCustomMsg(context.Context, *SendCustomMsgRequest) (*SendMsgStatusResponse, error)
@ -626,7 +626,7 @@ type AccountFieeServer interface {
VerifySliderStatus(context.Context, *VerifySliderStatusRequest) (*VerifySliderStatusResponse, error)
// submit info
SaveSubmitInfo(context.Context, *SubmitInfoRequest) (*CommonResponse, error)
// -----------------------------客服聊天系统--------------------------------
//-----------------------------客服聊天系统--------------------------------
CreateChatUser(context.Context, *ChatUserData) (*CreateChatUserResp, error)
UpdateChatUser(context.Context, *ChatUserData) (*CommonMsg, error)
SaveChatUser(context.Context, *ChatUserData) (*CommonMsg, error)
@ -3074,5 +3074,5 @@ var AccountFiee_ServiceDesc = grpc_go.ServiceDesc{
},
},
Streams: []grpc_go.StreamDesc{},
Metadata: "accountFiee.proto",
Metadata: "api/accountFiee/accountFiee.proto",
}

View File

@ -53,8 +53,8 @@ func (chatAutoReplyRulerDao) UpdateChatAutoReplyRuler(data *model.ChatAutoReplyR
if data.Ruler != "" {
thisData.Ruler = data.Ruler
}
if data.Status != 0 {
thisData.Status = data.Status
if data.RulerStatus != 0 {
thisData.RulerStatus = data.RulerStatus
}
if err = model.DB.Updates(&thisData).Error; err != nil {
@ -105,8 +105,8 @@ func (chatAutoReplyRulerDao) GetChatAutoReplyRulerList(info *accountFiee.GetChat
if info.Query.Ruler != "" {
dbQuery = dbQuery.Where("ruler =?", info.Query.Ruler)
}
if info.Query.Status != 0 {
dbQuery = dbQuery.Where("status = ?", info.Query.Status)
if info.Query.RulerStatus != 0 {
dbQuery = dbQuery.Where("ruler_status = ?", info.Query.RulerStatus)
}
}
if info.Where != "" {

View File

@ -8,7 +8,6 @@ package dao
import (
"errors"
"fmt"
"github.com/fonchain_enterprise/micro-account/api/accountFiee"
"github.com/fonchain_enterprise/micro-account/pkg/common/db"
"github.com/fonchain_enterprise/micro-account/pkg/m"
@ -103,7 +102,7 @@ func (chatUserDao) GetChatUserById(id int) (res model.ChatUser, err error) {
// 批量查询聊天用户
func (chatUserDao) GetChatUserList(info *accountFiee.GetChatUserListRequest) (resp []model.ChatUser, total int64, err error) {
var dbQuery = model.DB.Model(&model.ChatUser{}).Debug()
var dbQuery = model.DB.Model(&model.ChatUser{})
if info.Query != nil {
if info.Query.ID != 0 {

View File

@ -52,10 +52,9 @@ func (c ChatRecord) ChatMedia() string {
type ChatAutoReplyRuler struct {
Model
Title string `gorm:"column:title;comment:标题"`
Ruler string `gorm:"column:ruler;type:varchar(2000);comment:规则内容"`
Status int32 `gorm:"column:status;default:1;comment:启用状态: 1=启用 2=禁用"`
Response string `gorm:"column:response;varchar(2000);comment:回复内容"`
Title string `gorm:"column:title;comment:标题"`
Ruler string `gorm:"column:ruler;type:varchar(2000);comment:规则内容"`
RulerStatus int32 `gorm:"column:ruler_status;comment:规则状态: 1=启用 2=禁用"`
}
func (c ChatRecord) AutoChatRuler() string {
@ -66,7 +65,7 @@ type ChatUser struct {
Model
NickName string `gorm:"column:nick_name;comment:昵称"`
Account string `gorm:"column:account;comment:账号"`
Role int32 `gorm:"column:role;default:1;comment:聊天角色 1=用户 2=客服 3=客服机器人"`
Role int32 `gorm:"column:role;default:1;comment:聊天角色 1=用户 2=客服"`
Origin string `gorm:"column:origin;default:'fiee';comment:数据来源"`
OriginId int64 `gorm:"column:origin_id;comment:数据来源对应的用户ID"`
Avatar string `gorm:"column:avatar;comment:头像"`

View File

@ -11,7 +11,6 @@ func migration() {
&ChatMedia{},
&ChatRecord{},
&ChatUser{},
&ChatAutoReplyRuler{},
)
if err != nil {