package problem
|
|
import (
|
"apsClient/conf"
|
"apsClient/constvar"
|
"apsClient/model"
|
"apsClient/pkg/sqlitex"
|
"apsClient/service"
|
"fmt"
|
"net"
|
"sync"
|
)
|
|
var checkItems = []constvar.ProblemCode{
|
constvar.ProblemCodeService,
|
constvar.ProblemCodeNetwork,
|
constvar.ProblemCodeDB,
|
constvar.ProblemCodeSerf,
|
constvar.ProblemCodeCloud,
|
constvar.ProblemCodeDevice,
|
constvar.ProblemCodePlcConfig,
|
constvar.ProblemCodePlcAddressList,
|
constvar.ProblemCodePlcProcessModelAddressList,
|
constvar.ProblemCodePlcConnect,
|
}
|
var itemNameMap = map[constvar.ProblemCode]string{
|
constvar.ProblemCodeService: "服务",
|
constvar.ProblemCodeNetwork: "网络连接",
|
constvar.ProblemCodeDB: "数据库",
|
constvar.ProblemCodeSerf: "serf集群",
|
constvar.ProblemCodeCloud: "消息队列",
|
constvar.ProblemCodeDevice: "生产设备绑定",
|
constvar.ProblemCodePlcConfig: "plc配置",
|
constvar.ProblemCodePlcAddressList: "plc地址表",
|
constvar.ProblemCodePlcProcessModelAddressList: "plc工艺参数地址表",
|
constvar.ProblemCodePlcConnect: "plc连接",
|
}
|
|
type CheckResult struct {
|
ItemCode constvar.ProblemCode
|
ItemName string
|
CheckResult bool
|
}
|
|
var checkResultList []*CheckResult
|
var mutex sync.RWMutex
|
|
func Check() {
|
checkResultListTemp := make([]*CheckResult, 0)
|
var checkObj check
|
for _, item := range checkItems {
|
switch item {
|
case constvar.ProblemCodeService:
|
checkObj = &Default{}
|
case constvar.ProblemCodeNetwork:
|
checkObj = &Network{}
|
case constvar.ProblemCodeDB:
|
checkObj = &DB{}
|
case constvar.ProblemCodeSerf:
|
checkObj = &Serf{}
|
case constvar.ProblemCodeCloud:
|
checkObj = &Nsq{}
|
case constvar.ProblemCodeDevice:
|
checkObj = &Device{}
|
case constvar.ProblemCodePlcConfig:
|
checkObj = &PlcConfig{}
|
case constvar.ProblemCodePlcAddressList:
|
checkObj = &PlcAddressList{}
|
case constvar.ProblemCodePlcProcessModelAddressList:
|
checkObj = &PlcProcessModelAddressList{}
|
case constvar.ProblemCodePlcConnect:
|
checkObj = &PlcConnect{}
|
default:
|
continue
|
}
|
checkResultListTemp = append(checkResultListTemp, &CheckResult{
|
ItemCode: item,
|
ItemName: itemNameMap[item],
|
CheckResult: checkObj.Check(),
|
})
|
}
|
mutex.Lock()
|
defer mutex.Unlock()
|
checkResultList = checkResultListTemp
|
|
}
|
|
func Get() []*CheckResult {
|
mutex.RLock()
|
defer mutex.RUnlock()
|
return checkResultList
|
|
}
|
|
type check interface {
|
Check() bool
|
}
|
|
type Default struct{}
|
|
func (slf *Default) Check() bool {
|
return true
|
}
|
|
type Network struct{}
|
|
func (slf *Network) Check() bool {
|
ifaces, err := net.Interfaces()
|
if err != nil {
|
fmt.Println("Error:", err)
|
return false
|
}
|
var netAllFailed bool
|
for _, iFace := range ifaces {
|
if iFace.Flags == net.FlagUp {
|
netAllFailed = false
|
fmt.Printf("Interface %s is DOWN, indicating a network issue.\n", iFace.Name)
|
}
|
}
|
return !netAllFailed
|
}
|
|
type DB struct{}
|
|
func (slf *DB) Check() bool {
|
err := sqlitex.GetDB().DB().Ping()
|
if err != nil {
|
return false
|
}
|
return true
|
}
|
|
type Serf struct{}
|
|
func (slf *Serf) Check() bool {
|
return conf.Conf.SerfClusterStatus != ""
|
}
|
|
type Nsq struct{}
|
|
func (slf *Nsq) Check() bool {
|
old, err := model.NewSystemStatusSearch().SetKey(constvar.SystemStatusKeyNsq).First()
|
if err != nil {
|
return false
|
}
|
return old.Value == constvar.SystemStatusValueNormal
|
}
|
|
type Device struct{}
|
|
func (slf *Device) Check() bool {
|
list, err := service.GetDeviceIDList()
|
if err != nil {
|
return false
|
}
|
return len(list) > 0
|
}
|
|
type ProcessModel struct {
|
}
|
|
func (slf *ProcessModel) Check() bool {
|
return false
|
}
|
|
type PlcConfig struct{}
|
|
func (slf *PlcConfig) Check() bool {
|
plcConfig, _ := service.NewDevicePlcService().GetDevicePlc()
|
if plcConfig == nil {
|
return false
|
}
|
if plcConfig.Method == "" {
|
return false
|
}
|
if plcConfig.Method == constvar.PlcMethodModbusTCP && (plcConfig.Address == "" || plcConfig.Port == 0) {
|
return false
|
}
|
if plcConfig.Method == constvar.PlcMethodSerial && (plcConfig.BaudRate == 0 || plcConfig.SerialName == "") {
|
return false
|
}
|
|
if plcConfig.Method == constvar.PlcMethodModbusRTU && (plcConfig.DataBit == 0 || plcConfig.StopBit == 0 || plcConfig.Parity == 0) {
|
return false
|
}
|
return true
|
}
|
|
type PlcAddressList struct{}
|
|
func (slf *PlcAddressList) Check() bool {
|
plcConfig, _ := service.NewDevicePlcService().GetDevicePlc()
|
return plcConfig != nil && len(plcConfig.Details) > 0
|
}
|
|
type PlcProcessModelAddressList struct{}
|
|
func (slf *PlcProcessModelAddressList) Check() bool {
|
record, err := model.NewProcessModelPlcAddressSearch().SetDeviceID(conf.Conf.CurrentDeviceID).First()
|
if err != nil {
|
return false
|
}
|
if len(record.AddressList) == 0 {
|
return false
|
}
|
return true
|
}
|
|
type PlcConnect struct{}
|
|
func (slf *PlcConnect) Check() bool {
|
return service.PlcIsConnect()
|
}
|
