diff --git a/business/jxstore/cms/conn_test.go b/business/jxstore/cms/conn_test.go new file mode 100644 index 000000000..4a0c5bee4 --- /dev/null +++ b/business/jxstore/cms/conn_test.go @@ -0,0 +1,11 @@ +package cms + +import ( + "fmt" + "testing" +) + +func TestConn(t *testing.T) { + err := DelPrinterSeq(1000, "120220915001012") + fmt.Println(err) +} diff --git a/business/jxstore/cms/print.go b/business/jxstore/cms/print.go index c89abc84c..917eeed8f 100644 --- a/business/jxstore/cms/print.go +++ b/business/jxstore/cms/print.go @@ -2,6 +2,7 @@ package cms import ( "encoding/json" + "errors" "fmt" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/dao" @@ -340,6 +341,27 @@ func DelPrinterSeq(appID int, printNo string) (err error) { } } } + + // 简历连接 + conn, err := net.Dial("tcp", "www.jxcs.net:8000") + if err != nil { + return err + } + clearPrint := fmt.Sprintf(`{"print_no":%s}`, printNo) + // 发送数据 + if _, err := conn.Write([]byte(clearPrint)); err != nil { + return err + } + // 等待数据 + buf := make([]byte, 1024) + n, err := conn.Read(buf) + if err != nil { + return err + } + if string(buf[:n]) != "ok" { + return errors.New("缓存清理失败") + } + defer conn.Close() return err }