liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试删除重复

Browse Source
This commit is contained in:
苏尹岚
2020-08-31 14:17:28 +08:00
parent 4e9f514b03
commit 04256ca1a3
2 changed files with 34 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
business/jxstore/cms/store_sku.go
View File

@@ -4721,6 +4721,7 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
} }
return storeSkuAudits2, "", err return storeSkuAudits2, "", err
} }
// deletedDuplicateWaitAuditData(ctx, db)
task := tasksch.NewParallelTask("StoreSkuPriceAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(isContinueWhenError), ctx, task := tasksch.NewParallelTask("StoreSkuPriceAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeAudit := batchItemList[0].(*model.StoreSkuAudit) storeAudit := batchItemList[0].(*model.StoreSkuAudit)
@@ -4801,6 +4802,38 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
return nil, hint, err return nil, hint, err
} }
func DeletedDuplicateWaitAuditData(ctx *jxcontext.Context, db *dao.DaoDB) {
var (
duplicateDatas []*model.StoreSkuAudit
duplicateMaps = make(map[int]map[int][]*model.StoreSkuAudit)
)
sql := `
SELECT a.*
FROM store_sku_audit a ,
(
SELECT count(*), store_id ,name_id ,status, deleted_at
FROM store_sku_audit
WHERE status = 0
AND deleted_at = ?
GROUP BY 2,3,4,5
HAVING count(*) > 1
) b
WHERE a.store_id = b.store_id
AND a.name_id = b.name_id
AND a.status= b.status
AND a.deleted_at = b.deleted_at
`
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)
}
fmt.Println("test11111111111", utils.Format4Output(duplicateMaps, false))
// for _, v := range duplicateMaps {
// }
}
func GetSpecialtyStoreSkus(ctx *jxcontext.Context, storeIDs, vendorIDs []int) (err error) { func GetSpecialtyStoreSkus(ctx *jxcontext.Context, storeIDs, vendorIDs []int) (err error) {
type SpecialtyStoreSkus struct { type SpecialtyStoreSkus struct {
StoreID int `json:"门店ID"` StoreID int `json:"门店ID"`

9
business/jxstore/tempop/tempop.go
View File

@@ -1583,14 +1583,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// fmt.Println("addList2", addList) // fmt.Println("addList2", addList)
// fmt.Println("updateList2", utils.Format4Output(updateList, false)) // fmt.Println("updateList2", utils.Format4Output(updateList, false))
// fmt.Println("deleteList2", deleteList) // fmt.Println("deleteList2", deleteList)
var skuNames []model.SkuName cms.DeletedDuplicateWaitAuditData(ctx, dao.GetDB())
sql := `
SELECT * FROM sku_name WHERE img = 'https://image.jxc4.com/noGoodsImg.jpg' AND deleted_at = '1970-01-01 00:00:00'
`
dao.GetRows(dao.GetDB(), &skuNames, sql, nil)
for _, v := range skuNames {
cms.DeleteSkuName(ctx, v.ID, ctx.GetUserName())
}
return err return err
} }