报工数据同步云端

zhangqian

2023-11-27 6a5ea3391fd6d87ee43f408a69d09f7d6128a064

 service/report_work.go

@@ -5,8 +5,11 @@
   "apsClient/constvar"
   "apsClient/model"
   "apsClient/model/request"
   "apsClient/pkg/logx"
   "apsClient/pkg/snowflake"
   "encoding/json"
   "errors"
   "github.com/jinzhu/gorm"
   "time"
)

@@ -65,11 +68,27 @@
      WorkerTime:         nowTs - startTs,
      BarCode:            snowflake.GenerateIdStr(),
   }
   err = model.WithTransaction(func(db *gorm.DB) error {
      err = model.NewReportWorkSearch(nil).Create(record)
      if err != nil {
         return err
      }

   err = model.NewReportWorkSearch(nil).Create(record)
      content, err := json.Marshal(record)
      if err != nil {
         return err
      }
      err = model.NewReportsToCloudSearch(nil).Create(&model.ReportsToCloud{
         ReportType: constvar.ReportTypeReportWork,
         Content:    string(content),
      })
      return err
   })
   if err != nil {
      logx.Errorf("save report work transaction error: %v", err)
      return err
   }

   PlcCacheSet(conf.Conf.CurrentDeviceID, procedure.Channel, constvar.PlcCacheKeyFinishNumber, params.ReportAmount)
   return nil
}