commit 5515ece4f06e79221074f46c3d0357e812d64479
Author: huangsimin <huangsimin@ecpark.cn>
Date: Fri Nov 1 21:47:11 2019 +0800
init
diff --git a/command.go b/command.go
new file mode 100644
index 0000000..a379525
--- /dev/null
+++ b/command.go
@@ -0,0 +1,15 @@
+package main
+
+import "time"
+
+// Command 命令相关
+type Command struct {
+ commands string
+ commandTime time.Time
+}
+
+// NewCommand 生成一个命令
+func NewCommand() *Command {
+ c := &Command{}
+ return c
+}
diff --git a/go.mod b/go.mod
new file mode 100644
index 0000000..8fec63c
--- /dev/null
+++ b/go.mod
@@ -0,0 +1,8 @@
+module DPF
+
+go 1.13
+
+require (
+ github.com/gin-gonic/gin v1.4.0
+ github.com/tarm/goserial v0.0.0-20151007205400-b3440c3c6355
+)
diff --git a/go.sum b/go.sum
new file mode 100644
index 0000000..7d270d8
--- /dev/null
+++ b/go.sum
@@ -0,0 +1,31 @@
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/gin-contrib/sse v0.0.0-20190301062529-5545eab6dad3 h1:t8FVkw33L+wilf2QiWkw0UV77qRpcH/JHPKGpKa2E8g=
+github.com/gin-contrib/sse v0.0.0-20190301062529-5545eab6dad3/go.mod h1:VJ0WA2NBN22VlZ2dKZQPAPnyWw5XTlK1KymzLKsr59s=
+github.com/gin-gonic/gin v1.4.0 h1:3tMoCCfM7ppqsR0ptz/wi1impNpT7/9wQtMZ8lr1mCQ=
+github.com/gin-gonic/gin v1.4.0/go.mod h1:OW2EZn3DO8Ln9oIKOvM++LBO+5UPHJJDH72/q/3rZdM=
+github.com/golang/protobuf v1.3.1 h1:YF8+flBXS5eO826T4nzqPrxfhQThhXl0YzfuUPu4SBg=
+github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/json-iterator/go v1.1.6/go.mod h1:+SdeFBvtyEkXs7REEP0seUULqWtbJapLOCVDaaPEHmU=
+github.com/mattn/go-isatty v0.0.7 h1:UvyT9uN+3r7yLEYSlJsbQGdsaB/a0DlgWP3pql6iwOc=
+github.com/mattn/go-isatty v0.0.7/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
+github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
+github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/tarm/goserial v0.0.0-20151007205400-b3440c3c6355 h1:Kp3kg8YL2dc75mckomrHZQTfzNyFGnaqFhJeQw4ozGc=
+github.com/tarm/goserial v0.0.0-20151007205400-b3440c3c6355/go.mod h1:jcMo2Odv5FpDA6rp8bnczbUolcICW6t54K3s9gOlgII=
+github.com/ugorji/go v1.1.4 h1:j4s+tAvLfL3bZyefP2SEWmhBzmuIlH/eqNuPdFPgngw=
+github.com/ugorji/go v1.1.4/go.mod h1:uQMGLiO92mf5W77hV/PUCpI3pbzQx3CRekS0kk+RGrc=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/net v0.0.0-20190503192946-f4e77d36d62c/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190222072716-a9d3bda3a223 h1:DH4skfRX4EBpamg7iV4ZlCpblAHI6s6TDM39bFZumv8=
+golang.org/x/sys v0.0.0-20190222072716-a9d3bda3a223/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/go-playground/assert.v1 v1.2.1/go.mod h1:9RXL0bg/zibRAgZUYszZSwO/z8Y/a8bDuhia5mkpMnE=
+gopkg.in/go-playground/validator.v8 v8.18.2 h1:lFB4DoMU6B626w8ny76MV7VX6W2VHct2GVOI3xgiMrQ=
+gopkg.in/go-playground/validator.v8 v8.18.2/go.mod h1:RX2a/7Ha8BgOhfk7j780h4/u/RRjR0eouCJSH80/M2Y=
+gopkg.in/yaml.v2 v2.2.2 h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
diff --git a/main.go b/main.go
new file mode 100644
index 0000000..092e344
--- /dev/null
+++ b/main.go
@@ -0,0 +1,16 @@
+package main
+
+import (
+ "log"
+
+ "github.com/gin-gonic/gin"
+)
+
+func main() {
+ engine := gin.Default()
+
+ engine.GET("/status")
+ engine.POST("/operate")
+
+ log.Fatal(engine.Run(":15678"))
+}
diff --git a/serialport.go b/serialport.go
new file mode 100644
index 0000000..43da296
--- /dev/null
+++ b/serialport.go
@@ -0,0 +1,72 @@
+package main
+
+import (
+ "io"
+ "sync"
+
+ serial "github.com/tarm/goserial"
+)
+
+// CurrentOS 系统类别
+const CurrentOS = "linux"
+
+// SerialPort 串口
+type SerialPort struct {
+ com string
+ port1 string
+ port2 string
+
+ windowsRWLock *sync.Mutex
+ windowsRWPort io.ReadWriteCloser
+
+ linuxRPort io.ReadWriteCloser
+ linuxWPort io.ReadWriteCloser
+
+ baud int // 9600
+}
+
+// NewSerialPort 创建串口
+func NewSerialPort() *SerialPort {
+
+ sp := &SerialPort{}
+
+ sp.com = "COM1"
+
+ sp.port1 = "/dev/pts/11"
+ sp.port2 = "/dev/pts/12"
+
+ sp.baud = 9600
+
+ sp.windowsRWLock = &sync.Mutex{}
+
+ return sp
+}
+
+// OpenPort 打开串口
+func (sp *SerialPort) OpenPort() {
+
+ if CurrentOS == "linux" {
+
+ cfg1 := &serial.Config{Name: sp.port1, Baud: sp.baud, ReadTimeout: 5}
+ port1, err := serial.OpenPort(cfg1)
+ if err != nil {
+ sp.linuxRPort = port1
+ }
+
+ cfg2 := &serial.Config{Name: sp.port2, Baud: sp.baud, ReadTimeout: 5}
+ port2, err := serial.OpenPort(cfg2)
+ if err != nil {
+ sp.linuxWPort = port2
+ }
+
+ } else {
+
+ cfg1 := &serial.Config{Name: sp.com, Baud: sp.baud, ReadTimeout: 5}
+ port1, err := serial.OpenPort(cfg1)
+ if err != nil {
+ sp.windowsRWPort = port1
+ }
+
+ }
+
+}
diff --git a/worker.go b/worker.go
new file mode 100644
index 0000000..923ec12
--- /dev/null
+++ b/worker.go
@@ -0,0 +1,173 @@
+package main
+
+import (
+ "log"
+ "sync"
+ "time"
+)
+
+// Worker 接收命令
+type Worker struct {
+ commandLock *sync.Mutex
+ command *Command
+
+ port *SerialPort // 串口相关
+
+ readlogsLock *sync.Mutex
+ readlogs []Log
+
+ writelogsLock *sync.Mutex
+ isOperating bool
+ writelogs []Log
+
+ isStop int
+ waitGroup *sync.WaitGroup
+}
+
+// Log 日志
+type Log struct {
+ Data []byte
+ Time time.Time
+}
+
+// NewWorker 创建一个工人
+func NewWorker() *Worker {
+ w := &Worker{}
+
+ w.isStop = 0
+ w.waitGroup = &sync.WaitGroup{}
+
+ w.command = NewCommand()
+ w.commandLock = new(sync.Mutex)
+
+ w.readlogsLock = &sync.Mutex{}
+ w.readlogs = make([]Log, 0, 1000)
+
+ w.writelogsLock = &sync.Mutex{}
+ w.writelogs = make([]Log, 0, 1000)
+ w.isOperating = false
+
+ return w
+}
+
+func (worker *Worker) write(data []byte) {
+ worker.writelogsLock.Lock()
+ worker.isOperating = true
+ worker.writelogs = append(worker.writelogs, Log{data, time.Now()})
+ if len(worker.writelogs) >= 1000 {
+ worker.writelogs = worker.writelogs[500:1000]
+ }
+ worker.writelogsLock.Unlock()
+}
+
+// read 如果没有读到数据为nil
+func (worker *Worker) read() (result []byte) {
+
+ worker.readlogsLock.Lock()
+ if len(worker.readlogs) > 0 {
+ copy(worker.readlogs[len(worker.readlogs)-1].Data, result)
+ }
+ worker.writelogsLock.Unlock()
+
+ return result
+}
+
+func (worker *Worker) operator(wait *sync.WaitGroup) {
+ defer wait.Done()
+
+ if CurrentOS == "linux" {
+
+ for {
+
+ if worker.isStop > 0 {
+ break
+ }
+
+ now := time.Now()
+ worker.writelogsLock.Lock()
+ if worker.isOperating {
+ l := worker.writelogs[len(worker.writelogs)-1]
+ if now.Sub(l.Time).Seconds() >= 5 {
+ // TODO: 操作
+ worker.isOperating = false
+ }
+
+ }
+ worker.writelogsLock.Unlock()
+ }
+
+ } else { // Windows
+
+ }
+
+}
+
+func (worker *Worker) status(wait *sync.WaitGroup) {
+ defer wait.Done()
+
+ if CurrentOS == "linux" {
+
+ for {
+
+ if worker.isStop > 0 {
+ break
+ }
+
+ var buf []byte
+ n, err := worker.port.linuxRPort.Read(buf)
+ if err != nil {
+ log.Println(err)
+ } else {
+ if n > 0 {
+
+ worker.readlogsLock.Lock()
+ worker.readlogs = append(worker.readlogs, Log{buf, time.Now()})
+ if len(worker.readlogs) >= 1000 {
+ worker.readlogs = worker.readlogs[500:1000]
+ }
+
+ log.Println("data size ", n)
+ log.Panicln("data: ", buf)
+ worker.readlogsLock.Unlock()
+
+ }
+ }
+
+ time.Sleep(time.Millisecond * 50)
+ }
+
+ } else { // windows
+
+ for {
+
+ var buf []byte
+ n, err := worker.port.windowsRWPort.Read(buf)
+ if err != nil {
+ log.Println(err)
+ } else {
+ if n > 0 {
+
+ log.Println("data size ", n)
+ log.Panicln("data: ", buf)
+
+ }
+ }
+
+ time.Sleep(time.Millisecond * 50)
+ }
+ }
+
+}
+
+// Run 运行
+func (worker *Worker) Run() {
+
+ sp := NewSerialPort()
+ sp.OpenPort()
+ worker.port = sp
+
+ worker.waitGroup.Add(1)
+ go worker.status(worker.waitGroup)
+
+ worker.waitGroup.Wait()
+}