ZiHangQin/electricity_bill_calc_service
1
0
Fork 0
forked from free-lancers/electricity_bill_calc_service
Code Pull Requests Activity

fix(enduser):修正抄表记录的初始化与上传。现在可以正常上传了。

Browse Source
This commit is contained in:
徐涛 2022-09-20 14:50:14 +08:00
parent d7f3e0f096
commit aa3a4dc44e
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
service/end_user.go
View File

@ -175,7 +175,7 @@ func (es _EndUserService) BatchImportNonPVRegister(reportId string, file io.Read
err = global.DB.NewSelect().Model((*model.EndUserDetail)(nil)). err = global.DB.NewSelect().Model((*model.EndUserDetail)(nil)).
ColumnExpr("meter_04kv_id as meter"). ColumnExpr("meter_04kv_id as meter").
ColumnExpr("count(*) as appears"). ColumnExpr("count(*) as appears").
Where("park_id = ?", reportDetail.Id). Where("park_id = ?", reportDetail.ParkId).
Group("meter_04kv_id"). Group("meter_04kv_id").
Scan(ctx, &meterAppers) Scan(ctx, &meterAppers)
if err != nil { if err != nil {

8
service/report.go
View File

@ -138,7 +138,7 @@ func (_ReportService) IsNewPeriodValid(uid, pid string, period time.Time) (bool,
} }
func (_ReportService) InitializeNewReport(parkId string, period time.Time) (string, error) { func (_ReportService) InitializeNewReport(parkId string, period time.Time) (string, error) {
ctx, cancel := global.TimeoutContext() ctx, cancel := global.TimeoutContext(120)
defer cancel() defer cancel()
periods := make([]model.Report, 0) periods := make([]model.Report, 0)
@ -227,6 +227,7 @@ func (_ReportService) InitializeNewReport(parkId string, period time.Time) (stri
return "", err return "", err
} }
// 生成并插入户表信息 // 生成并插入户表信息
var inserts = make([]model.EndUserDetail, 0)
for _, customer := range currentActivatedCustomers { for _, customer := range currentActivatedCustomers {
newEndUser := model.EndUserDetail{ newEndUser := model.EndUserDetail{
ReportId: newReport.Id, ReportId: newReport.Id,
@ -253,7 +254,10 @@ func (_ReportService) InitializeNewReport(parkId string, period time.Time) (stri
newEndUser.LastPeriodFlat = lastPeriod.CurrentPeriodFlat newEndUser.LastPeriodFlat = lastPeriod.CurrentPeriodFlat
newEndUser.LastPeriodValley = lastPeriod.CurrentPeriodValley newEndUser.LastPeriodValley = lastPeriod.CurrentPeriodValley
} }
_, err = tx.NewInsert().Model(&newEndUser).Exec(ctx) inserts = append(inserts, newEndUser)
}
if len(inserts) > 0 {
_, err = tx.NewInsert().Model(&inserts).Exec(ctx)
if err != nil { if err != nil {
tx.Rollback() tx.Rollback()
return "", err return "", err