| | |
| | | private String getTeamNumReduce() {
|
| | | StringBuilder builder = new StringBuilder();
|
| | | builder.append("function(doc, aggr){ ");
|
| | | builder.append(" aggr.directOrderNum += doc.firstNum;");
|
| | | builder.append(" aggr.inDirectOrderNum += doc.secondNum;");
|
| | | builder.append(" aggr.beyondOrderNum += doc.beyondNum;");
|
| | | builder.append(" if(doc.firstNum > 0){ aggr.firstTotal += doc.firstNum;}");
|
| | | builder.append(" aggr.secondTotal += doc.secondNum;");
|
| | | builder.append(" aggr.beyondTotal += doc.beyondNum;");
|
| | | builder.append(" }");
|
| | | return builder.toString();
|
| | | }
|
| | |
| | | }
|
| | |
|
| | | Map<String, Object> map = new HashMap<>();
|
| | | map.put("directOrderNum", 0);
|
| | | map.put("inDirectOrderNum", 0);
|
| | | map.put("beyondOrderNum", 0);
|
| | | map.put("firstTotal", 0);
|
| | | map.put("secondTotal", 0);
|
| | | map.put("beyondTotal", 0);
|
| | | BasicDBObject initial = new BasicDBObject(map);
|
| | |
|
| | | // 进行按天、周、月分组
|
| | |
| | | Date dtime = sdf.parse(date);
|
| | | TeamDailyRecord dailyCount = new TeamDailyRecord();
|
| | | dailyCount.setCountDay(dtime);
|
| | | dailyCount.setFirstNum(new BigDecimal(dbObject.get("directOrderNum").toString()).intValue());
|
| | | dailyCount.setSecondNum(new BigDecimal(dbObject.get("inDirectOrderNum").toString()).intValue());
|
| | | dailyCount.setBeyondNum(new BigDecimal(dbObject.get("beyondOrderNum").toString()).intValue());
|
| | | dailyCount.setFirstNum(new BigDecimal(dbObject.get("firstTotal").toString()).intValue());
|
| | | dailyCount.setSecondNum(new BigDecimal(dbObject.get("secondTotal").toString()).intValue());
|
| | | dailyCount.setBeyondNum(new BigDecimal(dbObject.get("beyondTotal").toString()).intValue());
|
| | | |
| | | results.add(dailyCount);
|
| | | } catch (Exception e) {
|
| | | e.printStackTrace();
|
| | |
| | | }
|
| | |
|
| | | Map<String, Object> map = new HashMap<>();
|
| | | map.put("directOrderNum", 0);
|
| | | map.put("inDirectOrderNum", 0);
|
| | | map.put("beyondOrderNum", 0);
|
| | | map.put("firstTotal", 0);
|
| | | map.put("secondTotal", 0);
|
| | | map.put("beyondTotal", 0);
|
| | | BasicDBObject initial = new BasicDBObject(map);
|
| | |
|
| | | // 进行按天、周、月分组
|
| | |
| | |
|
| | | TeamDailyRecord dailyCount = new TeamDailyRecord();
|
| | | dailyCount.setYearMonth(object.toString());
|
| | | dailyCount.setFirstNum(new BigDecimal(dbObject.get("directOrderNum").toString()).intValue());
|
| | | dailyCount.setSecondNum(new BigDecimal(dbObject.get("inDirectOrderNum").toString()).intValue());
|
| | | dailyCount.setBeyondNum(new BigDecimal(dbObject.get("beyondOrderNum").toString()).intValue());
|
| | | dailyCount.setFirstNum(new BigDecimal(dbObject.get("firstTotal").toString()).intValue());
|
| | | dailyCount.setSecondNum(new BigDecimal(dbObject.get("secondTotal").toString()).intValue());
|
| | | dailyCount.setBeyondNum(new BigDecimal(dbObject.get("beyondTotal").toString()).intValue());
|
| | |
|
| | | results.add(dailyCount);
|
| | | }
|
| | |
| | | }
|
| | |
|
| | | Map<String, Object> map = new HashMap<>();
|
| | | map.put("directOrderNum", 0);
|
| | | map.put("inDirectOrderNum", 0);
|
| | | map.put("beyondOrderNum", 0);
|
| | | map.put("firstTotal", 0);
|
| | | map.put("secondTotal", 0);
|
| | | map.put("beyondTotal", 0);
|
| | | BasicDBObject initial = new BasicDBObject(map);
|
| | |
|
| | | // 进行按天、周、月分组
|
| | |
| | | }
|
| | |
|
| | | TeamDailyRecord dailyCount = new TeamDailyRecord();
|
| | | dailyCount.setFirstNum(new BigDecimal(dbObject.get("directOrderNum").toString()).intValue());
|
| | | dailyCount.setSecondNum(new BigDecimal(dbObject.get("inDirectOrderNum").toString()).intValue());
|
| | | dailyCount.setBeyondNum(new BigDecimal(dbObject.get("beyondOrderNum").toString()).intValue());
|
| | | |
| | | dailyCount.setFirstNum(new BigDecimal(dbObject.get("firstTotal").toString()).intValue());
|
| | | dailyCount.setSecondNum(new BigDecimal(dbObject.get("secondTotal").toString()).intValue());
|
| | | dailyCount.setBeyondNum(new BigDecimal(dbObject.get("beyondTotal").toString()).intValue());
|
| | | results.add(dailyCount);
|
| | | }
|
| | | }
|