hongze_cygx/models/apply_record.go

package models

import (
	"github.com/beego/beego/v2/client/orm"
	"time"
)

type CygxApplyRecord struct {
	ApplyRecordId    int       `orm:"column(apply_record_id);pk" description:"申请试用id"`
	BusinessCardUrl  string    `description:"名片地址"`
	RealName         string    `description:"姓名"`
	CompanyName      string    `description:"公司名称"`
	CompanyNamePay   string    `description:"公司名称"`
	Mobile           string    `description:"手机号"`
	CreateTime       time.Time `description:"创建时间"`
	ApplyMethod      int       `description:"1:已付费客户申请试用，2:非客户申请试用"`
	RegisterPlatform int       `description:"来源 1小程序，2：网页"`
}

func AddApplyRecord(item *ApplyTryReq, mobile, companyNamePay string, userId, companyIdPay, CompanyIdType int) (err error) {
	o, err := orm.NewOrm().Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			o.Rollback()
		} else {
			o.Commit()
		}
	}()

	sql := `INSERT INTO cygx_apply_record (user_id,business_card_url, real_name,company_name, mobile,create_time, apply_method,company_id_pay,company_name_pay,company_id_type)
          VALUES(?,?,?,?,?,?,?,?,?,?) `
	_, err = o.Raw(sql, userId, item.BusinessCardUrl, item.RealName, item.CompanyName, mobile, time.Now(), item.ApplyMethod, companyIdPay, companyNamePay, CompanyIdType).Exec()
	if err != nil {
		return
	}
	msql := `UPDATE  wx_user
		SET
		  note = ?,
		  is_note = 1,
		  apply_method = ?,
          real_name=?,
		  mobile=?
		WHERE user_id = ? `
	_, err = o.Raw(msql, item.CompanyName, item.ApplyMethod, item.RealName, mobile, userId).Exec()
	return
}

func GetApplyRecordCount(userId int) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT COUNT(1) AS count FROM cygx_apply_record WHERE user_id=? AND status=0 `
	err = o.Raw(sql, userId).QueryRow(&count)
	return
}

// 通过手机号获取详情
func GetCygxApplyRecordByMobile(mobile string) (item *CygxApplyRecord, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_apply_record   WHERE mobile=? AND status=0   ORDER BY apply_record_id DESC   LIMIT 1 `
	err = o.Raw(sql, mobile).QueryRow(&item)
	return
}

// 通过ID获取详情
func GetCygxApplyRecordById(applyRecordId int) (item *CygxApplyRecord, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_apply_record  WHERE apply_record_id=?  `
	err = o.Raw(sql, applyRecordId).QueryRow(&item)
	return
}

type CygxApplyRecordResp struct {
	Detail *CygxApplyRecord
}