package constvar const ( NsqTopicScheduleTask = "aps.%v.scheduleTask" //排程任务下发 NsqTopicGetPlcAddress = "aps.%v.getPlcAddress" NsqTopicSendPlcAddress = "aps.%v.sendPlcAddress" NsqTopicProcessParamsRequest = "aps.%v.processParams.request" NsqTopicProcessParamsResponse = "aps.%v.processParams.response" NsqTopicApsProcessParams = "aps.%v.aps.processParams" //有了新的工艺模型 NsqTopicTaskProcedureStatusUpdate = "aps.%v.task.procedure.status" //工序状态更新 NsqTopicSyncTaskProgress = "aps.%v.task.procedure.progress" //工序生产进度 NsqTopicDeviceUpdate = "aps.%v.device.update" //设备信息更改 NsqTopicPullDataRequest = "aps.%v.pull.data.request" //拉取数据请求 NsqTopicPullDataResponse = "aps.%v.pull.data.response" //拉取数据响应 ) type PlcStartAddressType int const ( PlcStartAddressTypeFinishNumber PlcStartAddressType = 1 PlcStartAddressTypeTotalNumber PlcStartAddressType = 2 ) type PlcStartAddressValueType string const ( PlcStartAddressValueTypeString PlcStartAddressValueType = "string" PlcStartAddressValueTypeInt PlcStartAddressValueType = "int" ) const ( PlcAddressDataPath = "datafile/" PlcAddressDataKeyFileName = "plc_address_key" PlcAddressDataValueFileName = "plc_address_value" ) type PlcMethod string const ( PlcMethodModbusTCP PlcMethod = "modbusTCP" PlcMethodSerial PlcMethod = "serial" PlcMethodModbusTCPChinese PlcMethod = "网络" PlcMethodSerialChinese PlcMethod = "串口" ) func (slf *PlcMethod) ConvertToEnglish() { if *slf == PlcMethodModbusTCPChinese { *slf = PlcMethodModbusTCP } if *slf == PlcMethodSerialChinese { *slf = PlcMethodSerial } } func (slf *PlcMethod) Valid() bool { return *slf == PlcMethodModbusTCP || *slf == PlcMethodSerial } const ( PlcCacheKeyFinishNumber = "finish_number" PlcCacheKeyTotalNumber = "total_number" ) const ( PlcPackageApache = "apache" PlcPackageGoBurrow = "goBurrow" PlcPackageApacheLongConnection = "apacheLong" ) type TaskMode int const ( TaskModeUnStarted TaskMode = 1 //未开始的 TaskModeCurrent TaskMode = 2 //未开始的和进行中的 TaskModeLastFinished TaskMode = 3 //上一个结束的 )