From 2a6f8c594b2278b5e8a9e126393860399226cfa8 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 11:22:03 +0800
Subject: [PATCH 01/38] git flow init

---
 .idea/vcs.xml       |  6 ++++++
 .idea/workspace.xml | 15 +++++++++++++++
 2 files changed, 21 insertions(+)
 create mode 100644 .idea/vcs.xml

diff --git a/.idea/vcs.xml b/.idea/vcs.xml
new file mode 100644
index 0000000..94a25f7
--- /dev/null
+++ b/.idea/vcs.xml
@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>
\ No newline at end of file
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 358167b..134a9a7 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -8,7 +8,11 @@
     <option name="LAST_RESOLUTION" value="IGNORE" />
   </component>
   <component name="GOROOT" url="file:///usr/local/Cellar/go/1.15.5/libexec" />
+  <component name="Git.Settings">
+    <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
+  </component>
   <component name="ProjectId" id="1lm7nLrR9364W3kc4Ropplb4iwV" />
+  <component name="ProjectLevelVcsManager" settingsEditedManually="true" />
   <component name="ProjectViewState">
     <option name="hideEmptyMiddlePackages" value="true" />
     <option name="showLibraryContents" value="true" />
@@ -33,6 +37,17 @@
   <component name="TypeScriptGeneratedFilesManager">
     <option name="version" value="3" />
   </component>
+  <component name="Vcs.Log.Tabs.Properties">
+    <option name="TAB_STATES">
+      <map>
+        <entry key="MAIN">
+          <value>
+            <State />
+          </value>
+        </entry>
+      </map>
+    </option>
+  </component>
   <component name="VgoProject">
     <integration-enabled>true</integration-enabled>
     <environment>

From 787a9494289d55b97f017a4fdb60cbeeacafdc3e Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 11:35:47 +0800
Subject: [PATCH 02/38] add git ignore file

---
 .gitignore | 2 ++
 1 file changed, 2 insertions(+)
 create mode 100644 .gitignore

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..ded517d
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,2 @@
+tty*
+telegram.db
\ No newline at end of file

From 8e417699c06a56e603cc343e6edce9ad93f67540 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 11:36:08 +0800
Subject: [PATCH 03/38] add test db

---
 .idea/workspace.xml | 10 +++++++++-
 cmd/root.go         |  5 +++++
 cmd/test.go         |  3 +++
 database/sqlite.go  | 12 ++++++++++--
 go.mod              |  1 +
 go.sum              |  2 ++
 telegram.yaml       |  1 +
 7 files changed, 31 insertions(+), 3 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 134a9a7..acfec4a 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -1,7 +1,15 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="ChangeListManager">
-    <list default="true" id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="" />
+    <list default="true" id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="">
+      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cmd/root.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/root.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cmd/test.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/test.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/database/sqlite.go" beforeDir="false" afterPath="$PROJECT_DIR$/database/sqlite.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/go.mod" beforeDir="false" afterPath="$PROJECT_DIR$/go.mod" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/go.sum" beforeDir="false" afterPath="$PROJECT_DIR$/go.sum" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/telegram.yaml" beforeDir="false" afterPath="$PROJECT_DIR$/telegram.yaml" afterDir="false" />
+    </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
     <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
diff --git a/cmd/root.go b/cmd/root.go
index bf391e3..ac88a72 100644
--- a/cmd/root.go
+++ b/cmd/root.go
@@ -29,6 +29,9 @@ var (
 	baudrate int
 	bytesize byte
 
+	dbFile string
+	dbInit bool
+
 	// rootCmd represents the base command when called without any subcommands
 	rootCmd = &cobra.Command{
 		Use:   "tele-recv",
@@ -90,5 +93,7 @@ func initConfig() {
 		device = viper.GetString("serial.device")
 		baudrate = viper.GetInt("serial.baudrate")
 		bytesize = byte(viper.GetInt("serial.bytesize"))
+		dbFile = viper.GetString("sqlite.file")
+		dbInit = viper.GetBool("sqlite.init")
 	}
 }
diff --git a/cmd/test.go b/cmd/test.go
index c7da629..f85f5d2 100644
--- a/cmd/test.go
+++ b/cmd/test.go
@@ -20,6 +20,7 @@ import (
 	"github.com/spf13/cobra"
 	"github.com/tarm/serial"
 	"os"
+	"it2000.com.cn/tele-recv/database"
 )
 
 // testCmd represents the test command
@@ -39,6 +40,8 @@ Test serial port`,
 		}
 		fmt.Println(c , "opened")
 		_ = s.Close()
+
+		database.Init(dbFile, dbInit)
 	},
 }
 
diff --git a/database/sqlite.go b/database/sqlite.go
index 6fb0296..865ec39 100644
--- a/database/sqlite.go
+++ b/database/sqlite.go
@@ -2,20 +2,21 @@ package database
 
 import (
 	"database/sql"
+	_ "github.com/mattn/go-sqlite3"
 	"log"
 	"os"
 )
 
 const (
 	DbDriver    = "sqlite3"
-	TableCreate =`'''
+	TableCreate =`
                 create table IF NOT EXISTS telegram (
                     [tele_id] INTEGER PRIMARY KEY AUTOINCREMENT,
                     [tele_recv_time] TIMESTAMP NOT NULL DEFAULT (datetime('now', 'localtime')),
                     [tele_processed] int(1) NOT NULL DEFAULT 0,
                     [tele_text] TEXT NOT NULL    
                 )
-            '''
+            
 `
 )
 var (
@@ -37,5 +38,12 @@ func getDb(file string, init bool) (*sql.DB, error) {
 	if err != nil {
 		log.Fatal("error in create telegram table", err)
 	}
+	log.Println("database ", db, " opened")
 	return db, nil
+}
+
+func Init(file string, init bool) error {
+	var dbErr error
+	db, dbErr = getDb(file, init)
+	return dbErr
 }
\ No newline at end of file
diff --git a/go.mod b/go.mod
index 80c8d48..4f116c0 100644
--- a/go.mod
+++ b/go.mod
@@ -5,6 +5,7 @@ go 1.15
 require (
 	github.com/fsnotify/fsnotify v1.4.9 // indirect
 	github.com/magiconair/properties v1.8.4 // indirect
+	github.com/mattn/go-sqlite3 v1.14.5
 	github.com/mitchellh/mapstructure v1.4.0 // indirect
 	github.com/pelletier/go-toml v1.8.1 // indirect
 	github.com/spf13/afero v1.5.1 // indirect
diff --git a/go.sum b/go.sum
index 0620a98..41b0411 100644
--- a/go.sum
+++ b/go.sum
@@ -118,6 +118,8 @@ github.com/magiconair/properties v1.8.4 h1:8KGKTcQQGm0Kv7vEbKFErAoAOFyyacLStRtQS
 github.com/magiconair/properties v1.8.4/go.mod h1:y3VJvCyxH9uVvJTWEGAELF3aiYNyPKd5NZ3oSwXrF60=
 github.com/mattn/go-colorable v0.0.9/go.mod h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU=
 github.com/mattn/go-isatty v0.0.3/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
+github.com/mattn/go-sqlite3 v1.14.5 h1:1IdxlwTNazvbKJQSxoJ5/9ECbEeaTTyeU7sEAZ5KKTQ=
+github.com/mattn/go-sqlite3 v1.14.5/go.mod h1:WVKg1VTActs4Qso6iwGbiFih2UIHo0ENGwNd0Lj+XmI=
 github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
 github.com/miekg/dns v1.0.14/go.mod h1:W1PPwlIAgtquWBMBEV9nkV9Cazfe8ScdGz/Lj7v3Nrg=
 github.com/mitchellh/cli v1.0.0/go.mod h1:hNIlj7HEI86fIcpObd7a0FcrxTWetlwJDGcceTlRvqc=
diff --git a/telegram.yaml b/telegram.yaml
index 86babc5..9fc6efc 100644
--- a/telegram.yaml
+++ b/telegram.yaml
@@ -6,3 +6,4 @@ serial:
 
 sqlite:
   file: telegram.db
+  init: true

From cd302234af2703e79d05b07ad80999022801d2d2 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 11:42:36 +0800
Subject: [PATCH 04/38] create test function

---
 .idea/workspace.xml | 11 +++++------
 cmd/test.go         | 40 +++++++++++++++++++++++-----------------
 2 files changed, 28 insertions(+), 23 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index acfec4a..2e7b71d 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -1,14 +1,9 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="ChangeListManager">
-    <list default="true" id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="">
+    <list default="true" id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="create test function">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/cmd/root.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/root.go" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/cmd/test.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/test.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/database/sqlite.go" beforeDir="false" afterPath="$PROJECT_DIR$/database/sqlite.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/go.mod" beforeDir="false" afterPath="$PROJECT_DIR$/go.mod" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/go.sum" beforeDir="false" afterPath="$PROJECT_DIR$/go.sum" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/telegram.yaml" beforeDir="false" afterPath="$PROJECT_DIR$/telegram.yaml" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -56,6 +51,10 @@
       </map>
     </option>
   </component>
+  <component name="VcsManagerConfiguration">
+    <MESSAGE value="create test function" />
+    <option name="LAST_COMMIT_MESSAGE" value="create test function" />
+  </component>
   <component name="VgoProject">
     <integration-enabled>true</integration-enabled>
     <environment>
diff --git a/cmd/test.go b/cmd/test.go
index f85f5d2..26a9aa0 100644
--- a/cmd/test.go
+++ b/cmd/test.go
@@ -19,30 +19,36 @@ import (
 	"fmt"
 	"github.com/spf13/cobra"
 	"github.com/tarm/serial"
-	"os"
 	"it2000.com.cn/tele-recv/database"
+	"os"
 )
 
 // testCmd represents the test command
 var testCmd = &cobra.Command{
 	Use:   "test",
-	Short: "Test Config",
-	Long: `Test config file.
-Test serial port`,
-	Run: func(cmd *cobra.Command, args []string) {
-		fmt.Println("test called")
-		fmt.Println("device :",device)
-		c := &serial.Config{Name: device, Baud: baudrate, Size: bytesize}
-		s, err := serial.OpenPort(c)
-		if err != nil {
-			fmt.Println(err)
-			os.Exit(1)
-		}
-		fmt.Println(c , "opened")
-		_ = s.Close()
+	Short: "Test running environment",
+	Long: `loading config file
+Test serial port
+Test load sqlite database and init table`,
+	Run: test,
+}
 
-		database.Init(dbFile, dbInit)
-	},
+func test(cmd *cobra.Command, args []string) {
+	fmt.Println("test called")
+	fmt.Println("device :", device)
+	c := &serial.Config{Name: device, Baud: baudrate, Size: bytesize}
+	s, err := serial.OpenPort(c)
+	if err != nil {
+		fmt.Println(err)
+		os.Exit(1)
+	}
+	fmt.Println(c, "opened")
+	_ = s.Close()
+
+	err = database.Init(dbFile, dbInit)
+	if err != nil {
+		println("create database error ", err)
+	}
 }
 
 func init() {

From 51fa99e57b1a9166c147d0a9608a84ea6987740a Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 14:07:59 +0800
Subject: [PATCH 05/38] add git toolbox

---
 .idea/workspace.xml | 20 ++++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 2e7b71d..9a1300d 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -3,7 +3,6 @@
   <component name="ChangeListManager">
     <list default="true" id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="create test function">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/cmd/test.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/test.go" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -14,6 +13,12 @@
   <component name="Git.Settings">
     <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
   </component>
+  <component name="GitToolBoxStore">
+    <option name="projectConfigVersion" value="2" />
+  </component>
+  <component name="ProblemsViewState">
+    <option name="selectedIndex" value="1" />
+  </component>
   <component name="ProjectId" id="1lm7nLrR9364W3kc4Ropplb4iwV" />
   <component name="ProjectLevelVcsManager" settingsEditedManually="true" />
   <component name="ProjectViewState">
@@ -34,9 +39,19 @@
     <property name="node.js.path.for.package.tslint" value="project" />
     <property name="node.js.selected.package.eslint" value="(autodetect)" />
     <property name="node.js.selected.package.tslint" value="(autodetect)" />
-    <property name="settings.editor.selected.configurable" value="terminal" />
+    <property name="settings.editor.selected.configurable" value="reference.settingsdialog.IDE.editor.colors.Console Font" />
   </component>
   <component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
+  <component name="TaskManager">
+    <task active="true" id="Default" summary="Default task">
+      <changelist id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="create test function" />
+      <created>1608530373779</created>
+      <option name="number" value="Default" />
+      <option name="presentableId" value="Default" />
+      <updated>1608530373779</updated>
+    </task>
+    <servers />
+  </component>
   <component name="TypeScriptGeneratedFilesManager">
     <option name="version" value="3" />
   </component>
@@ -50,6 +65,7 @@
         </entry>
       </map>
     </option>
+    <option name="oldMeFiltersMigrated" value="true" />
   </component>
   <component name="VcsManagerConfiguration">
     <MESSAGE value="create test function" />

From 8a116818cf5f175c8585e57e032147b91bbfe4ee Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 15:38:33 +0800
Subject: [PATCH 06/38] move to utils package

---
 .gitignore                    |   3 +-
 .idea/modules.xml             |   8 ---
 .idea/tele-recv.iml           |   8 ---
 .idea/vcs.xml                 |   6 --
 .idea/workspace.xml           |  82 ---------------------------
 cmd/read.go                   |  55 ------------------
 cmd/start.go                  | 104 ++++++++++++++++++++++++++++++++++
 cmd/test.go                   |  20 ++-----
 utils/serial.go               |  45 +++++++++++++++
 {database => utils}/sqlite.go |   5 +-
 10 files changed, 158 insertions(+), 178 deletions(-)
 delete mode 100644 .idea/modules.xml
 delete mode 100644 .idea/tele-recv.iml
 delete mode 100644 .idea/vcs.xml
 delete mode 100644 .idea/workspace.xml
 delete mode 100644 cmd/read.go
 create mode 100644 cmd/start.go
 create mode 100644 utils/serial.go
 rename {database => utils}/sqlite.go (93%)

diff --git a/.gitignore b/.gitignore
index ded517d..3c379ef 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,2 +1,3 @@
 tty*
-telegram.db
\ No newline at end of file
+telegram.db
+.idea
\ No newline at end of file
diff --git a/.idea/modules.xml b/.idea/modules.xml
deleted file mode 100644
index 25d714b..0000000
--- a/.idea/modules.xml
+++ /dev/null
@@ -1,8 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ProjectModuleManager">
-    <modules>
-      <module fileurl="file://$PROJECT_DIR$/.idea/tele-recv.iml" filepath="$PROJECT_DIR$/.idea/tele-recv.iml" />
-    </modules>
-  </component>
-</project>
\ No newline at end of file
diff --git a/.idea/tele-recv.iml b/.idea/tele-recv.iml
deleted file mode 100644
index c956989..0000000
--- a/.idea/tele-recv.iml
+++ /dev/null
@@ -1,8 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<module type="WEB_MODULE" version="4">
-  <component name="NewModuleRootManager">
-    <content url="file://$MODULE_DIR$" />
-    <orderEntry type="inheritedJdk" />
-    <orderEntry type="sourceFolder" forTests="false" />
-  </component>
-</module>
\ No newline at end of file
diff --git a/.idea/vcs.xml b/.idea/vcs.xml
deleted file mode 100644
index 94a25f7..0000000
--- a/.idea/vcs.xml
+++ /dev/null
@@ -1,6 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="VcsDirectoryMappings">
-    <mapping directory="$PROJECT_DIR$" vcs="Git" />
-  </component>
-</project>
\ No newline at end of file
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
deleted file mode 100644
index 9a1300d..0000000
--- a/.idea/workspace.xml
+++ /dev/null
@@ -1,82 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ChangeListManager">
-    <list default="true" id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="create test function">
-      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-    </list>
-    <option name="SHOW_DIALOG" value="false" />
-    <option name="HIGHLIGHT_CONFLICTS" value="true" />
-    <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
-    <option name="LAST_RESOLUTION" value="IGNORE" />
-  </component>
-  <component name="GOROOT" url="file:///usr/local/Cellar/go/1.15.5/libexec" />
-  <component name="Git.Settings">
-    <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
-  </component>
-  <component name="GitToolBoxStore">
-    <option name="projectConfigVersion" value="2" />
-  </component>
-  <component name="ProblemsViewState">
-    <option name="selectedIndex" value="1" />
-  </component>
-  <component name="ProjectId" id="1lm7nLrR9364W3kc4Ropplb4iwV" />
-  <component name="ProjectLevelVcsManager" settingsEditedManually="true" />
-  <component name="ProjectViewState">
-    <option name="hideEmptyMiddlePackages" value="true" />
-    <option name="showLibraryContents" value="true" />
-  </component>
-  <component name="PropertiesComponent">
-    <property name="RunOnceActivity.OpenProjectViewOnStart" value="true" />
-    <property name="RunOnceActivity.ShowReadmeOnStart" value="true" />
-    <property name="WebServerToolWindowFactoryState" value="false" />
-    <property name="go.import.settings.migrated" value="true" />
-    <property name="go.sdk.automatically.set" value="true" />
-    <property name="go.tried.to.enable.integration.vgo.integrator" value="true" />
-    <property name="last_opened_file_path" value="$PROJECT_DIR$" />
-    <property name="node.js.detected.package.eslint" value="true" />
-    <property name="node.js.detected.package.tslint" value="true" />
-    <property name="node.js.path.for.package.eslint" value="project" />
-    <property name="node.js.path.for.package.tslint" value="project" />
-    <property name="node.js.selected.package.eslint" value="(autodetect)" />
-    <property name="node.js.selected.package.tslint" value="(autodetect)" />
-    <property name="settings.editor.selected.configurable" value="reference.settingsdialog.IDE.editor.colors.Console Font" />
-  </component>
-  <component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
-  <component name="TaskManager">
-    <task active="true" id="Default" summary="Default task">
-      <changelist id="ab419b68-984b-4661-bb9a-26bcba1547b3" name="Default Changelist" comment="create test function" />
-      <created>1608530373779</created>
-      <option name="number" value="Default" />
-      <option name="presentableId" value="Default" />
-      <updated>1608530373779</updated>
-    </task>
-    <servers />
-  </component>
-  <component name="TypeScriptGeneratedFilesManager">
-    <option name="version" value="3" />
-  </component>
-  <component name="Vcs.Log.Tabs.Properties">
-    <option name="TAB_STATES">
-      <map>
-        <entry key="MAIN">
-          <value>
-            <State />
-          </value>
-        </entry>
-      </map>
-    </option>
-    <option name="oldMeFiltersMigrated" value="true" />
-  </component>
-  <component name="VcsManagerConfiguration">
-    <MESSAGE value="create test function" />
-    <option name="LAST_COMMIT_MESSAGE" value="create test function" />
-  </component>
-  <component name="VgoProject">
-    <integration-enabled>true</integration-enabled>
-    <environment>
-      <map>
-        <entry key="GOPROXY" value="https://goproxy.io" />
-      </map>
-    </environment>
-  </component>
-</project>
\ No newline at end of file
diff --git a/cmd/read.go b/cmd/read.go
deleted file mode 100644
index d0d2799..0000000
--- a/cmd/read.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-Copyright © 2020 NAME HERE <EMAIL ADDRESS>
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-package cmd
-
-import (
-	"fmt"
-
-	"github.com/spf13/cobra"
-)
-
-// readCmd represents the read command
-var readCmd = &cobra.Command{
-	Use:   "read",
-	Short: "A brief description of your command",
-	Long: `A longer description that spans multiple lines and likely contains examples
-and usage of using your command. For example:
-
-Cobra is a CLI library for Go that empowers applications.
-This application is a tool to generate the needed files
-to quickly create a Cobra application.`,
-	Run: func(cmd *cobra.Command, args []string) {
-		fmt.Println("read called")
-	},
-}
-
-func init() {
-	rootCmd.AddCommand(readCmd)
-
-	// Here you will define your flags and configuration settings.
-
-	// Cobra supports Persistent Flags which will work for this command
-	// and all subcommands, e.g.:
-	// readCmd.PersistentFlags().String("foo", "", "A help for foo")
-
-	// Cobra supports local flags which will only run when this command
-	// is called directly, e.g.:
-	// readCmd.Flags().BoolP("toggle", "t", false, "Help message for toggle")
-}
-
-func read() {
-
-}
diff --git a/cmd/start.go b/cmd/start.go
new file mode 100644
index 0000000..7b55f6e
--- /dev/null
+++ b/cmd/start.go
@@ -0,0 +1,104 @@
+/*
+Copyright © 2020 NAME HERE <EMAIL ADDRESS>
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+package cmd
+
+import (
+	"fmt"
+	"it2000.com.cn/tele-recv/utils"
+	"log"
+	"os"
+	"os/signal"
+	"syscall"
+
+	"github.com/spf13/cobra"
+)
+
+// startCmd represents the start command
+var startCmd = &cobra.Command{
+	Use:   "start",
+	Short: "A brief description of your command",
+	Long: `A longer description that spans multiple lines and likely contains examples
+and usage of using your command. For example:
+
+Cobra is a CLI library for Go that empowers applications.
+This application is a tool to generate the needed files
+to quickly create a Cobra application.`,
+	Run: start,
+}
+
+var run bool
+
+func init() {
+	rootCmd.AddCommand(startCmd)
+
+	// Here you will define your flags and configuration settings.
+
+	// Cobra supports Persistent Flags which will work for this command
+	// and all subcommands, e.g.:
+	// startCmd.PersistentFlags().String("foo", "", "A help for foo")
+
+	// Cobra supports local flags which will only run when this command
+	// is called directly, e.g.:
+	// startCmd.Flags().BoolP("toggle", "t", false, "Help message for toggle")
+}
+
+
+func start(cmd *cobra.Command, args []string){
+	// Go signal notification works by sending `os.Signal`
+	// values on a channel. We'll create a channel to
+	// receive these notifications (we'll also make one to
+	// notify us when the program can exit).
+	sigs := make(chan os.Signal, 1)
+	done := make(chan bool, 1)
+
+	// `signal.Notify` registers the given channel to
+	// receive notifications of the specified signals.
+	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
+	run = true
+
+	// This goroutine executes a blocking receive for
+	// signals. When it gets one it'll print it out
+	// and then notify the program that it can finish.
+	go func() {
+		sig := <-sigs
+		fmt.Println()
+		fmt.Println(sig)
+		run = false
+		done <- true
+	}()
+
+	// The program will wait here until it gets the
+	// expected signal (as indicated by the goroutine
+	// above sending a value on `done`) and then exit.
+	fmt.Println("awaiting signal")
+	for run {
+		if !utils.IsPortOpen() {
+			log.Println("try to open port")
+			err := utils.OpenPort(device, baudrate, bytesize)
+			if err != nil {
+				log.Fatal("error in open serial port ", err)
+			}
+			log.Println("starting read")
+		}
+		buffer, count := utils.ReadPort()
+		if count > 0 {
+			log.Print(string(buffer))
+		}
+	}
+	<-done
+	fmt.Println("exiting")
+
+}
diff --git a/cmd/test.go b/cmd/test.go
index 26a9aa0..754a9a1 100644
--- a/cmd/test.go
+++ b/cmd/test.go
@@ -16,11 +16,9 @@ limitations under the License.
 package cmd
 
 import (
-	"fmt"
 	"github.com/spf13/cobra"
-	"github.com/tarm/serial"
-	"it2000.com.cn/tele-recv/database"
-	"os"
+	"it2000.com.cn/tele-recv/utils"
+	"log"
 )
 
 // testCmd represents the test command
@@ -34,18 +32,10 @@ Test load sqlite database and init table`,
 }
 
 func test(cmd *cobra.Command, args []string) {
-	fmt.Println("test called")
-	fmt.Println("device :", device)
-	c := &serial.Config{Name: device, Baud: baudrate, Size: bytesize}
-	s, err := serial.OpenPort(c)
-	if err != nil {
-		fmt.Println(err)
-		os.Exit(1)
-	}
-	fmt.Println(c, "opened")
-	_ = s.Close()
+	log.Println("Testing environment")
+	_ = utils.OpenPort(device, baudrate, bytesize)
 
-	err = database.Init(dbFile, dbInit)
+	err := utils.InitDb(dbFile, dbInit)
 	if err != nil {
 		println("create database error ", err)
 	}
diff --git a/utils/serial.go b/utils/serial.go
new file mode 100644
index 0000000..8c8feb1
--- /dev/null
+++ b/utils/serial.go
@@ -0,0 +1,45 @@
+package utils
+
+import (
+	"github.com/tarm/serial"
+	"io"
+	"log"
+	"time"
+)
+
+var(
+	device string
+	baudrate int
+	bytesize byte
+	port  *serial.Port
+	portOpened bool
+)
+
+func OpenPort(device string, baudrate int, bytesize byte) error {
+	log.Println("opening port device:", device, ", baudrate=", baudrate, ", bytesize=",bytesize)
+	config := &serial.Config{Name: device, Baud: baudrate, Size: bytesize, ReadTimeout: time.Second * 1}
+	var err error
+	port, err = serial.OpenPort(config)
+	if err!=nil {
+		log.Fatalln("error in open serial port ",   err)
+		return err
+	}
+	log.Println("opened port ", port)
+	portOpened = true
+	return nil
+}
+
+func ReadPort() ([]byte, int){
+	buffer := make([]byte, 256)
+	count,err := port.Read(buffer)
+	if err != nil && err != io.EOF {
+		log.Println("error in read port ", err)
+		//TODO: 3 time fail try to
+	}
+	return buffer, count
+}
+
+func IsPortOpen() bool {
+	return portOpened
+}
+
diff --git a/database/sqlite.go b/utils/sqlite.go
similarity index 93%
rename from database/sqlite.go
rename to utils/sqlite.go
index 865ec39..fd68096 100644
--- a/database/sqlite.go
+++ b/utils/sqlite.go
@@ -1,4 +1,4 @@
-package database
+package utils
 
 import (
 	"database/sql"
@@ -16,7 +16,6 @@ const (
                     [tele_processed] int(1) NOT NULL DEFAULT 0,
                     [tele_text] TEXT NOT NULL    
                 )
-            
 `
 )
 var (
@@ -42,7 +41,7 @@ func getDb(file string, init bool) (*sql.DB, error) {
 	return db, nil
 }
 
-func Init(file string, init bool) error {
+func InitDb(file string, init bool) error {
 	var dbErr error
 	db, dbErr = getDb(file, init)
 	return dbErr

From 481870cea9602d0a8e39637035e6469ca07df050 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 16:18:08 +0800
Subject: [PATCH 07/38] check telegram string

---
 cmd/start.go      |  8 +++++---
 utils/telegram.go | 38 ++++++++++++++++++++++++++++++++++++++
 2 files changed, 43 insertions(+), 3 deletions(-)
 create mode 100644 utils/telegram.go

diff --git a/cmd/start.go b/cmd/start.go
index 7b55f6e..a57af46 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -55,8 +55,7 @@ func init() {
 	// startCmd.Flags().BoolP("toggle", "t", false, "Help message for toggle")
 }
 
-
-func start(cmd *cobra.Command, args []string){
+func start(cmd *cobra.Command, args []string) {
 	// Go signal notification works by sending `os.Signal`
 	// values on a channel. We'll create a channel to
 	// receive these notifications (we'll also make one to
@@ -95,7 +94,10 @@ func start(cmd *cobra.Command, args []string){
 		}
 		buffer, count := utils.ReadPort()
 		if count > 0 {
-			log.Print(string(buffer))
+			if lograw {
+				log.Print(string(buffer))
+			}
+			utils.Append(buffer)
 		}
 	}
 	<-done
diff --git a/utils/telegram.go b/utils/telegram.go
new file mode 100644
index 0000000..e08db3b
--- /dev/null
+++ b/utils/telegram.go
@@ -0,0 +1,38 @@
+package utils
+
+import (
+	"log"
+	"regexp"
+	"strings"
+)
+
+const (
+	StartTag   = "ZCZC"
+	EndTag     = "NNNN"
+	Expression = "(?s)ZCZC.*NNNN"
+)
+
+var buffer []byte
+
+func Append(data []byte) {
+	buffer = append(buffer, data...)
+	if buffer[len(buffer)-1] == '\r' {
+		buffer = append(buffer, '\n')
+	}
+	check()
+}
+
+func check() {
+	teleString := string(buffer)
+	if strings.Index(teleString, EndTag) > 0 {
+		exp, _ := regexp.Compile(Expression)
+		telegram := exp.FindString(string(buffer))
+
+		if len(telegram) > 0 {
+			log.Println("telegram : ", telegram)
+			buffer = nil
+			//TODO save telegram
+		}
+	}
+
+}

From 92a10cd4e6eaa64ea2486eafc3bdd0a8e7a22286 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 16:18:22 +0800
Subject: [PATCH 08/38] add lograw option

---
 cmd/root.go   | 7 ++++---
 telegram.yaml | 1 +
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/cmd/root.go b/cmd/root.go
index ac88a72..b94343a 100644
--- a/cmd/root.go
+++ b/cmd/root.go
@@ -24,10 +24,11 @@ import (
 )
 
 var (
-	cfgFile string
-	device string
+	cfgFile  string
+	device   string
 	baudrate int
 	bytesize byte
+	lograw   bool
 
 	dbFile string
 	dbInit bool
@@ -86,13 +87,13 @@ func initConfig() {
 
 	viper.AutomaticEnv() // read in environment variables that match
 
-
 	// If a config file is found, read it in.
 	if err := viper.ReadInConfig(); err == nil {
 		fmt.Println("Using config file:", viper.ConfigFileUsed())
 		device = viper.GetString("serial.device")
 		baudrate = viper.GetInt("serial.baudrate")
 		bytesize = byte(viper.GetInt("serial.bytesize"))
+		lograw = viper.GetBool("serial.lograw")
 		dbFile = viper.GetString("sqlite.file")
 		dbInit = viper.GetBool("sqlite.init")
 	}
diff --git a/telegram.yaml b/telegram.yaml
index 9fc6efc..1d18547 100644
--- a/telegram.yaml
+++ b/telegram.yaml
@@ -2,6 +2,7 @@ serial:
   device: ttyS1
   baudrate: 9600
   bytesize: 7
+  lograw: true
 
 
 sqlite:

From 5fb48afd7b8bd551535137bcfa6b5cee9ccee5d5 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 16:21:43 +0800
Subject: [PATCH 09/38] remove start tag

---
 utils/telegram.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/utils/telegram.go b/utils/telegram.go
index e08db3b..f9f216e 100644
--- a/utils/telegram.go
+++ b/utils/telegram.go
@@ -7,7 +7,6 @@ import (
 )
 
 const (
-	StartTag   = "ZCZC"
 	EndTag     = "NNNN"
 	Expression = "(?s)ZCZC.*NNNN"
 )

From 540e682c0baf29a8dc2628434d91a144480d1828 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 17:58:30 +0800
Subject: [PATCH 10/38] add socket

---
 cmd/root.go     |  3 +++
 telegram.yaml   |  4 ++++
 utils/socket.go | 46 ++++++++++++++++++++++++++++++++++++++++++++++
 3 files changed, 53 insertions(+)
 create mode 100644 utils/socket.go

diff --git a/cmd/root.go b/cmd/root.go
index b94343a..2db00aa 100644
--- a/cmd/root.go
+++ b/cmd/root.go
@@ -33,6 +33,8 @@ var (
 	dbFile string
 	dbInit bool
 
+	socketAddress string
+
 	// rootCmd represents the base command when called without any subcommands
 	rootCmd = &cobra.Command{
 		Use:   "tele-recv",
@@ -96,5 +98,6 @@ func initConfig() {
 		lograw = viper.GetBool("serial.lograw")
 		dbFile = viper.GetString("sqlite.file")
 		dbInit = viper.GetBool("sqlite.init")
+		socketAddress = viper.GetString("socket.address")
 	}
 }
diff --git a/telegram.yaml b/telegram.yaml
index 1d18547..56d430a 100644
--- a/telegram.yaml
+++ b/telegram.yaml
@@ -8,3 +8,7 @@ serial:
 sqlite:
   file: telegram.db
   init: true
+
+
+socket:
+  address: 127.0.0.1:6000
\ No newline at end of file
diff --git a/utils/socket.go b/utils/socket.go
new file mode 100644
index 0000000..d5b9d57
--- /dev/null
+++ b/utils/socket.go
@@ -0,0 +1,46 @@
+package utils
+
+import (
+	"log"
+	"net"
+)
+
+const ServerType = "tcp"
+
+var ServerRunning = false
+var client net.Conn
+
+func Listen(address string) {
+	server, err := net.Listen(ServerType, address)
+	if err != nil {
+		log.Fatal("error in create server ", err)
+	}
+	defer server.Close()
+	log.Println("listen on ", address)
+	for ServerRunning {
+		conn, err := server.Accept()
+		if err != nil {
+			ServerRunning = false
+			log.Fatalln("error in create connection ", err)
+		}
+		if client == nil {
+			client = conn
+		} else {
+			log.Println("client already connected, close")
+			conn.Close()
+		}
+	}
+}
+
+func Write(data string) {
+	defer func() {
+		client.Close()
+		client = nil
+	}()
+	_, err := client.Write([]byte(data))
+	if err != nil {
+		log.Println("error in write data to client socket ", err)
+		client.Close()
+		client = nil
+	}
+}

From f67d00d6b86f3a22ccc3b270e0b7f03e55aee264 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 17:58:55 +0800
Subject: [PATCH 11/38] add insert new telegram

---
 utils/sqlite.go | 77 ++++++++++++++++++++++++++++++++++++-------------
 1 file changed, 57 insertions(+), 20 deletions(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index fd68096..90753d1 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -5,11 +5,12 @@ import (
 	_ "github.com/mattn/go-sqlite3"
 	"log"
 	"os"
+	"time"
 )
 
 const (
 	DbDriver    = "sqlite3"
-	TableCreate =`
+	TableCreate = `
                 create table IF NOT EXISTS telegram (
                     [tele_id] INTEGER PRIMARY KEY AUTOINCREMENT,
                     [tele_recv_time] TIMESTAMP NOT NULL DEFAULT (datetime('now', 'localtime')),
@@ -17,32 +18,68 @@ const (
                     [tele_text] TEXT NOT NULL    
                 )
 `
-)
-var (
-	db *sql.DB
+	TableInsert = "insert into telegram (tele_text) values (?)"
 )
 
-func getDb(file string, init bool) (*sql.DB, error) {
-	log.Println("init database ", init)
-	if init {
-		log.Println("remove database file", file)
-		os.Remove(file)
+var (
+	dbFile      string
+	initTable   bool
+	initialized bool
+	isWriting   bool
+)
+
+func getDb() *sql.DB {
+	log.Println("init database ", initTable)
+	if initTable && !initialized {
+		log.Println("remove database file", dbFile)
+		os.Remove(dbFile)
 	}
-	db, err := sql.Open(DbDriver, file)
-	defer db.Close()
+	db, err := sql.Open(DbDriver, dbFile)
 	if err != nil {
 		log.Fatal("error in open database ", err)
 	}
-	_, err = db.Exec(TableCreate)
-	if err != nil {
-		log.Fatal("error in create telegram table", err)
-	}
-	log.Println("database ", db, " opened")
-	return db, nil
+	return db
 }
 
 func InitDb(file string, init bool) error {
+	dbFile = file
+	initTable = init
 	var dbErr error
-	db, dbErr = getDb(file, init)
-	return dbErr
-}
\ No newline at end of file
+	db := getDb()
+	defer db.Close()
+	_, dbErr = db.Exec(TableCreate)
+	if dbErr != nil {
+		log.Fatal("error in create telegram table", dbErr)
+	}
+	log.Println("database ", db, " initialized")
+	initialized = true
+	return nil
+}
+
+func InsertTelegram(teleString string) {
+	count := 0
+	for isWriting && count < 5 {
+		log.Println("waiting for write ")
+		time.Sleep(3 * time.Second)
+		count++
+	}
+	if count >= 5 {
+		log.Fatalln("database locked")
+	}
+	isWriting = true
+	db := getDb()
+	defer db.Close()
+	stmt, err := db.Prepare(TableInsert)
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer stmt.Close()
+	result, err := stmt.Exec(teleString)
+	id, _ := result.LastInsertId()
+	if err != nil {
+		isWriting = false
+		log.Fatalln("error in write telegram")
+	}
+	log.Println("telegram insert ", id)
+	isWriting = false
+}

From 62102871230d11f1bc23a0c689d452625b019636 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 17:59:15 +0800
Subject: [PATCH 12/38] add socket server

---
 cmd/start.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/cmd/start.go b/cmd/start.go
index a57af46..5c610e6 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -66,7 +66,7 @@ func start(cmd *cobra.Command, args []string) {
 	// `signal.Notify` registers the given channel to
 	// receive notifications of the specified signals.
 	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
-	run = true
+	utils.ServerRunning = true
 
 	// This goroutine executes a blocking receive for
 	// signals. When it gets one it'll print it out
@@ -83,7 +83,9 @@ func start(cmd *cobra.Command, args []string) {
 	// expected signal (as indicated by the goroutine
 	// above sending a value on `done`) and then exit.
 	fmt.Println("awaiting signal")
-	for run {
+	_ = utils.InitDb(dbFile, dbInit)
+	utils.Listen(socketAddress)
+	for utils.ServerRunning {
 		if !utils.IsPortOpen() {
 			log.Println("try to open port")
 			err := utils.OpenPort(device, baudrate, bytesize)

From 594f1e6778d95c41ca1b1c54ba96d3e8f82705da Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 21 Dec 2020 17:59:37 +0800
Subject: [PATCH 13/38] add telegram insert

---
 utils/telegram.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/utils/telegram.go b/utils/telegram.go
index f9f216e..76935ac 100644
--- a/utils/telegram.go
+++ b/utils/telegram.go
@@ -30,7 +30,7 @@ func check() {
 		if len(telegram) > 0 {
 			log.Println("telegram : ", telegram)
 			buffer = nil
-			//TODO save telegram
+			InsertTelegram(telegram)
 		}
 	}
 

From 6f00ed6029ff2f5147c5b9bdd271d60c9ee89be5 Mon Sep 17 00:00:00 2001
From: zhiqiang feng <fengzhq@it2000.com.cn>
Date: Tue, 22 Dec 2020 10:57:45 +0800
Subject: [PATCH 14/38] remove command function

---
 cmd/start.go    | 6 ++++--
 cmd/test.go     | 6 ++++--
 utils/serial.go | 3 +++
 3 files changed, 11 insertions(+), 4 deletions(-)

diff --git a/cmd/start.go b/cmd/start.go
index 5c610e6..197f196 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -36,7 +36,9 @@ and usage of using your command. For example:
 Cobra is a CLI library for Go that empowers applications.
 This application is a tool to generate the needed files
 to quickly create a Cobra application.`,
-	Run: start,
+	Run: func(cmd *cobra.Command, args []string) {
+		start()
+	},
 }
 
 var run bool
@@ -55,7 +57,7 @@ func init() {
 	// startCmd.Flags().BoolP("toggle", "t", false, "Help message for toggle")
 }
 
-func start(cmd *cobra.Command, args []string) {
+func start() {
 	// Go signal notification works by sending `os.Signal`
 	// values on a channel. We'll create a channel to
 	// receive these notifications (we'll also make one to
diff --git a/cmd/test.go b/cmd/test.go
index 754a9a1..18c2391 100644
--- a/cmd/test.go
+++ b/cmd/test.go
@@ -28,10 +28,12 @@ var testCmd = &cobra.Command{
 	Long: `loading config file
 Test serial port
 Test load sqlite database and init table`,
-	Run: test,
+	Run: func(cmd *cobra.Command, args []string) {
+		test()
+	},
 }
 
-func test(cmd *cobra.Command, args []string) {
+func test() {
 	log.Println("Testing environment")
 	_ = utils.OpenPort(device, baudrate, bytesize)
 
diff --git a/utils/serial.go b/utils/serial.go
index 8c8feb1..9c3665c 100644
--- a/utils/serial.go
+++ b/utils/serial.go
@@ -31,6 +31,9 @@ func OpenPort(device string, baudrate int, bytesize byte) error {
 
 func ReadPort() ([]byte, int){
 	buffer := make([]byte, 256)
+	if !ServerRunning {
+		return buffer, 0
+	}
 	count,err := port.Read(buffer)
 	if err != nil && err != io.EOF {
 		log.Println("error in read port ", err)

From 13ff3f09e87557da59874762af7eb6a6966c002a Mon Sep 17 00:00:00 2001
From: zhiqiang feng <fengzhq@it2000.com.cn>
Date: Tue, 22 Dec 2020 11:45:25 +0800
Subject: [PATCH 15/38] fix run, add connection check

---
 cmd/start.go    |  8 ++++----
 utils/socket.go | 41 +++++++++++++++++++++++++++++++++++++++--
 utils/sqlite.go | 14 +++++++++++---
 3 files changed, 54 insertions(+), 9 deletions(-)

diff --git a/cmd/start.go b/cmd/start.go
index 197f196..0ae9821 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -17,12 +17,13 @@ package cmd
 
 import (
 	"fmt"
-	"it2000.com.cn/tele-recv/utils"
 	"log"
 	"os"
 	"os/signal"
 	"syscall"
 
+	"it2000.com.cn/tele-recv/utils"
+
 	"github.com/spf13/cobra"
 )
 
@@ -41,8 +42,6 @@ to quickly create a Cobra application.`,
 	},
 }
 
-var run bool
-
 func init() {
 	rootCmd.AddCommand(startCmd)
 
@@ -77,7 +76,8 @@ func start() {
 		sig := <-sigs
 		fmt.Println()
 		fmt.Println(sig)
-		run = false
+		utils.ServerRunning = false
+		utils.StopSocketServer()
 		done <- true
 	}()
 
diff --git a/utils/socket.go b/utils/socket.go
index d5b9d57..96d1004 100644
--- a/utils/socket.go
+++ b/utils/socket.go
@@ -1,17 +1,21 @@
 package utils
 
 import (
+	"io"
 	"log"
 	"net"
+	"time"
 )
 
 const ServerType = "tcp"
 
 var ServerRunning = false
 var client net.Conn
+var server net.Listener
 
 func Listen(address string) {
-	server, err := net.Listen(ServerType, address)
+	var err error
+	server, err = net.Listen(ServerType, address)
 	if err != nil {
 		log.Fatal("error in create server ", err)
 	}
@@ -25,14 +29,22 @@ func Listen(address string) {
 		}
 		if client == nil {
 			client = conn
+			log.Println("client connected ", client.RemoteAddr())
+
 		} else {
 			log.Println("client already connected, close")
+			client.Close()
+			client = nil
 			conn.Close()
 		}
+		if IsClientConnected() {
+			connCheck()
+		}
+		time.Sleep(2 * time.Second)
 	}
 }
 
-func Write(data string) {
+func WriteToClient(data string) error {
 	defer func() {
 		client.Close()
 		client = nil
@@ -43,4 +55,29 @@ func Write(data string) {
 		client.Close()
 		client = nil
 	}
+	return err
+}
+
+func connCheck() bool {
+	_, err := client.Read(make([]byte, 0))
+	if err != nil && err != io.EOF {
+		// this connection is invalid
+		log.Println("conn closed....", err)
+		client = nil
+		return false
+	}
+	return true
+}
+
+func IsClientConnected() bool {
+	return client != nil
+}
+
+func StopSocketServer() {
+	if IsClientConnected() {
+		client.Close()
+	}
+	if server != nil {
+		server.Close()
+	}
 }
diff --git a/utils/sqlite.go b/utils/sqlite.go
index 90753d1..7647833 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -2,10 +2,11 @@ package utils
 
 import (
 	"database/sql"
-	_ "github.com/mattn/go-sqlite3"
 	"log"
 	"os"
 	"time"
+
+	_ "github.com/mattn/go-sqlite3"
 )
 
 const (
@@ -18,7 +19,8 @@ const (
                     [tele_text] TEXT NOT NULL    
                 )
 `
-	TableInsert = "insert into telegram (tele_text) values (?)"
+	InsertNew = "insert into telegram (tele_text) values (?)"
+	InsertOld = "insert into telegram (tele_text, tele_processed) values (?, 1)"
 )
 
 var (
@@ -69,7 +71,13 @@ func InsertTelegram(teleString string) {
 	isWriting = true
 	db := getDb()
 	defer db.Close()
-	stmt, err := db.Prepare(TableInsert)
+	var insertSQL string
+	if IsClientConnected() && WriteToClient(teleString) == nil {
+		insertSQL = InsertOld
+	} else {
+		insertSQL = InsertNew
+	}
+	stmt, err := db.Prepare(insertSQL)
 	if err != nil {
 		log.Fatal(err)
 	}

From f0983f0d02f7945ff9ebbbec64421aff32c4c2f9 Mon Sep 17 00:00:00 2001
From: zhiqiang feng <fengzhq@it2000.com.cn>
Date: Tue, 22 Dec 2020 12:07:30 +0800
Subject: [PATCH 16/38] start command doc

---
 cmd/start.go | 12 ++++--------
 1 file changed, 4 insertions(+), 8 deletions(-)

diff --git a/cmd/start.go b/cmd/start.go
index 0ae9821..0857a5a 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -30,13 +30,9 @@ import (
 // startCmd represents the start command
 var startCmd = &cobra.Command{
 	Use:   "start",
-	Short: "A brief description of your command",
-	Long: `A longer description that spans multiple lines and likely contains examples
-and usage of using your command. For example:
-
-Cobra is a CLI library for Go that empowers applications.
-This application is a tool to generate the needed files
-to quickly create a Cobra application.`,
+	Short: "start telegram receive service",
+	Long: `open serial port
+	start a tcp server for processing`,
 	Run: func(cmd *cobra.Command, args []string) {
 		start()
 	},
@@ -86,7 +82,7 @@ func start() {
 	// above sending a value on `done`) and then exit.
 	fmt.Println("awaiting signal")
 	_ = utils.InitDb(dbFile, dbInit)
-	utils.Listen(socketAddress)
+	go utils.Listen(socketAddress)
 	for utils.ServerRunning {
 		if !utils.IsPortOpen() {
 			log.Println("try to open port")

From 689c5748ecc97ab8dc40cc46769c192d6d27e900 Mon Sep 17 00:00:00 2001
From: zhiqiang feng <fengzhq@it2000.com.cn>
Date: Tue, 22 Dec 2020 12:08:06 +0800
Subject: [PATCH 17/38] reformat

---
 utils/serial.go | 26 +++++++++++++-------------
 1 file changed, 13 insertions(+), 13 deletions(-)

diff --git a/utils/serial.go b/utils/serial.go
index 9c3665c..06c1855 100644
--- a/utils/serial.go
+++ b/utils/serial.go
@@ -1,27 +1,28 @@
 package utils
 
 import (
-	"github.com/tarm/serial"
 	"io"
 	"log"
 	"time"
+
+	"github.com/tarm/serial"
 )
 
-var(
-	device string
-	baudrate int
-	bytesize byte
-	port  *serial.Port
-	portOpened bool
+var (
+	device     string
+	baudrate   int
+	bytesize   byte
+	port       *serial.Port
+	portOpened = false
 )
 
 func OpenPort(device string, baudrate int, bytesize byte) error {
-	log.Println("opening port device:", device, ", baudrate=", baudrate, ", bytesize=",bytesize)
+	log.Println("opening port device:", device, ", baudrate=", baudrate, ", bytesize=", bytesize)
 	config := &serial.Config{Name: device, Baud: baudrate, Size: bytesize, ReadTimeout: time.Second * 1}
 	var err error
 	port, err = serial.OpenPort(config)
-	if err!=nil {
-		log.Fatalln("error in open serial port ",   err)
+	if err != nil {
+		log.Fatalln("error in open serial port ", err)
 		return err
 	}
 	log.Println("opened port ", port)
@@ -29,12 +30,12 @@ func OpenPort(device string, baudrate int, bytesize byte) error {
 	return nil
 }
 
-func ReadPort() ([]byte, int){
+func ReadPort() ([]byte, int) {
 	buffer := make([]byte, 256)
 	if !ServerRunning {
 		return buffer, 0
 	}
-	count,err := port.Read(buffer)
+	count, err := port.Read(buffer)
 	if err != nil && err != io.EOF {
 		log.Println("error in read port ", err)
 		//TODO: 3 time fail try to
@@ -45,4 +46,3 @@ func ReadPort() ([]byte, int){
 func IsPortOpen() bool {
 	return portOpened
 }
-

From 7ef8270256373bbab84420dd9537858431f4740a Mon Sep 17 00:00:00 2001
From: zhiqiang feng <fengzhq@it2000.com.cn>
Date: Tue, 22 Dec 2020 12:08:58 +0800
Subject: [PATCH 18/38] not close connection after write

---
 utils/socket.go | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/utils/socket.go b/utils/socket.go
index 96d1004..c369228 100644
--- a/utils/socket.go
+++ b/utils/socket.go
@@ -45,11 +45,7 @@ func Listen(address string) {
 }
 
 func WriteToClient(data string) error {
-	defer func() {
-		client.Close()
-		client = nil
-	}()
-	_, err := client.Write([]byte(data))
+	_, err := client.Write([]byte(data + "\r\n"))
 	if err != nil {
 		log.Println("error in write data to client socket ", err)
 		client.Close()

From a44a58296e1906ee0eb83bd298172c71dab78abc Mon Sep 17 00:00:00 2001
From: zhiqiang feng <fengzhq@it2000.com.cn>
Date: Tue, 22 Dec 2020 12:09:33 +0800
Subject: [PATCH 19/38] if client connected, send data, mark processed 1

---
 utils/sqlite.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index 7647833..d93afaa 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -88,6 +88,10 @@ func InsertTelegram(teleString string) {
 		isWriting = false
 		log.Fatalln("error in write telegram")
 	}
-	log.Println("telegram insert ", id)
 	isWriting = false
+	if insertSQL == InsertOld {
+		log.Println("telegram processed ", id)
+	} else {
+		log.Println("telegram saved ", id)
+	}
 }

From 18e923ef8291c080ab0272f44c9edf917de7871f Mon Sep 17 00:00:00 2001
From: fengzhiqiang <fengzhiqiang@sh021.gzzn.dev>
Date: Wed, 23 Dec 2020 11:10:06 +0800
Subject: [PATCH 20/38] change default wait time

---
 utils/sqlite.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index d93afaa..86bff42 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -60,9 +60,9 @@ func InitDb(file string, init bool) error {
 
 func InsertTelegram(teleString string) {
 	count := 0
-	for isWriting && count < 5 {
+	for isWriting && count < 10 {
 		log.Println("waiting for write ")
-		time.Sleep(3 * time.Second)
+		time.Sleep(5 * time.Second)
 		count++
 	}
 	if count >= 5 {

From fd219b1a1336c08dbb7e1608bb65a99c773f5904 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 11:13:14 +0800
Subject: [PATCH 21/38] running status

---
 cmd/start.go | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/cmd/start.go b/cmd/start.go
index 5c610e6..d04f99c 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -39,8 +39,6 @@ to quickly create a Cobra application.`,
 	Run: start,
 }
 
-var run bool
-
 func init() {
 	rootCmd.AddCommand(startCmd)
 
@@ -75,7 +73,7 @@ func start(cmd *cobra.Command, args []string) {
 		sig := <-sigs
 		fmt.Println()
 		fmt.Println(sig)
-		run = false
+		utils.ServerRunning = false
 		done <- true
 	}()
 

From 0df588f587a5a34bd63c1ed520094a8f015dd88e Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 13:07:45 +0800
Subject: [PATCH 22/38] add load unprocessed

---
 utils/socket.go |  2 +-
 utils/sqlite.go | 99 ++++++++++++++++++++++++++++++++++++++-----------
 2 files changed, 79 insertions(+), 22 deletions(-)

diff --git a/utils/socket.go b/utils/socket.go
index c369228..efd96ec 100644
--- a/utils/socket.go
+++ b/utils/socket.go
@@ -30,7 +30,7 @@ func Listen(address string) {
 		if client == nil {
 			client = conn
 			log.Println("client connected ", client.RemoteAddr())
-
+			LoadUnprocessed()
 		} else {
 			log.Println("client already connected, close")
 			client.Close()
diff --git a/utils/sqlite.go b/utils/sqlite.go
index 86bff42..c370901 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -21,8 +21,17 @@ const (
 `
 	InsertNew = "insert into telegram (tele_text) values (?)"
 	InsertOld = "insert into telegram (tele_text, tele_processed) values (?, 1)"
+
+	count  = "select count(*) from telegram where tele_processed=0"
+	load   = "select tele_id, tele_text from telegram where tele_processed=0 Limit 100"
+	update = "update telegram set tele_processed = 1 where tele_id=?"
 )
 
+type telegram struct {
+	id   int64
+	text string
+}
+
 var (
 	dbFile      string
 	initTable   bool
@@ -50,25 +59,14 @@ func InitDb(file string, init bool) error {
 	db := getDb()
 	defer db.Close()
 	_, dbErr = db.Exec(TableCreate)
-	if dbErr != nil {
-		log.Fatal("error in create telegram table", dbErr)
-	}
+	checkDbErr(dbErr, "error in create table")
 	log.Println("database ", db, " initialized")
 	initialized = true
 	return nil
 }
 
 func InsertTelegram(teleString string) {
-	count := 0
-	for isWriting && count < 10 {
-		log.Println("waiting for write ")
-		time.Sleep(5 * time.Second)
-		count++
-	}
-	if count >= 5 {
-		log.Fatalln("database locked")
-	}
-	isWriting = true
+	getWriteLock()
 	db := getDb()
 	defer db.Close()
 	var insertSQL string
@@ -77,17 +75,12 @@ func InsertTelegram(teleString string) {
 	} else {
 		insertSQL = InsertNew
 	}
-	stmt, err := db.Prepare(insertSQL)
-	if err != nil {
-		log.Fatal(err)
-	}
+	stmt, _ := db.Prepare(insertSQL)
+
 	defer stmt.Close()
 	result, err := stmt.Exec(teleString)
 	id, _ := result.LastInsertId()
-	if err != nil {
-		isWriting = false
-		log.Fatalln("error in write telegram")
-	}
+	checkDbErr(err, "error in insert telegram ")
 	isWriting = false
 	if insertSQL == InsertOld {
 		log.Println("telegram processed ", id)
@@ -95,3 +88,67 @@ func InsertTelegram(teleString string) {
 		log.Println("telegram saved ", id)
 	}
 }
+
+func LoadUnprocessed() {
+	db := getDb()
+	defer db.Close()
+	for {
+		num := countTelegram()
+		if num < 1 {
+			break
+		}
+		log.Println("try to load unprocessed telegram ", num)
+		rows, err := db.Query(load)
+		checkDbErr(err, "error in query telegram")
+		defer rows.Close()
+		for rows.Next() {
+			var t telegram
+			err := rows.Scan(&t)
+			checkDbErr(err, "error in scan telegram")
+			if WriteToClient(t.text) == nil {
+				processed(t)
+			}
+		}
+	}
+}
+
+func processed(t telegram) {
+	db := getDb()
+	getWriteLock()
+	stmt, _ := db.Prepare(update)
+	result, err := stmt.Exec(t.id)
+	checkDbErr(err, "error in update telegram status")
+	id, _ := result.RowsAffected()
+	log.Println(t.id, " telegram update : ", id)
+	isWriting = false
+}
+
+func countTelegram() int64 {
+	db := getDb()
+	var countErr error
+	stmt, _ := db.Prepare(count)
+	defer stmt.Close()
+	var num int64
+	countErr = stmt.QueryRow().Scan(&num)
+	checkDbErr(countErr, "error in count telegram")
+	return num
+}
+
+func getWriteLock() {
+	count := 0
+	for isWriting && count < 10 {
+		log.Println("waiting for write ")
+		time.Sleep(5 * time.Second)
+		count++
+	}
+	if count >= 10 {
+		log.Fatalln("database locked")
+	}
+	isWriting = true
+}
+
+func checkDbErr(err error, msg string) {
+	if err != nil {
+		log.Fatalln(msg, err)
+	}
+}

From 5ef6955d4849bd15e5592b06a03bbfd848e4c432 Mon Sep 17 00:00:00 2001
From: fengzhiqiang <fengzhiqiang@sh021.gzzn.dev>
Date: Wed, 23 Dec 2020 13:41:46 +0800
Subject: [PATCH 23/38] update telegram

---
 utils/sqlite.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index c370901..a607032 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -90,10 +90,12 @@ func InsertTelegram(teleString string) {
 }
 
 func LoadUnprocessed() {
+	log.Println("loading telegram")
 	db := getDb()
 	defer db.Close()
 	for {
 		num := countTelegram()
+		log.Println("unprocessed : ", num)
 		if num < 1 {
 			break
 		}
@@ -103,7 +105,7 @@ func LoadUnprocessed() {
 		defer rows.Close()
 		for rows.Next() {
 			var t telegram
-			err := rows.Scan(&t)
+			err := rows.Scan(&t.id, &t.text)
 			checkDbErr(err, "error in scan telegram")
 			if WriteToClient(t.text) == nil {
 				processed(t)

From 97a7cf1d07a9b72a96f60dd9abf90e08a06edcee Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 13:45:00 +0800
Subject: [PATCH 24/38] get db remove init log

---
 utils/sqlite.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index c370901..068f081 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -40,7 +40,7 @@ var (
 )
 
 func getDb() *sql.DB {
-	log.Println("init database ", initTable)
+	//log.Println("init database ", initTable)
 	if initTable && !initialized {
 		log.Println("remove database file", dbFile)
 		os.Remove(dbFile)

From 216e92f98393e084e839869119d2954d3c57c9d7 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 13:49:46 +0800
Subject: [PATCH 25/38] add lock log

---
 utils/sqlite.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index 8d2be27..9404d07 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -116,6 +116,7 @@ func LoadUnprocessed() {
 
 func processed(t telegram) {
 	db := getDb()
+	log.Println("get lock")
 	getWriteLock()
 	stmt, _ := db.Prepare(update)
 	result, err := stmt.Exec(t.id)
@@ -123,6 +124,7 @@ func processed(t telegram) {
 	id, _ := result.RowsAffected()
 	log.Println(t.id, " telegram update : ", id)
 	isWriting = false
+	log.Println("release lock")
 }
 
 func countTelegram() int64 {

From bc3f765baf211da82750e4e2dd486d87a16fcee8 Mon Sep 17 00:00:00 2001
From: fengzhiqiang <fengzhiqiang@sh021.gzzn.dev>
Date: Wed, 23 Dec 2020 14:02:16 +0800
Subject: [PATCH 26/38] update process

---
 utils/sqlite.go | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index 9404d07..99df057 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -108,15 +108,13 @@ func LoadUnprocessed() {
 			err := rows.Scan(&t.id, &t.text)
 			checkDbErr(err, "error in scan telegram")
 			if WriteToClient(t.text) == nil {
-				processed(t)
+				processed(db, t)
 			}
 		}
 	}
 }
 
-func processed(t telegram) {
-	db := getDb()
-	log.Println("get lock")
+func processed(db *sql.DB, t telegram) {
 	getWriteLock()
 	stmt, _ := db.Prepare(update)
 	result, err := stmt.Exec(t.id)
@@ -140,6 +138,7 @@ func countTelegram() int64 {
 
 func getWriteLock() {
 	count := 0
+	log.Println("write lock :", isWriting)
 	for isWriting && count < 10 {
 		log.Println("waiting for write ")
 		time.Sleep(5 * time.Second)

From 18ff12f4244d5012c83f412c241fecd135811a2c Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 14:04:06 +0800
Subject: [PATCH 27/38] add transaction in write

---
 utils/sqlite.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index 99df057..3e7592f 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -116,6 +116,8 @@ func LoadUnprocessed() {
 
 func processed(db *sql.DB, t telegram) {
 	getWriteLock()
+	tx, err := db.Begin()
+	checkDbErr(err, "error in begin update")
 	stmt, _ := db.Prepare(update)
 	result, err := stmt.Exec(t.id)
 	checkDbErr(err, "error in update telegram status")
@@ -123,6 +125,7 @@ func processed(db *sql.DB, t telegram) {
 	log.Println(t.id, " telegram update : ", id)
 	isWriting = false
 	log.Println("release lock")
+	tx.Commit()
 }
 
 func countTelegram() int64 {

From 33eab0a6c6ea2c0f56cb75187d4ea1917c8243f3 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 14:12:00 +0800
Subject: [PATCH 28/38] check statement error

---
 utils/sqlite.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index 3e7592f..c6d9cae 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -118,7 +118,9 @@ func processed(db *sql.DB, t telegram) {
 	getWriteLock()
 	tx, err := db.Begin()
 	checkDbErr(err, "error in begin update")
-	stmt, _ := db.Prepare(update)
+	stmt, err := db.Prepare(update)
+	defer stmt.Close()
+	checkDbErr(err, "error in create update statement")
 	result, err := stmt.Exec(t.id)
 	checkDbErr(err, "error in update telegram status")
 	id, _ := result.RowsAffected()

From 7a21e09048a8b6b7929eb1ecfbdb693e7271c4f4 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 14:23:55 +0800
Subject: [PATCH 29/38] rewrite load

---
 utils/sqlite.go | 34 +++++++++++++++++++++++-----------
 1 file changed, 23 insertions(+), 11 deletions(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index c6d9cae..c0c7029 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -94,19 +94,11 @@ func LoadUnprocessed() {
 	db := getDb()
 	defer db.Close()
 	for {
-		num := countTelegram()
-		log.Println("unprocessed : ", num)
-		if num < 1 {
+		telegrams := getTelegram(db)
+		if len(telegrams) < 1 {
 			break
 		}
-		log.Println("try to load unprocessed telegram ", num)
-		rows, err := db.Query(load)
-		checkDbErr(err, "error in query telegram")
-		defer rows.Close()
-		for rows.Next() {
-			var t telegram
-			err := rows.Scan(&t.id, &t.text)
-			checkDbErr(err, "error in scan telegram")
+		for _, t := range telegrams {
 			if WriteToClient(t.text) == nil {
 				processed(db, t)
 			}
@@ -114,6 +106,26 @@ func LoadUnprocessed() {
 	}
 }
 
+func getTelegram(db *sql.DB) []telegram {
+	var telegrams []telegram
+	num := countTelegram()
+	log.Println("unprocessed : ", num)
+	if num < 1 {
+		return telegrams
+	}
+	log.Println("try to load unprocessed telegram ", num)
+	rows, err := db.Query(load)
+	checkDbErr(err, "error in query telegram")
+	defer rows.Close()
+	for rows.Next() {
+		var t telegram
+		err := rows.Scan(&t.id, &t.text)
+		checkDbErr(err, "error in scan telegram")
+		telegrams = append(telegrams, t)
+	}
+	return telegrams
+}
+
 func processed(db *sql.DB, t telegram) {
 	getWriteLock()
 	tx, err := db.Begin()

From bac084b1d0b1072195248c6660f7d5fd2f1cd683 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 14:30:09 +0800
Subject: [PATCH 30/38] add client ready flag

---
 utils/socket.go | 2 ++
 utils/sqlite.go | 4 +++-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/utils/socket.go b/utils/socket.go
index efd96ec..2d01956 100644
--- a/utils/socket.go
+++ b/utils/socket.go
@@ -12,6 +12,7 @@ const ServerType = "tcp"
 var ServerRunning = false
 var client net.Conn
 var server net.Listener
+var ClientReady = false
 
 func Listen(address string) {
 	var err error
@@ -29,6 +30,7 @@ func Listen(address string) {
 		}
 		if client == nil {
 			client = conn
+			ClientReady = false
 			log.Println("client connected ", client.RemoteAddr())
 			LoadUnprocessed()
 		} else {
diff --git a/utils/sqlite.go b/utils/sqlite.go
index c0c7029..a8d9ef2 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -70,7 +70,7 @@ func InsertTelegram(teleString string) {
 	db := getDb()
 	defer db.Close()
 	var insertSQL string
-	if IsClientConnected() && WriteToClient(teleString) == nil {
+	if ClientReady && WriteToClient(teleString) == nil {
 		insertSQL = InsertOld
 	} else {
 		insertSQL = InsertNew
@@ -104,6 +104,8 @@ func LoadUnprocessed() {
 			}
 		}
 	}
+	ClientReady = true
+	log.Println("client is ready for new telegram")
 }
 
 func getTelegram(db *sql.DB) []telegram {

From 8763ae6c084a21212895e0d420243469ff2acc53 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 14:31:25 +0800
Subject: [PATCH 31/38] update result

---
 utils/sqlite.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index a8d9ef2..743138e 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -138,7 +138,7 @@ func processed(db *sql.DB, t telegram) {
 	result, err := stmt.Exec(t.id)
 	checkDbErr(err, "error in update telegram status")
 	id, _ := result.RowsAffected()
-	log.Println(t.id, " telegram update : ", id)
+	log.Println(t.id, " telegram update : ", id > 0)
 	isWriting = false
 	log.Println("release lock")
 	tx.Commit()

From 2900409465d29bfb287a367fbc23dcf8e8f11b82 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 14:39:57 +0800
Subject: [PATCH 32/38] client close

---
 utils/socket.go | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/utils/socket.go b/utils/socket.go
index 2d01956..f9d6a9a 100644
--- a/utils/socket.go
+++ b/utils/socket.go
@@ -50,8 +50,7 @@ func WriteToClient(data string) error {
 	_, err := client.Write([]byte(data + "\r\n"))
 	if err != nil {
 		log.Println("error in write data to client socket ", err)
-		client.Close()
-		client = nil
+		closeClient()
 	}
 	return err
 }
@@ -71,6 +70,13 @@ func IsClientConnected() bool {
 	return client != nil
 }
 
+func closeClient() {
+	if client != nil {
+		client.Close()
+		client = nil
+	}
+}
+
 func StopSocketServer() {
 	if IsClientConnected() {
 		client.Close()

From 5d83a44a0773fdcefa2e437d0c5617befe1f7e00 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 15:47:36 +0800
Subject: [PATCH 33/38] add drone config

---
 .drone.yml | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 .drone.yml

diff --git a/.drone.yml b/.drone.yml
new file mode 100644
index 0000000..2ad2bd9
--- /dev/null
+++ b/.drone.yml
@@ -0,0 +1,36 @@
+---
+kind: pipeline
+name: default
+type: docker
+
+platform:
+  os: linux
+  arch: amd64
+
+clone:
+  image: reg.int.it2000.com.cn/devops/git
+  tags: true
+  skip_verify: true
+
+step:
+  - name: build
+      image: reg.int.it2000.com.cn/library/golang:1.15.6-alpine3.12
+      volumes:
+        - name: deps
+          path: /go
+      environment:
+        GO111MODULE: on
+        GOPROXY: https://goproxy.io
+      commands:
+        - go clean
+
+volumes:
+  - name: deps
+    host:
+      path: /opt/go
+  - name: certs
+    host:
+      path: /etc/ssl/certs
+  - name: docker
+    host:
+      path: /var/run/docker.sock
\ No newline at end of file

From af4e598acc051ca0954d6aa67922ac5e44609b8e Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 15:50:42 +0800
Subject: [PATCH 34/38] init readme

---
 README.md | 1 +
 1 file changed, 1 insertion(+)

diff --git a/README.md b/README.md
index e69de29..9dfb9f3 100644
--- a/README.md
+++ b/README.md
@@ -0,0 +1 @@
+### 电报接收
\ No newline at end of file

From fab3a2ad724e173fde706e4219c517de6e439f46 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 15:54:13 +0800
Subject: [PATCH 35/38] drone config error

---
 .drone.yml | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/.drone.yml b/.drone.yml
index 2ad2bd9..57755be 100644
--- a/.drone.yml
+++ b/.drone.yml
@@ -14,15 +14,15 @@ clone:
 
 step:
   - name: build
-      image: reg.int.it2000.com.cn/library/golang:1.15.6-alpine3.12
-      volumes:
-        - name: deps
-          path: /go
-      environment:
-        GO111MODULE: on
-        GOPROXY: https://goproxy.io
-      commands:
-        - go clean
+    image: reg.int.it2000.com.cn/library/golang:1.15.6-alpine3.12
+    volumes:
+    - name: deps
+      path: /go
+    environment:
+      GO111MODULE: on
+      GOPROXY: https://goproxy.io
+    commands:
+    - go build
 
 volumes:
   - name: deps

From 447075fa8317010b8722f6be3c71cec40cfb8b46 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 15:55:33 +0800
Subject: [PATCH 36/38] step -> steps

---
 .drone.yml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/.drone.yml b/.drone.yml
index 57755be..06f2d57 100644
--- a/.drone.yml
+++ b/.drone.yml
@@ -12,7 +12,7 @@ clone:
   tags: true
   skip_verify: true
 
-step:
+steps:
   - name: build
     image: reg.int.it2000.com.cn/library/golang:1.15.6-alpine3.12
     volumes:

From 6e9cf592c057e5e8d23ef3ea16f7c1523cc800ec Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 16:09:16 +0800
Subject: [PATCH 37/38] golang build image from alpine to buster

---
 .drone.yml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/.drone.yml b/.drone.yml
index 06f2d57..6fac683 100644
--- a/.drone.yml
+++ b/.drone.yml
@@ -14,7 +14,7 @@ clone:
 
 steps:
   - name: build
-    image: reg.int.it2000.com.cn/library/golang:1.15.6-alpine3.12
+    image: reg.int.it2000.com.cn/library/golang:1.15.6-buster
     volumes:
     - name: deps
       path: /go

From 8d777b413442bf8dcbfef28961f3344f18f1b026 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 16:16:28 +0800
Subject: [PATCH 38/38] add release to drone

---
 .drone.yml | 18 +++++++++++++++++-
 1 file changed, 17 insertions(+), 1 deletion(-)

diff --git a/.drone.yml b/.drone.yml
index 6fac683..ec15392 100644
--- a/.drone.yml
+++ b/.drone.yml
@@ -22,7 +22,23 @@ steps:
       GO111MODULE: on
       GOPROXY: https://goproxy.io
     commands:
-    - go build
+    - go build -o tele-recv-linux
+
+  - name: release
+    image: plugins/gitea-release
+    volumes:
+      - name: certs
+        path: /etc/ssl/certs
+    settings:
+      api_key: fe1e1a8dd77de7452a3f473984c7ac6fe6c5abaf
+      base_url: https://gitea.int.it2000.com.cn
+      title: 0.0.1
+      files:
+        - tele-recv-linux
+      checksum:
+        - sha256
+    when:
+      event: tag
 
 volumes:
   - name: deps