|
|
@@ -687,7 +687,7 @@ func (a *AnalysisEntity) GetPartResult(flag int) (map[string]interface{}, error)
|
|
|
|
|
|
// 离线 获取采购单位和中部单位数据
|
|
|
func (a *AnalysisEntity) BWData() (buyers []string, winners []string) {
|
|
|
- sql := `"buyer_terms": {"terms": {"field": "buyer","size": 50000}},"winner_terms": {"terms": {"field": "winner","size": 50000}}`
|
|
|
+ sql := `"buyer_terms": {"terms": {"field": "buyer","size": 50000}},"winner_terms": {"terms": {"field": "s_winner","size": 50000}}`
|
|
|
finalSql := fmt.Sprintf(a.GetCommonQuerySqlWithAggs(), sql)
|
|
|
res := GetAggs(PtIndex, PtType, finalSql)
|
|
|
if res == nil || len(res) == 0 {
|
|
|
@@ -1325,6 +1325,7 @@ func (a *AnalysisEntity) AllData() (rMap map[string]interface{}, err error) {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+ thisRow.Total = int64(thisRow.ProjectCount.DocCount)
|
|
|
data := ProjectScale(thisRow)
|
|
|
area_data := AreaDistribute(thisRow)
|
|
|
customerData, customerOther := CustomerDistribute(thisRow)
|
