reportRepositoryImpl.ftl 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  1. <#import "../function.ftl" as func>
  2. <#assign class=model.variables.class>
  3. <#assign classVar=model.variables.classVar>
  4. <#assign sys=model.variables.sys>
  5. <#assign module=model.variables.module>
  6. <#assign sub=model.sub>
  7. <#assign foreignKey=func.convertUnderLine(model.foreignKey)>
  8. <#assign isBaseModule=model.variables.isBaseModule>
  9. <#if isBaseModule = 'true'>
  10. package com.${vars.cAlias}.${sys}.repository.impl;
  11. <#else>
  12. package com.${vars.cAlias}.${sys}.${module}.repository.impl;
  13. </#if>
  14. import java.util.ArrayList;
  15. import java.util.List;
  16. import java.util.Map;
  17. import javax.annotation.Resource;
  18. import org.springframework.stereotype.Repository;
  19. import com.${vars.cAlias}.base.mongodb.repository.AbstractMongoRepository;
  20. import com.${vars.cAlias}.common.querybuilder.MGQueryBuilder;
  21. import com.mongodb.BasicDBObject;
  22. import com.${vars.cAlias}.base.web.util.PageReqUtil;
  23. <#if isBaseModule = 'true'>
  24. import com.${vars.cAlias}.${sys}.domain.${class}MGDomain;
  25. import com.${vars.cAlias}.${sys}.repository.${class}MGRepository;
  26. import com.${vars.cAlias}.${sys}.persistence.dao.${class}MGDao;
  27. import com.${vars.cAlias}.${sys}.persistence.entity.${class}Entity;
  28. <#else>
  29. import com.${vars.cAlias}.${sys}.${module}.domain.${class}MGDomain;
  30. import com.${vars.cAlias}.${sys}.${module}.repository.${class}MGRepository;
  31. import com.${vars.cAlias}.${sys}.${module}.persistence.dao.${class}MGDao;
  32. import com.${vars.cAlias}.${sys}.${module}.persistence.entity.${class}Entity;
  33. </#if>
  34. /**
  35. * 对象功能:${model.tabComment} Repository接口的实现类
  36. <#if vars.company?exists>
  37. * 开发公司:${vars.company}
  38. </#if>
  39. <#if vars.developer?exists>
  40. * 开发人员:${vars.developer}
  41. </#if>
  42. * 创建时间:${date?string("yyyy-MM-dd HH:mm:ss")}
  43. */
  44. @Repository
  45. public class ${class}MGRepositoryImpl extends AbstractMongoRepository< ${class}Entity,${class}MGDomain> implements ${class}MGRepository{
  46. private ${class}MGDao ${classVar}MGDao=null;
  47. public ${class}MGDomain newInstance() {
  48. return null;
  49. }
  50. public ${class}MGDomain newInstance(${class}Entity po) {
  51. return null;
  52. }
  53. @Override
  54. public List<${class}Entity> find(Map<String, Object> requestDatas){
  55. ${classVar}MGDao=${class}MGDao.newInstance();
  56. List<${class}Entity> list=null;
  57. MGQueryBuilder mongoQueryBuilder=new MGQueryBuilder(requestDatas);
  58. //查询条件
  59. BasicDBObject condObject=mongoQueryBuilder.buildGroupCondObj();
  60. if(mongoQueryBuilder.isNotQryGroupBy()){
  61. list=${classVar}MGDao.find(condObject);
  62. }else{
  63. //group by key
  64. BasicDBObject keyObject=mongoQueryBuilder.buildGroupKeyObj();
  65. //查询初始化数据
  66. BasicDBObject initObject=mongoQueryBuilder.buildGroupInitObj();
  67. String funcStr=mongoQueryBuilder.buildGroupFuncStr("count", "count_");
  68. list=${classVar}MGDao.group(keyObject,condObject,initObject,funcStr);
  69. }
  70. return list;
  71. }
  72. protected void setDao(){
  73. }
  74. }