update
continuous-integration/drone/push Build is passing Details

master
kgdxpr 4 years ago
parent 154cd25547
commit f1c17fc928

@ -4,6 +4,9 @@
<list default="true" id="0d4ad043-ffc9-484f-90ab-0d2e603f76d4" name="Default Changelist" comment="">
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/Business/MinIORelate/MinIORelateController/MinIORelateController.go" beforeDir="false" afterPath="$PROJECT_DIR$/Business/MinIORelate/MinIORelateController/MinIORelateController.go" afterDir="false" />
<change beforePath="$PROJECT_DIR$/Business/MinIORelate/MinIORelateDao/MinIORelateDao.go" beforeDir="false" afterPath="$PROJECT_DIR$/Business/MinIORelate/MinIORelateDao/MinIORelateDao.go" afterDir="false" />
<change beforePath="$PROJECT_DIR$/Config/Config.ini" beforeDir="false" afterPath="$PROJECT_DIR$/Config/Config.ini" afterDir="false" />
<change beforePath="$PROJECT_DIR$/Utils/ConfigUtil/ConfigUtil.go" beforeDir="false" afterPath="$PROJECT_DIR$/Utils/ConfigUtil/ConfigUtil.go" afterDir="false" />
</list>
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />

@ -22,18 +22,48 @@ func Routers(r *gin.RouterGroup) {
rr := r.Group("/minioRelate")
rr.GET("/getPostPolicyInfo", getPostPolicyInfo)
rr.GET("/GeneratePreviewUrl", GeneratePreviewUrl)
rr.GET("/SaveFileInfo", SaveFileInfo)
rr.GET("/generatePreviewUrl", generatePreviewUrl)
rr.GET("/saveFileInfo", saveFileInfo)
rr.GET("/getFileDownLoadUrl", getFileDownLoadUrl)
return
}
/**
ID
*/
func getFileDownLoadUrl(c *gin.Context) {
id := c.Query("id")
if id == "" {
c.JSON(http.StatusOK, gin.H{"success": false, "info": "文件id参数不允许为空"})
return
}
resMap, err := MinIORelateDao.GetDownLoadUrl(id)
if err != nil {
c.JSON(http.StatusOK, gin.H{"success": false, "info": "获取文件信息失败!"})
return
}
if len(resMap) == 0 {
c.JSON(http.StatusOK, gin.H{"success": false, "info": "未查询到文件信息!"})
return
}
originName := resMap["origin_name"]
storageKey := resMap["storage_key"]
storageBucket := resMap["storage_bucket"]
downloadUrl := ConfigUtil.MinioDownloadPrefix + storageBucket + "/" + storageKey
c.JSON(http.StatusOK, gin.H{"success": true, "download_url": downloadUrl, "origin_name": originName})
}
/**
2021-07-06
*/
func SaveFileInfo(c *gin.Context) {
func saveFileInfo(c *gin.Context) {
id := c.Query("id")
if id == "" {
c.JSON(http.StatusOK, gin.H{"success": false, "info": "文件id参数不允许为空"})
@ -100,7 +130,7 @@ func SaveFileInfo(c *gin.Context) {
2021-07-05
*/
func GeneratePreviewUrl(c *gin.Context) {
func generatePreviewUrl(c *gin.Context) {
id := c.Query("id")
if id == "" {
c.JSON(http.StatusOK, gin.H{"success": false, "info": "id参数不允许为空"})

@ -19,3 +19,11 @@ func GetFileKey(id string) (string, error) {
_, err := db.SQL(sql, id).Get(&key)
return key, err
}
func GetDownLoadUrl(id string) (map[string]string, error) {
sql := "select storage_url_prefix,storage_key,origin_name,storage_bucket from t_base_file where id=?"
var resMap = make(map[string]string)
_, err := db.SQL(sql, id).Get(&resMap)
return resMap, err
}

@ -33,6 +33,7 @@ minio_endpoint = 10.10.14.231:9000
minio_accessKeyId = minioadmin
minio_secretAccessKey = minioadmin
minio_bucket = dsideal
download_prefix = http://10.10.14.231:9000/
[obs]
obs_endpoint = https://obs.myhuaweicloud.com

@ -29,15 +29,16 @@ var (
MysqlPwd string
//REDIS配置
RedisIp string
RedisPort string
RedisDb string
RedisIp string
RedisPort string
RedisDb string
//minio
MinioEndPoint string
MinioAccessKeyId string
MinioSecretAccessKey string
MinioBucket string
MinioDownloadPrefix string
//obs
ObsEndPoint string
@ -111,6 +112,7 @@ func init() {
MinioAccessKeyId = iniParser.GetString("minio", "minio_accessKeyId")
MinioSecretAccessKey = iniParser.GetString("minio", "minio_secretAccessKey")
MinioBucket = iniParser.GetString("minio", "minio_bucket")
MinioDownloadPrefix = iniParser.GetString("minio", "download_prefix")
//obs
ObsEndPoint = iniParser.GetString("obs", "obs_endpoint")

Loading…
Cancel
Save