web_server/src/main/java/thyyxxk/webserver/service/medicalinsurance/SiQueryService.java

package thyyxxk.webserver.service.medicalinsurance;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import thyyxxk.webserver.config.exception.ExceptionEnum;
import thyyxxk.webserver.constants.sidicts.SiFunction;
import thyyxxk.webserver.constants.YesOrNo;
import thyyxxk.webserver.constants.sidicts.*;
import thyyxxk.webserver.dao.his.medicalinsurance.SiQueryDao;
import thyyxxk.webserver.entity.ResultVo;
import thyyxxk.webserver.entity.dictionary.PureCodeName;
import thyyxxk.webserver.entity.medicalinsurance.inpatient.InHspPsnInfo;
import thyyxxk.webserver.entity.medicalinsurance.outpatient.SpcChrDiseAcct;
import thyyxxk.webserver.entity.medicalinsurance.query.*;
import thyyxxk.webserver.entity.medicalinsurance.setlinfo.SiSetldetail;
import thyyxxk.webserver.entity.medicalinsurance.setllist.*;
import thyyxxk.webserver.service.wxapi.SendWxInfoService;
import thyyxxk.webserver.utils.*;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.util.*;

/**
 * @description: 医保查询服务
 * @author: DingJie
 * @create: 2021-06-23 16:35:23
 **/
@Slf4j
@Service
public class SiQueryService {
    private final ExecService exec;
    private final SiQueryDao dao;
    private final SendWxInfoService wxsrvc;
    private static final String RESULT_CODE = "infcode";
    private static final String ERROR_MESSAGE = "err_msg";
    private static final String OUTPUT = "output";

    @Autowired
    public SiQueryService(ExecService exec, SiQueryDao dao, SendWxInfoService wxsrvc) {
        this.exec = exec;
        this.dao = dao;
        this.wxsrvc = wxsrvc;
    }

    public ResultVo<SiPatInfo> getSiPatInfo(QryPsnBsInfo qryPsnBsInfo) {
        SiPatInfo siPatInfo = dao.selectSiPatInfoForZy(qryPsnBsInfo.getPatNo(), qryPsnBsInfo.getTimes(), qryPsnBsInfo.getLedgerSn());
        if (null == siPatInfo) {
            siPatInfo = new SiPatInfo();
        }
        return ResultVoUtil.success(siPatInfo);
    }

    public ResultVo<PsnBaseInfo> obtainBasicPersonInfo(QryPsnBsInfo qryPsnBsInfo) {
        if (null == qryPsnBsInfo.getOnlyQry() && StringUtil.isBlank(qryPsnBsInfo.getMedType())) {
            return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "请选择患者的医疗类别！");
        }
        if (StringUtil.isBlank(qryPsnBsInfo.getSocialNo()) && StringUtil.notBlank(qryPsnBsInfo.getPatNo())
                && qryPsnBsInfo.getPatNo().length() >= 15) {
            qryPsnBsInfo.setSocialNo(qryPsnBsInfo.getPatNo());
        }
        if (StringUtil.isBlank(qryPsnBsInfo.getSocialNo())) {
            QryPsnBsInfo qpbi = dao.selectMzSocialAndName(qryPsnBsInfo.getPatNo());
            if (StringUtil.isBlank(qpbi.getSocialNo())) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者的身份证不能为空，请补充！");
            }
            if (null == qryPsnBsInfo.getTimes()) {
                qryPsnBsInfo.setTimes(qpbi.getTimes());
            }
            qryPsnBsInfo.setName(qpbi.getName());
            qryPsnBsInfo.setSocialNo(qpbi.getSocialNo());
            qryPsnBsInfo.setLedgerSn(0);
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.OBTAIN_BASIC_PERSON_INFO, qryPsnBsInfo.getAdmdvs());
        JSONObject data = new JSONObject();
        if (qryPsnBsInfo.getSocialNo().length() < 15) {
            data.put("mdtrt_cert_type", MdtrtCertType.OTHER.getCode());
            data.put("psn_cert_type", PsnCertType.RESIDENCE_PERMIT_FOR_HMT.getCode());
        } else {
            data.put("mdtrt_cert_type", MdtrtCertType.RESIDENT_IDENTITY_CARD.getCode());
            data.put("psn_cert_type", "01");
        }
        data.put("mdtrt_cert_no", qryPsnBsInfo.getSocialNo());
        data.put("certno", qryPsnBsInfo.getSocialNo());
        if (StringUtil.notBlank(qryPsnBsInfo.getName())) {
            data.put("psn_name", qryPsnBsInfo.getName());
        }
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.OBTAIN_BASIC_PERSON_INFO);
        log.info("【操作员：{}】，人员基本信息获取：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONObject baseinfo = output.getJSONObject("baseinfo");
            PsnBaseInfo psnBaseinfo = JSONObject.parseObject(baseinfo.toJSONString(), PsnBaseInfo.class);
            psnBaseinfo.setPatNo(qryPsnBsInfo.getPatNo());
            psnBaseinfo.setTimes(qryPsnBsInfo.getTimes());
            psnBaseinfo.setLedgerSn(qryPsnBsInfo.getLedgerSn());
            psnBaseinfo.setMedType(qryPsnBsInfo.getMedType());
            psnBaseinfo.setGendName(Gend.get(psnBaseinfo.getGend()).getName());
            psnBaseinfo.setPsnCertTypeName(PsnCertType.get(psnBaseinfo.getPsnCertType()).getName());
            Naty naty = Naty.get(psnBaseinfo.getNaty());
            if (null != naty) {
                psnBaseinfo.setNatyName(naty.getName());
            }
            List<IdetInfo> idetInfos = new ArrayList<>();
            JSONArray idet = output.getJSONArray("idetinfo");
            for (int i = 0; i < idet.size(); i++) {
                JSONObject item = idet.getJSONObject(i);
                IdetInfo info = JSONObject.parseObject(item.toJSONString(), IdetInfo.class);
                PsnIdetType psnIdetType = PsnIdetType.get(info.getPsnIdetType());
                if (null != psnIdetType) {
                    psnBaseinfo.setPsnIdetType(psnIdetType.getCode());
                    info.setPsnIdetTypeName(psnIdetType.getName());
                }
                idetInfos.add(info);
            }
            if (StringUtil.notBlank(psnBaseinfo.getPsnIdetType())) {
                dao.updatePsnIdetType(psnBaseinfo.getPsnIdetType(), psnBaseinfo.getPsnNo());
            }
            psnBaseinfo.setIdetinfo(idetInfos);
            if (new Integer(1).equals(qryPsnBsInfo.getNeedSaving())) {
                dao.updateZyActpatient(psnBaseinfo);
                int saved = dao.selectSiZyInfoCount(qryPsnBsInfo.getPatNo(), qryPsnBsInfo.getTimes(), qryPsnBsInfo.getLedgerSn());
                if (saved == 0) {
                    dao.insertSiZyInfoPsnNo(psnBaseinfo);
                } else {
                    dao.updateSiZyInfoPsnNo(psnBaseinfo);
                }
                log.info("患者基本信息已更新：{}", psnBaseinfo);
                output.put("times", qryPsnBsInfo.getTimes());
            }
            List<InsuInfo> list = new ArrayList<>();
            JSONArray insuinfo = output.getJSONArray("insuinfo");
            for (int i = 0; i < insuinfo.size(); i++) {
                JSONObject item = insuinfo.getJSONObject(i);
                InsuInfo info = JSONObject.parseObject(item.toJSONString(), InsuInfo.class);
                Insutype insutype = Insutype.get(info.getInsutype());
                if (null != insutype) {
                    info.setInsutypeName(insutype.getName());
                }
                PsnType psnType = PsnType.get(info.getPsnType());
                if (null != psnType) {
                    info.setPsnTypeName(psnType.getName());
                }
                if (null != info.getPsnInsuStas()) {
                    if (info.getPsnInsuStas().equals(YesOrNo.YES.getCodeStr())) {
                        info.setPsnInsuStasName("正常参保");
                    } else {
                        info.setPsnInsuStasName("暂停参保");
                    }
                }
                if (null != info.getCvlservFlag()) {
                    if (info.getCvlservFlag().equals(YesOrNo.YES.getCodeStr())) {
                        info.setCvlservFlagName("是");
                    } else {
                        info.setCvlservFlagName("否");
                    }
                }
                if (null != info.getInsuplcAdmdvs()) {
                    info.setInsuplcAdmdvsName(dao.selectRegionName(info.getInsuplcAdmdvs()));
                }
                list.add(info);
            }
            psnBaseinfo.setInsuinfo(list);
            return ResultVoUtil.success(psnBaseinfo);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<MedInsInfo>> obtainMedicalInstitutionInfo(String type, String fuzzyName) {
        JSONObject input = exec.makeTradeHeader(SiFunction.OBTAIN_MEDICAL_INSTITUTION_INFO);
        JSONObject medinsinfo = new JSONObject();
        medinsinfo.put("fixmedins_type", type);
        medinsinfo.put("fixmedins_name", fuzzyName);
        input.getJSONObject("input").put("medinsinfo", medinsinfo);
        JSONObject result = exec.executeTrade(input, SiFunction.OBTAIN_MEDICAL_INSTITUTION_INFO);
        log.info("【操作员：{}】，获取定点医药机构信息：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONArray output = result.getJSONObject(OUTPUT).getJSONArray("medinsinfo");
            List<MedInsInfo> list = new ArrayList<>();
            for (int i = 0; i < output.size(); i++) {
                JSONObject item = output.getJSONObject(i);
                MedInsInfo info = JSONObject.parseObject(item.toJSONString(), MedInsInfo.class);
                info.setFixmedinsAdmdvs(info.getFixmedinsCode().substring(1, 7));
                info.setFixmedinsAdmdvsName(dao.selectRegionName(info.getFixmedinsAdmdvs()));
                FixmedinsType fixmedinsType = FixmedinsType.get(info.getFixmedinsType());
                if (null != fixmedinsType) {
                    info.setFixmedinsTypeName(fixmedinsType.getName());
                }
                HospLv hospLv = HospLv.get(info.getHospLv());
                if (null != hospLv) {
                    info.setHospLvName(hospLv.getName());
                }
                list.add(info);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<MdtrtInfo>> queryVisitInfo(BscQryPrm q) {
        PureCodeName codeName = dao.selectPsnNoByPatNoAndMedType(q.getPatNo(), q.getMedType());
        if (null == codeName) {
            return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有找到患者该医疗类别的我院就诊记录。");
        }
        q.setPsnNo(codeName.getName());
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_VISIT_INFO, codeName.getCode());
        String ref = JSONObject.toJSONStringWithDateFormat(q, "yyyy-MM-dd HH:mm:ss");
        input.getJSONObject("input").put("data", JSONObject.parseObject(ref));
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_VISIT_INFO);
        log.info("【操作员：{}】，查询就诊信息：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray mdts = output.getJSONArray("mdtrtinfo");
            List<MdtrtInfo> list = new ArrayList<>();
            for (int i = 0; i < mdts.size(); i++) {
                JSONObject item = mdts.getJSONObject(i);
                MdtrtInfo mdtrtInfo = JSONObject.parseObject(item.toJSONString(), MdtrtInfo.class);
                if (null != mdtrtInfo.getInsuOptins()) {
                    mdtrtInfo.setInsuOptinsName(dao.selectRegionName(mdtrtInfo.getInsuOptins()));
                }
                SiEnumReflectUtil.mdtrtInfoReflect(mdtrtInfo);
                list.add(mdtrtInfo);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<DiseInfo>> queryDiagnosisInfo(BscQryPrm q) {
        String admdvs = dao.selectAdmdvsByPsnNo(q.getPsnNo());
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_DIAGNOSIS_INFO, admdvs);
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        data.put("mdtrt_id", q.getMdtrtId());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_DIAGNOSIS_INFO);
        log.info("【操作员：{}】，查询诊断信息：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            List<DiseInfo> list = new ArrayList<>();
            JSONArray diseInfos = output.getJSONArray("diseinfo");
            for (int i = 0; i < diseInfos.size(); i++) {
                JSONObject item = diseInfos.getJSONObject(i);
                DiseInfo diseInfo = JSONObject.parseObject(item.toJSONString(), DiseInfo.class);
                SiEnumReflectUtil.diseInfoReflect(diseInfo);
                list.add(diseInfo);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<SetlInfo> querySettlementInfo(BscQryPrm q) {
        SiPatInfo siPatInfo;
        if (null == q.getMdtrtId()) {
            if (null == q.getLedgerSn()) {
                q.setLedgerSn(0);
            }
            siPatInfo = dao.selectSiPatInfoForZy(q.getPatNo(), q.getTimes(), q.getLedgerSn());
        } else {
            siPatInfo = dao.selectSiPatInfoByMdtrtId(q.getMdtrtId());
        }
        if (null == siPatInfo) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "该次就诊尚未结算，无法查询结算信息。");
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_SETTLEMENT_INFO, siPatInfo.getInsuplcAdmdvs());
        JSONObject data = new JSONObject();
        data.put("psn_no", siPatInfo.getPsnNo());
        data.put("setl_id", siPatInfo.getSetlId());
        data.put("mdtrt_id", siPatInfo.getMdtrtId());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_SETTLEMENT_INFO);
        log.info("【操作员：{}】，查询结算信息：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONObject obj = output.getJSONObject("setlinfo");
            if (null == obj) {
                return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到该次就诊的结算明细。");
            }
            SetlInfo setlInfo = JSONObject.parseObject(obj.toJSONString(), SetlInfo.class);
            ClrType clrType = ClrType.get(setlInfo.getClrType());
            if (null != clrType) {
                setlInfo.setClrTypeName(clrType.getName());
            }
            MedType medType = MedType.get(setlInfo.getMedType());
            if (null != medType) {
                setlInfo.setMedTypeName(medType.getName());
            }
            Insutype insutype = Insutype.get(setlInfo.getInsutype());
            if (null != insutype) {
                setlInfo.setInsutypeName(insutype.getName());
            }
            PsnType psnType = PsnType.get(setlInfo.getPsnType());
            if (null != psnType) {
                setlInfo.setPsnTypeName(psnType.getName());
            }

            JSONArray setldetail = output.getJSONArray("setldetail");
            if (null != setldetail && setldetail.size() > 0) {
                List<SiSetldetail> list = new ArrayList<>();
                for (int i = 0; i < setldetail.size(); i++) {
                    SiSetldetail setldtel = JSONObject.parseObject(setldetail.getJSONObject(i).toJSONString(), SiSetldetail.class);
                    FundPayType fundPayType = FundPayType.get(setldtel.getFundPayType());
                    if (null != fundPayType) {
                        setldtel.setFundPayTypeName(fundPayType.getName());
                    }
                    list.add(setldtel);
                }
                setlInfo.setSetldetail(list);
            }
            return ResultVoUtil.success(setlInfo);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<Map<String, Object>> queryFeeDetails(QryFeeDetl q) {
        SiPatInfo psninfo = dao.selectSiPatInfoByMdtrtId(q.getMdtrtId());
        if (null == psninfo) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的医保登记信息。");
        }
        Map<String, Object> map = new HashMap<>();
        map.put("psninfo", psninfo);
        if (!q.getType().equals("settled")) {
            List<SiSetlFeeDetl> list = dao.selectTempCharge(psninfo.getPatNo(), psninfo.getTimes(), psninfo.getLedgerSn());
            if (null == list || list.isEmpty()) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者没有已经上传的医保费用。");
            }
            map.put("feedtle", list);
            map.put("analyse", analyseFeedtle(list));
            return ResultVoUtil.success(map);
        }
        List<SiSetlFeeDetl> list = dao.selectFeeDetlList(psninfo.getMdtrtId(), psninfo.getPatNo(), psninfo.getTimes(), psninfo.getLedgerSn());
        if (list.size() > 0) {
            map.put("feedtle", list);
            map.put("analyse", analyseFeedtle(list));
            return ResultVoUtil.success(map);
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_FEE_DETAILS, psninfo.getInsuplcAdmdvs());
        JSONObject data = new JSONObject();
        data.put("psn_no", psninfo.getPsnNo());
        data.put("setl_id", psninfo.getSetlId());
        data.put("mdtrt_id", psninfo.getMdtrtId());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_FEE_DETAILS);
        log.info("【操作员：{}】，【就诊信息查询】查询费用明细：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONArray output = result.getJSONArray(OUTPUT);
            if (null == output || output.size() == 0) {
                return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到费用明细。");
            }
            for (int i = 0; i < output.size(); i++) {
                list.add(JSONObject.parseObject(output.getJSONObject(i).toJSONString(), SiSetlFeeDetl.class));
                if (list.size() == 30) {
                    dao.insertSetlFeeDetlBatch(list);
                    list.clear();
                }
            }
            if (list.size() > 0) {
                dao.insertSetlFeeDetlBatch(list);
            }
            list = dao.selectFeeDetlList(psninfo.getMdtrtId(), psninfo.getPatNo(), psninfo.getTimes(), psninfo.getLedgerSn());
            map.put("feedtle", list);
            map.put("analyse", analyseFeedtle(list));
            return ResultVoUtil.success(map);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    private Map<String, String[]> analyseFeedtle(List<SiSetlFeeDetl> fees) {
        Map<String, String[]> map = new HashMap<>();
        map.put("zhj", new String[]{"合计", "0.00", "0.00", "0.00"});
        fees.forEach(itm -> {
            if (StringUtil.isBlank(itm.getChrgitmLvName())) {
                ChrgitmLv chrgitmLv = ChrgitmLv.get(itm.getChrgitmLv());
                if (null == chrgitmLv) {
                    chrgitmLv = ChrgitmLv.SELF_PAY;
                }
                itm.setChrgitmLvName(chrgitmLv.getName());
            }

            String[] all = map.get("zhj");
            all[1] = DecimalUtil.add(all[1], itm.getDetItemFeeSumamt());
            all[2] = DecimalUtil.add(all[2], itm.getInscpScpAmt());
            all[3] = DecimalUtil.add(all[3], DecimalUtil.minus(itm.getDetItemFeeSumamt(), itm.getInscpScpAmt()));

            if (map.containsKey(itm.getMedChrgitmType())) {
                String[] dtle = map.get(itm.getMedChrgitmType());
                dtle[1] = DecimalUtil.add(dtle[1], itm.getDetItemFeeSumamt());
                dtle[2] = DecimalUtil.add(dtle[2], itm.getInscpScpAmt());
                dtle[3] = DecimalUtil.add(dtle[3], DecimalUtil.minus(itm.getDetItemFeeSumamt(), itm.getInscpScpAmt()));
            } else {
                String[] dtle = new String[4];
                MedChrgitmType type = MedChrgitmType.get(itm.getMedChrgitmType());
                if (type == null) {
                    type = MedChrgitmType.OTH;
                    itm.setMedChrgitmType(type.getCode());
                }
                dtle[0] = type.getName();
                dtle[1] = itm.getDetItemFeeSumamt();
                dtle[2] = itm.getInscpScpAmt();
                dtle[3] = DecimalUtil.minus(itm.getDetItemFeeSumamt(), itm.getInscpScpAmt());
                map.put(type.getCode(), dtle);
            }
        });
        return map;
    }

    public ResultVo<List<TrtInfo>> checkPersonTreatment(BscQryPrm q) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.CHECK_PERSON_TREATMENT,
                dao.selectAdmdvs(q.getPatNo(), q.getTimes()));
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        data.put("insutype", q.getInsutype());
        data.put("fixmedins_code", SiUtil.INSTITUTION_ID);
        data.put("med_type", q.getMedType());
        data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.CHECK_PERSON_TREATMENT);
        log.info("【操作员：{}】，人员待遇享受检查：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            List<TrtInfo> list = new ArrayList<>();
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray trtinfo = output.getJSONArray("trtinfo");
            for (int i = 0; i < trtinfo.size(); i++) {
                JSONObject obj = trtinfo.getJSONObject(i);
                TrtInfo item = JSONObject.parseObject(obj.toJSONString(), TrtInfo.class);
                TrtChkType trtChkType = TrtChkType.get(item.getTrtChkType());
                if (null != trtChkType) {
                    item.setTrtChkTypeName(trtChkType.getName());
                }
                FundPayType fundPayType = FundPayType.get(item.getFundPayType());
                if (null != fundPayType) {
                    item.setFundPayTypeName(fundPayType.getName());
                }
                if (null != item.getTrtEnjymntFlag()) {
                    if (item.getTrtEnjymntFlag().equals(YesOrNo.YES.getCodeStr())) {
                        item.setTrtEnjymntFlagName("是");
                    } else {
                        item.setTrtEnjymntFlagName("否");
                    }
                }
                list.add(item);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<InHspPsnInfo>> queryInHospitalPatientsInfo(BscQryPrm q) {
        if (StringUtil.notBlank(q.getPatNo())) {
            String psnNo = dao.selectPsnNo(q.getPatNo());
            if (null == psnNo) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "【住院号/门诊号：" + q.getPatNo() +
                        "】没有找到此患者在我院的医保在院信息，请核实。");
            }
            q.setPsnNo(psnNo);
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_IN_HOSPITAL_PATIENTS_INFO,
                dao.selectAdmdvsByPatNoAndPsnNo(q.getPatNo(), q.getPsnNo()));
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
        data.put("endtime", null == q.getEndtime() ? DateUtil.now() : DateUtil.formatDatetime(q.getEndtime()));
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_IN_HOSPITAL_PATIENTS_INFO);
        log.info("【操作员：{}】，在院信息查询：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray pts = output.getJSONArray("data");
            if (pts.size() == 0) {
                return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到医保在院的患者信息。");
            }
            List<InHspPsnInfo> list = new ArrayList<>();
            for (int i = 0; i < pts.size(); i++) {
                JSONObject item = pts.getJSONObject(i);
                InHspPsnInfo inHspPsnInfo = JSONObject.parseObject(item.toJSONString(), InHspPsnInfo.class);
                SiEnumReflectUtil.inHspPsnInfoReflect(inHspPsnInfo);
                list.add(inHspPsnInfo);
            }
            if (list.size() == 1 && null != q.getTimes()) {
                InHspPsnInfo info = list.get(0);
                dao.updateInhospInfo(q.getPatNo(), q.getTimes(), q.getLedgerSn(), info.getMdtrtId(), info.getInsutype());
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<RefMedin>> queryPersonnelTransferHospitalInfo(BscQryPrm q) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_TRANSFER_HOSPITAL_INFO,
                dao.selectAdmdvsByPatNoAndPsnNo(q.getPatNo(), q.getPsnNo()));
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
        data.put("endtime", DateUtil.formatDatetime(q.getEndtime()));
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_TRANSFER_HOSPITAL_INFO);
        log.info("【操作员：{}】，转院信息查询：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray array = output.getJSONArray("refmedin");
            if (null == array || array.size() == 0) {
                return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到符合条件的转院信息。");
            }
            List<RefMedin> list = new ArrayList<>();
            for (int i = 0; i < array.size(); i++) {
                JSONObject obj = array.getJSONObject(i);
                RefMedin item = JSONObject.parseObject(obj.toJSONString(), RefMedin.class);
                Insutype insutype = Insutype.get(item.getInsutype());
                if (null != insutype) {
                    item.setInsutypeName(insutype.getName());
                }
                DclaSouc dclaSouc = DclaSouc.get(item.getDclaSouc());
                if (null != dclaSouc) {
                    item.setDclaSoucName(dclaSouc.getName());
                }
                PsnCertType psnCertType = PsnCertType.get(item.getPsnCertType());
                if (null != psnCertType) {
                    item.setPsnCertTypeName(psnCertType.getName());
                }
                item.setGendName(Gend.get(item.getGend()).getName());
                if (null != item.getInsuOptins()) {
                    item.setInsuOptinsName(dao.selectRegionName(item.getInsuOptins()));
                }
                if (null != item.getOutFlag()) {
                    if (item.getOutFlag().equals(YesOrNo.YES.getCodeStr())) {
                        item.setOutFlagName("是");
                    } else {
                        item.setOutFlagName("否");
                    }
                }
                if (null != item.getHospAgreReflFlag()) {
                    if (item.getHospAgreReflFlag().equals(YesOrNo.YES.getCodeStr())) {
                        item.setHospAgreReflFlagName("是");
                    } else {
                        item.setHospAgreReflFlagName("否");
                    }
                }
                list.add(item);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<MedUseRcd>> querySpecialChronicDiseasesMedicalRecord(BscQryPrm q) {
        if (null == q.getPsnNo()) {
            String psnNo = dao.selectPsnNo(q.getPatNo());
            if (null == psnNo) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "【住院号/门诊号：" + q.getPatNo() +
                        "】未找到此患者的医保参保信息，请核实。");
            }
            q.setPsnNo(psnNo);
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_MEDICAL_RECORD,
                dao.selectAdmdvsByPsnNo(q.getPsnNo()));
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
        data.put("endtime", DateUtil.formatDatetime(q.getEndtime()));
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_MEDICAL_RECORD);
        log.info("【操作员：{}】，人员慢特病用药记录查询：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray array = output.getJSONArray("feedetail");
            if (null == array || array.size() == 0) {
                return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到此人的慢特病用药记录。");
            }
            List<MedUseRcd> list = new ArrayList<>();
            for (int i = 0; i < array.size(); i++) {
                JSONObject obj = array.getJSONObject(i);
                MedUseRcd item = JSONObject.parseObject(obj.toJSONString(), MedUseRcd.class);
                list.add(item);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<CumInfo>> queryPersonnelCumulativeInfo(BscQryPrm q) {
        String admdvs = q.getAdmdvs();
        if (StringUtil.isBlank(admdvs)) {
            admdvs = dao.selectAdmdvsByPsnNo(q.getPsnNo());
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO, admdvs);
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        data.put("cum_ym", q.getCumYm());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO);
        log.info("【操作员：{}】，人员累计信息查询：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray array = output.getJSONArray("cuminfo");
            List<CumInfo> list = new ArrayList<>();
            for (int i = 0; i < array.size(); i++) {
                JSONObject obj = array.getJSONObject(i);
                CumInfo item = JSONObject.parseObject(obj.toJSONString(), CumInfo.class);
                Insutype insutype = Insutype.get(item.getInsutype());
                if (null != insutype) {
                    item.setInsutypeName(insutype.getName());
                }
                list.add(item);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<SpcChrDiseAcct>> querySpecialChronicDiseasesAccreditation(BscQryPrm q) {
        if (null == q.getPsnNo()) {
            String psnNo = dao.selectPsnNo(q.getPatNo());
            if (null == psnNo) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "【住院号/门诊号：" + q.getPatNo() +
                        "】未找到此患者的医保参保信息，请核实。");
            }
            q.setPsnNo(psnNo);
        }
        if (StringUtil.isBlank(q.getAdmdvs())) {
            String admdvs = StringUtil.isBlank(q.getPatNo()) ? dao.selectAdmdvsByPsnNo(q.getPsnNo())
                    : dao.selectAdmdvsByPatNo(q.getPatNo());
            q.setAdmdvs(admdvs);
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_ACCREDITATION, q.getAdmdvs());
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_ACCREDITATION);
        log.info("【操作员：{}】，人员慢特病备案查询：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray details = output.getJSONArray("feedetail");
            if (null == details || details.size() == 0) {
                return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST, "没有查询到此患者的慢特病备案信息。");
            }
            List<SpcChrDiseAcct> list = new ArrayList<>();
            Date now = new Date();
            for (int i = 0; i < details.size(); i++) {
                JSONObject detail = details.getJSONObject(i);
                SpcChrDiseAcct spcChrDiseAcct = JSONObject.parseObject(detail.toJSONString(), SpcChrDiseAcct.class);
                if (null != q.getNeedAllRcd() && 1 == q.getNeedAllRcd()) {
                    list.add(spcChrDiseAcct);
                } else {
                    if (now.before(spcChrDiseAcct.getEnddate())) {
                        spcChrDiseAcct.setPatNo(q.getPatNo());
                        spcChrDiseAcct.setTimes(q.getTimes());
                        list.add(spcChrDiseAcct);
                    }
                }
            }
            if (list.size() > 0) {
                return ResultVoUtil.success(list);
            }
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者没有有效的慢特病备案，或慢特病备案已过期！");
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<PsnFixMedin>> queryPersonnelAssignmentInfo(BscQryPrm q) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_ASSIGNMENT_INFO,
                dao.selectAdmdvs(q.getPatNo(), q.getTimes()));
        JSONObject data = new JSONObject();
        data.put("psn_no", q.getPsnNo());
        data.put("biz_appy_type", q.getBizAppyType());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_ASSIGNMENT_INFO);
        log.info("【操作员：{}】，人员定点信息查询：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue(RESULT_CODE) == 0) {
            JSONObject output = result.getJSONObject(OUTPUT);
            JSONArray array = output.getJSONArray("psnfixmedin");
            if (null == array || array.size() == 0) {
                return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到对应的点定信息。");
            }
            List<PsnFixMedin> list = new ArrayList<>();
            for (int i = 0; i < array.size(); i++) {
                JSONObject obj = array.getJSONObject(i);
                PsnFixMedin item = JSONObject.parseObject(obj.toJSONString(), PsnFixMedin.class);
                Insutype insutype = Insutype.get(item.getInsutype());
                if (null != insutype) {
                    item.setInsutypeName(insutype.getName());
                }
                list.add(item);
            }
            return ResultVoUtil.success(list);
        }
        return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
    }

    public ResultVo<List<Integer>> fetchSiTimesList(String patNo) {
        List<Integer> list = dao.fetchSiTimesList(patNo);
        if (null == list || list.isEmpty()) {
            return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST, "此患者没有有效的结算信息。");
        }
        return ResultVoUtil.success(list);
    }

    public ResultVo<String> queryInsuplcAdmdvsByMdtrtId(String mdtrtId) {
        return ResultVoUtil.success(dao.selectInsuplcAdmdvsByMdtrtId(mdtrtId));
    }

    public ResultVo<List<SetlIndex>> querySiSetlIndex(QrySetlListPrm q) {
        List<SetlIndex> list = dao.selectSetlIndex(q);
        if (null == list || list.isEmpty()) {
            return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST);
        }
        for (SetlIndex index : list) {
            index.setGendName(Gend.get(index.getGend()).getName());
        }
        return ResultVoUtil.success(list);
    }

    public ResultVo querySiSetlList(SetlIndex index) {
        SiPatInfo siPatInfo = dao.selectSiPatInfo(index.getPatNo(), index.getTimes());
        if (null == siPatInfo) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的结算信息！");
        }
        CuminfoInYear cuminfo = getYearCuminfo(siPatInfo.getPsnNo(), siPatInfo.getInsuplcAdmdvs());
        if (cuminfo.getCode() != ExceptionEnum.SUCCESS.getCode()) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, cuminfo.getMessage());
        }
        if (index.getType() == SetlType.INPATIENT.getCode()) {
            InptntSetlmtLst lst = dao.selectZySetlifo(index.getSetlId());
            if (siPatInfo.getLedgerSn() > 1) {
                Date accountdate = dao.selectAccountDate(siPatInfo.getPatNo(), siPatInfo.getTimes(), siPatInfo.getLedgerSn() - 1);
                lst.setBegntime(accountdate);
            }
            if (null == lst) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的结算信息！");
            }
            PsnIdetType psnIdetType = PsnIdetType.get(lst.getPsnIdetType());
            if (null != psnIdetType) {
                lst.setPsnIdetTypeName(psnIdetType.getName());
            }
            Admdvs admdvs = Admdvs.get(lst.getInsuplcAdmdvs());
            if (null == admdvs) {
                lst.setInsuplcAdmdvsName(dao.selectRegionName(lst.getInsuplcAdmdvs()));
            } else {
                lst.setInsuplcAdmdvsName(admdvs.getName());
            }
            lst.setFixmedinsName(SiUtil.INSTITUTION_NAME);
            lst.setGendName(index.getGendName());
            SiEnumReflectUtil.inptntSetlmtLstReflect(lst);
            ResultVo<List<SiSetlFeeDetl>> chrgrsvo = getChrgitems(lst.getPsnNo(), lst.getSetlId(), lst.getMdtrtId(), lst.getInsuplcAdmdvs());
            if (!chrgrsvo.getCode().equals(ExceptionEnum.SUCCESS.getCode())) {
                return chrgrsvo;
            }
            analyzeZyChrgitm(lst, chrgrsvo.getData());
            lst.setYrAdmtimes(cuminfo.getYearAdmtimes());
            lst.setYrMedfeeSumamt(cuminfo.getYearMedfeesum());
            lst.setYrPayedBegnLine(cuminfo.getYearPayedBegnline());
            lst.setYrFundPaySumamt(cuminfo.getYearBaseFundPayAmt());
            lst.setYrBigAmtFundPay(cuminfo.getYearBigAmtpays());
            lst.setYrBigDssInsPay(cuminfo.getYearBigdssFundPayAmt());
            lst.setYrMafPay(cuminfo.getYearMafPayAmt());
            return listPolItemCodePayInfo(lst);
        } else {
            index.setLedgerSn(0);
            OtptntSetlmtLst lst = dao.selectMzSetlifo(index.getPatNo(), index.getTimes());
            if (null == lst) {
                return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的结算信息！");
            }
            Admdvs admdvs = Admdvs.get(lst.getInsuplcAdmdvs());
            if (null == admdvs) {
                lst.setInsuplcAdmdvsName(dao.selectRegionName(lst.getInsuplcAdmdvs()));
            } else {
                lst.setInsuplcAdmdvsName(admdvs.getName());
            }
            SiEnumReflectUtil.outptntSetlmtLstReflect(lst);
            List<BrfChrgitm> chrgitms = dao.selectMzBrfChrgitms(index.getPatNo(), index.getTimes());
            analyzeMzChrgitm(lst, chrgitms);
            lst.setYrAdmtimes(cuminfo.getYearAdmtimes());
            lst.setYrMedfeeSumamt(cuminfo.getYearMedfeesum());
            lst.setYrFundPaySumamt(cuminfo.getYearBaseFundPayAmt());
            lst.setYrBigAmtFundPay(cuminfo.getYearBigAmtpays());
            lst.setYrMafPay(cuminfo.getYearMafPayAmt());
            lst.setFixmedinsName(SiUtil.INSTITUTION_NAME);
            return ResultVoUtil.success(lst);
        }
    }

    private ResultVo<InptntSetlmtLst> listPolItemCodePayInfo(InptntSetlmtLst lst) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.LIST_POL_ITEM_CODE_PAY_INFO, lst.getInsuplcAdmdvs());
        JSONObject data = new JSONObject();
        data.put("psn_no", lst.getPsnNo());
        data.put("mdtrt_id", lst.getMdtrtId());
        data.put("setl_id", lst.getSetlId());
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.LIST_POL_ITEM_CODE_PAY_INFO);
        log.info("【操作员：{}】，政策信息查询：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger("code")) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (result.getIntValue("code") != 0) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心出错：" + result.getString("message"));
        }
        JSONArray array = result.getJSONArray("data");
        BigDecimal selfPaySum = new BigDecimal(0);
        BigDecimal fundPaySum = new BigDecimal(0);
        for (int i = 0; i < array.size(); i++) {
            JSONObject itm = array.getJSONObject(i);
            BigDecimal selfPayAmt = BigDecimal.valueOf(itm.getDouble("selfPayAmt"));
            String selfPayProp = itm.getString("selfPayProp");
            BigDecimal fundPayAmt = BigDecimal.valueOf(itm.getDouble("fundPayAmt"));
            String fundPayProp = itm.getString("fundPayProp");
            BigDecimal polItemPaySum = BigDecimal.valueOf(itm.getDouble("polItemPaySum"));
            selfPaySum = selfPaySum.add(selfPayAmt);
            fundPaySum = fundPaySum.add(fundPayAmt);

            PolItemCode polItemCode = PolItemCode.get(itm.getString("polItemCode"));
            if (null == polItemCode) {
                String message = String.format("找到了字典缺失的政策项：%s", itm);
                log.info(message);
                wxsrvc.sendCorpWxMsg("2801", message);
                continue;
            }
            switch (polItemCode) {
                case QZF:
                    lst.setSelfPayPsnAmt(selfPayAmt);
                    lst.setSelfPayPsnProp(selfPayProp);
                    lst.setSelfPayFundAmt(fundPayAmt);
                    lst.setSelfPayFundProp(fundPayProp);
                    lst.setSelfPaySum(polItemPaySum);
                    break;
                case YLXZF:
                    lst.setScndPrePayPsnAmt(selfPayAmt);
                    lst.setScndPrePayPsnProp(selfPayProp);
                    lst.setScndPrePayFundAmt(fundPayAmt);
                    lst.setScndPrePayFundProp(fundPayProp);
                    lst.setScndPrePaySum(polItemPaySum);
                    break;
                case CXEZF:
                    lst.setOvrlmtSelfPayPsnAmt(selfPayAmt);
                    lst.setOvrlmtSelfPayPsnProp(selfPayProp);
                    lst.setOvrlmtSelfPayFundAmt(fundPayAmt);
                    lst.setOvrlmtSelfPayFundProp(fundPayProp);
                    lst.setOvrlmtSelfPaySum(polItemPaySum);
                    break;
                case BCYFQFBZ:
                    lst.setBegnlinePsnAmt(selfPayAmt);
                    lst.setBegnlinePsnProp(selfPayProp);
                    lst.setBegnlineFundAmt(fundPayAmt);
                    lst.setBegnlineFundProp(fundPayProp);
                    lst.setBegnlineSum(polItemPaySum);
                    break;
                case TCYD:
                    lst.setFundFrstLvPsnAmt(selfPayAmt);
                    lst.setFundFrstLvPsnProp(selfPayProp);
                    lst.setFundFrstLvFundAmt(fundPayAmt);
                    lst.setFundFrstLvFundProp(fundPayProp);
                    lst.setFundFrstLvSum(polItemPaySum);
                    break;
                case TCED:
                    lst.setFundScndLvPsnAmt(selfPayAmt);
                    lst.setFundScndLvPsnProp(selfPayProp);
                    lst.setFundScndLvFundAmt(fundPayAmt);
                    lst.setFundScndLvFundProp(fundPayProp);
                    lst.setFundScndLvSum(polItemPaySum);
                    break;
                case DEYD:
                    lst.setBigAmtFrstLvPsnAmt(selfPayAmt);
                    lst.setBigAmtFrstLvPsnProp(selfPayProp);
                    lst.setBigAmtFrstLvFundAmt(fundPayAmt);
                    lst.setBigAmtFrstLvFundProp(fundPayProp);
                    lst.setBigAmtFrstLvSum(polItemPaySum);
                    break;
            }
        }
        lst.setAllPsnAmt(selfPaySum);
        lst.setAllFundAmt(fundPaySum);
        lst.setAllSum(fundPaySum.add(selfPaySum));
        return ResultVoUtil.success(lst);
    }

    private CuminfoInYear getYearCuminfo(String psnNo, String admdvs) {
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO, admdvs);
        JSONObject data = new JSONObject();
        data.put("psn_no", psnNo);
        data.put("cum_ym", "");
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO);
        CuminfoInYear cuminfo = new CuminfoInYear();
        if (null == result) {
            cuminfo.setCode(ExceptionEnum.NETWORK_ERROR.getCode());
            cuminfo.setMessage(ExceptionEnum.NETWORK_ERROR.getMessage());
            return cuminfo;
        }
        if (null == result.getInteger(RESULT_CODE)) {
            cuminfo.setCode(ExceptionEnum.LOGICAL_ERROR.getCode());
            cuminfo.setMessage("医保中心报错：" + result.getString("message"));
            return cuminfo;
        }
        if (result.getIntValue(RESULT_CODE) != 0) {
            cuminfo.setCode(ExceptionEnum.NETWORK_ERROR.getCode());
            cuminfo.setMessage("医保中心出错：" + result.getString("message"));
            return cuminfo;
        }
        cuminfo.setCode(ExceptionEnum.SUCCESS.getCode());
        String year = String.valueOf(LocalDate.now().getYear());
        JSONArray cuminfos = result.getJSONObject(OUTPUT).getJSONArray("cuminfo");
        log.info("累计信息：{}", cuminfos);
        for (int i = 0; i < cuminfos.size(); i++) {
            JSONObject itm = cuminfos.getJSONObject(i);
            if (itm.getString("year").equals(year)) {
                switch (itm.getString("cum_type_code")) {
                    case "C0000": // 本年住院次数
                        cuminfo.addYearAdmtimes(itm.getDoubleValue("cum"));
                        break;
                    case "F0000": // 医疗费合计
                        cuminfo.addYearFeesum(itm.getDoubleValue("cum"));
                        break;
                    case "Q0000": // 已付起付线
                        cuminfo.addYearPayedbegnline(itm.getDoubleValue("cum"));
                        break;
                    case "D310101": // 统筹支付
                    case "D390101":
                        cuminfo.addYearFundpays(itm.getDoubleValue("cum"));
                        break;
                    case "D330101": // 大额基金支付
                        cuminfo.addYearBigAmtpays(itm.getDoubleValue("cum"));
                        break;
                    case "D390201": // 大病保险支付
                        cuminfo.addYearBigdssInspays(itm.getDoubleValue("cum"));
                        break;
                    case "D610101": // 医疗救助支付
                        cuminfo.addYearMafpays(itm.getDoubleValue("cum"));
                        break;
                }
            }
        }
        return cuminfo;
    }

    private ResultVo<List<SiSetlFeeDetl>> getChrgitems(String psnNo, String setlId, String mdtrtId, String admdvs) {
        List<SiSetlFeeDetl> list = dao.selectAllSetlFeeDtle(mdtrtId);
        if (list.size() > 0) {
            return ResultVoUtil.success(list);
        }
        JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_FEE_DETAILS, admdvs);
        JSONObject data = new JSONObject();
        data.put("psn_no", psnNo);
        data.put("setl_id", setlId);
        data.put("mdtrt_id", mdtrtId);
        input.getJSONObject("input").put("data", data);
        JSONObject result = exec.executeTrade(input, SiFunction.QUERY_FEE_DETAILS);
        log.info("【操作员：{}】，【结算单查询】查询费用明细：\n参数：{}，\n结果：{}", TokenUtil.getTokenUserId(), input, result);
        if (null == result) {
            return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
        }
        if (null == result.getInteger(RESULT_CODE)) {
            return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错：" + result.getString("message"));
        }
        if (0 == result.getInteger(RESULT_CODE)) {
            JSONArray output = result.getJSONArray(OUTPUT);
            if (null == output || output.size() == 0) {
                return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST, "没有查询到费用明细。");
            }
            for (int i = 0; i < output.size(); i++) {
                list.add(JSONObject.parseObject(output.getJSONObject(i).toJSONString(), SiSetlFeeDetl.class));
                if (list.size() == 30) {
                    dao.insertSetlFeeDetlBatch(list);
                    list.clear();
                }
            }
            if (list.size() > 0) {
                dao.insertSetlFeeDetlBatch(list);
            }
            return ResultVoUtil.success(dao.selectAllSetlFeeDtle(mdtrtId));
        }
        return ResultVoUtil.fail(ExceptionEnum.INTERNAL_SERVER_ERROR, result.getString(ERROR_MESSAGE));
    }

    private void analyzeZyChrgitm(InptntSetlmtLst lst, List<SiSetlFeeDetl> chrgitms) {
        Map<String, BigDecimal> map = new HashMap<>();
        map.put("allfeeSum", new BigDecimal(0));
        map.put("totalFrst", new BigDecimal(0));
        map.put("totalScnd", new BigDecimal(0));
        chrgitms.forEach(itm -> {
            BigDecimal itmfeeSum = new BigDecimal(itm.getDetItemFeeSumamt());
            map.replace("allfeeSum", map.get("allfeeSum").add(itmfeeSum));
            if (itm.getChrgitmLv().equals(ChrgitmLv.FIRST_CLASS.getCode())) {
                map.replace("totalFrst", map.get("totalFrst").add(itmfeeSum));
            } else if (itm.getChrgitmLv().equals(ChrgitmLv.SECOND_CLASS.getCode())) {
                map.replace("totalScnd", map.get("totalScnd").add(itmfeeSum));
            }
            String typeKey = itm.getMedChrgitmType();
            String lvKey = typeKey + "-" + itm.getChrgitmLv();
            if (map.containsKey(typeKey)) {
                map.replace(typeKey, map.get(typeKey).add(itmfeeSum));
            } else {
                map.put(typeKey, itmfeeSum);
            }
            if (map.containsKey(lvKey)) {
                map.replace(lvKey, map.get(lvKey).add(itmfeeSum));
            } else {
                map.put(lvKey, itmfeeSum);
            }
        });
        lst.setAllfeeSum(map.get("allfeeSum"));
        lst.setAllfeeFrst(map.get("totalFrst"));
        lst.setAllfeeScnd(map.get("totalScnd"));
        lst.setWestMedFeeSum(map.get("09"));
        lst.setWestMedFeeFrst(map.get("09-01"));
        lst.setWestMedFeeScnd(map.get("09-02"));
        lst.setHerbalSum(map.get("10"));
        lst.setHerbalFrst(map.get("10-01"));
        lst.setHerbalScnd(map.get("10-02"));
        lst.setChnsPtntSum(map.get("11"));
        lst.setChnsPtntFrst(map.get("11-01"));
        lst.setChnsPtntScnd(map.get("11-02"));
        lst.setClinicSum(map.get("02"));
        lst.setClinicFrst(map.get("02-01"));
        lst.setClinicScnd(map.get("02-02"));
        lst.setTreatSum(map.get("05"));
        lst.setTreatFrst(map.get("05-01"));
        lst.setTreatScnd(map.get("05-02"));
        lst.setSurgerySum(map.get("06"));
        lst.setSurgeryFrst(map.get("06-01"));
        lst.setSurgeryScnd(map.get("06-02"));
        lst.setNursingSum(map.get("07"));
        lst.setNursingFrst(map.get("07-01"));
        lst.setNursingScnd(map.get("07-02"));
        lst.setSntryMtrlsSum(map.get("08"));
        lst.setSntryMtrlsFrst(map.get("08-01"));
        lst.setSntryMtrlsScnd(map.get("08-02"));
        lst.setExamSum(map.get("04"));
        lst.setExamFrst(map.get("04-01"));
        lst.setExamScnd(map.get("04-02"));
        lst.setNrmlTrtmtSum(map.get("12"));
        lst.setNrmlTrtmtFrst(map.get("12-01"));
        lst.setNrmlTrtmtScnd(map.get("12-02"));
        lst.setInspectSum(map.get("03"));
        lst.setInspectFrst(map.get("03-01"));
        lst.setInspectScnd(map.get("03-02"));
        lst.setRegisterSum(map.get("13"));
        lst.setRegisterFrst(map.get("13-01"));
        lst.setRegisterScnd(map.get("13-02"));
        lst.setBedfeeSum(map.get("01"));
        lst.setBedfeeFrst(map.get("01-01"));
        lst.setBedfeeScnd(map.get("01-02"));
        lst.setOthfeeSum(map.get("14"));
        lst.setOthfeeFrst(map.get("14-01"));
        lst.setOthfeeScnd(map.get("14-02"));
    }

    private void analyzeMzChrgitm(OtptntSetlmtLst lst, List<BrfChrgitm> chrgitms) {
        Map<String, BigDecimal> map = new HashMap<>();
        map.put("allfeeSum", BigDecimal.valueOf(0));
        map.put("totalThrd", BigDecimal.valueOf(0));
        map.put("totalScnd", BigDecimal.valueOf(0));
        map.put("othSum", BigDecimal.valueOf(0));
        map.put("othThrd", BigDecimal.valueOf(0));
        map.put("othScnd", BigDecimal.valueOf(0));
        chrgitms.forEach(itm -> {
            map.replace("allfeeSum", map.get("allfeeSum").add(BigDecimal.valueOf(itm.getChargeFee())));
            if (itm.getChrgitmLv().equals(ChrgitmLv.SELF_PAY.getCode())) {
                map.replace("totalThrd", map.get("totalThrd").add(BigDecimal.valueOf(itm.getChargeFee())));
            } else if (itm.getChrgitmLv().equals(ChrgitmLv.SECOND_CLASS.getCode())) {
                map.replace("totalScnd", map.get("totalScnd").add(BigDecimal.valueOf(itm.getChargeFee())));
            }
            String typeKey = itm.getMedChrgitmType();
            if (!typeKey.equals("09") && !typeKey.equals("11")) {
                map.replace("othSum", map.get("othSum").add(BigDecimal.valueOf(itm.getChargeFee())));
                if (itm.getChrgitmLv().equals(ChrgitmLv.SELF_PAY.getCode())) {
                    map.replace("othThrd", map.get("othThrd").add(BigDecimal.valueOf(itm.getChargeFee())));
                } else if (itm.getChrgitmLv().equals(ChrgitmLv.SECOND_CLASS.getCode())) {
                    map.replace("othScnd", map.get("othScnd").add(BigDecimal.valueOf(itm.getChargeFee())));
                }
            } else {
                String lvKey = typeKey + "-" + itm.getChrgitmLv();
                if (map.containsKey(typeKey)) {
                    map.replace(typeKey, map.get(typeKey).add(BigDecimal.valueOf(itm.getChargeFee())));
                } else {
                    map.put(typeKey, BigDecimal.valueOf(itm.getChargeFee()));
                }
                if (map.containsKey(lvKey)) {
                    map.replace(lvKey, map.get(lvKey).add(BigDecimal.valueOf(itm.getChargeFee())));
                } else {
                    map.put(lvKey, BigDecimal.valueOf(itm.getChargeFee()));
                }
            }

        });
        lst.setAllfeeSum(map.get("allfeeSum"));
        lst.setAllfeeThrd(map.get("totalThrd"));
        lst.setAllfeeScnd(map.get("totalScnd"));
        lst.setWestMedFeeSum(map.get("09"));
        lst.setWestMedFeeThrd(map.get("09-03"));
        lst.setWestMedFeeScnd(map.get("09-02"));
        lst.setChnsPtntSum(map.get("11"));
        lst.setChnsPtntThrd(map.get("11-03"));
        lst.setChnsPtntScnd(map.get("11-02"));
        lst.setMedsrvcSum(map.get("othSum"));
        lst.setMedsrvcThrd(map.get("othThrd"));
        lst.setMedsrvcScnd(map.get("othScnd"));
    }

    public ResultVo<List<SiMzMatnDise>> queryMzMatnDises() {
        return ResultVoUtil.success(dao.selectAllMzMatnDises());
    }

    public ResultVo<List<SetlStatisticResult>> selectSetlinfoStatistics(SetlCondition condition) {
        String begntime = condition.getMonth() + "-01 00:00:00.000";
        String endtime = DateUtil.getMonthEndtime(condition.getMonth());
        List<BaseSetlStatistics> baseStatistics;
        if (condition.getAdmdvs() == 1) {
            baseStatistics = dao.selectBaseSetlStatisticsInProvince(begntime, endtime, condition.getInsutype());
        } else {
            baseStatistics = dao.selectBaseSetlStatisticsOutProvince(begntime, endtime, condition.getInsutype());
        }
        if (null == baseStatistics || baseStatistics.isEmpty()) {
            return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST);
        }

        Map<String, List<BaseSetlStatistics>> tempMap = new HashMap<>();
        baseStatistics.forEach(itm -> {
            String key = itm.getInsuplcAdmdvs();
            if (tempMap.containsKey(key)) {
                tempMap.get(key).add(itm);
            } else {
                List<BaseSetlStatistics> tempList = new ArrayList<>();
                tempList.add(itm);
                tempMap.put(key, tempList);
            }
        });

        Map<String, List<BaseSetlStatistics>> admNameMap = new HashMap<>();
        for (Map.Entry<String, List<BaseSetlStatistics>> entry : tempMap.entrySet()) {
            String admdvs = entry.getKey();
            String admdvsName = dao.selectRegionName(admdvs);
            if (StringUtil.isBlank(admdvsName)) {
                admdvsName = dao.selectAdmdvsName(admdvs);
                if (StringUtil.isBlank(admdvsName)) {
                    admdvs = admdvs.substring(0, 4) + "00";
                    admdvsName = dao.selectRegionName(admdvs);
                }
            }
            if (admNameMap.containsKey(admdvsName)) {
                admNameMap.get(admdvsName).addAll(entry.getValue());
            } else {
                admNameMap.put(admdvsName, entry.getValue());
            }
        }

        List<SetlStatisticResult> resultList = new ArrayList<>();
        for (Map.Entry<String, List<BaseSetlStatistics>> entry : admNameMap.entrySet()) {
            List<BaseSetlStatistics> mapStatistics = entry.getValue();
            SetlStatisticResult resultItem = new SetlStatisticResult();
            resultItem.setAdmdvsName(entry.getKey());
            resultItem.setPsnSumamt(mapStatistics.size());
            String medfeeSumamt = "0";
            String baseMedFundpaySumamt = "0";
            String bigDssFundpaySumamt = "0";
            String clvFundpaySumamt = "0";
            String acctpaySumamt = "0";
            String othFundpaySumamt = "0";
            String fundpaySumamt = "0";
            for (BaseSetlStatistics itm : mapStatistics) {
                medfeeSumamt = DecimalUtil.add(medfeeSumamt, itm.getMedfeeSumamt());
                baseMedFundpaySumamt = DecimalUtil.add(baseMedFundpaySumamt, itm.getHifpPay());
                bigDssFundpaySumamt = DecimalUtil.add(bigDssFundpaySumamt, itm.getHifmiPay());
                clvFundpaySumamt = DecimalUtil.add(clvFundpaySumamt, itm.getCvlservPay());
                acctpaySumamt = DecimalUtil.add(acctpaySumamt, itm.getAcctPay());
                fundpaySumamt = DecimalUtil.add(fundpaySumamt, itm.getFundPaySumamt());
                String othpay = DecimalUtil.minusLink(itm.getFundPaySumamt(), itm.getHifpPay(),
                        itm.getHifmiPay(), itm.getCvlservPay(), itm.getAcctPay());
                othFundpaySumamt = DecimalUtil.add(othFundpaySumamt, othpay);
            }
            resultItem.setMedfeeSumamt(medfeeSumamt);
            resultItem.setBaseMedFundpaySumamt(baseMedFundpaySumamt);
            resultItem.setBigDssFundpaySumamt(bigDssFundpaySumamt);
            resultItem.setClvFundpaySumamt(clvFundpaySumamt);
            resultItem.setAcctpaySumamt(acctpaySumamt);
            resultItem.setOthFundpaySumamt(othFundpaySumamt);
            resultItem.setFundpaySumamt(fundpaySumamt);
            resultList.add(resultItem);
        }
        return ResultVoUtil.success(resultList);
    }
}