package cn.com.lzt.wageStats.service.impl;
import org.jeecgframework.core.common.service.impl.CommonServiceImpl;
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.userstats.enitity.ProjUserEntity;
import cn.com.lzt.wageStats.dao.WageStatsMinidaoDao;
import cn.com.lzt.wageStats.entity.DeptWageEntity;
import cn.com.lzt.wageStats.entity.ProjWageEntity;
import cn.com.lzt.wageStats.entity.UserWageStatsEntity;
import cn.com.lzt.wageStats.service.WageStatsServiceI;

@Service("wageStatsService")
@Transactional
public class WageStatsServiceImpl extends CommonServiceImpl implements WageStatsServiceI {

	@Autowired
	private WageStatsMinidaoDao wageStatsMinidaoDao;
	
	@Override
	public void wageStatsTaskData() {
		wageStatsTaskData(null);
	}

	@Override
	public void wageStatsTaskData(String attmonth) {
		LogUtil.info("===============工资统计定时任务开始=================");
		//String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString();
		String beforeMonth = DataUtil.getBeforeMonth();
		if(StringUtil.isNotEmpty(attmonth)){
			beforeMonth = attmonth;
		}
		Map<String,Object> params = new HashMap<String,Object>();
		params.put("yearmonth", beforeMonth);
		params.put("daycount", DataUtil.getMonthDays(DataUtil.getBeforeMonth()));
		//查询上个月的员工月度考勤
		MiniDaoPage<UserWageStatsEntity> userWagelist = new MiniDaoPage<UserWageStatsEntity>();
		userWagelist = wageStatsMinidaoDao.userWageStatsData(params,null);
		List<UserWageStatsEntity>  wageList = findByProperty(UserWageStatsEntity.class, "yearmonth", beforeMonth);
		try {
			deleteAllEntitie(wageList);
			super.batchSave(userWagelist.getResults());
			LogUtil.info("===============员工工资统计表保存成功=================");
		} catch (Exception e) {
			LogUtil.info("===============员工工资统计表保存失败=================");
		}
		//查询上个月的部门月度考勤
		MiniDaoPage<DeptWageEntity> deptWagelist = new MiniDaoPage<DeptWageEntity>();
		deptWagelist = wageStatsMinidaoDao.deptWageStatsData(params,null);
		List<DeptWageEntity>  deptList = findByProperty(DeptWageEntity.class, "yearmonth", beforeMonth);
		try {
			deleteAllEntitie(deptList);
			super.batchSave(deptWagelist.getResults());
			LogUtil.info("===============部门工资统计表保存成功=================");
		} catch (Exception e) {
			LogUtil.info("===============部门工资统计表保存失败=================");
		}
		
		//查询上个月的项目月度考勤
		MiniDaoPage<ProjWageEntity> projWagelist = new MiniDaoPage<ProjWageEntity>();
		projWagelist = wageStatsMinidaoDao.projWageStatsData(params,null);
		List<ProjWageEntity>  projList = findByProperty(ProjWageEntity.class, "yearmonth", beforeMonth);
		try {
			deleteAllEntitie(projList);
			super.batchSave(projWagelist.getResults());
			LogUtil.info("===============项目工资统计表保存成功=================");
		} catch (Exception e) {
			LogUtil.info("===============项目工资统计表保存失败=================");
		}
		LogUtil.info("===============工资统计定时任务结束=================");
		
	}

	
 	
}