MealsSubsidyServiceImpl.java 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172
  1. package cn.com.lzt.mealssubsidy.service.impl;
  2. import cn.com.lzt.mealssubsidy.entity.MealsSubsidyEntity;
  3. import cn.com.lzt.mealssubsidy.service.MealsSubsidyServiceI;
  4. import org.jeecgframework.core.common.service.impl.CommonServiceImpl;
  5. import org.jeecgframework.core.util.ApplicationContextUtil;
  6. import org.jeecgframework.core.util.MyClassLoader;
  7. import org.jeecgframework.core.util.StringUtil;
  8. import org.jeecgframework.web.cgform.enhance.CgformEnhanceJavaInter;
  9. import org.springframework.stereotype.Service;
  10. import org.springframework.transaction.annotation.Transactional;
  11. import java.io.Serializable;
  12. import java.util.*;
  13. @Service("mealsSubsidyService")
  14. @Transactional
  15. public class MealsSubsidyServiceImpl extends CommonServiceImpl implements MealsSubsidyServiceI {
  16. public void delete(MealsSubsidyEntity entity) throws Exception{
  17. super.delete(entity);
  18. //执行删除操作增强业务
  19. this.doDelBus(entity);
  20. }
  21. public Serializable save(MealsSubsidyEntity entity) throws Exception{
  22. Serializable t = super.save(entity);
  23. //执行新增操作增强业务
  24. this.doAddBus(entity);
  25. return t;
  26. }
  27. public void saveOrUpdate(MealsSubsidyEntity entity) throws Exception{
  28. super.saveOrUpdate(entity);
  29. //执行更新操作增强业务
  30. this.doUpdateBus(entity);
  31. }
  32. /**
  33. * 批量更新操作
  34. *
  35. */
  36. public void batchUpdate(List<MealsSubsidyEntity> entityList) throws Exception{
  37. for(MealsSubsidyEntity entity : entityList){
  38. super.updateEntitie(entity);
  39. }
  40. }
  41. /**
  42. * 新增操作增强业务
  43. * @param t
  44. * @return
  45. */
  46. private void doAddBus(MealsSubsidyEntity t) throws Exception{
  47. //-----------------sql增强 start----------------------------
  48. //-----------------sql增强 end------------------------------
  49. //-----------------java增强 start---------------------------
  50. //-----------------java增强 end-----------------------------
  51. }
  52. /**
  53. * 更新操作增强业务
  54. * @param t
  55. * @return
  56. */
  57. private void doUpdateBus(MealsSubsidyEntity t) throws Exception{
  58. //-----------------sql增强 start----------------------------
  59. //-----------------sql增强 end------------------------------
  60. //-----------------java增强 start---------------------------
  61. //-----------------java增强 end-----------------------------
  62. }
  63. /**
  64. * 删除操作增强业务
  65. * @param id
  66. * @return
  67. */
  68. private void doDelBus(MealsSubsidyEntity t) throws Exception{
  69. //-----------------sql增强 start----------------------------
  70. //-----------------sql增强 end------------------------------
  71. //-----------------java增强 start---------------------------
  72. //-----------------java增强 end-----------------------------
  73. }
  74. private Map<String,Object> populationMap(MealsSubsidyEntity t){
  75. Map<String,Object> map = new HashMap<String,Object>();
  76. map.put("id", t.getId());
  77. map.put("create_name", t.getCreateName());
  78. map.put("create_by", t.getCreateBy());
  79. map.put("create_date", t.getCreateDate());
  80. map.put("update_name", t.getUpdateName());
  81. map.put("update_by", t.getUpdateBy());
  82. map.put("update_date", t.getUpdateDate());
  83. map.put("sys_org_code", t.getSysOrgCode());
  84. map.put("sys_company_code", t.getSysCompanyCode());
  85. map.put("subsidy_type", t.getSubsidyType());
  86. map.put("subsidy_name", t.getSubsidyName());
  87. map.put("subsidy_money", t.getSubsidyMoney());
  88. map.put("calcu_unit", t.getCalcuUnit());
  89. map.put("status", t.getStatus());
  90. map.put("delete_flag", t.getDeleteFlag());
  91. return map;
  92. }
  93. /**
  94. * 替换sql中的变量
  95. * @param sql
  96. * @param t
  97. * @return
  98. */
  99. public String replaceVal(String sql,MealsSubsidyEntity t){
  100. sql = sql.replace("#{id}",String.valueOf(t.getId()));
  101. sql = sql.replace("#{create_name}",String.valueOf(t.getCreateName()));
  102. sql = sql.replace("#{create_by}",String.valueOf(t.getCreateBy()));
  103. sql = sql.replace("#{create_date}",String.valueOf(t.getCreateDate()));
  104. sql = sql.replace("#{update_name}",String.valueOf(t.getUpdateName()));
  105. sql = sql.replace("#{update_by}",String.valueOf(t.getUpdateBy()));
  106. sql = sql.replace("#{update_date}",String.valueOf(t.getUpdateDate()));
  107. sql = sql.replace("#{sys_org_code}",String.valueOf(t.getSysOrgCode()));
  108. sql = sql.replace("#{sys_company_code}",String.valueOf(t.getSysCompanyCode()));
  109. sql = sql.replace("#{subsidy_type}",String.valueOf(t.getSubsidyType()));
  110. sql = sql.replace("#{subsidy_name}",String.valueOf(t.getSubsidyName()));
  111. sql = sql.replace("#{subsidy_money}",String.valueOf(t.getSubsidyMoney()));
  112. sql = sql.replace("#{calcu_unit}",String.valueOf(t.getCalcuUnit()));
  113. sql = sql.replace("#{status}",String.valueOf(t.getStatus()));
  114. sql = sql.replace("#{delete_flag}",String.valueOf(t.getDeleteFlag()));
  115. sql = sql.replace("#{UUID}",UUID.randomUUID().toString());
  116. return sql;
  117. }
  118. /**
  119. * 执行JAVA增强
  120. */
  121. private void executeJavaExtend(String cgJavaType,String cgJavaValue,Map<String,Object> data) throws Exception {
  122. if(StringUtil.isNotEmpty(cgJavaValue)){
  123. Object obj = null;
  124. try {
  125. if("class".equals(cgJavaType)){
  126. //因新增时已经校验了实例化是否可以成功,所以这块就不需要再做一次判断
  127. obj = MyClassLoader.getClassByScn(cgJavaValue).newInstance();
  128. }else if("spring".equals(cgJavaType)){
  129. obj = ApplicationContextUtil.getContext().getBean(cgJavaValue);
  130. }
  131. if(obj instanceof CgformEnhanceJavaInter){
  132. CgformEnhanceJavaInter javaInter = (CgformEnhanceJavaInter) obj;
  133. javaInter.execute("t_bus_meals_subsidy",data);
  134. }
  135. } catch (Exception e) {
  136. e.printStackTrace();
  137. throw new Exception("执行JAVA增强出现异常!");
  138. }
  139. }
  140. }
  141. @Override
  142. public Boolean findByName(MealsSubsidyEntity mealsSubsidy) {
  143. List<MealsSubsidyEntity> postobj = new ArrayList<MealsSubsidyEntity>();
  144. StringBuffer hql = new StringBuffer(" from MealsSubsidyEntity where subsidyName=? and deleteFlag=0");
  145. if(StringUtil.isNotEmpty(mealsSubsidy.getId())){
  146. hql = new StringBuffer(" from MealsSubsidyEntity where id!=? and subsidyName=? and deleteFlag=0");
  147. postobj = findHql(hql.toString(),mealsSubsidy.getId(),mealsSubsidy.getSubsidyName());
  148. }else{
  149. postobj = findHql(hql.toString(),mealsSubsidy.getSubsidyName());
  150. }
  151. Boolean flag = true;
  152. if(postobj.size() > 0){
  153. flag = false;
  154. }
  155. return flag;
  156. }
  157. }