'commit'

dsSupport/Business/Preview/PreviewController/PreviewController.go

@@ -15,12 +15,17 @@ import (
 func Routers(r *gin.RouterGroup) {
 	rr := r.Group("/preview")
 	//配置接口
-	rr.GET("/preview", preview)
+	rr.GET("/previewOffice", previewOffice)
 	return
 }
 
-//	http://127.0.0.1:9000/support/preview/preview
-func preview(c *gin.Context) {
+//	http://127.0.0.1:9000/support/preview/previewOffice
+/**
+功能：提供Office系列文件的预览功能
+作者：黄海
+时间：2020-07-15
+ */
+func previewOffice(c *gin.Context) {
 	//本地物理路径
 	uEnc :=c.Query("p")
 	uDec, err := base64.URLEncoding.DecodeString(uEnc)

dsSupport/CronTask/CleanPreviewFile.go

@@ -0,0 +1,10 @@
+package CronTask
+
+import (
+	"fmt"
+	"time"
+)
+
+func Task (){
+	fmt.Println("hello world", time.Now())
+}

dsSupport/Utils/ObsUtil/ObsUtil.go

@@ -122,7 +122,6 @@ func UploadFileMultiPart(key string,sourceFile string){
 			close(partChan)
 		}
 	}
-
 	completeMultipartUploadInput := &obs.CompleteMultipartUploadInput{}
 	completeMultipartUploadInput.Bucket = ConfigUtil.Bucket
 	completeMultipartUploadInput.Key = key

dsSupport/go.mod

@@ -9,6 +9,7 @@ require (
 	github.com/json-iterator/go v1.1.10 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.1 // indirect
+	github.com/robfig/cron/v3 v3.0.0
 	golang.org/x/sys v0.0.0-20200625212154-ddb9806d33ae // indirect
 	google.golang.org/protobuf v1.25.0 // indirect
 	gopkg.in/ini.v1 v1.57.0

dsSupport/go.sum

@@ -57,6 +57,8 @@ github.com/modern-go/reflect2 v1.0.1 h1:9f412s+6RmYXLWZSEzVVgPGK7C2PphHj5RJrvfx9
 github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
+github.com/robfig/cron/v3 v3.0.0 h1:kQ6Cb7aHOHTSzNVNEhmp8EcWKLb4CbiMW9h9VyIhO4E=
+github.com/robfig/cron/v3 v3.0.0/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=

dsSupport/main.go

@@ -1,8 +1,10 @@
 package main
 
 import (
+	"dsSupport/CronTask"
 	"dsSupport/Router"
 	"github.com/gin-gonic/gin"
+	"github.com/robfig/cron/v3"
 )
 
 func main(){
@@ -14,6 +16,20 @@ func main(){
 	// http://127.0.0.1:9000/M3u8/B7/B7318F5D-46B8-4AA1-8811-1A9D65528E19/B7318F5D-46B8-4AA1-8811-1A9D65528E19.m3u8
 	//r.Static("/M3u8", "./Target")
 
+	//定时任务
+	crontab:=cron.New(cron.WithSeconds())  //精确到秒
+
+	//定义定时器调用的任务函数
+	task := func() {
+		CronTask.Task()
+	}
+	//定时任务
+	spec := "0 0 */1 * * ?" //cron表达式，每1小时一次
+	// 添加定时任务
+	crontab.AddFunc(spec, task)
+	// 启动定时器
+	crontab.Start()
+
 	// 指定地址和端口号
 	r.Run(":9000")
 }