liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

价格参考

Browse Source
This commit is contained in:
苏尹岚
2019-12-06 09:30:18 +08:00
parent ab7201e973
commit 43d18f6e96
1 changed files with 18 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
business/jxstore/report/report.go
View File

@@ -43,25 +43,27 @@ func StatisticsReportForStoreSkusPrice(ctx *jxcontext.Context, cityCodes, skuIDs
func BeginSavePriceRefer(ctx *jxcontext.Context, cityCodes, skuIDs []int) (err error) { func BeginSavePriceRefer(ctx *jxcontext.Context, cityCodes, skuIDs []int) (err error) {
db := dao.GetDB() db := dao.GetDB()
snapshotAt := utils.Str2Time(time.Now().Format("2006-01-02")) snapshotAt := utils.Time2Date(time.Now())
priceReferSnapshot, err := dao.GetStatisticsReportForStoreSkusPrice(db, cityCodes, skuIDs) priceReferSnapshot, err := dao.GetStatisticsReportForStoreSkusPrice(db, cityCodes, skuIDs)
dao.Begin(db) if len(priceReferSnapshot) > 0 {
defer func() { dao.Begin(db)
if r := recover(); r != nil || err != nil { defer func() {
dao.Rollback(db) if r := recover(); r != nil || err != nil {
if r != nil { dao.Rollback(db)
panic(r) if r != nil {
panic(r)
}
}
}()
dao.DeleteEntity(db, priceReferSnapshot[0], "SnapshotAt")
for _, v := range priceReferSnapshot {
dao.WrapAddIDCULDEntity(v, ctx.GetUserName())
v.SnapshotAt = snapshotAt
if err = dao.CreateEntity(db, v); err != nil {
return err
} }
} }
}() dao.Commit(db)
for _, v := range priceReferSnapshot {
dao.WrapAddIDCULDEntity(v, ctx.GetUserName())
v.SnapshotAt = snapshotAt
dao.DeleteEntity(db, v, "CityCode", "SkuID", "SnapshotAt")
if err = dao.CreateEntity(db, v); err != nil {
return err
}
} }
dao.Commit(db)
return err return err
} }