From d40cde3bca854c21c869cb35d25ece4aa7dac265 Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期四, 10 四月 2025 16:43:34 +0800 Subject: [PATCH] 检查记录 排除 未检查的记录 --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java | 154 +++++++++++++++++++++++++++++---------------------- 1 files changed, 88 insertions(+), 66 deletions(-) diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java index 45ce17b..fde56f9 100644 --- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java +++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java @@ -3,12 +3,12 @@ import cn.lihu.jh.framework.common.pojo.CommonResult; import cn.lihu.jh.framework.security.core.util.SecurityFrameworkUtils; import cn.lihu.jh.module.ecg.controller.admin.jobrecord.vo.JobRecordSaveReqVO; -import cn.lihu.jh.module.ecg.dal.dataobject.appointment.AppointmentDO; import cn.lihu.jh.module.ecg.dal.dataobject.checktype.CheckTypeDO; import cn.lihu.jh.module.ecg.dal.dataobject.devmanage.DeviceDO; import cn.lihu.jh.module.ecg.dal.dataobject.jobrecord.JobRecordDO; import cn.lihu.jh.module.ecg.dal.dataobject.patient.PatDetails; import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO; +import cn.lihu.jh.module.ecg.dal.mysql.checktype.CheckTypeMapper; import cn.lihu.jh.module.ecg.dal.mysql.devmanage.DeviceMapper; import cn.lihu.jh.module.ecg.dal.mysql.jobrecord.JobRecordMapper; import cn.lihu.jh.module.ecg.dal.mysql.queue.QueueMapper; @@ -16,20 +16,16 @@ import cn.lihu.jh.module.ecg.enums.DevStateEnum; import cn.lihu.jh.module.ecg.enums.QueueStatusEnum; import cn.lihu.jh.module.ecg.feign.*; -import cn.lihu.jh.module.ecg.feign.dto.AppointmentExternal; import cn.lihu.jh.module.ecg.service.queue.QueueServiceTxFunctions; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.dataformat.xml.XmlMapper; +import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.validation.annotation.Validated; import org.springframework.transaction.annotation.Transactional; -import java.io.Console; import java.time.LocalDate; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.List; -import java.util.Map; import cn.lihu.jh.module.ecg.controller.admin.devrent.vo.*; import cn.lihu.jh.module.ecg.dal.dataobject.devrent.DevRentDO; @@ -41,7 +37,6 @@ import javax.annotation.Resource; import static cn.lihu.jh.framework.common.exception.util.ServiceExceptionUtil.exception; -import static cn.lihu.jh.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND; import static cn.lihu.jh.framework.common.util.date.DateUtils.getCurTimeString; import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*; @@ -52,13 +47,14 @@ */ @Service @Validated +@Slf4j public class DevRentServiceImpl implements DevRentService { @Resource QueueServiceTxFunctions queueServiceTxFunctions; @Resource - private RemoteDataService remoteDataService; + private FeeConfirmFeignService feeConfirmFeignService; @Resource private DevRentMapper devRentMapper; @@ -71,6 +67,9 @@ @Resource QueueMapper queueMapper; + + @Resource + CheckTypeMapper checkTypeMapper; @Override public CommonResult<Long> registerOperation(DevRentSaveReqVO createReqVO) { @@ -87,7 +86,7 @@ String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); String userHisId = SecurityFrameworkUtils.getLoginUserHisId(); - // 鍚屾牱 鍦ㄩ绾︾‘璁ゆ椂 灏辫繘鍏� [dev_rent] 琛ㄤ簡 + // 鍦ㄩ绾︾‘璁ゆ椂 灏辫繘鍏� [dev_rent] 琛ㄤ簡 Long rent_id = createReqVO.getId(); List<Integer> jobTypeList = new ArrayList<Integer>(); @@ -153,8 +152,6 @@ procAffinityWhenRoutineFinish( firstOnStageQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes() ); } - // 纭垂澶勭悊 - feeConfirm(firstOnStageQueueItem, userHisId, userNickname); return CommonResult.success(rent_id); } @@ -168,6 +165,8 @@ public CommonResult<Long> readyOperation(DevRentSaveReqVO createReqVO) { Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + + // 鍦ㄩ绾︾‘璁ゆ椂 灏辫繘鍏� [dev_rent] 琛ㄤ簡 Long rent_id = createReqVO.getId(); // dev_rent 琛ㄧ殑ID // 鏍囨敞璁惧 宸查鍙� @@ -177,8 +176,8 @@ } List<Integer> jobTypeList = new ArrayList<Integer>(); - jobTypeList.add( DevRentStateEnum.READY.getState()); - jobTypeList.add( DevRentStateEnum.READY_CANCELLED.getState()); + jobTypeList.add( DevRentStateEnum.RECEIVED.getState()); + jobTypeList.add( DevRentStateEnum.RECEIVED_CANCELLED.getState()); JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); if (null == jobRecordDO) { List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState()); @@ -190,7 +189,7 @@ rent_id = devRentDOList.getFirst().getId(); createReqVO.setId( rent_id ); - createReqVO.setState( DevRentStateEnum.READY.getState() ); + createReqVO.setState( DevRentStateEnum.RECEIVED.getState() ); updateDevRent( createReqVO ); JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); @@ -201,7 +200,7 @@ jobRecordSaveReqVO.setPatId(createReqVO.getPatId()); jobRecordSaveReqVO.setPatName(createReqVO.getPatName()); jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); - jobRecordSaveReqVO.setJobType( DevRentStateEnum.READY.getState() ); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.RECEIVED.getState() ); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); jobRecordSaveReqVO.setCheckType( createReqVO.getCheckType() ); @@ -210,12 +209,12 @@ jobRecordMapper.insert(jobRecord); } else { // 鎾ら攢 鏀惧純鎿嶄綔 - createReqVO.setState( DevRentStateEnum.READY.getState() ); + createReqVO.setState( DevRentStateEnum.RECEIVED.getState() ); updateDevRent( createReqVO ); jobRecordDO.setDevId(createReqVO.getDevId()); - jobRecordDO.setJobType( DevRentStateEnum.READY.getState() ); + jobRecordDO.setJobType( DevRentStateEnum.RECEIVED.getState() ); jobRecordDO.setJobTime(createReqVO.getRentTime()); jobRecordDO.setRemark(createReqVO.getRemark()); jobRecordDO.setUpdater(String.valueOf(userId)); @@ -249,10 +248,11 @@ String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); Long rent_id = createReqVO.getId(); - // 瀵逛簬宸叉湁棰嗙敤锛屼絾鏄鏈烘椂浣跨敤鐨勪笉鏄凡棰嗙敤璁惧锛岄渶閲婃斁 婧愰鐢� 璁惧 DevRentDO devRentDO = getDevRent(rent_id); + + // 瀵逛簬宸叉湁棰嗙敤锛屼絾鏄鏈烘椂浣跨敤鐨勪笉鏄凡棰嗙敤璁惧锛屾姤閿� if ( null != devRentDO.getDevId() && !createReqVO.getDevId().equals(devRentDO.getDevId()) ) { - markDevFree( devRentDO.getDevId(), rent_id); + throw exception(DEVICE_NOT_PAT_RECEIVED); } // 璁剧疆璁惧 浣跨敤涓� @@ -269,7 +269,7 @@ // 绗竴娆� 瀹夎鎿嶄綔 if (null == jobRecordDO) { - List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.READY.getState()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.RECEIVED.getState()); if (devRentDOList.size() == 0) throw exception(DEV_INSTALL_NOT_RECEIVED); else if (devRentDOList.size() != 1) { @@ -480,13 +480,13 @@ DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class); createReqVO.setDevId(null); - createReqVO.setState( DevRentStateEnum.READY_CANCELLED.getState()); + createReqVO.setState( DevRentStateEnum.RECEIVED_CANCELLED.getState()); Long rent_id = createReqVO.getId(); List<Integer> jobTypeList = new ArrayList<Integer>(); - jobTypeList.add( DevRentStateEnum.READY.getState()); - jobTypeList.add( DevRentStateEnum.READY_CANCELLED.getState()); + jobTypeList.add( DevRentStateEnum.RECEIVED.getState()); + jobTypeList.add( DevRentStateEnum.RECEIVED_CANCELLED.getState()); JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); if (null == jobRecordDO) { List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState()); @@ -495,7 +495,7 @@ rent_id = devRentDOList.getFirst().getId(); createReqVO.setId( rent_id ); - createReqVO.setState( DevRentStateEnum.READY_CANCELLED.getState() ); + createReqVO.setState( DevRentStateEnum.RECEIVED_CANCELLED.getState() ); updateDevRent( createReqVO ); JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); @@ -505,7 +505,7 @@ jobRecordSaveReqVO.setDocName(userNickname); jobRecordSaveReqVO.setPatId(createReqVO.getPatId()); jobRecordSaveReqVO.setPatName(createReqVO.getPatName()); - jobRecordSaveReqVO.setJobType( DevRentStateEnum.READY_CANCELLED.getState() ); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.RECEIVED_CANCELLED.getState() ); jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); @@ -517,7 +517,7 @@ updateDevRent( createReqVO ); jobRecordDO.setDevId(null); - jobRecordDO.setJobType(DevRentStateEnum.READY_CANCELLED.getState()); + jobRecordDO.setJobType(DevRentStateEnum.RECEIVED_CANCELLED.getState()); jobRecordDO.setJobTime(createReqVO.getRentTime()); jobRecordDO.setRemark(createReqVO.getRemark()); jobRecordDO.setUpdater(String.valueOf(userId)); @@ -550,7 +550,7 @@ jobTypeList.add( DevRentStateEnum.INSTALL_CANCELLED.getState()); JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); if (null == jobRecordDO) { - List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.READY.getState()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.RECEIVED.getState()); if (devRentDOList.size() != 1) throw exception(DEV_INSTALL_EXIST); @@ -684,14 +684,15 @@ @Override public PageResult<DevRentDO> getDevRentPage(DevRentPageReqVO pageReqVO) { + pageReqVO.setState(0); return devRentMapper.selectPage(pageReqVO); } @Override - public DevRentDO getInstalledOrCancelledRent(DevRentSearchReqVO searchReqVO) { + public DevRentDO getExistingRent(DevRentSearchReqVO searchReqVO) { List<Integer> stateList = new ArrayList<>(); stateList.add( DevRentStateEnum.INSTALLED.getState() ); - stateList.add( DevRentStateEnum.INSTALL_CANCELLED.getState()); + stateList.add( DevRentStateEnum.RECEIVED.getState()); searchReqVO.setStateList( stateList ); return devRentMapper.getRentByState(searchReqVO); } @@ -707,8 +708,8 @@ @Override public DevRentDO getReadyOrCancelledRent(DevRentSearchReqVO searchReqVO) { List<Integer> stateList = new ArrayList<>(); - stateList.add( DevRentStateEnum.READY.getState() ); - stateList.add( DevRentStateEnum.READY_CANCELLED.getState()); + stateList.add( DevRentStateEnum.RECEIVED.getState() ); + stateList.add( DevRentStateEnum.RECEIVED_CANCELLED.getState()); searchReqVO.setStateList( stateList ); return devRentMapper.getRentByState(searchReqVO); } @@ -719,6 +720,49 @@ stateList.add( DevRentStateEnum.DISMANTLED.getState() ); searchReqVO.setStateList( stateList ); return devRentMapper.getRentByState(searchReqVO); + } + + // 纭垂澶勭悊 + // 杩斿洖鍊�: 0 鎴愬姛 1 澶辫触 2 涓嶇敤纭垂 + @Override + public Integer feeConfirm(Long rentId, String hisId, String userNickname, Boolean isFeeConfirmOrCancel) { + DevRentDO devRentDO = devRentMapper.selectById(rentId); + + // 鏌ヨ妫�鏌ョ被鍨嬶紝纭畾鏄惁闇�瑕佺‘璐� + CheckTypeDO checkTypeDO = checkTypeMapper.getCheckTypeByValue(devRentDO.getCheckType()); + if (0 == checkTypeDO.getExpenseRecognition()) { + return 2; + } + + PatDetails patDetails = devRentDO.getPatDetails(); + HisFeeConfirmReqBody hisFeeConfirmReqBody = new HisFeeConfirmReqBody(); + MsgHeader msgHeader = new MsgHeader(); + msgHeader.setMsgType("ODS_2212"); + msgHeader.setMsgVersion("3.0"); + msgHeader.setSender("ECG"); + hisFeeConfirmReqBody.setMsgHeader(msgHeader); + Item item = new Item(); + item.setItemCode( getHisCheckCode(devRentDO.getCheckType()) ); // + item.setItemStatus( isFeeConfirmOrCancel? "5" : "6" ); // 5 纭垂 6 鍙栨秷纭垂 + item.setExeOrganization("47162057-2"); + item.setExeDeptName("蹇冪數绉�"); + item.setExeDept("蹇冪數绉�"); + item.setExeDoctor( hisId ); // + item.setExeDoctorName( userNickname ); // + item.setExeDateTime( getCurTimeString() ); // + ExmRequest exmRequest = new ExmRequest(); + exmRequest.setAuthorOrganization("47162057-2"); + exmRequest.setRequestId( devRentDO.getApplyNo() ); // + exmRequest.setPatientType( getPatientType(patDetails.getSource()) ); // + exmRequest.setItem(item); + hisFeeConfirmReqBody.setExmRequest(exmRequest); + HisFeeConfirmRespResult result = feeConfirmFeignService.httpFeeApi("UpdateExmRequestStatus", "ECG", "ECG", hisFeeConfirmReqBody); + log.info( result.getMsgHeader().getStatus() ); + Integer returnValue = result.getMsgHeader().getStatus().equals("true") ? 0 : 1; + if (0 == returnValue) { + devRentMapper.setPaid(rentId, isFeeConfirmOrCancel ? 1 : 0); + } + return returnValue; // 0 鎴愬姛 1 澶辫触 2 涓嶇敤纭垂 } // 鏍囪 璁惧宸茶棰嗗彇 @@ -787,7 +831,7 @@ private void procAffinityWhenRoutineFinish(String patId, Integer[] affinityCheckTypes) { // 濡傛灉瀛樺湪 [浜插拰-鎺掗槦] 浜插拰椤癸紝鍒欓�夋嫨 鍏朵腑涓�涓翰鍜岄」 鎺ユ浛鍏� 澶勪簬 [灏辫瘖涓璢 List<QueueDO> affinityAffinityWaitingItems = queueMapper.getCurPatGivenCheckTypesAndStatus( - patId, affinityCheckTypes, QueueStatusEnum.AFFINITY_WAITING.getStatus()); + patId, affinityCheckTypes, QueueStatusEnum.AFFINITY.getStatus()); if (!affinityAffinityWaitingItems.isEmpty()) { QueueDO tmpQueueDO = affinityAffinityWaitingItems.get(0); tmpQueueDO.setStatus(QueueStatusEnum.ONSTAGE.getStatus()); @@ -795,20 +839,25 @@ } } + /** + * 棰嗙敤瀹屾垚锛屼富鍔ㄥ姹備緷闄� + */ private void procAffinityWhenReadyFinish(/*IN,OUT*/QueueDO bedOnStageQueueItem, Integer[] affinityCheckTypes) { - // 濡傛灉瀛樺湪 [瀹夎涓璢 浜插拰椤癸紝鍒欒窡闅忓叾涓竴涓翰鍜岄」 - List<QueueDO> affinityInstallingItems = queueMapper.getCurPatGivenCheckTypesAndStatus( - bedOnStageQueueItem.getPatId(), affinityCheckTypes, QueueStatusEnum.INSTALLING.getStatus()); + // 濡傛灉瀛樺湪 [瀹夎涓璢 [瀹夎杩囧彿] [瀹夎鍙洖] 鑳借渚濋檮鐨勬鏌ラ」锛屽垯渚濋檮鍒板叾涓竴涓鏌ラ」 + List<QueueDO> affinityInstallingItems = queueMapper.getCurPatGivenCheckTypesAndStatusList( + bedOnStageQueueItem.getPatId(), affinityCheckTypes, + List.of(QueueStatusEnum.INSTALLING.getStatus(), QueueStatusEnum.PASSED_INSTALL.getStatus(), + QueueStatusEnum.RECALLED_INSTALL.getStatus())); if (!affinityInstallingItems.isEmpty()) { QueueDO affinityInstallingItem = affinityInstallingItems.get(0); - bedOnStageQueueItem.setStatus(QueueStatusEnum.AFFINITY_RECEIVED.getStatus()); // 浜插拰-棰嗙敤 + bedOnStageQueueItem.setStatus(QueueStatusEnum.AFFINITY_INSTALL.getStatus()); // 浜插拰-棰嗙敤 bedOnStageQueueItem.setRoomId( affinityInstallingItem.getRoomId() ); bedOnStageQueueItem.setBedNo( affinityInstallingItem.getBedNo() ); // 棰嗙敤 鍒� 瀹夎 鍙兘浼氬湪涓嶅悓宸ヤ綅 } // 濡傛灉瀛樺湪 [浜插拰-鎺掗槦] 浜插拰椤癸紝鍒欓�夋嫨 鍏朵腑涓�涓翰鍜岄」 鎺ユ浛鍏� 澶勪簬 [灏辫瘖涓璢 List<QueueDO> affinityAffinityWaitingItems = queueMapper.getCurPatGivenCheckTypesAndStatus( - bedOnStageQueueItem.getPatId(), affinityCheckTypes, QueueStatusEnum.AFFINITY_WAITING.getStatus()); + bedOnStageQueueItem.getPatId(), affinityCheckTypes, QueueStatusEnum.AFFINITY.getStatus()); if (!affinityAffinityWaitingItems.isEmpty()) { QueueDO tmpQueueDO = affinityAffinityWaitingItems.get(0); tmpQueueDO.setStatus(QueueStatusEnum.ONSTAGE.getStatus()); @@ -816,9 +865,10 @@ } } + // 濡傛灉瀛樺湪 [浜插拰-棰嗙敤] 浜插拰椤癸紝鍒欓�夋嫨 鍏朵腑涓�涓翰鍜岄」 鎺ユ浛鍏� 澶勪簬 [瀹夎涓璢 private void procAffinityWhenInstallFinish(QueueDO bedInstallingQueueItem, Integer[] affinityCheckTypes) { List<QueueDO> affinityAffinityReceivedItems = queueMapper.getCurPatGivenCheckTypesAndStatus( - bedInstallingQueueItem.getPatId(), affinityCheckTypes, QueueStatusEnum.AFFINITY_RECEIVED.getStatus()); + bedInstallingQueueItem.getPatId(), affinityCheckTypes, QueueStatusEnum.AFFINITY_INSTALL.getStatus()); if (!affinityAffinityReceivedItems.isEmpty()) { QueueDO tmpQueueDO = affinityAffinityReceivedItems.get(0); tmpQueueDO.setStatus(QueueStatusEnum.INSTALLING.getStatus()); @@ -826,34 +876,6 @@ tmpQueueDO.setBedNo( bedInstallingQueueItem.getBedNo() ); // 浠� [棰嗙敤] 鍒� [瀹夎]锛� 鍙灔鍦ㄤ笉鍚屽伐浣嶄笂鎿嶄綔 queueMapper.updateById(tmpQueueDO); } - } - - private void feeConfirm(QueueDO queueItem, String hisId, String userNickname, Boolean isFeeConfirmCancel) throws JsonProcessingException { - PatDetails patDetails = queueItem.getPatDetails(); - - HisFeeConfirmReqBody hisFeeConfirmReqBody = new HisFeeConfirmReqBody(); - MsgHeader msgHeader = new MsgHeader(); - msgHeader.setMsgType("ODS_2212"); - msgHeader.setMsgVersion("3.0"); - msgHeader.setSender("ECG"); - hisFeeConfirmReqBody.setMsgHeader(msgHeader); - Item item = new Item(); - item.setItemCode( getHisCheckCode(queueItem.getBookCheckType()) ); // - item.setItemStatus( isFeeConfirmCancel? "6" : "5" ); // - item.setExeOrganization("47162057-2"); - item.setExeDeptName("蹇冪數绉�"); - item.setExeDept("蹇冪數绉�"); - item.setExeDoctor( hisId ); // - item.setExeDoctorName( userNickname ); // - item.setExeDateTime( getCurTimeString() ); // - ExmRequest exmRequest = new ExmRequest(); - exmRequest.setAuthorOrganization("47162057-2"); - exmRequest.setRequestId( patDetails.getApplyNo() ); // - exmRequest.setPatientType( getPatientType(patDetails.getSource()) ); // - exmRequest.setItem(item); - hisFeeConfirmReqBody.setExmRequest(exmRequest); - HisFeeConfirmRespResult result = remoteDataService.httpFeeApi("UpdateExmRequestStatus", "ECG", "ECG", hisFeeConfirmReqBody); - result.getMsgHeader().getStatus(); } private String getHisCheckCode(Integer checkType) { -- Gitblit v1.9.3