jy/src/jfw/modules/subscribepay/src/util/msgremind.go

//未支付订单提醒
package util

import (
	. "config"
	"encoding/hex"
	"fmt"
	"log"
	"math"
	"qfw/util"
	qrpc "qfw/util/rpc"
	"strconv"
	"strings"
	"sync"
	"time"

	"github.com/shopspring/decimal"
	"go.mongodb.org/mongo-driver/bson"
)

var MsgRemind = &msgRemind{
	unpaidOrders: &sync.Map{},
}

type msgRemind struct {
	unpaidOrders *sync.Map
}

type unpaidOrder struct {
	orderId      int    //订单id
	orderCode    string //订单编号
	userId       string //用户id
	prepayTime   int64  //下单时间
	remindStatus int    //1-下单时间2小时提醒 2-剩余2小时自动关闭时再次提醒
	vipType      int    //-1：直接购买 0：试用 1：续费 2：升级
	orderMoney   int    //订单金额
}

/*新的订单存库以后，再存入内存中
 *@param orderId 订单id
 *@param orderMoney 订单金额
 *@param vipType -1：直接购买 0：试用 1：续费 2：升级
 *@param remindStatus 1-下单时间2小时提醒 2-剩余2小时自动关闭时再次提醒
 *@param orderCode 订单编号
 *@param userId 用户id
 *@param prepayTime 购买时间
 */
func (m *msgRemind) Add(orderId, orderMoney, vipType, remindStatus int, orderCode, userId string, prepayTime int64) {
	log.Println("未支付待提醒订单加入", orderId, orderCode, userId, prepayTime)
	m.unpaidOrders.Store(orderId, &unpaidOrder{
		orderCode:    orderCode,
		userId:       userId,
		prepayTime:   prepayTime,
		orderId:      orderId,
		orderMoney:   orderMoney,
		vipType:      vipType,
		remindStatus: remindStatus,
	})
}

/*删除待提醒的订单
 *@param orderId 订单id
 */
func (m *msgRemind) Delete(orderId int) {
	log.Println("删除待提醒的订单", orderId)
	m.unpaidOrders.Delete(orderId)
}

/*
 *订单支付成功以后，消息通知处理
 *@param orderId 订单id
 *@param orderCode 订单编号
 *@param userId 用户id
 *@param prepayTime 购买时间
 *@param vipType -1：直接购买 0：试用 1：续费 2：升级
 */
func (m *msgRemind) PaySuccess(orderId int, orderCode, userId, prepayTime string, vipType int) {
	go func() {
		defer util.Catch()
		log.Println("支付成功以后，消息提醒处理", orderId, orderCode, userId, prepayTime)
		m.unpaidOrders.Delete(orderId)
		user, ok := MQFW.FindById("user", userId, `{"s_m_openid":1,"s_jpushid":1,"s_opushid":1,"s_appponetype":1,"i_ispush":1,"l_vip_endtime":1}`)
		if !ok || user == nil || len(*user) == 0 {
			return
		}
		isPushWx := util.IntAllDef((*user)["i_ispush"], 1)
		s_m_openid, _ := (*user)["s_m_openid"].(string)
		s_jpushid, _ := (*user)["s_jpushid"].(string)
		s_opushid, _ := (*user)["s_opushid"].(string)
		s_appponetype, _ := (*user)["s_appponetype"].(string)
		log.Println("支付成功，推送消息", userId, "s_m_openid", s_m_openid, "s_jpushid", s_jpushid, "s_opushid", s_opushid, "s_appponetype", s_appponetype)
		if isPushWx == 1 && s_m_openid != "" {
			l_vip_endtime := (*user)["l_vip_endtime"]
			expireTime := util.FormatDateWithObj(&l_vip_endtime, util.Date_Short_Layout)
			wxPushOk, _ := qrpc.WxSendTmplMsg(Config.Weixinrpc, &qrpc.WxTmplMsg{
				OpenId: s_m_openid,
				TplId:  MessageConfig.WxTpl_PaySuccess.Id,
				TmplData: map[string]*qrpc.TmplItem{
					"first": &qrpc.TmplItem{
						Value: fmt.Sprintf(MessageConfig.WxTpl_PaySuccess.First.Value, orderCode),
					},
					"keyword1": &qrpc.TmplItem{
						Value: fmt.Sprintf(MessageConfig.WxTpl_PaySuccess.Keyword1.Value, m.getVipType(vipType)),
					},
					"keyword2": &qrpc.TmplItem{
						Value: orderCode,
					},
					"keyword3": &qrpc.TmplItem{
						Value: strings.Split(prepayTime, " ")[0],
					},
					"keyword4": &qrpc.TmplItem{
						Value: expireTime,
					},
				},
				Url: Config.WebDomain + "/front/sess/" + Se_Topnet.EncodeString(s_m_openid+",uid,"+strconv.Itoa(int(time.Now().Unix()))+",msgremind") + "__" + hex.EncodeToString([]byte(fmt.Sprintf("type=paid"))),
			})
			log.Println("支付成功，微信推送", userId, wxPushOk)
		} else if s_opushid != "" || s_jpushid != "" {
			appPushOk := qrpc.AppPush(Config.AppPushServiceRpc, map[string]interface{}{
				"phoneType":   s_appponetype,
				"otherPushId": s_opushid,
				"jgPushId":    s_jpushid,
				"url":         "/jyapp/free/sess/" + Se_Topnet.EncodeString(userId+",uid,"+strconv.Itoa(int(time.Now().Unix()))+",msgremind") + "__" + hex.EncodeToString([]byte(fmt.Sprintf("type=paid"))),
				"userId":      userId,
				"type":        "vipNotice",
				"descript":    fmt.Sprintf(MessageConfig.WxTpl_PaySuccess.First.Value, orderCode),
				"title":       "剑鱼提醒",
			})
			log.Println("支付成功，app推送", userId, appPushOk)
		}
	}()
}

/*
 *订单支付成功以后，消息通知处理
 *@param orderId 订单id
 *@param orderCode 订单编号
 *@param userId 用户id
 *@param prepayTime 购买时间
 *@param vipType -1：直接购买 0：试用 1：续费 2：升级
 */
func (m *msgRemind) DistributionSuccess(orderId int, userId string, price int, product string) {
	go func() {
		priceFloat := decimal.NewFromFloat(float64(price)).Div(decimal.NewFromFloat(float64(100)))
		defer util.Catch()
		log.Println("分销成功以后，消息提醒处理", orderId, userId)
		m.unpaidOrders.Delete(orderId)
		user, ok := MQFW.FindById("user", userId, `{"s_m_openid":1,"s_jpushid":1,"s_opushid":1,"s_appponetype":1,"i_ispush":1,"l_vip_endtime":1}`)
		if !ok || user == nil || len(*user) == 0 {
			return
		}
		isPushWx := util.IntAllDef((*user)["i_ispush"], 1)
		s_m_openid, _ := (*user)["s_m_openid"].(string)
		s_jpushid, _ := (*user)["s_jpushid"].(string)
		s_opushid, _ := (*user)["s_opushid"].(string)
		s_appponetype, _ := (*user)["s_appponetype"].(string)
		log.Println("分销成功以后，推送消息", "isPushWx", isPushWx, userId, "s_m_openid", s_m_openid, "s_jpushid", s_jpushid, "s_opushid", s_opushid, "s_appponetype", s_appponetype)
		url := ""
		partner := Mysql.CountBySql(`select count(*) from dis_partner where uid=? and type!=3`, userId) > 0
		if !partner {
			url = "/page_partner/partner/partner.html"
		} else {
			url = "/jyapp/free/notice"
		}
		if s_opushid != "" || s_jpushid != "" {
			appPushOk := qrpc.AppPush(Config.AppPushServiceRpc, map[string]interface{}{
				"phoneType":   s_appponetype,
				"otherPushId": s_opushid,
				"jgPushId":    s_jpushid,
				"url":         url,
				"userId":      userId,
				"type":        "profit",
				"title":       fmt.Sprintf(Config.ProfitTitle, fmt.Sprint(priceFloat)),
				"descript":    fmt.Sprintf(Config.ProfitDescript, product, fmt.Sprint(priceFloat)),
			})
			log.Println("分销成功，app推送", userId, appPushOk)
		}
		value := bson.M{
			"s_title":      fmt.Sprintf(Config.ProfitTitle, fmt.Sprint(priceFloat)),             //入库时间
			"s_id":         "",                                                                  //购买内容数量
			"i_unread":     1,                                                                   //是否已经生效 0-未生效
			"s_userid":     userId,                                                              //试用设置地区
			"s_url":        "",                                                                  //试用设置行业
			"s_type":       "profit",                                                            //生效时间
			"s_descript":   fmt.Sprintf(Config.ProfitDescript, product, fmt.Sprint(priceFloat)), //副标题
			"s_descript1":  "注册成为剑鱼伙伴，领取您的佣金！",                                                  //副标题
			"l_comeintime": time.Now().Unix(),
			"l_timestamp":  time.Now().Unix(),
		}
		MQFW.Save("jyapp_notice", value)
		log.Println("分销消息", ok, value)
	}()
}
func (m *msgRemind) getExpireTime() int64 {
	order_countdown := Config.OrderCountdown //配置文件读取
	if strings.Contains(util.ObjToString(order_countdown), "h") {
		onehour, _ := time.ParseDuration(util.ObjToString(order_countdown))
		return int64(onehour.Seconds())
	} else {
		return util.Int64All(order_countdown) * 24 * 60 * 60
	}
}

func (m *msgRemind) getVipType(vipType int) string {
	switch vipType {
	case 0:
		return "（试用）"
	case 1:
		return "（续费）"
	case 2:
		return "（升级）"
	}
	return ""
}

func (m *msgRemind) run() {
	duration := TimeTaskConfig.UnpaidRemind.Duration
	if duration == 0 {
		duration = 10
	}
	log.Println("未支付订单定时任务run after", duration, "m")
	time.AfterFunc(time.Duration(duration)*time.Minute, func() {
		defer util.Catch()
		m.unpaidOrders.Range(func(k interface{}, v interface{}) bool {
			orderId, _ := k.(int)
			unpaidOrder, _ := v.(*unpaidOrder)
			if Mysql.CountBySql("select count(1) as count from dataexport_order where id=? and order_status=0 and del_status=0 and (remind_status<>2 or remind_status is null)", orderId) == 0 {
				log.Println("未支付订单状态发生变化，不推送消息", unpaidOrder.userId, orderId, unpaidOrder.orderCode)
				return true
			}
			now_unix := time.Now().Unix()
			remind_status := 0
			//剩余2小时
			if unpaidOrder.remindStatus != 2 && unpaidOrder.prepayTime+m.getExpireTime() > now_unix && now_unix >= unpaidOrder.prepayTime+m.getExpireTime()-TimeTaskConfig.UnpaidRemind.BeforeExpire {
				remind_status = 2
			} else if unpaidOrder.remindStatus == 0 && now_unix > unpaidOrder.prepayTime+TimeTaskConfig.UnpaidRemind.AfterOrder { //下单时间后2小时未支付
				remind_status = 1
			}
			if remind_status == 0 {
				return true
			}
			user, ok := MQFW.FindById("user", unpaidOrder.userId, `{"s_m_openid":1,"s_jpushid":1,"s_opushid":1,"s_appponetype":1,"i_ispush":1}`)
			if !ok || user == nil || len(*user) == 0 {
				return true
			}
			isPushWx := util.IntAllDef((*user)["i_ispush"], 1)
			s_m_openid, _ := (*user)["s_m_openid"].(string)
			s_jpushid, _ := (*user)["s_jpushid"].(string)
			s_opushid, _ := (*user)["s_opushid"].(string)
			s_appponetype, _ := (*user)["s_appponetype"].(string)
			log.Println("未支付订单，推送消息", unpaidOrder.userId, orderId, unpaidOrder.orderCode, "remind_status", remind_status, "i_ispush", isPushWx, "s_m_openid", s_m_openid, "s_jpushid", s_jpushid, "s_opushid", s_opushid, "s_appponetype", s_appponetype)
			wxPushOk, appPushOk := false, false
			if isPushWx == 1 && s_m_openid != "" {
				tmplData := map[string]*qrpc.TmplItem{
					"first": &qrpc.TmplItem{
						Value: fmt.Sprintf(MessageConfig.WxTpl_Unpaid.First.Value, unpaidOrder.orderCode),
						Color: MessageConfig.WxTpl_Unpaid.First.Color,
					},
					"keyword1": &qrpc.TmplItem{
						Value: util.FormatDateByInt64(&unpaidOrder.prepayTime, util.Date_Short_Layout),
					},
					"keyword2": &qrpc.TmplItem{
						Value: unpaidOrder.orderCode,
					},
					"keyword3": &qrpc.TmplItem{
						Value: fmt.Sprintf(MessageConfig.WxTpl_Unpaid.Keyword3.Value, fmt.Sprintf("%.2f", float64(unpaidOrder.orderMoney)/100)),
					},
					"keyword4": &qrpc.TmplItem{
						Value: fmt.Sprintf(MessageConfig.WxTpl_Unpaid.Keyword4.Value, m.getVipType(unpaidOrder.vipType)),
					},
				}
				if remind_status == 2 {
					tmplData["remark"] = &qrpc.TmplItem{
						Value: fmt.Sprintf(MessageConfig.WxTpl_Unpaid.Remark.Value, math.Ceil(float64(TimeTaskConfig.UnpaidRemind.BeforeExpire)/3600)),
					}
				}
				wxPushOk, _ = qrpc.WxSendTmplMsg(Config.Weixinrpc, &qrpc.WxTmplMsg{
					OpenId:   s_m_openid,
					TplId:    MessageConfig.WxTpl_Unpaid.Id,
					TmplData: tmplData,
					Url:      Config.WebDomain + "/front/sess/" + Se_Topnet.EncodeString(s_m_openid+",uid,"+strconv.Itoa(int(time.Now().Unix()))+",msgremind") + "__" + hex.EncodeToString([]byte(fmt.Sprintf("type=unpaid&ordercode=%s", unpaidOrder.orderCode))),
				})
				log.Println("未支付订单，微信推送", unpaidOrder.userId, orderId, unpaidOrder.orderCode, wxPushOk)
			} else if s_opushid != "" || s_jpushid != "" {
				appPushOk = qrpc.AppPush(Config.AppPushServiceRpc, map[string]interface{}{
					"phoneType":   s_appponetype,
					"otherPushId": s_opushid,
					"jgPushId":    s_jpushid,
					"url":         "/jyapp/free/sess/" + Se_Topnet.EncodeString(unpaidOrder.userId+",uid,"+strconv.Itoa(int(time.Now().Unix()))+",msgremind") + "__" + hex.EncodeToString([]byte(fmt.Sprintf("type=unpaid&ordercode=%s", unpaidOrder.orderCode))),
					"userId":      unpaidOrder.userId,
					"type":        "vipNotice",
					"descript":    fmt.Sprintf(MessageConfig.WxTpl_Unpaid.First.Value, unpaidOrder.orderCode),
					"title":       "剑鱼提醒",
				})
				log.Println("未支付订单，app推送", unpaidOrder.userId, orderId, unpaidOrder.orderCode, appPushOk)
			}
			if wxPushOk || appPushOk {
				if remind_status == 2 {
					m.unpaidOrders.Delete(orderId)
				} else {
					unpaidOrder.remindStatus = 1
					m.unpaidOrders.Store(orderId, unpaidOrder)
				}
				Mysql.Update("dataexport_order", map[string]interface{}{
					"id": orderId,
				}, map[string]interface{}{
					"remind_status": remind_status,
				})
			}
			return true
		})
		m.run()
	})
}
func (m *msgRemind) gc() {
	time.AfterFunc(5*time.Minute, func() {
		defer util.Catch()
		m.unpaidOrders.Range(func(k interface{}, v interface{}) bool {
			unpaidOrder, _ := v.(*unpaidOrder)
			if time.Now().Unix() > unpaidOrder.prepayTime+m.getExpireTime() {
				m.unpaidOrders.Delete(k)
			}
			return true
		})
		m.gc()
	})
}
func init() {
	if TimeTaskConfig.IsRun {
		go func() {
			defer util.Catch()
			log.Println("开始加载72小时内的订单到内存中。。。")
			startTime := time.Unix(time.Now().Unix()-MsgRemind.getExpireTime(), 0)
			startTimes := util.FormatDate(&startTime, util.Date_Full_Layout)
			list := Mysql.SelectBySql("select id,order_code,order_money,user_id,prepay_time,remind_status,vip_type from dataexport_order where order_money>0 and prepay_time>=? and product_type='VIP订阅' and order_status=0 and del_status=0 and (remind_status<>2 or remind_status is null)", startTimes)
			if list == nil {
				log.Println("加载72小时内的订单到内存中失败")
				return
			}
			for _, v := range *list {
				order_code, _ := v["order_code"].(string)
				user_id, _ := v["user_id"].(string)
				prepay_time, _ := v["prepay_time"].(string)
				if order_code == "" || user_id == "" || prepay_time == "" {
					continue
				}
				prepayTime, err := time.ParseInLocation(util.Date_Full_Layout, prepay_time, time.Local)
				if err != nil {
					continue
				}
				orderId := util.IntAll(v["id"])
				MsgRemind.Add(orderId, util.IntAll(v["order_money"]), util.IntAllDef(v["vip_type"], -1), util.IntAll(v["remind_status"]), order_code, user_id, prepayTime.Unix())
			}
			log.Println("加载72小时内的订单到内存中结束。。。", len(*list))
		}()
	}
	MsgRemind.run()
	MsgRemind.gc()
}