WagestrategyServiceImpl.java 7.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193
  1. package cn.com.lzt.wagestrategy.service.impl;
  2. import java.io.Serializable;
  3. import java.util.HashMap;
  4. import java.util.Map;
  5. import java.util.UUID;
  6. import org.jeecgframework.core.common.service.impl.CommonServiceImpl;
  7. import org.jeecgframework.core.util.ApplicationContextUtil;
  8. import org.jeecgframework.core.util.MyClassLoader;
  9. import org.jeecgframework.core.util.StringUtil;
  10. import org.jeecgframework.minidao.pojo.MiniDaoPage;
  11. import org.jeecgframework.web.cgform.enhance.CgformEnhanceJavaInter;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.stereotype.Service;
  14. import org.springframework.transaction.annotation.Transactional;
  15. import cn.com.lzt.wagestrategy.dao.WagestrategyMiniDao;
  16. import cn.com.lzt.wagestrategy.dto.WagestrategyDto;
  17. import cn.com.lzt.wagestrategy.entity.WagestrategyEntity;
  18. import cn.com.lzt.wagestrategy.service.WagestrategyServiceI;
  19. @Service("wagestrategyService")
  20. @Transactional
  21. public class WagestrategyServiceImpl extends CommonServiceImpl implements WagestrategyServiceI {
  22. @Autowired
  23. WagestrategyMiniDao wagestrategyMiniDao;
  24. public void delete(WagestrategyEntity entity) throws Exception{
  25. super.delete(entity);
  26. //执行删除操作增强业务
  27. this.doDelBus(entity);
  28. }
  29. public Serializable save(WagestrategyEntity entity) throws Exception{
  30. Serializable t = super.save(entity);
  31. //执行新增操作增强业务
  32. this.doAddBus(entity);
  33. return t;
  34. }
  35. public void saveOrUpdate(WagestrategyEntity entity) throws Exception{
  36. super.saveOrUpdate(entity);
  37. //执行更新操作增强业务
  38. this.doUpdateBus(entity);
  39. }
  40. /**
  41. * 新增操作增强业务
  42. * @param t
  43. * @return
  44. */
  45. private void doAddBus(WagestrategyEntity t) throws Exception{
  46. //-----------------sql增强 start----------------------------
  47. //-----------------sql增强 end------------------------------
  48. //-----------------java增强 start---------------------------
  49. //-----------------java增强 end-----------------------------
  50. }
  51. /**
  52. * 更新操作增强业务
  53. * @param t
  54. * @return
  55. */
  56. private void doUpdateBus(WagestrategyEntity t) throws Exception{
  57. //-----------------sql增强 start----------------------------
  58. //-----------------sql增强 end------------------------------
  59. //-----------------java增强 start---------------------------
  60. //-----------------java增强 end-----------------------------
  61. }
  62. /**
  63. * 删除操作增强业务
  64. * @param id
  65. * @return
  66. */
  67. private void doDelBus(WagestrategyEntity t) throws Exception{
  68. //-----------------sql增强 start----------------------------
  69. //-----------------sql增强 end------------------------------
  70. //-----------------java增强 start---------------------------
  71. //-----------------java增强 end-----------------------------
  72. }
  73. private Map<String,Object> populationMap(WagestrategyEntity t){
  74. Map<String,Object> map = new HashMap<String,Object>();
  75. map.put("id", t.getId());
  76. map.put("DutiesId", t.getDutiesId());
  77. // map.put("parentDutiesid", t.getParentDutiesid());
  78. map.put("basic_wage", t.getBasicWage());
  79. map.put("subsidy", t.getSubsidy());
  80. map.put("create_name", t.getCreateName());
  81. map.put("create_by", t.getCreateBy());
  82. map.put("create_date", t.getCreateDate());
  83. map.put("update_name", t.getUpdateName());
  84. map.put("update_by", t.getUpdateBy());
  85. map.put("update_date", t.getUpdateDate());
  86. map.put("sys_org_code", t.getSysOrgCode());
  87. map.put("sys_company_code", t.getSysCompanyCode());
  88. map.put("status", t.getStatus());
  89. map.put("delete_flag", t.getDeleteFlag());
  90. return map;
  91. }
  92. /**
  93. * 替换sql中的变量
  94. * @param sql
  95. * @param t
  96. * @return
  97. */
  98. public String replaceVal(String sql,WagestrategyEntity t){
  99. sql = sql.replace("#{id}",String.valueOf(t.getId()));
  100. sql = sql.replace("#{DutiesId}",String.valueOf(t.getDutiesId()));
  101. // sql = sql.replace("#{parentDutiesid}",String.valueOf(t.getParentDutiesid()));
  102. sql = sql.replace("#{basic_wage}",String.valueOf(t.getBasicWage()));
  103. sql = sql.replace("#{subsidy}",String.valueOf(t.getSubsidy()));
  104. sql = sql.replace("#{create_name}",String.valueOf(t.getCreateName()));
  105. sql = sql.replace("#{create_by}",String.valueOf(t.getCreateBy()));
  106. sql = sql.replace("#{create_date}",String.valueOf(t.getCreateDate()));
  107. sql = sql.replace("#{update_name}",String.valueOf(t.getUpdateName()));
  108. sql = sql.replace("#{update_by}",String.valueOf(t.getUpdateBy()));
  109. sql = sql.replace("#{update_date}",String.valueOf(t.getUpdateDate()));
  110. sql = sql.replace("#{sys_org_code}",String.valueOf(t.getSysOrgCode()));
  111. sql = sql.replace("#{sys_company_code}",String.valueOf(t.getSysCompanyCode()));
  112. sql = sql.replace("#{status}",String.valueOf(t.getStatus()));
  113. sql = sql.replace("#{delete_flag}",String.valueOf(t.getDeleteFlag()));
  114. sql = sql.replace("#{UUID}",UUID.randomUUID().toString());
  115. return sql;
  116. }
  117. /**
  118. * 执行JAVA增强
  119. */
  120. private void executeJavaExtend(String cgJavaType,String cgJavaValue,Map<String,Object> data) throws Exception {
  121. if(StringUtil.isNotEmpty(cgJavaValue)){
  122. Object obj = null;
  123. try {
  124. if("class".equals(cgJavaType)){
  125. //因新增时已经校验了实例化是否可以成功,所以这块就不需要再做一次判断
  126. obj = MyClassLoader.getClassByScn(cgJavaValue).newInstance();
  127. }else if("spring".equals(cgJavaType)){
  128. obj = ApplicationContextUtil.getContext().getBean(cgJavaValue);
  129. }
  130. if(obj instanceof CgformEnhanceJavaInter){
  131. CgformEnhanceJavaInter javaInter = (CgformEnhanceJavaInter) obj;
  132. javaInter.execute("t_bus_wagestrategy",data);
  133. }
  134. } catch (Exception e) {
  135. e.printStackTrace();
  136. throw new Exception("执行JAVA增强出现异常!");
  137. }
  138. }
  139. }
  140. @Override
  141. public void logicDel(WagestrategyEntity entity) throws Exception {
  142. super.updateEntitie(entity);
  143. //执行更新操作增强业务
  144. this.doUpdateBus(entity);
  145. }
  146. @Override
  147. public MiniDaoPage<WagestrategyDto> getWagestrategyDtoPage(
  148. WagestrategyDto wagestrategyDto, int page, int rows, String authSql, String sortorder) {
  149. // TODO Auto-generated method stub
  150. return wagestrategyMiniDao.getWagestrategyDtoPage(wagestrategyDto, page, rows, authSql, sortorder);
  151. }
  152. /* (non-Javadoc)
  153. * @see cn.com.lzt.wagestrategy.service.WagestrategyServiceI#getComWagestrategyDtoPage(cn.com.lzt.wagestrategy.dto.WagestrategyDto, int, int, java.lang.String, java.lang.String)
  154. */
  155. @Override
  156. public MiniDaoPage<WagestrategyDto> getComWagestrategyDtoPage(WagestrategyDto wagestrategyDto, int page, int rows, String authSql, String sortorder) {
  157. return wagestrategyMiniDao.getComWagestrategyDtoPage(wagestrategyDto, page, rows, authSql, sortorder);
  158. }
  159. /* (non-Javadoc)
  160. * @see cn.com.lzt.wagestrategy.service.WagestrategyServiceI#getZoneWagestrategyDtoPage_com(cn.com.lzt.wagestrategy.dto.WagestrategyDto, int, int, java.lang.String, java.lang.String)
  161. */
  162. @Override
  163. public MiniDaoPage<WagestrategyDto> getZoneWagestrategyDtoPage(WagestrategyDto wagestrategyDto, int page, int rows, String authSql, String sortorder) {
  164. return wagestrategyMiniDao.getZoneWagestrategyDtoPage(wagestrategyDto, page, rows, authSql, sortorder);
  165. }
  166. /* (non-Javadoc)
  167. * @see cn.com.lzt.wagestrategy.service.WagestrategyServiceI#getProjectWagestrategyDtoPage_com(cn.com.lzt.wagestrategy.dto.WagestrategyDto, int, int, java.lang.String, java.lang.String)
  168. */
  169. @Override
  170. public MiniDaoPage<WagestrategyDto> getProjectWagestrategyDtoPage(WagestrategyDto wagestrategyDto, int page, int rows, String authSql, String sortorder) {
  171. return wagestrategyMiniDao.getProjectWagestrategyDtoPage(wagestrategyDto, page, rows, authSql, sortorder);
  172. }
  173. }