package cn.com.lzt.overtimestats.service.impl; import org.jeecgframework.core.common.service.impl.CommonServiceImpl; import org.jeecgframework.core.constant.Globals; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.io.Serializable; import org.jeecgframework.core.util.ApplicationContextUtil; import org.jeecgframework.core.util.JeecgDataAutorUtils; import org.jeecgframework.core.util.LogUtil; import org.jeecgframework.core.util.MyClassLoader; import org.jeecgframework.core.util.StringUtil; import org.jeecgframework.minidao.pojo.MiniDaoPage; import org.jeecgframework.web.cgform.enhance.CgformEnhanceJavaInter; import cn.com.lzt.common.util.DataUtil; import cn.com.lzt.distributionstats.entity.ProjDistributionStatsEntity; import cn.com.lzt.overtimestats.dao.OvertimeStatsMinidaoDao; import cn.com.lzt.overtimestats.entity.DeptOvertimeStatsEntity; import cn.com.lzt.overtimestats.entity.ProjOvertimeStatsEntity; import cn.com.lzt.overtimestats.entity.UserOvertimeStatsEntity; import cn.com.lzt.overtimestats.service.OvertimeStatsServiceI; import cn.com.lzt.wageStats.service.WageStatsServiceI; @Service("overtimeStatsService") @Transactional public class OvertimeStatsServiceImpl extends CommonServiceImpl implements OvertimeStatsServiceI { @Autowired private OvertimeStatsMinidaoDao overtimeStatsMinidaoDao; @Override public void overtimeStatsTaskData() { overtimeStatsTaskData(null); } @Override public void overtimeStatsTaskData(String attmonth) { LogUtil.info("===============人员统计定时任务开始================="); //String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString(); String beforeMonth = DataUtil.getBeforeMonth(); if(StringUtil.isNotEmpty(attmonth)){ beforeMonth = attmonth; } Map params = new HashMap(); params.put("yearmonth", beforeMonth); params.put("basepay", Globals.BASE_PAY); //查询上个月的员工月度考勤 MiniDaoPage userOvertimelist = new MiniDaoPage(); userOvertimelist = overtimeStatsMinidaoDao.userOvertimeStatsData(params,null); List userOverList = findByProperty(UserOvertimeStatsEntity.class, "yearmonth", beforeMonth); try { deleteAllEntitie(userOverList); super.batchSave(userOvertimelist.getResults()); LogUtil.info("===============员工加班统计表保存成功================="); } catch (Exception e) { LogUtil.info("===============员工加班统计表保存失败================="); } //查询上个月的部门月度考勤 MiniDaoPage deptOvertimelist = new MiniDaoPage(); deptOvertimelist = overtimeStatsMinidaoDao.deptOvertimeStatsData(params,null); List deptOverList = findByProperty(DeptOvertimeStatsEntity.class, "yearmonth",beforeMonth); try { deleteAllEntitie(deptOverList); super.batchSave(deptOvertimelist.getResults()); LogUtil.info("===============部门加班统计表保存成功================="); } catch (Exception e) { LogUtil.info("===============部门加班统计表保存失败================="); } //查询上个月的项目月度考勤 MiniDaoPage projOvertimelist = new MiniDaoPage(); projOvertimelist = overtimeStatsMinidaoDao.projOvertimeStatsData(params,null); List projOverList = findByProperty(ProjOvertimeStatsEntity.class, "yearmonth",beforeMonth); try { deleteAllEntitie(projOverList); super.batchSave(projOvertimelist.getResults()); LogUtil.info("===============项目加班统计表保存成功================="); } catch (Exception e) { LogUtil.info("===============项目加班统计表保存失败================="); } LogUtil.info("===============加班统计定时任务开始================="); } }