aa

business/jxstore/report/report.go

@@ -666,6 +666,7 @@ func RefreshJDMembers(ctx *jxcontext.Context) (err error) {
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
 			pageNo := batchItemList[0].(int)
 			pageResult2, err := api.JdAPI.QueryMemberTransListByCondition("", "", pageNo, pageSize)
+			if pageResult2 != nil {
 				for _, v := range pageResult2.Rows {
 					if utils.Str2Time(v.Endtimestr+" 23:59:59").Sub(time.Now()) >= 0 {
 						if memberMap[v.Merchantcardno] != nil { //库里有这个人的会员信息了
@@ -694,6 +695,7 @@ func RefreshJDMembers(ctx *jxcontext.Context) (err error) {
 						}
 					}
 				}
+			}
 			return retVal, successCount, err
 		}, pages)
 	tasksch.HandleTask(task, nil, true).Run()