|
...
|
...
|
@@ -27,12 +27,12 @@ func DataFromXiangMi(message *sarama.ConsumerMessage) error { |
|
|
|
// TODO 使用小程序id作为module
|
|
|
|
dataAction := msgData.Module + "/" + msgData.Action
|
|
|
|
switch dataAction {
|
|
|
|
//case "xiangmi.order/ship":
|
|
|
|
// err = syncBestshopOrder(msgData.Data)
|
|
|
|
// if err != nil {
|
|
|
|
// e := fmt.Errorf("[Consumer][SyncBestshopOrder] %s", err)
|
|
|
|
// return e
|
|
|
|
// }
|
|
|
|
case "xiangmi.order/ship":
|
|
|
|
err = syncBestshopOrder(msgData.Data)
|
|
|
|
if err != nil {
|
|
|
|
e := fmt.Errorf("[Consumer][SyncBestshopOrder] %s", err)
|
|
|
|
return e
|
|
|
|
}
|
|
|
|
// TODO 统一操作小程序订单
|
|
|
|
case "wxapplet.order/ship":
|
|
|
|
err = syncBestshopOrder(msgData.Data)
|
...
|
...
|
|
