测试删除重复
This commit is contained in:
@@ -4805,7 +4805,6 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
|
||||
func DeletedDuplicateWaitAuditData(ctx *jxcontext.Context, db *dao.DaoDB) {
|
||||
var (
|
||||
duplicateDatas []*model.StoreSkuAudit
|
||||
duplicateMaps = make(map[int]map[int][]*model.StoreSkuAudit)
|
||||
duplicateStore = make(map[int][]*model.StoreSkuAudit)
|
||||
)
|
||||
sql := `
|
||||
@@ -4829,17 +4828,17 @@ func DeletedDuplicateWaitAuditData(ctx *jxcontext.Context, db *dao.DaoDB) {
|
||||
for _, v := range duplicateDatas {
|
||||
duplicateStore[v.StoreID] = append(duplicateStore[v.StoreID], v)
|
||||
}
|
||||
for k, v := range duplicateStore {
|
||||
for _, v := range duplicateStore {
|
||||
duplicateSkuName := make(map[int][]*model.StoreSkuAudit)
|
||||
for _, vv := range v {
|
||||
duplicateSkuName[vv.NameID] = append(duplicateSkuName[vv.NameID], vv)
|
||||
}
|
||||
duplicateMaps[k] = duplicateSkuName
|
||||
for _, vv := range duplicateSkuName {
|
||||
for i := 0; i < len(vv)-1; i++ {
|
||||
dao.DeleteEntity(db, vv[i])
|
||||
}
|
||||
}
|
||||
}
|
||||
fmt.Println("test11111111111", utils.Format4Output(duplicateMaps, false))
|
||||
// for _, v := range duplicateMaps {
|
||||
|
||||
// }
|
||||
}
|
||||
|
||||
func GetSpecialtyStoreSkus(ctx *jxcontext.Context, storeIDs, vendorIDs []int) (err error) {
|
||||
|
||||
Reference in New Issue
Block a user