test

liuxiaolong

2019-06-26 73000facfdc05d2c72d418aa4b7b2cc9c078d695

test

 controllers/camera.go

@@ -207,15 +207,15 @@

    runTypeStr := c.Query("runType")
    cameraName := c.Query("cameraName")
    fmt.Println("runType:",runTypeStr)
    fmt.Println("cameraName:",cameraName)
    fmt.Println("runType:", runTypeStr)
    fmt.Println("cameraName:", cameraName)
    runType, err := strconv.Atoi(runTypeStr)
    if err !=nil || (runType !=0 && runType !=1) {
        util.ResponseFormat(c,code.RequestParamError,"参数有误")
        return
    }
    var api dbapi.CameraApi
    b,list := api.GetCamerasByRunType(runType)
    b, list := api.GetCamerasByRunType(runType, cameraName)
    if b {
        dataBytes, _ := json.Marshal(list)
        var cams []CameraVo

 main.go

@@ -6,10 +6,11 @@
    "webserver/extend/config"
    "webserver/models"
    "webserver/router"
    "webserver/service"
)

func main() {

    go service.TestPushImgMsg()
    envirment := flag.String("e", "dev", "")
    flag.Usage = func() {
        glog.Exit("flag parse usage !")

 service/FaceSdkService.go

@@ -6,6 +6,9 @@
    "encoding/json"
    "fmt"
    "github.com/gogo/protobuf/proto"
    "github.com/satori/go.uuid"
    "io/ioutil"
    "time"
)

const (
@@ -13,6 +16,26 @@
    Url_Service_PULL = "tcp:///tmp///webserver-1.ipc"
)
var imgPushChan chan protomsg.Recvmsg

func TestPushImgMsg() {
    InitService()
    imgData := readImgFile()
    for {
        PushImgMsg(protomsg.Recvmsg{
            Id:uuid.NewV4().String(),
            Addr:"",
            Picdata:imgData,
        })

        time.Sleep(5*time.Second)
    }
}

func readImgFile() []byte{
    filePath := "/home/user/workspace/timg.jpg"
    bytes, _ := ioutil.ReadFile(filePath)
    return bytes
}

func PushImgMsg(is protomsg.Recvmsg){
    imgPushChan <- is
@@ -42,7 +65,7 @@
        }
        rMsg := protomsg.SdkMessage{}
        if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{
            fmt.Println(rMsg)
            fmt.Println("recv MSG:",rMsg)
            resultMap[rMsg.Cid] = rMsg
        }