首次报工开始时间为工序开始时间

zhangqian

2023-11-29 28addaa46cb97c20ad37e13eb10535de7b75e71c

 service/report_work.go

@@ -33,17 +33,12 @@
   for _, worker := range procedure.ProceduresInfo.Workers {
      if params.WorkerID == worker.WorkerID {
         workerName = worker.WorkerName
         if worker.StartTime < nowTs {
            startTs = worker.StartTime
         }
      }
   }
   if workerName == "" {
      return errors.New("没有找到当前值班人员")
   }
   if startTs == 0 {
      return errors.New("没有找到当前值班人员开始时间")
   }

   finishAmount := params.ReportAmount
   lastReportWork, err := GetLastReportWork(params.ProcedureId)
   if err == nil {
@@ -52,6 +47,8 @@
      }
      finishAmount = params.ReportAmount - lastReportWork.ReportAmount
      startTs = lastReportWork.EndTime
   } else {
      startTs = procedure.RealStartTime
   }

   record := &model.ReportWork{
@@ -71,7 +68,7 @@
      BarCode:            snowflake.GenerateIdStr(),
   }
   err = model.WithTransaction(func(db *gorm.DB) error {
      err = model.NewReportWorkSearch(nil).Create(record)
      err = model.NewReportWorkSearch(db).Create(record)
      if err != nil {
         return err
      }
@@ -80,17 +77,23 @@
      if err != nil {
         return err
      }
      err = model.NewReportsToCloudSearch(nil).Create(&model.ReportsToCloud{
      err = model.NewReportsToCloudSearch(db).Create(&model.ReportsToCloud{
         ReportType: constvar.ReportTypeReportWork,
         Content:    string(content),
      })
      return err
      if err != nil {
         return err
      }

      return nil
   })
   if err != nil {
      logx.Errorf("save report work transaction error: %v", err)
      return err
   }
   _ = NewProgressService().UpdateProgress(conf.Conf.CurrentDeviceID, procedure.Channel, int64(params.ReportAmount))

   err = NewProgressService().UpdateProgressByProceduresId(procedure.ID, int64(params.ReportAmount))

   return nil
}