aa

business/jxstore/report/report.go

@@ -409,11 +409,13 @@ type GetStoreManageStateResult struct {
 	RepurchaseRate   int     `json:"repurchaseRate"`   //复购率（转化率）
 }
 
-func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, fromTime, toTime string) (getStoreManageStateResult []*GetStoreManageStateResult, err error) {
+func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, fromTime, toTime string, offset, pageSize int) (pageInfo *model.PagedInfo, err error) {
 	var (
-		db                 = dao.GetDB()
-		fromTimeT, toTimeT = utils.Str2Time(fromTime), utils.Str2Time(toTime)
-		dayCount           = int(fromTimeT.Sub(toTimeT).Hours())/24 + 1 //查的几天
+		db                        = dao.GetDB()
+		fromTimeT, toTimeT        = utils.Str2Time(fromTime), utils.Str2Time(toTime)
+		dayCount                  = int(fromTimeT.Sub(toTimeT).Hours())/24 + 1 //查的几天
+		getStoreManageStateResult []*GetStoreManageStateResult
+		storeIDsPage              []int
 	)
 	//权限
 	if permission.IsRoled(ctx) {
@@ -426,17 +428,19 @@ func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, f
 					}
 				}
 			} else {
-				fmt.Println("storeIDs1111111111111111111111111111111111", storeIDsMap, ctx.GetUserID())
 				for k, _ := range storeIDsMap {
 					storeIDs2 = append(storeIDs2, k)
 				}
 			}
-			fmt.Println("storeIDs1111111111111111111111111111111111", storeIDs2)
 			storeIDs = nil
 			storeIDs = storeIDs2
 		}
 	}
-	fmt.Println("storeIDs1111111111111111111111111111111111", storeIDs)
+	index2 := (offset+1)*pageSize - 1
+	if index2 > len(storeIDs) {
+		index2 = len(storeIDs) - 1
+	}
+	storeIDsPage = storeIDs[offset*pageSize : index2]
 	task := tasksch.NewParallelTask("GetStoreManageState", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			v := batchItemList[0].(int)
@@ -514,13 +518,16 @@ func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, f
 			retVal = []*GetStoreManageStateResult{result}
 			// getStoreManageStateResult = append(getStoreManageStateResult, result)
 			return retVal, err
-		}, storeIDs)
+		}, storeIDsPage)
 	tasksch.HandleTask(task, nil, true).Run()
 	result, _ := task.GetResult(0)
 	for _, v := range result {
 		getStoreManageStateResult = append(getStoreManageStateResult, v.(*GetStoreManageStateResult))
 	}
-	return getStoreManageStateResult, err
+	return &model.PagedInfo{
+		TotalCount: len(storeIDs),
+		Data:       getStoreManageStateResult,
+	}, err
 }
 
 func CalculateCoverArea(coordinate []string, vendorID int) (area float64) {