zhangqian
2023-11-30 4171453db37dab28918f63d0a45414d87f1bb7a7
工序状态改变增加改变时间
4个文件已修改
4 ■■■■ 已修改文件
crontask/cron_task.go 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
model/common/common.go 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
model/task_status_sync.go 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/task.go 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
crontask/cron_task.go
@@ -130,6 +130,7 @@
            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)
model/common/common.go
@@ -128,6 +128,7 @@
    IsFinish           bool   //是否完成
    FinishAmount       int    `json:"finishAmount"`       //isFinish = true时取工序最终加工数传上去
    ProductProcedureID string `json:"productProcedureID"` //产品工序id
    Ts                 int64  `json:"ts"`                 //发生时间
}
// DeviceMsg 下发到终端的设备信息
model/task_status_sync.go
@@ -16,6 +16,7 @@
        DeviceId           string `json:"deviceId"`                                     //设备编号
        IsProcessing       bool   //是否处理中
        IsFinish           bool   //是否完成
        Ts                 int64  //发生时间
    }
    TaskStatusSyncSearch struct {
service/task.go
@@ -206,6 +206,7 @@
// SaveTaskStatusSync 保存任务同步信息
func (slf TaskService) SaveTaskStatusSync(db *gorm.DB, record *model.TaskStatusSync) (err error) {
    record.Ts = time.Now().Unix()
    return model.NewTaskStatusSyncSearch(db).Create(record)
}