package cn.com.lzt.arrangeduty.service.impl; import java.io.Serializable; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import org.jeecgframework.core.common.service.impl.CommonServiceImpl; import org.jeecgframework.core.constant.Globals; import org.jeecgframework.core.util.ApplicationContextUtil; import org.jeecgframework.core.util.JeecgDataAutorUtils; import org.jeecgframework.core.util.MyClassLoader; import org.jeecgframework.core.util.StringUtil; import org.jeecgframework.minidao.annotation.Arguments; import org.jeecgframework.minidao.annotation.ResultType; import org.jeecgframework.minidao.pojo.MiniDaoPage; import org.jeecgframework.web.cgform.enhance.CgformEnhanceJavaInter; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import cn.com.lzt.arrangeduty.dao.ArrangeDutyMinidao; import cn.com.lzt.arrangeduty.dao.MealsSubsidyMiniDao; import cn.com.lzt.arrangeduty.dao.ProjectDepartMinidao; import cn.com.lzt.arrangeduty.dao.UserOrgMinidao; import cn.com.lzt.arrangeduty.dto.ArrangeDutyDto; import cn.com.lzt.arrangeduty.dto.MealsSubsidyDto; import cn.com.lzt.arrangeduty.dto.ProjectDepartDto; import cn.com.lzt.arrangeduty.dto.UserOrgDto; import cn.com.lzt.arrangeduty.entity.ArrangeDutyEntity; import cn.com.lzt.arrangeduty.service.ArrangeDutyServiceI; @Service("arrangeDutyService") @Transactional public class ArrangeDutyServiceImpl extends CommonServiceImpl implements ArrangeDutyServiceI { @Autowired ArrangeDutyMinidao arrangeDutyMinidao; @Autowired MealsSubsidyMiniDao mealsSubsidyMiniDao; @Autowired ProjectDepartMinidao projectDepartMinidao; @Autowired UserOrgMinidao userOrgMinidao; public void delete(ArrangeDutyEntity entity) throws Exception{ super.delete(entity); //执行删除操作增强业务 this.doDelBus(entity); } public Serializable save(ArrangeDutyEntity entity) throws Exception{ Serializable t = super.save(entity); //执行新增操作增强业务 this.doAddBus(entity); return t; } public void saveOrUpdate(ArrangeDutyEntity entity) throws Exception{ super.saveOrUpdate(entity); //执行更新操作增强业务 this.doUpdateBus(entity); } /** * 新增操作增强业务 * @param t * @return */ private void doAddBus(ArrangeDutyEntity t) throws Exception{ //-----------------sql增强 start---------------------------- //-----------------sql增强 end------------------------------ //-----------------java增强 start--------------------------- //-----------------java增强 end----------------------------- } /** * 更新操作增强业务 * @param t * @return */ private void doUpdateBus(ArrangeDutyEntity t) throws Exception{ //-----------------sql增强 start---------------------------- //-----------------sql增强 end------------------------------ //-----------------java增强 start--------------------------- //-----------------java增强 end----------------------------- } /** * 删除操作增强业务 * @param id * @return */ private void doDelBus(ArrangeDutyEntity t) throws Exception{ //-----------------sql增强 start---------------------------- //-----------------sql增强 end------------------------------ //-----------------java增强 start--------------------------- //-----------------java增强 end----------------------------- } private Map populationMap(ArrangeDutyEntity t){ Map map = new HashMap(); map.put("id", t.getId()); map.put("duty_name", t.getDutyName()); map.put("pid", t.getPid()); map.put("duty_type", t.getDutyType()); map.put("normalwork_stime", t.getNormalworkStime()); map.put("normalwork_etime", t.getNormalworkEtime()); map.put("spunch_minute", t.getSpunchMinute()); map.put("epunch_minute", t.getEpunchMinute()); map.put("datum_workhours", t.getDatumWorkhours()); map.put("shift_workhours", t.getShiftWorkhours()); map.put("onduty_stime", t.getOndutyStime()); map.put("onduty_etime", t.getOndutyEtime()); // map.put("onduty_flag", t.getOndutyFlag()); map.put("onduty_workhours", t.getOndutyWorkhours()); map.put("timeout_overtime_stime", t.getTimeOutOvertimeStime()); map.put("timeout_overtime_etime", t.getTimeOutOvertimeEtime()); // map.put("timeout_overtime_flag", t.getTimeoutOvertimeFlag()); map.put("timeout_overtime_hours", t.getTimeOutOvertimeHours()); map.put("duty_mealid", t.getDutyMealid()); map.put("remark", t.getRemark()); map.put("create_name", t.getCreateName()); map.put("create_by", t.getCreateBy()); map.put("create_date", t.getCreateDate()); map.put("update_name", t.getUpdateName()); map.put("update_by", t.getUpdateBy()); map.put("update_date", t.getUpdateDate()); map.put("sys_org_code", t.getSysOrgCode()); map.put("sys_company_code", t.getSysCompanyCode()); map.put("status", t.getStatus()); map.put("delete_flag", t.getDeleteFlag()); return map; } /** * 替换sql中的变量 * @param sql * @param t * @return */ public String replaceVal(String sql,ArrangeDutyEntity t){ sql = sql.replace("#{id}",String.valueOf(t.getId())); sql = sql.replace("#{duty_name}",String.valueOf(t.getDutyName())); sql = sql.replace("#{pid}",String.valueOf(t.getPid())); sql = sql.replace("#{duty_type}",String.valueOf(t.getDutyType())); sql = sql.replace("#{normalwork_stime}",String.valueOf(t.getNormalworkStime())); sql = sql.replace("#{normalwork_etime}",String.valueOf(t.getNormalworkEtime())); sql = sql.replace("#{spunch_minute}",String.valueOf(t.getSpunchMinute())); sql = sql.replace("#{epunch_minute}",String.valueOf(t.getEpunchMinute())); sql = sql.replace("#{datum_workhours}",String.valueOf(t.getDatumWorkhours())); sql = sql.replace("#{shift_workhours}",String.valueOf(t.getShiftWorkhours())); sql = sql.replace("#{onduty_stime}",String.valueOf(t.getOndutyStime())); sql = sql.replace("#{onduty_etime}",String.valueOf(t.getOndutyEtime())); // sql = sql.replace("#{onduty_flag}",String.valueOf(t.getOndutyFlag())); sql = sql.replace("#{onduty_workhours}",String.valueOf(t.getOndutyWorkhours())); sql = sql.replace("#{timeout_overtime_stime}",String.valueOf(t.getTimeOutOvertimeStime())); sql = sql.replace("#{timeout_overtime_etime}",String.valueOf(t.getTimeOutOvertimeEtime())); // sql = sql.replace("#{timeout_overtime_flag}",String.valueOf(t.getTimeoutOvertimeFlag())); sql = sql.replace("#{timeout_overtime_hours}",String.valueOf(t.getTimeOutOvertimeHours())); sql = sql.replace("#{duty_mealid}",String.valueOf(t.getDutyMealid())); sql = sql.replace("#{remark}",String.valueOf(t.getRemark())); sql = sql.replace("#{create_name}",String.valueOf(t.getCreateName())); sql = sql.replace("#{create_by}",String.valueOf(t.getCreateBy())); sql = sql.replace("#{create_date}",String.valueOf(t.getCreateDate())); sql = sql.replace("#{update_name}",String.valueOf(t.getUpdateName())); sql = sql.replace("#{update_by}",String.valueOf(t.getUpdateBy())); sql = sql.replace("#{update_date}",String.valueOf(t.getUpdateDate())); sql = sql.replace("#{sys_org_code}",String.valueOf(t.getSysOrgCode())); sql = sql.replace("#{sys_company_code}",String.valueOf(t.getSysCompanyCode())); sql = sql.replace("#{status}",String.valueOf(t.getStatus())); sql = sql.replace("#{delete_flag}",String.valueOf(t.getDeleteFlag())); sql = sql.replace("#{UUID}",UUID.randomUUID().toString()); return sql; } /** * 执行JAVA增强 */ private void executeJavaExtend(String cgJavaType,String cgJavaValue,Map data) throws Exception { if(StringUtil.isNotEmpty(cgJavaValue)){ Object obj = null; try { if("class".equals(cgJavaType)){ //因新增时已经校验了实例化是否可以成功,所以这块就不需要再做一次判断 obj = MyClassLoader.getClassByScn(cgJavaValue).newInstance(); }else if("spring".equals(cgJavaType)){ obj = ApplicationContextUtil.getContext().getBean(cgJavaValue); } if(obj instanceof CgformEnhanceJavaInter){ CgformEnhanceJavaInter javaInter = (CgformEnhanceJavaInter) obj; javaInter.execute("t_bus_arrange_duty",data); } } catch (Exception e) { e.printStackTrace(); throw new Exception("执行JAVA增强出现异常!"); } } } @Override public void logicDel(ArrangeDutyEntity entity) throws Exception { super.updateEntitie(entity); //执行更新操作增强业务 this.doUpdateBus(entity); } @Override public MiniDaoPage getArrangeDutyDtoPage( ArrangeDutyDto arrangeDutyDto, int page, int rows, String authSql) { // TODO Auto-generated method stub return arrangeDutyMinidao.getArrangeDutyDtoPage(arrangeDutyDto, page, rows, authSql); } /*@Override public MiniDaoPage getProjectPostDetail( ProjectPostDetailDto projectPostDetailMiniDaoEntity, int page, int rows, String authSql) { // TODO Auto-generated method stub return projectPostDetailMiniDao.getProjectPostDetail(projectPostDetailMiniDaoEntity, page, rows, authSql); }*/ @Override public List getMealsSubsidyByIdList( MealsSubsidyDto mealsSubsidyDto, String authSql) { // TODO Auto-generated method stub return mealsSubsidyMiniDao.getMealsSubsidyByIdList(mealsSubsidyDto, authSql); } @Override public List getArrangeDutyMonthNoPage( ArrangeDutyDto arrangeDutyDto, String authSql) { // TODO Auto-generated method stub return arrangeDutyMinidao.getArrangeDutyMonthNoPage(arrangeDutyDto, authSql); } @Override public List getArrangeOnDutyNoPage( ArrangeDutyDto arrangeDutyDto, String authSql) { // TODO Auto-generated method stub return arrangeDutyMinidao.getArrangeOnDutyNoPage(arrangeDutyDto, authSql); } @Override public List getArrangeDutyByIdList( ArrangeDutyDto arrangeDutyDto, String authSql) { // TODO Auto-generated method stub return arrangeDutyMinidao.getArrangeDutyByIdList(arrangeDutyDto, authSql); } @Override public List getMealsSubsidySelect( MealsSubsidyDto mealsSubsidyDto, String authSql) { return mealsSubsidyMiniDao.getMealsSubsidySelect(mealsSubsidyDto, authSql); } @Override public List getArrangeDutyDtoExport( ArrangeDutyDto arrangeDutyDto, String authSql) { // TODO Auto-generated method stub return arrangeDutyMinidao.getArrangeDutyDtoExport(arrangeDutyDto, authSql); } @Override public List getUserOrgDtoAll(UserOrgDto userOrgDto, String authSql) { // TODO Auto-generated method stub return userOrgMinidao.getUserOrgDtoAll(userOrgDto, authSql); } @Override public String getDUTYTYPE_xiuxiId() { List> mapList=new ArrayList>(); String sql="SELECT * from t_bus_arrange_duty where duty_type='"+Globals.DUTYTYPE_xiuxi+"'"; mapList=this.findForJdbc(sql, null); return mapList.get(0).get("id").toString(); } }