Compare commits
2 Commits
94ad896335
...
f11c42defc
| Author | SHA1 | Date |
|---|---|---|
 wzz
|
f11c42defc | 8 months ago |
|
wzz
|
e114c2bd87 | 8 months ago |
10 changed files with 241 additions and 243 deletions
@ -1,211 +1,211 @@ |
|||||
package com.acupuncture.web.controller.web; |
//package com.acupuncture.web.controller.web;
|
||||
|
//
|
||||
import cn.hutool.core.bean.BeanUtil; |
//import cn.hutool.core.bean.BeanUtil;
|
||||
import cn.hutool.core.collection.CollectionUtil; |
//import cn.hutool.core.collection.CollectionUtil;
|
||||
import cn.hutool.core.date.DateUtil; |
//import cn.hutool.core.date.DateUtil;
|
||||
import cn.hutool.core.util.IdUtil; |
//import cn.hutool.core.util.IdUtil;
|
||||
import com.acupuncture.common.annotation.Anonymous; |
//import com.acupuncture.common.annotation.Anonymous;
|
||||
import com.acupuncture.framework.datasource.DynamicDataSourceContextHolder; |
//import com.acupuncture.framework.datasource.DynamicDataSourceContextHolder;
|
||||
import com.acupuncture.system.domain.po.FmsFollowupTask; |
//import com.acupuncture.system.domain.po.FmsFollowupTask;
|
||||
import com.acupuncture.system.domain.po.FmsPatientQueueRelation; |
//import com.acupuncture.system.domain.po.FmsPatientQueueRelation;
|
||||
import com.acupuncture.system.domain.vo.FmsFollowupVo; |
//import com.acupuncture.system.domain.vo.FmsFollowupVo;
|
||||
import com.acupuncture.system.domain.vo.UmsDataSourceVo; |
//import com.acupuncture.system.domain.vo.UmsDataSourceVo;
|
||||
import com.acupuncture.system.persist.dao.FmsFollowupDao; |
//import com.acupuncture.system.persist.dao.FmsFollowupDao;
|
||||
import com.acupuncture.system.persist.dao.UmsDataSourceDao; |
//import com.acupuncture.system.persist.dao.UmsDataSourceDao;
|
||||
import com.acupuncture.system.persist.mapper.FmsFollowupTaskMapper; |
//import com.acupuncture.system.persist.mapper.FmsFollowupTaskMapper;
|
||||
import com.acupuncture.system.persist.mapper.FmsPatientQueueRelationMapper; |
//import com.acupuncture.system.persist.mapper.FmsPatientQueueRelationMapper;
|
||||
import io.swagger.annotations.Api; |
//import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation; |
//import io.swagger.annotations.ApiOperation;
|
||||
import lombok.extern.slf4j.Slf4j; |
//import lombok.extern.slf4j.Slf4j;
|
||||
import org.quartz.TriggerUtils; |
//import org.quartz.TriggerUtils;
|
||||
import org.quartz.impl.triggers.CronTriggerImpl; |
//import org.quartz.impl.triggers.CronTriggerImpl;
|
||||
import org.springframework.scheduling.annotation.Scheduled; |
//import org.springframework.scheduling.annotation.Scheduled;
|
||||
import org.springframework.transaction.annotation.Propagation; |
//import org.springframework.transaction.annotation.Propagation;
|
||||
import org.springframework.transaction.annotation.Transactional; |
//import org.springframework.transaction.annotation.Transactional;
|
||||
import org.springframework.web.bind.annotation.PostMapping; |
//import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RequestMapping; |
//import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController; |
//import org.springframework.web.bind.annotation.RestController;
|
||||
|
//
|
||||
import javax.annotation.Resource; |
//import javax.annotation.Resource;
|
||||
import java.util.ArrayList; |
//import java.util.ArrayList;
|
||||
import java.util.Calendar; |
//import java.util.Calendar;
|
||||
import java.util.Date; |
//import java.util.Date;
|
||||
import java.util.List; |
//import java.util.List;
|
||||
|
//
|
||||
/** |
///**
|
||||
* @Author zzc |
// * @Author zzc
|
||||
* @Package com.acupuncture.web.controller.web |
// * @Package com.acupuncture.web.controller.web
|
||||
* @Date 2025/2/13 8:50 |
// * @Date 2025/2/13 8:50
|
||||
* @description: |
// * @description:
|
||||
*/ |
// */
|
||||
@Slf4j |
//@Slf4j
|
||||
@Api(tags = "定时任务相关") |
//@Api(tags = "定时任务相关")
|
||||
@RestController |
//@RestController
|
||||
@RequestMapping("/task") |
//@RequestMapping("/task")
|
||||
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class) |
//@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
|
||||
public class TaskController { |
//public class TaskController {
|
||||
|
//
|
||||
@Resource |
// @Resource
|
||||
private FmsFollowupDao fmsFollowupDao; |
// private FmsFollowupDao fmsFollowupDao;
|
||||
@Resource |
// @Resource
|
||||
private FmsFollowupTaskMapper fmsFollowupTaskMapper; |
// private FmsFollowupTaskMapper fmsFollowupTaskMapper;
|
||||
@Resource |
// @Resource
|
||||
private UmsDataSourceDao umsDataSourceDao; |
// private UmsDataSourceDao umsDataSourceDao;
|
||||
@Resource |
// @Resource
|
||||
private FmsPatientQueueRelationMapper fmsPatientQueueRelationMapper; |
// private FmsPatientQueueRelationMapper fmsPatientQueueRelationMapper;
|
||||
|
//
|
||||
@ApiOperation("定时任务添加随访工单") |
// @ApiOperation("定时任务添加随访工单")
|
||||
@PostMapping("/task") |
// @PostMapping("/task")
|
||||
// @Scheduled(fixedRate = 10000)
|
//// @Scheduled(fixedRate = 10000)
|
||||
@Anonymous |
// @Anonymous
|
||||
public void task() { |
// public void task() {
|
||||
// TODO 生成工单第一次生成之后2周的，往后只生成之后一周。第一次随访时间： （ 患者的出院时间 - 7 + 轮次时间） 到 （患者的出院时间 + 7 + 轮次时间 ）
|
// // TODO 生成工单第一次生成之后2周的，往后只生成之后一周。第一次随访时间： （ 患者的出院时间 - 7 + 轮次时间） 到 （患者的出院时间 + 7 + 轮次时间 ）
|
||||
|
//
|
||||
//查询租户，根据租户循环切换数据源，定时处理所有医院的随访工单
|
// //查询租户，根据租户循环切换数据源，定时处理所有医院的随访工单
|
||||
// UmsDataSourceVo.Result result1 = new UmsDataSourceVo.Result();
|
//// UmsDataSourceVo.Result result1 = new UmsDataSourceVo.Result();
|
||||
// result1.setDataSourceKey("MASTER");
|
//// result1.setDataSourceKey("MASTER");
|
||||
// changeDataSource(result1);
|
//// changeDataSource(result1);
|
||||
List<UmsDataSourceVo.Result> query = umsDataSourceDao.query(null); |
// List<UmsDataSourceVo.Result> query = umsDataSourceDao.query(null);
|
||||
if (CollectionUtil.isEmpty(query)) { |
// if (CollectionUtil.isEmpty(query)) {
|
||||
return; |
// return;
|
||||
} |
// }
|
||||
//查询公共队列
|
// //查询公共队列
|
||||
List<FmsFollowupVo.FollowupQueueVO> queueResults = fmsFollowupDao.queryCommonQueue(null); |
// List<FmsFollowupVo.FollowupQueueVO> queueResults = fmsFollowupDao.queryCommonQueue(null);
|
||||
//切换数据源
|
// //切换数据源
|
||||
for (UmsDataSourceVo.Result result : query) { |
// for (UmsDataSourceVo.Result result : query) {
|
||||
if ("MASTER".equals(result.getDataSourceKey())) { |
// if ("MASTER".equals(result.getDataSourceKey())) {
|
||||
continue; |
// continue;
|
||||
} |
// }
|
||||
changeDataSource(result); |
// changeDataSource(result);
|
||||
{ |
// {
|
||||
//获取随访患者列表，根据患者出院日时间和队列添加工单
|
// //获取随访患者列表，根据患者出院日时间和队列添加工单
|
||||
//1. 查询队列
|
// //1. 查询队列
|
||||
List<FmsFollowupVo.FollowupQueueVO> queueList = fmsFollowupDao.selectQueueList(null, null, null, result.getTenantId()); |
// List<FmsFollowupVo.FollowupQueueVO> queueList = fmsFollowupDao.selectQueueList(null, null, null, result.getTenantId());
|
||||
|
//
|
||||
if (CollectionUtil.isEmpty(queueList)) { |
// if (CollectionUtil.isEmpty(queueList)) {
|
||||
queueList = queueResults; |
// queueList = queueResults;
|
||||
} else { |
// } else {
|
||||
queueList.addAll(queueResults); |
// queueList.addAll(queueResults);
|
||||
} |
// }
|
||||
for (FmsFollowupVo.FollowupQueueVO followupQueueVO : queueList) { |
// for (FmsFollowupVo.FollowupQueueVO followupQueueVO : queueList) {
|
||||
//2. 查询队列随访患者列表
|
// //2. 查询队列随访患者列表
|
||||
List<FmsFollowupVo.FollowupPatient> patientList = fmsFollowupDao.queryPatient(followupQueueVO.getId(), (byte) 0, null, followupQueueVO.getTenantId()); |
// List<FmsFollowupVo.FollowupPatient> patientList = fmsFollowupDao.queryPatient(followupQueueVO.getId(), (byte) 0, null, followupQueueVO.getTenantId());
|
||||
if (CollectionUtil.isEmpty(patientList)) { |
// if (CollectionUtil.isEmpty(patientList)) {
|
||||
continue; |
// continue;
|
||||
} |
// }
|
||||
//随访总月数
|
// //随访总月数
|
||||
Integer followupMonth = followupQueueVO.getFollowupMonth(); |
// Integer followupMonth = followupQueueVO.getFollowupMonth();
|
||||
for (FmsFollowupVo.FollowupPatient followupPatient : patientList) { |
// for (FmsFollowupVo.FollowupPatient followupPatient : patientList) {
|
||||
//获取随访到期时间 出院时间+随访总月数 = 到期时间
|
// //获取随访到期时间 出院时间+随访总月数 = 到期时间
|
||||
Calendar calendar = Calendar.getInstance(); |
// Calendar calendar = Calendar.getInstance();
|
||||
calendar.setTime(followupPatient.getDischargeTime()); |
// calendar.setTime(followupPatient.getDischargeTime());
|
||||
calendar.set(Calendar.MONTH, followupMonth); |
// calendar.set(Calendar.MONTH, followupMonth);
|
||||
Date time = calendar.getTime(); |
// Date time = calendar.getTime();
|
||||
|
//
|
||||
//获取队列信息
|
// //获取队列信息
|
||||
String frequency = followupQueueVO.getFrequency(); |
// String frequency = followupQueueVO.getFrequency();
|
||||
List<Date> dateList = new ArrayList<>(); |
// List<Date> dateList = new ArrayList<>();
|
||||
try { |
// try {
|
||||
CronTriggerImpl cronTrigger = new CronTriggerImpl(); |
// CronTriggerImpl cronTrigger = new CronTriggerImpl();
|
||||
cronTrigger.setCronExpression(frequency); |
// cronTrigger.setCronExpression(frequency);
|
||||
//TriggerUtils.computeFireTimesBetween(要计算触发时间的触发器对象, 用于计算触发时间的日历对象, 计算触发时间的起始时间点, 计算触发时间的结束时间点);
|
// //TriggerUtils.computeFireTimesBetween(要计算触发时间的触发器对象, 用于计算触发时间的日历对象, 计算触发时间的起始时间点, 计算触发时间的结束时间点);
|
||||
dateList = TriggerUtils.computeFireTimesBetween(cronTrigger, null, followupPatient.getDischargeTime(), time); |
// dateList = TriggerUtils.computeFireTimesBetween(cronTrigger, null, followupPatient.getDischargeTime(), time);
|
||||
if (CollectionUtil.isEmpty(dateList)) { |
// if (CollectionUtil.isEmpty(dateList)) {
|
||||
continue; |
// continue;
|
||||
} |
// }
|
||||
} catch (Exception e) { |
// } catch (Exception e) {
|
||||
e.printStackTrace(); |
// e.printStackTrace();
|
||||
} |
// }
|
||||
//3. 判断随访类型
|
// //3. 判断随访类型
|
||||
if (followupQueueVO.getFollowupType() == 0) { |
// if (followupQueueVO.getFollowupType() == 0) {
|
||||
//单次
|
// //单次
|
||||
FmsFollowupTask fmsFollowupTask = new FmsFollowupTask(); |
// FmsFollowupTask fmsFollowupTask = new FmsFollowupTask();
|
||||
BeanUtil.copyProperties(followupQueueVO, fmsFollowupTask); |
// BeanUtil.copyProperties(followupQueueVO, fmsFollowupTask);
|
||||
fmsFollowupTask.setId(IdUtil.getSnowflakeNextId()); |
// fmsFollowupTask.setId(IdUtil.getSnowflakeNextId());
|
||||
fmsFollowupTask.setName(followupPatient.getName()); |
// fmsFollowupTask.setName(followupPatient.getName());
|
||||
fmsFollowupTask.setPinyinFull(followupPatient.getPinyinFull()); |
// fmsFollowupTask.setPinyinFull(followupPatient.getPinyinFull());
|
||||
fmsFollowupTask.setPinyinSimple(followupPatient.getPinyinSimple()); |
// fmsFollowupTask.setPinyinSimple(followupPatient.getPinyinSimple());
|
||||
fmsFollowupTask.setGender(followupPatient.getGender()); |
// fmsFollowupTask.setGender(followupPatient.getGender());
|
||||
if (followupPatient.getBirthDate() != null) { |
// if (followupPatient.getBirthDate() != null) {
|
||||
fmsFollowupTask.setAge(DateUtil.age(followupPatient.getBirthDate(), new Date())); |
// fmsFollowupTask.setAge(DateUtil.age(followupPatient.getBirthDate(), new Date()));
|
||||
} |
// }
|
||||
fmsFollowupTask.setEthnicity(followupPatient.getEthnicity()); |
// fmsFollowupTask.setEthnicity(followupPatient.getEthnicity());
|
||||
fmsFollowupTask.setEducationYears(followupPatient.getEducationYears()); |
// fmsFollowupTask.setEducationYears(followupPatient.getEducationYears());
|
||||
fmsFollowupTask.setPhone(followupPatient.getPhone()); |
// fmsFollowupTask.setPhone(followupPatient.getPhone());
|
||||
fmsFollowupTask.setTenantId(followupPatient.getTenantId()); |
// fmsFollowupTask.setTenantId(followupPatient.getTenantId());
|
||||
fmsFollowupTask.setIdCardType(followupPatient.getIdCardType()); |
// fmsFollowupTask.setIdCardType(followupPatient.getIdCardType());
|
||||
fmsFollowupTask.setIdCard(followupPatient.getIdCard()); |
// fmsFollowupTask.setIdCard(followupPatient.getIdCard());
|
||||
fmsFollowupTask.setTimes(1); |
// fmsFollowupTask.setTimes(1);
|
||||
fmsFollowupTask.setQueueId(followupQueueVO.getId()); |
// fmsFollowupTask.setQueueId(followupQueueVO.getId());
|
||||
fmsFollowupTask.setPatientId(followupPatient.getId()); |
// fmsFollowupTask.setPatientId(followupPatient.getId());
|
||||
fmsFollowupTask.setEducationYears(followupPatient.getEducationYears()); |
// fmsFollowupTask.setEducationYears(followupPatient.getEducationYears());
|
||||
fmsFollowupTask.setDelFlag((byte) 0); |
// fmsFollowupTask.setDelFlag((byte) 0);
|
||||
fmsFollowupTask.setCreateTime(new Date()); |
// fmsFollowupTask.setCreateTime(new Date());
|
||||
fmsFollowupTask.setStatus((byte) 0); |
// fmsFollowupTask.setStatus((byte) 0);
|
||||
fmsFollowupTask.setStartTime(dateList.get(0)); |
// fmsFollowupTask.setStartTime(dateList.get(0));
|
||||
fmsFollowupTask.setEndTime(dateList.get(0)); |
// fmsFollowupTask.setEndTime(dateList.get(0));
|
||||
fmsFollowupTask.setFollowuper(followupQueueVO.getPersonInCharge()); |
// fmsFollowupTask.setFollowuper(followupQueueVO.getPersonInCharge());
|
||||
fmsFollowupTask.setFollowupTime(dateList.get(0)); |
// fmsFollowupTask.setFollowupTime(dateList.get(0));
|
||||
changeDataSource(result); |
// changeDataSource(result);
|
||||
fmsFollowupTaskMapper.insertSelective(fmsFollowupTask); |
// fmsFollowupTaskMapper.insertSelective(fmsFollowupTask);
|
||||
|
//
|
||||
} else { |
// } else {
|
||||
//周期
|
// //周期
|
||||
//4. 根据频次和总月数添加
|
// //4. 根据频次和总月数添加
|
||||
int i = 0; |
// int i = 0;
|
||||
for (Date date : dateList) { |
// for (Date date : dateList) {
|
||||
i+=1; |
// i+=1;
|
||||
//单次
|
// //单次
|
||||
FmsFollowupTask fmsFollowupTask = new FmsFollowupTask(); |
// FmsFollowupTask fmsFollowupTask = new FmsFollowupTask();
|
||||
BeanUtil.copyProperties(followupQueueVO, fmsFollowupTask); |
// BeanUtil.copyProperties(followupQueueVO, fmsFollowupTask);
|
||||
fmsFollowupTask.setId(IdUtil.getSnowflakeNextId()); |
// fmsFollowupTask.setId(IdUtil.getSnowflakeNextId());
|
||||
fmsFollowupTask.setName(followupPatient.getName()); |
// fmsFollowupTask.setName(followupPatient.getName());
|
||||
fmsFollowupTask.setPinyinFull(followupPatient.getPinyinFull()); |
// fmsFollowupTask.setPinyinFull(followupPatient.getPinyinFull());
|
||||
fmsFollowupTask.setPinyinSimple(followupPatient.getPinyinSimple()); |
// fmsFollowupTask.setPinyinSimple(followupPatient.getPinyinSimple());
|
||||
fmsFollowupTask.setGender(followupPatient.getGender()); |
// fmsFollowupTask.setGender(followupPatient.getGender());
|
||||
if (followupPatient.getBirthDate() != null) { |
// if (followupPatient.getBirthDate() != null) {
|
||||
fmsFollowupTask.setAge(DateUtil.age(followupPatient.getBirthDate(), new Date())); |
// fmsFollowupTask.setAge(DateUtil.age(followupPatient.getBirthDate(), new Date()));
|
||||
} |
// }
|
||||
fmsFollowupTask.setEthnicity(followupPatient.getEthnicity()); |
// fmsFollowupTask.setEthnicity(followupPatient.getEthnicity());
|
||||
fmsFollowupTask.setEducationYears(followupPatient.getEducationYears()); |
// fmsFollowupTask.setEducationYears(followupPatient.getEducationYears());
|
||||
fmsFollowupTask.setTimes(i); |
// fmsFollowupTask.setTimes(i);
|
||||
fmsFollowupTask.setPhone(followupPatient.getPhone()); |
// fmsFollowupTask.setPhone(followupPatient.getPhone());
|
||||
fmsFollowupTask.setTenantId(followupPatient.getTenantId()); |
// fmsFollowupTask.setTenantId(followupPatient.getTenantId());
|
||||
fmsFollowupTask.setIdCardType(followupPatient.getIdCardType()); |
// fmsFollowupTask.setIdCardType(followupPatient.getIdCardType());
|
||||
fmsFollowupTask.setIdCard(followupPatient.getIdCard()); |
// fmsFollowupTask.setIdCard(followupPatient.getIdCard());
|
||||
fmsFollowupTask.setId(IdUtil.getSnowflakeNextId()); |
// fmsFollowupTask.setId(IdUtil.getSnowflakeNextId());
|
||||
fmsFollowupTask.setQueueId(followupQueueVO.getId()); |
// fmsFollowupTask.setQueueId(followupQueueVO.getId());
|
||||
fmsFollowupTask.setDelFlag((byte) 0); |
// fmsFollowupTask.setDelFlag((byte) 0);
|
||||
fmsFollowupTask.setCreateTime(new Date()); |
// fmsFollowupTask.setCreateTime(new Date());
|
||||
fmsFollowupTask.setEducationYears(followupPatient.getEducationYears()); |
// fmsFollowupTask.setEducationYears(followupPatient.getEducationYears());
|
||||
fmsFollowupTask.setStatus((byte) 0); |
// fmsFollowupTask.setStatus((byte) 0);
|
||||
fmsFollowupTask.setStartTime(date); |
// fmsFollowupTask.setStartTime(date);
|
||||
fmsFollowupTask.setEndTime(date); |
// fmsFollowupTask.setEndTime(date);
|
||||
fmsFollowupTask.setFollowuper(followupQueueVO.getPersonInCharge()); |
// fmsFollowupTask.setFollowuper(followupQueueVO.getPersonInCharge());
|
||||
fmsFollowupTask.setFollowupTime(date); |
// fmsFollowupTask.setFollowupTime(date);
|
||||
changeDataSource(result); |
// changeDataSource(result);
|
||||
fmsFollowupTask.setPatientId(followupPatient.getId()); |
// fmsFollowupTask.setPatientId(followupPatient.getId());
|
||||
fmsFollowupTaskMapper.insertSelective(fmsFollowupTask); |
// fmsFollowupTaskMapper.insertSelective(fmsFollowupTask);
|
||||
} |
// }
|
||||
} |
// }
|
||||
changeDataSource(result); |
// changeDataSource(result);
|
||||
//将患者设置为已生成工单
|
// //将患者设置为已生成工单
|
||||
FmsPatientQueueRelation fmsPatientQueueRelation = BeanUtil.copyProperties(followupPatient, FmsPatientQueueRelation.class); |
// FmsPatientQueueRelation fmsPatientQueueRelation = BeanUtil.copyProperties(followupPatient, FmsPatientQueueRelation.class);
|
||||
fmsPatientQueueRelation.setTaskFlag((byte) 1); |
// fmsPatientQueueRelation.setTaskFlag((byte) 1);
|
||||
fmsPatientQueueRelation.setPatientId(followupPatient.getId()); |
// fmsPatientQueueRelation.setPatientId(followupPatient.getId());
|
||||
fmsPatientQueueRelationMapper.updateByPrimaryKeySelective(fmsPatientQueueRelation); |
// fmsPatientQueueRelationMapper.updateByPrimaryKeySelective(fmsPatientQueueRelation);
|
||||
} |
// }
|
||||
} |
// }
|
||||
|
//
|
||||
} |
// }
|
||||
} |
// }
|
||||
} |
// }
|
||||
|
//
|
||||
private static void changeDataSource(UmsDataSourceVo.Result result) { |
// private static void changeDataSource(UmsDataSourceVo.Result result) {
|
||||
try { |
// try {
|
||||
DynamicDataSourceContextHolder.setDataSourceType(result.getDataSourceKey()); |
// DynamicDataSourceContextHolder.setDataSourceType(result.getDataSourceKey());
|
||||
}finally { |
// }finally {
|
||||
DynamicDataSourceContextHolder.clearDataSourceType(); |
// DynamicDataSourceContextHolder.clearDataSourceType();
|
||||
} |
// }
|
||||
} |
// }
|
||||
} |
//}
|
||||
|
|||||
Loading…
Reference in new issue