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);
|
}
|
}*/
|
}
|
|
}
|
