WarehouseServiceImpl.java 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136
  1. package cn.com.lzt.warehouse.service.impl;
  2. import cn.com.lzt.warehouse.service.WarehouseServiceI;
  3. import org.jeecgframework.core.common.service.impl.CommonServiceImpl;
  4. import cn.com.lzt.warehouse.entity.WarehouseEntity;
  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("warehouseService")
  16. @Transactional
  17. public class WarehouseServiceImpl extends CommonServiceImpl implements WarehouseServiceI {
  18. public void delete(WarehouseEntity entity) throws Exception{
  19. super.delete(entity);
  20. //执行删除操作增强业务
  21. this.doDelBus(entity);
  22. }
  23. public Serializable save(WarehouseEntity entity) throws Exception{
  24. Serializable t = super.save(entity);
  25. //执行新增操作增强业务
  26. this.doAddBus(entity);
  27. return t;
  28. }
  29. public void saveOrUpdate(WarehouseEntity entity) throws Exception{
  30. super.saveOrUpdate(entity);
  31. //执行更新操作增强业务
  32. this.doUpdateBus(entity);
  33. }
  34. /**
  35. * 自定义按钮-[停用仓库]业务处理
  36. * @param id
  37. * @return
  38. */
  39. public void doBtnenableBus(WarehouseEntity t) throws Exception{
  40. }
  41. /**
  42. * 新增操作增强业务
  43. * @param t
  44. * @return
  45. */
  46. private void doAddBus(WarehouseEntity t) throws Exception{
  47. }
  48. /**
  49. * 更新操作增强业务
  50. * @param t
  51. * @return
  52. */
  53. private void doUpdateBus(WarehouseEntity t) throws Exception{
  54. }
  55. /**
  56. * 删除操作增强业务
  57. * @param id
  58. * @return
  59. */
  60. private void doDelBus(WarehouseEntity t) throws Exception{
  61. }
  62. private Map<String,Object> populationMap(WarehouseEntity t){
  63. Map<String,Object> map = new HashMap<String,Object>();
  64. map.put("id", t.getId());
  65. map.put("create_name", t.getCreateName());
  66. map.put("create_by", t.getCreateBy());
  67. map.put("create_date", t.getCreateDate());
  68. map.put("update_name", t.getUpdateName());
  69. map.put("update_by", t.getUpdateBy());
  70. map.put("update_date", t.getUpdateDate());
  71. map.put("warehouse_code", t.getWarehouseCode());
  72. map.put("warehouse_name", t.getWarehouseName());
  73. map.put("warehouse_address", t.getWarehouseAddress());
  74. map.put("responsible_person", t.getResponsiblePerson());
  75. map.put("remark", t.getRemark());
  76. map.put("status", t.getStatus());
  77. map.put("delete_flag", t.getDeleteFlag());
  78. return map;
  79. }
  80. /**
  81. * 替换sql中的变量
  82. * @param sql
  83. * @param t
  84. * @return
  85. */
  86. public String replaceVal(String sql,WarehouseEntity t){
  87. sql = sql.replace("#{id}",String.valueOf(t.getId()));
  88. sql = sql.replace("#{create_name}",String.valueOf(t.getCreateName()));
  89. sql = sql.replace("#{create_by}",String.valueOf(t.getCreateBy()));
  90. sql = sql.replace("#{create_date}",String.valueOf(t.getCreateDate()));
  91. sql = sql.replace("#{update_name}",String.valueOf(t.getUpdateName()));
  92. sql = sql.replace("#{update_by}",String.valueOf(t.getUpdateBy()));
  93. sql = sql.replace("#{update_date}",String.valueOf(t.getUpdateDate()));
  94. sql = sql.replace("#{warehouse_code}",String.valueOf(t.getWarehouseCode()));
  95. sql = sql.replace("#{warehouse_name}",String.valueOf(t.getWarehouseName()));
  96. sql = sql.replace("#{warehouse_address}",String.valueOf(t.getWarehouseAddress()));
  97. sql = sql.replace("#{responsible_person}",String.valueOf(t.getResponsiblePerson()));
  98. sql = sql.replace("#{remark}",String.valueOf(t.getRemark()));
  99. sql = sql.replace("#{status}",String.valueOf(t.getStatus()));
  100. sql = sql.replace("#{delete_flag}",String.valueOf(t.getDeleteFlag()));
  101. sql = sql.replace("#{UUID}",UUID.randomUUID().toString());
  102. return sql;
  103. }
  104. /**
  105. * 执行JAVA增强
  106. */
  107. private void executeJavaExtend(String cgJavaType,String cgJavaValue,Map<String,Object> data) throws Exception {
  108. // if(StringUtil.isNotEmpty(cgJavaValue)){
  109. // Object obj = null;
  110. // try {
  111. // if("class".equals(cgJavaType)){
  112. // //因新增时已经校验了实例化是否可以成功,所以这块就不需要再做一次判断
  113. // obj = MyClassLoader.getClassByScn(cgJavaValue).newInstance();
  114. // }else if("spring".equals(cgJavaType)){
  115. // obj = ApplicationContextUtil.getContext().getBean(cgJavaValue);
  116. // }
  117. // if(obj instanceof CgformEnhanceJavaInter){
  118. // CgformEnhanceJavaInter javaInter = (CgformEnhanceJavaInter) obj;
  119. // javaInter.execute(data);
  120. // }
  121. // } catch (Exception e) {
  122. // e.printStackTrace();
  123. // throw new Exception("执行JAVA增强出现异常!");
  124. // }
  125. // }
  126. }
  127. }