102 lines
3.2 KiB
Go
102 lines
3.2 KiB
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 {
|
|
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
|
|
}
|