main.go

package main

import (
	"PanIndex/Util"
	"PanIndex/boot"
	"PanIndex/config"
	"PanIndex/entity"
	"PanIndex/jobs"
	"PanIndex/service"
	"flag"
	"fmt"
	"github.com/bluele/gcache"
	"github.com/gin-gonic/gin"
	"github.com/gobuffalo/packr/v2"
	uuid "github.com/satori/go.uuid"
	log "github.com/sirupsen/logrus"
	"github.com/unrolled/secure"
	"html/template"
	"io/ioutil"
	"net/http"
	"net/url"
	"os"
	"path/filepath"
	"strconv"
	"strings"
	"sync"
	"time"
)

//var configPath = flag.String("config", "config.json", "配置文件config.json的路径")
var Host = flag.String("host", "", "绑定host，默认为0.0.0.0")
var Port = flag.String("port", "", "绑定port，默认为5238")
var Debug = flag.Bool("debug", false, "调试模式，设置为true可以输出更多日志")
var DataPath = flag.String("data_path", "data", "数据存储目录，默认程序同级目录")
var CertFile = flag.String("cert_file", "", "/path/to/test.pem")
var KeyFile = flag.String("key_file", "", "/path/to/test.key")
var ConfigQuery = flag.String("cq", "", "获取配置参数，例如port")
var GC = gcache.New(100).LRU().Build()

func main() {
	flag.Parse()
	pr := boot.PrintConfig(*DataPath, *ConfigQuery)
	if pr {
		return
	}
	boot.Start(*Host, *Port, *Debug, *DataPath)
	r := gin.New()
	r.Use(gin.Logger())
	//设置Html模板
	r.SetHTMLTemplate(initTemplates())
	//设置静态资源文件
	initStaticBox(r)
	r.NoRoute(func(c *gin.Context) {
		path := c.Request.URL.Path
		method := c.Request.Method
		_, ad := c.GetQuery("admin")
		if strings.HasPrefix(path, "/api/") && !strings.HasPrefix(path, "/api/public") {
			requestToken := c.Query("token")
			if requestToken != config.GloablConfig.ApiToken {
				message := "Invalid api token"
				c.String(http.StatusOK, message)
				return
			}
		}
		if path == "/api/public/downloadMultiFiles" {
			downloadMultiFiles(c) //文件夹下载
		} else if path == "/api/public/files" {
			files(c) //查询目录下文件列表
		} else if path == "/api/public/transcode" {
			transcode(c) //转码测试
		} else if path == "/api/public/shortInfo" {
			shortInfo(c) //短链接&二维码
		} else if path == "/api/public/onedrive/exchangeToken" {
			oneExchangeToken(c) //交换token
		} else if path == "/api/public/onedrive/refreshToken" {
			oneRefreshToken(c) //刷新token
		} else if method == http.MethodGet && strings.HasPrefix(path, "/api/public/raw") {
			raw(c) //原始文件预览
		} else if method == http.MethodPost && strings.HasPrefix(path, "/api/public/autoAddPassword") {
			autoAddPassword(c) //文件、目录添加输入密码
		} else if method == http.MethodPost && strings.HasPrefix(path, "/api/public/autoRemovePassword") {
			autoRemovePassword(c) //文件、目录删除错误的输入密码
		} else if method == http.MethodPost && path == "/api/admin/save" {
			adminSave(c) //后台配置保存
		} else if method == http.MethodPost && path == "/api/admin/getAccount" {
			adminGetAccount(c) //查询账号信息
		} else if path == "/api/admin/deleteAccounts" {
			adminDeleteAccounts(c) //后台删除账号
		} else if path == "/api/admin/sortAccounts" {
			adminSortAccounts(c) //后台账号拖动排序
		} else if path == "/api/admin/updateCache" {
			updateCache(c) //后台刷新缓存
		} else if path == "/api/admin/updateCookie" {
			updateCookie(c) //后台刷新cookie
		} else if path == "/api/admin/setDefaultAccount" {
			setDefaultAccount(c) //设置默认账号
		} else if path == "/api/admin/config" {
			getConfig(c) //配置信息
		} else if path == "/api/admin/envToConfig" {
			envToConfig(c) //环境变量写入配置
		} else if path == "/api/admin/upload" {
			upload(c) //后台上传文件
		} else if ad {
			admin(c) //后台页面跳转
			//adminSystem(c) //后台页面跳转
		} else {
			isForbidden := checkReferer(c)
			if isForbidden == true {
				c.String(http.StatusForbidden, "403 Hotlink Forbidden")
				return
			} else {
				k, s := c.GetQuery("search")
				if s {
					search(c, k)
				} else {
					//短链跳转
					shortRedirect(c)
					//正常跳转
					index(c)
				}
			}
		}
	})
	log.Infoln("程序启动成功")
	if *CertFile != "" && *KeyFile != "" {
		//开启https
		p, _ := strconv.Atoi(config.GloablConfig.Port)
		r.Use(TlsHandler(p))
		r.RunTLS(fmt.Sprintf("%s:%s", config.GloablConfig.Host, config.GloablConfig.Port), *CertFile, *KeyFile)
	} else {
		r.Run(fmt.Sprintf("%s:%s", config.GloablConfig.Host, config.GloablConfig.Port))
	}
}

//防盗链检测
func checkReferer(c *gin.Context) bool {
	isForbidden := true
	if config.GloablConfig.EnableSafetyLink == "0" {
		//开启了防盗链
		isForbidden = false
	} else {
		host := c.Request.Host
		referer, err := url.Parse(c.Request.Referer())
		if err != nil {
			log.Warningln(err)
		}
		if referer != nil && referer.Host != "" {
			if referer.Host == host {
				//站内，自动通过
				isForbidden = false
			} else if referer.Host != host && len(config.GloablConfig.OnlyReferrer) > 0 {
				//外部引用，并且设置了防盗链，需要进行判断
				for _, rf := range strings.Split(config.GloablConfig.OnlyReferrer, ",") {
					if rf == referer.Host {
						isForbidden = false
						break
					}
				}
			} else {
				isForbidden = false
			}
		} else {
			if config.GloablConfig.IsNullReferrer == "1" {
				isForbidden = false
			} else {
				isForbidden = true
			}
		}
	}
	return isForbidden
}

func TlsHandler(port int) gin.HandlerFunc {
	return func(c *gin.Context) {
		secureMiddleware := secure.New(secure.Options{
			SSLRedirect: true,
			SSLHost:     ":" + strconv.Itoa(port),
		})
		err := secureMiddleware.Process(c.Writer, c.Request)
		// If there was an error, do not continue.
		if err != nil {
			return
		}
		c.Next()
	}
}

func initTemplates() *template.Template {
	themes := [6]string{"mdui", "mdui-light", "mdui-dark", "classic", "bootstrap", "materialdesign"}
	box := packr.New("templates", "./templates")
	/*data, _ := box.FindString("pan/admin/login-bak.html")
	tmpl := template.New("pan/admin/login-bak.html")
	if Util.FileExist("./templates/pan/admin/login-bak.html") {
		s, _ := ioutil.ReadFile("./templates/pan/admin/login-bak.html")
		data = string(s)
	}
	tmpl.Parse(data)
	data, _ = box.FindString("pan/admin/index.html")
	if Util.FileExist("./templates/pan/admin/index.html") {
		s, _ := ioutil.ReadFile("./templates/pan/admin/index.html")
		data = string(s)
	}
	tmpl.New("pan/admin/index.html").Parse(data)*/
	tmpl := template.New("")
	//添加后台模板
	templatesFileNames := []string{"base", "appearance", "common", "disk", "hide", "login", "pwd", "safety", "view"}
	addTemplatesFromFolder("admin", tmpl, box, templatesFileNames)
	for _, theme := range themes {
		tmpName := strings.Join([]string{"pan/", "/index.html"}, theme)
		tmpFile := strings.ReplaceAll(tmpName, "-dark", "")
		tmpFile = strings.ReplaceAll(tmpFile, "-light", "")
		data, _ := box.FindString(tmpFile)
		if Util.FileExist("./templates/" + tmpFile) {
			s, _ := ioutil.ReadFile("./templates/" + tmpFile)
			data = string(s)
		}
		tmpl.New(tmpName).Funcs(template.FuncMap{"unescaped": unescaped, "contains": strings.Contains}).Parse(data)
	}
	//添加详情模板
	viewTemplates := [10]string{"base", "img", "audio", "video", "code", "office", "ns", "pdf", "md", "epub"}
	for _, vt := range viewTemplates {
		tmpName := fmt.Sprintf("pan/%s/view-%s.html", "mdui", vt)
		data, _ := box.FindString(tmpName)
		if Util.FileExist("./templates/" + tmpName) {
			s, _ := ioutil.ReadFile("./templates/" + tmpName)
			data = string(s)
		}
		tmpl.New(tmpName).Funcs(template.FuncMap{"unescaped": unescaped, "contains": strings.Contains}).Parse(data)
	}
	return tmpl
}

//将文件夹里面的所有html添加为模板
func addTemplatesFromFolder(folder string, tmpl *template.Template, box *packr.Box, templatesFileNames []string) {
	for _, vt := range templatesFileNames {
		tmpName := fmt.Sprintf("pan/%s/%s.html", folder, vt)
		data, _ := box.FindString(tmpName)
		if Util.FileExist("./templates/" + tmpName) {
			s, _ := ioutil.ReadFile("./templates/" + tmpName)
			data = string(s)
		}
		tmpl.New(tmpName).Funcs(template.FuncMap{"unescaped": unescaped, "contains": strings.Contains}).Parse(data)
	}
}

func initStaticBox(r *gin.Engine) {
	staticBox := packr.New("static", "./static")
	if Util.FileExist("./static") {
		r.Static("/static", "./static")
	} else {
		r.StaticFS("/static", staticBox)
	}
}

var dls = sync.Map{}

//var dl = service.DownLock{}
func index(c *gin.Context) {
	tmpFile := strings.Join([]string{"pan/", "/index.html"}, config.GloablConfig.Theme)
	pwd := ""
	sColumn := config.GloablConfig.SColumn
	sOrder := config.GloablConfig.SOrder
	pwdCookie, err := c.Request.Cookie("dir_pwd")
	_, has := c.GetQuery("v")
	if err == nil {
		decodePwd, err := url.QueryUnescape(pwdCookie.Value)
		if err != nil {
			log.Warningln(err)
		}
		pwd = decodePwd
	}
	sc, err := c.Request.Cookie("SColumn")
	if err == nil {
		sColumn, err = url.QueryUnescape(sc.Value)
		if err != nil {
			log.Warningln(err)
		}
	}
	so, err := c.Request.Cookie("SOrder")
	if err == nil {
		sOrder, err = url.QueryUnescape(so.Value)
		if err != nil {
			log.Warningln(err)
		}
	}
	pathName := c.Request.URL.Path
	//pwd = Util.GetPwdFromCookie(pwd, pathName)
	if pathName != "/" && pathName[len(pathName)-1:] == "/" {
		pathName = pathName[0 : len(pathName)-1]
	}
	index := 0
	DIndex := ""
	if strings.HasPrefix(pathName, "/d_") {
		iStr := Util.GetBetweenStr(pathName, "_", "/")
		index, _ = strconv.Atoi(iStr)
		pathName = strings.ReplaceAll(pathName, "/d_"+iStr, "")
		DIndex = fmt.Sprintf("/d_%d", index)
	} else {
		DIndex = ""
	}
	if len(config.GloablConfig.Accounts) == 0 {
		//未绑定任何账号，跳转到后台进行配置
		c.Redirect(http.StatusFound, "/?admin")
		return
	}
	account := config.GloablConfig.Accounts[index]
	result := make(map[string]interface{})
	if pathName == "/" && config.GloablConfig.AccountChoose == "display" {
		result = service.AccountsToNodes(config.GloablConfig.Accounts, pwd)
	} else {
		result = service.GetFilesByPath(account, pathName, pwd, sColumn, sOrder, has)
	}
	result["HerokuappUrl"] = config.GloablConfig.HerokuAppUrl
	result["Mode"] = account.Mode
	result["PrePaths"] = Util.GetPrePath(result["Path"].(string))
	result["Config"] = config.GloablConfig
	result["Title"] = account.Name
	result["Accounts"] = config.GloablConfig.Accounts
	result["DIndex"] = DIndex
	result["AccountId"] = account.Id
	result["Footer"] = config.GloablConfig.Footer
	cookieTheme, error := c.Cookie("Theme")
	if error != nil {
		result["Theme"] = config.GloablConfig.Theme
	} else {
		result["Theme"] = cookieTheme
	}
	result["FaviconUrl"] = config.GloablConfig.FaviconUrl
	fs, ok := result["List"].([]entity.FileNode)
	if ok {
		if len(fs) == 1 && !fs[0].IsFolder && result["isFile"].(bool) {
			t := service.GetViewTemplate(fs[0])
			if has && t != "" {
				//跳转文件预览页面
				if account.Mode == "native" {
					result["downloadUrl"] = ""
				} else if account.Mode == "ftp" {
					result["downloadUrl"] = ""
				} else if account.Mode == "webdav" {
					result["downloadUrl"] = ""
				} else {
					var dl = service.DownLock{}
					/*dls.LoadOrStore(fs[0].FileId, dl)*/
					if _, ok := dls.Load(fs[0].FileId); ok {
						ss, _ := dls.Load(fs[0].FileId)
						dl = ss.(service.DownLock)
					} else {
						dl.FileId = fs[0].FileId
						dl.L = new(sync.Mutex)
						dls.LoadOrStore(fs[0].FileId, dl)
					}
					result["DownloadUrl"] = dl.GetDownlaodUrl(account, fs[0])
				}
				theme := strings.ReplaceAll(config.GloablConfig.Theme, "-dark", "")
				theme = strings.ReplaceAll(theme, "-light", "")
				tmpFile = fmt.Sprintf("pan/%s/view-%s.html", theme, t)
				c.HTML(http.StatusOK, tmpFile, result)
				return
			} else {
				//文件
				if result["HasPwd"].(bool) {
					//访问文件或是文件预览时， 如果密码错误或未输入密码
					//返回未授权的访问
					c.JSON(http.StatusUnauthorized, gin.H{
						"status": http.StatusUnauthorized,
						"msg":    "Unauthorized access, please add a password to the cookie.",
					})
					return
				}
				if account.Mode == "native" {
					c.Writer.Header().Add("Content-Disposition", fmt.Sprintf("attachment; filename=%s", fs[0].FileName))
					c.Writer.Header().Add("Content-Type", "application/octet-stream")
					c.File(fs[0].FileId)
					return
				} else if account.Mode == "ftp" {
					c.Writer.Header().Add("Content-Disposition", fmt.Sprintf("attachment; filename=%s", fs[0].FileName))
					c.Data(http.StatusOK, "application/octet-stream", Util.FtpReadFileToBytes(account, fs[0].FileId))
					return
				} else if account.Mode == "webdav" {
					c.Writer.Header().Add("Content-Disposition", fmt.Sprintf("attachment; filename=%s", fs[0].FileName))
					c.Data(http.StatusOK, "application/octet-stream", Util.WebDavReadFileToBytes(account, fs[0].FileId))
					return
				} else {
					var dl = service.DownLock{}
					/*dls.LoadOrStore(fs[0].FileId, dl)*/
					if _, ok := dls.Load(fs[0].FileId); ok {
						ss, _ := dls.Load(fs[0].FileId)
						dl = ss.(service.DownLock)
					} else {
						dl.FileId = fs[0].FileId
						dl.L = new(sync.Mutex)
						dls.LoadOrStore(fs[0].FileId, dl)
					}
					downUrl := dl.GetDownlaodUrl(account, fs[0])
					c.Redirect(http.StatusFound, downUrl)
					return
				}
			}
		}
	}
	c.HTML(http.StatusOK, tmpFile, result)
}

func search(c *gin.Context, key string) {
	sColumn := config.GloablConfig.SColumn
	sOrder := config.GloablConfig.SOrder
	tmpFile := strings.Join([]string{"pan/", "/index.html"}, config.GloablConfig.Theme)
	pathName := c.Request.URL.Path
	if pathName != "/" && pathName[len(pathName)-1:] == "/" {
		pathName = pathName[0 : len(pathName)-1]
	}
	index := 0
	DIndex := ""
	if strings.HasPrefix(pathName, "/d_") {
		iStr := Util.GetBetweenStr(pathName, "_", "/")
		index, _ = strconv.Atoi(iStr)
		pathName = strings.ReplaceAll(pathName, "/d_"+iStr, "")
		DIndex = fmt.Sprintf("/d_%d", index)
	} else {
		DIndex = ""
	}
	if len(config.GloablConfig.Accounts) == 0 {
		//未绑定任何账号，跳转到后台进行配置
		c.Redirect(http.StatusFound, "/?admin")
		return
	}
	sc, err := c.Request.Cookie("SColumn")
	if err == nil {
		sColumn, err = url.QueryUnescape(sc.Value)
		if err != nil {
			log.Warningln(err)
		}
	}
	so, err := c.Request.Cookie("SOrder")
	if err == nil {
		sOrder, err = url.QueryUnescape(so.Value)
		if err != nil {
			log.Warningln(err)
		}
	}
	account := config.GloablConfig.Accounts[index]
	result := service.SearchFilesByKey(key, sColumn, sOrder)
	result["HerokuappUrl"] = config.GloablConfig.HerokuAppUrl
	result["Mode"] = account.Mode
	result["PrePaths"] = Util.GetPrePath(result["Path"].(string))
	result["Title"] = account.Name
	result["Config"] = config.GloablConfig
	result["Accounts"] = config.GloablConfig.Accounts
	result["DIndex"] = DIndex
	result["AccountId"] = account.Id
	result["Footer"] = config.GloablConfig.Footer
	cookieTheme, error := c.Cookie("Theme")
	if error != nil {
		result["Theme"] = config.GloablConfig.Theme
	} else {
		result["Theme"] = cookieTheme
	}
	result["FaviconUrl"] = config.GloablConfig.FaviconUrl
	result["SearchKey"] = key
	c.HTML(http.StatusOK, tmpFile, result)
}

func downloadMultiFiles(c *gin.Context) {
	fileId := c.Query("fileId")
	accountId := c.Query("accountId")
	account := service.GetAccount(accountId)
	ua := c.Request.UserAgent()
	if account.Mode == "native" {
		dp := *DataPath
		if os.Getenv("PAN_INDEX_DATA_PATH") != "" {
			dp = os.Getenv("PAN_INDEX_DATA_PATH")
		}
		if dp == "" {
			dp = "data"
		}
		//src := service.GetPath(accountId, accountId)
		t := time.Now().Format("20060102150405")
		dst := dp + string(filepath.Separator) + t + ".zip"
		Util.Zip(dp+string(filepath.Separator)+t+".zip", fileId)
		c.Writer.Header().Add("Content-Disposition", fmt.Sprintf("attachment; filename=%s", t+".zip"))
		c.Writer.Header().Add("Content-Type", "application/octet-stream")
		fmt.Println("0")
		c.File(dst)
		os.Remove(dst)
		return
	} else {
		downUrl := service.GetDownlaodMultiFiles(account, fileId, ua)
		c.JSON(http.StatusOK, gin.H{"redirect_url": downUrl})
	}
}

func admin(c *gin.Context) {
	logout := c.Query("logout")
	adminModule := c.Query("admin")
	if adminModule == "" {
		adminModule = "common"
	}
	cookieTheme, error := c.Cookie("Theme")
	Theme := "mdui"
	if strings.HasPrefix(config.GloablConfig.Theme, "mdui") {
		Theme = config.GloablConfig.Theme
	}
	if error == nil {
		Theme = cookieTheme
	}
	sessionId, error := c.Cookie("sessionId")
	if logout != "" && logout == "true" {
		//退出登录
		GC.Remove(sessionId)
		c.HTML(http.StatusOK, "pan/admin/login.html",
			gin.H{"RedirectUrl": "login",
				"Error":      true,
				"Msg":        "退出成功",
				"Theme":      Theme,
				"FaviconUrl": config.GloablConfig.FaviconUrl})
	} else {
		configData := service.GetConfig()
		data := gin.H{"Config": configData, "Theme": Theme, "RedirectUrl": adminModule, "Version": boot.VERSION, "FaviconUrl": config.GloablConfig.FaviconUrl}
		if adminModule == "pwd" {
			pwdDirs := service.TransformPwdDirs(configData.PwdDirId)
			data["PwdDirs"] = pwdDirs
		}
		if adminModule == "hide" {
			hideFiles := service.TransformHideFiles(configData.HideFileId)
			data["HideFiles"] = hideFiles
		}
		if c.Request.Method == "GET" {
			if error == nil && sessionId != "" && GC.Has(sessionId) {
				//登录状态跳转首页
				c.HTML(http.StatusOK, fmt.Sprintf("pan/admin/%s.html", adminModule), data)
			} else {
				c.HTML(http.StatusOK, "pan/admin/login.html", gin.H{"RedirectUrl": "login", "Error": false, "Theme": Theme, "FaviconUrl": config.GloablConfig.FaviconUrl})
			}
		} else {
			//登录
			password, _ := c.GetPostForm("password")
			if password == config.GloablConfig.AdminPassword {
				//登录成功
				u1 := uuid.NewV4().String()
				c.SetCookie("sessionId", u1, 7*24*60*60, "/", "", false, true)
				GC.SetWithExpire(u1, u1, time.Hour*24*7)
				c.HTML(http.StatusOK, fmt.Sprintf("pan/admin/%s.html", adminModule), data)
			} else {
				c.HTML(http.StatusOK, "pan/admin/login.html", gin.H{"RedirectUrl": "login", "Error": true, "Theme": Theme, "FaviconUrl": config.GloablConfig.FaviconUrl, "Msg": "密码错误，请重试！"})
			}
		}
	}
}

func adminGetAccount(c *gin.Context) {
	id := c.Query("id")
	c.JSON(http.StatusOK, service.GetAccount(id))
}

func adminSave(c *gin.Context) {
	configMap := make(map[string]interface{})
	c.BindJSON(&configMap)
	service.SaveConfig(configMap)
	c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "配置已更新，部分配置重启后生效！"})
}

func adminDeleteAccounts(c *gin.Context) {
	delIds := []string{}
	c.BindJSON(&delIds)
	service.DeleteAccount(delIds)
	c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "删除成功！"})
}

func adminSortAccounts(c *gin.Context) {
	sortIds := []string{}
	c.BindJSON(&sortIds)
	service.SortAccounts(sortIds)
	c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "排序完成！"})
}

func getConfig(c *gin.Context) {
	c.JSON(http.StatusOK, service.GetConfig())
}

func updateCache(c *gin.Context) {
	accountId := c.PostForm("accountId")
	cachePath := c.PostForm("cachePath")
	account := service.GetAccount(accountId)
	if account.Mode == "native" {
		c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "当前网盘无需刷新操作！"})
	} else {
		if account.Status == -1 {
			c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "目录缓存中，请勿重复操作！"})
		} else {
			account.SyncDir = cachePath
			account.SyncChild = 0
			go jobs.SyncOneAccount(account)
			c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "正在缓存目录，请稍后刷新页面查看缓存结果！"})
		}
	}
}

func updateCookie(c *gin.Context) {
	id := c.Query("id")
	account := service.GetAccount(id)
	if account.Mode == "native" {
		c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "当前网盘无需刷新操作！"})
	} else {
		if account.CookieStatus == -1 {
			c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "cookie刷新中，请勿重复操作！"})
		} else {
			go jobs.AccountLogin(account)
			c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "正在刷新cookie，请稍后刷新页面查看缓存结果！"})
		}
	}
}

func setDefaultAccount(c *gin.Context) {
	id := c.Query("id")
	service.SetDefaultAccount(id)
	c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "默认账号设置成功！"})
}

func envToConfig(c *gin.Context) {
	service.EnvToConfig()
	c.JSON(http.StatusOK, gin.H{"status": 0, "msg": "同步配置"})
}

func upload(c *gin.Context) {
	accountId := c.PostForm("uploadAccount")
	path := c.PostForm("uploadPath")
	t := c.PostForm("type")
	msg := ""
	if t == "0" {
		msg = service.Upload(accountId, path, c)
	} else if t == "1" {
		service.Async(accountId, path)
		msg = "刷新缓存成功"
	} else if t == "2" {
		service.Upload(accountId, path, c)
		service.Async(accountId, path)
		msg = "上传并刷新成功"
	}
	c.JSON(http.StatusOK, gin.H{"status": 0, "msg": msg})
}
func oneExchangeToken(c *gin.Context) {
	clientId := c.PostForm("client_id")
	clientSecret := c.PostForm("client_secret")
	code := c.PostForm("code")
	redirectUri := c.PostForm("redirect_uri")
	zone := c.PostForm("zone")
	tokenInfo := Util.OneExchangeToken(zone, clientId, redirectUri, clientSecret, code)
	c.String(http.StatusOK, tokenInfo)
}
func oneRefreshToken(c *gin.Context) {
	clientId := c.PostForm("client_id")
	clientSecret := c.PostForm("client_secret")
	refreshToken := c.PostForm("refresh_token")
	redirectUri := c.PostForm("redirect_uri")
	zone := c.PostForm("zone")
	tokenInfo := Util.OneGetRefreshToken(zone, clientId, redirectUri, clientSecret, refreshToken)
	c.String(http.StatusOK, tokenInfo)
}
func raw(c *gin.Context) {
	path := c.Request.URL.Path
	//获取文件路径
	p := strings.ReplaceAll(path, "/api/public/raw", "")
	if p != "/" && p[len(p)-1:] == "/" {
		p = p[0 : len(p)-1]
	}
	index := 0
	if strings.HasPrefix(p, "/d_") {
		iStr := Util.GetBetweenStr(p, "_", "/")
		index, _ = strconv.Atoi(iStr)
		p = strings.ReplaceAll(p, "/d_"+iStr, "")
	}
	if len(config.GloablConfig.Accounts) == 0 {
		//未绑定任何账号，跳转到后台进行配置
		c.Redirect(http.StatusFound, "/?admin")
		return
	}
	account := config.GloablConfig.Accounts[index]
	data, contentType := service.GetFileData(account, p)

	if data == nil {
		c.String(http.StatusOK, "")
	} else {
		c.Data(http.StatusOK, contentType, data)
	}
	c.Abort()
}
func files(c *gin.Context) {
	parentPath := c.PostForm("parentPath")
	mediaType := c.PostForm("mediaType")
	sColumn := c.PostForm("sColumn")
	sOrder := c.PostForm("sOrder")
	accountId := c.PostForm("accountId")
	if sColumn == "" {
		sColumn = config.GloablConfig.SColumn
	}
	if sOrder == "" {
		sOrder = config.GloablConfig.SOrder
	}
	files := service.GetFiles(accountId, parentPath, sColumn, sOrder, mediaType)
	c.JSON(http.StatusOK, gin.H{
		"message": "success",
		"status":  0,
		"data":    files,
	})
}
func transcode(c *gin.Context) {
	accountId := c.Query("accountId")
	fileId := c.Query("fileId")
	c.String(http.StatusOK, Util.AliTranscoding(accountId, fileId))
	c.Abort()
}
func adminSystem(c *gin.Context) {
	c.HTML(http.StatusOK, "pan/admin/base.html", gin.H{})
	c.Abort()
}
func shortInfo(c *gin.Context) {
	accountId := c.PostForm("accountId")
	path := c.PostForm("path")
	prefix := c.PostForm("prefix")
	url, qrCode, msg := service.ShortInfo(accountId, path, prefix)
	c.JSON(http.StatusOK, gin.H{
		"short_url": url,
		"qr_code":   qrCode,
		"msg":       msg,
	})
	c.Abort()
}
func shortRedirect(c *gin.Context) {
	pathName := c.Request.URL.Path
	if pathName != "/" && pathName[len(pathName)-1:] == "/" {
		pathName = pathName[0 : len(pathName)-1]
	}
	paths := strings.Split(pathName, "/")
	if len(paths) == 3 && paths[1] == "s" {
		redirectUri := service.GetRedirectUri(paths[2])
		c.Redirect(http.StatusFound, redirectUri)
	}
	c.Abort()
}
func autoAddPassword(c *gin.Context) {
	oldDirPwd := c.PostForm("oldDirPwd")
	oldDirPwd, _ = url.QueryUnescape(oldDirPwd)
	newDirPwd := service.AutoAddPassword(oldDirPwd)
	c.JSON(http.StatusOK, gin.H{
		"newDirPwd": newDirPwd,
	})
}
func autoRemovePassword(c *gin.Context) {
	cookieDirPwd := c.PostForm("cookieDirPwd")
	fileId := c.PostForm("fileId")
	cookieDirPwd, _ = url.QueryUnescape(cookieDirPwd)
	fileId, _ = url.QueryUnescape(fileId)
	newDirPwd := service.AutoRemovePassword(cookieDirPwd, fileId)
	c.JSON(http.StatusOK, gin.H{
		"newDirPwd": newDirPwd,
	})
}
func unescaped(x string) interface{} { return template.HTML(x) }