package com.coffee.bus.controller; import cn.dev33.satoken.SaManager; import cn.dev33.satoken.annotation.SaCheckPermission; import cn.dev33.satoken.stp.StpLogic; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.mapper.Mapper; import com.coffee.bus.controller.vo.GetPatientInfoVo; import com.coffee.bus.controller.vo.MonitorFinishedVo; import com.coffee.bus.entity.*; import com.coffee.bus.enums.DeviceStatusEnum; import com.coffee.bus.enums.PatientAlarmEnum; import com.coffee.bus.registry.patient.PatientOperator; import com.coffee.bus.registry.patient.PatientRegistry; import com.coffee.bus.service.*; import com.coffee.bus.service.dto.*; import com.coffee.bus.utils.WsPublishUtils; import com.coffee.common.crud.BaseService; import com.coffee.common.crud.controller.BaseQueryController; import com.coffee.common.exception.CustomException; import com.coffee.common.result.R; import io.swagger.annotations.*; import lombok.AllArgsConstructor; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import org.springframework.web.context.request.async.DeferredResult; import java.util.*; import java.util.stream.Collectors; /** * @author lifang * @version 1.0.0 * @ClassName BusHospitalController.java * @Description TODO * @createTime 2022年03月19日 09:28:00 */ @RestController @AllArgsConstructor @RequestMapping("/bus/patient") @Api(tags = "医院病人管理",description = "关于病人的相关操作,查询操作权限【bus:patient:query】") public class BusPatientController implements BaseQueryController { private final LocalBusPatientService patientService; private final LocalBusClinicService clinicService; private final PatientRegistry patientRegistry; private final LocalBusInfusionHistoryService infusionService; private final LocalBusDeviceManualService manualService; private final WsPublishUtils wsPublishUtils; @PostMapping("/no_page") @SaCheckPermission("bus:patient:query") @ApiOperation(value = "输注监控列表",notes = "病人监控管理列表，权限【bus:patient:query】") public R> selectPage(@RequestBody PatientMonitorQuery query){ return R.success(patientService.selectAll(query)); } @GetMapping("/repeat/device") @ApiOperation(value = "设备重复提示列表",notes = "当出现病患同一时间绑定了多个泵时,调用该接口查询出所有设备重复报警数据，权限【无】") public R> repeatDevice(){ return R.success(patientService.repeatDevice()); } @GetMapping("/none/device") @ApiOperation(value = "临床无泵列表",notes = "当出现病患同一时间没有泵时,调用该接口查询出所有没有泵信息的病患临床数据，权限【无】") public R> noneDevice(){ return R.success(patientService.noneDevice()); } @PostMapping("/judge/repeat") @ApiOperation(value = "判断所给病号中是否出现了绑定设备重复",notes = "当结束管理时，调用改接口判断所结束病号是否出现了设备重复异常,权限【无】") @ApiResponses({ @ApiResponse(code = 200,message = "0 病人中未出现重复,非0 病人中出现重复"), }) public R judgeRepeat(@RequestBody List patientCode){ return R.success(patientService.count(new QueryWrapper().lambda().in(BusPatientEntity::getCode,patientCode).eq(BusPatientEntity::getAlarm,PatientAlarmEnum.DEVICE_REPEAT))); } @PostMapping("/judge/finished") @ApiOperation(value = "判断给定病号中是否可以结束临床管理",notes = "病患当前绑定主设备必须要在关机、不在服务器、待机中才能结束管理,权限【无】") @ApiResponses({ @ApiResponse(code = 500,message = "没有选择病号"), @ApiResponse(code =200 ,message = "若存在不可以结束的临床信息，返回1",response = BusDeviceRunningEntity.class) }) public R judgeFinished(@RequestBody List patientCodes){ if(CollectionUtil.isEmpty(patientCodes)){ throw new CustomException("请选择一个病患"); } return R.success(infusionService.count(new QueryWrapper() .lambda() .nested(i->i.ne(BusInfusionHistoryEntity::getRunState,DeviceStatusEnum.Shutdown) .ne(BusInfusionHistoryEntity::getRunState,DeviceStatusEnum.NoSignal)) .in(BusInfusionHistoryEntity::getPatientCode,patientCodes) .eq(BusInfusionHistoryEntity::getFinished,false))!=0); } @PostMapping("/do/{monitorType}/finished") @SaCheckPermission("bus:patient:finished") @ApiResponse(code = 4001,message = "病号当前绑定了多个设备，不可结束管理") @ApiOperation(value = "结束管理",notes = "病患当前绑定主设备必须要在关机、不在服务器、待机中才能结束管理,权限【bus:patient:finished】") public R finished(@PathVariable("monitorType")@ApiParam(value = "是否为无泵管理 false、无泵 true、有泵",defaultValue = "false" ) boolean haveDevice, @RequestBody MonitorFinishedVo monitorFinishedVo, @RequestAttribute("tenantId")@ApiParam(hidden = true) String tenantId){ if(haveDevice){ R result = monitorFinished(monitorFinishedVo, tenantId); wsPublishUtils.publishMonitorTotalCount(tenantId); return result; }else { return manualFinished(monitorFinishedVo); } } /** * 描述: 输注监控结束管理（即使用驼人网络泵产品） * @author lifang * @date 2022/5/10 11:48 * @param monitorFinishedVo * @param tenantId * @return R */ private R monitorFinished(MonitorFinishedVo monitorFinishedVo, String tenantId){ List patientCodes = monitorFinishedVo.getPatientCodes(); if(CollectionUtil.isEmpty(patientCodes)){ List clinicIds = monitorFinishedVo.getClinicIds(); if (CollectionUtil.isEmpty(clinicIds)) { throw new CustomException("未选择临床信息"); } } List patients = patientService.list(new QueryWrapper().lambda().in(BusPatientEntity::getCode, patientCodes)); List undoConfigs=new ArrayList<>(); for (BusPatientEntity patient : patients) { undoConfigs.add( ManualUndoConfig.of( Collections.singletonList(patient.getInfusionId()), patient.getCode(), patient.getClinicId(), tenantId, true, monitorFinishedVo.getUndo()) ); } //病患绑定的有设备,对设备进行撤泵操作,且结束临床 infusionService.batchUndo(undoConfigs,true); return R.success(true); } /** * 描述: 其他监控手动结束管理（即未采用驼人网络泵产品） * @author lifang * @date 2022/5/10 11:49 * @param monitorFinishedVo * @return R */ private R manualFinished(MonitorFinishedVo monitorFinishedVo){ List clinicIds = monitorFinishedVo.getClinicIds(); if (CollectionUtil.isEmpty(clinicIds)) { throw new CustomException("未选择临床信息"); } manualService.finishedMonitor(monitorFinishedVo); return R.success(true); } @PostMapping("/monitor/reset/{clinicId}") @SaCheckPermission("device:patient:edit") @ApiOperation(value = "病人当前监控时间重启",notes = "当结束临床后有新的输注信息产生，那么病人监控会重新显示，此时监控时间不会重新计算，需先调用该接口，权限标识为【device:patient:edit】") public R reset(@ApiParam("临床id")@PathVariable("clinicId")String clinicId){ R result = R.success(clinicService.update(new UpdateWrapper().lambda().eq(BusClinicEntity::getId, clinicId) .set(BusClinicEntity::getEndTime, null))); BusClinicEntity clinic = clinicService.getById(clinicId); wsPublishUtils.publishPatientMonitor(clinic.getPatientCode(),clinic.getTenantId()); return result; } @PostMapping("/{alarm}/_count") @SaCheckPermission("device:patient:query") @ApiOperation(value = "病人报警数量统计",notes = "病人报警数量统计 0、未报警 1、泵重复 2、无泵，权限标识为【device:patient:query】") public R alarmCount(@PathVariable("alarm") int alarm){ PatientAlarmEnum alarmEnum = PatientAlarmEnum.of(alarm); if(alarmEnum==null){ return R.success(0L); } return R.success(patientService.patientAlarmCount(alarmEnum)); } @PostMapping("/shift") @SaCheckPermission("device:patient:shift") @ApiOperation(value = "主泵切换的操作,只切换，不结束",notes = "当出现泵重复状态时，若用户想要进行主泵的切换，调用该接口进行操作，主泵切换完成后，会将副泵自动撤泵，权限标识为【device:patient:shift】") public R shift(@RequestBody@Validated DeviceShiftConfig shiftConfig){ patientService.shift(shiftConfig); wsPublishUtils.publishPatientMonitor(shiftConfig.getPatientCode(),shiftConfig.getTenantId()); return R.success(); } @PostMapping("/undo") @SaCheckPermission("device:patient:undo") @ApiOperation(value = "批量撤泵,只撤泵，不切换",notes = "当出现泵重复状态时，若用户想要取消对其他副泵的监控，则调用此接口进行撤泵操作，权限标识为【device:patient:undo】") public R shift(@RequestBody@Validated ManualUndoConfig undoConfig, @RequestAttribute("tenantId")@ApiParam(hidden = true) String tenantId){ undoConfig.setTenantId(tenantId); //泵切换完成后，对病号报警解除 infusionService.undo(undoConfig,false); PatientOperator operator = patientRegistry.getOperator(undoConfig.getTenantId(), undoConfig.getPatientCode()); //判断当前病号下是否还存在副泵 long count = infusionService.count(new QueryWrapper().lambda().eq(BusInfusionHistoryEntity::getClinicId, operator.getClinicId()) .eq(BusInfusionHistoryEntity::getFinished,false) .eq(BusInfusionHistoryEntity::getIsUndo,false)); //处理缓存信息 if(count==1){ patientService.update(new UpdateWrapper().lambda() .eq(BusPatientEntity::getCode,undoConfig.getPatientCode()) .eq(BusPatientEntity::getTenantId,undoConfig.getTenantId()) .set(BusPatientEntity::getAlarm, PatientAlarmEnum.NONE)); wsPublishUtils.publishDeviceRepeat(undoConfig.getTenantId()); } wsPublishUtils.publishPatientMonitor(undoConfig.getPatientCode(),undoConfig.getTenantId()); return R.success(); } @GetMapping("/monitor/{monitorType}/{clinicId}") @SaCheckPermission("device:patient:query") @ApiOperation(value = "查看病人当前监控详情",notes = "查看病人当前监控详情，权限标识为【device:patient:query】") public R monitor(@PathVariable("monitorType")@ApiParam(value = "是否为有泵监控",example = "0、无泵，1、有泵") Boolean haveDevice, @PathVariable("clinicId")@ApiParam(value = "临床id")String clinicId){ PatientMonitorDetailResult result = new PatientMonitorDetailResult(); BusClinicEntity clinic = clinicService.getById(clinicId); result.setClinic(clinic); if(clinic==null){ throw new CustomException("该临床信息不存在,请刷新后重试"); } if(haveDevice){ BusInfusionHistoryEntity infusion =infusionService.currentInClinic(clinic.getId()); result.setInfusion(infusion); if(StrUtil.isBlank(clinic.getWard())){ clinic.setWard(infusion.getWard()); } if(StrUtil.isBlank(clinic.getBedNo())){ clinic.setBedNo(infusion.getBedNo()); } if(StrUtil.isNotEmpty(infusion.getClinicId())){ result.setClinic(clinic); } }else { //无泵查看 result.setDeviceManual( manualService.getOne(new QueryWrapper().lambda().eq(BusDeviceManualEntity::getClinicId, clinic.getId()))); } return R.success(result); } @PostMapping("/stats/status") @SaCheckPermission("device:patient:query") @ApiOperation(value = "按照状态统计病人监控状态数量",notes = "权限【device:patient:query】") public R statsStatus(){ return R.success(patientService.statusStats(null)); } @PostMapping("/stats/time") @SaCheckPermission("device:patient:query") @ApiOperation(value = "按照时间统计病人监控数量",notes = "权限【device:patient:query】") public R statsTime(){ return R.success(patientService.timeStats(null)); } @PostMapping("/pull/async") @SaCheckPermission("device:patient:pull") @ApiOperation(value = "异步更新患者信息,超时时间默认为10s,超时后数据返回继续处理,输注监控",notes = "权限标识为【bus:patient:pull】") public DeferredResult> syn(@RequestAttribute("tenantId")@ApiParam(hidden = true) String tenantId, @RequestBody GetPatientInfoVo vo){ return patientService.getPatientInfoFromHis(tenantId,vo.getPatientCode(),vo.getTimeout(),false); } @SaCheckPermission("device:patient:query") @ApiOperation(value = "泵重复绑定数量",notes = "权限标识为【bus:patient:query】") @PostMapping("/_count/repeat") public R repeatCount(){ return R.success(CollectionUtil.size(patientService.repeatDevice())); } @SaCheckPermission("device:patient:query") @ApiOperation(value = "无泵数量",notes = "权限标识为【bus:patient:query】") @PostMapping("/_count/none") public R noneCount(){ return R.success(CollectionUtil.size(patientService.repeatDevice())); } /** * 描述: * @author lifang * @date 2022/5/15 21:56 * @param tenantId * @param vo * @return R */ @PostMapping("/pull/sync") @SaCheckPermission("device:patient:pull") @ApiOperation(value = "同步更新患者信息,超时时间默认为10s,超时后数据返回则不进行处理,无泵更新",notes = "权限标识为【bus:patient:pull】") public DeferredResult> async(@RequestAttribute("tenantId")@ApiParam(hidden = true) String tenantId, @RequestBody GetPatientInfoVo vo){ return patientService.getPatientInfoFromHis(tenantId,vo.getPatientCode(),vo.getTimeout(),true); } @Override public BaseService, BusPatientEntity, String> getService() { return patientService; } @Override public String getPermissionPrefix() { return "bus:patient:"; } @Override public StpLogic getStpLogin() { return SaManager.getStpLogic(""); } }