门店评分并发修改

business/jxstore/misc/store_score.go

@@ -6,6 +6,7 @@ import (
 	"sync"
 	"time"
 
+	"git.rosy.net.cn/baseapi"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/jxstore/cms"
 	"git.rosy.net.cn/jx-callback/business/jxutils"
@@ -18,6 +19,7 @@ import (
 
 const (
 	EnableScheduleScoreStore = !true
+	ParallelCount            = 5
 
 	GoldMedalScore   = 90
 	SilverMedalScore = 80
@@ -38,7 +40,8 @@ const (
 	AbsentGoodsOrderNormalRatio = 1.0                                          //百分比
 	StoreRangeGoodRadius        = 2.0                                          //千米
 	StoreRangeBadRadius         = 1.0                                          //千米
-	SaleSkuPriceRatio           = 90                                           //百分比
+	SaleSkuPriceRatio           = 90                                           //千米
+	SaleSkuCheckRange           = 5.0                                          //千米
 )
 
 var (
@@ -115,7 +118,7 @@ func (s *StoreScoreDataWrapper) SetData(storeID int, valueName string, value int
 }
 
 //得到所有门店的商品
-func GetAllStoreSkus(ctx *jxcontext.Context, storeList []*cms.StoreExt) {
+func GetAllStoreSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, storeList []*cms.StoreExt) {
 	allStoreSkusWrapper.InitData()
 	taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 		storeInfo := batchItemList[0].(*cms.StoreExt)
@@ -133,8 +136,8 @@ func GetAllStoreSkus(ctx *jxcontext.Context, storeList []*cms.StoreExt) {
 		allStoreSkusWrapper.SetData(storeID, jxSkuMapData)
 		return retVal, err
 	}
-	taskParallel := tasksch.NewParallelTask("GetAllStoreSkus", nil, ctx, taskFunc, storeList)
-	tasksch.HandleTask(taskParallel, nil, true).Run()
+	taskParallel := tasksch.NewParallelTask("得到所有门店商品", nil, ctx, taskFunc, storeList)
+	tasksch.HandleTask(taskParallel, parentTask, true).Run()
 	taskParallel.GetResult(0)
 }
 
@@ -153,8 +156,7 @@ func GetOpenTime(opTimeList []int16) (opTime float64) {
 }
 
 //营业时间12小时及以上满分，总分10分，每少一个小时扣1分
-func ScoreStoreOpenTime(storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreStoreOpenTime(storeInfo *cms.StoreExt) {
 	storeID := storeInfo.ID
 	storeStatus := storeInfo.Status
 	isStoreOpen := storeStatus == model.StoreStatusOpened
@@ -177,12 +179,10 @@ func ScoreStoreOpenTime(storeList []*cms.StoreExt) {
 			storeScoreDataWrapper.SetData(storeID, model.FieldStoreOpenTime, finalScore)
 		}
 	}
-	}
 }
 
 //可售商品数量大于1000，总分10分，按比例扣
-func ScoreSaleSkuCount(ctx *jxcontext.Context, storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreSaleSkuCount(storeInfo *cms.StoreExt) {
 	storeID := storeInfo.ID
 	skusMapData := allStoreSkusWrapper.GetData(storeID)
 	if len(skusMapData) > 0 {
@@ -202,12 +202,10 @@ func ScoreSaleSkuCount(ctx *jxcontext.Context, storeList []*cms.StoreExt) {
 		}
 		storeScoreDataWrapper.SetData(storeID, model.FieldSaleSkuCount, finalScore)
 	}
-	}
 }
 
 //平均捡货时间小于等于拣货截止时间为10分满分，每超出1分钟，减1分
-func ScoreAveragePickupTime(storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreAveragePickupTime(storeInfo *cms.StoreExt) {
 	storeID := storeInfo.ID
 	db := dao.GetDB()
 	orderList, err := dao.GetDailyFinishOrderList(db, storeID)
@@ -231,12 +229,10 @@ func ScoreAveragePickupTime(storeList []*cms.StoreExt) {
 		finalScore := totalScore / orderListCount
 		storeScoreDataWrapper.SetData(storeID, model.FieldAveragePickupTime, finalScore)
 	}
-	}
 }
 
 //差评订单和完成订单比例小于0.2%,得满分10分，每增加0.1%减1分
-func ScoreBadCommentOrder(storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreBadCommentOrder(storeInfo *cms.StoreExt) {
 	storeID := storeInfo.ID
 	db := dao.GetDB()
 	badCommentOrderCount, _ := dao.GetDailyBadCommentOrderCount(db, storeID)
@@ -255,12 +251,10 @@ func ScoreBadCommentOrder(storeList []*cms.StoreExt) {
 		}
 		storeScoreDataWrapper.SetData(storeID, model.FieldBadCommentOrder, finalScore)
 	}
-	}
 }
 
 //未完成订单和完成订单比小于1%，得满分10分，比例每增加5%，分数减1
-func ScoreUnfinishOrder(storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreUnfinishOrder(storeInfo *cms.StoreExt) {
 	storeID := storeInfo.ID
 	db := dao.GetDB()
 	unFinishOrderCount, _ := dao.GetDailyUnFinishOrderCount(db, storeID)
@@ -279,12 +273,10 @@ func ScoreUnfinishOrder(storeList []*cms.StoreExt) {
 		}
 		storeScoreDataWrapper.SetData(storeID, model.FieldUnfinishOrder, finalScore)
 	}
-	}
 }
 
 //缺货订单和完成订单比小于1%得10分，比例每增加0.1%减1分
-func ScoreAbsentGoodsOrder(storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreAbsentGoodsOrder(storeInfo *cms.StoreExt) {
 	storeID := storeInfo.ID
 	db := dao.GetDB()
 	absentGoodsOrderCount, _ := dao.GetDailyAbsentGoodsOrderCount(db, storeID)
@@ -303,12 +295,10 @@ func ScoreAbsentGoodsOrder(storeList []*cms.StoreExt) {
 		}
 		storeScoreDataWrapper.SetData(storeID, model.FieldAbsentGoodsOrder, finalScore)
 	}
-	}
 }
 
 //促销品数量20个以上为满分10分，每少2个扣1分
-func ScorePromotionSku(storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScorePromotionSku(storeInfo *cms.StoreExt) {
 	storeID := storeInfo.ID
 	db := dao.GetDB()
 	beginTime := time.Now()
@@ -334,13 +324,11 @@ func ScorePromotionSku(storeList []*cms.StoreExt) {
 		}
 		storeScoreDataWrapper.SetData(storeID, model.FieldPromotionSku, finalScore)
 	}
-	}
 }
 
 //经营全平台满分10分，每少一个平台扣2分(一个平台没有得0分)
-func ScoreFullVendor(storeList []*cms.StoreExt) {
+func ScoreFullVendor(storeInfo *cms.StoreExt) {
 	fullVendorCount := len(fullVendorList)
-	for _, storeInfo := range storeList {
 	finalScore := 0
 	storeID := storeInfo.ID
 	storeStatus := storeInfo.Status
@@ -354,7 +342,6 @@ func ScoreFullVendor(storeList []*cms.StoreExt) {
 			count++
 		}
 	}
-
 	if count > 0 {
 		if count == fullVendorCount {
 			finalScore = ItemTotalScore
@@ -364,12 +351,10 @@ func ScoreFullVendor(storeList []*cms.StoreExt) {
 		}
 	}
 	storeScoreDataWrapper.SetData(storeID, model.FieldFullVendor, finalScore)
-	}
 }
 
 //经营范围面积大于半径2km的圆得满分10分，低于1km得分0
-func ScoreStoreRange(storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreStoreRange(storeInfo *cms.StoreExt) {
 	finalScore := 0
 	storeID := storeInfo.ID
 	if storeInfo.DeliveryRangeType == model.DeliveryRangeTypePolygon {
@@ -387,7 +372,7 @@ func ScoreStoreRange(storeList []*cms.StoreExt) {
 			finalScore = ItemTotalScore - int(math.Round(diff*ratio))
 		}
 	} else if storeInfo.DeliveryRangeType == model.DeliveryRangeTypeRadius {
-			deliveryRadius := utils.Str2Float64(storeInfo.DeliveryRange) / 1000
+		deliveryRadius := utils.Str2Float64WithDefault(storeInfo.DeliveryRange, 0) / 1000
 		if deliveryRadius >= StoreRangeGoodRadius {
 			finalScore = ItemTotalScore
 		} else if deliveryRadius <= StoreRangeBadRadius {
@@ -399,17 +384,16 @@ func ScoreStoreRange(storeList []*cms.StoreExt) {
 		}
 	}
 	storeScoreDataWrapper.SetData(storeID, model.FieldStoreRange, finalScore)
-	}
 }
 
 //得到距离某个门店多少KM内的所有门店信息
-func GetRangeStoreList(storeID int, lng, lat, checkDist float64, storeList []*cms.StoreExt) (outStoreList []*cms.StoreExt) {
+func GetRangeStoreList(storeID int, lng, lat, checkRange float64, storeList []*cms.StoreExt) (outStoreList []*cms.StoreExt) {
 	for _, storeInfo := range storeList {
 		if storeInfo.ID == storeID {
 			outStoreList = append(outStoreList, storeInfo)
 		} else {
 			distance := jxutils.EarthDistance(lng, lat, storeInfo.FloatLng, storeInfo.FloatLat)
-			if distance <= checkDist {
+			if distance <= checkRange {
 				outStoreList = append(outStoreList, storeInfo)
 			}
 		}
@@ -454,13 +438,12 @@ func GetSkusCountLessEqualAvgPrice(storeID int, skusAveragePrice map[int]int) (c
 }
 
 //可售商品价格在附近5km内门店比较，价格低于等于平均值的商品数占90%以上满分10分，比例每降低10%减1分，100%超标得0分
-func ScoreSaleSkuPrice(ctx *jxcontext.Context, storeList []*cms.StoreExt) {
-	for _, storeInfo := range storeList {
+func ScoreSaleSkuPrice(storeInfo *cms.StoreExt, storeList []*cms.StoreExt) {
 	finalScore := 0
 	storeID := storeInfo.ID
 	totalCount := len(allStoreSkusWrapper.GetData(storeID))
 	if totalCount > 0 {
-			rangeStoreList := GetRangeStoreList(storeID, storeInfo.FloatLng, storeInfo.FloatLat, 5, storeList)
+		rangeStoreList := GetRangeStoreList(storeID, storeInfo.FloatLng, storeInfo.FloatLat, SaleSkuCheckRange, storeList)
 		skusAveragePrice := GetStoreSkusAveragePrice(rangeStoreList)
 		count := GetSkusCountLessEqualAvgPrice(storeID, skusAveragePrice)
 		if count > 0 {
@@ -477,7 +460,6 @@ func ScoreSaleSkuPrice(ctx *jxcontext.Context, storeList []*cms.StoreExt) {
 		}
 		storeScoreDataWrapper.SetData(storeID, model.FieldSaleSkuPrice, finalScore)
 	}
-	}
 }
 
 func GetFilterStoreListEx(storeList []*cms.StoreExt, storeIDMap map[int]int) (outStoreList []*cms.StoreExt) {
@@ -506,24 +488,55 @@ func GetFilterStoreListEx(storeList []*cms.StoreExt, storeIDMap map[int]int) (ou
 }
 
 func ScoreStore(ctx *jxcontext.Context, storeIDList []int) (retVal interface{}, err error) {
+	var storeList []*cms.StoreExt
+	taskCount := 4
+	taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
+		switch step {
+		case 0:
+			baseapi.SugarLogger.Debugf("ScoreStore step0 begin")
 			storeScoreDataWrapper.InitData()
-	storeList, err := GetStoreList(ctx)
+			storeList, err = GetStoreList(ctx)
 			storeIDMap := jxutils.IntList2Map(storeIDList)
 			storeList = GetFilterStoreListEx(storeList, storeIDMap)
-
-	GetAllStoreSkus(ctx, storeList)
-	ScoreStoreOpenTime(storeList)
-	ScoreSaleSkuCount(ctx, storeList)
-	ScoreAveragePickupTime(storeList)
-	ScoreBadCommentOrder(storeList)
-	ScoreUnfinishOrder(storeList)
-	ScoreAbsentGoodsOrder(storeList)
-	ScorePromotionSku(storeList)
-	ScoreFullVendor(storeList)
-	ScoreStoreRange(storeList)
-	ScoreSaleSkuPrice(ctx, storeList)
+			baseapi.SugarLogger.Debugf("ScoreStore step0 end")
+		case 1:
+			baseapi.SugarLogger.Debugf("ScoreStore step1 begin")
+			GetAllStoreSkus(ctx, task, storeList)
+			baseapi.SugarLogger.Debugf("ScoreStore step1 end")
+		case 2:
+			baseapi.SugarLogger.Debugf("ScoreStore step2 begin")
+			taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				storeInfo := batchItemList[0].(*cms.StoreExt)
+				ScoreStoreOpenTime(storeInfo)
+				ScoreSaleSkuCount(storeInfo)
+				ScoreAveragePickupTime(storeInfo)
+				ScoreBadCommentOrder(storeInfo)
+				ScoreUnfinishOrder(storeInfo)
+				ScoreAbsentGoodsOrder(storeInfo)
+				ScorePromotionSku(storeInfo)
+				ScoreFullVendor(storeInfo)
+				ScoreStoreRange(storeInfo)
+				ScoreSaleSkuPrice(storeInfo, storeList)
+				return retVal, err
+			}
+			taskParallel := tasksch.NewParallelTask("计算门店得分", tasksch.NewParallelConfig().SetParallelCount(ParallelCount), ctx, taskFunc, storeList)
+			tasksch.HandleTask(taskParallel, task, true).Run()
+			taskParallel.GetResult(0)
+			_, err = taskParallel.GetResult(0)
+			if err != nil {
+				baseapi.SugarLogger.Debugf("ScoreStore taskParallel error:%v", err)
+			}
+			baseapi.SugarLogger.Debugf("ScoreStore step2 end")
+		case 3:
+			baseapi.SugarLogger.Debugf("ScoreStore step3 begin")
 			InsertStoreScore()
 			allStoreSkusWrapper.ClearData()
+			baseapi.SugarLogger.Debugf("ScoreStore step3 end")
+		}
+		return result, err
+	}
+	taskSeq := tasksch.NewSeqTask("门店评分-序列任务", ctx, taskSeqFunc, taskCount)
+	tasksch.HandleTask(taskSeq, nil, true).Run()
 
 	return retVal, err
 }