From 9d88c7c467f8d93af4aab9ba0b6d6c01c2ffc546 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期四, 20 八月 2020 20:35:30 +0800
Subject: [PATCH] add get buckets contrl

---
 controllers/sdk.go |  160 ++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 108 insertions(+), 52 deletions(-)

diff --git a/controllers/sdk.go b/controllers/sdk.go
index c2f2cc9..76e1570 100644
--- a/controllers/sdk.go
+++ b/controllers/sdk.go
@@ -4,7 +4,6 @@
 	"net/http"
 	"strconv"
 	"webserver/extend/code"
-	"webserver/extend/config"
 	"webserver/extend/util"
 	"webserver/middlewares/auth"
 	"webserver/service"
@@ -48,7 +47,7 @@
 // @Description 绠楁硶淇濆瓨
 // @Accept json
 // @Produce json
-// @Tags sdk
+// @Tags 绠楁硶
 // @Param reqMap body controllers.SdkVo true "浜鸿劯妫�娴�"
 // @Success 200 {string} json "{"code":200, msg:"璇锋眰澶勭悊鎴愬姛",data:"",success:true}"
 // @Failure 500 {string} json "{"code":500, msg:"璇锋眰澶辫触",data:"",success:false}"
@@ -74,16 +73,18 @@
 // @Summary 鏌ユ壘鎵�鏈夌畻娉�
 // @Description 鏌ユ壘鎵�鏈夌畻娉�
 // @Produce json
-// @Tags sdk
+// @Tags 绠楁硶
 // @Param sdkName query string false "鍙�夊弬鏁�"
+// @Param installed query bool true "鏌ュ凡瀹夎鎴栬�呮煡鎵�鏈�"
 // @Success 200 {string} json "{"code":200, msg:"璇锋眰澶勭悊鎴愬姛",data:"绠楁硶鍒楄〃",success:true}"
 // @Failure 500 {string} json "{"code":500, msg:"璇锋眰澶辫触",data:"[]",success:false}"
 // @Router /data/api-v/sdk/findAllSdk [GET]
 func (sc SdkController) FindAllSdk(c *gin.Context) {
 	sdkName := c.Query("sdkName")
+	installed, _ := strconv.ParseBool(c.Query("installed"))
 	logger.Debug("FindAllSdk sdkName:", sdkName)
 
-	sdks := service.GetSdkList("") //鏈満宸插畨瑁呯殑绠楁硶
+	sdks := service.GetSdkList("", installed) //鏈満宸插畨瑁呯殑绠楁硶
 
 	util.ResponseFormat(c, code.Success, sdks)
 }
@@ -92,7 +93,7 @@
 // @Summary 鏍规嵁id鑾峰彇绠楁硶淇℃伅
 // @Description 鏍规嵁id鑾峰彇绠楁硶淇℃伅
 // @Produce json
-// @Tags sdk
+// @Tags 绠楁硶
 // @Param id query string true "绠楁硶id锛屽繀濉�"
 // @Success 200 {string} json "{"code":200, msg:"璇锋眰澶勭悊鎴愬姛",data:"绠楁硶淇℃伅",success:true}"
 // @Failure 500 {string} json "{"code":500, msg:"璇锋眰澶辫触",data:"",success:false}"
@@ -135,7 +136,7 @@
 // @Summary 鏍规嵁taskId鑾峰彇绠楁硶淇℃伅
 // @Description 鏍规嵁taskId鑾峰彇绠楁硶淇℃伅
 // @Produce json
-// @Tags sdk
+// @Tags 绠楁硶
 // @Param taskId query string true "taskId锛屽繀濉�"
 // @Success 200 {string} json "{"code":200, msg:"璇锋眰澶勭悊鎴愬姛",data:"绠楁硶淇℃伅",success:true}"
 // @Failure 500 {string} json "{"code":500, msg:"璇锋眰澶辫触",data:"",success:false}"
@@ -159,7 +160,7 @@
 // @Description 绠楁硶瀹夎鍖呬笂浼�(鍒嗗潡妫�鏌�)
 // @Accept multipart/form-data
 // @Produce json
-// @Tags sdk
+// @Tags 绠楁硶
 // @Param chunkNumber formData int true "褰撳墠鏄鍑犱釜鍒嗗潡"
 // @Param chunkSize formData int true "姣忎竴鍧楃殑澶у皬"
 // @Param currentChunkSize formData int true "褰撳墠鍧楃殑澶у皬"
@@ -211,7 +212,7 @@
 // @Description 绠楁硶瀹夎鍖呬笂浼�
 // @Accept multipart/form-data
 // @Produce json
-// @Tags sysset
+// @Tags 绠楁硶
 // @Param chunkNumber formData int true "褰撳墠鏄鍑犱釜鍒嗗潡"
 // @Param chunkSize formData int true "姣忎竴鍧楃殑澶у皬"
 // @Param currentChunkSize formData int true "褰撳墠鍧楃殑澶у皬"
@@ -258,59 +259,114 @@
 		Header:           header,
 	}
 	var sv service.SysService
-	if b,isComplete := sv.PatchUpload(&arg); b {
-		if isComplete { //涓婁紶瀹屾瘯闇�瑕佽嚜鍔ㄨЕ鍙戝畨瑁�
-			var sv service.SdkInstallService
-			if b,err := sv.SdkInstall(identifier, filename);b {
-				util.ResponseFormat(c,&code.Code{http.StatusOK, true, "绠楁硶瀹夎鎴愬姛"},"绠楁硶瀹夎鎴愬姛")
-				return
-			} else {
-				util.ResponseFormat(c,&code.Code{http.StatusBadRequest, false, "绠楁硶瀹夎澶辫触"},err.Error())
-				return
-			}
-		}
-		util.ResponseFormat(c, code.Success, "")
+	if b,_ := sv.PatchUpload(&arg); b {
+		//if isComplete { //涓婁紶瀹屾瘯闇�瑕佽嚜鍔ㄨЕ鍙戝畨瑁�
+		//	var sv service.SdkInstallService
+		//	if b,err := sv.SdkInstall(identifier, filename);b {
+		//		util.ResponseFormat(c,&code.Code{http.StatusOK, true, "绠楁硶瀹夎鎴愬姛"},"绠楁硶瀹夎鎴愬姛")
+		//		return
+		//	} else {
+		//		util.ResponseFormat(c,&code.Code{http.StatusBadRequest, false, "绠楁硶瀹夎澶辫触"},err.Error())
+		//		return
+		//	}
+		//}
+		util.ResponseFormat(c, code.Success, "涓婁紶瀹屾垚")
 	} else {
 		util.ResponseFormat(c, code.ComError, "")
 	}
 }
 
-func (sc SdkController) SdkDownLoad(c *gin.Context) {
-	var soApi dbapi.SdkApi
-	var sdkConfig map[string]interface{}
+// @Security ApiKeyAuth
+// @Summary 涓婁紶瀹屾垚鑾峰彇瀹夎淇℃伅
+// @Description 涓婁紶瀹屾垚鑾峰彇瀹夎淇℃伅
+// @Produce json
+// @Tags 绠楁硶
+// @Param identifier formData string true "鏁翠釜鏂囦欢鐨勫敮涓�鏍囪瘑锛岀洰鍓嶆槸md5"
+// @Param filename formData string true "鏂囦欢鍚嶇О"
+// @Success 200 {string} json "{"code":200, msg:"", success:true}"
+// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
+// @Router /data/api-v/sdk/showInstallInfo [post]
+func (sc SdkController) ShowInstallInfo(c *gin.Context) {
+	identifier := c.Request.FormValue("identifier")
+	filename := c.Request.FormValue("filename")
+	var sv service.SdkInstallService
+	b,d, err := sv.ShowInstallInfo(identifier, filename)
+	if b {
+		util.ResponseFormat(c,code.Success, d)
+	} else {
+		util.ResponseFormat(c,&code.Code{http.StatusInternalServerError, false, err.Error()}, err.Error())
+	}
+}
 
+// @Security ApiKeyAuth
+// @Summary 涓婁紶瀹屾垚寮�濮嬪畨瑁�
+// @Description 涓婁紶瀹屾垚寮�濮嬪畨瑁�
+// @Produce json
+// @Tags 绠楁硶
+// @Param identifier formData string true "鏁翠釜鏂囦欢鐨勫敮涓�鏍囪瘑锛岀洰鍓嶆槸md5"
+// @Param filename formData string true "鏂囦欢鍚嶇О"
+// @Success 200 {string} json "{"code":200, msg:"", success:true}"
+// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
+// @Router /data/api-v/sdk/install [post]
+func (sc SdkController) Install(c *gin.Context) {
+	identifier := c.Request.FormValue("identifier")
+	filename := c.Request.FormValue("filename")
+
+	var sv service.SdkInstallService
+	if b,err := sv.SdkInstall(identifier, filename);b {
+		util.ResponseFormat(c,&code.Code{http.StatusOK, true, "绠楁硶瀹夎鎴愬姛"},"绠楁硶瀹夎鎴愬姛")
+		return
+	} else {
+		util.ResponseFormat(c,&code.Code{http.StatusBadRequest, false, err.Error()},err.Error())
+		return
+	}
+}
+
+// @Security ApiKeyAuth
+// @Summary 浠庡晢鍩庝笅杞芥垨鍗囩骇绠楁硶
+// @Description 浠庡晢鍩庝笅杞芥垨鍗囩骇绠楁硶
+// @Produce json
+// @Tags 绠楁硶
+// @Param path query string true "绠楁硶id"
+// @Success 200 {string} json "{"code":200, msg:"", success:true}"
+// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
+// @Router /data/api-v/sdk/sdkDownload [get]
+func (sc SdkController) SdkDownLoad(c *gin.Context) {
 	sdkId, exist := c.GetQuery("path")
 	if !exist {
-		util.ResponseFormat(c, code.ComError, "涓嬭浇鐨勭畻娉曞弬鏁版湁璇�")
+		util.ResponseFormat(c, code.RequestParamError, "涓嬭浇鐨勭畻娉曞弬鏁版湁璇�")
+		return
 	}
 
-	logger.Info(sdkId)
-
-	// 鍏堟煡鎵炬湰鍦扮洰褰曞唴鏄惁宸插瓨鍦ㄧ畻娉晄o, 娌℃湁璧颁簯绔笅杞�
-	if sdkConfig = service.FindLocalSdkSoById(sdkId); sdkConfig == nil {
-		sdkConfig = service.DownSdk(sdkId)
+	if b,err := service.DownloadOrUpgrade(sdkId);b {
+		util.ResponseFormat(c, code.Success, "绠楁硶瀹夎鎴愬姛")
+	} else {
+		util.ResponseFormat(c, &code.Code{http.StatusBadRequest, false, err.Error()}, err.Error())
 	}
-
-	if sdkConfig != nil {
-		if regSdkSuccess, _ := soApi.Register(sdkConfig); regSdkSuccess {
-			util.ResponseFormat(c, code.Success, "涓嬭浇绠楁硶鎴愬姛锛�")
-			return
-		}
-	}
-
-	flag := c.Query("needUpdateMiddle")
-	// 涓嬭浇绠楁硶锛堟湁鏃跺�欎篃闇�瑕佹妸涓棿浠朵竴璧蜂笅杞戒笅鏉ワ級
-	if flag == "true" {
-		// 涓嬭浇骞舵洿鏂颁腑闂翠欢,甯︿笂MD5鏍¢獙
-		flag1, err := service.DownSo("http://" + config.SoPath.Ip + ":" + config.SoPath.Port + "/" + "middleware.so")
-		logger.Debug("涓棿浠惰矾寰勶細", "http://"+config.SoPath.Ip+":"+config.SoPath.Port+"/"+"middleware.so")
-		if err != nil {
-			logger.Info(err)
-		}
-		if !flag1 {
-			util.ResponseFormat(c, code.ComError, "璇烽噸鏂颁笅杞界畻娉�")
-		}
-	}
-
-	util.ResponseFormat(c, code.ComError, "绠楁硶涓嬭浇澶辫触,璇烽噸璇�")
 }
+
+// @Security ApiKeyAuth
+// @Summary 浣跨敤婵�娲荤爜婵�娲诲畨瑁呯畻娉�
+// @Description 浣跨敤婵�娲荤爜婵�娲诲畨瑁呯畻娉�
+// @Produce json
+// @Tags 绠楁硶
+// @Param code query string true "婵�娲荤爜"
+// @Param sdkId query string true "绠楁硶id"
+// @Success 200 {string} json "{"code":200, msg:"", success:true}"
+// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
+// @Router /data/api-v/sdk/active [get]
+func (sc SdkController) Active(c *gin.Context) {
+	cod := c.GetString("code")
+	sdkId := c.GetString("sdkId")
+	if cod == "" || sdkId == "" {
+		util.ResponseFormat(c, code.RequestParamError, "婵�娲荤爜鍜岀畻娉昳d涓嶈兘涓虹┖")
+		return
+	}
+	var sv service.SdkInstallService
+	d, err := sv.Active(cod, sdkId)
+	if err == nil {
+		util.ResponseFormat(c,code.Success,  d)
+	} else {
+		util.ResponseFormat(c,code.ComError, err.Error())
+	}
+}
\ No newline at end of file

--
Gitblit v1.8.0