更新

app/svc/svc_comm_deal_commission.go

@@ -140,6 +140,9 @@ func CommSettleDone(eg *xorm.Engine, pvd string, oid int64, masterId string, map
 	if set != nil {
 		appName = set.Val
 	}
+	if mapData["pvd_oid"] != "" {
+		oid = utils.StrToInt64(mapData["pvd_oid"])
+	}
 	for _, item := range ol {
 		if mapData["reward_type"] == "2" && item.Level == 0 {
 			continue

consume/md/md.go

@@ -21,6 +21,7 @@ type ZhiosTaskReward struct {
 	RewardType  string `json:"reward_type"`
 	PlanType    string `json:"plan_type"`
 	Provider    string `json:"provider"`
+	PvdOid      string `json:"pvd_oid"`
 }
 type AcquisitionCfg struct {
 	Id                string `json:"id"`

consume/zhios_relate_reward_exchange.go

@@ -93,6 +93,7 @@ func handleZhiosRelateRewardExchange(msg []byte) error {
 		"title":        title,
 		"device_model": canalMsg.DeviceModel,
 		"reward_type":  canalMsg.RewardType,
+		"pvd_oid":      canalMsg.PvdOid,
 	}
 	svc.CommGetLvUser(eg, CommissionParam, utils.StrToInt64(canalMsg.Oid), mid, mapData)
 	return nil