合并设备和plc配置

zhangqian

2023-10-20 9a240b711d25f57703b9cf104eb602969437541e

合并设备和plc配置

 model/common/common.go

@@ -124,10 +124,13 @@
    IsFinish     bool   //是否完成
}

type Device struct {
// DeviceMsg 下发到终端的设备信息
type DeviceMsg struct {
    ID                  string                 `gorm:"comment:主键ID;primaryKey;type:varchar(191);" json:"id"`
    DeviceProcedureAttr []*DeviceProcedureAttr `json:"deviceProcedureAttr"` // 设备工序属性列表
    ExtChannelAmount    int                    `gorm:"type:tinyint;comment:额外的通道数量;default:0;" json:"extChannelAmount"`
    PlcAddressList      []*PlcAddress
    PlcConfig           *PlcConfig
}
type DeviceProcedureAttr struct {
    ProcedureID   string `gorm:"index;type:varchar(191);comment:工序ID" json:"procedureId"`

 nsq/msg_handler.go

@@ -251,29 +251,29 @@

func (slf *DeviceUpdate) HandleMessage(data []byte) (err error) {
    logx.Infof("get a device update message :%s", data)
    var device common.Device
    err = json.Unmarshal(data, &device)
    var msg common.DeviceMsg
    err = json.Unmarshal(data, &msg)
    if err != nil {
        logx.Infof("unmarshal device update msg err :%s", err)
        return err
    }

    procedures := make([]string, 0, len(device.DeviceProcedureAttr))
    for _, attr := range device.DeviceProcedureAttr {
    procedures := make([]string, 0, len(msg.DeviceProcedureAttr))
    for _, attr := range msg.DeviceProcedureAttr {
        procedures = append(procedures, attr.ProcedureName)
    }

    deviceRecord := &model.Device{
        DeviceID:         device.ID,
        DeviceID:         msg.ID,
        Procedures:       strings.Join(procedures, ","),
        ExtChannelAmount: device.ExtChannelAmount,
        ExtChannelAmount: msg.ExtChannelAmount,
    }

    oldRecord, err := model.NewDeviceSearch().SetDeviceId(device.ID).First()
    oldRecord, err := model.NewDeviceSearch().SetDeviceId(msg.ID).First()
    if err == gorm.ErrRecordNotFound {
        err = model.NewDeviceSearch().Create(deviceRecord)
    } else {
        err = model.NewDeviceSearch().SetID(oldRecord.ID).Save(deviceRecord)
    } else if oldRecord.ExtChannelAmount != deviceRecord.ExtChannelAmount || oldRecord.Procedures != deviceRecord.Procedures {
        err = model.NewDeviceSearch().SetDeviceId(msg.ID).Save(deviceRecord)
    }

    if err != nil {
@@ -281,6 +281,28 @@
        return err
    }

    if msg.PlcConfig.Method == "" {
        return nil
    }

    msg.PlcConfig.Method.ConvertToEnglish()
    var record model.DevicePlc
    err = mapstructure.Decode(msg.PlcConfig, &record)
    if err != nil {
        logx.Infof("decode from PlcAddressList to DevicePlc  Details err:%v", err)
    }
    err = mapstructure.Decode(msg.PlcAddressList, &record.Details)
    if err != nil {
        logx.Infof("decode from PlcAddressList to DevicePlc  Details err:%v", err)
    }
    detail, err := json.Marshal(record.Details)
    record.Detail = string(detail)
    record.ID = 1
    err = model.NewDevicePlcSearch().SetId(record.ID).Save(&record)
    if err != nil {
        return err
    }

    return nil
}