diff --git a/business/jxstore/cms/temp.go b/business/jxstore/cms/temp.go index f436f3e94..1a123481a 100644 --- a/business/jxstore/cms/temp.go +++ b/business/jxstore/cms/temp.go @@ -7,6 +7,10 @@ import ( "os" ) +var ( + textChan chan string +) + func TestTemp() { server := "127.0.0.1:8000" tcpAddr, err := net.ResolveTCPAddr("tcp4", server) @@ -23,6 +27,10 @@ func TestTemp() { connHandler(conn) } +func TestTemp2(data string) { + textChan <- data +} + func connHandler(c net.Conn) { //接收终端输入 //reader := bufio.NewReader(os.Stdin) @@ -30,15 +38,16 @@ func connHandler(c net.Conn) { //buf := make([]byte, 1024) fmt.Println("Please input data...") go func() { - for i := 0; i <= 10; i++ { + for { //读取终端输入直到读取到\n //input, err := reader.ReadString('\n') //if err != nil { // fmt.Println("ReadString err:", err) // return //} + s := <-textChan //写入数据 - n, err := c.Write([]byte(fmt.Sprintf("input 1111111111 %d", i))) + n, err := c.Write([]byte(s)) if err != nil { fmt.Println("Write err:", err, n) return diff --git a/controllers/job_controller.go b/controllers/job_controller.go index 8e4dc2dfe..5c349be94 100644 --- a/controllers/job_controller.go +++ b/controllers/job_controller.go @@ -551,3 +551,17 @@ func (c *JobController) TempJob() { return retVal, "", err }) } + +// @Title 测试接口2 +// @Description 测试接口 +// @Param token header string false "认证token" +// @Param data formData string false "data" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /TempJob2 [post] +func (c *JobController) TempJob2() { + c.callTempJob2(func(params *tJobTempJob2Params) (retVal interface{}, errCode string, err error) { + cms.TestTemp2(params.Data) + return retVal, "", err + }) +} diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go index 10e0d9496..3b2ec8cb8 100644 --- a/routers/commentsRouter_controllers.go +++ b/routers/commentsRouter_controllers.go @@ -691,6 +691,15 @@ func init() { Filters: nil, Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.ControllerComments{ + Method: "TempJob2", + Router: "/TempJob2", + AllowHTTPMethods: []string{"post"}, + MethodParams: param.Make(), + Filters: nil, + Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], beego.ControllerComments{ Method: "UpdateJob",