426 lines
16 KiB
Go
426 lines
16 KiB
Go
package weixinmsg
|
||
|
||
import (
|
||
"fmt"
|
||
"strings"
|
||
"time"
|
||
|
||
"git.rosy.net.cn/baseapi/utils"
|
||
"git.rosy.net.cn/jx-callback/business/jxutils"
|
||
"git.rosy.net.cn/jx-callback/business/model"
|
||
"git.rosy.net.cn/jx-callback/business/model/legacymodel"
|
||
"git.rosy.net.cn/jx-callback/globals"
|
||
"git.rosy.net.cn/jx-callback/globals/api"
|
||
"github.com/astaxie/beego/orm"
|
||
)
|
||
|
||
const (
|
||
// WX_TO_ORDER_PAGE_URL = "http://www.jxc4.com/jx/h5/#/?jxStoreId="
|
||
// WX_TO_SHOW_COMMENTS_DETAIL_URL = "http://www.jxc4.com/jx/h5/#/assess-list?jxStoreId=" //展示差评详情的页面
|
||
WX_TO_ORDER_PAGE_URL = "http://wx.jxc4.com/#/?jxStoreId="
|
||
WX_TO_STORE_SKU_PAGE_URL = "http://wx.jxc4.com/#/shop?jxStoreId="
|
||
WX_TO_SHOW_COMMENTS_DETAIL_URL = "http://wx.jxc4.com/#/assess-list?jxStoreId=" //展示差评详情的页面
|
||
WX_TO_SHOW_MSG = "http://wx.jxc4.com/#/message-detail?msgID=%d&msgStatusID=%d"
|
||
|
||
WX_MINI_TO_ORDER_PAGE_URL = "pages/order-manager/main"
|
||
WX_MINI_TO_STORE_SKU_PAGE_URL = "pages/goods-manager/main"
|
||
WX_MINI_TO_SHOW_COMMENTS_DETAIL_URL = "pages/store-comment/main"
|
||
WX_MINI_TO_SHOW_MSG = ""
|
||
|
||
//新订单模板消息文字颜色
|
||
WX_NEW_ORDER_TEMPLATE_COLOR = "#173177"
|
||
WX_HIGHLEVEL_TEMPLATE_COLOR = "#FF0000" //红色
|
||
WX_HIGHLEVEL_TEMPLATE_COLOR2 = "#333333" //黑色
|
||
WX_TEMPLATE_VENDERCOLOR_JDDJ = "#47B34F"
|
||
WX_TEMPLATE_VENDERCOLOR_MT = "#F4A800"
|
||
WX_TEMPLATE_VENDERCOLOR_ELM = "#0191EA" //蓝色
|
||
WX_TEMPLATE_VENDERCOLOR_BAD_COMMENTS = "#4F4DA0"
|
||
|
||
WX_NEWORDER_TEMPLATE_ID = "_DtNGwmOeR6TkkTVUblxLIlkV2MAPOX57TkvfdqG6nY" //微信新订单推送
|
||
WX_MTPS_DELIVERY_GRABDONE_TEMPLATE_ID = "h4dkON6AgnHz1XmaksEUB_8Bcir4V8MSexUhC149pPE" //微信美团配送员接单推送
|
||
WX_MTPS_DELIVERY_DONE_TEMPLATE_ID = "YXdCrQAHZlcZX1htYUiarrLmtkmKAjp7rynjwObgODo" //微信美团配送员配送完成推送
|
||
WX_MTPS_UNABLE_DELIVER_TEMPLATE_ID = "ZFph5Hp7oLlrzVRXbsKIC_StmaBeB9Dlp4tlHeAmUQ8" //微信美团配送配送能力不足推送
|
||
WX_MTPS_DELIVERY_EXCEPTION_TEMPLATE_ID = "RkfOFHgR1N75L4-a6Gv0DljpCsVfOHhLm_vyXh8MR-w" //微信美团配送异常推送
|
||
WX_BAD_COMMENT_PUSH_TEMPLATE_ID = "zMZH5Ek0k1OHlWnsDb98UaHEOlkJZYok2QOJUfwfJWs" //微信差评消息推送
|
||
|
||
WX_DADA_DELIVERY_GRABDONE_TEMPLATE_ID = "h4dkON6AgnHz1XmaksEUB_8Bcir4V8MSexUhC149pPE" //微信达达众包配送员接单推送
|
||
WX_DADA_DELIVERY_DONE_TEMPLATE_ID = "YXdCrQAHZlcZX1htYUiarrLmtkmKAjp7rynjwObgODo" //微信达达众包配送员配送完成推送
|
||
|
||
WX_SALE_BILL_TEMPLATE_ID = "eTUuFZMWH7IsVBfcxNMpmaHYaxRkUaD6zG8wSGJDcic"
|
||
)
|
||
|
||
var (
|
||
venderColors = map[int]string{
|
||
model.VendorIDJD: WX_TEMPLATE_VENDERCOLOR_JDDJ,
|
||
model.VendorIDMTWM: WX_TEMPLATE_VENDERCOLOR_MT,
|
||
model.VendorIDELM: WX_TEMPLATE_VENDERCOLOR_ELM,
|
||
model.VendorIDEBAI: WX_TEMPLATE_VENDERCOLOR_ELM,
|
||
}
|
||
testMiniProgramStoreMap = map[int]int{
|
||
// 101089: 1,
|
||
// 100888: 1,
|
||
// 100204: 1,
|
||
// 100205: 1,
|
||
// 100147: 1,
|
||
}
|
||
debugOpenIDMap = map[string]int{
|
||
"oYN_usk0AeGc_C6VEZfmFQP5VHMQ": 1, // 周小扬
|
||
"oYN_ust9hXKEvEv0X6Mq6nlAWs_E": 1, // me
|
||
"oYN_usvnObzrPweIgHTad9-uMf78": 1, // 老赵
|
||
}
|
||
)
|
||
|
||
func GetWeixinOpenIDsFromStoreID(storeID int) (retVal []string) {
|
||
db := orm.NewOrm()
|
||
var lists []orm.ParamsList
|
||
num, err := db.Raw(`
|
||
SELECT openid
|
||
FROM weixins t1
|
||
JOIN
|
||
(SELECT id
|
||
FROM weixins
|
||
WHERE jxstoreid = ? AND parentid = -1) t2 ON t2.id = t1.parentid
|
||
WHERE openid IS NOT NULL
|
||
UNION
|
||
SELECT openid
|
||
FROM weixins
|
||
WHERE jxstoreid = ? AND parentid = -1 AND openid IS NOT NULL
|
||
`, storeID, storeID).ValuesList(&lists)
|
||
if err != nil || num == 0 {
|
||
globals.SugarLogger.Infof("GetWeixinOpenIDsFromStoreID can not find openid for store:%d, num:%d, error:%v", storeID, num, err)
|
||
return retVal
|
||
}
|
||
for _, v := range lists {
|
||
retVal = append(retVal, v[0].(string))
|
||
}
|
||
if !globals.ReallyCallPlatformAPI {
|
||
// todo，调试，只发给我
|
||
globals.SugarLogger.Debugf("GetWeixinOpenIDsFromStoreID store:%d, openids:%v", storeID, retVal)
|
||
if storeID == 100146 {
|
||
retVal = []string{"oYN_ust9hXKEvEv0X6Mq6nlAWs_E"}
|
||
} else {
|
||
retVal = nil
|
||
}
|
||
}
|
||
return retVal
|
||
}
|
||
|
||
func SendMsgToStore(storeID int, templateID, downloadURL, miniPageURL string, data interface{}) (err error) {
|
||
globals.SugarLogger.Debugf("SendMsgToStore storeID:%d, templateID:%s, downloadURL:%s, miniPageURL:%s", storeID, templateID, downloadURL, miniPageURL)
|
||
if globals.ReallySendWeixinMsg {
|
||
if storeID == 0 { // 测试，只发给我
|
||
// SmartMessageTemplateSend("oYN_ust9hXKEvEv0X6Mq6nlAWs_E", templateID, downloadURL, miniPageURL, data)
|
||
} else {
|
||
openIDs := GetWeixinOpenIDsFromStoreID(storeID)
|
||
successCount := 0
|
||
for _, openID := range openIDs {
|
||
if testMiniProgramStoreMap[storeID] == 0 && debugOpenIDMap[openID] == 0 {
|
||
miniPageURL = ""
|
||
}
|
||
globals.SugarLogger.Debugf("SendMsgToStore storeID:%d, openID:%s, templateID:%s, downloadURL:%s, miniPageURL:%s", storeID, openID, templateID, downloadURL, miniPageURL)
|
||
if err2 := SmartMessageTemplateSend(openID, templateID, downloadURL, miniPageURL, data); err2 == nil {
|
||
successCount++
|
||
} else {
|
||
err = err2
|
||
}
|
||
}
|
||
if successCount > 0 {
|
||
err = nil // 只要成功一个都当成成功
|
||
}
|
||
if err != nil {
|
||
globals.SugarLogger.Debugf("SendMsgToStore all failed storeID:%d, templateID:%s, error:%v", storeID, templateID, err)
|
||
}
|
||
}
|
||
}
|
||
return err
|
||
}
|
||
|
||
func SmartMessageTemplateSend(userOpenID, templateID, downloadURL, miniPageURL string, data interface{}) (err error) {
|
||
var miniProgram map[string]interface{}
|
||
if miniPageURL != "" {
|
||
miniProgram = map[string]interface{}{
|
||
"appid": api.WeixinMiniAPI.GetAppID(),
|
||
"pagepath": miniPageURL,
|
||
}
|
||
}
|
||
globals.SugarLogger.Debugf("SmartMessageTemplateSend openID:%s, templateID:%s, downloadURL:%s, miniProgram:%s", userOpenID, templateID, downloadURL, utils.Format4Output(miniProgram, true))
|
||
if err = api.WeixinAPI.MessageTemplateSend(userOpenID, templateID, downloadURL, miniProgram, data); err != nil {
|
||
globals.SugarLogger.Debugf("SmartMessageTemplateSend openID:%s, templateID:%s, downloadURL:%s, miniProgram:%s, failed with error:%v", userOpenID, templateID, downloadURL, utils.Format4Output(miniProgram, true), err)
|
||
}
|
||
return err
|
||
}
|
||
|
||
func NotifyNewOrder(order *model.GoodsOrder) (err error) {
|
||
globals.SugarLogger.Debugf("NotifyNewOrder orderID:%s", order.VendorOrderID)
|
||
if order.VendorID == model.VendorIDELM {
|
||
return nil
|
||
}
|
||
|
||
if !model.IsOrderSolid(order) {
|
||
globals.SugarLogger.Infof("NotifyNewOrder orderID:%s is not solid", order.VendorOrderID)
|
||
return nil
|
||
}
|
||
sb := new(strings.Builder)
|
||
sb.WriteString("老板，")
|
||
sb.WriteString(order.ConsigneeName)
|
||
sb.WriteString("购买了商品")
|
||
sb.WriteString(order.Skus[0].SkuName)
|
||
sb.WriteString("共")
|
||
sb.WriteString(utils.Int2Str(order.Skus[0].Count))
|
||
sb.WriteString("份（")
|
||
sb.WriteString(jxutils.IntPrice2StandardString(order.Skus[0].SalePrice))
|
||
sb.WriteString("元/份）等，共支付了")
|
||
sb.WriteString(jxutils.IntPrice2StandardString(order.ActualPayPrice))
|
||
sb.WriteString("元")
|
||
data := map[string]interface{}{
|
||
"first": map[string]interface{}{
|
||
"value": sb.String(),
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
"Day": map[string]interface{}{
|
||
"value": FormatDeliveryTime(order),
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
"orderId": map[string]interface{}{
|
||
"value": order.VendorOrderID,
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
"orderType": map[string]interface{}{
|
||
"value": fmt.Sprintf("%s 第%d号订单", model.VendorChineseNames[order.VendorID], order.OrderSeq),
|
||
"color": venderColors[order.VendorID],
|
||
},
|
||
"customerName": map[string]interface{}{
|
||
"value": order.ConsigneeName,
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
"customerPhone": map[string]interface{}{
|
||
"value": order.ConsigneeMobile,
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
}
|
||
storeID := jxutils.GetJxStoreIDFromOrder(order)
|
||
return SendMsgToStore(storeID, WX_NEWORDER_TEMPLATE_ID, fmt.Sprintf("%s%d", WX_TO_ORDER_PAGE_URL, storeID), WX_MINI_TO_ORDER_PAGE_URL, data)
|
||
}
|
||
|
||
func NotifyWaybillStatus(bill *model.Waybill, order *model.GoodsOrder, isBillAlreadyCandidate bool) error {
|
||
globals.SugarLogger.Debugf("NotifyWaybillStatus orderID:%s bill:%v", order.VendorOrderID, bill)
|
||
if order.VendorID == model.VendorIDELM {
|
||
return nil
|
||
}
|
||
|
||
if !model.IsOrderSolid(order) {
|
||
globals.SugarLogger.Infof("NotifyWaybillStatus orderID:%s is not solid", order.VendorOrderID)
|
||
return nil
|
||
}
|
||
var title string
|
||
templateID := ""
|
||
remark := ""
|
||
titleColor := ""
|
||
switch bill.Status {
|
||
case model.WaybillStatusAccepted:
|
||
if bill.WaybillVendorID == model.VendorIDMTPS {
|
||
templateID = WX_MTPS_DELIVERY_GRABDONE_TEMPLATE_ID
|
||
} else if bill.WaybillVendorID == model.VendorIDDada {
|
||
templateID = WX_DADA_DELIVERY_GRABDONE_TEMPLATE_ID
|
||
}
|
||
remark = FormatDeliveryTime(order)
|
||
if isBillAlreadyCandidate {
|
||
titleColor = WX_HIGHLEVEL_TEMPLATE_COLOR
|
||
title = fmt.Sprintf("%s 第%d号订单由于之前安排的配送员长时间没有取货，我们已重新安排%s配送员%s负责配送。^_^", model.VendorChineseNames[bill.OrderVendorID], order.OrderSeq, model.VendorChineseNames[bill.WaybillVendorID], bill.CourierName)
|
||
} else {
|
||
titleColor = WX_HIGHLEVEL_TEMPLATE_COLOR2
|
||
title = fmt.Sprintf("%s 第%d号订单长时间无人配送，我们已安排%s配送员%s负责配送。^_^", model.VendorChineseNames[bill.OrderVendorID], order.OrderSeq, model.VendorChineseNames[bill.WaybillVendorID], bill.CourierName)
|
||
}
|
||
case model.WaybillStatusDelivered:
|
||
if bill.WaybillVendorID == model.VendorIDMTPS {
|
||
templateID = WX_MTPS_DELIVERY_DONE_TEMPLATE_ID
|
||
} else if bill.WaybillVendorID == model.VendorIDDada {
|
||
templateID = WX_DADA_DELIVERY_DONE_TEMPLATE_ID
|
||
}
|
||
titleColor = venderColors[bill.OrderVendorID]
|
||
title = fmt.Sprintf("%s 第%d号订单的配送完成", model.VendorChineseNames[bill.OrderVendorID], order.OrderSeq)
|
||
}
|
||
if templateID != "" {
|
||
data := map[string]interface{}{
|
||
"first": map[string]interface{}{
|
||
"value": title,
|
||
"color": titleColor,
|
||
},
|
||
"keyword1": map[string]interface{}{
|
||
"value": bill.VendorOrderID,
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
"keyword2": map[string]interface{}{
|
||
"value": fmt.Sprintf("%s（%s）", bill.CourierName, model.VendorChineseNames[bill.WaybillVendorID]),
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
"keyword3": map[string]interface{}{
|
||
"value": bill.CourierMobile,
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
"remark": map[string]interface{}{
|
||
"value": remark,
|
||
"color": WX_NEW_ORDER_TEMPLATE_COLOR,
|
||
},
|
||
}
|
||
return SendMsgToStore(jxutils.GetJxStoreIDFromOrder(order), templateID, "", "", data)
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func PushJDBadCommentToWeiXin(comment *legacymodel.JxBadComments) (err error) {
|
||
globals.SugarLogger.Debugf("PushJDBadCommentToWeiXin orderID:%s", comment.OrderId)
|
||
|
||
sb := new(strings.Builder)
|
||
sb.WriteString("你收到了京东到家客户(")
|
||
sb.WriteString(comment.Userphone)
|
||
sb.WriteString(")的一条")
|
||
sb.WriteString(utils.Int2Str(comment.Score))
|
||
sb.WriteString("星差评，请商家在1小时内及时联系客户处理!")
|
||
|
||
data := map[string]interface{}{
|
||
"first": map[string]interface{}{
|
||
"value": sb.String(),
|
||
"color": WX_HIGHLEVEL_TEMPLATE_COLOR,
|
||
},
|
||
"keyword1": map[string]interface{}{
|
||
"value": comment.Createtime,
|
||
"color": WX_TEMPLATE_VENDERCOLOR_BAD_COMMENTS,
|
||
},
|
||
"keyword2": map[string]interface{}{
|
||
"value": comment.OrderId,
|
||
"color": WX_TEMPLATE_VENDERCOLOR_BAD_COMMENTS,
|
||
},
|
||
"remark": map[string]interface{}{
|
||
"value": genJdCommentRemark(comment),
|
||
"color": WX_TEMPLATE_VENDERCOLOR_BAD_COMMENTS,
|
||
},
|
||
}
|
||
storeID := int(utils.Str2Int64(comment.Jxstoreid))
|
||
return SendMsgToStore(storeID, WX_BAD_COMMENT_PUSH_TEMPLATE_ID, fmt.Sprintf("%s%d", WX_TO_SHOW_COMMENTS_DETAIL_URL, storeID), WX_MINI_TO_SHOW_COMMENTS_DETAIL_URL, data)
|
||
}
|
||
|
||
func NotifySaleBill(storeID int, title, fileURL string) (err error) {
|
||
globals.SugarLogger.Debugf("NotifySaleBill storeID:%d, fileURL:%s", storeID, fileURL)
|
||
data := map[string]interface{}{
|
||
"first": map[string]interface{}{
|
||
"value": "新的账单上传成功！",
|
||
"color": "#00008B",
|
||
},
|
||
"keyword1": map[string]interface{}{
|
||
"value": title,
|
||
},
|
||
"keyword2": map[string]interface{}{
|
||
"value": "点击查看详情",
|
||
"color": "#00008B",
|
||
},
|
||
"keyword3": map[string]interface{}{
|
||
"value": "京西菜市",
|
||
},
|
||
"keyword4": map[string]interface{}{
|
||
"value": utils.GetCurTimeStr(),
|
||
},
|
||
"remark": map[string]interface{}{
|
||
"value": "手机买菜上京西，极速到家送惊喜",
|
||
},
|
||
}
|
||
return SendMsgToStore(storeID, WX_SALE_BILL_TEMPLATE_ID, fileURL, "", data)
|
||
}
|
||
|
||
func NotifyStoreOpRequestStatus(isAccepted bool, storeID, nameID int, spuName string, originalUnitPrice, unitPrice int, rejectReason string) (err error) {
|
||
globals.SugarLogger.Debugf("NotifyStoreOpRequestStatus isAccepted:%t, storeID:%d, nameID:%d, spuName:%s, originalUnitPrice:%d, unitPrice:%d, rejectReason:%s", isAccepted, storeID, nameID, spuName, originalUnitPrice, unitPrice, rejectReason)
|
||
templateID := ""
|
||
fileURL := fmt.Sprintf("%s%d", WX_TO_STORE_SKU_PAGE_URL, storeID)
|
||
data := make(map[string]interface{})
|
||
if isAccepted {
|
||
templateID = "gIG2olBZtQbjXmp6doNB_dESu60By5xuXYOGxksLv3Y"
|
||
data = map[string]interface{}{
|
||
"first": map[string]interface{}{
|
||
"value": fmt.Sprintf("%s%s元，修改为%s元，已经通过审核。^_^", spuName, jxutils.IntPrice2StandardString(int64(originalUnitPrice)), jxutils.IntPrice2StandardString(int64(unitPrice))),
|
||
"color": "#333333",
|
||
},
|
||
"keyword1": map[string]interface{}{
|
||
"value": "审核通过",
|
||
"color": "#2E408E",
|
||
},
|
||
"keyword2": map[string]interface{}{
|
||
"value": utils.Time2Str(time.Now()),
|
||
"color": "#2E408E",
|
||
},
|
||
"remark": map[string]interface{}{
|
||
"value": "点击查看详情",
|
||
},
|
||
}
|
||
} else {
|
||
templateID = "tn2QXWi4HtSIwaztmtN6Bb2uzNL-jBxWltCZTDNJuYE"
|
||
data = map[string]interface{}{
|
||
"first": map[string]interface{}{
|
||
"value": fmt.Sprintf("您好！抱歉的通知您。%s%s元，修改为%s元，未通过审核。原因：%s", spuName, jxutils.IntPrice2StandardString(int64(originalUnitPrice)), jxutils.IntPrice2StandardString(int64(unitPrice)), rejectReason),
|
||
"color": "#E80000",
|
||
},
|
||
"keyword1": map[string]interface{}{
|
||
"value": "1",
|
||
"color": "#2E408E",
|
||
},
|
||
"keyword2": map[string]interface{}{
|
||
"value": utils.Time2Str(time.Now()),
|
||
"color": "#2E408E",
|
||
},
|
||
"remark": map[string]interface{}{
|
||
"value": "请您及时到商品管理修改价格，修改后请重新提交。",
|
||
},
|
||
}
|
||
}
|
||
return SendMsgToStore(storeID, templateID, fileURL, WX_MINI_TO_STORE_SKU_PAGE_URL, data)
|
||
}
|
||
|
||
func NotifyStoreMessage(storeID, msgID, msgStatusID int, title, content string) (err error) {
|
||
globals.SugarLogger.Debugf("NotifyStoreMessage storeID:%d, msgID:%d, title:%s, content:%s", storeID, msgID, title, content)
|
||
templateID := "7ngcTFYiUFw66BMzIYntM1tpy-xZkJwlcCT5pVtXwtw"
|
||
fileURL := fmt.Sprintf(WX_TO_SHOW_MSG, msgID, msgStatusID)
|
||
data := map[string]interface{}{
|
||
"first": map[string]interface{}{
|
||
"value": content,
|
||
"color": "#333333",
|
||
},
|
||
"keyword1": map[string]interface{}{
|
||
"value": title,
|
||
"color": "#2E408E",
|
||
},
|
||
"keyword2": map[string]interface{}{
|
||
"value": "请忽略",
|
||
"color": "#2E408E",
|
||
},
|
||
"keyword3": map[string]interface{}{
|
||
"value": "请忽略",
|
||
"color": "#2E408E",
|
||
},
|
||
"remark": map[string]interface{}{
|
||
"value": "",
|
||
},
|
||
}
|
||
return SendMsgToStore(storeID, templateID, fileURL, WX_MINI_TO_SHOW_MSG, data)
|
||
}
|
||
|
||
func FormatDeliveryTime(order *model.GoodsOrder) string {
|
||
var tmpTime time.Time
|
||
if order.ExpectedDeliveredTime == utils.DefaultTimeValue {
|
||
tmpTime = order.OrderCreatedAt.Add(1 * time.Hour)
|
||
} else {
|
||
tmpTime = order.ExpectedDeliveredTime
|
||
}
|
||
left := tmpTime.Sub(time.Now()) / time.Minute
|
||
leftHours := left / 60
|
||
leftMinutes := left % 60
|
||
return fmt.Sprintf("请于%s前送达（剩余时间%d小时%d分钟）", utils.Time2Str(tmpTime), leftHours, leftMinutes)
|
||
}
|
||
|
||
func genJdCommentRemark(comment *legacymodel.JxBadComments) string {
|
||
sb := new(strings.Builder)
|
||
sb.WriteString("差评标签：")
|
||
sb.WriteString(comment.Vendertags)
|
||
sb.WriteString(" 差评内容：")
|
||
sb.WriteString(comment.Scorecontent)
|
||
return sb.String()
|
||
}
|