停止消费时关闭tcp连接

zhangqian

2023-10-20 7276ab65576ec73b439a40d7f1a3035a534b968c

 model/common/common.go

@@ -107,11 +107,8 @@
   }
   ResponseProcessParams struct {
      Number    string                 `json:"number"`    //工艺模型编号
      OrderId   string                 `json:"orderId"`   //订单id
      Product   string                 `json:"product"`   //产品名称
      Procedure string                 `json:"procedure"` //工序
      WorkOrder string                 `json:"workOrder"` //工单
      Device    string                 `json:"device"`    //设备
      Params    string                 `json:"params"`
      ParamsMap map[string]interface{} `json:"paramsMap"`
      DeviceId  string                 `json:"deviceId" gorm:"-"` //用于过滤获取nsq消息
@@ -137,3 +134,20 @@
   ProcedureName string `gorm:"type:varchar(191);comment:工序名称" json:"procedureName"`
   DeviceID      string `gorm:"index;type:varchar(191);not null;comment:设备ID" json:"deviceId"`
}

type PullDataType string

const (
   PullDataTypeProcessModel = "process_model"
   PullDataTypeDevice       = "device"
)

// MsgPullDataRequest 拉取云端数据
type MsgPullDataRequest struct {
   DataType PullDataType `json:"dataType"` //要拉取的数据类型
}

type MsgPullDataResponse struct {
   DataType PullDataType `json:"dataType"` //要拉取的数据类型
   Data     interface{}  //返回的数据
}