V2版本重构造

@@ -7,10 +7,7 @@ aliyun_logs_access ="${aliyun_logs_access||F:/log/app.log}"
 #阿里云基础配置
 #阿里云基础配置
 AccessKeyID ="LTAI4FhiZ3UktC6N1u3H5GFC"
 AccessKeyID ="LTAI4FhiZ3UktC6N1u3H5GFC"
 AccessKeySecret ="UyspWwdni55CYQ02hUCint4qY2jNYO"
 AccessKeySecret ="UyspWwdni55CYQ02hUCint4qY2jNYO"
-#AccessKeyID ="LTAI4Fz1LUBW2fXp6QWaJHRS"
-#AccessKeySecret ="aLZXwK8pgrs10Ws03qcN7NsrSXFVsg"
-#阿里云->绑定域名  cname = https://media.goexample.live/
-cname ="https://media.fjmaimaimai.com/"
+cname ="https://media.goexample.live/"
 
 
 
 
 #友盟推送
 #友盟推送

@@ -7,5 +7,5 @@ AccessKeySecret ="aLZXwK8pgrs10Ws03qcN7NsrSXFVsg"
 log_level = "${LOG_LEVEL||debug}"
 log_level = "${LOG_LEVEL||debug}"
 aliyun_logs_access ="${aliyun_logs_access||F:/log/app.log}"
 aliyun_logs_access ="${aliyun_logs_access||F:/log/app.log}"
 
 
-#阿里云 https://media.goexample.live/
+#阿里云
 cname ="https://media.fjmaimaimai.com/"
 cname ="https://media.fjmaimaimai.com/"

@@ -3,11 +3,25 @@ module openapi
 go 1.12
 go 1.12
 
 
 require (
 require (
+	github.com/ajg/form v1.5.1 // indirect
 	github.com/aliyun/alibaba-cloud-sdk-go v1.60.348
 	github.com/aliyun/alibaba-cloud-sdk-go v1.60.348
 	github.com/aliyun/aliyun-sts-go-sdk v0.0.0-20171106034748-98d3903a2309
 	github.com/aliyun/aliyun-sts-go-sdk v0.0.0-20171106034748-98d3903a2309
 	github.com/astaxie/beego v1.10.0
 	github.com/astaxie/beego v1.10.0
+	github.com/fatih/structs v1.1.0 // indirect
+	github.com/gavv/httpexpect v2.0.0+incompatible
+	github.com/google/go-querystring v1.0.0 // indirect
+	github.com/imkira/go-interpol v1.1.0 // indirect
 	github.com/klauspost/cpuid v1.2.3 // indirect
 	github.com/klauspost/cpuid v1.2.3 // indirect
+	github.com/moul/http2curl v1.0.0 // indirect
+	github.com/onsi/ginkgo v1.10.3
+	github.com/onsi/gomega v1.7.1
 	github.com/satori/go.uuid v1.2.0
 	github.com/satori/go.uuid v1.2.0
+	github.com/sergi/go-diff v1.1.0 // indirect
+	github.com/valyala/fasthttp v1.13.1 // indirect
+	github.com/xeipuuv/gojsonschema v1.2.0 // indirect
+	github.com/yalp/jsonpath v0.0.0-20180802001716-5cc68e5049a0 // indirect
+	github.com/yudai/gojsondiff v1.0.0 // indirect
+	github.com/yudai/golcs v0.0.0-20170316035057-ecda9a501e82 // indirect
 	gitlab.fjmaimaimai.com/mmm-go/gocomm v0.0.1
 	gitlab.fjmaimaimai.com/mmm-go/gocomm v0.0.1
 )
 )
 
 

 package main
 package main
 
 
 import (
 import (
-	"fmt"
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego"
-	"gitlab.fjmaimaimai.com/mmm-go/gocomm/config"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
-	"openapi/internal/utils"
-	_ "openapi/routers"
-	"time"
-)
+	"openapi/pkg/constant"
 
 
-func init() {
-	time.Local = time.FixedZone("CST", 3600*8)
-	log.InitLog(config.Logger{
-		Filename: beego.AppConfig.String("aliyun_logs_access"),
-		Level:    fmt.Sprintf("%v", utils.ResolveLogLevel(beego.AppConfig.String("log_level"))),
-	})
-}
+	_ "openapi/pkg/log"
+	_ "openapi/pkg/port/beego"
+)
 
 
 func main() {
 func main() {
 	defer func() {
 	defer func() {
-		log.Info("open-api on stop!")
+		log.Info("server on stop!")
 	}()
 	}()
-
-	log.Info("open-api on start!")
-	log.Info("Beego Run Mode:", beego.BConfig.RunMode)
-
+	log.Info("server on start!")
+	constant.DebugConfig()
 	beego.Run()
 	beego.Run()
 }
 }

@@ -3,10 +3,10 @@ package push
 import (
 import (
 	"encoding/json"
 	"encoding/json"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
-	"openapi/internal/push"
-	"openapi/internal/push/getui"
-	"openapi/internal/utils"
-	"openapi/protocol"
+	protocol "openapi/pkg/domain"
+	"openapi/pkg/infrastructure/push"
+	"openapi/pkg/infrastructure/push/getui"
+	"openapi/pkg/infrastructure/utils"
 )
 )
 
 
 //推送信息
 //推送信息

-package vod
+package service
 
 
 import (
 import (
-	"openapi/internal/aliyun"
-	"openapi/protocol"
+	protocol "openapi/pkg/domain"
+	"openapi/pkg/infrastructure/aliyun"
 )
 )
 
 
 //错误处理
 //错误处理

-package vod
+package service
 
 
 import (
 import (
-	"github.com/astaxie/beego"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
-	"openapi/internal/aliyun"
-	"openapi/internal/utils"
-	"openapi/protocol"
+	"openapi/pkg/constant"
+	protocol "openapi/pkg/domain"
+	"openapi/pkg/infrastructure/aliyun"
+	"openapi/pkg/infrastructure/utils"
 )
 )
 
 
 //创建视频上传凭证
 //创建视频上传凭证
@@ -44,7 +44,7 @@ func CreateUploadVideo(header *protocol.RequestHeader, request *aliyun.CreateUpl
 		return
 		return
 	}
 	}
 	rsp.FileName = fileName
 	rsp.FileName = fileName
-	rsp.FileURL = up.GetFileUrl(beego.AppConfig.String("cname"))
+	rsp.FileURL = up.GetFileUrl(constant.CName)
 	return
 	return
 }
 }
 
 

+package constant
+
+import (
+	"fmt"
+	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
+)
+
+var (
+	LogFilePath string = "F:/log/app.log"
+	LogLevel    string = "error"
+)
+
+func init() {
+	LogLevel = config.StringDefault("log_level", LogLevel)
+	LogFilePath = config.StringDefault("aliyun_logs_access", LogFilePath)
+}
+
+func DebugConfig() {
+	for i := range config.HistorySort {
+		k := config.HistorySort[i]
+		v, ok := config.History[k]
+		if !ok {
+			continue
+		}
+		log.Debug(fmt.Sprintf("【load config】 %v=%v", k, v))
+	}
+}

+package constant
+
+import (
+	"github.com/astaxie/beego"
+)
+
+var config = NewConfigLoader()
+
+type ConfigLoader struct {
+	History     map[string]interface{}
+	HistorySort []string
+}
+
+func NewConfigLoader() *ConfigLoader {
+	return &ConfigLoader{
+		History:     make(map[string]interface{}),
+		HistorySort: make([]string, 0),
+	}
+}
+
+func (c *ConfigLoader) String(key string) (ret string, ok bool) {
+	if ret = beego.AppConfig.String(key); len(ret) != 0 {
+		ok = true
+		c.SetHistory(key, ret)
+		return
+	}
+	return
+}
+
+func (c *ConfigLoader) StringDefault(key string, defaultValue string) string {
+	if ret, ok := c.String(key); ok {
+		return ret
+	}
+	return defaultValue
+}
+
+func (c *ConfigLoader) SetHistory(key string, value interface{}) {
+	if _, ok := c.History[key]; !ok {
+		c.History[key] = value
+		c.HistorySort = append(c.HistorySort, key)
+	}
+}

+package constant
+
+var (
+	RegionID               = "cn-shanghai"
+	AccessKeyID     string = "LTAI4FhiZ3UktC6N1u3H5GFC"
+	AccessKeySecret string = "UyspWwdni55CYQ02hUCint4qY2jNYO"
+	CName           string = "https://media.goexample.live/"
+)
+
+func init() {
+	AccessKeyID = config.StringDefault("AccessKeyID", AccessKeyID)
+	AccessKeySecret = config.StringDefault("AccessKeySecret", AccessKeySecret)
+	CName = config.StringDefault("cname", CName)
+}

-package protocol
+package domain
 
 
 const RelateSplit = "/"
 const RelateSplit = "/"

-package protocol
+package domain
 
 
 import (
 import (
 	"encoding/json"
 	"encoding/json"

-package protocol
+package domain
 
 
 import (
 import (
 	"fmt"
 	"fmt"

-package protocol
+package domain
 
 
 var errmessge ErrorMap = map[int]string{
 var errmessge ErrorMap = map[int]string{
 	0:   "成功",
 	0:   "成功",

-package protocol
+package domain
 
 
 import "encoding/json"
 import "encoding/json"
 
 

-package protocol
+package domain
 
 
 import "mime/multipart"
 import "mime/multipart"
 
 

 package aliyun
 package aliyun
 
 
-import "github.com/astaxie/beego"
-
 var (
 var (
-	RegionID        = "cn-shanghai"
-	AccessKeyID     = beego.AppConfig.String("AccessKeyID")
-	AccessKeySecret = beego.AppConfig.String("AccessKeySecret")
+//RegionID        = "cn-shanghai"
+//AccessKeyID     = beego.AppConfig.String("AccessKeyID")
+//AccessKeySecret = beego.AppConfig.String("AccessKeySecret")
 )
 )
 
 
 const (
 const (

@@ -9,7 +9,8 @@ import (
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/common"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/common"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	comm_time "gitlab.fjmaimaimai.com/mmm-go/gocomm/time"
 	comm_time "gitlab.fjmaimaimai.com/mmm-go/gocomm/time"
-	"openapi/internal/utils"
+	"openapi/pkg/constant"
+	"openapi/pkg/infrastructure/utils"
 	"path"
 	"path"
 	"path/filepath"
 	"path/filepath"
 	"time"
 	"time"
@@ -17,13 +18,13 @@ import (
 
 
 //客户端
 //客户端
 func DefaultVodClient() (client *vod.Client, err error) {
 func DefaultVodClient() (client *vod.Client, err error) {
-	return InitVodClient(AccessKeyID, AccessKeySecret)
+	return InitVodClient(constant.AccessKeyID, constant.AccessKeySecret)
 }
 }
 
 
 //初始化客户端
 //初始化客户端
 func InitVodClient(accessKeyId string, accessKeySecret string) (client *vod.Client, err error) {
 func InitVodClient(accessKeyId string, accessKeySecret string) (client *vod.Client, err error) {
 	// 点播服务接入区域
 	// 点播服务接入区域
-	regionId := RegionID
+	regionId := constant.RegionID
 	// 创建授权对象
 	// 创建授权对象
 	credential := &credentials.AccessKeyCredential{
 	credential := &credentials.AccessKeyCredential{
 		accessKeyId,
 		accessKeyId,
@@ -73,7 +74,7 @@ func RefreshUploadVideo(client *vod.Client, r *RefreshUploadVideoRequest) (respo
 	if up, e := ParseUploadAddress(rsp.UploadAddress); e != nil {
 	if up, e := ParseUploadAddress(rsp.UploadAddress); e != nil {
 		log.Error(e)
 		log.Error(e)
 	} else {
 	} else {
-		response.FileURL = up.GetFileUrl(beego.AppConfig.String("cname"))
+		response.FileURL = up.GetFileUrl(constant.CName)
 	}
 	}
 	return
 	return
 }
 }

@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"fmt"
 	"github.com/astaxie/beego/httplib"
 	"github.com/astaxie/beego/httplib"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
-	"openapi/internal/push"
-	"openapi/internal/utils"
+	"openapi/pkg/infrastructure/push"
+	"openapi/pkg/infrastructure/utils"
 	"strings"
 	"strings"
 	"sync"
 	"sync"
 	"time"
 	"time"

 package getui
 package getui
 
 
 import (
 import (
-	"openapi/internal/push"
-	"openapi/internal/utils"
+	"openapi/pkg/infrastructure/push"
+	"openapi/pkg/infrastructure/utils"
 	"testing"
 	"testing"
 )
 )
 
 

@@ -2,7 +2,7 @@ package getui
 
 
 import (
 import (
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/identity/uid"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/identity/uid"
-	"openapi/internal/push"
+	"openapi/pkg/infrastructure/push"
 )
 )
 
 
 //1.消息模板
 //1.消息模板

@@ -7,7 +7,7 @@ import (
 	"github.com/astaxie/beego/httplib"
 	"github.com/astaxie/beego/httplib"
 	"io/ioutil"
 	"io/ioutil"
 	"net/http"
 	"net/http"
-	"openapi/internal/push"
+	"openapi/pkg/infrastructure/push"
 	"strings"
 	"strings"
 	"time"
 	"time"
 )
 )

+package log
+
+import (
+	"fmt"
+	"gitlab.fjmaimaimai.com/mmm-go/gocomm/config"
+	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
+	"openapi/pkg/constant"
+	"openapi/pkg/infrastructure/utils"
+)
+
+func init() {
+	log.InitLog(config.Logger{
+		Filename: constant.LogFilePath,
+		Level:    fmt.Sprintf("%v", utils.ResolveLogLevel(constant.LogLevel)),
+	})
+}

+package beego
+
+import (
+	_ "openapi/pkg/port/beego/routers"
+)
+
+func init() {
+
+}

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"fmt"
 	"github.com/astaxie/beego/plugins/cors"
 	"github.com/astaxie/beego/plugins/cors"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/time"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/time"
-	"openapi/protocol"
+	protocol "openapi/pkg/domain"
 	"strconv"
 	"strconv"
 	"strings"
 	"strings"
 
 

@@ -3,9 +3,9 @@ package v1
 import (
 import (
 	"encoding/json"
 	"encoding/json"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
-	"openapi/controllers"
-	"openapi/protocol"
-	"openapi/services/push"
+	push "openapi/pkg/application/push/service"
+	protocol "openapi/pkg/domain"
+	"openapi/pkg/port/beego/controllers"
 )
 )
 
 
 type PushController struct {
 type PushController struct {

@@ -3,10 +3,10 @@ package v1
 import (
 import (
 	"encoding/json"
 	"encoding/json"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
 	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
-	"openapi/controllers"
-	"openapi/internal/aliyun"
-	"openapi/protocol"
-	"openapi/services/vod"
+	vod "openapi/pkg/application/vod/service"
+	"openapi/pkg/domain"
+	"openapi/pkg/infrastructure/aliyun"
+	"openapi/pkg/port/beego/controllers"
 )
 )
 
 
 type VodController struct {
 type VodController struct {
@@ -16,14 +16,14 @@ type VodController struct {
 //创建视频上传凭证 CreateUploadVideo
 //创建视频上传凭证 CreateUploadVideo
 // @router /createUploadVideo [post]
 // @router /createUploadVideo [post]
 func (this *VodController) CreateUploadVideo() {
 func (this *VodController) CreateUploadVideo() {
-	var msg *protocol.ResponseMessage
+	var msg *domain.ResponseMessage
 	defer func() {
 	defer func() {
 		this.Resp(msg)
 		this.Resp(msg)
 	}()
 	}()
 	var request *aliyun.CreateUploadVideoRequest
 	var request *aliyun.CreateUploadVideoRequest
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 		log.Error(err)
 		log.Error(err)
-		msg = protocol.BadRequestParam(1)
+		msg = domain.BadRequestParam(1)
 		return
 		return
 	}
 	}
 	if b, m := this.Valid(request); !b {
 	if b, m := this.Valid(request); !b {
@@ -34,13 +34,13 @@ func (this *VodController) CreateUploadVideo() {
 		request.FileName = aliyun.DefaultVideoFileName
 		request.FileName = aliyun.DefaultVideoFileName
 	}
 	}
 	header := controllers.GetRequestHeader(this.Ctx)
 	header := controllers.GetRequestHeader(this.Ctx)
-	msg = protocol.NewReturnResponse(vod.CreateUploadVideo(header, request))
+	msg = domain.NewReturnResponse(vod.CreateUploadVideo(header, request))
 }
 }
 
 
 //创建视频上传凭证(多个) CreateUploadVideos
 //创建视频上传凭证(多个) CreateUploadVideos
 // @router /createUploadVideos [post]
 // @router /createUploadVideos [post]
 func (this *VodController) CreateUploadVideos() {
 func (this *VodController) CreateUploadVideos() {
-	var msg *protocol.ResponseMessage
+	var msg *domain.ResponseMessage
 	var response *aliyun.CreateUploadVideosResponse = &aliyun.CreateUploadVideosResponse{
 	var response *aliyun.CreateUploadVideosResponse = &aliyun.CreateUploadVideosResponse{
 		List: make([]*aliyun.CreateUploadVideoResponse, 0),
 		List: make([]*aliyun.CreateUploadVideoResponse, 0),
 	}
 	}
@@ -50,7 +50,7 @@ func (this *VodController) CreateUploadVideos() {
 	var request *aliyun.CreateUploadVideosRequest
 	var request *aliyun.CreateUploadVideosRequest
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 		log.Error(err)
 		log.Error(err)
-		msg = protocol.BadRequestParam(1)
+		msg = domain.BadRequestParam(1)
 		return
 		return
 	}
 	}
 	if b, m := this.Valid(request); !b {
 	if b, m := this.Valid(request); !b {
@@ -60,7 +60,7 @@ func (this *VodController) CreateUploadVideos() {
 	header := controllers.GetRequestHeader(this.Ctx)
 	header := controllers.GetRequestHeader(this.Ctx)
 	var err error
 	var err error
 	if len(request.Items) == 0 {
 	if len(request.Items) == 0 {
-		msg = protocol.BadRequestParam(2)
+		msg = domain.BadRequestParam(2)
 	}
 	}
 	for i := range request.Items {
 	for i := range request.Items {
 		r := request.Items[i]
 		r := request.Items[i]
@@ -71,20 +71,20 @@ func (this *VodController) CreateUploadVideos() {
 			response.List = append(response.List, rsp)
 			response.List = append(response.List, rsp)
 		}
 		}
 	}
 	}
-	msg = protocol.NewReturnResponse(response, err)
+	msg = domain.NewReturnResponse(response, err)
 }
 }
 
 
 //刷新视频上传凭证 RefreshUploadVideo
 //刷新视频上传凭证 RefreshUploadVideo
 // @router /refreshUploadVideo [post]
 // @router /refreshUploadVideo [post]
 func (this *VodController) RefreshUploadVideo() {
 func (this *VodController) RefreshUploadVideo() {
-	var msg *protocol.ResponseMessage
+	var msg *domain.ResponseMessage
 	defer func() {
 	defer func() {
 		this.Resp(msg)
 		this.Resp(msg)
 	}()
 	}()
 	var request *aliyun.RefreshUploadVideoRequest
 	var request *aliyun.RefreshUploadVideoRequest
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 		log.Error(err)
 		log.Error(err)
-		msg = protocol.BadRequestParam(1)
+		msg = domain.BadRequestParam(1)
 		return
 		return
 	}
 	}
 	if b, m := this.Valid(request); !b {
 	if b, m := this.Valid(request); !b {
@@ -92,20 +92,20 @@ func (this *VodController) RefreshUploadVideo() {
 		return
 		return
 	}
 	}
 	header := controllers.GetRequestHeader(this.Ctx)
 	header := controllers.GetRequestHeader(this.Ctx)
-	msg = protocol.NewReturnResponse(vod.RefreshUploadVideo(header, request))
+	msg = domain.NewReturnResponse(vod.RefreshUploadVideo(header, request))
 }
 }
 
 
 //创建图片上传凭证 CreateUploadImage
 //创建图片上传凭证 CreateUploadImage
 // @router /createUploadImage [post]
 // @router /createUploadImage [post]
 func (this *VodController) CreateUploadImage() {
 func (this *VodController) CreateUploadImage() {
-	var msg *protocol.ResponseMessage
+	var msg *domain.ResponseMessage
 	defer func() {
 	defer func() {
 		this.Resp(msg)
 		this.Resp(msg)
 	}()
 	}()
 	var request *aliyun.CreateUploadImageRequest
 	var request *aliyun.CreateUploadImageRequest
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 		log.Error(err)
 		log.Error(err)
-		msg = protocol.BadRequestParam(1)
+		msg = domain.BadRequestParam(1)
 		return
 		return
 	}
 	}
 	if b, m := this.Valid(request); !b {
 	if b, m := this.Valid(request); !b {
@@ -114,13 +114,13 @@ func (this *VodController) CreateUploadImage() {
 	}
 	}
 
 
 	header := controllers.GetRequestHeader(this.Ctx)
 	header := controllers.GetRequestHeader(this.Ctx)
-	msg = protocol.NewReturnResponse(vod.CreateUploadImage(header, request))
+	msg = domain.NewReturnResponse(vod.CreateUploadImage(header, request))
 }
 }
 
 
 //创建图片上传凭证 CreateUploadImages
 //创建图片上传凭证 CreateUploadImages
 // @router /createUploadImages [post]
 // @router /createUploadImages [post]
 func (this *VodController) CreateUploadImages() {
 func (this *VodController) CreateUploadImages() {
-	var msg *protocol.ResponseMessage
+	var msg *domain.ResponseMessage
 	defer func() {
 	defer func() {
 		this.Resp(msg)
 		this.Resp(msg)
 	}()
 	}()
@@ -132,7 +132,7 @@ func (this *VodController) CreateUploadImages() {
 	)
 	)
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 		log.Error(err)
 		log.Error(err)
-		msg = protocol.BadRequestParam(1)
+		msg = domain.BadRequestParam(1)
 		return
 		return
 	}
 	}
 	if b, m := this.Valid(request); !b {
 	if b, m := this.Valid(request); !b {
@@ -141,7 +141,7 @@ func (this *VodController) CreateUploadImages() {
 	}
 	}
 	var err error
 	var err error
 	if len(request.Items) == 0 {
 	if len(request.Items) == 0 {
-		msg = protocol.BadRequestParam(2)
+		msg = domain.BadRequestParam(2)
 	}
 	}
 	header := controllers.GetRequestHeader(this.Ctx)
 	header := controllers.GetRequestHeader(this.Ctx)
 	for i := range request.Items {
 	for i := range request.Items {
@@ -153,20 +153,20 @@ func (this *VodController) CreateUploadImages() {
 			response.List = append(response.List, rsp)
 			response.List = append(response.List, rsp)
 		}
 		}
 	}
 	}
-	msg = protocol.NewReturnResponse(response, err)
+	msg = domain.NewReturnResponse(response, err)
 }
 }
 
 
 //获取视频播放地址 GetPlayInfo
 //获取视频播放地址 GetPlayInfo
 // @router /getPlayInfo [post]
 // @router /getPlayInfo [post]
 func (this *VodController) GetPlayInfo() {
 func (this *VodController) GetPlayInfo() {
-	var msg *protocol.ResponseMessage
+	var msg *domain.ResponseMessage
 	defer func() {
 	defer func() {
 		this.Resp(msg)
 		this.Resp(msg)
 	}()
 	}()
 	var request *aliyun.GetPlayInfoRequest
 	var request *aliyun.GetPlayInfoRequest
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 		log.Error(err)
 		log.Error(err)
-		msg = protocol.BadRequestParam(1)
+		msg = domain.BadRequestParam(1)
 		return
 		return
 	}
 	}
 	if b, m := this.Valid(request); !b {
 	if b, m := this.Valid(request); !b {
@@ -174,20 +174,20 @@ func (this *VodController) GetPlayInfo() {
 		return
 		return
 	}
 	}
 	header := controllers.GetRequestHeader(this.Ctx)
 	header := controllers.GetRequestHeader(this.Ctx)
-	msg = protocol.NewReturnResponse(vod.GetPlayInfo(header, request))
+	msg = domain.NewReturnResponse(vod.GetPlayInfo(header, request))
 }
 }
 
 
 //获取视频播放凭证 GetVideoPlayAuth
 //获取视频播放凭证 GetVideoPlayAuth
 // @router /getVideoPlayAuth [post]
 // @router /getVideoPlayAuth [post]
 func (this *VodController) GetVideoPlayAuth() {
 func (this *VodController) GetVideoPlayAuth() {
-	var msg *protocol.ResponseMessage
+	var msg *domain.ResponseMessage
 	defer func() {
 	defer func() {
 		this.Resp(msg)
 		this.Resp(msg)
 	}()
 	}()
 	var request *aliyun.GetVideoPlayAuthRequest
 	var request *aliyun.GetVideoPlayAuthRequest
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 	if err := json.Unmarshal(this.ByteBody, &request); err != nil {
 		log.Error(err)
 		log.Error(err)
-		msg = protocol.BadRequestParam(1)
+		msg = domain.BadRequestParam(1)
 		return
 		return
 	}
 	}
 	if b, m := this.Valid(request); !b {
 	if b, m := this.Valid(request); !b {
@@ -195,5 +195,5 @@ func (this *VodController) GetVideoPlayAuth() {
 		return
 		return
 	}
 	}
 	header := controllers.GetRequestHeader(this.Ctx)
 	header := controllers.GetRequestHeader(this.Ctx)
-	msg = protocol.NewReturnResponse(vod.GetVideoPlayAuth(header, request))
+	msg = domain.NewReturnResponse(vod.GetVideoPlayAuth(header, request))
 }
 }

@@ -2,8 +2,9 @@ package routers
 
 
 import (
 import (
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego"
-	"openapi/controllers"
-	"openapi/controllers/v1"
+	"openapi/pkg/constant"
+	"openapi/pkg/port/beego/controllers"
+	"openapi/pkg/port/beego/controllers/v1"
 )
 )
 
 
 var nsV1 *beego.Namespace
 var nsV1 *beego.Namespace
@@ -12,8 +13,7 @@ func init() {
 	nsV1 := beego.NewNamespace("v1",
 	nsV1 := beego.NewNamespace("v1",
 		beego.NSNamespace("vod", beego.NSBefore(controllers.AllowOption), beego.NSInclude(&v1.VodController{})),
 		beego.NSNamespace("vod", beego.NSBefore(controllers.AllowOption), beego.NSInclude(&v1.VodController{})),
 		beego.NSNamespace("push", beego.NSBefore(controllers.AllowOption), beego.NSInclude(&v1.PushController{})),
 		beego.NSNamespace("push", beego.NSBefore(controllers.AllowOption), beego.NSInclude(&v1.PushController{})),
-		//beego.NSNamespace("vod", beego.NSBefore(controllers.FilterComm), beego.NSBefore(controllers.AllowOption), beego.NSInclude(&v1.VodController{})),
 	)
 	)
-	beego.SetStaticPath("/log", beego.AppConfig.String("aliyun_logs_access"))
+	beego.SetStaticPath("/log", constant.LogFilePath)
 	beego.AddNamespace(nsV1)
 	beego.AddNamespace(nsV1)
 }
 }

-package routers
-
-import (
-	"github.com/astaxie/beego"
-	"github.com/astaxie/beego/context/param"
-)
-
-func init() {
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:PushController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:PushController"],
-		beego.ControllerComments{
-			Method:           "PushInfo",
-			Router:           `/pushInfo`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:VodController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:VodController"],
-		beego.ControllerComments{
-			Method:           "CreateUploadImage",
-			Router:           `/createUploadImage`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:VodController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:VodController"],
-		beego.ControllerComments{
-			Method:           "CreateUploadImages",
-			Router:           `/createUploadImages`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:VodController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:VodController"],
-		beego.ControllerComments{
-			Method:           "CreateUploadVideo",
-			Router:           `/createUploadVideo`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:VodController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:VodController"],
-		beego.ControllerComments{
-			Method:           "CreateUploadVideos",
-			Router:           `/createUploadVideos`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:VodController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:VodController"],
-		beego.ControllerComments{
-			Method:           "GetPlayInfo",
-			Router:           `/getPlayInfo`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:VodController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:VodController"],
-		beego.ControllerComments{
-			Method:           "GetVideoPlayAuth",
-			Router:           `/getVideoPlayAuth`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-	beego.GlobalControllerRouter["openapi/controllers/v1:VodController"] = append(beego.GlobalControllerRouter["openapi/controllers/v1:VodController"],
-		beego.ControllerComments{
-			Method:           "RefreshUploadVideo",
-			Router:           `/refreshUploadVideo`,
-			AllowHTTPMethods: []string{"post"},
-			MethodParams:     param.Make(),
-			Params:           nil})
-
-}

+package push
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("消息推送测试", func() {
+	ginkgo.Describe("消息推送测试", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"mmmType":     1,
+					"deviceToken": "",
+					"clientId":    "b5fff5f6b0af551da5f381fa47991828",
+					"appkey":      "5AjJeDOSOZ5ojQpXJFjhg9",
+					"secret":      "9VnM8MaA6n84Y5VnOIaSvA",
+					"appId":       "TkpBI4awmg9fBUx3NWKXS6",
+					"title":       " hello",
+					"content":     " hello content",
+					"ext":         map[string]interface{}{"transData": "trans-content"},
+				}
+				httpExpect.POST("/v1/push/pushInfo").
+					WithJSON(body).
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package push
+
+import (
+	"github.com/astaxie/beego"
+	"github.com/onsi/ginkgo"
+	"github.com/onsi/gomega"
+	"net/http"
+	"net/http/httptest"
+	_ "openapi/pkg/port/beego"
+	"testing"
+)
+
+func TestPush(t *testing.T) {
+	gomega.RegisterFailHandler(ginkgo.Fail)
+	ginkgo.RunSpecs(t, "Beego Port Config Correlations Test Case Suite")
+}
+
+var handler http.Handler
+var server *httptest.Server
+
+var _ = ginkgo.BeforeSuite(func() {
+	handler = beego.BeeApp.Handlers
+	beego.BConfig.CopyRequestBody = true
+	server = httptest.NewServer(handler)
+})
+
+var _ = ginkgo.AfterSuite(func() {
+	server.Close()
+})

+package vod
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("创建图片上传凭证(单图片)", func() {
+	ginkgo.Describe("创建图片上传凭证(单图片)", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"fileName": "test.jpg",
+				}
+				httpExpect.POST("/v1/vod/createUploadImage").
+					WithJSON(body).
+					WithHeader("x-mmm-appproject", "opportunity").
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package vod
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("创建图片上传凭证(多图片)", func() {
+	ginkgo.Describe("创建图片上传凭证(多图片)", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"items": []struct {
+						FileName string `json:"fileName"`
+					}{{FileName: "test.jpg"}},
+				}
+				httpExpect.POST("/v1/vod/createUploadImages").
+					WithJSON(body).
+					WithHeader("x-mmm-appproject", "opportunity").
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package vod
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("创建视频上传凭证(单视频)", func() {
+	ginkgo.Describe("创建视频上传凭证(单视频)", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"fileName": "test.mp4",
+				}
+				httpExpect.POST("/v1/vod/createUploadVideos").
+					WithJSON(body).
+					WithHeader("x-mmm-appproject", "opportunity").
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package vod
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("创建视频上传凭证(多视频)", func() {
+	ginkgo.Describe("创建视频上传凭证(多视频)", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"items": []struct {
+						FileName string `json:"fileName"`
+					}{{FileName: "test.mp4"}},
+				}
+				httpExpect.POST("/v1/vod/createUploadVideos").
+					WithJSON(body).
+					WithHeader("x-mmm-appproject", "opportunity").
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package vod
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("获取播放信息测试", func() {
+	ginkgo.Describe("获取播放信息测试", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"videoId": "7be8e50dd65e45d285908bf28c8e94b2",
+				}
+				httpExpect.POST("/v1/vod/getPlayInfo").
+					WithJSON(body).
+					WithHeader("x-mmm-appproject", "opportunity").
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package vod
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("获取播放凭证测试", func() {
+	ginkgo.Describe("获取播放凭证测试", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"videoId": "7be8e50dd65e45d285908bf28c8e94b2",
+				}
+				httpExpect.POST("/v1/vod/getVideoPlayAuth").
+					WithJSON(body).
+					WithHeader("x-mmm-appproject", "opportunity").
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package vod
+
+import (
+	"github.com/gavv/httpexpect"
+	"github.com/onsi/ginkgo"
+	"net/http"
+)
+
+var _ = ginkgo.Describe("刷新视频上次凭证", func() {
+	ginkgo.Describe("刷新视频上次凭证", func() {
+		ginkgo.Context("", func() {
+			ginkgo.It("", func() {
+				httpExpect := httpexpect.New(ginkgo.GinkgoT(), server.URL)
+				body := map[string]interface{}{
+					"videoId": "1023bc472c69499dbe332afa785ee610",
+				}
+				httpExpect.POST("/v1/vod/refreshUploadVideo").
+					WithJSON(body).
+					WithHeader("x-mmm-appproject", "opportunity").
+					Expect().
+					Status(http.StatusOK).
+					JSON().
+					Object().
+					ContainsKey("code").ValueEqual("code", 0).
+					ContainsKey("msg").ValueEqual("msg", "成功")
+			})
+		})
+	})
+})

+package vod
+
+import (
+	"github.com/astaxie/beego"
+	"github.com/onsi/ginkgo"
+	"github.com/onsi/gomega"
+	"net/http"
+	"net/http/httptest"
+	_ "openapi/pkg/port/beego"
+	"testing"
+)
+
+func TestPush(t *testing.T) {
+	gomega.RegisterFailHandler(ginkgo.Fail)
+	ginkgo.RunSpecs(t, "Beego Port Config Correlations Test Case Suite")
+}
+
+var handler http.Handler
+var server *httptest.Server
+
+var _ = ginkgo.BeforeSuite(func() {
+	handler = beego.BeeApp.Handlers
+	beego.BConfig.CopyRequestBody = true
+	server = httptest.NewServer(handler)
+})
+
+var _ = ginkgo.AfterSuite(func() {
+	server.Close()
+})