From 07db163a6cb8e9b83abf4e31b84f3e678f69efee Mon Sep 17 00:00:00 2001
From: huangjiajun <582604932@qq.com>
Date: Sun, 29 Sep 2024 16:59:41 +0800
Subject: [PATCH] 1

---
 consume/ad_original_data_application.go | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/consume/ad_original_data_application.go b/consume/ad_original_data_application.go
index 068fe83..3b183d1 100644
--- a/consume/ad_original_data_application.go
+++ b/consume/ad_original_data_application.go
@@ -2,6 +2,7 @@ package consume
 
 import (
 	"applet/app/cfg"
+	"applet/app/e"
 	"applet/app/lib/wechat"
 	md2 "applet/app/md"
 	"applet/app/utils"
@@ -11,6 +12,7 @@ import (
 	"code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git/rabbit"
 	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/rule/one_circles"
 	db "code.fnuoos.com/zhimeng/model.git/src"
+	"code.fnuoos.com/zhimeng/model.git/src/super/implement"
 	"code.fnuoos.com/zhimeng/model.git/src/super/model"
 	"encoding/json"
 	"errors"
@@ -78,7 +80,15 @@ func handleAdOriginalDataApplication(msgData []byte) error {
 	if err != nil {
 		return err
 	}
-	err, args := wxApiService.GetAdposDetail(msg.AppId, 1, 1, msg.Date, msg.Date, msg.AdId)
+	userWxAppletListDb := implement.NewUserWxAppletListDb(db.Db)
+	UserWxAppletList, err := userWxAppletListDb.GetUserWxAppletList(msg.Mid)
+	if err != nil {
+		return err
+	}
+	if UserWxAppletList == nil {
+		return e.NewErr(400, "未查询到对应记录")
+	}
+	err, args := wxApiService.GetAdposDetail(UserWxAppletList.Appid, 1, 1, msg.Date, msg.Date, msg.AdId)
 	if err != nil {
 		return err
 	}