xg

src/jfw/modules/subscribepay/src/entity/bidReportPayBack.go

@@ -14,7 +14,7 @@ type bidCreditReportPay struct{}
 var BidCreditReportPay bidCreditReportPay
 
 func (b *bidCreditReportPay) PayCallBack(param *CallBackParam) bool {
-	orderdata := util.Mysql.FindOne("dataexport_order", param.GetPaySuccessOrderQuery(), "id,filter,order_code,order_status,user_id,product_type,discount_price,d_relation_id,user_mail", "")
+	orderdata := util.Mysql.FindOne("dataexport_order", param.GetPaySuccessOrderQuery(), "id,filter,order_code,order_status,user_id,product_type,discount_price,d_relation_id,user_mail,prepay_time", "")
 	if orderdata == nil {
 		return false
 	}

src/jfw/modules/subscribepay/src/service/userAccountInfo.go

@@ -7,6 +7,7 @@ import (
 	"database/sql"
 	"encoding/base64"
 	"fmt"
+	"go.mongodb.org/mongo-driver/bson"
 	"jy/src/jfw/modules/subscribepay/src/config"
 	"jy/src/jfw/modules/subscribepay/src/entity"
 	"jy/src/jfw/modules/subscribepay/src/util"
@@ -340,10 +341,9 @@ func (this *UserAccount) GetAccountInfo() {
 			}
 		}
 		reportMail := ""
-		orders1 := util.Mysql.SelectBySql(`SELECT user_mail from dataexport_order where user_id=? and order_status=1 and (product_type='投标企业信用报告' or product_type='企业中标分析报告下载包' or product_type='业主采购分析报告下载包' or
-                product_type = '市场分析定制报告下载包') order by create_time desc limit 1`, qutil.ObjToString(sessVal["userId"]))
-		if orders1 != nil && len(*orders1) == 1 {
-			reportMail = qutil.ObjToString((*orders1)[0]["user_mail"])
+		record, _ := util.MQFW.Find("analysis_report_screen", bson.M{"s_userId": qutil.ObjToString(sessVal["userId"])}, bson.M{"l_createTime": -1}, bson.M{"s_email": 1}, true, -1, -1)
+		if record != nil && len(*record) > 0 {
+			reportMail = qutil.ObjToString((*record)[0]["s_email"])
 		}
 		if reportMail == "" {
 			reportMail = qutil.ObjToString((*userMsg)["s_myemail"])