ZoneServiceImpl.java 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178
  1. package cn.com.lzt.zone.service.impl;
  2. import cn.com.lzt.zone.service.ZoneServiceI;
  3. import org.jeecgframework.core.common.service.impl.CommonServiceImpl;
  4. import cn.com.lzt.zone.entity.ZoneEntity;
  5. import org.springframework.stereotype.Service;
  6. import org.springframework.transaction.annotation.Transactional;
  7. import java.util.HashMap;
  8. import java.util.Map;
  9. import java.util.UUID;
  10. import java.io.Serializable;
  11. import org.jeecgframework.core.util.ApplicationContextUtil;
  12. import org.jeecgframework.core.util.MyClassLoader;
  13. import org.jeecgframework.core.util.StringUtil;
  14. import org.jeecgframework.web.cgform.enhance.CgformEnhanceJavaInter;
  15. @Service("zoneService")
  16. @Transactional
  17. public class ZoneServiceImpl extends CommonServiceImpl implements ZoneServiceI {
  18. public void delete(ZoneEntity entity) throws Exception{
  19. super.delete(entity);
  20. //执行删除操作增强业务
  21. this.doDelBus(entity);
  22. }
  23. public Serializable save(ZoneEntity entity) throws Exception{
  24. Serializable t = super.save(entity);
  25. //执行新增操作增强业务
  26. this.doAddBus(entity);
  27. return t;
  28. }
  29. public void saveOrUpdate(ZoneEntity entity) throws Exception{
  30. super.saveOrUpdate(entity);
  31. //执行更新操作增强业务
  32. this.doUpdateBus(entity);
  33. }
  34. /**
  35. * 新增操作增强业务
  36. * @param t
  37. * @return
  38. */
  39. private void doAddBus(ZoneEntity t) throws Exception{
  40. //-----------------sql增强 start----------------------------
  41. //-----------------sql增强 end------------------------------
  42. //-----------------java增强 start---------------------------
  43. //-----------------java增强 end-----------------------------
  44. }
  45. /**
  46. * 更新操作增强业务
  47. * @param t
  48. * @return
  49. */
  50. private void doUpdateBus(ZoneEntity t) throws Exception{
  51. //-----------------sql增强 start----------------------------
  52. //-----------------sql增强 end------------------------------
  53. //-----------------java增强 start---------------------------
  54. //-----------------java增强 end-----------------------------
  55. }
  56. /**
  57. * 删除操作增强业务
  58. * @param id
  59. * @return
  60. */
  61. private void doDelBus(ZoneEntity t) throws Exception{
  62. //-----------------sql增强 start----------------------------
  63. //-----------------sql增强 end------------------------------
  64. //-----------------java增强 start---------------------------
  65. //-----------------java增强 end-----------------------------
  66. }
  67. private Map<String,Object> populationMap(ZoneEntity t){
  68. Map<String,Object> map = new HashMap<String,Object>();
  69. map.put("id", t.getId());
  70. map.put("create_name", t.getCreateName());
  71. map.put("create_by", t.getCreateBy());
  72. map.put("create_date", t.getCreateDate());
  73. map.put("update_name", t.getUpdateName());
  74. map.put("update_by", t.getUpdateBy());
  75. map.put("update_date", t.getUpdateDate());
  76. map.put("code", t.getCode());
  77. map.put("name", t.getName());
  78. map.put("leadername", t.getLeadername());
  79. map.put("leader", t.getLeader());
  80. map.put("defnum1", t.getDefnum1());
  81. map.put("defnum2", t.getDefnum2());
  82. map.put("defnum3", t.getDefnum3());
  83. map.put("defnum4", t.getDefnum4());
  84. map.put("defnum5", t.getDefnum5());
  85. map.put("defnum6", t.getDefnum6());
  86. map.put("defnum7", t.getDefnum7());
  87. map.put("defnum8", t.getDefnum8());
  88. map.put("defnum9", t.getDefnum9());
  89. map.put("defnum10", t.getDefnum10());
  90. map.put("defstr1", t.getDefstr1());
  91. map.put("defstr2", t.getDefstr2());
  92. map.put("defstr3", t.getDefstr3());
  93. map.put("defstr4", t.getDefstr4());
  94. map.put("defstr5", t.getDefstr5());
  95. map.put("defstr6", t.getDefstr6());
  96. map.put("defstr7", t.getDefstr7());
  97. map.put("defstr8", t.getDefstr8());
  98. map.put("defstr9", t.getDefstr9());
  99. map.put("defstr10", t.getDefstr10());
  100. return map;
  101. }
  102. /**
  103. * 替换sql中的变量
  104. * @param sql
  105. * @param t
  106. * @return
  107. */
  108. public String replaceVal(String sql,ZoneEntity t){
  109. sql = sql.replace("#{id}",String.valueOf(t.getId()));
  110. sql = sql.replace("#{create_name}",String.valueOf(t.getCreateName()));
  111. sql = sql.replace("#{create_by}",String.valueOf(t.getCreateBy()));
  112. sql = sql.replace("#{create_date}",String.valueOf(t.getCreateDate()));
  113. sql = sql.replace("#{update_name}",String.valueOf(t.getUpdateName()));
  114. sql = sql.replace("#{update_by}",String.valueOf(t.getUpdateBy()));
  115. sql = sql.replace("#{update_date}",String.valueOf(t.getUpdateDate()));
  116. sql = sql.replace("#{code}",String.valueOf(t.getCode()));
  117. sql = sql.replace("#{name}",String.valueOf(t.getName()));
  118. sql = sql.replace("#{leadername}",String.valueOf(t.getLeadername()));
  119. sql = sql.replace("#{leader}",String.valueOf(t.getLeader()));
  120. sql = sql.replace("#{defnum1}",String.valueOf(t.getDefnum1()));
  121. sql = sql.replace("#{defnum2}",String.valueOf(t.getDefnum2()));
  122. sql = sql.replace("#{defnum3}",String.valueOf(t.getDefnum3()));
  123. sql = sql.replace("#{defnum4}",String.valueOf(t.getDefnum4()));
  124. sql = sql.replace("#{defnum5}",String.valueOf(t.getDefnum5()));
  125. sql = sql.replace("#{defnum6}",String.valueOf(t.getDefnum6()));
  126. sql = sql.replace("#{defnum7}",String.valueOf(t.getDefnum7()));
  127. sql = sql.replace("#{defnum8}",String.valueOf(t.getDefnum8()));
  128. sql = sql.replace("#{defnum9}",String.valueOf(t.getDefnum9()));
  129. sql = sql.replace("#{defnum10}",String.valueOf(t.getDefnum10()));
  130. sql = sql.replace("#{defstr1}",String.valueOf(t.getDefstr1()));
  131. sql = sql.replace("#{defstr2}",String.valueOf(t.getDefstr2()));
  132. sql = sql.replace("#{defstr3}",String.valueOf(t.getDefstr3()));
  133. sql = sql.replace("#{defstr4}",String.valueOf(t.getDefstr4()));
  134. sql = sql.replace("#{defstr5}",String.valueOf(t.getDefstr5()));
  135. sql = sql.replace("#{defstr6}",String.valueOf(t.getDefstr6()));
  136. sql = sql.replace("#{defstr7}",String.valueOf(t.getDefstr7()));
  137. sql = sql.replace("#{defstr8}",String.valueOf(t.getDefstr8()));
  138. sql = sql.replace("#{defstr9}",String.valueOf(t.getDefstr9()));
  139. sql = sql.replace("#{defstr10}",String.valueOf(t.getDefstr10()));
  140. sql = sql.replace("#{UUID}",UUID.randomUUID().toString());
  141. return sql;
  142. }
  143. /**
  144. * 执行JAVA增强
  145. */
  146. private void executeJavaExtend(String cgJavaType,String cgJavaValue,Map<String,Object> data) throws Exception {
  147. if(StringUtil.isNotEmpty(cgJavaValue)){
  148. Object obj = null;
  149. try {
  150. if("class".equals(cgJavaType)){
  151. //因新增时已经校验了实例化是否可以成功,所以这块就不需要再做一次判断
  152. obj = MyClassLoader.getClassByScn(cgJavaValue).newInstance();
  153. }else if("spring".equals(cgJavaType)){
  154. obj = ApplicationContextUtil.getContext().getBean(cgJavaValue);
  155. }
  156. if(obj instanceof CgformEnhanceJavaInter){
  157. CgformEnhanceJavaInter javaInter = (CgformEnhanceJavaInter) obj;
  158. javaInter.execute("t_b_zone",data);
  159. }
  160. } catch (Exception e) {
  161. e.printStackTrace();
  162. throw new Exception("执行JAVA增强出现异常!");
  163. }
  164. }
  165. }
  166. }