Skip to content

P
ppt_server
Commit 8c41e3b3 by Li Feifei
Options

code format

parent 444a7deb
Pipeline #15601 failed with stages
in 12 seconds
Showing with 1008 additions and 632 deletions
app/api/file.go 0 → 100755
package api
import (
"ppt_server/app/model"
"ppt_server/app/service"
"ppt_server/library/response"
"github.com/gogf/gf/net/ghttp"
)
var File = fileApi{}
type fileApi struct{}
func (f *fileApi) Index(r *ghttp.Request) {
response.Success(r)
}
/**
* @Author lifeifei
* @Date 9:44 上午 2021/7/22
* @Summary 课件上传接口
* @Tags 客户端通过接口上传课件
* @Produce json
* @Router POST /file/upload
* @Param room_num formData string true "房间名称"
* @Param name formData string true "课件名称"
* @Param nickname formData string true "用户昵称"
* @Param type formData string true "文件类型"
* @Param url formData int true "课件地址"
* @Param uuid formData string true "用户唯一标识"
* @Return {"code":0,"data":null,"msg":"成功"}
**/
func (f *fileApi) Upload(r *ghttp.Request) {
var req model.FileUploadRequest
if err := r.Parse(&req); err != nil {
response.Fail(r, err)
}
go service.File.Upload(&req)
response.Success(r)
}
app/dao/internal/xyu_room.go 0 → 100755
package internal
import (
"github.com/gogf/gf/database/gdb"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/frame/gmvc"
)
type xyuRoomColumns struct {
Id string
RoomNum string
}
type XyuRoomDao struct {
gmvc.M
DB gdb.DB
Table string
Columns xyuRoomColumns
}
var (
XyuRoom = XyuRoomDao{
M: g.DB("default").Model("xyu_room").Safe(),
DB: g.DB("default"),
Table: "xyu_room",
Columns: xyuRoomColumns{
Id: "id",
RoomNum: "room_num",
},
}
)
app/dao/internal/xyu_room_files.go 0 → 100755
package internal
import (
"github.com/gogf/gf/database/gdb"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/frame/gmvc"
)
type xyuRoomFilesColumns struct {
Id string
RoomId string
Name string
}
type XyuRoomFilesDao struct {
gmvc.M
DB gdb.DB
Table string
Columns xyuRoomFilesColumns
}
var (
XyuRoomFiles = XyuRoomFilesDao{
M: g.DB("default").Model("xyu_room_files").Safe(),
DB: g.DB("default"),
Table: "xyu_room_files",
Columns: xyuRoomFilesColumns{
Id: "id",
RoomId: "room_id",
Name: "name",
},
}
)
app/dao/xyu_room.go 0 → 100755
package dao
import "ppt_server/app/dao/internal"
type xyuRoomDao struct {
internal.XyuRoomDao
}
var XyuRoom = xyuRoomDao{internal.XyuRoom}
app/dao/xyu_room_files.go 0 → 100755
package dao
import "ppt_server/app/dao/internal"
type xyuRoomFilesDao struct {
internal.XyuRoomFilesDao
}
var XyuRoomFile = xyuRoomFilesDao{
internal.XyuRoomFiles,
}
app/model/file.go 0 → 100755
package model
import (
"github.com/gogf/gf/container/gset"
"ppt_server/app/model/internal"
)
type (
XyuRoom internal.XyuRoom
XyuRoomFiles internal.XyuRoomFiles
// 客户端上传课件请求参数
FileUploadRequest struct {
RoomNum string `p:"room_num" v:"required#房间号不能为空"`
Name string `p:"name" v:"required#课件名称不能为空"`
Nickanem string `p:"nickname" v:"required#用户昵称不能为空"`
Type int `p:"type" v:"required|min:1|max:3#类型不能为空|类型只能1~3"`
Url string `p:"url" v:"required#上传课件地址不能为空"`
Uuid string `p:"uuid" v:"required#上传者UUID不能为空"`
}
// web365解析文件返回信息
UploadFileInfo struct {
FileName string `json:"FileName"`
FileSize int64 `json:"FileSize"`
PageCount int `jons:"PageCount"`
SlideCount int `json:"SlideCount"`
SheetCount int `json:"SheetCount"`
}
//OssPacked
Packed struct {
FileName string `json:"fileName"`
Hash string `json:"json"`
ImagesName *gset.Set `json:"imagesName"`
OssImagesPath string `json:"ossImagesPath"`
ImageInfos [][]interface{} `json:"imageInfos"`
}
// 服务端通知返回信息
NotifyResponse struct {
Code int64 `json:"code"`
Msg string `json:"msg"`
}
)
app/model/internal/xyu_room.go 0 → 100755
package internal
type XyuRoom struct {
Id int `orm:"id,primary" json:"id"`
RoomNum string `orm:"room_num" json:"room_num"`
}
app/model/internal/xyu_room_files.go 0 → 100755
package internal
type XyuRoomFiles struct {
Id int `orm:"id,primary" json:"id"`
RoomId int `orm:"room_id" json:"room_id"`
Name string `orm:"name" json:"name"`
}
app/service/file.go 0 → 100755
package service
import (
"ppt_server/app/dao"
"ppt_server/app/model"
"ppt_server/packed"
"github.com/gogf/gf/frame/g"
)
var File = &fileService{
done: make(chan error),
ok: make(chan g.Map),
}
type fileService struct {
done chan error
ok chan g.Map
}
// 上传课件
func (f *fileService) Upload(r *model.FileUploadRequest) {
// 解析上传课件URL
parserURLObject, err := packed.Upload(r, f.done, f.ok)
if err != nil {
g.Log().Async().Errorf("Parser Url err: %s\n", err)
return
}
// 检查房间是否存在
var room model.XyuRoom
if err = dao.XyuRoom.Where(dao.XyuRoom.Columns.RoomNum, r.RoomNum).Scan(&room); err != nil {
g.Log().Async().Error(err)
go func() { f.done <- err }()
}
// 上传操作
go parserURLObject.Worker(err)
// 回调通知
n := packed.NewNotify()
select {
case <-f.done:
// 上传失败
n.Fail(parserURLObject)
return
case res := <-f.ok:
// 上传成功
count, err := dao.XyuRoomFile.Where(dao.XyuRoomFile.Columns.RoomId, room.Id).
Where(dao.XyuRoomFile.Columns.Name, r.Name).Count()
if err != nil {
g.Log().Async().Errorf("Mysql Err: %s\n", err)
return
}
// 数据库已经存在不需要通知
if count == 1 {
return
}
res["room_id"] = room.Id
n.Success(res)
return
}
}
boot/boot.go 0 → 100755
package boot
import (
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/net/ghttp"
)
func init() {
g.Server().SetNameToUriType(ghttp.URI_TYPE_CAMEL)
g.Log().SetAsync(true)
}
conf/2817229__offcncloud.com.key deleted 100644 → 0
-----BEGIN RSA PRIVATE KEY-----
MIIEogIBAAKCAQEAo+8g8CvasfIwe4uToDzY8ir2rZoaBBV8EqM2gu+EwpmYnfBD
FYagyWvNDYNRYBKJgZuT/BU4f/dF0bFTFp0KwxcYDkhYE1TBNsnPqTNZGp0K2C9m
v2ATLyf+2DuVhW4etlQVnsqQBxPEoWCPmf4Mrta4xy83ZqS7BRBmi8avGyzhYjjB
hYLVuDAyOb+pDSGe9rpgcp0pyzpJ/4u8xLRO08CAUbyhN5l9ubrIBmV1F4PMhy1H
mmq26cJdMXcumzUZRebWtKK4xxZFteG8GNZIA0Oz8sk1RKjMgAVko7Uu6eR4rSlG
+R6pI79Npps3REIm1m8A3kMDCEmdDnl5q+ef3wIDAQABAoIBAHN4Mkk5epewsfmz
vM43TdB19r8dNon94CD4maLstySjL96/p2D4LTTzG8IS5zS2meiS/0+mWt+3+pPT
RWU+RKBaGfWle3RSVK4UxJK3umGGkGbqLINMVvb2QwloHs+XW0auP3RT1dNGV1Ac
RcoAKkrUr96NIYbJLXpJrRFzZ0/JzaKeHNB0OB8xQeWTVdM6liBgKhE8EMKqzA7E
Z3vZaB5Z4ezcYM+eKjKCkXkkhwc4AxibKdFdfBmdB6oFvMGoZjLbET/8CeOp6xKH
ovNEPohKpz0ewz932ZrpcikvnucXXhzhaxwmUmLF74WvVU+T5uIMjkj8jyylrUxw
kMzgufECgYEA9ew+hKtS8wWfnDqfURpDezjMueQF5/2kUVKuwsNhERLuXCe4XLFb
USAvHWrCiEqO0RA4Y+CybTS9kekMyC3lRHc+3otZ9ienp9BAcqA1T8UO2HEfFrfG
knUH9Xw7vjKwKBHPBARlnURqoiX5B9pjRs/Kya+19XVcAB7RNfbcvBsCgYEAqqbQ
b/3RYkM+fhy7xTITP6ommjRcnfI2RV/gGlt4jYM6/2GJ1PH3zOv+nhZfoffw/NYp
3A7zKfUe37frp5eYyoeZB1nB6Xo+aNsF0nSsc0x/Jms83gT5mfT3v9zUpOhe9FvH
iKgS0SYJVe9D5yuefLP1WNuYCy6/BLqE7nvyX40CgYBiD+s6EesItyRXMtUWjQd9
mj+gnHlycaTVPMgtJ6WMHmVn3/rXE23bYp8G9uxNVpWube5efVoIy/APv8N2Cz8R
1w79xMmBq3xiIVuhmZrIjUaHLkx8TZnkCsC6tehIxoOR5tAKxQoT9RUkRUoRRJcz
xGYTmHpRP5QJBEDeaOrKIwKBgBQ+zBWtOAz/S0es4v3nDe+MoR3EPoSiepvKXwzh
czDes74edTqlJi/Sg5d/sgLGJnnocnjf8Ss2IF6MNFHio0bLxXTgyieH0CWiblNk
ch0PozoMmOECGBaSwF2rtjKGOtWkmcx1nB3h9FOUmiqvuxKyStYq3yPcfN7zvdeJ
Ltz1AoGAI2P5xabnyBT2RU0pHth+YLg6SX0KNAPDuASTEUVcEFxftPmv90QRQhMU
2Ks6BpL+hwGxL6qu6heeq4PU9MVsFWCEZh9/igHDf0hHM60+euo/g8FHUkNn4/1q
2dd8CJM1uD/LSY0Cu7I3o2TOILHX9METraw6EWDq4iHnPy/tySI=
-----END RSA PRIVATE KEY-----
conf/2817229__offcncloud.com.pem deleted 100644 → 0
-----BEGIN CERTIFICATE-----
MIIGxTCCBa2gAwIBAgIQBlYKeyjVKIgKNuFr3A2gfzANBgkqhkiG9w0BAQsFADBf
MQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3
d3cuZGlnaWNlcnQuY29tMR4wHAYDVQQDExVHZW9UcnVzdCBDTiBSU0EgQ0EgRzEw
HhcNMTkwOTE2MDAwMDAwWhcNMjEwOTE1MTIwMDAwWjB4MQswCQYDVQQGEwJDTjES
MBAGA1UECAwJ5YyX5Lqs5biCMS0wKwYDVQQKDCTljJfkuqzkuK3lhazmlZnogrLn
p5HmioDmnInpmZDlhazlj7gxCzAJBgNVBAsTAklUMRkwFwYDVQQDDBAqLm9mZmNu
Y2xvdWQuY29tMIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAo+8g8Cva
sfIwe4uToDzY8ir2rZoaBBV8EqM2gu+EwpmYnfBDFYagyWvNDYNRYBKJgZuT/BU4
f/dF0bFTFp0KwxcYDkhYE1TBNsnPqTNZGp0K2C9mv2ATLyf+2DuVhW4etlQVnsqQ
BxPEoWCPmf4Mrta4xy83ZqS7BRBmi8avGyzhYjjBhYLVuDAyOb+pDSGe9rpgcp0p
yzpJ/4u8xLRO08CAUbyhN5l9ubrIBmV1F4PMhy1Hmmq26cJdMXcumzUZRebWtKK4
xxZFteG8GNZIA0Oz8sk1RKjMgAVko7Uu6eR4rSlG+R6pI79Npps3REIm1m8A3kMD
CEmdDnl5q+ef3wIDAQABo4IDYjCCA14wHwYDVR0jBBgwFoAUkZ9eMRWuEJ+tYMH3
wcyqSDQvDCYwHQYDVR0OBBYEFBdhbm8eOCcYqUMMraPc3XpinOcDMCsGA1UdEQQk
MCKCECoub2ZmY25jbG91ZC5jb22CDm9mZmNuY2xvdWQuY29tMA4GA1UdDwEB/wQE
AwIFoDAdBgNVHSUEFjAUBggrBgEFBQcDAQYIKwYBBQUHAwIwdQYDVR0fBG4wbDA0
oDKgMIYuaHR0cDovL2NybDMuZGlnaWNlcnQuY29tL0dlb1RydXN0Q05SU0FDQUcx
LmNybDA0oDKgMIYuaHR0cDovL2NybDQuZGlnaWNlcnQuY29tL0dlb1RydXN0Q05S
U0FDQUcxLmNybDBMBgNVHSAERTBDMDcGCWCGSAGG/WwBATAqMCgGCCsGAQUFBwIB
FhxodHRwczovL3d3dy5kaWdpY2VydC5jb20vQ1BTMAgGBmeBDAECAjBvBggrBgEF
BQcBAQRjMGEwIQYIKwYBBQUHMAGGFWh0dHA6Ly9vY3NwLmRjb2NzcC5jbjA8Bggr
BgEFBQcwAoYwaHR0cDovL2NybC5kaWdpY2VydC1jbi5jb20vR2VvVHJ1c3RDTlJT
QUNBRzEuY3J0MAkGA1UdEwQCMAAwggF9BgorBgEEAdZ5AgQCBIIBbQSCAWkBZwB2
ALvZ37wfinG1k5Qjl6qSe0c4V5UKq1LoGpCWZDaOHtGFAAABbTkJDU8AAAQDAEcw
RQIhAKxPVhYZl6lmgwkrHtPR6Tj+w07w8OEzzIi5tCux/F+NAiBzfajUaCWyHBkq
FmzUoZ2WRxhwDLJsGMfY/GVcLOf+XgB2AId1v+dZfPiMQ5lfvfNu/1aNR1Y2/0q1
YMG06v9eoIMPAAABbTkJDbUAAAQDAEcwRQIhAJ+oKOIjCEdBwBsdj9CYaJ1PBLoS
BfEAGv/rOy7t6rNoAiBdK24FvESSzbrN5hfPRCyZKTDQ0CCqsMn/5ztQ/z5iNAB1
AESUZS6w7s6vxEAH2Kj+KMDa5oK+2MsxtT/TM5a1toGoAAABbTkJDLoAAAQDAEYw
RAIgXX/xR8XI24dq8iZxhZBmLOLuo4ZbjOvdNz9wPV35eQQCICQu0+sZQ9aQXp9I
jRAnxxVtibIkystgYpgTn/VqMN/MMA0GCSqGSIb3DQEBCwUAA4IBAQBt0ddC3sUW
hRmTThB9ohImhH+pkwkDNRMF8YbOiDFuxFVBcvpKLjE+4BS0Tznkl7kMY/uCCmoo
PZeIdvpSIqVq6GmixWjcixOSXZ1gqiRHomqFOIYPi3emJbDV+J6c1rUzQvr8LFNb
Fen0xrT1ZNVK4W1GVM0givqjlvz0MI+8ds35HwuofzO8OUiJmcKziOTnlqHn/qNC
nFHlyCU33NYZw2YsZXZorJiPqoYAGSMcvunwKA7g0cZNMq9TXzOm9xDYrJ+wcEcU
uy0B6LfHkftgHlJ+7cOzQu4Gx8HI/eoJuTayifkjQQIAd4WgVmFLjDFkU0fZA5vL
S+8iHnMiCHok
-----END CERTIFICATE-----
-----BEGIN CERTIFICATE-----
MIIFGjCCBAKgAwIBAgIQCgRw0Ja8ihLIkKbfgm7sSzANBgkqhkiG9w0BAQsFADBh
MQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3
d3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD
QTAeFw0xOTA2MjAxMjI3NThaFw0yOTA2MjAxMjI3NThaMF8xCzAJBgNVBAYTAlVT
MRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j
b20xHjAcBgNVBAMTFUdlb1RydXN0IENOIFJTQSBDQSBHMTCCASIwDQYJKoZIhvcN
AQEBBQADggEPADCCAQoCggEBALFJ+j1KeZVG4jzgQob23lQ8PJUNhY31ufZihuUx
hYc6HSU4Lw0fxfA43a9DpJl74M3E6F1ZRBOfJ+dWnaiyYD0PxRIQd4wJisti4Uad
vz61IYY/oQ/Elxk/X7GFDquYuxCSyBdHtTVMXCxFSvQ2C/7jWZFDfGGKKNoQSiJy
wDe8iiHbUOakLMmXmOTZyWJnFdR/TH5YNTiMKCNUPHAleG4IigGxDyL/gbwrdDNi
bDA4lUNhD0xNvPjQ8BNKqm5HWDvirUuHdC+4hpi0GJO34O3iiRV16YmWTuVFNboU
LDZ0+PQtctJnatpuZKPGyKX6jCpPvzzPw/EhNDlpEdrYHZMCAwEAAaOCAc4wggHK
MB0GA1UdDgQWBBSRn14xFa4Qn61gwffBzKpINC8MJjAfBgNVHSMEGDAWgBQD3lA1
VtFMu2bwo+IbG8OXsj3RVTAOBgNVHQ8BAf8EBAMCAYYwHQYDVR0lBBYwFAYIKwYB
BQUHAwEGCCsGAQUFBwMCMA8GA1UdEwEB/wQFMAMBAf8wMQYIKwYBBQUHAQEEJTAj
MCEGCCsGAQUFBzABhhVodHRwOi8vb2NzcC5kY29jc3AuY24wRAYDVR0fBD0wOzA5
oDegNYYzaHR0cDovL2NybC5kaWdpY2VydC1jbi5jb20vRGlnaUNlcnRHbG9iYWxS
b290Q0EuY3JsMIHOBgNVHSAEgcYwgcMwgcAGBFUdIAAwgbcwKAYIKwYBBQUHAgEW
HGh0dHBzOi8vd3d3LmRpZ2ljZXJ0LmNvbS9DUFMwgYoGCCsGAQUFBwICMH4MfEFu
eSB1c2Ugb2YgdGhpcyBDZXJ0aWZpY2F0ZSBjb25zdGl0dXRlcyBhY2NlcHRhbmNl
IG9mIHRoZSBSZWx5aW5nIFBhcnR5IEFncmVlbWVudCBsb2NhdGVkIGF0IGh0dHBz
Oi8vd3d3LmRpZ2ljZXJ0LmNvbS9ycGEtdWEwDQYJKoZIhvcNAQELBQADggEBABfg
eXrxIrtlixBv+KMDeqKxtNJbZiLDzJBkGCd4HI63X5eS6BElJBn6mI9eYVrr7qOL
Tp7WiO02Sf1Yrpaz/ePSjZ684o89UAGpxOfbgVSMvo/a07n/220jUWLxzaJhQNLu
lACXwwWsxYf8twP8glkoIHnUUNTlhsyyl1ZzvVC4bDpI4hC6QkJGync1MNqYSMj8
tZbhQNw3HdSmcTO0Nc/J/pK2VZc6fFbKBgspmzdHc6jMKG2t4lisXEysS3wPcg0a
Nfr1Odl5+myh3MnMK08f6pTXvduLz+QZiIh8IYL+Z6QWgTZ9e2jnV8juumX1I8Ge
7cZdtNnTCB8hFfwGLUA=
-----END CERTIFICATE-----
conf/app.conf deleted 100644 → 0
appname = ppt_server
httpport = 80
runmode = dev
autorender = false
copyrequestbody = true
EnableDocs = true
sqlconn =
EnableHTTPS=true
EnableHttpTLS = true
HttpsPort = 443
HTTPSCertFile="conf/2817229__offcncloud.com.pem"
HTTPSKeyFile="conf/2817229__offcncloud.com.key"
config/config.toml 0 → 100755
# HTTP Server
[server]
Address = ":80"
ServerAgent = "gf-app"
LogPath = "/tmp/log/gf-app/server"
DumpRouterMap = true
# Logger.
[logger]
Path = "/tmp/log/gf-app"
Level = "all"
StdoutPrint = true
HeaderPrint = true
# 回调通知
[notify]
url = "http://offcn-live-svc"
[oss]
url = "https://xiaoyu-live.oss-cn-beijing.aliyuncs.com"
point = "oss-cn-beijing.aliyuncs.com"
bucket = "xiaoyu-live"
# 下载zip包存储目录
[temp]
path = "/data/files/"
# Database.
[database]
link = "mysql:video:vlty&AxMwT$lmLv6bN8dkDuBYlh%N5pe@tcp(rm-2zevlk47ul0ovuci80o.mysql.rds.aliyuncs.com:3306)/xyu"
debug = true
# Database logger.
[database.logger]
Path = "/tmp/log/gf-app/sql"
Level = "all"
Stdout = true
controllers/upload.go deleted 100644 → 0
package controllers
import (
"github.com/astaxie/beego"
"ppt_server/models"
"ppt_server/upload"
)
type Response struct {
Code int `json:"code"`
Msg string `json:"msg"`
}
type UploadController struct {
beego.Controller
}
func (this *UploadController) newResponse(code int, msg string) {
response := &Response{
Code: code,
}
if msg != "" {
response.Msg = msg
}
this.Data["json"] = response
this.ServeJSON()
}
func (this *UploadController) Get() {
this.newResponse(200, "成功")
}
func (this *UploadController) Post() {
u := models.XyuSmallTempFiles{}
if err := this.ParseForm(&u); err != nil {
//handle error
this.newResponse(100, "参数绑定失败")
return
}
if u.RoomNum == "" || u.Uuid == "" || u.Url == "" {
this.newResponse(100, "参数不正确")
return
}
go upload.Upload(&u)
this.newResponse(200, "成功")
return
//fmt.Println(u)
}
\ No newline at end of file
go.mod 100644 → 100755
module ppt_server
go 1.12
go 1.16
require (
github.com/aliyun/aliyun-oss-go-sdk v2.0.6+incompatible
github.com/astaxie/beego v1.12.1
github.com/beego/bee v1.12.3
github.com/go-sql-driver/mysql v1.5.0
github.com/shiena/ansicolor v0.0.0-20151119151921-a422bbe96644 // indirect
github.com/streadway/amqp v1.0.0
github.com/stretchr/objx v0.1.1 // indirect
golang.org/x/time v0.0.0-20191024005414-555d28b269f0 // indirect
github.com/aliyun/aliyun-oss-go-sdk v2.1.9+incompatible // indirect
github.com/gogf/gf v1.16.4 // indirect
github.com/xxjwxc/gowp v0.0.0-20210520113007-57eb4693b12d // indirect
golang.org/x/time v0.0.0-20210611083556-38a9dc6acbc6 // indirect
)
go.sum 100644 → 100755
This diff is collapsed. Click to expand it.
interfaces/interfaces.go 0 → 100644
/**
* @Authore: lifeifei
* @Date: 2021/7/22 2:08 下午
*/
package interfaces
// 分组路由
type Router interface {
Init()
}
library/http/http_client.go 0 → 100755
package http
import (
"io"
"net/http"
"os"
"time"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/net/ghttp"
)
func Get(url string) ([]byte, error) {
return Handle(g.Client().Timeout(30 * time.Second).Get(url))
}
func Handle(response *ghttp.ClientResponse, err error) ([]byte, error) {
if err != nil {
return nil, err
}
defer response.Close()
return response.ReadAll(), nil
}
// 下载文件
func Download(file string, path string) error {
g.Log().Async().Infof("Download zip url: %s ", file)
resp, err := http.Get(file)
if err != nil {
return err
}
defer resp.Body.Close()
// 创建一个文件用于保存
out, err := os.Create(path)
if err != nil {
return err
}
defer out.Close()
// 然后将响应流和文件流对接起来
_, err = io.Copy(out, resp.Body)
if err != nil && err == io.EOF {
return nil
}
if err != nil {
return err
}
return nil
}
library/oss/oss.go 0 → 100644
/**
* @Authore: lifeifei
* @Date: 2021/7/23 2:48 下午
*/
package oss
import (
"io"
"os"
"sync"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
"github.com/gogf/gf/frame/g"
)
var (
client *oss.Client
bucket *oss.Bucket
once sync.Once
)
func init() {
once.Do(func() {
client, _ = oss.New(g.Cfg().GetString("oss.point"),
os.Getenv("s_access_id"), os.Getenv("s_access_secret"))
bucket, _ = client.Bucket(g.Cfg().GetString("oss.bucket"))
})
}
//OSS上传
func Upload(path string, reader io.Reader) error {
return bucket.PutObject(path, reader)
}
library/response/response.go 0 → 100644
/**
* @Authore: lifeifei
* @Date: 2021/7/21 3:08 下午
*/
package response
import (
"net/http"
"github.com/gogf/gf/errors/gerror"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/net/ghttp"
"github.com/gogf/gf/util/gvalid"
)
func Success(r *ghttp.Request, data ...interface{}) {
res := g.Map{
"code": 0,
"msg": "成功",
"data": nil,
}
if len(data) > 0 {
res["data"] = data[0]
}
_ = r.Response.WriteJsonExit(res)
}
func Fail(r *ghttp.Request, err error) {
switch e := err.(type) {
case gvalid.Error:
_ = r.Response.WriteJsonExit(g.Map{
"code": http.StatusBadRequest,
"msg": e.FirstString(),
})
case *gerror.Error:
_ = r.Response.WriteJsonExit(g.Map{
"code": e.Code(),
"msg": e.Error(),
})
default:
_ = r.Response.WriteJsonExit(g.Map{
"code": http.StatusInternalServerError,
"msg": e.Error(),
})
}
}
main.go 100644 → 100755
This diff is collapsed. Click to expand it.
middleware/middleware.go 0 → 100755
package middleware
import (
"bytes"
"io/ioutil"
"ppt_server/library/response"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/net/ghttp"
)
// Recover异常恢复
func Recover(r *ghttp.Request) {
r.Middleware.Next()
if err := r.GetError(); err != nil {
r.Response.ClearBuffer()
response.Fail(r, err)
}
}
// CorS跨域
func Cors(r *ghttp.Request) {
r.Response.CORSDefault()
r.Middleware.Next()
}
// BodyDump打印请求体
func BodyDump(r *ghttp.Request) {
reqBody, _ := ioutil.ReadAll(r.Request.Body)
r.Request.Body = ioutil.NopCloser(bytes.NewBuffer(reqBody))
if len(reqBody) > 0 {
g.Log().Async().Infof("path: %s, method: %s params: %s",
r.Request.URL.RequestURI(), r.Method, string(reqBody))
}
r.Middleware.Next()
}
models/database.go deleted 100644 → 0
package models
import (
"fmt"
"log"
"ppt_server/utils"
"sync"
"github.com/astaxie/beego/orm"
_ "github.com/go-sql-driver/mysql"
)
var (
user string = utils.ConfigObject.DBuser
pass string = utils.ConfigObject.DBpass
host string = utils.ConfigObject.DBHost
port string = utils.ConfigObject.DBPort
dbname string = utils.ConfigObject.DBname
charset string = utils.ConfigObject.DBcharset
driver string = utils.ConfigObject.Driver
maxFreeConn int = utils.ConfigObject.MaxFreeLink
maxConn int = utils.ConfigObject.MaxLink
prefix string = utils.ConfigObject.DBprefix
)
type XyuRoom struct {
Id int `json:"id"`
RoomNum string `json:"room_num"`
StartTime string `json:"start_time"`
EndTime string `json:"end_time"`
Status int `json:"status"`
TeacherPassword string `json:"teacher_password"`
AssistantPassword string `json:"assistant_password"`
StudentPassword string `json:"student_password"`
HostPassword string `json:"host_password"`
SupervisePassword string `json:"supervise_password"`
IsRecording int
RoomType int `json:"room_type"`
ActualPush int
}
type XyuSmallRoom struct {
Id int
RoomId int
MaxPush int
RoomMode int
AllowMic int
}
type XyuSmallRoomWindow struct {
Id int
RoomNum string `json:"room_num"`
WId int `json:"wndindex"`
EId string `json:"e_id"`
PId string `json:"pid"`
Role string `json:"role"`
UserId string `json:"user_id"`
SetType int `json:"set_type"`
CreateTime string `json:"create_time"`
Status int
}
type XyuRoomUsers struct {
Id int `json:"id"`
Role string `json:"role"`
RoomNum string `json:"room_num"`
Token string `json:"token"`
}
type XyuSmallRoomPeople struct {
Id int
RoomNum string `pk;json:"room_num";`
Teacher int
Assistant int
Student int
Host int
Supervise int
}
type XyuSmallRoomRecord struct {
Id int
RoomNum string
Sessid string
Peerid string
RecordName string
TimeStamp string
}
type XyuSmallTempFiles struct {
Id int
RoomNum string `form:"room_num"`
Name string `form:"name"`
Nickanem string `form:"nickname"`
Type int `form:"type"`
Url string `form:"url"`
Time string `form:"time"'`
Uuid string `form:"uuid"`
Status int
}
type XyuRoomFiles struct {
Id int
RoomId int
Name string
}
var once sync.Once
func init() {
once.Do(func() {
init_mysql()
})
}
func init_mysql() {
dbConfStr := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=%s",
user, pass, host, port, dbname, charset)
log.Println("dbconf => ", dbConfStr)
_ = orm.RegisterDriver(driver, orm.DRMySQL)
err := orm.RegisterDataBase("default", driver, dbConfStr, maxFreeConn, maxConn)
if err != nil {
log.Println("db connect error => ", err)
return
}
orm.RegisterModel(new(XyuRoom), new(XyuRoomUsers), new(XyuSmallRoom), new(XyuSmallRoomWindow),
new(XyuSmallRoomPeople), new(XyuSmallRoomRecord), new(XyuSmallTempFiles), new(XyuRoomFiles))
//orm.Debug = true
log.Println("MySQL connect success")
}
packed/file_parser.go 0 → 100755
package packed
import (
"fmt"
"mime"
"path"
"strings"
"github.com/gogf/gf/encoding/gurl"
"github.com/gogf/gf/errors/gerror"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/text/gstr"
)
type parser struct {
path string
slicePath []string
url string //课件地址
ext string //课件后缀
name string //课件名称
}
func parseURL(ossFileLink, name string) (*parser, error) {
parseURLPath, err := gurl.ParseURL(ossFileLink, 32)
if err != nil {
return nil, err
}
slicePath := gstr.SplitAndTrim(parseURLPath["path"], "/", "/")
if len(slicePath) < 4 {
return nil, gerror.New("上传URL格式不正确")
}
f := &parser{
ext: path.Ext(name),
url: ossFileLink,
path: parseURLPath["path"],
slicePath: slicePath,
name: name,
}
return f, nil
}
//解析课件的URL
func (f *parser) splitFileInfoLink() string {
return fmt.Sprintf("%s?info=0&ssl=1&furl=%s%s", ParserFileLink, g.Cfg().GetString("oss.url"), f.path)
}
// 临时存储解析包地址
func (f *parser) splitTempZipLink() string {
return fmt.Sprintf("%s%s.zip", g.Cfg().GetString("temp.path"), f.slicePath[2])
}
// 上传课件路径
func (f *parser) splitUploadPath() string {
return strings.Join(f.slicePath[0:len(f.slicePath)-1], "/") + "/"
}
// 文件名称hash
func (f *parser) nameHash() string {
return f.slicePath[3]
}
// 文件内容hash
func (f *parser) contentHash() string {
return f.slicePath[2]
}
// 数据库存储path
func (f *parser) dataPath() string {
return f.path[1:]
}
// 解析doctype
func (f *parser) docType() string {
switch f.ext {
case ".ppt", "pptx":
return "4"
case ".doc", "docx":
return "2"
case "xls", "xlsx":
return "3"
case ".pdf":
return "1"
default:
return "0"
}
}
// 获取文件mine
func (f *parser) mineType() string {
return mime.TypeByExtension(f.ext)
}
packed/file_upload.go 0 → 100755
package packed
import (
"archive/zip"
"bytes"
"encoding/json"
"fmt"
"image"
"image/jpeg"
"image/png"
"io/ioutil"
"os"
"path"
"regexp"
"strings"
"ppt_server/app/model"
"ppt_server/library/http"
"ppt_server/library/oss"
"github.com/gogf/gf/container/gset"
"github.com/gogf/gf/errors/gerror"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/os/gtime"
"github.com/xxjwxc/gowp/workpool"
)
// 解析URL返回基本信息
type ObtainFile struct {
r *model.FileUploadRequest // 客户端请求参数
ok chan g.Map // 上传课件响应成功
err chan error // 上传课件失败Error
fileSize int64 // 课件大小
pageCount int // 课件图片数量
parser *parser // 课件对象
packed *model.Packed // packed.json
}
const (
ParserFileLink = "http://doc.offcncloud.com/"
OssIntranetLink = "xiaoyu-live.oss-cn-beijing-internal.aliyuncs.com"
UploadFileLinkHost = "desktop.offcncloud.com"
)
var (
reFileNameCompile, _ = regexp.Compile(`p([\d]+)[.].*`)
typeMaterial = map[int]string{
1: "is_material",
2: "is_courseware",
3: "is_titlebook",
}
)
func Upload(r *model.FileUploadRequest, errChan chan error,
ok chan g.Map) (file *ObtainFile, err error) {
f, err := parseURL(r.Url, r.Name)
if err != nil {
return nil, err
}
file = &ObtainFile{
ok: ok,
err: errChan,
parser: f,
r: r,
packed: &model.Packed{
FileName: f.name,
Hash: f.contentHash(),
ImagesName: gset.NewSet(),
OssImagesPath: f.splitUploadPath() + "images/",
},
}
return file, nil
}
//从web365获取上传文件信息
func (f *ObtainFile) fileInfo() error {
fileBytes, err := http.Get(f.parser.splitFileInfoLink())
if err != nil {
return err
}
var fileInfo model.UploadFileInfo
if err = json.Unmarshal(fileBytes, &fileInfo); err != nil {
return err
}
if fileInfo.FileSize != 0 {
f.fileSize = fileInfo.FileSize
}
switch {
case fileInfo.SlideCount != 0:
f.pageCount = fileInfo.SlideCount
case fileInfo.PageCount != 0:
f.pageCount = fileInfo.PageCount
case fileInfo.SheetCount != 0:
f.pageCount = fileInfo.SheetCount
}
return nil
}
// 获取图片宽和高 并将图片上传到OSS
func (f *ObtainFile) taskJob(file *zip.File) ([]interface{}, error) {
fd, err := file.Open()
if err != nil {
return nil, err
}
defer fd.Close()
pictureBytes, _ := ioutil.ReadAll(fd)
// 获取图片信息reader
imageReader := ioutil.NopCloser(bytes.NewBuffer(pictureBytes))
// 上传图片reader
fileReader := ioutil.NopCloser(bytes.NewBuffer(pictureBytes))
var img image.Image
fileSuffix := path.Ext(file.Name) //获取文件后缀
switch fileSuffix {
case ".png":
img, err = png.Decode(imageReader)
case ".jpeg":
img, err = jpeg.Decode(imageReader)
default:
return nil, gerror.New("image ext is not found")
}
if err != nil {
return nil, err
}
replaceName := fmt.Sprintf("%05s", reFileNameCompile.ReplaceAllString(file.Name, "$1")) + fileSuffix
info := img.Bounds()
imageInfo := []interface{}{replaceName, info.Max.X, info.Max.Y}
g.Log().Async().Infof("Upload picture file: %s Success", replaceName)
return imageInfo, oss.Upload(f.parser.splitUploadPath()+"images/"+replaceName, fileReader)
}
func (f *ObtainFile) task(file *zip.File) error {
var (
err error
imageInfo []interface{}
)
for i := 0; i < 3; i++ {
if imageInfo, err = f.taskJob(file); err == nil {
f.packed.ImageInfos = append(f.packed.ImageInfos, imageInfo)
f.packed.ImagesName.AddIfNotExist(imageInfo[0])
break
}
}
return err
}
func (f *ObtainFile) uploadPicture() error {
reader, err := zip.OpenReader(f.parser.splitTempZipLink())
if err != nil {
return err
}
defer reader.Close()
pool := workpool.New(100)
for _, file := range reader.File {
pool.DoWait(func() error {
return f.task(file)
})
}
return pool.Wait()
}
// 上传packed.json
func (f *ObtainFile) uploadPacked() error {
packedBytes, err := json.Marshal(f.packed)
if err != nil {
return err
}
return oss.Upload(f.parser.splitUploadPath()+"packed.json", bytes.NewReader(packedBytes))
}
// 进行解析上传操作
func (f *ObtainFile) Worker(err error) {
if err != nil {
return
}
// 解析课件获取课件信息
if err = f.fileInfo(); err != nil {
g.Log().Async().Error(err)
f.err <- err
return
}
g.Log().Async().Infof("file: %s file info complete", f.parser.name)
downloadZipLink := fmt.Sprintf("%s?info=1&words=%v&ssl=1&furl=%s/%s",
ParserFileLink, f.pageCount, g.Cfg().GetString("oss.url"),
f.parser.dataPath)
// 下载ZIP包
if err = http.Download(downloadZipLink, f.parser.splitTempZipLink()); err != nil {
g.Log().Async().Error(err)
f.err <- err
return
}
// 清理ZIP包
defer os.Remove(f.parser.splitTempZipLink())
g.Log().Async().Infof("file: %s Zip Donwload Complete", f.parser.name)
// 解析ZIP包并上传图片到OSS
if err = f.uploadPicture(); err != nil {
g.Log().Async().Error(err)
f.err <- err
return
}
// 上传packed.json到oss
if err = f.uploadPacked(); err != nil {
g.Log().Async().Error(err)
f.err <- err
return
}
g.Log().Async().Infof("filename: %s upload success!", f.parser.name)
m := g.Map{
"name": f.parser.name,
"file_name_hash": f.parser.nameHash(),
"hash": f.parser.contentHash(),
"path": f.parser.dataPath(),
"doc_type": f.parser.docType(),
"type": f.parser.mineType(),
"files_size": f.fileSize,
"page_count": f.pageCount,
"link": strings.Replace(f.parser.url, OssIntranetLink, UploadFileLinkHost, -1),
"private": "1",
"time": gtime.Datetime(),
"nickname": f.r.Nickanem,
"uuid": f.r.Uuid,
}
m[typeMaterial[f.r.Type]] = 1
f.ok <- m
}
packed/notify.go 0 → 100755
package packed
import (
"encoding/json"
"os"
"ppt_server/app/model"
"github.com/gogf/gf/errors/gerror"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/text/gregex"
)
type Notify struct {
name string
password string
url string
client *sessionHttpClient
}
func NewNotify() *Notify {
return &Notify{
url: g.Cfg().GetString("notify.url"),
name: os.Getenv("live_name"),
password: os.Getenv("live_pwd"),
client: NewSessionHttpClient(),
}
}
//回调验权
func (n *Notify) verify(url string, data g.Map) error {
res, err := n.client.Post(url, data)
if err != nil {
return err
}
var notifyResponse model.NotifyResponse
if err = json.Unmarshal(res, &notifyResponse); err != nil {
return err
}
if notifyResponse.Code != 200 {
return gerror.New(notifyResponse.Msg)
}
return nil
}
// 登录
func (n *Notify) auth(data g.Map) error {
if err := n.verify(n.url+"/web/login", g.Map{
"name": n.name,
"password": n.password,
}); err != nil {
return err
}
// 获取Token
bufferBytes, err := n.client.Get(n.url + "/web/admin")
if err != nil {
return err
}
buf, _ := gregex.Match(`<meta name="csrf-token" content="([^"]+)">`, bufferBytes)
data["_token"] = string(buf[1])
return nil
}
// 发送通知
func (n *Notify) notify(path string, data g.Map) error {
var err error
if err = n.auth(data); err != nil {
return err
}
if err = n.verify(n.url+path, data); err != nil {
return err
}
g.Log().Async().Infof("Notify Success!")
return nil
}
// 上传课件失败通知
func (n *Notify) Fail(object *ObtainFile) {
if err := n.notify("/web/room_files_error", g.Map{
"code": 400,
"uuid": object.r.Uuid,
"room_num": object.r.RoomNum,
"path": object.parser.dataPath,
}); err != nil {
g.Log().Async().Error(err)
}
}
// 上传成功通知
func (n *Notify) Success(res g.Map) {
if err := n.notify("/web/room_files_add", res); err != nil {
g.Log().Async().Error(err)
}
}
packed/session_http_client.go 0 → 100644
/**
* @Authore: lifeifei
* @Date: 2021/7/21 4:26 下午
*/
package packed
import (
"net/http"
"net/http/cookiejar"
"time"
clientHttp "ppt_server/library/http"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/net/ghttp"
)
// 保持会话请求
type sessionHttpClient struct {
c *ghttp.Client
}
func NewSessionHttpClient() *sessionHttpClient {
jar, _ := cookiejar.New(nil)
c := g.Client()
c.Jar = jar
c.CheckRedirect = func(req *http.Request, via []*http.Request) error {
return http.ErrUseLastResponse
}
return &sessionHttpClient{c}
}
func (client *sessionHttpClient) Post(link string, data ...interface{}) ([]byte, error) {
return clientHttp.Handle(client.c.Timeout(10*time.Second).Post(link, data))
}
func (client *sessionHttpClient) Get(url string) ([]byte, error) {
return clientHttp.Handle(client.c.Timeout(10 * time.Second).Get(url))
}
router/api/file.go 0 → 100644
/**
* @Authore: lifeifei
* @Date: 2021/7/22 10:26 上午
*/
package api
import (
"ppt_server/app/api"
"ppt_server/interfaces"
"github.com/gogf/gf/net/ghttp"
)
type _file struct {
router *ghttp.RouterGroup
}
func NewFileRouter(router *ghttp.RouterGroup) interfaces.Router {
return &_file{router}
}
func (f *_file) Init() {
group := f.router.Group(`/file`)
{
// 阿里云健康检测
group.GET(`/upload`, api.File.Index)
// 课件解析
group.POST(`/upload`, api.File.Upload)
}
}
router/router.go 0 → 100755
package router
import (
"ppt_server/middleware"
apiRouter "ppt_server/router/api"
"github.com/gogf/gf/frame/g"
)
func init() {
g.Server().Use(
middleware.Recover,
middleware.Cors,
)
api := g.Server().Group("").Middleware(middleware.BodyDump)
{
//课件解析
apiRouter.NewFileRouter(api).Init()
}
}
routers/router.go deleted 100644 → 0
// @APIVersion 1.0.0
// @Title beego Test API
// @Description beego has a very cool tools to autogenerate documents for your API
// @Contact astaxie@gmail.com
// @TermsOfServiceUrl http://beego.me/
// @License Apache 2.0
// @LicenseUrl http://www.apache.org/licenses/LICENSE-2.0.html
package routers
import (
"encoding/json"
"fmt"
"ppt_server/controllers"
"github.com/astaxie/beego/context"
"github.com/astaxie/beego"
"ppt_server/upload"
)
func init() {
beego.Router("/file/upload", &controllers.UploadController{})
beego.Post("/file/callback", func(ctx *context.Context) {
var mapFiles map[string]interface{}
var err error
fmt.Println("body === ", string(ctx.Input.RequestBody))
if err = json.Unmarshal(ctx.Input.RequestBody, &mapFiles); err != nil {
ctx.WriteString("Error " + err.Error())
return
}
if mapFiles["success"].(string) == "false" {
_ = upload.UpdateFileError("1", mapFiles["uuid"].(string), mapFiles["roomNum"].(string), mapFiles["path"].(string))
ctx.WriteString("Upload Fail")
return
}
if err = upload.CreateFileDataBase(mapFiles); err != nil {
_ = upload.UpdateFileError("2", mapFiles["uuid"].(string), mapFiles["roomNum"].(string), mapFiles["path"].(string))
ctx.WriteString("Error " + err.Error())
return
}
ctx.WriteString("Upload Ok")
})
}
upload/mq.go deleted 100644 → 0
/**
* @Authore: lifeifei
* @Date: 2021/1/25 10:47 上午
*/
package upload
import (
"encoding/json"
"fmt"
beeLogger "github.com/beego/bee/logger"
"github.com/streadway/amqp"
)
type RabbitMQ struct {
connection *amqp.Connection
channel *amqp.Channel
}
func (r *RabbitMQ) mqConnect() error {
var err error
RabbitUrl := fmt.Sprintf("amqp://%s:%s@%s:%d/",
"video",
"1fqH4WFR19uckgRyHzgISw",
"test-rmq.offcncloud.com/",
5672)
if r.connection, err = amqp.DialConfig(RabbitUrl, amqp.Config{Vhost: "v.ofc.office"}); err != nil {
beeLogger.Log.Errorf("RabbitMQ Server Connect Fail: %s", err)
return err
}
c, err := r.connection.Channel()
if err != nil {
beeLogger.Log.Errorf("Channel connet fail: %s", err)
return err
}
r.channel = c
beeLogger.Log.Success("RabbitMQ Server is running...")
return nil
}
func (r *RabbitMQ) mqClose() {
if r.channel != nil {
err := r.channel.Close()
if err != nil {
beeLogger.Log.Errorf("RabbitMQ Server Close Err: %s", err)
}
}
if r.connection != nil {
err := r.connection.Close()
if err != nil {
beeLogger.Log.Errorf("RabbitMQ Server Channel Close Err: %s", err)
}
}
}
func (r *RabbitMQ) Send(req map[string]interface{}) error {
defer r.mqClose()
if err := r.mqConnect(); err != nil {
return err
}
bytes, err := json.Marshal(req)
if err != nil {
return err
}
return r.channel.Publish("X.ofc.ppt2image", "RK.ofc.ppt2image", false, false, amqp.Publishing{
ContentType: "text/plain",
Body: bytes,
})
}
func Send(r map[string]interface{}) error {
mq := &RabbitMQ{}
return mq.Send(r)
}
upload/ppt.go deleted 100644 → 0
/**
* @Authore: lifeifei
* @Date: 2021/1/25 10:11 上午
*/
package upload
import (
"github.com/astaxie/beego/orm"
beeLogger "github.com/beego/bee/logger"
"mime"
Qurl "net/url"
"path"
"ppt_server/models"
"strings"
"time"
)
type PPT struct {
request *models.XyuSmallTempFiles
}
func (p *PPT) Transform() (err error) {
maps := make(map[string]interface{})
o := orm.NewOrm()
var room models.XyuRoom
err = o.QueryTable("xyu_room").Filter("room_num", p.request.RoomNum).One(&room)
if err != nil {
beeLogger.Log.Errorf("获取房间信息失败:%s", err)
return
}
maps["url"] = p.request.Url
maps["room_id"] = room.Id
maps["id"] = time.Now().Unix()
maps["is_courseware"] = "1"
maps["private"] = "1"
maps["nickname"] = p.request.Nickanem
maps["name"] = p.request.Name
maps["time"] = time.Now().Format("2006-01-02 15:04:0")
maps["uuid"] = p.request.Uuid
switch p.request.Type {
case 1:
maps["is_material"] = 1
case 2:
maps["is_courseware"] = 1
case 3:
maps["is_titlebook"] = 1
}
objectName := p.request.Url[strings.Index(p.request.Url, "com/")+4:]
url, _ := Qurl.QueryUnescape(p.request.Url)
filename := path.Base(url)
ext := path.Ext(filename)
slice_path := strings.Split(objectName, "/")
maps["file_name_hash"] = slice_path[3]
maps["hash"] = slice_path[2]
var docType string
if strings.Contains(ext, "ppt") || strings.Contains(ext, "pptx") {
docType = "4"
} else if strings.Contains(ext, "doc") || strings.Contains(ext, "docx") {
docType = "2"
} else if strings.Contains(ext, "xls") || strings.Contains(ext, "xlsx") {
docType = "3"
} else if strings.Contains(ext, "pdf") {
docType = "1"
}
maps["doc_type"] = docType
_ = mime.AddExtensionType(".pptx", "application/vnd.openxmlformats-officedocument.presentationml.presentation")
maps["type"] = mime.TypeByExtension(ext)
maps["path"] = objectName
link := strings.Replace(p.request.Url, "xiaoyu-live.oss-cn-beijing-internal.aliyuncs.com", "desktop.offcncloud.com", -1)
maps["link"] = link
if err = Send(maps); err != nil {
beeLogger.Log.Errorf("Send Error: %s", err)
_ = UpdateFileError("6", maps["uuid"].(string), maps["roomNum"].(string), objectName)
return
}
return nil
}
utils/const_smail.go deleted 100644 → 0
package utils
const (
ROOM_FIELD = "room_num"
CREATEROOM = "auth-createroom"
JOINROOM = "auth-push"
LEAVEROOM = "auth-unpush"
LEAVEPOD = "auth-podexit"
LEAVEEDGEID = "auth-edgeexit"
RECORDCREATE = "record-create"
TIME_FORMAT = "2006-01-02 15:04:05"
TABLE_XYU_ROOM_USERS = "xyu_room_users"
TABLE_XYU_ROOM = "xyu_room"
TABLE_XYU_SMAIL_ROOM = "xyu_small_room"
TABLE_XYU_SMAIL_ROOM_WINDOW = "xyu_small_room_window"
TABLE_XYU_SMALL_PEOPLE = "xyu_small_room_people"
TABLE_XYU_SMALL_RECORD = "xyu_small_room_record"
TEACHER = "teacher"
ASSISTANT = "assistant"
STUDENT = "student"
HOST = "host"
SUPERVISE = "supervise"
)
utils/utils.go deleted 100644 → 0
package utils
import (
"encoding/json"
"fmt"
"io/ioutil"
"os"
"time"
)
type RabbitMqConf struct {
Username string
Password string
Host string
Port int
ConfFilePath string
Driver string
DBHost string
DBPort string
DBpass string
DBuser string
DBname string
DBcharset string
DBprefix string
ReconnectionTime time.Duration
MaxFreeLink int
MaxLink int
}
var ConfigObject *RabbitMqConf
func (r *RabbitMqConf) Reload() {
if confFileExists, _ := PathExists(r.ConfFilePath); !confFileExists {
fmt.Println("Config File ", r.ConfFilePath, " is not exist!!")
return
}
data, err := ioutil.ReadFile(r.ConfFilePath)
if err != nil {
panic(err)
}
//将json数据解析到struct中
err = json.Unmarshal(data, r)
if err != nil {
panic(err)
}
}
//判断一个文件是否存在
func PathExists(path string) (bool, error) {
_, err := os.Stat(path)
if err == nil {
return true, nil
}
if os.IsNotExist(err) {
return false, nil
}
return false, err
}
func init() {
ConfigObject = &RabbitMqConf{
Host: os.Getenv("rb_host"),
Username: os.Getenv("rb_user"),
Password: os.Getenv("rb_pass"),
DBHost: os.Getenv("write_sql"),
DBuser: os.Getenv("write_user"),
DBpass: os.Getenv("write_pass"),
DBPort: "3306",
DBname: "xyu",
Driver: "mysql",
DBcharset: "utf8",
Port: 5672,
ConfFilePath: "conf/rmq.conf",
ReconnectionTime: 10 * time.Second,
}
ConfigObject.Reload()
// ConfigObject = &RabbitMqConf{
// DBHost: "rm-2ze364spvypz122fw8o.mysql.rds.aliyuncs.com",
// DBuser: "video",
// DBpass: "vlty&AxMwT$lmLv6bN8dkDuBYlh%N5pe",
// DBPort: "3306",
// DBname: "xyu",
// Driver: "mysql",
// DBcharset: "utf8",
// Username: "admin",
// Password: "admin",
// Host: "192.168.10.156",
// Port: 5672,
// ConfFilePath: "conf/rmq.conf",
// ReconnectionTime: 1 * time.Second,
// }
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment