forked from kidgrow-microservices-platform

houruijun
2020-10-14 c143d93014527f616aaaa7fe23ad91e3e9b6c7e3
kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ConsumptionRecordServiceImpl.java
@@ -553,6 +553,8 @@
        consumptionVo.setBusinessId(consumptionRequest.getBusinessId());
        consumptionVo.setBcode(bcode);
        consumptionVo.setRecordType(recordType);
        logger.info("扣费业务返回参数实体:"+consumptionRequest.toString());
        logger.info("扣费业务返回其他参数:bcode:{},recordType:{},reMsg:{},isSuccess:{}",bcode,recordType,reMsg,isSuccess);
        if (isSuccess) {
            return ResultBody.ok().data(consumptionVo).msg(reMsg);
        } else {
@@ -591,12 +593,13 @@
     * 参数验证
     */
    private Boolean VateParams(ConsumptionRequest consumptionRequest) {
        logger.info("收到扣费请求的参数:"+consumptionRequest.toString());
        if (consumptionRequest != null) {
            //从请求头获取医院和科室id
            String hosId = consumptionRequest.getHospitalId().toString();
            String depId = consumptionRequest.getDepartmentId().toString();
            String doctorId = consumptionRequest.getDoctorId().toString();
            String diaId = consumptionRequest.getDiaId().toString();
            String diaId = consumptionRequest.getDiaId();
            if (StringUtils.isNotBlank(consumptionRequest.getBusinessId())
                    && consumptionRequest.getConsumptionCount() > 0
                    && StringUtils.isNotBlank(hosId)
@@ -637,7 +640,7 @@
            } else {
                returnMap.put("vateRe", false);
                returnMap.put("vateMsg", "余额获取异常,data为空!");
                logger.error("医院id:【{}】余额获取异常!", hospitalId);
                logger.info("医院id:【{}】余额获取异常!", hospitalId);
            }
        } else {
            returnMap.put("vateRe", false);
@@ -745,7 +748,7 @@
                "\",\"date\":\"" + DateUtils.formatDate(new Date(), "yyyy-MM-dd") + "\"}";
        rabbitTemplate.convertAndSend(ConsumptionConstant.EXCHANGE_DATA, ConsumptionConstant.ROUTINGKEY_DATA + envName, context);
        log.error("骨龄评价扣费消息已发送:" + context);
        log.info("骨龄评价扣费消息已发送:" + context);
    }
    /**
@@ -755,6 +758,7 @@
     * @return
     */
    private Boolean departmentIsPay(ConsumptionRequest consumptionRequest) {
        log.info("查看当前科室是否开通了单次支付请求参数:"+consumptionRequest.toString());
        PayManager payManager = payManagerService.findByObject(consumptionRequest.getHospitalId(), consumptionRequest.getDepartmentId());
        if (payManager == null) {
            return false;
@@ -770,6 +774,7 @@
     * @return
     */
    private Boolean departmentPayStatus(ConsumptionRequest consumptionRequest) {
        log.info("查看当前科室当前诊断id的支付状态是否成功请求参数:"+consumptionRequest.toString());
        SaasClientPay saasClientPay = saasClientPayService.findModelByObject(consumptionRequest.getHospitalId(), consumptionRequest.getDepartmentId(), consumptionRequest.getDiaId());
        if (saasClientPay == null) {
            return false;