| | |
|---|
| | | logx.Errorf("ScheduleTask HandleMessage Unmarshal json err: %v", err.Error()) |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | | if len(resp.KeyData) == 0 || len(resp.AddressData) == 0 || resp.DeviceId != conf.Conf.System.DeviceId { |
|---|
| | | if resp.DeviceId != conf.Conf.System.DeviceId { |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | | //通知回复收到 |
|---|
| | | ReceivedMessageChan <- &ReceivedMessage{ |
|---|
| | | Topic: slf.Topic, |
|---|
| | | Message: data, |
|---|
| | | } |
|---|
| | | if len(resp.KeyData) == 0 || len(resp.AddressData) == 0 { |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | | //写入到文件 |
|---|
| | |
|---|
| | | address := cast.ToInt(strings.ReplaceAll(addresses[i], "\r", "")) |
|---|
| | | plc_address.Set(key, address) |
|---|
| | | logx.Infof("plc address set ok: key:%v, address:%v", key, address) |
|---|
| | | } |
|---|
| | | //通知回复收到 |
|---|
| | | ReceivedMessageChan <- &ReceivedMessage{ |
|---|
| | | Topic: slf.Topic, |
|---|
| | | Message: data, |
|---|
| | | } |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | |
|---|
| | | logx.Infof("unmarshal process params sync err :%s", err) |
|---|
| | | return err |
|---|
| | | } |
|---|
| | | err = model.NewProcessModelSearch().Create(&processModel) |
|---|
| | | err = model.NewProcessModelSearch().Save(&processModel) |
|---|
| | | if err != nil { |
|---|
| | | logx.Infof("save process params sync err :%s", err) |
|---|
| | | return err |
|---|
