改价格包时,不用事务
This commit is contained in:
@@ -336,15 +336,14 @@ func UpdateConfig(ctx *jxcontext.Context, key, configType, value string) (hint s
|
|||||||
dao.Rollback(db)
|
dao.Rollback(db)
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
|
dao.Commit(db)
|
||||||
for _, v := range storeMapList {
|
for _, v := range storeMapList {
|
||||||
if _, err = dao.UpdateEntityLogicallyAndUpdateSyncStatus(db, &model.StoreSkuBind{}, nil, ctx.GetUserName(), map[string]interface{}{
|
if _, err = dao.UpdateEntityLogicallyAndUpdateSyncStatus(db, &model.StoreSkuBind{}, nil, ctx.GetUserName(), map[string]interface{}{
|
||||||
model.FieldStoreID: v.StoreID,
|
model.FieldStoreID: v.StoreID,
|
||||||
}, dao.GetSyncStatusStructField(model.VendorNames[v.VendorID]), model.SyncFlagPriceMask); err != nil {
|
}, dao.GetSyncStatusStructField(model.VendorNames[v.VendorID]), model.SyncFlagPriceMask); err != nil {
|
||||||
dao.Rollback(db)
|
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
dao.Commit(db)
|
|
||||||
case model.ConfigTypeFreightPack:
|
case model.ConfigTypeFreightPack:
|
||||||
dao.Commit(db)
|
dao.Commit(db)
|
||||||
storeMapList, err := dao.GetStoresMapList(db, nil, nil, model.StoreStatusAll, model.StoreIsSyncYes, "")
|
storeMapList, err := dao.GetStoresMapList(db, nil, nil, model.StoreStatusAll, model.StoreIsSyncYes, "")
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ import (
|
|||||||
|
|
||||||
const (
|
const (
|
||||||
useGetRowsWhenGetRow = true
|
useGetRowsWhenGetRow = true
|
||||||
transactionWarningSeconds = 2 * 60 // 5分钟
|
transactionWarningSeconds = 10 * 60 // 5分钟
|
||||||
)
|
)
|
||||||
|
|
||||||
type DaoDB struct {
|
type DaoDB struct {
|
||||||
|
|||||||
Reference in New Issue
Block a user