package cn.besteam.modules.medical.job;

import cn.besteam.modules.medical.entity.MwDataStatistics;
import cn.besteam.modules.medical.mapper.MwDataStatisticsMapper;
import cn.besteam.modules.system.entity.SysDepartment;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.Map;


@Component
@Configurable
//@EnableScheduling
@EnableAsync
public class insertDataStatisticsJob {

	@Autowired
	MwDataStatisticsMapper dataStatisticsMapper;

	/**
	 *  select * from sys_department where del_flag=0 and org_type=1
	 * and id not in (select parent_id from sys_department where del_flag=0 and org_type=1)
	 *  定时生成大屏数据
	 * @throws Exception
	 */
	@Async
	//@Scheduled(cron = "0 0/10 * * * ? ")
	@Scheduled(cron = "0 0 0 1 * ?")
	public void addDataStatistics() throws Exception {

		/*List<SysDepartment> sysDepartments=dataStatisticsMapper.getAreaDepartment();
		for(SysDepartment sysDepartment:sysDepartments){
			*//*根据县级获取医院数和预警数据统计数据*//*

			List<Map<String,Object>> WarningRecordCount=dataStatisticsMapper.getWarningRecordCount(sysDepartment.getId());
			//医院数
			Integer hospitals=Integer.valueOf(WarningRecordCount.get(0).get("number").toString());
			//未出医废预警
			Integer warningWithout=Integer.valueOf(WarningRecordCount.get(1).get("number").toString());
			//入库超时预警
			Integer warningTimeoutPut=Integer.valueOf(WarningRecordCount.get(2).get("number").toString());
			//出库超时预警
			Integer warningTimeoutOut=Integer.valueOf(WarningRecordCount.get(3).get("number").toString());
			//遗失预警
			Integer warningMissing=Integer.valueOf(WarningRecordCount.get(4).get("number").toString());
			*//*根据县级获取收集统计数据*//*

			List<Map<String,Object>> CollectRecordSum=dataStatisticsMapper.getCollectRecordSum(sysDepartment.getId());
			//收集总数量
			Integer totalNumber=Double.valueOf(CollectRecordSum.get(0).get("sums").toString()).intValue();
			//收集重量
			BigDecimal totalWeight=new BigDecimal(CollectRecordSum.get(1).get("sums").toString());
			//未入库重量
			BigDecimal weightNotput=new BigDecimal(CollectRecordSum.get(2).get("sums").toString());
			//未出库重量
			BigDecimal weightNotout=new BigDecimal(CollectRecordSum.get(3).get("sums").toString());
			//今日收集重量
			BigDecimal todayWeight=new BigDecimal(CollectRecordSum.get(4).get("sums").toString());
			//今日入库重量
			BigDecimal todayWeightPut=new BigDecimal(CollectRecordSum.get(5).get("sums").toString());
			//今日出库重量
			BigDecimal todayWeightOut=new BigDecimal(CollectRecordSum.get(6).get("sums").toString());
			//今日未入库重量
			BigDecimal todayWeightNotput=new BigDecimal(CollectRecordSum.get(7).get("sums").toString());
			//今日未出库重量
			BigDecimal todayWeightNotout=new BigDecimal(CollectRecordSum.get(8).get("sums").toString());
			*//* 七日数据集合(总数据)*//*

			List<Map<String,Object>> CollectRecordDays7Total=dataStatisticsMapper.getCollectRecordDays7(sysDepartment.getId(),"");
			String sevendaysWeightAnalyse="";
			if(CollectRecordDays7Total!=null && CollectRecordDays7Total.size()>0){
				sevendaysWeightAnalyse=CollectRecordDays7Total.toString();
			}
			*//*七日数据集合(入库)*//*

			List<Map<String,Object>> CollectRecordDays7Put=dataStatisticsMapper.getCollectRecordDays7(sysDepartment.getId(),"2,3");
			String sevendaysWeightAnalysePut="";
			if(CollectRecordDays7Put!=null && CollectRecordDays7Put.size()>0){
				sevendaysWeightAnalysePut=CollectRecordDays7Put.toString();
			}
			*//*七日数据集合(出库)*//*

			List<Map<String,Object>> CollectRecordDays7Out=dataStatisticsMapper.getCollectRecordDays7(sysDepartment.getId(),"3");
			String sevendaysWeightAnalyseOut="";
			if(CollectRecordDays7Out!=null && CollectRecordDays7Out.size()>0){
				sevendaysWeightAnalyseOut=CollectRecordDays7Out.toString();
			}
			MwDataStatistics mwDataStatistics=new MwDataStatistics();
			mwDataStatistics.setDepartmentId(sysDepartment.getId());
			mwDataStatistics.setPredepartmentId(sysDepartment.getParentId());
			mwDataStatistics.setHospitals(hospitals);
			mwDataStatistics.setTotalWeight(totalWeight);
			mwDataStatistics.setTotalNumber(totalNumber);
			mwDataStatistics.setTodayWeight(todayWeight);
			mwDataStatistics.setTodayWeightPut(todayWeightPut);
			mwDataStatistics.setTodayWeightOut(todayWeightOut);
			mwDataStatistics.setWeightNotout(weightNotout);
			mwDataStatistics.setWeightNotput(weightNotput);
			mwDataStatistics.setWarningWithout(warningWithout);
			mwDataStatistics.setWarningTimeoutPut(warningTimeoutPut);
			mwDataStatistics.setWarningTimeoutOut(warningTimeoutOut);
			mwDataStatistics.setWarningMissing(warningMissing);
			mwDataStatistics.setSevendaysWeightAnalyse(sevendaysWeightAnalyse);
			mwDataStatistics.setSevendaysWeightAnalysePut(sevendaysWeightAnalysePut);
			mwDataStatistics.setSevendaysWeightAnalyseOut(sevendaysWeightAnalyseOut);
			mwDataStatistics.setTodayWeightNotout(todayWeightNotout);
			mwDataStatistics.setTodayWeightNotput(todayWeightNotput);
			MwDataStatistics mwDataStatistics_=dataStatisticsMapper.selectOne(new QueryWrapper<MwDataStatistics>().eq("department_id",sysDepartment.getId()));
			if(mwDataStatistics_!=null){
				mwDataStatistics.setId(mwDataStatistics_.getId());
				mwDataStatistics.setCreateTime(new Date());
				dataStatisticsMapper.updateById(mwDataStatistics);
			}else {
				mwDataStatistics.setCreateTime(new Date());
				dataStatisticsMapper.insert(mwDataStatistics);
			}
		}*/
	}

}