|
@@ -3,7 +3,9 @@ package bidCreditReport
|
|
|
import (
|
|
|
"app.yhyue.com/moapp/jybase/encrypt"
|
|
|
"app.yhyue.com/moapp/jybase/es"
|
|
|
+ . "app.yhyue.com/moapp/jybase/mongodb"
|
|
|
"bp.jydev.jianyu360.cn/BaseService/pushpkg/p"
|
|
|
+ . "bp.jydev.jianyu360.cn/BaseService/userCenter/identity"
|
|
|
"encoding/csv"
|
|
|
"errors"
|
|
|
"fmt"
|
|
@@ -137,6 +139,7 @@ func (b *bidCreditReport) ReportQuery(orderNo string) bool {
|
|
|
ctx := gctx.New()
|
|
|
orderCode := gconv.String((*datas)[0]["order_code"])
|
|
|
entName := gconv.String((*datas)[0]["ent_name"])
|
|
|
+ buyer := gconv.String((*datas)[0]["buyer"])
|
|
|
fileName := "/" + b.folderName(bcrId, orderCode, entName) + "/" + entName + ".pdf"
|
|
|
downloadUrl := g.Config().MustGet(ctx, "bidCreditReport.visitUrl").String() + fileName
|
|
|
r1 := util.Mysql.UpdateOrDeleteBySql(`update jianyu.bid_credit_report set download_url=?,report_url=?,status=2,complete_time=? where id=?`, downloadUrl, reportUrl, gtime.Datetime(), bcrId)
|
|
@@ -155,6 +158,8 @@ func (b *bidCreditReport) ReportQuery(orderNo string) bool {
|
|
|
"l_createTime": time.Now().Unix(),
|
|
|
"s_pdfUrl": downloadUrl,
|
|
|
"bcr_id": bcrId,
|
|
|
+ "ent": entName,
|
|
|
+ "buyer": buyer,
|
|
|
},
|
|
|
}, true, false)
|
|
|
downloadUrl = config.Config.WebDomain + downloadUrl
|
|
@@ -182,7 +187,7 @@ func (b *bidCreditReport) ReportQuery(orderNo string) bool {
|
|
|
}
|
|
|
for _, v := range userMails {
|
|
|
go func(vv string) {
|
|
|
- if b.sendMail(userId, v, entName, gconv.String((*datas)[0]["buyer"]), downloadUrl, orderCode) && userMail == vv {
|
|
|
+ if b.sendMail(userId, v, entName, buyer, downloadUrl, orderCode) && userMail == vv {
|
|
|
util.Mysql.UpdateOrDeleteBySql(`update jianyu.bid_credit_report set status=2,send_mail=1,send_mail_time=? where id=?`, gtime.Datetime(), bcrId)
|
|
|
}
|
|
|
}(v)
|
|
@@ -217,6 +222,16 @@ func (b *bidCreditReport) Create(id int64) error {
|
|
|
certNo := gconv.String((*datas)[0]["cert_no"])
|
|
|
orderNo := gconv.String((*datas)[0]["order_no"])
|
|
|
outBizNo := guid.S()
|
|
|
+ mgoUserId := userId
|
|
|
+ if !IsObjectIdHex(mgoUserId) {
|
|
|
+ identity := IdentityByPositionId(util.BaseMysql, gconv.Int64(userId))
|
|
|
+ if identity != nil && identity.UserId > 0 {
|
|
|
+ user, ok := util.MQFW.FindOneByField("user", map[string]interface{}{"base_user_id": identity.UserId}, `{"_id":1}`)
|
|
|
+ if ok && user != nil && len(*user) > 0 {
|
|
|
+ mgoUserId = BsonIdToSId((*user)["_id"])
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
if !g.Config().MustGet(ctx, "bidCreditReport.productEnv").Bool() || garray.NewStrArrayFrom(g.Config().MustGet(ctx, "bidCreditReport.testIds").Strings()).Contains(userId) {
|
|
|
outBizNo = "test_" + outBizNo
|
|
|
}
|