fix

services/base_from_smm_http.go

@@ -49,134 +49,6 @@ type SmmResp struct {
 	Data SmmResponse `json:"data"`
 }
 
-// smmPostCurl post请求同花顺接口
-//func smmPostCurl(urlStr string, dataMap map[string]io.Reader, num int, token string) (body []byte, err error, errMsg string) {
-//	logMsg := ``
-//	defer func() {
-//		if err != nil {
-//			if logMsg != `` {
-//				errMsg = logMsg
-//				go alarm_msg.SendAlarmMsg("post请求SMM接口失败，ERR："+err.Error()+";errMsg:"+errMsg, 3)
-//			}
-//		}
-//	}()
-//	// 创建一个新的buffer，用于存储请求体
-//	var reqBody bytes.Buffer
-//	writer := multipart.NewWriter(&reqBody)
-//
-//	// 添加Form-data参数
-//	for key, value := range dataMap {
-//		part, err := writer.CreateFormFile(key, key)
-//		if err != nil {
-//			fmt.Println("Error creating form file:", err)
-//			return
-//		}
-//		_, err = io.Copy(part, value)
-//		if err != nil {
-//			fmt.Println("Error copying file content:", err)
-//			return
-//		}
-//	}
-//
-//	// 关闭multipart writer
-//	writer.Close()
-//
-//	// 发送POST请求
-//	req, err := netHttp.NewRequest("POST", urlStr, &reqBody)
-//	if err != nil {
-//		fmt.Println("Error creating request:", err)
-//		return
-//	}
-//
-//	req.Header.Set("Content-Type", writer.FormDataContentType())
-//
-//	client := &netHttp.Client{}
-//	resp, err := client.Do(req)
-//	if err != nil {
-//		fmt.Println("Error sending request:", err)
-//		return
-//	}
-//	defer resp.Body.Close()
-//
-//	// 处理响应
-//	fmt.Println("Response Status:", resp.Status)
-//
-//	body, err = ioutil.ReadAll(resp.Body)
-//	if err != nil {
-//		fmt.Println("Error reading response body:", err)
-//		return
-//	}
-//	utils.FileLog.Info("SMM刷新token:" + string(body))
-//
-//	var response SmmResponse
-//	err = json.Unmarshal(body, &response)
-//	if err != nil {
-//		utils.FileLog.Info("post Err:", err.Error(), ";url:", urlStr, ";response:", string(body))
-//		err = errors.New("Unmarshal Err:" + err.Error())
-//		return
-//	}
-//	utils.FileLog.Info(fmt.Sprint("post request url:", urlStr, ";token:", token, ";response:", string(body)))
-//	logMsg = fmt.Sprint("post request url:", urlStr, ";token:", token, ";response:", string(body))
-//
-//	//如果是token失效，同时只是第一次请求（没有尝试强制刷新token，那么重新请求）
-//	if utils.InArrayByInt([]int{-10020001, -10020002}, int(response.Code)) && num <= 0 {
-//		//token失效
-//		token, err = refreshSmmAccessToken()
-//		if err != nil {
-//			return
-//		}
-//		num++
-//		return smmPostCurl(urlStr, dataMap, num, token)
-//	} else if response.Code != 0 {
-//		utils.FileLog.Info(fmt.Sprint("post data err:", response.Msg, ";url:", urlStr, ";response:", string(body)))
-//		err = errors.New(response.Msg)
-//		return
-//	}
-//
-//	return
-//}
-
-// GetSmmAccessToken 获取accessToken
-//func GetSmmAccessToken(isRefresh bool) (token string, err error) {
-//	defer func() {
-//		if err != nil {
-//			go alarm_msg.SendAlarmMsg("获取SMM的token失败，ERR："+err.Error(), 3)
-//		}
-//	}()
-//	redisKey := utils.CACHE_EDB_SMM_SERVER_TOKEN
-//	token, redisErr := utils.Rc.RedisString(redisKey)
-//	//如果从redis中accessToken 获取失败或者token为空了，再或者需要强制刷新了，那么重新获取accessToken
-//	if redisErr != nil || token == `` || isRefresh {
-//		token, _ = refreshSmmAccessToken()
-//		return
-//	}
-//	return
-//}
-
-// refreshSmmAccessToken 强制刷新获取accessToken
-//func refreshSmmAccessToken() (token string, err error) {
-//	defer func() {
-//		if err != nil {
-//			go alarm_msg.SendAlarmMsg("刷新SMM的token失败；ERR："+err.Error(), 3)
-//		}
-//	}()
-//	tokenInfo, tmpErr := getSmmAccessToken()
-//	if tmpErr != nil {
-//		err = tmpErr
-//		return
-//	}
-//	token = tokenInfo.Token
-//
-//	//token存入redis
-//	redisKey := utils.CACHE_EDB_SMM_SERVER_TOKEN
-//	err = utils.Rc.Put(redisKey, token, time.Hour*24*7)
-//	if err != nil {
-//		err = fmt.Errorf("获取SMM的token成功；SMM token存入redis失败，ERR：%s", err.Error())
-//		return
-//	}
-//	return
-//}
-
 type GetSmmTokenResp struct {
 	Code int          `json:"code"`
 	Msg  string       `json:"msg"`