msb-public
/
go-fly
mirror of https://github.com/taoshihan1991/go-fly.git
1
0
Code Issues Projects Releases Wiki Activity

增加发送消息接口

Browse Source
pull/30/head
taoshihan1991 4 years ago
parent b6919e7e47
commit 30ac128a5f
6 changed files with 252 additions and 8 deletions
Show Stats Download Patch File Download Diff File

106
controller/message.go
Unescape View File

@ -0,0 +1,106 @@
package controller
import (
"encoding/json"
"github.com/gin-gonic/gin"
"github.com/gorilla/websocket"
"github.com/taoshihan1991/imaptool/models"
"time"
)
// @Summary 发送消息接口
// @Produce json
// @Accept multipart/form-data
// @Param from_id formData string true "来源uid"
// @Param to_id formData string true "目标uid"
// @Param content formData string true "内容"
// @Param type formData string true "类型|kefu,visitor"
// @Success 200 {object} controller.Response
// @Failure 200 {object} controller.Response
// @Router /message [post]
func SendMessage(c *gin.Context) {
fromId := c.PostForm("from_id")
toId := c.PostForm("to_id")
content := c.PostForm("content")
cType := c.PostForm("type")
if content==""{
c.JSON(200, gin.H{
"code": 400,
"msg": "内容不能为空",
})
return
}
var kefuInfo models.User
var vistorInfo models.Visitor
if cType=="kefu"{
kefuInfo=models.FindUser(fromId)
vistorInfo=models.FindVisitorByVistorId(toId)
}else if cType=="visitor"{
vistorInfo=models.FindVisitorByVistorId(fromId)
kefuInfo=models.FindUser(toId)
}
if kefuInfo.ID==0 ||vistorInfo.ID==0{
c.JSON(200, gin.H{
"code": 400,
"msg": "用户不存在",
})
return
}
models.CreateMessage(kefuInfo.Name,vistorInfo.VisitorId,content,cType)
if cType=="kefu"{
guest,ok:=clientList[vistorInfo.VisitorId]
if guest==nil||!ok{
c.JSON(200, gin.H{
"code": 200,
"msg": "ok",
})
return
}
conn := guest.conn
msg := TypeMessage{
Type: "message",
Data: ClientMessage{
Name: kefuInfo.Nickname,
Avator: kefuInfo.Avator,
Id: kefuInfo.Name,
Time: time.Now().Format("2006-01-02 15:04:05"),
ToId: vistorInfo.VisitorId,
Content: content,
},
}
str, _ := json.Marshal(msg)
conn.WriteMessage(websocket.TextMessage,str)
}
if cType=="visitor"{
kefuConns,ok := kefuList[kefuInfo.Name]
if kefuConns==nil||!ok{
c.JSON(200, gin.H{
"code": 200,
"msg": "ok",
})
return
}
msg := TypeMessage{
Type: "message",
Data: ClientMessage{
Avator: vistorInfo.Avator,
Id: vistorInfo.VisitorId,
Name: vistorInfo.Name,
ToId: kefuInfo.Name,
Content: content,
Time: time.Now().Format("2006-01-02 15:04:05"),
},
}
str, _ := json.Marshal(msg)
for _,kefuConn:=range kefuConns{
kefuConn.WriteMessage(websocket.TextMessage,str)
}
}
c.JSON(200, gin.H{
"code": 200,
"msg": "ok",
})
}

52
docs/docs.go
Unescape View File

@ -1,6 +1,6 @@
// GENERATED BY THE COMMAND ABOVE; DO NOT EDIT
// This file was generated by swaggo/swag at
// 2020-07-13 19:22:07.3168355 +0800 CST m=+0.136007801
// 2020-07-23 16:30:50.1490506 +0800 CST m=+0.137007801
package docs
@ -66,6 +66,56 @@ var doc = `{
}
}
},
"/message": {
"post": {
"consumes": [
"multipart/form-data"
],
"produces": [
"application/json"
],
"summary": "发送消息接口",
"parameters": [
{
"type": "string",
"description": "来源uid",
"name": "from_id",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "目标uid",
"name": "to_id",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "内容",
"name": "content",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "类型|kefu,visitor",
"name": "type",
"in": "formData",
"required": true
}
],
"responses": {
"200": {
"description": "OK",
"schema": {
"type": "object",
"$ref": "#/definitions/controller.Response"
}
}
}
}
},
"/messages": {
"get": {
"consumes": [

50
docs/swagger.json
Unescape View File

@ -53,6 +53,56 @@
}
}
},
"/message": {
"post": {
"consumes": [
"multipart/form-data"
],
"produces": [
"application/json"
],
"summary": "发送消息接口",
"parameters": [
{
"type": "string",
"description": "来源uid",
"name": "from_id",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "目标uid",
"name": "to_id",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "内容",
"name": "content",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "类型|kefu,visitor",
"name": "type",
"in": "formData",
"required": true
}
],
"responses": {
"200": {
"description": "OK",
"schema": {
"type": "object",
"$ref": "#/definitions/controller.Response"
}
}
}
}
},
"/messages": {
"get": {
"consumes": [

34
docs/swagger.yaml
Unescape View File

@ -46,6 +46,40 @@ paths:
$ref: '#/definitions/controller.Response'
type: object
summary: 登陆验证接口
/message:
post:
consumes:
- multipart/form-data
parameters:
- description: 来源uid
in: formData
name: from_id
required: true
type: string
- description: 目标uid
in: formData
name: to_id
required: true
type: string
- description: 内容
in: formData
name: content
required: true
type: string
- description: 类型|kefu,visitor
in: formData
name: type
required: true
type: string
produces:
- application/json
responses:
"200":
description: OK
schema:
$ref: '#/definitions/controller.Response'
type: object
summary: 发送消息接口
/messages:
get:
consumes:

2
main.go
Unescape View File

@ -47,7 +47,7 @@ func main() {
//获取消息
engine.GET("/messages",middleware.JwtApiMiddleware, controller.GetVisitorMessage)
//发送单条消息
engine.POST("/message",controller.GetVisitorMessage)
engine.POST("/message",controller.SendMessage)
//获取未读消息数
engine.GET("/message_status",controller.GetVisitorMessage)
//设置消息已读

16
static/html/chat_main.html
Unescape View File

@ -300,17 +300,21 @@
if(this.messageContent==""||this.currentGuest==""){
return;
}
let _this=this;
let mes = {};
mes.type = "kfChatMessage";
this.kfConfig.content = this.messageContent;
mes.data = this.kfConfig;
this.socket.send(JSON.stringify(mes));
this.messageContent = "";
mes.type = "kefu";
mes.content = this.messageContent;
mes.from_id = this.kfConfig.id;
mes.to_id = this.currentGuest;
mes.content = this.messageContent;
$.post("/message",mes,function(){
_this.messageContent = "";
});
let content = {}
content.avator = this.kfConfig.avator;
content.name = this.kfConfig.name;
content.content = this.kfConfig.content;
content.content = this.messageContent;
content.is_kefu = true;
content.time = '';
this.msgList.push(content);

Write Preview
Loading…
Cancel
Save