fux

zhangqian

2023-10-20 d9de157184611738e0f8e27309b449bc11e2be75

fux

 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消息

 nsq/msg_handler.go

@@ -214,11 +214,18 @@

func (slf *ProcessParamsSync) HandleMessage(data []byte) (err error) {
    logx.Infof("get an process params sync message :%s", data)
    var processModel model.ProcessModel
    err = json.Unmarshal(data, &processModel)
    var processModelMsg common.ResponseProcessParams
    err = json.Unmarshal(data, &processModelMsg)
    if err != nil {
        logx.Infof("unmarshal process params sync err :%s", err)
        return err
    }
    processModel := model.ProcessModel{
        Number:    processModelMsg.Number,
        Product:   processModelMsg.Product,
        Procedure: processModelMsg.Procedure,
        Params:    processModelMsg.Params,
        IsNew:     true,
    }
    err = model.WithTransaction(func(db *gorm.DB) error {
        err = model.NewProcessModelSearch().SetOrm(db).SetProduct(processModel.Product).SetProcedure(processModel.Procedure).
@@ -226,7 +233,6 @@
        if err != nil {
            return err
        }
        processModel.IsNew = true
        return model.NewProcessModelSearch().SetOrm(db).Create(&processModel)
    })