| | |
| | | IsFinish: record.IsFinish, |
| | | FinishAmount: finishAmount, |
| | | ProductProcedureID: record.ProductProcedureID, |
| | | Ts: record.Ts, |
| | | } |
| | | caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicTaskProcedureStatusUpdate, conf.Conf.NsqConf.NodeId), "") |
| | | err = caller.Send(msg) |
| | |
| | | IsFinish bool //是否完成 |
| | | FinishAmount int `json:"finishAmount"` //isFinish = true时取工序最终加工数传上去 |
| | | ProductProcedureID string `json:"productProcedureID"` //产品工序id |
| | | Ts int64 `json:"ts"` //发生时间 |
| | | } |
| | | |
| | | // DeviceMsg 下发到终端的设备信息 |
| | |
| | | DeviceId string `json:"deviceId"` //设备编号 |
| | | IsProcessing bool //是否处理中 |
| | | IsFinish bool //是否完成 |
| | | Ts int64 //发生时间 |
| | | } |
| | | |
| | | TaskStatusSyncSearch struct { |
| | |
| | | |
| | | // SaveTaskStatusSync 保存任务同步信息 |
| | | func (slf TaskService) SaveTaskStatusSync(db *gorm.DB, record *model.TaskStatusSync) (err error) { |
| | | record.Ts = time.Now().Unix() |
| | | return model.NewTaskStatusSyncSearch(db).Create(record) |
| | | } |
| | | |