执行月度统计前先删除本月记录，防止重复数据

zhangqian

2024-05-06 3abb522a610fa41a8d5570b643d88a23030e56db

执行月度统计前先删除本月记录，防止重复数据

 task/month_stats.go

@@ -4,6 +4,7 @@
    "encoding/json"
    "fmt"
    "github.com/shopspring/decimal"
    "gorm.io/gorm"
    "time"
    "wms/constvar"
    "wms/models"
@@ -125,8 +126,14 @@
            }
        }

        err = models.NewMonthStatsSearch().SetDate(date).Delete()
        if err != nil {
            return
        }

        record.BeginMoreUnits = moreUnits
        err = models.NewMonthStatsSearch().Create(&record)
        err = models.WithTransaction(func(db *gorm.DB) error {
            err = models.NewMonthStatsSearch().SetOrm(db).Create(&record)
        if err != nil {
            logx.Errorf("NewMonthStatsSearch Create err:%v, record: %+v", err, record)
            service.SendAlarm("月度统计创建本月失败", fmt.Sprintf("NewMonthStatsSearch Create err:%v, record: %+v", err, record))
@@ -145,12 +152,14 @@
                "end_more_units":    moreUnits,
                "end_amount":        amount,
            }
            err = models.NewMonthStatsSearch().SetID(oldRecordsMap[productId].Id).UpdateByMap(m)
                err = models.NewMonthStatsSearch().SetOrm(db).SetID(oldRecordsMap[productId].Id).UpdateByMap(m)
            if err != nil {
                logx.Errorf("NewMonthStatsSearch UpdateByMap err:%v, id:%v, m:%+v", err, oldRecordsMap[productId].ID, m)
                service.SendAlarm("月度统计更改上月失败", fmt.Sprintf("NewMonthStatsSearch Create err:%v, record: %+v", err, record))
            }
        }
            return nil
        })
    }
    return
}