From a7e5430cf06a82f7c17b6565bd9f1ce581187adb Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 21 十月 2023 15:24:58 +0800
Subject: [PATCH] 打印数据同步日志

---
 api/v1/config.go |   90 ++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 84 insertions(+), 6 deletions(-)

diff --git a/api/v1/config.go b/api/v1/config.go
index d14c0a6..267a041 100644
--- a/api/v1/config.go
+++ b/api/v1/config.go
@@ -1,12 +1,17 @@
 package v1
 
 import (
+	"apsClient/conf"
+	"apsClient/constvar"
 	"apsClient/model"
+	"apsClient/model/request"
 	_ "apsClient/model/response"
 	"apsClient/pkg/contextx"
 	"apsClient/pkg/ecode"
 	"apsClient/pkg/logx"
 	"apsClient/service"
+	"apsClient/utils"
+	"fmt"
 	"github.com/gin-gonic/gin"
 )
 
@@ -27,7 +32,7 @@
 	ConfigData, err := service.NewConfigService().GetNetConfigList()
 	if err != nil {
 		logx.Errorf("get net config error: %v", err.Error())
-		ctx.FailWithMsg(ecode.UnknownErr, "鑾峰彇缃戠粶閰嶇疆澶辫触")
+		ctx.FailWithMsg(ecode.DBErr, "鑾峰彇缃戠粶閰嶇疆澶辫触")
 		return
 	}
 
@@ -40,7 +45,7 @@
 // @Produce   application/json
 // @Param	  object	body  model.NetConfig	true	"鍙傛暟"
 // @Success   200   {object}  contextx.Response{data=[]response.ProcessParams}  "鎴愬姛"
-// @Router    /v1/config/net [put]
+// @Router    /v1/config/net [post]
 func (slf *ConfigApi) SetNetConfig(c *gin.Context) {
 	var params model.NetConfig
 	ctx, ok := contextx.NewContext(c, &params)
@@ -48,19 +53,92 @@
 		return
 	}
 
-	_, err := service.NewConfigService().GetNetConfig(params.Id)
+	_, err := service.NewConfigService().GetNetConfig(params.ID)
 
 	if err != nil {
 		logx.Errorf("get net config error: %v", err.Error())
-		ctx.FailWithMsg(ecode.UnknownErr, "鑾峰彇缃戠粶閰嶇疆澶辫触")
+		ctx.FailWithMsg(ecode.DBErr, "鑾峰彇缃戠粶閰嶇疆澶辫触")
 		return
 	}
-
-	err = service.NewConfigService().SetNetConfig(params.Id, &params)
+	err = service.NewConfigService().SetNetConfig(params.ID, &params)
 	if err != nil {
 		logx.Errorf("SetNetConfig error: %v", err.Error())
 		ctx.FailWithMsg(ecode.DBErr, "璁剧疆澶辫触")
 		return
 	}
+	if conf.Conf.System.NetSetShellPath == "" || conf.Conf.System.NetUpShellName == "" || conf.Conf.System.NetDownShellName == "" {
+		ctx.FailWithMsg(ecode.DBErr, "璇峰厛閰嶇疆缃戠粶璁剧疆璺緞鍜岃剼鏈悕")
+		return
+	}
+	var shName string
+	if params.Status == model.NetConfigStatusEnabled {
+		shName = conf.Conf.System.NetUpShellName
+	} else {
+		shName = conf.Conf.System.NetDownShellName
+	}
+	sh := fmt.Sprintf("%s %v %v %v %v", shName, params.NetworkCard, params.IP, params.MASK, params.Gateway)
+	err = utils.Cmd(conf.Conf.System.NetSetShellPath + sh)
+	if err != nil {
+		logx.Errorf("network update failed: %v", err.Error())
+		ctx.FailWithMsg(ecode.UnknownErr, "缃戠粶璁剧疆澶辫触")
+		return
+	}
+	ctx.Ok()
+}
+
+// PlcGet
+// @Tags      Config
+// @Summary   鑾峰彇plc閰嶇疆
+// @Produce   application/json
+// @Success   200   {object}  contextx.Response{data=model.DevicePlc}  "鎴愬姛"
+// @Router    /v1/config/plc [get]
+func (slf *ConfigApi) PlcGet(c *gin.Context) {
+	ctx, ok := contextx.NewContext(c, nil)
+	if !ok {
+		return
+	}
+
+	plcData, code := service.NewDevicePlcService().GetDevicePlc()
+	if code != ecode.OK {
+		ctx.Fail(code)
+		return
+	}
+	ctx.OkWithDetailed(plcData)
+}
+
+// PlcUpdate
+// @Tags	Config
+// @Summary	 鏇存柊plc閰嶇疆
+// @Produce	application/json
+// @Param		object	body	request.UpdatePlc	true	"鏌ヨ鍙傛暟"
+// @Success	200		{object}	contextx.Response{}
+// @Router		/v1/config/plc [post]
+func (slf *ConfigApi) PlcUpdate(c *gin.Context) {
+	var params request.UpdatePlc
+	ctx, ok := contextx.NewContext(c, &params)
+	if !ok {
+		return
+	}
+
+	if !params.Method.Valid() {
+		ctx.FailWithMsg(ecode.ParamsErr, "鎺ュ彛鏂瑰紡涓嶆纭�")
+		return
+	}
+
+	if params.Method == constvar.PlcMethodModbusTCP && (params.Address == "" || params.Port == 0) {
+		ctx.FailWithMsg(ecode.ParamsErr, "褰撴帴鍙ｆ柟寮忎负modbusTCP鏃讹紝address鍜宲ort涓嶈兘涓虹┖")
+		return
+	}
+	if params.Method == constvar.PlcMethodSerial && (params.BaudRate == 0 || params.SerialName == "") {
+		ctx.FailWithMsg(ecode.ParamsErr, "褰撴帴鍙ｆ柟寮忎负serial鏃讹紝baudRate鍜宻erialName涓嶈兘涓虹┖")
+		return
+	}
+
+	errCode := service.NewDevicePlcService().UpdateDevicePlc(&params)
+	if errCode != ecode.OK {
+		ctx.Fail(errCode)
+		return
+	}
+
 	ctx.Ok()
 }

--
Gitblit v1.8.0