aa

business/jxstore/tempop/tempop.go

@@ -1921,6 +1921,8 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 			page := batchItemList[0].(int)
 			results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize)
 			for _, v := range results {
+				userMembers, _ := dao.GetUserMember(db, "", "", v.Merchantcardno, model.VendorIDJD, 0, -1)
+				if len(userMembers) == 0 {
 					userMember := &model.UserMember{
 						VendorOrderID: v.Orderid,
 						VendorID:      model.VendorIDJD,
@@ -1939,6 +1941,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 					}
 					dao.CreateEntity(db, userMember)
 				}
+			}
 			return retVal, successCount, err
 		}, pages)
 	tasksch.HandleTask(task, nil, false).Run()