SiMzFeeOprnSystem/src/main/java/thyyxxk/simzfeeoprnsystm/service/SiMzFeeService.java

package thyyxxk.simzfeeoprnsystm.service;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.springframework.beans.factory.annotation.Value;
import thyyxxk.simzfeeoprnsystm.dao.SiLogDao;
import thyyxxk.simzfeeoprnsystm.dao.SiMzDao;
import thyyxxk.simzfeeoprnsystm.dao.SiSetldetailDao;
import thyyxxk.simzfeeoprnsystm.dao.SiSetlinfoDao;
import thyyxxk.simzfeeoprnsystm.dicts.*;
import thyyxxk.simzfeeoprnsystm.external.WebHisService;
import thyyxxk.simzfeeoprnsystm.pojo.*;
import thyyxxk.simzfeeoprnsystm.pojo.ResultVo;
import thyyxxk.simzfeeoprnsystm.pojo.SiPatInfo;
import thyyxxk.simzfeeoprnsystm.utils.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

@Slf4j
@Service
public class SiMzFeeService {
    private final SiMzDao mzDao;
    private final SiSetlinfoDao setlinfoDao;
    private final SiSetldetailDao setldetailDao;
    private final ExecService exec;
    private final WebHisService webHisService;
    private final MariadbService mariadbService;
    private static final String RESULT_CODE = "infcode";
    private static final String ERROR_MESSAGE = "err_msg";
    private static final String OUTPUT = "output";
    private final SiLogDao logDao;
    @Value("${web-his-url}")
    private String webHisUrl;

    @Autowired
    public SiMzFeeService(SiMzDao mzDao, SiSetlinfoDao setlinfoDao,
                          SiSetldetailDao setldetailDao, ExecService exec, WebHisService webHisService, MariadbService mariadbService, SiLogDao logDao) {
        this.mzDao = mzDao;
        this.setlinfoDao = setlinfoDao;
        this.setldetailDao = setldetailDao;
        this.exec = exec;
        this.webHisService = webHisService;
        this.mariadbService = mariadbService;
        this.logDao = logDao;
    }

    public ResultVo<String> outpatientRegistration(MzPatientInfo p) {
        Regstrtn regstrtn = mzDao.selectRegstrtn(p.getPatNo(), p.getTimes());
        if (null == regstrtn) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "mz_visit_table患者信息为空，请联系医生重开处方。");
        }
        ReadCardBizType readCardBizType = ReadCardBizType.get(p.getReadCardBizType());
        if (readCardBizType != ReadCardBizType.REGISTRATION && !p.getInsuplcAdmdvs().startsWith("43")) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "省外异地的患者请读社保卡或医保电子凭证登记！");
        }
        if (StringUtil.notBlank(p.getMedType())) {
            mzDao.updateMedtype(p.getMedType(), p.getPatNo(), p.getTimes());
        }
        if (readCardBizType == ReadCardBizType.REGISTRATION) {
            MdtrtCertType mdtrtCertType = MdtrtCertType.getByLabel(p.getMdtrtCertType());
            regstrtn.setMdtrtCertType(mdtrtCertType.getCode());
            if (mdtrtCertType.getCode().equals(MdtrtCertType.SOCIAL_SECURITY_CARD.getCode())) {
                String[] out = p.getReadCardResult().split("\\|");
                regstrtn.setMdtrtCertNo(out[2]);
                regstrtn.setCardSn(out[3]);
            } else if (mdtrtCertType.getCode().equals(MdtrtCertType.MEDICAL_INSURANCE_ELECTRONIC_VOUCHER.getCode())) {
                JSONObject qrinfo = JSONObject.parseObject(p.getReadCardResult());
                regstrtn.setMdtrtCertNo(qrinfo.getString("ecToken"));
            }
        }

        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.OUTPATIENT_REGISTRATION,
                p.getInsuplcAdmdvs(), p.getStaffId());
        regstrtn.setInsutype(p.getInsutype());
        regstrtn.setPsnType(p.getPsnType());
        regstrtn.setIptOtpNo(p.getPatNo());
        String ref = JSONObject.toJSONStringWithDateFormat(regstrtn, "yyyy-MM-dd HH:mm:ss");
        input.getJSONObject("input").put("data", JSONObject.parseObject(ref));
        JSONObject result = exec.executeTrade(input, SiFunction.OUTPATIENT_REGISTRATION);
        log.info("【操作员：{}】，门诊挂号：\n参数：{}，\n结果：{}", p.getStaffId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, p.getPatNo(), p.getTimes(), infcode, regstrtn.getPsnNo()));
        if (null == infcode) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (infcode == 0) {
            JSONObject output = result.getJSONObject(OUTPUT).getJSONObject("data");
            p.setMdtrtId(output.getString("mdtrt_id"));
            p.setVisitDate(regstrtn.getBegntime());
            mzDao.afterRegistrtn(p);
            return ResultVoUtil.success("挂号成功。");
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<String> revokeOutpatientRegistration(MzPatientInfo p) {
        if (null == p.getTimes()) {
            p.setTimes(mzDao.selectMaxTimes(p.getPatNo()));
        }
        SiPatInfo siPatInfo = mzDao.selectSiPatInfoForMz(p.getPatNo(), p.getTimes());
        if (null == siPatInfo || StringUtil.isBlank(siPatInfo.getMdtrtId())) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者没有有效的医保挂号信息。");
        }
        RevokeRegRequest request = new RevokeRegRequest();
        request.setInsuplcAdmdvs(siPatInfo.getInsuplcAdmdvs()); ;
        request.setStaffId(p.getStaffId());
        request.setPsnNo(siPatInfo.getPsnNo());
        request.setMdtrtId(siPatInfo.getMdtrtId());
        request.setPatNo(p.getPatNo());
        request.setTimes(p.getTimes());
        return executeOutpatientRegRevoke(request);
    }

    public ResultVo<String> executeOutpatientRegRevoke(RevokeRegRequest request) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.REVOKE_OUTPATIENT_REGISTRATION,
                request.getInsuplcAdmdvs(), request.getStaffId());
        JSONObject data = new JSONObject();
        data.put("psn_no", request.getPsnNo());
        data.put("mdtrt_id", request.getMdtrtId());
        data.put("ipt_otp_no", request.getPatNo());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.REVOKE_OUTPATIENT_REGISTRATION);
        log.info("【操作员：{}】，取消门诊挂号：\n参数：{}，\n结果：{}", request.getStaffId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, request.getPatNo(), request.getTimes(), infcode, request.getPsnNo()));
        if (null == infcode) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (infcode == 0) {
            mzDao.clearMdtrtIdForMz(request.getPatNo(), request.getTimes(), null);
            return ResultVoUtil.success("取消门诊挂号成功。");
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    private ResultVo<String> uploadOutpatientInfo(SpcChrDiseAcct spcChrDiseAcct, SiPatInfo siPatInfo) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.UPLOAD_OUTPATIENT_INFO,
                siPatInfo.getInsuplcAdmdvs(), spcChrDiseAcct.getStaffId());
        JSONObject mdtrtinfo = new JSONObject();
        List<Diagnoses> diagnosesList = new ArrayList<>();
        String icdCodeNew = mzDao.selectIcdCodeNew(siPatInfo.getPatNo(), siPatInfo.getTimes());
        if (StringUtil.isBlank(icdCodeNew)) {
            diagnosesList = mzDao.selectMzDiags(siPatInfo.getPatNo(), siPatInfo.getTimes());
            if (null == diagnosesList || diagnosesList.isEmpty()) {
                log.info("【{}】 上传就诊信息失败，门诊诊断为空。", siPatInfo.getPatNo());
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者的门诊诊断为空，请联系医生填写。");
            }
        } else {
            Diagnoses base = mzDao.selectDiseinfo(siPatInfo.getPatNo(), siPatInfo.getTimes());
            String[] icds = icdCodeNew.split(",");
            for (int i = 0; i < icds.length; i++) {
                String icd = icds[i];
                String icdTextNew = mzDao.selectIcdTextNew(icd);
                Diagnoses diag = new Diagnoses();
                diag.setDiagCode(icd);
                diag.setDiagName(icdTextNew);
                diag.setDiagSrtNo(i + 1);
                diag.setDiagType("1");
                diag.setValiFlag("1");
                diag.setDiagDept(base.getDiagDept());
                diag.setDiagTime(base.getDiagTime());
                diag.setDiseDorNo(base.getDiseDorNo());
                diag.setDiseDorName(base.getDiseDorName());
                diagnosesList.add(diag);
            }
        }
        if (siPatInfo.getMedType().equals("14") || siPatInfo.getMedType().equals("51")) {
            if (StringUtil.isBlank(spcChrDiseAcct.getOpspDiseCode())) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "生育门诊与慢特病门诊的病种不能为空 ！");
            }
        }
        mdtrtinfo.put("mdtrt_id", siPatInfo.getMdtrtId());
        mdtrtinfo.put("psn_no", siPatInfo.getPsnNo());
        mdtrtinfo.put("med_type", siPatInfo.getMedType());
        mdtrtinfo.put("begntime", DateUtil.formatDatetime(siPatInfo.getVisitDatetime()));
        mdtrtinfo.put("main_cond_dscr", spcChrDiseAcct.getOpspDiseName());
        mdtrtinfo.put("dise_codg", spcChrDiseAcct.getOpspDiseCode());
        mdtrtinfo.put("dise_name", spcChrDiseAcct.getOpspDiseName());
        mdtrtinfo.put("birctrl_type", "");
        mdtrtinfo.put("birctrl_matn_date", "");
        mdtrtinfo.put("exp_content", spcChrDiseAcct.getExpContent());
        String ref = JSONObject.toJSONString(diagnosesList);
        input.getJSONObject("input").put("mdtrtinfo", mdtrtinfo);
        input.getJSONObject("input").put("diseinfo", JSONArray.parse(ref));
        JSONObject result = exec.executeTrade(input, SiFunction.UPLOAD_OUTPATIENT_INFO);
        log.info("【操作员：{}】门诊就诊信息上传：\n参数：{}，\n结果：{}", spcChrDiseAcct.getStaffId(), input, result);
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, siPatInfo.getPatNo(), siPatInfo.getTimes(), infcode, siPatInfo.getPsnNo()));
        if (result.getIntValue(RESULT_CODE) == 0) {
            Diagnoses main = diagnosesList.get(0);
            mzDao.updatePatDiseinfo(siPatInfo.getPatNo(), siPatInfo.getTimes(), main.getDiagCode(), main.getDiagName());
            return ResultVoUtil.success("门诊就诊信息上传成功。");
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<SiPatInfo> uploadOutpatientFeeDetails(SpcChrDiseAcct p) {
        String patNo = p.getPatNo();
        if (null == p.getTimes()) {
            p.setTimes(mzDao.selectMaxTimes(patNo));
        }
        SiPatInfo siPatInfo = mzDao.selectSiPatInfoForMz(patNo, p.getTimes());
        if (null == siPatInfo || StringUtil.isBlank(siPatInfo.getMdtrtId())) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "【门诊号：" + patNo +
                    "】未找到此患者的医保挂号信息，请核实。");
        }
        if (!p.getFromDirectReg()) {
            ResultVo<String> uplRes = uploadOutpatientInfo(p, siPatInfo);
            if (null != uplRes && uplRes.getCode() != ExceptionEnum.SUCCESS.getCode()) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, uplRes.getMessage());
            }
        }
        List<FeeDetail> feeDetails = mzDao.selectOutpatientFees(patNo, p.getTimes());
        if (null == feeDetails || feeDetails.isEmpty()) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者没有需要上传的费用。");
        }
        MzVisit mzVisit = mzDao.selectMzVisitInfo(patNo, p.getTimes());
        if (null == mzVisit || StringUtil.isBlank(mzVisit.getVisitDeptCode())) {
            log.info("【{}，{}】就诊科室没有匹配医保码，无法使用门诊统筹。", patNo, p.getTimes());
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "就诊科室没有匹配医保码，无法使用门诊统筹。");
        }
        String batchNo = patNo + "_" + p.getTimes();
        feeDetails.forEach(item -> {
            item.setMdtrtId(siPatInfo.getMdtrtId());
            item.setPsnNo(siPatInfo.getPsnNo());
            item.setChrgBchno(batchNo);
            item.setRxCircFlag(YesOrNo.NO.getCodeStr());
            item.setHospApprFlag(YesOrNo.YES.getCodeStr());
            item.setBilgDeptCodg(mzVisit.getVisitDeptCode());
            item.setBilgDeptName(mzVisit.getVisitDeptName());
            if (siPatInfo.getMedType().equals("51")) {
                item.setMatnFeeFlag("1");
            }
        });
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.UPLOAD_OUTPATIENT_FEE_DETAILS,
                siPatInfo.getInsuplcAdmdvs(), p.getStaffId());
        String ref = JSONArray.toJSONStringWithDateFormat(feeDetails, "yyyy-MM-dd HH:mm:ss");
        JSONArray feedetail = JSONArray.parseArray(ref);
        input.getJSONObject("input").put("feedetail", feedetail);
        JSONObject result = exec.executeTrade(input, SiFunction.UPLOAD_OUTPATIENT_FEE_DETAILS);
        log.info("【操作员：{}】门诊费用明细信息上传：\n参数：{}，\n结果：{}", p.getStaffId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, p.getPatNo(), p.getTimes(), infcode, siPatInfo.getPsnNo()));
        if (null == infcode) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (infcode == 0) {
            JSONArray feeRes = result.getJSONObject(OUTPUT).getJSONArray("result");
            double fulamtOwnpayAmt = 0d;
            double overlmtAmt = 0d;
            double preselfpayAmt = 0d;
            double inscpScpAmt = 0d;
            for (int i = 0; i < feeRes.size(); i++) {
                JSONObject fee = feeRes.getJSONObject(i);
                fulamtOwnpayAmt += fee.getDoubleValue("fulamt_ownpay_amt");
                overlmtAmt += fee.getDoubleValue("overlmt_amt");
                preselfpayAmt += fee.getDoubleValue("preselfpay_amt");
                inscpScpAmt += fee.getDoubleValue("inscp_scp_amt");

                String detlSn = fee.getString("feedetl_sn");
                String chrgLv = fee.getString("chrgitm_lv");
                String chrgType = fee.getString("med_chrgitm_type");
                String[] sns = detlSn.split("_");
                int times = Integer.parseInt(sns[1]);
                int recNo = Integer.parseInt(sns[2]);
                int odrNo = Integer.parseInt(sns[3]);
                int itmNo = Integer.parseInt(sns[4]);
                mzDao.afterUploadFees(patNo, times, recNo, odrNo, itmNo, chrgLv, chrgType);
            }
            siPatInfo.setFulamtOwnpayAmt(fulamtOwnpayAmt);
            siPatInfo.setOverlmtAmt(overlmtAmt);
            siPatInfo.setPreselfpayAmt(preselfpayAmt);
            siPatInfo.setInscpScpAmt(inscpScpAmt);
            mzDao.updateSortOfAmt(siPatInfo);
            return ResultVoUtil.success(siPatInfo);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<String> revokeOutpatientFeeDetails(MzPatientInfo p) {
        if (null == p.getTimes()) {
            p.setTimes(mzDao.selectMaxTimes(p.getPatNo()));
        }
        SiPatInfo siPatInfo = mzDao.selectSiPatInfoForMz(p.getPatNo(), p.getTimes());
        if (null == siPatInfo || StringUtil.isBlank(siPatInfo.getMdtrtId())) {
            return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有此患者的医保挂号信息！");
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.REVOKE_OUTPATIENT_FEE_DETAILS,
                siPatInfo.getInsuplcAdmdvs(), p.getStaffId());
        JSONObject data = new JSONObject();
        data.put("mdtrt_id", siPatInfo.getMdtrtId());
        data.put("psn_no", siPatInfo.getPsnNo());
        data.put("chrg_bchno", "0000");
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.REVOKE_OUTPATIENT_FEE_DETAILS);
        log.info("【操作员：{}】门诊费用明细信息撤销，参数：{}，结果：{}", p.getStaffId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, p.getPatNo(), p.getTimes(), infcode, siPatInfo.getPsnNo()));
        if (null == infcode) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (infcode == 0) {
            mzDao.afterRevokeFees(p.getPatNo(), p.getTimes());
            return ResultVoUtil.success("门诊费用明细信息撤销成功。");
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<FundDetail> outpatientPreSettlement(MzPatientInfo p) {
        while (MzgjUtil.inProcessing(p.getPatNo())) {
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
        if (null == p.getTimes()) {
            p.setTimes(mzDao.selectMaxTimes(p.getPatNo()));
        }
        ResultVo<FundDetail> setlfund = getFundDetailByPatientInfo(p.getPatNo(), p.getTimes());
        if (setlfund != null) {
            return setlfund;
        }
        MzPreSetlmt mzPreSetlmt = mzDao.selectPreSetlmt(p.getPatNo(), p.getTimes());
        if (null == mzPreSetlmt || null == mzPreSetlmt.getMedfeeSumamt()) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者没有已上传的费用。");
        }
        ReadCardBizType readCardBizType = ReadCardBizType.get(p.getReadCardBizType());
        if (readCardBizType == ReadCardBizType.SETTLEMENT) {
            MdtrtCertType mdtrtCertType = MdtrtCertType.getByLabel(p.getMdtrtCertType());
            mzPreSetlmt.setMdtrtCertType(mdtrtCertType.getCode());
            if (mdtrtCertType.getCode().equals(MdtrtCertType.SOCIAL_SECURITY_CARD.getCode())) {
                String[] out = p.getReadCardResult().split("\\|");
                mzPreSetlmt.setMdtrtCertNo(out[2]);
                mzPreSetlmt.setCardSn(out[3]);
            } else if (mdtrtCertType.getCode().equals(MdtrtCertType.MEDICAL_INSURANCE_ELECTRONIC_VOUCHER.getCode())) {
                JSONObject qrinfo = JSONObject.parseObject(p.getReadCardResult());
                if (!p.getSocialNo().trim().equals(qrinfo.getString("idNo").trim())) {
                    return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "电子医保凭证身份证与HIS身份证不一致，请确认是否人证相符。");
                }
                mzPreSetlmt.setMdtrtCertNo(qrinfo.getString("ecToken"));
            }
        }
        mzPreSetlmt.setMedfeeSumamt(mzPreSetlmt.getMedfeeSumamt().setScale(2, RoundingMode.HALF_UP));
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.OUTPATIENT_PRE_SETTLEMENT,
                mzPreSetlmt.getInsuplcAdmdvs(), p.getStaffId());
        mzPreSetlmt.setPsnSetlway(PsnSetlWay.SETTLE_BY_ITEMS.getCode());
        mzPreSetlmt.setAcctUsedFlag(p.getAcctUsedFlag());
        mzPreSetlmt.setChrgBchno(p.getPatNo() + "_" + p.getTimes());
        mzPreSetlmt.setExpContent(p.getExpContent());
        String ref = JSONObject.toJSONString(mzPreSetlmt);
        input.getJSONObject("input").put("data", JSONObject.parseObject(ref));
        JSONObject result = exec.executeTrade(input, SiFunction.OUTPATIENT_PRE_SETTLEMENT);
        log.info("【操作员：{}】门诊预结算：\n参数：{}，\n结果：{}", p.getStaffId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, p.getPatNo(), p.getTimes(), infcode, mzPreSetlmt.getPsnNo()));
        if (null == infcode) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (infcode == 0) {
            JSONObject setlinfo = result.getJSONObject(OUTPUT).getJSONObject("setlinfo");
            FundDetail fundDetail = new FundDetail();
            fundDetail.setTotalCost(setlinfo.getString("medfee_sumamt"));
            fundDetail.setFundPay(setlinfo.getString("fund_pay_sumamt"));
            fundDetail.setCashPay(setlinfo.getString("psn_cash_pay"));
            fundDetail.setAcctPay(setlinfo.getString("acct_pay"));
            fundDetail.setSelfPay(setlinfo.getString("psn_part_amt"));
            fundDetail.setCardType(getCardType(mzPreSetlmt.getInsuplcAdmdvs()));
            return ResultVoUtil.success(fundDetail);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    private ResultVo<FundDetail> getFundDetailByPatientInfo(String patientId, int times) {
        SiSetlinfo sisetlinfo = mzDao.selectSettledInfo(patientId, times, 0);
        if (null != sisetlinfo && null != sisetlinfo.getSetlId()) {
            return getFundDetailFromSetlinfo(sisetlinfo);
        }
        return null;
    }

    private ResultVo<FundDetail> getFundDetailFromSetlinfo(SiSetlinfo setlinfo) {
        FundDetail fundDetail = new FundDetail();
        fundDetail.setCardType(getCardType(setlinfo.getInsuplcAdmdvs()));
        fundDetail.setTotalCost(String.valueOf(setlinfo.getMedfeeSumamt()));
        fundDetail.setFundPay(String.valueOf(setlinfo.getFundPaySumamt()));
        fundDetail.setCashPay(String.valueOf(setlinfo.getPsnCashPay()));
        fundDetail.setAcctPay(String.valueOf(setlinfo.getAcctPay()));
        fundDetail.setSelfPay(String.valueOf(setlinfo.getPsnPartAmt()));
        if (setlinfo.getRevoked() == 1) {
            fundDetail.reverseAll();
        }
        fundDetail.setSetlinfo(setlinfo);
        return ResultVoUtil.success(fundDetail);
    }

    private Integer getCardType(String insplc) {
        if (insplc.startsWith("4301")) {
            return 1;
        } else if (insplc.equals("439900")) {
            return 2;
        }
        return 3;
    }

    public ResultVo<FundDetail> outpatientSettlement(MzPatientInfo p) {
        ResultVo<FundDetail> setlfund = getFundDetailByPatientInfo(p.getPatNo(), p.getTimes());
        if (setlfund != null) {
            return setlfund;
        }
        Setlmt setlmt = mzDao.selectSetlmt(p.getPatNo(), p.getTimes());
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.OUTPATIENT_SETTLEMENT,
                setlmt.getInsuplcAdmdvs(), p.getStaffId());
        ReadCardBizType readCardBizType = ReadCardBizType.get(p.getReadCardBizType());
        if (readCardBizType == ReadCardBizType.SETTLEMENT) {
            MdtrtCertType mdtrtCertType = MdtrtCertType.getByLabel(p.getMdtrtCertType());
            setlmt.setMdtrtCertType(mdtrtCertType.getCode());
            if (mdtrtCertType.getCode().equals(MdtrtCertType.SOCIAL_SECURITY_CARD.getCode())) {
                String[] out = p.getReadCardResult().split("\\|");
                setlmt.setMdtrtCertNo(out[2]);
                setlmt.setCardSn(out[3]);
            } else if (mdtrtCertType.getCode().equals(MdtrtCertType.MEDICAL_INSURANCE_ELECTRONIC_VOUCHER.getCode())) {
                JSONObject qrinfo = JSONObject.parseObject(p.getReadCardResult());
                if (!p.getSocialNo().trim().equals(qrinfo.getString("idNo").trim())) {
                    return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "电子医保凭证身份证与HIS身份证不一致，请确认是否人证相符。");
                }
                setlmt.setMdtrtCertNo(qrinfo.getString("ecToken"));
            }
        }
        setlmt.setMedfeeSumamt(setlmt.getMedfeeSumamt().setScale(2, RoundingMode.HALF_UP));
        setlmt.setPsnSetlway(PsnSetlWay.SETTLE_BY_ITEMS.getCode());
        setlmt.setChrgBchno(p.getPatNo() + "_" + p.getTimes());
        setlmt.setAcctUsedFlag(p.getAcctUsedFlag());
        setlmt.setInvono(SnowFlakeId.getInstance().nextId());
        setlmt.setExpContent(p.getExpContent());
        String ref = JSONObject.toJSONString(setlmt);
        input.getJSONObject("input").put("data", JSONObject.parseObject(ref));
        JSONObject result = exec.executeTrade(input, SiFunction.OUTPATIENT_SETTLEMENT);
        log.info("【操作员：{}】门诊结算：\n参数：{}，\n结果：{}", p.getStaffId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR, "与医保中心的连接出现网络异常！");
        }
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, p.getPatNo(), p.getTimes(), infcode, setlmt.getPsnNo()));
        if (null == infcode) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (infcode == 0) {
            JSONObject setlinfo = result.getJSONObject(OUTPUT).getJSONObject("setlinfo");
            SiSetlinfo setlEntity = JSONObject.parseObject(setlinfo.toJSONString(), SiSetlinfo.class);
            setlEntity.setPatNo(p.getPatNo());
            setlEntity.setTimes(p.getTimes());
            setlEntity.setLedgerSn(0);
            setlEntity.setStaffId(p.getStaffId());
            setlEntity.setRevoked(YesOrNo.NO.getCode());
            setlEntity.setSetlType(ClrType.OUTPATIENT.getCode());
            setlEntity.setInsuplcAdmdvs(setlmt.getInsuplcAdmdvs());
            setlEntity.setBegntime(mzDao.selectBegntime(p.getPatNo(), p.getTimes()));
            setlEntity.setEndtime(setlEntity.getSetlTime());
            setlEntity.setMzSaved(p.getSaved());
            BigDecimal hospitalPart = BigDecimal.ZERO;
            JSONArray setldetail = result.getJSONObject(OUTPUT).getJSONArray("setldetail");
            for (int i = 0; i < setldetail.size(); i++) {
                SiSetldetail setldetailEntity = JSONObject.parseObject(setldetail.getJSONObject(i).toJSONString(),
                        SiSetldetail.class);
                setldetailEntity.setPatNo(p.getPatNo());
                setldetailEntity.setTimes(p.getTimes());
                setldetailEntity.setLedgerSn(0);
                if (setldetailEntity.getFundPayType().equals("999996") || setldetailEntity.getSetlProcInfo().equals("999996")) {
                    hospitalPart = hospitalPart.add(BigDecimal.valueOf(setldetailEntity.getFundPayamt()));
                }
                setldetailDao.insert(setldetailEntity);
            }
            setlEntity.setHospPartAmt(hospitalPart.doubleValue());
            setlinfoDao.insert(setlEntity);
            setlinfoDao.updateSiZyInfoSetlId(p.getPatNo(), p.getTimes(), 0, setlEntity.getSetlId(),
                    setlEntity.getMedinsSetlId(), input.getString("msgid"));
            webHisService.saveCumInfo(webHisUrl, setlEntity);

            if (BigDecimal.ZERO.compareTo(BigDecimal.valueOf(setlEntity.getPsnCashPay())) == 0) {
                ResultVo<String> mzChargeResponse = mzChargeFee(p.getPatNo(), p.getTimes(),
                        String.valueOf(setlEntity.getMedfeeSumamt()));
                if (mzChargeResponse.getCode() != ExceptionEnum.SUCCESS.getCode()) {
                    revokeOutpatientSettlementForTask(setlEntity);
                    return ResultVoUtil.fail(ExceptionEnum.INTERNAL_SERVER_ERROR, mzChargeResponse.getMessage());
                }
            }

            return getFundDetailFromSetlinfo(setlEntity);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<FundDetail> revokeOutpatientSettlement(MzPatientInfo p) {
        if (null == p.getTimes()) {
            p.setTimes(mzDao.selectMaxTimes(p.getPatNo()));
        }
        SiSetlinfo setlinfo = mzDao.selectSettledInfo(p.getPatNo(), p.getTimes(), 0);
        if (null == setlinfo) {
            setlinfo = mzDao.selectSettledInfo(p.getPatNo(), p.getTimes(), 1);
            if (null == setlinfo) {
                return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有此患者的已结算数据。");
            }
            return getFundDetailFromSetlinfo(setlinfo);
        }

        String staffDept = mzDao.selectStaffDepartment(p.getStaffId());
        if (!Objects.equals(staffDept, "3020100") &&
                !Objects.equals(staffDept, "3060000") &&
                !Objects.equals(staffDept, "3100000")) {
            if (!Objects.equals(p.getStaffId(), setlinfo.getStaffId())) {
                return ResultVoUtil.fail(ExceptionEnum.INTERNAL_SERVER_ERROR, "您没有权限撤销本条医保业务，请到收费窗口退处方，或者联系医保科处理。");
            }
        }

        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.REVOKE_OUTPATIENT_SETTLEMENT,
                mzDao.selectAdmdvs(setlinfo.getPatNo(), setlinfo.getTimes(), setlinfo.getLedgerSn()), p.getStaffId());
        JSONObject data = new JSONObject();
        data.put("setl_id", setlinfo.getSetlId());
        data.put("mdtrt_id", setlinfo.getMdtrtId());
        data.put("psn_no", setlinfo.getPsnNo());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.REVOKE_OUTPATIENT_SETTLEMENT);
        log.info("【操作员：{}】门诊结算撤销：\n参数：{}，\n结果：{}", p.getStaffId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, p.getPatNo(), p.getTimes(), infcode, setlinfo.getPsnNo()));
        if (null == infcode) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (infcode == 0) {
            afterRevokeSetl(p.getPatNo(), p.getTimes(), input.getString("msgid"));
            if (null != p.getNeedRevokeRegistration() && p.getNeedRevokeRegistration() == 1) {
                revokeOutpatientFeeDetails(p);
                revokeOutpatientRegistration(p);
            }
            return getFundDetailFromSetlinfo(setlinfo);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public void revokeOutpatientSettlementForTask(SiSetlinfo setlinfo) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.REVOKE_OUTPATIENT_SETTLEMENT,
                mzDao.selectAdmdvs(setlinfo.getPatNo(), setlinfo.getTimes(), setlinfo.getLedgerSn()), "99999");
        JSONObject data = new JSONObject();
        data.put("setl_id", setlinfo.getSetlId());
        data.put("mdtrt_id", setlinfo.getMdtrtId());
        data.put("psn_no", setlinfo.getPsnNo());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.REVOKE_OUTPATIENT_SETTLEMENT);
        log.info("【操作员：99999】门诊结算撤销：\n参数：{}，\n结果：{}", input, result);
        Integer infcode = result.getInteger(RESULT_CODE);
        logDao.insert(new SiLog(input, result, setlinfo.getPatNo(), setlinfo.getTimes(), infcode, setlinfo.getPsnNo()));
        if (null != infcode && infcode == 0) {
            afterRevokeSetl(setlinfo.getPatNo(), setlinfo.getTimes(), input.getString("msgid"));
            MzPatientInfo mzPatientInfo = new MzPatientInfo();
            mzPatientInfo.setPatNo(setlinfo.getPatNo());
            mzPatientInfo.setTimes(setlinfo.getTimes());
            mzPatientInfo.setStaffId("99999");
            revokeOutpatientFeeDetails(mzPatientInfo);
            revokeOutpatientRegistration(mzPatientInfo);
        }
    }

    public void afterRevokeSetl(String patNo, int times, String msgId) {
        try {
            mzDao.deleteSetlInfo(patNo, times);
            mzDao.deleteSetlDetail(patNo, times);
            mzDao.updateRvkSetlMsgid(patNo, times, msgId);
        } catch (Exception e) {
            String sql1 = String.format("update t_si_setlinfo set revoked=1,mz_saved=0 where pat_no='%s' and times=%d;\n", patNo, times);
            String sql2 = String.format("delete from t_si_setldetail where pat_no='%s' and times=%d;\n", patNo, times);
            String sql3 = String.format("update t_si_pat_info set rvk_setl_msgid='%s' where pat_no='%s' and times=%d;",
                    msgId, patNo, times);
            String sql = sql1 + sql2 + sql3;
            mariadbService.insertNewRecord(sql);
        }
    }

    public ResultVo<FundDetail> directRegistration(DirectionRegParam param) {
        log.info("门诊共济：{}", param);
        if (MzgjUtil.inProcessing(param.getPatientId())) {
            log.info("【{}】此患者上一次的共济流程尚未结束，请稍后再试。", param.getPatientId());
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者上一次的共济流程尚未结束，请稍后再试。");
        }
        ResultVo<FundDetail> setlfund = getFundDetailByPatientInfo(param.getPatientId(), param.getTimes());
        if (setlfund != null) {
            return setlfund;
        }
        MzgjUtil.addProcess(param.getPatientId());
        try {
            return executeMzgj(param);
        } catch (Exception e) {
            log.error("门诊共济出错：", e);
            return ResultVoUtil.fail(ExceptionEnum.INTERNAL_SERVER_ERROR, e.getMessage());
        } finally {
            MzgjUtil.finishProcessing(param.getPatientId());
        }
    }

    private ResultVo<FundDetail> executeMzgj(DirectionRegParam param) {
        if (mzDao.selectExistCount(param.getPatientId(), param.getTimes()) == 0) {
            int update = mzDao.updateMzTimes(param.getPatientId(), param.getTimes());
            if (update == 0) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR,
                        "不存在此患者第[" + param.getTimes() + "]次的就诊信息，请重新查询。");
            }
        }
        mzDao.deleteTempPatinfo(param.getPatientId(), param.getTimes());
        MzPatientInfo mzptnt = new MzPatientInfo();
        mzptnt.setStaffId(param.getStaffId());
        mzptnt.setPatNo(param.getPatientId());
        mzptnt.setTimes(param.getTimes());
        mzptnt.setMedType("11");
        mzptnt.setAcctUsedFlag(String.valueOf(param.getAcctUsedFlag()));
        SiPatInfo siPatInfo = mzDao.selectSiPatInfoForMz(mzptnt.getPatNo(), mzptnt.getTimes());
        mzptnt.setInsuplcAdmdvs(siPatInfo.getInsuplcAdmdvs());
        mzptnt.setInsutype(siPatInfo.getInsutype());
        mzptnt.setPsnType(siPatInfo.getPsnType());
        mzptnt.setName(siPatInfo.getPsnName());
        mzptnt.setSocialNo(siPatInfo.getCertno());
        if (StringUtil.notBlank(param.getReadCardResult())) {
            MdtrtCertType mdtrtCertType = MdtrtCertType.get(param.getReadCardType());
            mzptnt.setMdtrtCertType(mdtrtCertType.getLabel());
            mzptnt.setReadCardBizType(ReadCardBizType.REGISTRATION.getCode());
            mzptnt.setReadCardResult(param.getReadCardResult());
        }

        ResultVo<String> regres = outpatientRegistration(mzptnt);
        if (null == regres) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (regres.getCode() != ExceptionEnum.SUCCESS.getCode()) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, regres.getMessage());
        }

        // 挂号登记成功后上传就诊信息
        siPatInfo = mzDao.selectSiPatInfoForMz(mzptnt.getPatNo(), mzptnt.getTimes());
        siPatInfo.setFromDirectReg(true);
        SpcChrDiseAcct spcChrDiseAcct = new SpcChrDiseAcct();
        spcChrDiseAcct.setStaffId(param.getStaffId());
        spcChrDiseAcct.setExpContent(param.getExpContent());
        ResultVo<String> upldMdtrtRes = uploadOutpatientInfo(spcChrDiseAcct, siPatInfo);
        if (null == upldMdtrtRes) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (upldMdtrtRes.getCode() != ExceptionEnum.SUCCESS.getCode()) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, upldMdtrtRes.getMessage());
        }

        // 上传就诊信息成功后生成门诊医保费用
        ResultVo<List<Map<String, Object>>> getMzRcptRes = webHisService.getMzReceipts(webHisUrl, mzptnt);
        if (null == getMzRcptRes) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (getMzRcptRes.getCode() != ExceptionEnum.SUCCESS.getCode()) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, getMzRcptRes.getMessage());
        }
        List<MzReceipt> mzReceipts = new ArrayList<>();
        for (Map<String, Object> item : getMzRcptRes.getData()) {
            int times = (int) item.get("times");
            if (times != mzptnt.getTimes()) {
                continue;
            }
            mzDao.deleteAllReceipts(param.getPatientId(), times);
            Map<Integer, List<MzReceipt>> orderReceiptsMap = FilterUtil.cast(item.get("mzReceipts"));
            for (Map.Entry<Integer, List<MzReceipt>> entry : orderReceiptsMap.entrySet()) {
                mzReceipts.addAll(entry.getValue());
            }
        }
        if (mzReceipts.isEmpty()) {
            return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有可以上传到医保的费用。");
        }
        ResultVo<String> insertSiMzFeeRes = webHisService.insertSiMzFees(webHisUrl, mzReceipts);
        if (null == insertSiMzFeeRes) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (insertSiMzFeeRes.getCode() != ExceptionEnum.SUCCESS.getCode()) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, insertSiMzFeeRes.getMessage());
        }

        // 生成费用成功后上传到医保
        spcChrDiseAcct.setStaffId(param.getStaffId());
        spcChrDiseAcct.setPatNo(mzptnt.getPatNo());
        spcChrDiseAcct.setTimes(mzptnt.getTimes());
        spcChrDiseAcct.setFromDirectReg(true);
        ResultVo<SiPatInfo> upldFeeRes = uploadOutpatientFeeDetails(spcChrDiseAcct);
        if (null == upldFeeRes) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (upldFeeRes.getCode() != ExceptionEnum.SUCCESS.getCode()) {
            revokeOutpatientRegistration(mzptnt);
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, upldFeeRes.getMessage());
        }
        // 上传完成之后结算并返回结算结果
        mzptnt.setReadCardBizType(ReadCardBizType.SETTLEMENT.getCode());
        return outpatientSettlement(mzptnt);
    }

    private ResultVo<String> mzChargeFee(String patientId, int times, String totalFee) {
        JSONObject params = new JSONObject();
        params.put("patientId", patientId);
        params.put("times", times);
        params.put("totalFee", totalFee);
        int tryTimes = 1;
        JSONObject response = webHisService.mzChargeFee(params);
        log.info("第{}次保存处方：\n参数：{}\n结果：{}", tryTimes, params, response);
        while (0 != response.getInteger("code") && tryTimes < 5
                && !response.getString("message").contains("已经收费")) {
            try {
                tryTimes += 1;
                response = webHisService.mzChargeFee(params);
                log.info("第{}次保存处方：\n参数：{}\n结果：{}", tryTimes, params, response);
                TimeUnit.SECONDS.sleep(Math.min(tryTimes, 3));
            } catch (Exception e) {
                log.error("TIMEUNIT SLEEP ERROR", e);
            }
        }
        if (0 != response.getInteger("code") && !response.getString("message").contains("已经收费")) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR, "自动保存处方失败，将为您撤销门诊医保业务。");
        }
        return ResultVoUtil.success();
    }

    public ResultVo<Integer> isPatientDuringSiSettle(String patientId) {
        int result = MzgjUtil.inProcessing(patientId) ? 1 : 0;
        return ResultVoUtil.success(result);
    }
}