@Service
public class MongoService {

    /**
     * MongoDb的操作模板.
     */
    @Autowired
    private MongoTemplate mongoTemplate;

    /**
     * 执行命令.
     * 
     * @return
     */
    public String executeCommand(String json) {

        CommandResult result = mongoTemplate.executeCommand(json);
        if (result.ok()) {
            return CommonUtil.jsonFormatter(result.toString());
        }
        return "执行命令失败：" + result.getErrorMessage();
    }
}

{
    "aggregate":"agentTicketLog",
    "pipeline":[
        {
            "$match":{
                "duration":{
                    "$lt":300
                }
            }
        },
        {
            "$group":{
                "_id":"$ipcc",
                "total":{
                    "$sum":1
                }
            }
        },
        {
            "$project":{
                "total":1,
                "_id":0,
                "ipcc":"$_id"
            }
        },
        {
            "$sort":{
                "total":-1
            }
        }
    ]
}