|
@@ -589,6 +589,7 @@ type PCInfo struct {
|
|
|
|
|
|
//采购单位
|
|
//采购单位
|
|
func analysisData(res []*AggregationsBucket, mycs map[string]interface{}, omyr map[string]interface{}, pcor string) []*PTComs {
|
|
func analysisData(res []*AggregationsBucket, mycs map[string]interface{}, omyr map[string]interface{}, pcor string) []*PTComs {
|
|
|
|
+ defer qutil.Catch()
|
|
var (
|
|
var (
|
|
ADRes_r []*PTComs
|
|
ADRes_r []*PTComs
|
|
entersFifty []string
|
|
entersFifty []string
|
|
@@ -626,10 +627,10 @@ func analysisData(res []*AggregationsBucket, mycs map[string]interface{}, omyr m
|
|
wg.Add(1)
|
|
wg.Add(1)
|
|
wc <- true
|
|
wc <- true
|
|
go func(entersFifty []string) {
|
|
go func(entersFifty []string) {
|
|
|
|
+ defer qutil.Catch()
|
|
defer func() {
|
|
defer func() {
|
|
wg.Done()
|
|
wg.Done()
|
|
<-wc
|
|
<-wc
|
|
- qutil.Catch()
|
|
|
|
}()
|
|
}()
|
|
entInfo := entity.GetEntInfo(entersFifty, pcor)
|
|
entInfo := entity.GetEntInfo(entersFifty, pcor)
|
|
lock.Lock()
|
|
lock.Lock()
|
|
@@ -669,6 +670,7 @@ func analysisData(res []*AggregationsBucket, mycs map[string]interface{}, omyr m
|
|
|
|
|
|
//采购单位
|
|
//采购单位
|
|
func analysisDataByBuyer(res []map[string]interface{}, mycs map[string]interface{}) []*PTComs {
|
|
func analysisDataByBuyer(res []map[string]interface{}, mycs map[string]interface{}) []*PTComs {
|
|
|
|
+ defer qutil.Catch()
|
|
var ADRes = []*PTComs{}
|
|
var ADRes = []*PTComs{}
|
|
var ADRes_r = []*PTComs{}
|
|
var ADRes_r = []*PTComs{}
|
|
var enters = []string{}
|
|
var enters = []string{}
|
|
@@ -695,10 +697,10 @@ func analysisDataByBuyer(res []map[string]interface{}, mycs map[string]interface
|
|
wg.Add(1)
|
|
wg.Add(1)
|
|
wc <- true
|
|
wc <- true
|
|
go func(entersFifty []string) {
|
|
go func(entersFifty []string) {
|
|
|
|
+ defer qutil.Catch()
|
|
defer func() {
|
|
defer func() {
|
|
wg.Done()
|
|
wg.Done()
|
|
<-wc
|
|
<-wc
|
|
- qutil.Catch()
|
|
|
|
}()
|
|
}()
|
|
entInfo := entity.GetEntInfoByQYXY(entersFifty, "C")
|
|
entInfo := entity.GetEntInfoByQYXY(entersFifty, "C")
|
|
wl.Lock()
|
|
wl.Lock()
|
|
@@ -783,6 +785,7 @@ func analysisDataByBuyer(res []map[string]interface{}, mycs map[string]interface
|
|
|
|
|
|
//中标单位
|
|
//中标单位
|
|
func analysisDataByWinner(res []map[string]interface{}, mycs map[string]interface{}, omyr map[string]interface{}, pcor string) []*PTComs {
|
|
func analysisDataByWinner(res []map[string]interface{}, mycs map[string]interface{}, omyr map[string]interface{}, pcor string) []*PTComs {
|
|
|
|
+ defer qutil.Catch()
|
|
var ADRes = []*PTComs{}
|
|
var ADRes = []*PTComs{}
|
|
var ADRes_r = []*PTComs{}
|
|
var ADRes_r = []*PTComs{}
|
|
var enters = []string{}
|
|
var enters = []string{}
|
|
@@ -812,10 +815,10 @@ func analysisDataByWinner(res []map[string]interface{}, mycs map[string]interfac
|
|
wg.Add(1)
|
|
wg.Add(1)
|
|
wc <- true
|
|
wc <- true
|
|
go func(entersFifty []string, pcor string) {
|
|
go func(entersFifty []string, pcor string) {
|
|
|
|
+ defer qutil.Catch()
|
|
defer func() {
|
|
defer func() {
|
|
wg.Done()
|
|
wg.Done()
|
|
<-wc
|
|
<-wc
|
|
- qutil.Catch()
|
|
|
|
}()
|
|
}()
|
|
entInfo := entity.GetEntInfoByQYXY(entersFifty, pcor)
|
|
entInfo := entity.GetEntInfoByQYXY(entersFifty, pcor)
|
|
wl.Lock()
|
|
wl.Lock()
|
|
@@ -840,10 +843,10 @@ func analysisDataByWinner(res []map[string]interface{}, mycs map[string]interfac
|
|
wg.Add(1)
|
|
wg.Add(1)
|
|
wc <- true
|
|
wc <- true
|
|
go func(entersFifty []string, pcor string) {
|
|
go func(entersFifty []string, pcor string) {
|
|
|
|
+ defer qutil.Catch()
|
|
defer func() {
|
|
defer func() {
|
|
wg.Done()
|
|
wg.Done()
|
|
<-wc
|
|
<-wc
|
|
- qutil.Catch()
|
|
|
|
}()
|
|
}()
|
|
entInfo := entity.GetEntInfoByQYXY(entersFifty, pcor)
|
|
entInfo := entity.GetEntInfoByQYXY(entersFifty, pcor)
|
|
wl.Lock()
|
|
wl.Lock()
|