修改包名

.gitignore

@@ -1,8 +1,8 @@
-/hongze_public_api.exe
+/eta_pub.exe
 /lastupdate.tmp
 /rdlucklog
 /.idea
 /conf
 .DS_Store
-/hongze_public_api
-hongze_public_api
+/eta_pub
+eta_pub

controllers/base_auth.go

@@ -2,21 +2,21 @@ package controllers
 
 import (
 	"encoding/json"
+	"eta/eta_pub/models"
+	"eta/eta_pub/services/alarm_msg"
+	"eta/eta_pub/utils"
 	"fmt"
+	"github.com/beego/beego/v2/server/web"
 	"github.com/rdlucklib/rdluck_tools/log"
-	"hongze/hongze_public_api/models"
-	"hongze/hongze_public_api/services/alarm_msg"
-	"hongze/hongze_public_api/utils"
 	"net/http"
 	"net/url"
-	"github.com/beego/beego/v2/server/web"
 )
 
 var apiLog *log.Log
 
 func init() {
 	if utils.RunMode == "release" {
-		logDir := `/data/rdlucklog/hongze_public_api`
+		logDir := `/data/rdlucklog/eta_pub`
 		apiLog = log.Init("20060102.api", logDir)
 	} else {
 		apiLog = log.Init("20060102.api")

controllers/base_common.go

@@ -2,10 +2,10 @@ package controllers
 
 import (
 	"encoding/json"
+	"eta/eta_pub/services/alarm_msg"
+	"eta/eta_pub/utils"
 	"fmt"
 	"github.com/beego/beego/v2/server/web"
-	"hongze/hongze_public_api/services/alarm_msg"
-	"hongze/hongze_public_api/utils"
 	"net/http"
 	"net/url"
 )
@@ -38,7 +38,7 @@ func (c *BaseCommonController) ServeJSON(encoding ...bool) {
 		hasEncoding = true
 	}
 	if c.Data["json"] == nil {
-		msg := "接口:"+"URI:"+c.Ctx.Input.URI()+";无返回值"
+		msg := "接口:" + "URI:" + c.Ctx.Input.URI() + ";无返回值"
 		go alarm_msg.SendAlarmMsg(msg, 3)
 		return
 	}

controllers/image.go

@@ -2,11 +2,11 @@ package controllers
 
 import (
 	"encoding/json"
+	"eta/eta_pub/models"
+	"eta/eta_pub/services"
+	"eta/eta_pub/services/ppt2img"
+	"eta/eta_pub/utils"
 	"fmt"
-	"hongze/hongze_public_api/models"
-	"hongze/hongze_public_api/services"
-	"hongze/hongze_public_api/services/ppt2img"
-	"hongze/hongze_public_api/utils"
 	"io/ioutil"
 	"os"
 	"os/exec"
@@ -161,7 +161,7 @@ func (this *ImageController) Base64Upload() {
 	}
 	outFileName = uploadDir + randStr + ".png"
 	fmt.Println("start convert", time.Now())
-	cd := exec.Command("highcharts-export-server", "--infile", saveSvgPath, "--constr", "Chart", "--scale", "2","--workers","10","--workLimit","5", "--outfile", outFileName)
+	cd := exec.Command("highcharts-export-server", "--infile", saveSvgPath, "--constr", "Chart", "--scale", "2", "--workers", "10", "--workLimit", "5", "--outfile", outFileName)
 	str, err := cd.Output()
 	fmt.Println(string(str))
 	if err != nil {
@@ -221,10 +221,10 @@ func (this *ImageController) Ppt2Image() {
 	}
 
 	// 下载ppt
-	pptPath,err := utils.DownloadImage(req.PptUrl)
-	if err != nil{
+	pptPath, err := utils.DownloadImage(req.PptUrl)
+	if err != nil {
 		br.Msg = "下载ppt失败"
-		br.ErrMsg = "下载ppt失败,Err:"+err.Error()
+		br.ErrMsg = "下载ppt失败,Err:" + err.Error()
 		return
 	}
 	defer func() {
@@ -234,9 +234,9 @@ func (this *ImageController) Ppt2Image() {
 	// ppt转pdf
 	converterType := "pdf"
 	pdfPath, err := ppt2img.FuncDocs2Pdf(utils.LibreOfficePath, pptPath, "./static/pdf", converterType)
-	if err != nil{
+	if err != nil {
 		br.Msg = "ppt转pdf失败"
-		br.ErrMsg = "ppt转pdf失败,Err:"+err.Error()
+		br.ErrMsg = "ppt转pdf失败,Err:" + err.Error()
 		return
 	}
 	defer func() {
@@ -245,13 +245,13 @@ func (this *ImageController) Ppt2Image() {
 	}()
 
 	// 生成临时存放图片的目录
-	uploadDir := "./static/pdf/png/"+utils.GetRandStringNoSpecialChar(16)+"/"
+	uploadDir := "./static/pdf/png/" + utils.GetRandStringNoSpecialChar(16) + "/"
 	{
 		if !utils.FileIsExist(uploadDir) {
 			err := os.MkdirAll(uploadDir, 0777)
 			if err != nil {
 				br.Msg = "创建存放图片的目录失败"
-				br.ErrMsg = "创建存放图片的目录失败,Err:"+err.Error()
+				br.ErrMsg = "创建存放图片的目录失败,Err:" + err.Error()
 				return
 			}
 		}
@@ -261,43 +261,42 @@ func (this *ImageController) Ppt2Image() {
 		os.RemoveAll(uploadDir)
 	}()
 
-	pdfPathList := strings.Split(pdfPath,"/")
-	pngName := strings.Split(path.Base(pdfPathList[len(pdfPathList)-1]), ".")[0]	//图片名称
-	convPngName := uploadDir + pngName+".png"
+	pdfPathList := strings.Split(pdfPath, "/")
+	pngName := strings.Split(path.Base(pdfPathList[len(pdfPathList)-1]), ".")[0] //图片名称
+	convPngName := uploadDir + pngName + ".png"
 
 	// pdf 转图片
-	_,err = ppt2img.Pdf2Img(pdfPath,convPngName)
-	if err != nil{
+	_, err = ppt2img.Pdf2Img(pdfPath, convPngName)
+	if err != nil {
 		br.Msg = "pdf转png失败"
-		br.ErrMsg = "pdf转png失败,Err:"+err.Error()
+		br.ErrMsg = "pdf转png失败,Err:" + err.Error()
 		return
 	}
 
 	// oss的图片存放地址
-	resourceUrlList := make([]string,0)
-
+	resourceUrlList := make([]string, 0)
 
 	// 获取生成的文件列表
-	fileInfoList,err := ioutil.ReadDir(uploadDir)
+	fileInfoList, err := ioutil.ReadDir(uploadDir)
 	if err != nil {
 		br.Msg = "获取生成的文件列表失败"
-		br.ErrMsg = "获取生成的文件列表失败,Err:"+err.Error()
+		br.ErrMsg = "获取生成的文件列表失败,Err:" + err.Error()
 		return
 	}
 	countFile := len(fileInfoList)
-	for i:=0;i<countFile;i++{
-		tmpFilePath := fmt.Sprintf("%s%s-%d.png",uploadDir,pngName,i)
-		if utils.FileIsExist(tmpFilePath){
-			resourceUrl,tmpErr := uploadToAliOss(tmpFilePath)
-			if tmpErr != nil{
+	for i := 0; i < countFile; i++ {
+		tmpFilePath := fmt.Sprintf("%s%s-%d.png", uploadDir, pngName, i)
+		if utils.FileIsExist(tmpFilePath) {
+			resourceUrl, tmpErr := uploadToAliOss(tmpFilePath)
+			if tmpErr != nil {
 				br.Msg = "上传图片至oss失败"
-				br.ErrMsg = "上传图片至oss失败,Err:"+err.Error()
+				br.ErrMsg = "上传图片至oss失败,Err:" + err.Error()
 				return
 			}
-			resourceUrlList = append(resourceUrlList,resourceUrl)
-		}else{
+			resourceUrlList = append(resourceUrlList, resourceUrl)
+		} else {
 			br.Msg = "上传图片至oss失败"
-			br.ErrMsg = "上传图片至oss失败,Err:"+err.Error()
+			br.ErrMsg = "上传图片至oss失败,Err:" + err.Error()
 			return
 		}
 	}
@@ -309,7 +308,7 @@ func (this *ImageController) Ppt2Image() {
 }
 
 // 上传文件到阿里云
-func uploadToAliOss(outFileName string) (resourceUrl string,err error) {
+func uploadToAliOss(outFileName string) (resourceUrl string, err error) {
 	var saveToOssPath string
 	randStr := utils.GetRandStringNoSpecialChar(28)
 	uploadDir := "static/images/"

controllers/report.go

@@ -2,8 +2,8 @@ package controllers
 
 import (
 	"encoding/json"
-	"hongze/hongze_public_api/models"
-	"hongze/hongze_public_api/services"
+	"eta/eta_pub/models"
+	"eta/eta_pub/services"
 )
 
 // ReportController 报告模块

controllers/wechat.go

@@ -2,13 +2,13 @@ package controllers
 
 import (
 	"encoding/json"
-	"hongze/hongze_public_api/models"
-	"hongze/hongze_public_api/services"
-	"hongze/hongze_public_api/services/alarm_msg"
-	"hongze/hongze_public_api/utils"
+	"eta/eta_pub/models"
+	"eta/eta_pub/services"
+	"eta/eta_pub/services/alarm_msg"
+	"eta/eta_pub/utils"
 )
 
-//发送模板消息
+// 发送模板消息
 type WechatController struct {
 	BaseAuthController
 }
@@ -42,12 +42,12 @@ func (this *WechatController) SendTemplateMsg() {
 		return
 	}
 	if sendItem.WxAppId == "" {
-		sendItem.WxAppId = utils.WxAppId   //默认是弘则研究公众号的appId
+		sendItem.WxAppId = utils.WxAppId //默认是弘则研究公众号的appId
 	}
 	go func() {
-		if 	sendItem.RedirectTarget == 3 {
+		if sendItem.RedirectTarget == 3 {
 			err = services.SendWxTemplateMsgCygx(sendItem)
-		}else{
+		} else {
 			err = services.SendWxTemplateMsg(sendItem)
 		}
 		if err != nil {

go.mod

@@ -1,4 +1,4 @@
-module hongze/hongze_public_api
+module eta/eta_pub
 
 go 1.19
 

main.go

@@ -1,7 +1,7 @@
 package main
 
 import (
-	_ "hongze/hongze_public_api/routers"
+	_ "eta/eta_pub/routers"
 	"os"
 
 	"github.com/beego/beego/v2/server/web"
@@ -31,7 +31,7 @@ func main() {
 	svcConfig := &service.Config{
 		Name:        "Trim",         //服务显示名称
 		DisplayName: "Trim Service", //服务名称
-		Description: "微服务",       //服务描述
+		Description: "微服务",          //服务描述
 	}
 
 	prg := &program{}

models/db.go

@@ -1,8 +1,8 @@
 package models
 
 import (
+	"eta/eta_pub/utils"
 	_ "github.com/go-sql-driver/mysql"
-	"hongze/hongze_public_api/utils"
 	"time"
 
 	"github.com/beego/beego/v2/client/orm"

models/wechat.go

@@ -2,8 +2,8 @@ package models
 
 import (
 	"encoding/json"
+	"eta/eta_pub/utils"
 	"fmt"
-	"hongze/hongze_public_api/utils"
 
 	"github.com/beego/beego/v2/client/orm"
 	"github.com/rdlucklib/rdluck_tools/http"
@@ -22,7 +22,7 @@ type WxAccessToken struct {
 	Errmsg      string `json:"errmsg"`
 }
 
-func GetWxToken(wxAppId,wxAppSecret string) (item *WxAccessToken, err error) {
+func GetWxToken(wxAppId, wxAppSecret string) (item *WxAccessToken, err error) {
 	getUrl := "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + wxAppId + "&secret=" + wxAppSecret
 	result, err := http.Get(getUrl)
 	if err != nil {
@@ -43,9 +43,9 @@ func GetWxToken(wxAppId,wxAppSecret string) (item *WxAccessToken, err error) {
 
 func GetWxTokenCygx() (item *WxAccessToken, err error) {
 	var getUrl string
-	if utils.RunMode == "debug"{
+	if utils.RunMode == "debug" {
 		getUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + utils.WxAppId + "&secret=" + utils.WxAppSecret
-	}else{
+	} else {
 		getUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + utils.WxAppIdCygx + "&secret=" + utils.WxAppSecretCygx
 	}
 
@@ -67,7 +67,7 @@ func GetWxTokenCygx() (item *WxAccessToken, err error) {
 }
 
 // ModifyAccessToken 修改wx_access_token
-func ModifyAccessToken(accessToken string,expiresIn int64)(err error){
+func ModifyAccessToken(accessToken string, expiresIn int64) (err error) {
 	o := orm.NewOrm()
 	sql := `SELECT * FROM wx_token LIMIT 1`
 	wxToken := new(WxToken)
@@ -87,4 +87,4 @@ func ModifyAccessToken(accessToken string,expiresIn int64)(err error){
 		fmt.Println("更新 TOKEN:", err)
 	}
 	return
-}
+}

models/wechat_send_msg.go

@@ -1,8 +1,8 @@
 package models
 
 import (
+	"eta/eta_pub/utils"
 	"github.com/beego/beego/v2/client/orm"
-	"hongze/hongze_public_api/utils"
 	"strings"
 )
 

routers/commentsRouter.go

@@ -7,40 +7,40 @@ import (
 
 func init() {
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"],
-        beego.ControllerComments{
-            Method: "Ppt2Image",
-            Router: `/ppt2img`,
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"],
+		beego.ControllerComments{
+			Method:           "Ppt2Image",
+			Router:           `/ppt2img`,
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"],
-        beego.ControllerComments{
-            Method: "Base64Upload",
-            Router: `/svg_to_png`,
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"],
+		beego.ControllerComments{
+			Method:           "Base64Upload",
+			Router:           `/svg_to_png`,
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ReportController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ReportController"],
-        beego.ControllerComments{
-            Method: "HandleVideoDecibel",
-            Router: `/handle_video_decibel`,
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:ReportController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:ReportController"],
+		beego.ControllerComments{
+			Method:           "HandleVideoDecibel",
+			Router:           `/handle_video_decibel`,
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:WechatController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:WechatController"],
-        beego.ControllerComments{
-            Method: "SendTemplateMsg",
-            Router: `/send_template_msg`,
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:WechatController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:WechatController"],
+		beego.ControllerComments{
+			Method:           "SendTemplateMsg",
+			Router:           `/send_template_msg`,
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
 }

routers/commentsRouter_controllers.go

@@ -7,40 +7,40 @@ import (
 
 func init() {
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"],
-        beego.ControllerComments{
-            Method: "Ppt2Image",
-            Router: "/ppt2img",
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"],
+		beego.ControllerComments{
+			Method:           "Ppt2Image",
+			Router:           "/ppt2img",
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ImageController"],
-        beego.ControllerComments{
-            Method: "Base64Upload",
-            Router: "/svg_to_png",
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:ImageController"],
+		beego.ControllerComments{
+			Method:           "Base64Upload",
+			Router:           "/svg_to_png",
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ReportController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:ReportController"],
-        beego.ControllerComments{
-            Method: "HandleVideoDecibel",
-            Router: "/handle_video_decibel",
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:ReportController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:ReportController"],
+		beego.ControllerComments{
+			Method:           "HandleVideoDecibel",
+			Router:           "/handle_video_decibel",
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
-    beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:WechatController"] = append(beego.GlobalControllerRouter["hongze/hongze_public_api/controllers:WechatController"],
-        beego.ControllerComments{
-            Method: "SendTemplateMsg",
-            Router: "/send_template_msg",
-            AllowHTTPMethods: []string{"post"},
-            MethodParams: param.Make(),
-            Filters: nil,
-            Params: nil})
+	beego.GlobalControllerRouter["eta/eta_pub/controllers:WechatController"] = append(beego.GlobalControllerRouter["eta/eta_pub/controllers:WechatController"],
+		beego.ControllerComments{
+			Method:           "SendTemplateMsg",
+			Router:           "/send_template_msg",
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 
 }

routers/router.go

@@ -8,7 +8,7 @@
 package routers
 
 import (
-	"hongze/hongze_public_api/controllers"
+	"eta/eta_pub/controllers"
 
 	"github.com/beego/beego/v2/server/web"
 )

services/alarm_msg/alarm_msg.go

@@ -2,8 +2,8 @@ package alarm_msg
 
 import (
 	"encoding/json"
+	"eta/eta_pub/utils"
 	"github.com/rdlucklib/rdluck_tools/http"
-	"hongze/hongze_public_api/utils"
 )
 
 // projectName-项目名称

services/audio/audio.go

@@ -2,8 +2,8 @@ package audio
 
 import (
 	"bytes"
+	"eta/eta_pub/utils"
 	"fmt"
-	"hongze/hongze_public_api/utils"
 	"math"
 	"os"
 	"os/exec"

services/oss.go

@@ -5,7 +5,7 @@ import (
 	"os"
 	"time"
 
-	"hongze/hongze_public_api/utils"
+	"eta/eta_pub/utils"
 )
 
 // UploadFileToAliyun 上传文件到阿里云

services/report.go

@@ -1,10 +1,10 @@
 package services
 
 import (
+	"eta/eta_pub/models"
+	"eta/eta_pub/services/audio"
+	"eta/eta_pub/utils"
 	"fmt"
-	"hongze/hongze_public_api/models"
-	"hongze/hongze_public_api/services/audio"
-	"hongze/hongze_public_api/utils"
 	"os"
 	"path"
 )

services/wechat_send_msg.go

@@ -4,10 +4,10 @@ import (
 	"bytes"
 	"encoding/json"
 	"errors"
+	"eta/eta_pub/models"
+	"eta/eta_pub/services/alarm_msg"
+	"eta/eta_pub/utils"
 	"fmt"
-	"hongze/hongze_public_api/models"
-	"hongze/hongze_public_api/services/alarm_msg"
-	"hongze/hongze_public_api/utils"
 	"io/ioutil"
 	"net/http"
 	"strconv"

services/wechat_send_msg_cygx.go

@@ -4,18 +4,16 @@ import (
 	"bytes"
 	"encoding/json"
 	"errors"
+	"eta/eta_pub/models"
+	"eta/eta_pub/services/alarm_msg"
+	"eta/eta_pub/utils"
 	"fmt"
-	"hongze/hongze_public_api/models"
-	"hongze/hongze_public_api/services/alarm_msg"
-	"hongze/hongze_public_api/utils"
 	"io/ioutil"
 	"net/http"
 	"strings"
 	"time"
 )
 
-
-
 func SendWxTemplateMsgCygx(sendInfo *models.SendWxTemplate) (err error) {
 	var msg string
 	defer func() {
@@ -114,9 +112,9 @@ func sendTemplateMsgCygx(sendMap map[string]interface{}, openIdArr []string, res
 func toSendTemplateMsgCygx(data []byte, resource string, sendType int, openId, uniqueCode string) (err error) {
 	utils.FileLog.Info("Send:" + string(data))
 	//获取accessToken
-	accessToken, err,errMsg := getWxAccessTokenCygx()
+	accessToken, err, errMsg := getWxAccessTokenCygx()
 	if err != nil {
-		utils.FileLog.Info(fmt.Sprintf("获取Token失败,err：%s,errMsg：%s",err.Error(), errMsg))
+		utils.FileLog.Info(fmt.Sprintf("获取Token失败,err：%s,errMsg：%s", err.Error(), errMsg))
 		return
 	}
 	sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken
@@ -161,10 +159,10 @@ func toSendTemplateMsgCygx(data []byte, resource string, sendType int, openId, u
 	}
 
 	//accessToken过期
-	if templateResponse.Errcode == 40001{
+	if templateResponse.Errcode == 40001 {
 		//强刷token并重新推送
-		accessToken,err,errMsg = refreshWxAccessTokenCygx()
-		if err != nil{
+		accessToken, err, errMsg = refreshWxAccessTokenCygx()
+		if err != nil {
 			utils.FileLog.Info(fmt.Sprintf("refreshWxAccessToken Err:%s", err.Error()))
 			return err
 		}
@@ -220,15 +218,15 @@ func toSendTemplateMsgCygx(data []byte, resource string, sendType int, openId, u
 }
 
 // getWxAccessTokenCygx 获取微信token
-func getWxAccessTokenCygx()(accessToken string,err error,errMsg string){
+func getWxAccessTokenCygx() (accessToken string, err error, errMsg string) {
 	var tokenKey string
-	if utils.RunMode == "debug"{
+	if utils.RunMode == "debug" {
 		tokenKey = utils.CACHE_WX_ACCESS_TOKEN_HZ
-	}else{
+	} else {
 		tokenKey = utils.CACHE_WX_ACCESS_TOKEN_CYGX
 	}
 	accessToken, err = utils.Rc.RedisString(tokenKey)
-	if accessToken != ""{
+	if accessToken != "" {
 		return
 	}
 
@@ -237,10 +235,10 @@ func getWxAccessTokenCygx()(accessToken string,err error,errMsg string){
 }
 
 // refreshWxAccessTokenCygx 强制刷新微信token
-func refreshWxAccessTokenCygx()(accessToken string,err error,errMsg string){
-	fmt.Println("强制刷新"+utils.WxAppIdCygx+"微信token")
-	if errMsg !=``{
-		utils.FileLog.Info(fmt.Sprintf("强制刷新%s微信token异常：%s", utils.WxAppIdCygx,errMsg))
+func refreshWxAccessTokenCygx() (accessToken string, err error, errMsg string) {
+	fmt.Println("强制刷新" + utils.WxAppIdCygx + "微信token")
+	if errMsg != `` {
+		utils.FileLog.Info(fmt.Sprintf("强制刷新%s微信token异常：%s", utils.WxAppIdCygx, errMsg))
 	}
 	//调用微信官方接口获取新的accessToken
 	wxAccessToken, tmpErr := models.GetWxTokenCygx()
@@ -258,23 +256,23 @@ func refreshWxAccessTokenCygx()(accessToken string,err error,errMsg string){
 	accessToken = wxAccessToken.AccessToken
 	//更新mysql的accessToken(如果是debug环境的话)
 	var tokenKey string
-	if utils.RunMode == "debug"{
+	if utils.RunMode == "debug" {
 		expiresIn := time.Now().Add(time.Duration(wxAccessToken.ExpiresIn) * time.Second).Unix()
-		err = models.ModifyAccessToken(wxAccessToken.AccessToken,expiresIn)
-		if err!=nil{
+		err = models.ModifyAccessToken(wxAccessToken.AccessToken, expiresIn)
+		if err != nil {
 			errMsg = "更新mysql中的accessToken失败 Err:" + err.Error()
 			return
 		}
 		tokenKey = utils.CACHE_WX_ACCESS_TOKEN_HZ
-	}else{
+	} else {
 		tokenKey = utils.CACHE_WX_ACCESS_TOKEN_CYGX
 	}
 	//更新redis的accessToken（过期时间提前十分钟）
-	redisTimeExpire := time.Duration(wxAccessToken.ExpiresIn - 600) * time.Second
-	err = utils.Rc.Put(tokenKey,accessToken,redisTimeExpire)
-	if err!=nil{
+	redisTimeExpire := time.Duration(wxAccessToken.ExpiresIn-600) * time.Second
+	err = utils.Rc.Put(tokenKey, accessToken, redisTimeExpire)
+	if err != nil {
 		errMsg = "更新redis中的accessToken失败 Err:" + err.Error()
 		return
 	}
 	return
-}
+}

utils/config.go

@@ -87,7 +87,7 @@ func init() {
 			RunMode = "release"
 		}
 		fmt.Println("RunMode:", RunMode)
-		configPath := `/home/code/config/hongze_public_api/conf/app.conf`
+		configPath := `/home/code/config/eta_pub/conf/app.conf`
 		fmt.Println("configPath:", configPath)
 		err = web.LoadAppConfig("ini", configPath)
 		if err != nil {