更新

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 {

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               //唯品会-全部订单
 
 }
 

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",
 	},

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