diff --git a/business/partner/purchase/jd/store_sku.go b/business/partner/purchase/jd/store_sku.go index 108f224e5..d155346bd 100644 --- a/business/partner/purchase/jd/store_sku.go +++ b/business/partner/purchase/jd/store_sku.go @@ -134,8 +134,6 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks } if len(errList) == 0 { syncMask = -1 - } else if len(errList) > 1 { - err = fmt.Errorf("%v", errList) } if syncMask != 0 && len(batchSkuIDs) > 0 { db := dao.GetDB() // 多线程问题 @@ -143,7 +141,14 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks UPDATE store_sku_bind t1 SET t1.jd_sync_status = t1.jd_sync_status & ? ` + sqlWhere0 + " AND t1.sku_id IN (" + dao.GenQuestionMarks(len(batchSkuIDs)) + ")" - _, err = dao.ExecuteSQL(db, sql, ^syncMask, storeID, batchSkuIDs) + if _, err = dao.ExecuteSQL(db, sql, ^syncMask, storeID, batchSkuIDs); err != nil { + errList = append(errList, err) + } + } + if len(errList) == 1 { + err = errList[0] + } else if len(errList) > 1 { + err = fmt.Errorf("%v", errList) } return nil, err }, storeSkus)