liusheng
2024-04-24 01c9667cfb06970564e837dc343d5cee0eb3aed7
smartor/src/main/java/com/smartor/service/impl/HeTaskServiceImpl.java
@@ -1,6 +1,6 @@
package com.smartor.service.impl;
import com.ruoyi.common.enums.SendTypeEnum;
import com.google.gson.Gson;
import com.ruoyi.common.exception.base.BaseException;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.DtoConversionUtils;
@@ -8,7 +8,7 @@
import com.smartor.domain.*;
import com.smartor.mapper.HeTaskMapper;
import com.smartor.mapper.PatArchiveMapper;
import com.smartor.mapper.PatHetaskRelevanceMapper;
import com.smartor.mapper.PatTaskRelevanceMapper;
import com.smartor.service.IHeTaskService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
@@ -19,8 +19,6 @@
import java.util.ArrayList;
import java.util.List;
import java.util.Timer;
import java.util.TimerTask;
/**
 * 宣教任务Service业务层处理
@@ -44,7 +42,7 @@
    private HeLibraryServiceImpl heLibraryService;
    @Autowired
    private PatHetaskRelevanceMapper patHetaskRelevanceMapper;
    private PatTaskRelevanceMapper PatTaskRelevanceMapper;
    @Autowired
    private SendService sendService;
@@ -85,19 +83,19 @@
    /**
     * 查询宣教任务列表
     *
     * @param patHetaskRelevanceVO 宣教任务
     * @param patTaskRelevanceVO 宣教任务
     * @return 宣教任务
     */
    @Override
    public List<PatHetaskRelevanceVO> selectHeTaskList(PatHetaskRelevanceVO patHetaskRelevanceVO) {
        PatHetaskRelevance patHetaskRelevance = new PatHetaskRelevance();
        List<PatHetaskRelevance> patHetaskRelevances = patHetaskRelevanceMapper.selectPatHetaskRelevanceList(patHetaskRelevance);
        List<PatHetaskRelevanceVO> patHetaskRelevanceVOS = DtoConversionUtils.sourceToTarget(patHetaskRelevances, PatHetaskRelevanceVO.class);
        for (PatHetaskRelevanceVO patHetaskRelevanceVO1 : patHetaskRelevanceVOS) {
            HeTask heTask1 = heTaskMapper.selectHeTaskById(patHetaskRelevanceVO1.getHeTaskId());
            patHetaskRelevanceVO1.setHeTask(heTask1);
    public List<PatTaskRelevanceVO> selectHeTaskList(PatTaskRelevanceVO patTaskRelevanceVO) {
        PatTaskRelevance patTaskRelevance = new PatTaskRelevance();
        List<PatTaskRelevance> patTaskRelevances = PatTaskRelevanceMapper.selectPatTaskRelevanceList(patTaskRelevance);
        List<PatTaskRelevanceVO> PatTaskRelevanceVOS = DtoConversionUtils.sourceToTarget(patTaskRelevances, PatTaskRelevanceVO.class);
        for (PatTaskRelevanceVO patTaskRelevanceVO1 : PatTaskRelevanceVOS) {
            HeTask heTask1 = heTaskMapper.selectHeTaskById(patTaskRelevanceVO1.getTaskId());
            patTaskRelevanceVO1.setHeTask(heTask1);
        }
        return patHetaskRelevanceVOS;
        return PatTaskRelevanceVOS;
    }
    /**
@@ -115,11 +113,11 @@
//        if (heTaskVO.getIsSend() == 2) {
//            //发送方式
//            String sendtype = SendTypeEnum.getDescByCode(heTaskVO.getPreachform().intValue());
//            for (PatHetaskRelevance patHetaskRelevance : heTaskVO.getPatHetaskRelevances()) {
//            for (PatTaskRelevance PatTaskRelevance : heTaskVO.getPatTaskRelevances()) {
//                //开始发送
//                SendMagParam sendMagParam = new SendMagParam();
//                sendMagParam.setType(sendtype);
//                sendMagParam.setPhone(patHetaskRelevance.getPhone());
//                sendMagParam.setPhone(PatTaskRelevance.getPhone());
//                //这里的模板ID不确定,先这样写
//                sendMagParam.setTmpCode("SMS_461860582");
//                sendMagParam.setContent("Test发送数据");
@@ -129,7 +127,7 @@
//                }
//
//                //必须全部成功,才能修改发送状态
//                if (heTaskVO.getPatHetaskRelevances().size() == integer) {
//                if (heTaskVO.getPatTaskRelevances().size() == integer) {
//                    //如果发送成功
//                    heTaskVO.setSendState(1L);
//                }
@@ -141,10 +139,10 @@
//
//            //将任务与患者关联
//            Integer i = null;
//            if (ObjectUtils.isNotEmpty(heTaskVO.getPatHetaskRelevances())) {
//                for (PatHetaskRelevance patHetaskRelevance : heTaskVO.getPatHetaskRelevances()) {
//                    patHetaskRelevance.setHeTaskId(heTask.getId());
//                    i = patHetaskRelevanceMapper.insertPatHetaskRelevance(patHetaskRelevance);
//            if (ObjectUtils.isNotEmpty(heTaskVO.getPatTaskRelevances())) {
//                for (PatTaskRelevance PatTaskRelevance : heTaskVO.getPatTaskRelevances()) {
//                    PatTaskRelevance.setHeTaskId(heTask.getId());
//                    i = PatTaskRelevanceMapper.insertPatTaskRelevance(PatTaskRelevance);
//                }
//
//            }
@@ -156,11 +154,11 @@
//                @Override
//                public void run() {
//                    Integer integer = 0;
//                    for (PatHetaskRelevance patHetaskRelevance : heTaskVO.getPatHetaskRelevances()) {
//                    for (PatTaskRelevance PatTaskRelevance : heTaskVO.getPatTaskRelevances()) {
//                        String sendtype = SendTypeEnum.getDescByCode(heTaskVO.getPreachform().intValue());
//                        SendMagParam sendMagParam = new SendMagParam();
//                        sendMagParam.setType(sendtype);
//                        sendMagParam.setPhone(patHetaskRelevance.getPhone());
//                        sendMagParam.setPhone(PatTaskRelevance.getPhone());
//                        //这里的模板ID不确定,先这样写
//                        sendMagParam.setTmpCode("SMS_461860582");
//                        sendMagParam.setContent("Test发送数据");
@@ -170,7 +168,7 @@
//                        }
//                    }
//                    //必须全部成功,才能修改发送状态
//                    if (heTaskVO.getPatHetaskRelevances().size() == integer) {
//                    if (heTaskVO.getPatTaskRelevances().size() == integer) {
//                        //如果发送成功
//                        heTaskVO.setSendState(1L);
//                    }
@@ -178,10 +176,10 @@
//                    heTask.setCreateTime(DateUtils.getNowDate());
//                    heTaskMapper.insertHeTask(heTask);
//
//                    if (ObjectUtils.isNotEmpty(heTaskVO.getPatHetaskRelevances())) {
//                        for (PatHetaskRelevance patHetaskRelevance : heTaskVO.getPatHetaskRelevances()) {
//                            patHetaskRelevance.setHeTaskId(heTask.getId());
//                            patHetaskRelevanceMapper.insertPatHetaskRelevance(patHetaskRelevance);
//                    if (ObjectUtils.isNotEmpty(heTaskVO.getPatTaskRelevances())) {
//                        for (PatTaskRelevance PatTaskRelevance : heTaskVO.getPatTaskRelevances()) {
//                            PatTaskRelevance.setHeTaskId(heTask.getId());
//                            PatTaskRelevanceMapper.insertPatTaskRelevance(PatTaskRelevance);
//                        }
//
//                    }
@@ -210,13 +208,18 @@
            //将任务信息新增到宣教任务表中
            HeTask heTask = DtoConversionUtils.sourceToTarget(heTaskVO, HeTask.class);
            heTask.setCreateTime(DateUtils.getNowDate());
            heTask.setPreachform(new Gson().toJson(heTaskVO.getPreachform()));
            heTask.setTextParam(new Gson().toJson(heTaskVO.getTextParam()));
            heTaskMapper.insertHeTask(heTask);
            integer = heTask.getId().intValue();
            //新增
            for (PatHetaskRelevance patHetaskRelevance : heTaskVO.getPatHetaskRelevances()) {
                patHetaskRelevance.setHeTaskId(heTask.getId());
                patHetaskRelevanceMapper.insertPatHetaskRelevance(patHetaskRelevance);
            if (CollectionUtils.isNotEmpty(heTaskVO.getPatTaskRelevances())) {
                for (PatTaskRelevance PatTaskRelevance : heTaskVO.getPatTaskRelevances()) {
                    PatTaskRelevance.setTaskId(heTask.getId());
                    PatTaskRelevanceMapper.insertPatTaskRelevance(PatTaskRelevance);
                }
            }
        } else if (heTaskVO.getIsoperation() != null && heTaskVO.getIsoperation() == 2) {
@@ -224,14 +227,14 @@
            heTask.setUpdateTime(DateUtils.getNowDate());
            heTaskMapper.updateHeTask(heTask);
            //新增、删除、修改患者信息
            for (PatHetaskRelevance patHetaskRelevance : heTaskVO.getPatHetaskRelevances()) {
                if (patHetaskRelevance.getIsoperation() != null && patHetaskRelevance.getIsoperation() == 1) {
                    patHetaskRelevanceMapper.insertPatHetaskRelevance(patHetaskRelevance);
                } else if (patHetaskRelevance.getIsoperation() != null && patHetaskRelevance.getIsoperation() == 2) {
                    patHetaskRelevance.setHeTaskId(heTask.getId());
                    patHetaskRelevanceMapper.updatePatHetaskRelevance(patHetaskRelevance);
                } else if (patHetaskRelevance.getIsoperation() != null && patHetaskRelevance.getIsoperation() == 3) {
                    patHetaskRelevanceMapper.deletePatHetaskRelevanceById(patHetaskRelevance.getId());
            for (PatTaskRelevance PatTaskRelevance : heTaskVO.getPatTaskRelevances()) {
                if (PatTaskRelevance.getIsoperation() != null && PatTaskRelevance.getIsoperation() == 1) {
                    PatTaskRelevanceMapper.insertPatTaskRelevance(PatTaskRelevance);
                } else if (PatTaskRelevance.getIsoperation() != null && PatTaskRelevance.getIsoperation() == 2) {
                    PatTaskRelevance.setTaskId(heTask.getId());
                    PatTaskRelevanceMapper.updatePatTaskRelevance(PatTaskRelevance);
                } else if (PatTaskRelevance.getIsoperation() != null && PatTaskRelevance.getIsoperation() == 3) {
                    PatTaskRelevanceMapper.deletePatTaskRelevanceById(PatTaskRelevance.getId());
                }
            }
            integer = heTask.getId().intValue();
@@ -239,9 +242,9 @@
            heTaskMapper.deleteHeTaskById(heTaskVO.getId());
            //删除患者信息
            for (PatHetaskRelevance patHetaskRelevance : heTaskVO.getPatHetaskRelevances()) {
                if (patHetaskRelevance.getIsoperation() != null && patHetaskRelevance.getIsoperation() == 3) {
                    patHetaskRelevanceMapper.deletePatHetaskRelevanceById(patHetaskRelevance.getId());
            for (PatTaskRelevance PatTaskRelevance : heTaskVO.getPatTaskRelevances()) {
                if (PatTaskRelevance.getIsoperation() != null && PatTaskRelevance.getIsoperation() == 3) {
                    PatTaskRelevanceMapper.deletePatTaskRelevanceById(PatTaskRelevance.getId());
                }
            }
            integer = heTaskVO.getId().intValue();
@@ -295,8 +298,8 @@
     * @return
     */
    @Override
    public List<PatHetaskRelevance> getPatientInfo(PatArchiveReq patArchiveReq) {
        List<PatHetaskRelevance> patHetaskRelevances = new ArrayList<>();
    public List<PatTaskRelevance> getPatientInfo(PatArchiveReq patArchiveReq) {
        List<PatTaskRelevance> PatTaskRelevances = new ArrayList<>();
        List<PatArchive> patArchiveList = new ArrayList<>();
        if (patArchiveReq.getAllhosp() != null && patArchiveReq.getAllhosp() == 1) {
@@ -319,13 +322,14 @@
            }
        }
        for (PatArchive patArchive : patArchiveList) {
            PatHetaskRelevance patHetaskRelevance = DtoConversionUtils.sourceToTarget(patArchive, PatHetaskRelevance.class);
            patHetaskRelevance.setCreateTime(patArchive.getCreateTime());
            patHetaskRelevance.setCreateBy(patArchive.getCreateBy());
            patHetaskRelevances.add(patHetaskRelevance);
            PatTaskRelevance patTaskRelevance = DtoConversionUtils.sourceToTarget(patArchive, PatTaskRelevance.class);
            patTaskRelevance.setCreateTime(patArchive.getCreateTime());
            patTaskRelevance.setCreateBy(patArchive.getCreateBy());
            patTaskRelevance.setDeptName(patArchive.getDept());
            PatTaskRelevances.add(patTaskRelevance);
        }
        return patHetaskRelevances;
        return PatTaskRelevances;
    }
}