jx-callback/business/jxutils/smsmsg/smsmsg.go

package smsmsg

import (
	"fmt"

	aliyunsmsclient "github.com/KenmyZhang/aliyun-communicate"

	"git.rosy.net.cn/baseapi/utils"
	"git.rosy.net.cn/baseapi/utils/errlist"
	"git.rosy.net.cn/jx-callback/business/jxutils"
	"git.rosy.net.cn/jx-callback/business/model"
	"git.rosy.net.cn/jx-callback/business/model/dao"
	"git.rosy.net.cn/jx-callback/globals"
	"git.rosy.net.cn/jx-callback/globals/api"
)

var (
	warningMap = map[string]int{
		"isv.AMOUNT_NOT_ENOUGH": 1,
		"isv.ACCOUNT_ABNORMAL":  1,
		"isv.OUT_OF_SERVICE":    1,
		"isv.DAY_LIMIT_CONTROL": 1,
	}
)

func SendSMSMsg(mobileList []string, signName, templateCode string, templateParam map[string]interface{}, order *model.GoodsOrder) (err error) {
	if len(mobileList) > 0 {
		errList := errlist.New()
		mobileList = jxutils.StringMap2List(jxutils.StringList2Map(mobileList))
		for _, mobileNum := range mobileList {
			if mobileNum != "" {
				globals.SugarLogger.Debugf("SendSMSMsg mobileNum:%s, templateCode:%s", mobileNum, templateCode)
				if true { //globals.EnableStoreWrite {
					if response, err := api.SMSClient.Execute(globals.AliKey, globals.AliSecret, mobileNum, signName, templateCode, string(utils.MustMarshal(templateParam))); err != nil {
						globals.SugarLogger.Warnf("SendSMSMsg mobileNum:%s failed with error:%v", mobileNum, err)
						errList.AddErr(err)
					} else if response.Code != aliyunsmsclient.ResponseCodeOk {
						errMsg := fmt.Sprintf("SendSMSMsg mobileNum:%s failed with response:%s", mobileNum, utils.Format4Output(response, true))
						errList.AddErr(fmt.Errorf(errMsg))
						if warningMap[response.Code] == 1 {
							globals.SugarLogger.Warnf(errMsg)
						} else {
							globals.SugarLogger.Infof(errMsg)
						}
					} else {
						if order != nil {
							err = updateStoreSMSNotifyMark(order)
						}
					}
				}
			}
		}
		err = errList.GetErrListAsOne()
	}
	return err
}

func getOrderNotifyPhone(order *model.GoodsOrder) (phoneList []string) {
	return dao.GetOrderNotifyPhones(dao.GetDB(), jxutils.GetSaleStoreIDFromOrder(order))
}

func NotifyNewOrder(order *model.GoodsOrder) (err error) {
	if isPushSMS(order) {
		err = SendSMSMsg(getOrderNotifyPhone(order), globals.SMSSignName, globals.SMSNewOrderTemplate, map[string]interface{}{
			"daySeq":        order.OrderSeq,
			"consigneeName": order.ConsigneeName,
			"payMoney":      jxutils.IntPrice2StandardString(order.ActualPayPrice),
		}, order)
	}
	return err
}

func NotifyOrderCanceled(order *model.GoodsOrder) (err error) {
	err = SendSMSMsg(getOrderNotifyPhone(order), globals.SMSSignName, globals.SMSOrderCanceledTemplate, map[string]interface{}{
		"vendorName": model.VendorChineseNames[order.VendorID],
		"seq":        order.OrderSeq,
		"orderID":    order.VendorOrderID,
	}, order)
	return err
}

func isPushSMS(order *model.GoodsOrder) bool {
	stores, _ := dao.GetStoreList(dao.GetDB(), []int{order.StoreID}, nil, nil, nil, "")
	if len(stores) > 0 {
		if stores[0].SMSNotifyMark == model.NO {
			return true
		} else {
			return false
		}
	} else {
		return false
	}
}

func updateStoreSMSNotifyMark(order *model.GoodsOrder) (err error) {
	var db = dao.GetDB()
	stores, _ := dao.GetStoreList(db, []int{order.StoreID}, nil, nil, nil, "")
	if len(stores) > 0 {
		stores[0].SMSNotifyMark = model.YES
		_, err = dao.UpdateEntity(db, stores[0], "SMSNotifyMark")
	}
	return err
}

//每月向用户发送
func NotifyNewUserOrder(order *model.GoodsOrder) (err error) {
	var (
		db       = dao.GetDB()
		storeTel string
		storeID  int
		mobile   string
	)
	if order.StoreID == 0 {
		storeID = order.JxStoreID
	} else {
		storeID = order.StoreID
	}
	if order.ConsigneeMobile2 == "" {
		mobile = order.ConsigneeMobile
	} else {
		mobile = order.ConsigneeMobile2
	}
	uoSMS, err := dao.GetUserOrderSMS(db, mobile, "")
	stores, _ := dao.GetStoreList(db, []int{storeID}, nil, nil, nil, "")
	if len(stores) > 0 {
		if stores[0].Tel1 == "" {
			storeTel = stores[0].Tel2
		} else {
			storeTel = stores[0].Tel1
		}
	}
	if uoSMS == nil {
		uoSMSc := &model.UserOrderSms{
			Mobile:       mobile,
			Name:         order.ConsigneeName,
			VendorUserID: order.VendorUserID,
			TotalCount:   0,
			SMSMark:      model.NO,
		}
		err = dao.CreateEntity(db, uoSMSc)
		if uoSMS.SMSMark != model.YES {
			err = SendSMSMsg([]string{uoSMS.Mobile}, globals.SMSSignName, globals.SMSNewUserOrderTemplate, map[string]interface{}{
				"tel": storeTel,
			}, nil)
			if err == nil {
				uoSMS.SMSMark = model.YES
				uoSMS.TotalCount++
				_, err = dao.UpdateEntity(db, uoSMS, "SMSMark", "TotalCount")
			}
		}
	} else {
		if uoSMS.SMSMark != model.YES {
			err = SendSMSMsg([]string{uoSMS.Mobile}, globals.SMSSignName, globals.SMSNewUserOrderTemplate, map[string]interface{}{
				"tel": storeTel,
			}, nil)
			if err == nil {
				uoSMS.SMSMark = model.YES
				uoSMS.TotalCount++
				_, err = dao.UpdateEntity(db, uoSMS, "SMSMark", "TotalCount")
			}
		}
	}
	return err
}

//给配送员发短信
func NotifyNewCourierOrder(bill *model.Waybill) (err error) {
	var (
		db       = dao.GetDB()
		storeTel string
		storeID  int
	)
	order := &model.GoodsOrder{}
	order.VendorOrderID = bill.VendorOrderID
	err = dao.GetEntity(db, order, "VendorOrderID")
	if order.StoreID == 0 {
		storeID = order.JxStoreID
	} else {
		storeID = order.StoreID
	}
	stores, _ := dao.GetStoreList(db, []int{storeID}, nil, nil, nil, "")
	if len(stores) > 0 {
		if stores[0].Tel1 == "" {
			storeTel = stores[0].Tel2
		} else {
			storeTel = stores[0].Tel1
		}
	}
	err = SendSMSMsg([]string{bill.CourierMobile}, globals.SMSSignName, globals.SMSNewOrderTemplate, map[string]interface{}{
		"tel": storeTel,
	}, nil)
	return err
}