From b23f597060bec60d5c3ca37ff8ffb590de8323de Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Tue, 15 Jun 2021 17:28:35 +0800 Subject: [PATCH] aa --- business/jxstore/cms/temp.go | 40 +++++++++++++++++++++++++++++++++ controllers/job_controller.go | 2 +- controllers/print_controller.go | 34 ---------------------------- 3 files changed, 41 insertions(+), 35 deletions(-) diff --git a/business/jxstore/cms/temp.go b/business/jxstore/cms/temp.go index 5d2ac294f..b04dbc74c 100644 --- a/business/jxstore/cms/temp.go +++ b/business/jxstore/cms/temp.go @@ -1 +1,41 @@ package cms + +import ( + "fmt" + "net" +) + +func TestTemp() { + conn, err := net.Dial("tcp", "www.jxcs.net:8000") + if err != nil { + fmt.Println("Dial err:", err) + return + } + connHandler(conn) +} + +func connHandler(c net.Conn) { + //接收终端输入 + //reader := bufio.NewReader(os.Stdin) + //缓冲 + buf := make([]byte, 1024) + fmt.Println("Please input data...") + for { + //读取终端输入直到读取到\n + //input, err := reader.ReadString('\n') + //if err != nil { + // fmt.Println("ReadString err:", err) + // return + //} + //写入数据 + c.Write([]byte("aaaaaaaaaaaaaa")) + //服务器端返回的数据写入buf + cnt, err := c.Read(buf) + if err != nil { + fmt.Println("Read err:", err) + return + } + //服务器端回传的信息 + fmt.Println("server response:", string(buf[0:cnt])) + } +} diff --git a/controllers/job_controller.go b/controllers/job_controller.go index b2643cced..8e4dc2dfe 100644 --- a/controllers/job_controller.go +++ b/controllers/job_controller.go @@ -547,7 +547,7 @@ func (c *JobController) RefreshJdDelivery() { func (c *JobController) TempJob() { c.callTempJob(func(params *tJobTempJobParams) (retVal interface{}, errCode string, err error) { //cms.TempJob() - //cms.TestTemp() + cms.TestTemp() return retVal, "", err }) } diff --git a/controllers/print_controller.go b/controllers/print_controller.go index a6a2f49ad..80c1b6613 100644 --- a/controllers/print_controller.go +++ b/controllers/print_controller.go @@ -1,11 +1,9 @@ package controllers import ( - "fmt" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/globals" beego "github.com/astaxie/beego/server/web" - "net" ) type PrintController struct { @@ -18,12 +16,6 @@ type CallBackPrint struct { } func (c *PrintController) Msg() { - conn, err := net.Dial("tcp", "www.jxcs.net:8000") - if err != nil { - fmt.Println("Dial err:", err) - return - } - connHandler(conn) //if c.Ctx.Input.Method() == http.MethodPost { callBackPrint := &CallBackPrint{} globals.SugarLogger.Debugf("print callback callbackResponse:%s", utils.Format4Output(c.Ctx.Request, true)) @@ -33,29 +25,3 @@ func (c *PrintController) Msg() { // c.Abort("404") //} } - -func connHandler(c net.Conn) { - //接收终端输入 - //reader := bufio.NewReader(os.Stdin) - //缓冲 - buf := make([]byte, 1024) - fmt.Println("Please input data...") - for { - //读取终端输入直到读取到\n - //input, err := reader.ReadString('\n') - //if err != nil { - // fmt.Println("ReadString err:", err) - // return - //} - //写入数据 - c.Write([]byte("aaaaaaaaaaaaaa")) - //服务器端返回的数据写入buf - cnt, err := c.Read(buf) - if err != nil { - fmt.Println("Read err:", err) - return - } - //服务器端回传的信息 - fmt.Println("server response:", string(buf[0:cnt])) - } -}