美团会员和京东物流自动充值

business/jxstore/cms/job.go

@@ -532,25 +532,42 @@ func ImprotMtMembers(ctx *jxcontext.Context, mtMembers []*model.MtMember) (err e
 	return err
 }
 
-func RechargeMtMembers(ctx *jxcontext.Context, phone int) (err error) {
+func RechargeMtMembers(ctx *jxcontext.Context, phone int) (errCode string, err error) {
 	var (
 		db = dao.GetDB()
 	)
-	mtMember, err := dao.GetMtMember(db)
+	errCode, err = AcceptJob(ctx, model.JobIDMtMembers)
+	if errCode != "" {
+		return errCode, err
+	}
 	if err != nil {
-		return err
+		return errCode, err
+	}
+	mtMember, err := dao.GetMtMember(db)
+	if mtMember == nil {
+		return errCode, fmt.Errorf("美团会员数量不足，请等待补充！")
+	}
+	if err != nil {
+		return errCode, err
 	}
 	if err = api.MtMemberAPI.RechargeExchange(phone, mtMember.ShortLink); err == nil {
 		mtMember.DeletedAt = time.Now()
 		dao.UpdateEntity(db, mtMember, "DeletedAt")
 	}
-	return err
+	return errCode, err
 }
 
 func SendJdDelivery(ctx *jxcontext.Context, dOrder *model.DeliveryOrder) (errCode string, err error) {
 	var (
 		db = dao.GetDB()
 	)
+	errCode, err = AcceptJob(ctx, model.JobIDJdDelivery)
+	if errCode != "" {
+		return errCode, err
+	}
+	if err != nil {
+		return errCode, err
+	}
 	sendDeliveryList, _, err := dao.QueryUserDeliveryAddress(db, int64(dOrder.DeliverySendID), nil, 0, 0)
 	receiveDeliveryList, _, err := dao.QueryUserDeliveryAddress(db, int64(dOrder.DeliveryReceiveID), nil, 0, 0)
 	userBill, err := dao.GetUserBill(db, ctx.GetUserID(), "")