1

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
 	}