|
@@ -358,7 +358,7 @@ func (b *bidCreditReport) sendMail(userId, userMail, entName, buyer, downloadUrl
|
|
|
|
|
|
// 芝麻企业信用招投标报告创建请求
|
|
|
func (b *bidCreditReport) Create(id int64) error {
|
|
|
- datas := util.Mysql.SelectBySql(`select mold,bidding_id,project_name,user_id,order_code,ent_name,cert_no,buyer,prove_purchase,prove_purchase_status,prove_executed,prove_executed_status,prove_dishonesty,prove_dishonesty_status,prove_produce,prove_produce_status,creditchina,performance,out_biz_no,order_no from jianyu.bid_credit_report where id=?`, id)
|
|
|
+ datas := util.Mysql.SelectBySql(`select price,mold,bidding_id,project_name,user_id,order_code,ent_name,cert_no,buyer,prove_purchase,prove_purchase_status,prove_executed,prove_executed_status,prove_dishonesty,prove_dishonesty_status,prove_produce,prove_produce_status,creditchina,performance,out_biz_no,order_no from jianyu.bid_credit_report where id=?`, id)
|
|
|
if datas == nil || len(*datas) == 0 {
|
|
|
return errors.New("没有找到相关记录")
|
|
|
}
|
|
@@ -372,6 +372,7 @@ func (b *bidCreditReport) Create(id int64) error {
|
|
|
biddingId := gconv.String((*datas)[0]["bidding_id"])
|
|
|
projectName := gconv.String((*datas)[0]["project_name"])
|
|
|
performance := gconv.String((*datas)[0]["performance"])
|
|
|
+ price := gconv.Int((*datas)[0]["price"])
|
|
|
var err error
|
|
|
outBizNo := guid.S()
|
|
|
mgoUserId := userId
|
|
@@ -398,9 +399,10 @@ func (b *bidCreditReport) Create(id int64) error {
|
|
|
}
|
|
|
if orderNo == "" {
|
|
|
biz := map[string]interface{}{
|
|
|
- "scene_code": "ZTB_REPORT_JY",
|
|
|
- "out_biz_no": outBizNo,
|
|
|
- "order_type": consts.ZMReportOrderType[mold], //报告类型
|
|
|
+ "scene_code": "ZTB_REPORT_JY",
|
|
|
+ "out_biz_no": outBizNo,
|
|
|
+ "order_type": consts.ZMReportOrderType[mold], //报告类型
|
|
|
+ "report_amount": b.YuanToWan(float64(price * 100)),
|
|
|
}
|
|
|
if buyer != "" {
|
|
|
biz["bidding_ep_name"] = buyer
|
|
@@ -834,9 +836,9 @@ func (b *bidCreditReport) GetProjectDataInfo(di *DI) (dataInfo g.List, err error
|
|
|
})
|
|
|
}
|
|
|
//同类项目
|
|
|
- if basicClass == "" { // todo
|
|
|
- basicClass = "服务"
|
|
|
- }
|
|
|
+ //if basicClass == "" { // todo
|
|
|
+ // basicClass = "服务"
|
|
|
+ //}
|
|
|
if basicClass != "" {
|
|
|
//项目潜在供应商
|
|
|
potentialSupplier := b.GetPotentialSupplier(di.UserId, buyer, basicClass)
|
|
@@ -1402,7 +1404,7 @@ func (b *bidCreditReport) GetNewSupplierList(userId, name string) (newSupplierLi
|
|
|
// 近期拟购 recent_prepare_purchase 近三个月 采购意向
|
|
|
func (b *bidCreditReport) GetRecentPreparePurchase(userId, name string) (recentPreparePurchase []g.Map) {
|
|
|
now := time.Now()
|
|
|
- fromTime := now.AddDate(-2, -3, 0).Unix() //todo -2 改成 0
|
|
|
+ fromTime := now.AddDate(0, -3, 0).Unix() //todo -2 改成 0
|
|
|
searchSql := fmt.Sprintf(`{"query":{"bool":{"must":[{"term":{"toptype":"采购意向"}},{"term":{"buyer":"%s"}},{"range":{"publishtime":{"gt":%d}}}]}},"size":0,"aggs":{"group_by_basicClass":{"terms":{"field":"basicClass","size":10},"aggs":{"project_data":{"top_hits":{"size":10,"_source":["projectname","budget","publishtime"],"sort":[{"publishtime":{"order":"desc"}}]}}}}}}`, name, fromTime)
|
|
|
aggs, _, _ := es.GetAggs(consts.ESBiddingIndex, consts.ESBiddingType, searchSql)
|
|
|
if aggs != nil {
|