aa

business/jxstore/act/act.go

@@ -644,6 +644,10 @@ func CreateAct(ctx *jxcontext.Context, act *model.Act, vendorIDs []int, vendorOr
 }
 
 func CreateActForMtByOrder(ctx *jxcontext.Context, act *model.Act, vendorID int, vendorOrgCode string, actStoreSku []*ActStoreSkuParam) (err error) {
+	var (
+		db             = dao.GetDB()
+		actStoreSkuMap = make(map[int][]*model.StoreSkuBind)
+	)
 	if vendorID != model.VendorIDMTWM {
 		return fmt.Errorf("此接口只支持美团使用！")
 	}
@@ -651,7 +655,29 @@ func CreateActForMtByOrder(ctx *jxcontext.Context, act *model.Act, vendorID int,
 		return fmt.Errorf("此接口只支持创建直降！")
 	}
 	setActDefault(act)
-	db := dao.GetDB()
+	//处理actStoreSku
+	//参数有可能传多个店多个商品，先分好组：map = [门店ID][]{商品ID1,商品ID2},[门店ID][]{商品ID1,商品ID3,商品ID4}
+	for _, v := range actStoreSku {
+		if resultList, _ := dao.GetStoresSkusInfo(db, []int{v.StoreID}, []int{v.SkuID}); len(resultList) > 0 {
+			actStoreSkuMap[v.StoreID] = append(actStoreSkuMap[v.StoreID], &model.StoreSkuBind{
+				SkuID:     v.SkuID,
+				MtwmPrice: resultList[0].MtwmPrice,
+			})
+		}
+	}
+	//根据平台价排序
+	for _, storeSkus := range actStoreSkuMap {
+		for i := 0; i < len(storeSkus)-1; i++ {
+			for j := 0; j < len(storeSkus)-i-1; j++ {
+				if storeSkus[j].MtwmPrice < storeSkus[j+1].MtwmPrice {
+					temp := storeSkus[j].MtwmPrice
+					storeSkus[j].MtwmPrice = storeSkus[j+1].MtwmPrice
+					storeSkus[j+1].MtwmPrice = temp
+				}
+			}
+		}
+	}
+	fmt.Println("1111111111111111111111111111", utils.Format4Output(actStoreSkuMap, true))
 	txDB, _ := dao.Begin(db)
 	defer func() {
 		if r := recover(); r != nil {
@@ -676,6 +702,7 @@ func CreateActForMtByOrder(ctx *jxcontext.Context, act *model.Act, vendorID int,
 		dao.Rollback(db, txDB)
 		return err
 	}
+
 	dao.Commit(db, txDB)
 	return err
 }