JiXieShi
/
SerialTerminalForWindowsTerminal
mirror of https://github.com/jixishi/SerialTerminalForWindowsTerminal.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

增加hex收发功能

main
JiXieShi 2024-04-13 14:44:48 +08:00
parent d6458dd31d
commit 61ad821ecc
1 changed files with 112 additions and 87 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

199
main.go
View File

@ -2,6 +2,7 @@ package main
import ( import (
"bufio" "bufio"
"encoding/hex"
"flag" "flag"
"fmt" "fmt"
"github.com/zimolab/charsetconv" "github.com/zimolab/charsetconv"
@ -13,33 +14,32 @@ import (
) )
type Config struct { type Config struct {
logPath string enableLog bool
port string logFilePath string
endstr string portName string
codein string endStr string
codeout string inputCode string
baud int outputCode string
prity int baudRate int
stopbits int parityBit int
databits int stopBits int
logFlag bool dataBits int
} }
type Cmd struct { type Command struct {
name string name string
des string description string
call func() function func()
} }
var ( var (
conf Config config Config
cmds []Cmd commands []Command
port serial.Port serialPort serial.Port
err error err error
args []string
args []string
) )
func CheckPort() { func checkPortAvailability() {
ports, err := serial.GetPortsList() ports, err := serial.GetPortsList()
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
@ -52,14 +52,14 @@ func CheckPort() {
fmt.Printf(" %v", port) fmt.Printf(" %v", port)
} }
} }
func usage() { func printUsage() {
CheckPort() checkPortAvailability()
fmt.Printf("\n参数帮助:\n") fmt.Printf("\n参数帮助:\n")
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "p", "port", "", "连接的串口(/dev/ttyUSB0、COMx)", "") fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "p", "portName", "", "连接的串口(/dev/ttyUSB0、COMx)", "")
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "b", "baud", 115200, "波特率", 115200) fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "b", "baudRate", 115200, "波特率", 115200)
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "s", "stop", 1, "停止位", 1)
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "d", "data", 8, "数据位", 8) fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "d", "data", 8, "数据位", 8)
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "s", "stop", 0, "停止位停止位(0: 1停止 1:1.5停止 2:2停止)", 0)
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "o", "out", "UTF-8", "输出编码", "UTF-8") fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "o", "out", "UTF-8", "输出编码", "UTF-8")
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "i", "in", "UTF-8", "输入编码", "UTF-8") fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "i", "in", "UTF-8", "输入编码", "UTF-8")
fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "e", "end", "\n", "终端换行符", "\\n") fmt.Printf("\t-%v -%v %T \n\t %v\t默认值:%v\n", "e", "end", "\n", "终端换行符", "\\n")
@ -69,55 +69,69 @@ func usage() {
} }
func init() { func init() {
log.SetFlags(log.Ldate | log.Ltime | log.Lshortfile | log.Lmsgprefix) log.SetFlags(log.Ldate | log.Ltime | log.Lshortfile | log.Lmsgprefix)
flag.BoolVar(&conf.logFlag, "log", false, "是否启用日志保存") flag.BoolVar(&config.enableLog, "log", false, "是否启用日志保存")
flag.BoolVar(&conf.logFlag, "l", false, "") flag.BoolVar(&config.enableLog, "l", false, "")
flag.StringVar(&conf.logPath, "Path", "./Log.txt", "日志保存路径") flag.StringVar(&config.logFilePath, "Path", "./Log.txt", "日志保存路径")
flag.StringVar(&conf.logPath, "P", "./Log.txt", "") flag.StringVar(&config.logFilePath, "P", "./Log.txt", "")
flag.StringVar(&conf.port, "port", "", "连接的串口\t(/dev/ttyUSB0、COMx)") flag.StringVar(&config.portName, "portName", "", "连接的串口\t(/dev/ttyUSB0、COMx)")
flag.StringVar(&conf.port, "p", "", "") flag.StringVar(&config.portName, "p", "", "")
flag.StringVar(&conf.endstr, "end", "\n", "终端换行符") flag.StringVar(&config.endStr, "end", "\n", "终端换行符")
flag.StringVar(&conf.endstr, "e", "\n", "") flag.StringVar(&config.endStr, "e", "\n", "")
flag.IntVar(&conf.baud, "baud", 115200, "波特率") flag.IntVar(&config.baudRate, "baudRate", 115200, "波特率")
flag.IntVar(&conf.baud, "b", 115200, "") flag.IntVar(&config.baudRate, "b", 115200, "")
flag.IntVar(&conf.prity, "verify", 0, "奇偶校验(0:无校验、1:奇校验、2:偶校验、3:1校验、4:0校验)") flag.IntVar(&config.parityBit, "verify", 0, "奇偶校验(0:无校验 1:奇校验 2:偶校验 3:1校验 4:0校验)")
flag.IntVar(&conf.prity, "v", 0, "") flag.IntVar(&config.parityBit, "v", 0, "")
flag.IntVar(&conf.stopbits, "stop", 1, "停止位") flag.IntVar(&config.stopBits, "stop", 0, "停止位(0: 1停止 1:1.5停止 2:2停止)")
flag.IntVar(&conf.stopbits, "s", 1, "") flag.IntVar(&config.stopBits, "s", 0, "")
flag.IntVar(&conf.databits, "data", 8, "数据位") flag.IntVar(&config.dataBits, "data", 8, "数据位")
flag.IntVar(&conf.databits, "d", 8, "") flag.IntVar(&config.dataBits, "d", 8, "")
flag.StringVar(&conf.codeout, "out", "UTF-8", "输出编码") flag.StringVar(&config.outputCode, "out", "UTF-8", "输出编码")
flag.StringVar(&conf.codeout, "o", "UTF-8", "") flag.StringVar(&config.outputCode, "o", "UTF-8", "")
flag.StringVar(&conf.codein, "in", "UTF-8", "输入编码") flag.StringVar(&config.inputCode, "in", "UTF-8", "输入编码")
flag.StringVar(&conf.codein, "i", "UTF-8", "") flag.StringVar(&config.inputCode, "i", "UTF-8", "")
cmdinit() cmdinit()
} }
func cmdhelp() { func cmdhelp() {
var page = 0 var page = 0
fmt.Printf(">-------Help(%v)-------<\n", page) fmt.Printf(">-------Help(%v)-------<\n", page)
for i := 0; i < len(cmds); i++ { for i := 0; i < len(commands); i++ {
output(conf.codeout, fmt.Sprintf(" %-10v --%v\n", cmds[i].name, cmds[i].des)) strout(config.outputCode, fmt.Sprintf(" %-10v --%v\n", commands[i].name, commands[i].description))
} }
} }
func cmdexit() { func cmdexit() {
os.Exit(0) os.Exit(0)
} }
func cmdargs() { func cmdargs() {
fmt.Printf(">-------Args()-------<\n") fmt.Printf(">-------Args(%v)-------<\n", len(args)-1)
fmt.Printf("%q\n", args) fmt.Printf("%q\n", args[1:])
}
func cmdhex() {
fmt.Printf(">-----Hex Send-----<\n")
fmt.Printf("%q\n", args[1:])
s := strings.Join(args[1:], "")
b, err := hex.DecodeString(s)
if err != nil {
log.Fatal(err)
}
_, err = serialPort.Write(b)
if err != nil {
log.Fatal(err)
}
} }
func cmdinit() { func cmdinit() {
cmds = append(cmds, Cmd{name: ".help", des: "帮助信息", call: cmdhelp}) commands = append(commands, Command{name: ".help", description: "帮助信息", function: cmdhelp})
cmds = append(cmds, Cmd{name: ".args", des: "参数信息", call: cmdargs}) commands = append(commands, Command{name: ".args", description: "参数信息", function: cmdargs})
cmds = append(cmds, Cmd{name: ".exit", des: "退出终端", call: cmdexit}) commands = append(commands, Command{name: ".hex", description: "发送Hex", function: cmdhex})
commands = append(commands, Command{name: ".exit", description: "退出终端", function: cmdexit})
} }
func input() { func input() {
input := bufio.NewScanner(os.Stdin) input := bufio.NewScanner(os.Stdin)
@ -125,66 +139,77 @@ func input() {
for { for {
input.Scan() input.Scan()
args = strings.Split(input.Text(), " ") args = strings.Split(input.Text(), " ")
for _, cmd := range cmds { for _, cmd := range commands {
if strings.Compare(strings.TrimSpace(args[0]), cmd.name) == 0 { if strings.Compare(strings.TrimSpace(args[0]), cmd.name) == 0 {
cmd.call() cmd.function()
ok = true ok = true
} }
} }
if !ok { if !ok {
_, err := port.Write(input.Bytes()) _, err := serialPort.Write(input.Bytes())
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
_, err = io.WriteString(port, conf.endstr) _, err = io.WriteString(serialPort, config.endStr)
//_, err = io.Copy(portName, os.Stdin)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
} }
} }
} }
func output(cs, str string) { func strout(cs, str string) {
charsetconv.EncodeWith(strings.NewReader(str), os.Stdout, charsetconv.Charset(cs), false) err = charsetconv.EncodeWith(strings.NewReader(str), os.Stdout, charsetconv.Charset(cs), false)
}
func main() {
flag.Parse()
if conf.port == "" {
fmt.Println("端口未指定")
usage()
os.Exit(0)
}
mode := &serial.Mode{
BaudRate: conf.baud,
StopBits: serial.StopBits(conf.stopbits),
DataBits: conf.databits,
Parity: serial.Parity(conf.prity),
}
port, err = serial.Open(conf.port, mode)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
defer port.Close() }
func output(out io.Writer) {
if strings.Compare(config.inputCode, "hex") == 0 {
_, err = io.Copy(hex.NewEncoder(out), serialPort)
} else {
err = charsetconv.ConvertWith(serialPort, charsetconv.Charset(config.inputCode), out, charsetconv.Charset(config.outputCode), false)
}
if err != nil {
log.Fatal(err)
}
}
func main() {
flag.Parse()
if config.portName == "" {
fmt.Println("端口未指定")
printUsage()
os.Exit(0)
}
mode := &serial.Mode{
BaudRate: config.baudRate,
StopBits: serial.StopBits(config.stopBits),
DataBits: config.dataBits,
Parity: serial.Parity(config.parityBit),
}
serialPort, err = serial.Open(config.portName, mode)
if err != nil {
log.Fatal(err)
}
defer func(port serial.Port) {
err := port.Close()
if err != nil {
}
}(serialPort)
go input() go input()
if conf.logFlag { if config.enableLog {
f, err := os.OpenFile(conf.logPath, os.O_RDWR|os.O_APPEND|os.O_CREATE, 0666) f, err := os.OpenFile(config.logFilePath, os.O_RDWR|os.O_APPEND|os.O_CREATE, 0666)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
out := io.MultiWriter(os.Stdout, f) out := io.MultiWriter(os.Stdout, f)
for { for {
err = charsetconv.ConvertWith(port, charsetconv.Charset(conf.codein), out, charsetconv.Charset(conf.codeout), false) output(out)
//_, err = io.Copy(out, port)
if err != nil {
log.Fatal(err)
}
} }
} else { } else {
for { for {
err = charsetconv.ConvertWith(port, charsetconv.Charset(conf.codein), os.Stdout, charsetconv.Charset(conf.codeout), false) output(os.Stdout)
//_, err := io.Copy(os.Stdout, port)
if err != nil {
log.Fatal(err)
}
} }
} }
} }