lhf

apis/forward/base.go

@@ -0,0 +1,11 @@
+package forward
+
+import "github.com/gin-gonic/gin"
+
+//李宏飞
+func InitForwardRouter(engine *gin.RouterGroup) {
+	v1 := engine.Group("v1")
+	{
+		v1.POST("/forward/lhf", LiHongFei)
+	}
+}

apis/forward/li.hong.fei.go

@@ -0,0 +1,31 @@
+package forward
+
+import (
+	"duoduo/tools"
+	"duoduo/tools/app"
+	"github.com/gin-gonic/gin"
+	"io/ioutil"
+)
+
+func LiHongFei(c *gin.Context) {
+
+	var dat interface{}
+
+	fun := c.Request.Header.Get("function")
+	body, err := ioutil.ReadAll(c.Request.Body)
+	if err != nil {
+		app.Error(c, 400, err, err.Error())
+		return
+	}
+	val, err := PostForward(body, fun)
+	if err != nil {
+		app.Error(c, 500, err, err.Error())
+	}
+	err = tools.JsonUnmarshal(val, &dat)
+	if err != nil {
+		app.Error(c, 500, err, err.Error())
+	}
+
+	c.JSON(200, dat)
+
+}

apis/forward/post.go

@@ -0,0 +1,42 @@
+package forward
+
+import (
+	"bytes"
+	"duoduo/conf"
+	"io/ioutil"
+	"net/http"
+)
+
+func PostForward(inputObj []byte, function string) (string, error) {
+
+	//数据转json
+
+	buffer := bytes.NewBuffer(inputObj)
+
+	confIni, errConf := conf.ConnIni()
+	if errConf != nil {
+		return "", errConf
+	}
+
+	path := confIni.MustValue("forward", "url")
+
+	request, err := http.NewRequest("POST", path+function, buffer)
+	if err != nil {
+
+		return "", err
+	}
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+	client := http.Client{}
+	//创建客户端
+	resp, err := client.Do(request) //发送请求
+	if err != nil {
+		return "", err
+	}
+	respBytes, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		return "", err
+	}
+
+	return string(respBytes), nil
+
+}

conf/conf.ini

@@ -10,4 +10,6 @@ mysql_port = 3306
 mysql_username = gogs
 [wx]
 app_id = wxc5b88e9d942121cc
-secret = 66d4694c94371186f5f15abbd76a89c6
+secret = 66d4694c94371186f5f15abbd76a89c6
+[forward]
+url = http://127.0.0.1:8082

conf/conf_master.ini

@@ -10,4 +10,6 @@ mysql_port = 3306
 mysql_username = gogs
 [wx]
 app_id = wxc5b88e9d942121cc
-secret = 66d4694c94371186f5f15abbd76a89c6
+secret = 66d4694c94371186f5f15abbd76a89c6
+[forward]
+url = http://127.0.0.1:8082

conf/conf_test.ini

@@ -10,4 +10,6 @@ mysql_port = 3306
 mysql_username = gogs
 [wx]
 app_id = wxc5b88e9d942121cc
-secret = 66d4694c94371186f5f15abbd76a89c6
+secret = 66d4694c94371186f5f15abbd76a89c6
+[forward]
+url = http://127.0.0.1:8082

models/forward/li.hong.fei.go

@@ -0,0 +1,8 @@
+package forward
+
+type LiHongFeiRequest struct {
+}
+
+type LiHongFeiResponse struct {
+	Dat interface{} `json:"dat"`
+}

routers/router.go

@@ -1,6 +1,7 @@
 package routers
 
 import (
+	"duoduo/apis/forward"
 	"duoduo/apis/pdd"
 	"duoduo/apis/user"
 	"duoduo/conf"
@@ -22,6 +23,7 @@ func InitRouter() {
 		pdd.InitPddDdkRouter(r2)
 		pdd.InitSetRouter(r2)
 		user.InitUserRouter(r2)
+		forward.InitForwardRouter(r2)
 	}
 	if conf.Model == "master" {
 		r.RunTLS(":443", "./shisanmiao.com.pem", "./shisanmiao.com.key")