| | |
| | | |
| | | import ( |
| | | "apsClient/conf" |
| | | "apsClient/crontask" |
| | | "apsClient/model" |
| | | "apsClient/nsq" |
| | | "apsClient/pkg/logx" |
| | | "apsClient/router" |
| | | "apsClient/service" |
| | | "apsClient/service/plc_address" |
| | | "fmt" |
| | | "net/http" |
| | | "os" |
| | |
| | | return |
| | | } |
| | | |
| | | if err := nsq.Init(); err != nil { |
| | | logx.Errorf("nsq Init err:%v", err) |
| | | return |
| | | } |
| | | |
| | | if err := crontask.InitTask(); err != nil { |
| | | logx.Errorf("crontab task Init err:%v", err) |
| | | return |
| | | } |
| | | //加载plc写入地址 |
| | | plc_address.LoadAddressFromFile() |
| | | |
| | | //提前加载任务 |
| | | service.NewTaskService().GetTask() |
| | | |
| | | go shutdown() |
| | | logx.Infof("apsClient start serve...") |
| | | server := &http.Server{ |