fix

zhangqian

2023-09-01 313dc7a884e8db3d8597c8eb0003b1f0ae92ca63

fix

 api/v1/task.go

@@ -142,7 +142,7 @@
    }

    processParamsArr := make([]response.ProcessParams, 0, len(paramsMap))
    for k, v := range data.ParamsMap {
    for k, v := range paramsMap {
        processParamsArr = append(processParamsArr, response.ProcessParams{
            Key:   k,
            Value: v,

 model/procedures.go

@@ -15,6 +15,7 @@
        ID             int    `gorm:"primarykey"`
        WorkOrderID    string `gorm:"index;type:varchar(191);not null;comment:工单ID" json:"-"`
        OrderID        string `gorm:"index;type:varchar(191);not null;comment:订单ID" json:"-"`
        DeviceID       string `gorm:"type:varchar(191);comment:设备ID" json:"deviceId"`
        StartTime      int64  `gorm:"comment:计划开始时间" json:"startTime"`
        EndTime        int64  `gorm:"comment:计划结束时间" json:"endTime"`
        Status         ProcedureStatus
@@ -92,6 +93,11 @@
    return slf
}

func (slf *ProceduresSearch) SetDeviceId(id string) *ProceduresSearch {
    slf.DeviceID = id
    return slf
}

func (slf *ProceduresSearch) SetStatus(status ProcedureStatus) *ProceduresSearch {
    slf.Status = status
    return slf

 model/process_model.go

@@ -16,7 +16,7 @@
        Procedure  string                 `gorm:"column:procedure;type:varchar(255);not null;default '';comment:工序" json:"procedure"`     //工序
        WorkOrder  string                 `gorm:"column:work_order;type:varchar(255);not null;default '';comment:工单" json:"workOrder"`    //工单
        Device     string                 `gorm:"column:device;type:varchar(255);not null;default '';comment:设备" json:"device"`           //设备
        Params     string                 `json:"-" gorm:"type:text;comment:工艺参数键值对json串"`
        Params     string                 `gorm:"type:text;comment:工艺参数键值对json串"`
        ParamsMap  map[string]interface{} `json:"paramsMap" gorm:"-"`
    }


 nsq/msg_handler.go

@@ -134,6 +134,16 @@

func (slf *ProcessParams) HandleMessage(data []byte) (err error) {
    logx.Infof("get an process params message :%s", data)
    var processModel model.ProcessModel
    err = json.Unmarshal(data, &processModel)
    if err != nil {
        logx.Infof("unmarshal process params sync err :%s", err)
        return err
    }
    err = model.NewProcessModelSearch().Create(&processModel)
    if err != nil {
        logx.Infof("save process params err :%s", err)
    }
    //通知回复收到
    ReceivedMessageChan <- &ReceivedMessage{
        Topic:   slf.Topic,