From 84fb8e390b83dc9482524c12d7af6c93405c3fc1 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 08 十二月 2023 16:36:32 +0800
Subject: [PATCH] debug
---
service/report_work.go | 25 ++++++++++++++-----------
1 files changed, 14 insertions(+), 11 deletions(-)
diff --git a/service/report_work.go b/service/report_work.go
index 0426957..4d7a0cb 100644
--- a/service/report_work.go
+++ b/service/report_work.go
@@ -10,6 +10,7 @@
"encoding/json"
"errors"
"github.com/jinzhu/gorm"
+ "github.com/spf13/cast"
"time"
)
@@ -33,17 +34,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 +48,8 @@
}
finishAmount = params.ReportAmount - lastReportWork.ReportAmount
startTs = lastReportWork.EndTime
+ } else {
+ startTs = procedure.RealStartTime
}
record := &model.ReportWork{
@@ -68,10 +66,10 @@
WorkerID: params.WorkerID,
WorkerName: workerName,
WorkerTime: nowTs - startTs,
- BarCode: snowflake.GenerateIdStr(),
+ BarCode: cast.ToString(snowflake.GenerateID()),
}
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,18 +78,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
}
- PlcCacheSet(conf.Conf.CurrentDeviceID, procedure.Channel, constvar.PlcCacheKeyFinishNumber, params.ReportAmount)
+ err = NewProgressService().UpdateProgressByProceduresId(procedure.ID, params.ReportAmount)
+
return nil
}
--
Gitblit v1.8.0