- dao.SetStoreSkuSyncStatus中这个函数之前是要设置没有删除或同步标志不为0的,会导致将同步标志不为0且删除了的把标志去掉,现在改为只设置没有删除的
This commit is contained in:
@@ -269,6 +269,7 @@ func GetFullStoreSkus(db *DaoDB, vendorID, storeID int) (skus []*StoreSkuSyncInf
|
|||||||
return skus, err
|
return skus, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 这个函数之前是要设置没有删除或同步标志不为0的,会导致将同步标志不为0且删除了的把标志去掉,现在改为只设置没有删除的
|
||||||
func SetStoreSkuSyncStatus(db *DaoDB, vendorID int, storeIDs []int, skuIDs []int, syncStatus int) (num int64, err error) {
|
func SetStoreSkuSyncStatus(db *DaoDB, vendorID int, storeIDs []int, skuIDs []int, syncStatus int) (num int64, err error) {
|
||||||
globals.SugarLogger.Debugf("SetStoreSkuSyncStatus, storeIDs:%v, vendorID:%d", storeIDs, vendorID)
|
globals.SugarLogger.Debugf("SetStoreSkuSyncStatus, storeIDs:%v, vendorID:%d", storeIDs, vendorID)
|
||||||
|
|
||||||
@@ -276,14 +277,13 @@ func SetStoreSkuSyncStatus(db *DaoDB, vendorID int, storeIDs []int, skuIDs []int
|
|||||||
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
||||||
sql := `
|
sql := `
|
||||||
UPDATE store_sku_bind t1
|
UPDATE store_sku_bind t1
|
||||||
SET t1.%s_sync_status = IF(t1.deleted_at = ?, t1.%s_sync_status | ?, 0)
|
SET t1.%s_sync_status = t1.%s_sync_status | ?
|
||||||
`
|
`
|
||||||
fmtParams := []interface{}{
|
fmtParams := []interface{}{
|
||||||
fieldPrefix,
|
fieldPrefix,
|
||||||
fieldPrefix,
|
fieldPrefix,
|
||||||
}
|
}
|
||||||
sqlParams := []interface{}{
|
sqlParams := []interface{}{
|
||||||
utils.DefaultTimeValue,
|
|
||||||
syncStatus,
|
syncStatus,
|
||||||
}
|
}
|
||||||
if isSingleStorePF && (syncStatus&model.SyncFlagNewMask) != 0 {
|
if isSingleStorePF && (syncStatus&model.SyncFlagNewMask) != 0 {
|
||||||
@@ -292,8 +292,8 @@ func SetStoreSkuSyncStatus(db *DaoDB, vendorID int, storeIDs []int, skuIDs []int
|
|||||||
`
|
`
|
||||||
fmtParams = append(fmtParams, fieldPrefix)
|
fmtParams = append(fmtParams, fieldPrefix)
|
||||||
}
|
}
|
||||||
sql += " WHERE (t1.deleted_at = ? OR t1.%s_sync_status <> 0)"
|
sql += " WHERE (t1.deleted_at = ?)"
|
||||||
fmtParams = append(fmtParams, fieldPrefix)
|
// fmtParams = append(fmtParams, fieldPrefix)
|
||||||
sqlParams = append(sqlParams, utils.DefaultTimeValue)
|
sqlParams = append(sqlParams, utils.DefaultTimeValue)
|
||||||
if len(storeIDs) > 0 {
|
if len(storeIDs) > 0 {
|
||||||
sql += " AND t1.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
|
sql += " AND t1.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
|
||||||
|
|||||||
Reference in New Issue
Block a user