修复价格

business/jxstore/tempop/tempop.go

@@ -1609,35 +1609,31 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// 		continue
 	// 	}
 	// }
-	var (
-		pageSize = 100
-		rr       []int64
-	)
-	pageResult, err := api.JdShopAPI.SearchWare4Valid("", 1, 1)
-	for pageNo := 1; pageNo <= pageResult.TotalItem/pageSize+1; pageNo++ {
-		result, err := api.JdShopAPI.SearchWare4Valid("", pageNo, pageSize)
-		if err == nil {
-			for _, v := range result.Data {
-				result, _ := api.JdShopAPI.SearchSkuList(v.WareID)
-				for _, vv := range result {
-					result2, _ := api.JdShopAPI.FindSkuById(vv.SkuID)
-					_, _, _, specUnit, _, specQuality := jxutils.SplitSkuName(result2.SaleAttrs[0].AttrValueAlias[0])
-					if specQuality < 100 && specUnit != "kg" && specUnit != "L" {
-						var storeSku *model.StoreSkuBind
-						sql := `
-							SELECT * FROM store_sku_bind WHERE store_id = 102919 AND jds_id = ? 
-						`
-						sqlParams := []interface{}{vv.SkuID}
-						err = dao.GetRow(dao.GetDB(), &storeSku, sql, sqlParams)
-						if storeSku == nil {
-							rr = append(rr, vv.SkuID)
+	storeSkus, err := dao.GetStoresSkusInfo(dao.GetDB(), []int{667112}, nil)
+	task := tasksch.NewParallelTask("刷新门店价格", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			v := batchItemList[0].(*model.StoreSkuBind)
+			skus, _ := dao.GetSkus(dao.GetDB(), []int{v.SkuID}, nil, nil, nil, nil)
+			if len(skus) > 0 {
+				sku := skus[0]
+				if v.Price == v.UnitPrice {
+					if sku.Unit == model.UnitNames[0] {
+						if sku.SpecUnit == model.SpecUnitNames[1] || sku.SpecUnit == model.SpecUnitNames[2] {
+							v.Price = utils.Float64TwoInt(utils.Int2Float64(v.UnitPrice) * float64(sku.SpecQuality) * 2)
+						} else {
+							v.Price = utils.Float64TwoInt(utils.Int2Float64(v.UnitPrice) * float64(sku.SpecQuality/500))
 						}
+						v.JdsSyncStatus = v.JdsSyncStatus | 16
+						v.MtwmSyncStatus = v.MtwmSyncStatus | 16
+						v.EbaiSyncStatus = v.EbaiSyncStatus | 16
+						dao.UpdateEntity(dao.GetDB(), v, "Price", "JdsSyncStatus", "MtwmSyncStatus", "EbaiSyncStatus")
 					}
 				}
 			}
-		}
-	}
-	fmt.Println("testrr2", rr)
+			return retVal, err
+		}, storeSkus)
+	tasksch.HandleTask(task, nil, true).Run()
+	task.GetID()
 	return err
 }