diff --git a/app/svc/svc_order_track_save_create_update.go b/app/svc/svc_order_track_save_create_update.go index 655d9e5..b909036 100644 --- a/app/svc/svc_order_track_save_create_update.go +++ b/app/svc/svc_order_track_save_create_update.go @@ -82,9 +82,7 @@ func OrderSaveCreateUpdate(eg *xorm.Engine, pvd string, ordData *[]md.OrderInfo, if pvd == md.PVD_TO_KFC { //判断下 pvd = md.PVD_KFC } - if pvd == md.PVD_WPHUNIONOWN { //判断下 - pvd = md.PVD_VIP - } + if pvd == md.PVD_TIKTOKOWNLIVE { //判断下 pvd = md.PVD_TIKTOKLIVE } @@ -101,7 +99,9 @@ func OrderSaveCreateUpdate(eg *xorm.Engine, pvd string, ordData *[]md.OrderInfo, } // 用推广位计算出查询对应人员的等级 userInfo := parsePids(eg, dbName, pvd, pids) - + if pvd == md.PVD_WPHUNIONOWN { //判断下 + pvd = md.PVD_VIP + } pidToUser := map[string]*md.UserPid{} for _, vv := range userInfo { if pvd == md.PVD_TB { diff --git a/consume/init.go b/consume/init.go index 024f0be..099b693 100644 --- a/consume/init.go +++ b/consume/init.go @@ -22,11 +22,11 @@ func initConsumes() { //jobs[consumeMd.ZhiosOrderTrackRefundForTbAllConsumeFunName] = ZhiosOrderTrackRefundForTbAllConsume //淘宝-全部退款 //jobs[consumeMd.ZhiosOrderTrackRefundForTbPartConsumeFunName] = ZhiosOrderTrackRefundForTbPartConsume //淘宝-部分退款 - //jobs[consumeMd.ZhiosOrderTrackCreateForJdConsumeFunName] = ZhiosOrderTrackCreateForJdConsume //京东-创建订单 - //jobs[consumeMd.ZhiosOrderTrackUpdateForJdConsumeFunName] = ZhiosOrderTrackUpdateForJdConsume //京东-更新订单 - //jobs[consumeMd.ZhiosOrderTrackCreateForPddConsumeFunName] = ZhiosOrderTrackCreateForPddConsume //拼多多-全部订单 - //jobs[consumeMd.ZhiosOrderTrackCreateForTikTokTeamConsumeFunName] = ZhiosOrderTrackCreateForTikTokTeamConsume //抖音团长服务费-全部订单 - jobs[consumeMd.ZhiosOrderTrackCreateForWphConsumeFunName] = ZhiosOrderTrackCreateForWphConsume //唯品会-全部订单 + jobs[consumeMd.ZhiosOrderTrackCreateForJdConsumeFunName] = ZhiosOrderTrackCreateForJdConsume //京东-创建订单 + jobs[consumeMd.ZhiosOrderTrackUpdateForJdConsumeFunName] = ZhiosOrderTrackUpdateForJdConsume //京东-更新订单 + jobs[consumeMd.ZhiosOrderTrackCreateForPddConsumeFunName] = ZhiosOrderTrackCreateForPddConsume //拼多多-全部订单 + jobs[consumeMd.ZhiosOrderTrackCreateForTikTokTeamConsumeFunName] = ZhiosOrderTrackCreateForTikTokTeamConsume //抖音团长服务费-全部订单 + jobs[consumeMd.ZhiosOrderTrackCreateForWphConsumeFunName] = ZhiosOrderTrackCreateForWphConsume //唯品会-全部订单 } diff --git a/consume/md/consume_key.go b/consume/md/consume_key.go index e74bddf..1ee8426 100644 --- a/consume/md/consume_key.go +++ b/consume/md/consume_key.go @@ -61,7 +61,7 @@ var RabbitMqQueueKeyList = []*MqQueue{ Name: "order_track_create_for_wph", Type: DirectQueueType, IsPersistent: false, - RoutKey: "pdd", + RoutKey: "vip", BindKey: "", ConsumeFunName: "ZhiosOrderTrackCreateForWphConsume", }, diff --git a/go.mod b/go.mod index 36ae674..3e4b030 100644 --- a/go.mod +++ b/go.mod @@ -46,6 +46,7 @@ require ( ) require ( + filippo.io/edwards25519 v1.1.0 // indirect github.com/KyleBanks/depth v1.2.1 // indirect github.com/PuerkitoBio/goquery v1.9.2 // indirect github.com/PuerkitoBio/purell v1.1.1 // indirect