merge test

README.me

+gf demo

app/api/file.go

+package api
+
+import (
+	"ppt_server/app/model"
+	"ppt_server/app/service"
+	"ppt_server/library/response"
+	"ppt_server/packed/file"
+
+	"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)
+	}
+	// 检测课件格式
+	parserFile, err := file.Upload(&req, service.File.Done, service.File.Ok)
+	if err != nil {
+		response.Fail(r, err)
+	}
+	go service.File.Upload(parserFile)
+	response.Success(r)
+}

app/dao/internal/xyu_room.go

+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

+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

+package dao
+
+import "ppt_server/app/dao/internal"
+
+type xyuRoomDao struct {
+	internal.XyuRoomDao
+}
+
+var XyuRoom = xyuRoomDao{internal.XyuRoom}

app/dao/xyu_room_files.go

+package dao
+
+import "ppt_server/app/dao/internal"
+
+type xyuRoomFilesDao struct {
+	internal.XyuRoomFilesDao
+}
+
+var XyuRoomFile = xyuRoomFilesDao{
+	internal.XyuRoomFiles,
+}

app/model/file.go

+package model
+
+import (
+	"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#课件名称不能为空"`
+		NickName string `p:"nickname" v:"required#用户昵称不能为空"`
+		Type     int    `p:"type"`
+		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    []string        `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

+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

+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

+package service
+
+import (
+	"ppt_server/app/dao"
+	"ppt_server/app/model"
+	"ppt_server/packed/file"
+
+	"github.com/gogf/gf/frame/g"
+)
+
+var File = &fileService{
+	Done: make(chan error),
+	Ok:   make(chan bool),
+}
+
+type fileService struct {
+	Done chan error
+	Ok   chan bool
+}
+
+// 上传课件
+func (f *fileService) Upload(file *file.ObtainFile) {
+	// 检查房间是否存在
+	var room model.XyuRoom
+	err := dao.XyuRoom.Where(dao.XyuRoom.Columns.RoomNum, file.R.RoomNum).Scan(&room)
+
+	// 上传操作
+	go file.Worker(err)
+
+	// 回调通知
+	select {
+	case <-f.Done:
+		// 上传失败
+		file.Fail()
+		return
+	case <-f.Ok:
+		// 上传成功
+		count, err := dao.XyuRoomFile.Where(dao.XyuRoomFile.Columns.RoomId, room.Id).
+			Where(dao.XyuRoomFile.Columns.Name, file.R.Name).Count()
+		if err != nil {
+			g.Log().Async().Errorf("Mysql Err: %s\n", err)
+			return
+		}
+		// 数据库已经存在不需要通知
+		if count == 1 {
+			return
+		}
+		file.Success(room.Id)
+		return
+	}
+}

boot/boot.go

+package boot
+
+import (
+	"fmt"
+	"github.com/gogf/gf/frame/g"
+	"github.com/gogf/gf/net/ghttp"
+	"os"
+)
+
+
+
+func init() {
+
+	link := fmt.Sprintf("mysql:%s:%s@tcp(%s:3306)/xyu",
+		os.Getenv("read_user"),
+		os.Getenv("read_pass"),
+		os.Getenv("read_sql"))
+	_ = g.Config().Set("database.link", link)
+
+	g.Server().SetNameToUriType(ghttp.URI_TYPE_CAMEL)
+
+	g.Log().SetAsync(true)
+}

conf/2817229__offcncloud.com.key

------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

------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

-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

+# 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-internal.aliyuncs.com"
+    point  = "oss-cn-beijing-internal.aliyuncs.com"
+    bucket = "xiaoyu-live"
+
+ # 下载zip包存储目录
+ [temp]
+    path = "/data/files/"
+
+# Database.
+[database]
+    debug = false
+    # Database logger.
+    [database.logger]
+        Path   = "/tmp/log/gf-app/sql"
+        Level  = "all"
+        Stdout = true

controllers/upload.go

-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

 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
 )

interfaces/interfaces.go

+/**
+* @Authore: lifeifei
+* @Date: 2021/7/22 2:08 下午
+ */
+package interfaces
+
+// 分组路由
+type Router interface {
+	Init()
+}

library/http/http_client.go

+package http
+
+import (
+	"fmt"
+	"io"
+	"os"
+	"strings"
+	"time"
+
+	"github.com/gogf/gf/frame/g"
+	"github.com/gogf/gf/net/ghttp"
+	"github.com/gogf/gf/util/gconv"
+)
+
+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
+}
+
+type WriteCounter struct {
+	Total uint64
+	Length uint64
+}
+
+func (wc *WriteCounter) Write(p []byte) (int, error) {
+	n := len(p)
+	wc.Total += uint64(n)
+	wc.PrintProgress()
+	return n, nil
+}
+
+func (wc WriteCounter) PrintProgress() {
+	// Clear the line by using a character return to go back to the start and remove
+	// the remaining characters by filling it with spaces
+	fmt.Printf("\r%s", strings.Repeat(" ", 35))
+
+	// Return again and print current status of download
+	// We use the humanize package to print the bytes in a meaningful way (e.g. 10 MB)
+	fmt.Printf("\rDownloading... %s complete", fmt.Sprintf("%.2f", gconv.Float64(wc.Total)/gconv.Float64(wc.Length) * 100) + "%")
+}
+
+
+
+
+// 下载文件
+func Download(file string, path string) error {
+	g.Log().Async().Infof("Download File: %s", path)
+	resp, err := g.Client().Get(file)
+
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	// 创建一个文件用于保存
+	out, err := os.Create(path)
+	if err != nil {
+		return err
+	}
+
+
+
+	defer out.Close()
+
+	// 然后将响应流和文件流对接起来
+	counter := &WriteCounter{Length: gconv.Uint64(resp.Header.Get("Content-Length"))}
+	_, err = io.Copy(out, io.TeeReader(resp.Body, counter))
+
+	if err != nil && err == io.EOF {
+		return nil
+	}
+	if err != nil {
+		return err
+	}
+	fmt.Print("\n")
+	return nil
+}

library/http/session_http_client.go

+/**
+* @Authore: lifeifei
+* @Date: 2021/7/21 4:26 下午
+ */
+package http
+
+import (
+	"net/http"
+	"net/http/cookiejar"
+	"time"
+
+	"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 handle(client.c.Timeout(10*time.Second).Post(link, data))
+}
+
+func (client *SessionHttpClient) Get(url string) ([]byte, error) {
+	return handle(client.c.Timeout(10 * time.Second).Get(url))
+
+}

library/oss/oss.go

+/**
+* @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

+/**
+* @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(),
+		})
+	}
+
+}

middleware/middleware.go

+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

-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/file_notify.go

+package file
+
+import (
+	"encoding/json"
+	"os"
+
+	"ppt_server/app/model"
+	"ppt_server/library/http"
+
+	"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   *http.SessionHttpClient
+}
+
+func newNotify() *notify {
+	return &notify{
+		url:      g.Cfg().GetString("notify.url"),
+		name:     os.Getenv("live_name"),
+		password: os.Getenv("live_pwd"),
+		client:   http.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) notice(path string, data g.Map) error {
+	if err := n.auth(data); err != nil {
+		return err
+	}
+	g.Log().Async().Infof("Notify Success!")
+	return n.verify(n.url+path, data)
+}

packed/file/file_parser.go

+package file
+
+import (
+	"fmt"
+	"mime"
+	"net/http"
+	"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 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.NewCode(http.StatusBadRequest, "上传URL格式不正确")
+	}
+	f := &parser{
+		ext:       path.Ext(ossFileLink),
+		url:       ossFileLink,
+		path:      parseURLPath["path"],
+		slicePath: slicePath,
+		name:      path.Base(ossFileLink),
+	}
+
+	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.dataPath())
+}
+
+// 临时存储解析包地址
+func (f *parser) splitTempZipLink() string {
+	return fmt.Sprintf("%s%s.zip", g.Cfg().GetString("temp.path"), f.slicePath[2])
+}
+
+// 获取文件名称
+func (f *parser) filename() string {
+	return f.name
+}
+
+// 上传课件路径
+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.splitUploadPath() + gurl.Encode(f.slicePath[len(f.slicePath)-1:][0])
+}
+
+// 解析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 "1"
+	}
+}
+
+// 获取文件mine
+func (f *parser) mineType() string {
+	_ = mime.AddExtensionType(".pptx", "application/vnd.openxmlformats-officedocument.presentationml.presentation")
+	_ = mime.AddExtensionType(".ppt", "application/vnd.ms-powerpoint")
+	return mime.TypeByExtension(f.ext)
+}

packed/file/file_upload.go

+package file
+
+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/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 bool                // 上传课件响应成功
+	err       chan error               // 上传课件失败Error
+	fileSize  int64                    // 课件大小
+	pageCount int                      // 课件图片数量
+	parser    *parser                  // 课件对象
+	n         *notify                  // 事件通知
+	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]+)[.].*`)
+
+
+func Upload(r *model.FileUploadRequest, errChan chan error,
+	ok chan bool) (file *ObtainFile, err error) {
+
+	f, err := parseURL(r.Url)
+	if err != nil {
+		return nil, err
+	}
+
+	file = &ObtainFile{
+		ok:     ok,
+		err:    errChan,
+		parser: f,
+		R:      r,
+		packed: &model.Packed{
+			FileName:      f.filename(),
+			Hash:          f.contentHash(),
+			OssImagesPath: f.splitUploadPath() + "images/",
+		},
+		n: newNotify(),
+	}
+	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}
+
+	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)
+			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 {
+	for i := 1; i <= f.pageCount; i++ {
+		f.packed.ImagesName = append(f.packed.ImagesName, fmt.Sprintf("%05d", i) +".png")
+	}
+	packedBytes, err := json.Marshal(f.packed)
+	if err != nil {
+		return  err
+	}
+	return oss.Upload(f.parser.splitUploadPath()+"packed.json", bytes.NewReader(packedBytes))
+}
+
+// 拼接下载zip包地址
+func (f *ObtainFile) splitDownloadLink() string {
+	return  fmt.Sprintf("%s?info=1&words=%v&ssl=1&furl=%s/%s",
+		parserFileLink, f.pageCount, g.Cfg().GetString("oss.url"),
+		f.parser.dataPath())
+}
+
+func (f *ObtainFile) deferWorker(err error) {
+	// 清理ZIP包
+	_ = os.Remove(f.parser.splitTempZipLink())
+	// 通知
+	if err != nil {
+		g.Log().Async().Error(err)
+		f.err <- err
+		return
+	}
+	f.ok <- true
+}
+
+// 进行解析上传操作
+func (f *ObtainFile) Worker(err error) {
+	defer func() {
+		f.deferWorker(err)
+	}()
+	if err != nil {
+		return
+	}
+	// 解析课件获取课件信息
+	if err = f.fileInfo(); err != nil {
+		return
+	}
+	g.Log().Async().Infof("[1] file: %s file info complete", f.parser.filename())
+
+	// 下载ZIP包
+	if err = http.Download(f.splitDownloadLink(), f.parser.splitTempZipLink()); err != nil {
+		return
+	}
+	g.Log().Async().Infof("[2] file: %s zip donwload complete", f.parser.filename())
+
+	// 解析ZIP包并上传图片到OSS
+	if err = f.uploadPicture(); err != nil {
+		return
+	}
+	g.Log().Async().Infof("[3] file: %s picture upload oss complete", f.parser.filename())
+
+	// 上传packed.json到oss
+	if err = f.uploadPacked(); err != nil {
+		return
+	}
+	g.Log().Async().Infof("[4] file: %s upload complete!", f.parser.filename())
+}
+
+// 上传失败通知
+func (f *ObtainFile) Fail() {
+	if err := f.n.notice("/web/room_files_error", g.Map{
+		"code":     400,
+		"uuid":     f.R.Uuid,
+		"room_num": f.R.RoomNum,
+		"path":     f.parser.dataPath(),
+	}); err != nil {
+		g.Log().Async().Error(err)
+	}
+}
+
+// 上传成功通知
+func (f *ObtainFile) Success(roomID int) {
+
+	if err := f.n.notice("/web/room_files_add", g.Map{
+		"name":           f.R.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.NickName,
+		"uuid":           f.R.Uuid,
+		"room_id":        roomID,
+		"is_courseware" : 1,
+	}); err != nil {
+		g.Log().Async().Error(err)
+	}
+}

router/api/file.go

+/**
+* @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

+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

-// @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

-/**
-* @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

-/**
-* @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

-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

-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,
-// 	}
-
-}