From d8ab702e37077c5f822a6ec1997a2d10b530c439 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 16 九月 2023 22:42:29 +0800
Subject: [PATCH] 增加实时获取生产进度接口

---
 api/v1/plc.go |   63 +++++++++++++++++++++++++++++++
 1 files changed, 63 insertions(+), 0 deletions(-)

diff --git a/api/v1/plc.go b/api/v1/plc.go
index 5f3b279..1d528fb 100644
--- a/api/v1/plc.go
+++ b/api/v1/plc.go
@@ -6,6 +6,8 @@
 	"apsClient/model/response"
 	_ "apsClient/model/response"
 	"apsClient/pkg/contextx"
+	"apsClient/pkg/ecode"
+	"apsClient/pkg/logx"
 	"apsClient/pkg/plc/apacheplc4x"
 	"apsClient/service"
 	"github.com/gin-gonic/gin"
@@ -60,3 +62,64 @@
 	}
 	ctx.Ok()
 }
+
+// GetProductProgressRealTime
+// @Tags      鐢熶骇鏁伴噺
+// @Summary   瀹炴椂鑾峰彇鐢熶骇杩涘害
+// @Produce   application/json
+// @Param     object  body    request.SendProcessParams true  "鏌ヨ鍙傛暟"
+// @Success   200   {object}  contextx.Response{data=response.ProductProgress}  "鎴愬姛"
+// @Router    /v1/plc/productProgressRealTime [post]
+func (slf *PlcApi) GetProductProgressRealTime(c *gin.Context) {
+	var params request.GetProductProgress
+	ctx, ok := contextx.NewContext(c, &params)
+	if !ok {
+		return
+	}
+	var finishNumber, totalNumber int64
+	plcConfig, code := service.NewDevicePlcService().GetDevicePlc()
+	if code != ecode.OK {
+		return
+	}
+	for _, addressItem := range plcConfig.Details {
+		if addressItem.FieldName == constvar.PlcStartAddressTypeFinishNumber {
+			value, err := service.PlcReadDirect(plcConfig, addressItem.StartAddress, addressItem.Length, addressItem.Type)
+			if err != nil {
+				logx.Infof("plc read finish number err: %v", err)
+				continue
+			}
+			finishNumber = cast.ToInt64(value)
+			logx.Infof("plc read finish number: %v", finishNumber)
+			break
+		}
+	}
+
+	for _, addressItem := range plcConfig.Details {
+		if addressItem.FieldName == constvar.PlcStartAddressTypeTotalNumber {
+			value, err := service.PlcReadDirect(plcConfig, addressItem.StartAddress, addressItem.Length, addressItem.Type)
+			if err != nil {
+				logx.Infof("plc read total number err: %v", err)
+				continue
+			}
+			totalNumber = cast.ToInt64(value)
+			logx.Infof("plc read total number: %v", totalNumber)
+			break
+		}
+	}
+	resp := new(response.ProductProgress)
+	resp.FinishNumber = cast.ToInt(finishNumber)
+	resp.TotalNumber = cast.ToInt(totalNumber)
+
+	plcStatus := 1 //鏂紑杩炴帴
+	isConnect := apacheplc4x.IsConnect()
+	if isConnect {
+		if resp.FinishNumber > 0 { //鐢熶骇
+			plcStatus = 2
+		} else { //寰呮満
+			plcStatus = 3
+		}
+	}
+	resp.PlcStatus = plcStatus
+
+	ctx.OkWithDetailed(resp)
+}

--
Gitblit v1.8.0