package com.ruoyi.task.mapper; import com.ruoyi.template.domain.VO.HeLibraryCountVO; import org.apache.ibatis.annotations.MapKey; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import java.util.Date; import java.util.List; import java.util.Map; import com.ruoyi.common.core.service.dto.PatMedReq; import com.ruoyi.common.core.service.dto.PatMedRes; import com.ruoyi.task.domain.entity.ServiceSubtaskEntity; import com.ruoyi.task.domain.ServiceStatisticsRequest; import com.ruoyi.task.domain.ServiceStatisticsResponse; import com.ruoyi.task.domain.ServiceSubtask; import com.ruoyi.task.domain.ServiceSubtaskCount; import com.ruoyi.task.domain.ServiceSubtaskCountReq; import com.ruoyi.task.domain.ServiceSubtaskScriptCount; import com.ruoyi.task.domain.ServiceSubtaskStatistic; import com.ruoyi.task.domain.VO.ServiceSubtaskCotinueCountVO; /** * 单一任务（随访）Mapper接口 * * @author ruoyi * @date 2024-02-02 */ @Mapper public interface ServiceSubtaskMapper { /** * 查询单一任务（随访） * * @param id 单一任务（随访）主键 * @return 单一任务（随访） */ public ServiceSubtask selectServiceSubtaskById(Long id); /** * 查询单一任务（随访）列表 *

* 入参 soonTimeout=1 且 soonTimeoutHours=N 时，仅返回“尚未超时、且将在 N 小时内超时”的数据， * 截止时间口径与 getCurrentUserServiceSubtaskCount 的 soonTimeoutCount 一致。 * * @param serviceSubtaskVO 单一任务（随访） * @return 单一任务（随访）集合 */ public List selectServiceSubtaskList(ServiceSubtaskEntity serviceSubtaskVO); /** * 分页第一阶段：只取当前页的子任务 id。 *

* where / order 与 {@link #selectServiceSubtaskList} 共用同一份 XML 片段 * （{@code serviceSubtaskWhere} / {@code serviceSubtaskOrderByPaged}）， * 保证两条语句口径一致，不会出现「第一阶段选出行、第二阶段又被过滤掉」。 *

* 之所以要单独一条：列表语句 select 约 100 列，深翻页时被 offset 跳过的每一行 * 都要回表读整行；而只取 id 的语句可以走覆盖索引并提前截断。 * * @param serviceSubtaskVO 查询条件（pageNum 是 offset、pageSize 是每页条数，由调用方算好） * @return 当前页的子任务 id，已按排序规则排好序 */ public List selectServiceSubtaskIdsPage(ServiceSubtaskEntity serviceSubtaskVO); /** * 用于补偿查询 * * @param serviceSubtaskVO * @return */ public List getCompensateServiceSubtaskList(ServiceSubtaskEntity serviceSubtaskVO); public List selectServiceSubtaskByDiagname(ServiceSubtask serviceSubtask); public List queryServiceSubtaskList(ServiceSubtaskEntity serviceSubtaskVO); public List selectServiceSubtaskBySendstate(ServiceSubtaskEntity serviceSubtaskVO); public List selectServiceSubtaskListByCreateTime(ServiceSubtaskEntity serviceSubtaskVO); public List selectServiceSubtaskListAgain(ServiceSubtaskEntity serviceSubtaskVO); public List selectServiceSubtaskListDeadLine(ServiceSubtaskEntity serviceSubtaskVO); public List selectSendstateByCondition(ServiceSubtask serviceSubtask); /** * 新增单一任务（随访） * * @param ServiceSubtask 单一任务（随访） * @return 结果 */ public int insertServiceSubtask(ServiceSubtask ServiceSubtask); /** * 任务组（appltype=5）：统计某一轮次内仍在运行的 subtask 数量。 * 仍在运行 = sendstate in (1,2,3) 且未删除。 * 用于判断本轮是否已全部 finalize（成功/失败/不执行/超时）。 * * @param scheduleId 计划主键 * @param loopCount 轮次（0=首轮） */ public int countActiveByScheduleIdAndLoop(@Param("scheduleId") Long scheduleId, @Param("loopCount") Long loopCount); /** * 任务组（appltype=5）：拉取某一轮次的全部 subtask（用于克隆到下一轮）。 */ public List selectByScheduleIdAndLoop(@Param("scheduleId") Long scheduleId, @Param("loopCount") Long loopCount); /** * 随访及时率：应随访时间<实际随访时间 * * @param ServiceSubtask * @return */ public Double selectTimelyRate(ServiceSubtask ServiceSubtask); /** * 随访及时率（按 groupKey 分组批量统计） *

* rate：出院时间(endtime)起 rateDay + 补偿天数 内完成随访的占比。 * 补偿天数取自 service_subtask_preachform.compensate_time 按子任务求和， * 用子任务快照而非 service_task.preachform_desc，保证历史数据不随任务改配置而变动。 * rateDay 为空时 rate 返回 NULL。 *

* finishRate：应随访时间(visit_time) <= 实际完成时间(finishtime) 的占比，当前未被随访统计使用。 * * @param ServiceSubtaskvo * @return */ @MapKey("groupKey") public Map> selectTimelyRateBatch(ServiceSubtaskEntity ServiceSubtaskvo); /** * 随访及时率详情 * * @param ServiceSubtask * @return */ public List selectTimelyRateDetail(ServiceSubtask ServiceSubtask); /** * 修改单一任务（随访） * * @return 结果 */ public Boolean updateServiceSubtask(ServiceSubtask ServiceSubtask); public Boolean updateServiceSubtaskByPatId(ServiceSubtask ServiceSubtask); public Boolean updateServiceSubtaskByCondition(ServiceSubtask ServiceSubtask); public Boolean updateServiceSubtaskByTaskGuid(ServiceSubtask ServiceSubtask); /** * 删除单一任务（随访） * * @param id 单一任务（随访）主键 * @return 结果 */ public int deleteServiceSubtaskById(Long id); public int deleteServiceSubtaskByCondition(@Param("taskid") Long id, @Param("patid") Long patid); /** * 删除患者出院记录对应的未完成随访任务 * * @param patid 患者ID * @param inhospids 出院记录ID集合 * @param sendstates 未完成状态集合 * @return 删除条数 */ public int deleteUnfinishedServiceSubtaskByInhospids(@Param("patid") Long patid, @Param("inhospids") List inhospids, @Param("sendstates") List sendstates); /** * 统计患者指定任务下未完成的随访任务数量（用于人工随访重复校验） * * @param patid 患者ID * @param taskid 任务ID * @param sendstates 未完成状态集合 * @return 未完成任务数量 */ int countUnfinishedServiceSubtaskByPatidAndTaskid(@Param("patid") Long patid, @Param("taskid") Long taskid, @Param("sendstates") List sendstates); /** * 删除单一任务（随访） * * @return 结果 */ public List getDataByTime(@Param("beganTime") String beganTime, @Param("endTime") String endTime); public List getSfFzInfoEveryMonth(ServiceSubtaskCountReq serviceSubtaskCountReq); public List getSfStatistics(ServiceSubtaskCountReq serviceSubtaskCountReq); /** * 随访分类统计：按分组（groupKey=drcode / leaveldeptcode / leavehospitaldistrictcode）在库里聚合。 *

* 用于替代“把 getSfStatistics 命中的全部明细行捞回内存再逐行累加”的老做法， * 只返回分组数（几十行）的结果；统计口径与 {@code getStatisticCategory} 完全一致。 * * @param serviceSubtaskCountReq 查询条件（必须已设置 groupKey / groupKeyList） * @return 每个分组的聚合统计 */ public List getSfStatisticsScriptSum(ServiceSubtaskCountReq serviceSubtaskCountReq); /** * 随访分类统计：满意度题目量按分组聚合（替代 getSfStatisticsCategory 的 IN 大列表 + 内存过滤）。 * * @param serviceSubtaskCountReq 查询条件（必须已设置 groupKey / groupKeyList / configValue） * @return 每行包含 groupCode、joyAllCount、joyCount 三个键 */ public List> getSfStatisticsScriptJoySum(ServiceSubtaskCountReq serviceSubtaskCountReq); public List getSpecialSfStatistics(ServiceSubtaskCountReq serviceSubtaskCountReq); public List getSfStatisticsHyperlink(ServiceSubtaskCountReq serviceSubtaskCountReq); public List getSfStatisticsGroupKey(ServiceSubtaskCountReq serviceSubtaskCountReq); public List getSfStatisticsJoy(ServiceSubtaskCountReq serviceSubtaskCountReq); public List getSfStatisticsJoydetails(ServiceSubtaskCountReq serviceSubtaskCountReq); /** * 获取问题统计结果（随访） * * @return 结果 */ public List getSfStatisticsCategory(ServiceSubtaskCountReq serviceSubtaskCountReq); /** * 获取问题统计结果（随访） * * @return 结果 */ public List getSfStatisticsScriptDetails(ServiceSubtaskCountReq serviceSubtaskCountReq); /** * 获取问题回答统计结果（随访） * * @return 结果 */ public List getSfStatisticsScriptItemDetails(ServiceSubtaskCountReq serviceSubtaskCountReq); public List getDeptRanking(PatMedReq patMedReq); public List getServiceStatistics(ServiceStatisticsRequest serviceStatisticsRequest); /** * 统计任务各种状态的数量（优化版） * 用于替代应用层的循环统计，直接在数据库层进行聚合计算 * * @param serviceSubtaskVO 查询条件 * @return Map 包含各状态统计数据 * total: 患者服务总量 * wxsf: 无需随访数量 sendstate != 4 * xsf: 需随访数量 sendstate = 4 * dsf: 待随访数量 sendstate = 1L, 2L, 3L, 5L, 7L * ywc: 已完成数量 sendstate = 6L * dfs: 待发送数量 sendstate = 1L, 3L, 4L, 5L, 6L, 7L * yfs: 已发送数量 sendstate = 2L * cs: 超时数量 sendstate = 7L * yc: 异常数量 excep = '1' * yc: 警告数量 excep = '2' */ public Map countByCondition(ServiceSubtaskEntity serviceSubtaskVO); /** * 统计任务各种状态的数量（优化版） * * @param serviceSubtaskVO 查询条件 * @return Map 包含各状态统计数据 * pendingVisitCount: 当前登录人截止今日待随访总量 * failedVisitCount: 当前登录人随访任务失败总量 * abnormalVisitVount: 当前登录人随访任务异常总量 * allVisitCount: 当前登录人随访任务总量 * soonTimeoutCount: 当前登录人即将超时数量（超时截止时间在 soonTimeoutHours 小时内，仅统计尚未超时的数据） */ public Map getCurrentUserServiceSubtaskCount(ServiceSubtaskEntity serviceSubtaskVO); /** * 当前登录人待处理随访任务，按出院年月分组统计 *

* 统计口径：出院随访/门诊随访（service_type in 2,3）+ 人工（current_preachform = '1'） * + 待随访状态（sendstate in 1,2,3,5,7）+ 出院时间早于等于今天 - 7 天。 * * @param serviceSubtaskVO 查询条件（orgid、科室、病区） * @return 每行包含 month（yyyy-MM）与 cnt（数量），数量为 0 的月份不会返回 */ public List> countPendingManualTaskByMonth(ServiceSubtaskEntity serviceSubtaskVO); /** * 获取门诊随访人数 * * @param patMedReq * @return */ PatMedRes selectVisitCount(PatMedReq patMedReq); /** * 按病区分组统计延续护理数量 * * @param vo 查询条件 * @return 每个病区的统计结果 */ List> getContinueNurseCount(ServiceSubtaskCotinueCountVO vo); /** * 按科室分组统计延续护理数量 * * @param vo 查询条件 * @return 每个科室的统计结果 */ List> getContinueNurseCountByDept(ServiceSubtaskCotinueCountVO vo); /** * 宣教统计：按病区或科室分组统计发送成功率和已读率 * * @param heLibraryCountVO 查询条件 * @return 每组的统计结果（groupName, sendSuccessCount, totalCount, readCount） */ List> getHeLibraryCount(HeLibraryCountVO heLibraryCountVO); /** * 宣教统计超链接 */ List gethelibraryCountHyperlink(HeLibraryCountVO heLibraryCountVO); /** * 条件更新原任务的“是否再次随访”标识，用于二次随访幂等控制。 * 仅当当前值不是目标值时才更新，返回受影响行数。 * * @param id 子任务 ID * @param isVisitAgain 目标值（2-已再次随访） * @return 受影响行数，1 表示抢到生成权，0 表示已被其他请求处理 */ int updateIsVisitAgainById(@Param("id") Long id, @Param("isVisitAgain") Integer isVisitAgain); }