|
|
@@ -35,6 +35,33 @@ func projectTask(data []byte, mapInfo map[string]interface{}) {
|
|
|
var n int
|
|
|
i := 0
|
|
|
for tmp := make(map[string]interface{}); query.Next(tmp); i = i + 1 {
|
|
|
+ pp := map[string]map[string]interface{}{}
|
|
|
+ if packages, ok := tmp["package"].(map[string]interface{}); ok {
|
|
|
+ for _, pks := range packages {
|
|
|
+ if pk, ok := pks.([]interface{}); ok {
|
|
|
+ for _, v := range pk {
|
|
|
+ if p, ok := v.(map[string]interface{}); ok {
|
|
|
+ winner := util.ObjToString(p["winner"])
|
|
|
+ bidamount := util.Float64All((p["bidamount"]))
|
|
|
+ if len(winner) > 4 && bidamount > 0 {
|
|
|
+ p := map[string]interface{}{
|
|
|
+ "winner": winner,
|
|
|
+ "bidamount": bidamount,
|
|
|
+ }
|
|
|
+ pp[winner] = p
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ pk1 := []map[string]interface{}{}
|
|
|
+ for _, v := range pp {
|
|
|
+ pk1 = append(pk1, v)
|
|
|
+ }
|
|
|
+ if len(pk1) > 0 {
|
|
|
+ tmp["package1"] = pk1
|
|
|
+ }
|
|
|
//不生索引字段
|
|
|
delete(tmp, "package")
|
|
|
delete(tmp, "winnerorder")
|
