Browse Source

优化修改sshd模块代码,解决bug

niujiuru 2 weeks ago
parent
commit
028b293b91
4 changed files with 11 additions and 11 deletions
  1. 1 1
      Makefile
  2. 7 7
      sshd/client/client.go
  3. 2 2
      sshd/sshd.go
  4. 1 1
      utils/shell/executor.go

+ 1 - 1
Makefile

@@ -135,7 +135,7 @@ yfkj_ssh_client.out : libswapi.a libair530z.a ./sshd/client/client.go
 	$(GO) mod tidy
 	$(SETGO_ENV) CGO_LDFLAGS="$(LIB6)" $(GO_BUILD) $(GO_FLAGS) -o $@ ./sshd/client/*.go
 	@cp $@ ./build/$(basename $@)_$(DATE)$(suffix $@)
-	rm -rf $@
+	#rm -rf $@
 
 # 综合应用测试程序
 LIBS := -Wl,-Bstatic -L./swapi -lswapi -L./hk_takephoto -lhk_takephoto -L./dh_takephoto -ldh_takephoto -L./air720u -lair720u -L./air530z -lair530z -L./ec200u -lec200u

+ 7 - 7
sshd/client/client.go

@@ -76,7 +76,7 @@ func main() {
 		if pingState.Load() { //// 等待成功连接上目标设备卍
 			break
 		}
-		fmt.Printf("[%s] 无法连接目标设备!!\n", MODULE_NAME)
+		fmt.Printf("[%s] 尝试连接目标设备....\n", MODULE_NAME)
 		time.Sleep(1 * time.Second)
 	}
 
@@ -109,7 +109,7 @@ func term(pingState *atomic.Bool) {
 			if err == io.EOF {
 				os.Exit(0)
 			}
-			fmt.Println("读取用户输入失败:", err)
+			fmt.Println("读取用户输入失败: ", err)
 			continue
 		}
 
@@ -135,10 +135,10 @@ func term(pingState *atomic.Bool) {
 		}
 
 		if result.Stdout != "" {
-			fmt.Println(result.Stdout)
+			fmt.Print(result.Stdout)
 		}
 		if result.Stderr != "" {
-			fmt.Fprintln(os.Stderr, result.Stderr)
+			fmt.Fprint(os.Stderr, result.Stderr)
 		}
 
 		if result.Cwd != "" {
@@ -202,10 +202,10 @@ func printWelcome() {
 | |\  | | || (__| | | | | | |  __/
 |_| \_|_|\__\___|_| |_|_|_|_|\___|
 
-═#═#═#═#═#═#═#═#═#═#═#═#═#═#═#═#═#
+═════════════════════════════════
        云飞科技RTU远程运维终端
-═#═#═#═#═#═#═#═#═#═#═#═#═#═#═#═#═#
-提示: 输入 'quit' 命令, 退出终端模拟器
+═════════════════════════════════
+提示: 输入'quit'命令, 退出终端
 `
 	fmt.Println(welcome)
 }

+ 2 - 2
sshd/sshd.go

@@ -222,7 +222,7 @@ func (c *MQTTCoupler) handleRequests(client mqtt.Client, msg mqtt.Message) {
 
 func (c *MQTTCoupler) execOneCmd(msg mqtt.Message) {
 	str := string(msg.Payload())
-	baseapp.Logger.Infof("[%s] 收到一个RPC请求: %s", MODULE_NAME, str)
+	baseapp.Logger.Debugf("[%s] 收到一个RPC请求: %s", MODULE_NAME, str)
 
 	var resp *jsonrpc2.Response // 预先定义一个空的应答
 	var clientID string         // 该客户端的|唯一标识|
@@ -354,7 +354,7 @@ retp:
 		baseapp.Logger.Errorf("[%s] 发送RPC应答失败: %v!!", MODULE_NAME, err)
 	}
 
-	baseapp.Logger.Infof("[%s] 发送一个RPC应答, 报文内容: %s", MODULE_NAME, text)
+	baseapp.Logger.Debugf("[%s] 发送一个RPC应答, 报文内容: %s", MODULE_NAME, text)
 }
 
 func (c *MQTTCoupler) startExecutorReaper(interval, timeout time.Duration) {

+ 1 - 1
utils/shell/executor.go

@@ -25,7 +25,7 @@ func (e *Executor) Exec(p ExecuteParams) (*ExecuteResult, error) {
 			}, nil
 		}
 		e.cwd = dir
-		return &ExecuteResult{ExitCode: 0}, nil
+		return &ExecuteResult{ExitCode: 0, Cwd: e.cwd}, nil
 	}
 
 	if strings.TrimSpace(p.Cmd) == "pwd" {