| | |
|---|
| | | "apsClient/router" |
|---|
| | | "apsClient/serf" |
|---|
| | | "apsClient/service" |
|---|
| | | "apsClient/service/plc_address" |
|---|
| | | "fmt" |
|---|
| | | "log" |
|---|
| | | "net/http" |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //加载plc写入地址 |
|---|
| | | plc_address.LoadAddressFromFile() |
|---|
| | | //plc_address.LoadAddressFromFile() |
|---|
| | | |
|---|
| | | // 启动数据同步 |
|---|
| | | var serfStartChan = make(chan bool) |
|---|
| | |
|---|
| | | "task_status_sync", |
|---|
| | | "device", |
|---|
| | | "device_plc", |
|---|
| | | "system_status", |
|---|
| | | "process_model_plc_address", |
|---|
| | | } |
|---|
| | | |
|---|
| | | agent := serf.InitAgent("apsClient", syncTables, sqlitex.GetDB()) |
|---|
| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | //从文件里读取当前生产设备id |
|---|
| | | conf.Conf.CurrentDeviceID = service.ReadDeviceIDFromFile() |
|---|
| | | if conf.Conf.CurrentDeviceID == "" { |
|---|
| | | conf.Conf.CurrentDeviceID = conf.Conf.System.DeviceId |
|---|
| | | //从文件里读取当前生产设备id获取设备列表第一个 |
|---|
| | | err := service.InitCurrentDeviceID() |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("InitCurrentDeviceID error: %v, exit", err) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 判断当前集群状态 |
|---|
