From 34ee046ce2c44ec8273807b4567611bed0a580c2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Fri, 29 Nov 2019 11:09:07 +0800
Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E4=BA=AC=E4=B8=9C=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E4=BF=AE=E6=94=B9=EF=BC=8C=E5=88=B7=E6=96=B0=E8=AE=A2?=
 =?UTF-8?q?=E5=8D=95=E7=BB=93=E7=AE=97=E4=BB=B7=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/tempop/tempop.go | 25 ++++++++++++++++++++-----
 business/model/dao/dao_order.go   |  3 +--
 2 files changed, 21 insertions(+), 7 deletions(-)

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 8005bb8bb..90d0776cb 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1470,6 +1470,8 @@ func ExecuteFileName(filename string) (name string) {
 func GetJdUsers(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint string, err error) {
 	var (
 		jxVendorIDsMap = make(map[string]string)
+		pageNoList     []int
+		storeUserList  []interface{}
 	)
 	//获取京东有效的店
 	db := dao.GetDB()
@@ -1477,11 +1479,24 @@ func GetJdUsers(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint
 	for _, v := range storeMapList {
 		jxVendorIDsMap[v.VendorStoreID] = v.VendorStoreID
 	}
-	//获取京东商城所有用户
-	storeUserList, err := api.JdAPI.PrivilegeSearchUserAll()
 	taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
 		switch step {
 		case 0:
+			//获取京东商城所有用户
+			_, _, toatlPage, _ := api.JdAPI.PrivilegeSearchUser(1)
+			for i := 1; i <= toatlPage; i++ {
+				pageNoList = append(pageNoList, i)
+			}
+			taskFunc1 := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				pageNo := batchItemList[0].(int)
+				storeUserLists, _, _, err := api.JdAPI.PrivilegeSearchUser(pageNo)
+				retVal = storeUserLists
+				return retVal, err
+			}
+			taskParallel1 := tasksch.NewParallelTask("获取京东商城所有用户列表", tasksch.NewParallelConfig(), ctx, taskFunc1, pageNoList)
+			tasksch.HandleTask(taskParallel1, task, true).Run()
+			storeUserList, err = taskParallel1.GetResult(0)
+		case 1:
 			taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 				vv := batchItemList[0].(*jdapi.StoreUserInfo)
 				vendorStoreIDs, err := api.JdAPI.GetJdUserBindStoreIDs(vv.ID)
@@ -1505,16 +1520,16 @@ func GetJdUsers(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint
 				}
 				return retVal, err
 			}
-			taskParallel := tasksch.NewParallelTask("获取京东商城用户列表", tasksch.NewParallelConfig(), ctx, taskFunc, storeUserList)
+			taskParallel := tasksch.NewParallelTask("获取京东商城用户关联门店列表", tasksch.NewParallelConfig(), ctx, taskFunc, storeUserList)
 			tasksch.HandleTask(taskParallel, task, true).Run()
 			_, err = taskParallel.GetResult(0)
-		case 1:
+		case 2:
 			//写excel
 			WriteToExcel(task, jdUsersStruct.userMap)
 		}
 		return result, err
 	}
-	taskSeq := tasksch.NewSeqTask2("获取京东商城用户列表-序列任务", ctx, isContinueWhenError, taskSeqFunc, 2)
+	taskSeq := tasksch.NewSeqTask2("获取京东商城用户关联门店列表-序列任务", ctx, isContinueWhenError, taskSeqFunc, 3)
 	tasksch.HandleTask(taskSeq, nil, true).Run()
 	if !isAsync {
 		_, err = taskSeq.GetResult(0)
diff --git a/business/model/dao/dao_order.go b/business/model/dao/dao_order.go
index 673e06405..0e798884e 100644
--- a/business/model/dao/dao_order.go
+++ b/business/model/dao/dao_order.go
@@ -80,12 +80,11 @@ func QueryOrders(db *DaoDB, vendorOrderID string, actID int, vendorIDs []int, st
 			AND t2.store_id = IF(t4.jx_store_id <> 0, t4.jx_store_id, t4.store_id)
 			AND t4.order_created_at BETWEEN t1.begin_at AND t1.end_at
 			WHERE t1.status = 1
-			AND t1.type = ?
 			AND t1.id = ?
 			GROUP BY 1,2
 		)s ON s.vendor_order_id = a.vendor_order_id AND s.vendor_id = a.vendor_id	
 		`
-		sqlParams = append(sqlParams, model.ActSkuFake, actID)
+		sqlParams = append(sqlParams, actID)
 	}
 	sql += `
 	WHERE 1=1