测试删除重复

This commit is contained in:
苏尹岚
2020-08-31 15:04:45 +08:00
parent 837f5bf7f2
commit f6f0557150

View File

@@ -4803,10 +4803,10 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
}
func DeletedDuplicateWaitAuditData(ctx *jxcontext.Context, db *dao.DaoDB) {
type duplicateMaps2 map[int][]*model.StoreSkuAudit
var (
duplicateDatas []*model.StoreSkuAudit
duplicateMaps = make(map[int]duplicateMaps2)
duplicateMaps = make(map[int]map[int][]*model.StoreSkuAudit)
duplicateStore = make(map[int][]*model.StoreSkuAudit)
)
sql := `
SELECT a.*
@@ -4827,7 +4827,14 @@ func DeletedDuplicateWaitAuditData(ctx *jxcontext.Context, db *dao.DaoDB) {
sqlParams := []interface{}{utils.DefaultTimeValue}
dao.GetRows(db, &duplicateDatas, sql, sqlParams)
for _, v := range duplicateDatas {
duplicateMaps[v.StoreID][v.NameID] = append(duplicateMaps[v.StoreID][v.NameID], v)
duplicateStore[v.StoreID] = append(duplicateStore[v.StoreID], v)
}
for k, v := range duplicateStore {
duplicateSkuName := make(map[int][]*model.StoreSkuAudit)
for _, vv := range v {
duplicateSkuName[vv.NameID] = append(duplicateSkuName[vv.NameID], vv)
}
duplicateMaps[k] = duplicateSkuName
}
fmt.Println("test11111111111", utils.Format4Output(duplicateMaps, false))
// for _, v := range duplicateMaps {