| | |
| | | import org.apache.commons.collections4.MapUtils; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | //import org.springframework.amqp.rabbit.annotation.RabbitListener; |
| | | //import org.springframework.amqp.rabbit.core.RabbitTemplate; |
| | | import org.springframework.amqp.rabbit.annotation.RabbitListener; |
| | | import org.springframework.amqp.rabbit.core.RabbitTemplate; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | //记录类型 |
| | | int recordType=ConsumptionConstant.BEFORE_DEDUCTION; |
| | | //业务执行结果 |
| | | boolean isSuccess = false; |
| | | boolean isSuccess = true; |
| | | //业务执行结果信息 |
| | | String reMsg = ""; |
| | | if (VateParams(consumptionRequest)) { |
| | | //先获取这个业务关联的扣费记录 |
| | | List<ConsumptionRecord> consumptionRecordList = GetBusinessConsumptionList(consumptionRequest.getBusinessId()); |
| | | Long hospitalId = Long.valueOf(httpServletRequest.getHeader(SecurityConstants.USER_HOSPITAL_ID_HEADER)); |
| | | Long departmentId = Long.valueOf(httpServletRequest.getHeader(SecurityConstants.USER_DEP_ID_HEADER)); |
| | | //1.先检查是否已经扣费 |
| | | if (!isBeforeDeduction(consumptionRecordList, ConsumptionConstant.DEDUCTION)) { |
| | | //2.没有扣费,检查是否已经预扣费 |
| | |
| | | //4.余额充足 获取要扣的套餐 写预扣费记录 |
| | | if (beforeConsumption(consumptionRequest)) { |
| | | //预扣费成功 |
| | | isSuccess = true; |
| | | reMsg = "预扣费成功!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_IS_BEFORE_DEDUCTION; |
| | | } else { |
| | | //预扣费执行失败 |
| | | isSuccess = false; |
| | | reMsg = "预扣费执行失败!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_ERROR; |
| | | } |
| | | } else { |
| | | //余额不足 |
| | | isSuccess = false; |
| | | reMsg = "余额不足或获取失败!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_FAIL; |
| | | } |
| | |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_IS_DEDUCTION; |
| | | } |
| | | } else { |
| | | isSuccess = false; |
| | | reMsg = "传入参数有误!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_PARAMS_ERROR; |
| | | } |
| | |
| | | //记录类型 |
| | | int recordType=ConsumptionConstant.DEDUCTION; |
| | | //业务执行结果 |
| | | boolean isSuccess = false; |
| | | boolean isSuccess = true; |
| | | //业务执行结果信息 |
| | | String reMsg = ""; |
| | | if (VateParams(consumptionRequest)) { |
| | | //先获取这个业务关联的扣费记录 |
| | | List<ConsumptionRecord> consumptionRecordList = GetBusinessConsumptionList(consumptionRequest.getBusinessId()); |
| | | Long hospitalId = Long.valueOf(httpServletRequest.getHeader(SecurityConstants.USER_HOSPITAL_ID_HEADER)); |
| | | Long departmentId = Long.valueOf(httpServletRequest.getHeader(SecurityConstants.USER_DEP_ID_HEADER)); |
| | | |
| | | //1.先检查是否已经扣费 |
| | | if (!isBeforeDeduction(consumptionRecordList, ConsumptionConstant.DEDUCTION)) { |
| | | //2.没有扣费,检查是否已经预扣费 |
| | |
| | | logger.info("医院id:【{}】AI返回结果应该不走预扣,目前确已经预扣!", hospitalId); |
| | | } else { |
| | | //预扣费执行失败 |
| | | isSuccess = false; |
| | | reMsg = "预扣费执行失败!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_ERROR; |
| | | return ResultReturn(consumptionRequest, bcode,ConsumptionConstant.BEFORE_DEDUCTION, reMsg, isSuccess); |
| | | } |
| | | } else { |
| | | //余额不足 |
| | | isSuccess = false; |
| | | reMsg = "余额不足或获取失败!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_FAIL; |
| | | return ResultReturn(consumptionRequest, bcode,ConsumptionConstant.BEFORE_DEDUCTION, reMsg, isSuccess); |
| | | } |
| | | } |
| | | if (consumptionBusiess(consumptionRequest, consumptionRecordList)) { |
| | | isSuccess = true; |
| | | reMsg = "该业务扣费成功!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_IS_DEDUCTION; |
| | | } else { |
| | | isSuccess = false; |
| | | reMsg = "该业务扣费失败!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_FAIL; |
| | | } |
| | |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_IS_DEDUCTION; |
| | | } |
| | | } else { |
| | | isSuccess = false; |
| | | reMsg = "传入参数有误!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_PARAMS_ERROR; |
| | | } |
| | |
| | | consumptionRecordNew.setLastRecordId(consumptionRecord.getId()); |
| | | if (SaveConsumptionRecord(consumptionRecordNew)) |
| | | { |
| | | isSuccess=true; |
| | | reMsg = "有预扣,写退还预扣成功!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_RETURN_BEFORE_DEDUCTION; |
| | | } |
| | |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_PARAMS_ERROR; |
| | | } |
| | | } else { |
| | | isSuccess = true; |
| | | //已经扣费 |
| | | reMsg = "该业务已经扣费!"; |
| | | bcode = ConsumptionConstant.BUSINESS_CODE_IS_DEDUCTION; |
| | |
| | | */ |
| | | private Boolean beforeConsumption(ConsumptionRequest consumptionRequest) { |
| | | Long hospitalId = Long.valueOf(httpServletRequest.getHeader(SecurityConstants.USER_HOSPITAL_ID_HEADER)); |
| | | Long departmentId = Long.valueOf(httpServletRequest.getHeader(SecurityConstants.USER_DEP_ID_HEADER)); |
| | | |
| | | ProductOrderDetail productOrderDetail = deductionDepartmentProduct(consumptionRequest.getConsumptionCount()); |
| | | if (productOrderDetail != null) { |
| | | ConsumptionRecord consumptionRecord = new ConsumptionRecord(); |