| | |
|---|
| | | import com.smartor.mapper.ServiceTaskMapper; |
|---|
| | | import com.smartor.mapper.SysUserImportMapper; |
|---|
| | | import com.smartor.service.*; |
|---|
| | | import com.sun.org.apache.bcel.internal.generic.NEW; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.commons.collections4.CollectionUtils; |
|---|
| | | import org.apache.commons.lang3.ObjectUtils; |
|---|
| | |
|---|
| | | public void dealHisData2() { |
|---|
| | | //将患者信息、出院、门诊数据全部采集 |
|---|
| | | // 指定的开始日期 |
|---|
| | | LocalDate endDate = LocalDate.of(2024, 9, 1); |
|---|
| | | LocalDate endDate = LocalDate.of(2025, 3, 3); |
|---|
| | | // 当前日期 |
|---|
| | | LocalDate currentDate = LocalDate.now(); |
|---|
| | | // 定义日期格式 |
|---|
| | |
|---|
| | | //如何任务被“暂停”或“终止” |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | if (org.apache.commons.lang3.StringUtils.isEmpty(serviceSubtask.getPhone())) { |
|---|
| | | serviceSubtask.setRemark("手机号为空"); |
|---|
| | | serviceSubtask.setSendstate(4L); |
|---|
| | | serviceSubtask.setResult("error"); |
|---|
| | | serviceSubtask.setFinishtime(new Date()); |
|---|
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | boolean dateToday = isDateToday(serviceSubtask.getLongSendTime()); |
|---|
| | | //说明是立即发送(先把消息放到cache-0中， displayNo不知道怎么配置) |
|---|
| | | if (dateToday) { |
|---|
| | |
|---|
| | | //将子任务ID删除 、sendstate改成3 |
|---|
| | | serviceSubtask.setSendstate(3L); |
|---|
| | | serviceSubtask.setId(null); |
|---|
| | | serviceSubtask.setFinishtime(null); |
|---|
| | | serviceSubtask.setCreateTime(new Date()); |
|---|
| | | serviceSubtask.setUpdateTime(new Date()); |
|---|
| | | serviceSubtaskMapper.insertServiceSubtask(serviceSubtask); |
|---|
| | | //处理重复新增问题，先查一下今天是不是有新增过，新增过就不新增了 |
|---|
| | | ServiceSubtaskVO ssvo = new ServiceSubtaskVO(); |
|---|
| | | LocalDate today = LocalDate.now(); |
|---|
| | | LocalTime startOfDay = LocalTime.of(0, 0, 0); |
|---|
| | | LocalTime endOfDay = LocalTime.of(23, 59, 59); |
|---|
| | | Date startOfDayDate = Date.from(today.atTime(startOfDay).atZone(ZoneId.systemDefault()).toInstant()); |
|---|
| | | Date endOfDayDate = Date.from(today.atTime(endOfDay).atZone(ZoneId.systemDefault()).toInstant()); |
|---|
| | | ssvo.setCreateStartTime(startOfDayDate); |
|---|
| | | ssvo.setCreateEndTime(endOfDayDate); |
|---|
| | | ssvo.setCreateBy(serviceSubtask.getCreateBy()); |
|---|
| | | ssvo.setSendname(serviceSubtask.getSendname()); |
|---|
| | | ssvo.setSfzh(serviceSubtask.getSfzh()); |
|---|
| | | List<ServiceSubtask> serviceSubtaskListByCreateTime = serviceSubtaskMapper.selectServiceSubtaskListByCreateTime(ssvo); |
|---|
| | | if (CollectionUtils.isEmpty(serviceSubtaskListByCreateTime)) |
|---|
| | | serviceSubtaskMapper.insertServiceSubtask(serviceSubtask); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else if (descByCode.equals("短信")) { |
|---|
| | |
|---|
| | | String filename = null; |
|---|
| | | if (cry.equals("0")) filename = "入院信息" + System.currentTimeMillis(); |
|---|
| | | if (cry.equals("1")) filename = "出院信息" + System.currentTimeMillis(); |
|---|
| | | File file = new File("D:\\public\\华卓集成平台数据\\" + filename); |
|---|
| | | File file = new File("D:\\public\\HIS数据采集\\" + filename); |
|---|
| | | if (!file.exists()) { |
|---|
| | | // 如果文件不存在，则创建新文件 |
|---|
| | | try { |
|---|
| | |
|---|
| | | patMedInhosp.setNurseId(thiedInhospInfo.getNurseId()); |
|---|
| | | patMedInhosp.setNurseName(thiedInhospInfo.getNurseName()); |
|---|
| | | patMedInhosp.setSerialnum(thiedInhospInfo.getInpatientId()); |
|---|
| | | patMedInhosp.setFuflag("1"); |
|---|
| | | if (cry.equals("0")) { |
|---|
| | | patMedInhosp.setInhospstate("0"); |
|---|
| | | } else if (cry.equals("1")) { |
|---|
