mtmember

business/jxstore/cms/job.go

@@ -2,6 +2,7 @@ package cms
 
 import (
 	"fmt"
+	"strings"
 	"time"
 
 	"git.rosy.net.cn/jx-callback/globals"
@@ -481,6 +482,7 @@ func ImprotMtMembers(ctx *jxcontext.Context, mtMembers []*model.MtMember) (err e
 		db = dao.GetDB()
 	)
 	for _, v := range mtMembers {
+		v.ShortLink = v.URL[strings.LastIndex(v.URL, "/")+1 : len(v.URL)]
 		dao.WrapAddIDCULDEntity(v, ctx.GetUserName())
 	}
 	if err = dao.CreateMultiEntities(db, mtMembers); err == nil {
@@ -494,3 +496,18 @@ func ImprotMtMembers(ctx *jxcontext.Context, mtMembers []*model.MtMember) (err e
 	}
 	return err
 }
+
+func RechargeMtMembers(ctx *jxcontext.Context, phone int) (err error) {
+	var (
+		db = dao.GetDB()
+	)
+	mtMember, err := dao.GetMtMember(db)
+	if err != nil {
+		return err
+	}
+	if err = api.MtMemberAPI.RechargeExchange(phone, mtMember.ShortLink); err == nil {
+		mtMember.DeletedAt = time.Now()
+		dao.UpdateEntity(db, mtMember, "DeletedAt")
+	}
+	return err
+}

business/model/dao/dao_job.go

@@ -246,3 +246,15 @@ func GetJobOrders(db *DaoDB, jobID int, jobOrderID int64, userID string, statusC
 	}
 	return pagedInfo, err
 }
+
+func GetMtMember(db *DaoDB) (mtMember *model.MtMember, err error) {
+	sql := `
+		SELECT *
+		  FROM mt_member
+		 WHERE deleted_at = ?  
+		 LIMIT 1  
+	`
+	sqlParams := []interface{}{utils.DefaultTimeValue}
+	err = GetRow(db, &mtMember, sql, sqlParams)
+	return mtMember, err
+}

business/model/job.go

@@ -113,6 +113,7 @@ type MtMember struct {
 
 	URL        string    `orm:"column(url)" json:"url"` //网址
 	ExpiryDate time.Time `json:"expiryDate"`            //有效期
+	ShortLink  string    `json:"shortLink"`             //密钥？
 }
 
 func (v *MtMember) TableUnique() [][]string {