zhangqian
2023-10-21 5a9e2e97e78a05209a57a75a75678d67c32c58d5
service/device_plc.go
@@ -1,13 +1,15 @@
package service
import (
   "apsClient/conf"
   "apsClient/model"
   "apsClient/model/request"
   "apsClient/pkg/ecode"
   "apsClient/pkg/logx"
   "apsClient/pkg/structx"
   "encoding/json"
   "gorm.io/gorm"
   "errors"
   "github.com/jinzhu/gorm"
)
type DevicePlcService struct{}
@@ -16,11 +18,10 @@
   return DevicePlcService{}
}
func (DevicePlcService) GetDevicePlc() (*model.DevicePlc, int) {
   DevicePlc, err := model.NewDevicePlcSearch().SetOrder("id desc").First()
func (slf DevicePlcService) GetDevicePlc() (*model.DevicePlc, int) {
   DevicePlc, err := model.NewDevicePlcSearch().SetDeviceId(conf.Conf.System.DeviceId).First()
   if err == gorm.ErrRecordNotFound {
      return &model.DevicePlc{
         Id:         0,
         Brand:      "",
         Method:     "",
         Address:    "",
@@ -39,6 +40,17 @@
   return DevicePlc, ecode.OK
}
func (slf DevicePlcService) GetDeviceChannelAmount() (int, error) {
   plcConfig, code := slf.GetDevicePlc()
   if code != ecode.OK || plcConfig.ID == 0 {
      return 0, errors.New("未获取到PLC地址,请在工艺模型库中上传!")
   }
   if len(plcConfig.Details) == 0 {
      return 0, errors.New("未获取到PLC地址,请在工艺模型库中上传!")
   }
   return len(plcConfig.Details) / 2, nil
}
func (DevicePlcService) UpdateDevicePlc(plc *request.UpdatePlc) int {
   var record model.DevicePlc
   err := structx.AssignTo(plc, &record)