From b163fa8f851be7e6d19b0ea937f6efd25012cfc4 Mon Sep 17 00:00:00 2001 From: louwenzhi Date: Mon, 23 Aug 2021 14:48:56 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=93=E5=8D=B0=E6=9C=8D=E5=8A=A1=EF=BC=8C?= =?UTF-8?q?=E4=B8=B2=E5=8F=A3=E6=89=93=E5=8D=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- common/Utils.go | 63 +++++++++++++++++++++++++--------------------- config/config.go | 1 + config/config.yaml | 8 +++--- db/Printertab.go | 22 ++++++++++++---- engine/printer.go | 37 +++++++++++++++++++++++++-- 5 files changed, 92 insertions(+), 39 deletions(-) diff --git a/common/Utils.go b/common/Utils.go index e34872e..95f0141 100644 --- a/common/Utils.go +++ b/common/Utils.go @@ -1,10 +1,12 @@ package common import ( + "LAPP_PRN_Service/db" "container/list" "errors" "fmt" "github.com/lianggx6/goutf16" + "github.com/tarm/serial" "io/ioutil" "log" "math/rand" @@ -328,32 +330,6 @@ func SetDefaultPrinter(printerName string) error { return nil } -// 发送到打印机 -//func SendFileToPrinter(filePath string,printerName string) error { -// var ( -// dll = syscall.NewLazyDLL(EnsureDir("config/TSCLIB.dll")) -// ) -// //调用文件 -// //打开 打印机 端口. -// open := dll.NewProc("openport") -// -// //关闭连接 -// closefile := dll.NewProc("closeport") -// defer closefile.Call() -// -// printer, _ := syscall.UTF16PtrFromString(printerName) -// info1, info2, err := open.Call(uintptr(unsafe.Pointer(printer))) -// glog.InfoExtln("Printer", "info1: ", info1) -// glog.InfoExtln("Printer", "info2: ", info2) -// glog.InfoExtln("Printer", "err: ", err) -// //发送文件 -// sendfile := dll.NewProc("sendfile") -// filePathstr, _ := syscall.UTF16PtrFromString(filePath) -// -// sendfile.Call(uintptr(unsafe.Pointer(filePathstr))) -// -// return nil -//} // 发送到打印机 func SendFileToPrinter(filePath string, ip string, port int) error { var ( @@ -367,22 +343,51 @@ func SendFileToPrinter(filePath string, ip string, port int) error { closefile := dll.NewProc("closeport") defer closefile.Call() - ipstr,_ := syscall.BytePtrFromString(ip) + ipstr, _ := syscall.BytePtrFromString(ip) ret, _, msg := open.Call(uintptr(unsafe.Pointer(ipstr)), uintptr(port)) if ret == 0 { return msg } //发送文件 sendfile := dll.NewProc("sendfile") - filePathstr,_ := syscall.BytePtrFromString(filePath) + filePathstr, _ := syscall.BytePtrFromString(filePath) - ret, _, msg =sendfile.Call(uintptr(unsafe.Pointer(filePathstr))) + ret, _, msg = sendfile.Call(uintptr(unsafe.Pointer(filePathstr))) if ret == 0 { return msg } return nil } +// 发送到打印机 +func SendFileBySerial(bytesFile []db.ByteFile, SerialName string, SerialPort int) error { + + var ( + err error + bytesRow db.ByteFile + ) + + c := &serial.Config{Name: SerialName, Baud: SerialPort} + s, err := serial.OpenPort(c) + if err != nil { + return err + } + defer s.Close() + + //发送之前清空缓冲区 + buffer := make([]byte, 8000) + _, err = s.Read(buffer) + if err != nil { + return err + } + for _, bytesRow = range bytesFile { + if _, err = s.Write(bytesRow.ByteLine); err != nil { + return err + } + } + return nil +} + func ShellExecute(hwnd HWND, lpOperation, lpFile, lpParameters, lpDirectory string, nShowCmd int) error { var op, param, directory uintptr if len(lpOperation) != 0 { diff --git a/config/config.go b/config/config.go index 5f43247..a812f88 100644 --- a/config/config.go +++ b/config/config.go @@ -26,6 +26,7 @@ type EnvConfig struct { TemplatePath string `yaml:"templatepath"` ReadTaskInterval int `yaml:"readtaskinterval"` PrinterType string `yaml:"printertype"` + Printers string `yaml:"printers"` Inbox string `yaml:"inbox"` Outbox string `yaml:"outbox"` Day int `yaml:"day"` diff --git a/config/config.yaml b/config/config.yaml index fc9067d..930b695 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -1,8 +1,8 @@ plantnr: 100 dbtype: mssql -server: localhost +server: 101.201.121.115 #server: CCN-MESDB -ip: 127.0.0.1 +ip: 101.201.121.115 #ip: 192.168.3.22 user: sa password: Leit2020 @@ -19,7 +19,9 @@ templatepath: Template # 打印任务读取频率 readtaskinterval: 5 # 支持打印机类型 -printertype: N,L,E,D +printertype: N,L,E,D,S #D是TSC打印机，S是串口打印机 +# 支持打印机 +printers : "COM" inbox: Template\\Inbox outbox: Template\\Outbox # 间隔时间 diff --git a/db/Printertab.go b/db/Printertab.go index 3e5576f..d5f8a15 100644 --- a/db/Printertab.go +++ b/db/Printertab.go @@ -29,6 +29,8 @@ type Printer struct { PrinterType string `xorm:"varchar(1) 'PrinterType' not null" json:"Printer-PrinterType"` PrinterName string `xorm:"varchar(100) 'PrinterName' not null" json:"Printer-PrinterName"` IpAddress string `xorm:"varchar(15) 'IpAddress' not null" json:"Printer-IpAddress"` + SerialName string `xorm:"varchar(15) 'SerialName' not null" json:"Printer-SerialName"` + SerialPort int `xorm:"int 'SerialPort' not null" json:"Printer-SerialPort"` Active int `xorm:"smallint 'Active' not null" json:"Printer-Active"` PrinterSpec string `xorm:"varchar(30) 'PrinterSpec' not null" json:"Printer-PrinterSpec"` PageSize string `xorm:"varchar(18) 'PageSize' not null" json:"Printer-PageSize"` @@ -99,15 +101,25 @@ func (t *Printer) GetPrinterList(conf *conf.EnvConfig) ([]Printer, error) { var ( printertablist []Printer pt []string + printers []string ) e := G_DbEngine pt = strings.Split(conf.PrinterType, ",") - - err := e.Where("PlantNr = ? and Active = ?", conf.PlantNr, 1).In("PrinterType", pt).Find(&printertablist) - if err != nil { - glog.Infoln("failed to query Printer for type: %s due to: %v", pt, err) - return nil, err + printers = strings.Split(conf.Printers, ",") + if len(printers) > 0 { + err := e.Where("PlantNr = ? and Active = ?", conf.PlantNr, 1).In("PrinterId", printers).In("PrinterType", pt).Find(&printertablist) + if err != nil { + glog.Infoln("failed to query Printer for type: %s due to: %v", pt, err) + return nil, err + } + } else { + err := e.Where("PlantNr = ? and Active = ?", conf.PlantNr, 1).In("PrinterType", pt).Find(&printertablist) + if err != nil { + glog.Infoln("failed to query Printer for type: %s due to: %v", pt, err) + return nil, err + } } + return printertablist, nil } diff --git a/engine/printer.go b/engine/printer.go index 164cacb..8684593 100644 --- a/engine/printer.go +++ b/engine/printer.go @@ -18,6 +18,8 @@ type Printer struct { PrinterType string // 打印机类型，N=网络端口打印，L=文件打印 Ip string // 打印机IP地址 Port int // 打印机端口号 + SerialName string // 串口名称 + SerialPort int // 串口号 Interval int // 打印机打印间隔时间，单位：秒 conn net.Conn // 打印机连接句柄 InTaskChan chan db.PrintTask // 任务接入管道 @@ -33,6 +35,8 @@ func (p *Printer) Create(printertab db.Printer) { p.Ip = printertab.IpAddress p.Port = printertab.Port p.Interval = printertab.PrintInterval + p.SerialName = printertab.SerialName + p.SerialPort = printertab.SerialPort p.Printertab = printertab p.InTaskChan = make(chan db.PrintTask, 1000) @@ -156,7 +160,7 @@ func (p *Printer) printByDLL(conf *conf.EnvConfig, saveChan chan db.PrintTask) { continue } // 通过windows文件输出方式打印 - if err = common.SendFileToPrinter(t.TaskFile, p.Ip,p.Port); err != nil { + if err = common.SendFileToPrinter(t.TaskFile, p.Ip, p.Port); err != nil { glog.InfoExtln("Printer", "Failed to by dll: ", err) continue } @@ -188,6 +192,31 @@ func (p *Printer) printByExcel(conf *conf.EnvConfig, printChan chan db.PrintTask } } +func (p *Printer) printBySerial(conf *conf.EnvConfig, saveChan chan db.PrintTask) { + var ( + t db.PrintTask + err error + bytesFile []db.ByteFile + ) + + for { + t = <-p.InTaskChan + if bytesFile, err = t.GenBytesFile(conf); err != nil { + glog.InfoExtln("Printer", "Failed to generate bytes for task : ", t) + continue + } + // 通过串口形式打印 + if err = common.SendFileBySerial(bytesFile, p.SerialName, p.SerialPort); err != nil { + glog.InfoExtln("Printer", "Failed to by dll: ", err) + continue + } + saveChan <- t + if p.Interval > 0 { + time.Sleep(time.Duration(p.Interval) * time.Second) + } + } +} + // 创建打印机对象 func CreatePrinter(printertab db.Printer) (p *Printer) { p = &Printer{} @@ -214,7 +243,7 @@ func StartPrinter(p *Printer, conf *conf.EnvConfig, printChan, outChan chan db.P go func() { p.printByFile(conf, outChan) }() - case "D": // 输出文件打印 + case "D": // TSC打印机输出文件打印 go func() { p.printByDLL(conf, outChan) }() @@ -222,6 +251,10 @@ func StartPrinter(p *Printer, conf *conf.EnvConfig, printChan, outChan chan db.P go func() { p.printByExcel(conf, printChan) }() + case "S": // 网口打印机 + go func() { + p.printBySerial(conf, printChan) + }() } }