企业风险

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

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"io/ioutil"
 	"jy/src/jfw/modules/subscribepay/src/config"
+	"jy/src/jfw/modules/subscribepay/src/entity/bidCreditReport"
 	"jy/src/jfw/modules/subscribepay/src/pay"
 	"jy/src/jfw/modules/subscribepay/src/util"
 	"log"
@@ -1384,16 +1385,20 @@ func bidReportOrder(m map[string]interface{}, userId, productId string) (*OrderI
 	email := qu.ObjToString(m["email"])
 	phone := qu.ObjToString(m["order_phone"])
 	company := qu.ObjToString(m["company"])
+	certNo := qu.ObjToString(m["cert_no"])
 	if !EmailReg.MatchString(email) || company == "" {
 		return nil, "数据校验不通过"
 	}
+	if bidCreditReport.BidCreditReport.EntHasRisk(userId, certNo) {
+		return nil, "暂无报告可以下载"
+	}
 	//生成订单号
 	orderCode := pay.GetOrderCode(userId)
 	order_phone := qu.ObjToString(m["order_phone"])
 	now := time.Now()
 	report := map[string]interface{}{
 		"ent_name": company,
-		"cert_no":  qu.ObjToString(m["cert_no"]),
+		"cert_no":  certNo,
 		"buyer":    qu.ObjToString(m["buyer"]),
 		"email":    email,
 		"phone":    order_phone,

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

@@ -342,7 +342,7 @@ 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`, userId)
-		if orders != nil && len(*orders1) == 1 {
+		if orders1 != nil && len(*orders1) == 1 {
 			reportMail = qutil.ObjToString((*orders1)[0]["user_mail"])
 		}
 		if reportMail == "" {