web_server/src/main/java/thyyxxk/webserver/service/PublicServer.java

package thyyxxk.webserver.service;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.ListUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import thyyxxk.webserver.config.exception.BizException;
import thyyxxk.webserver.config.exception.ExceptionEnum;
import thyyxxk.webserver.dao.his.PublicDao;
import thyyxxk.webserver.dao.his.yibao.TransferInOfExpensesDao;
import thyyxxk.webserver.entity.ResultVo;
import thyyxxk.webserver.entity.datamodify.GetDropdownBox;
import thyyxxk.webserver.entity.datamodify.ZyDetailCharge;
import thyyxxk.webserver.entity.login.UserInfo;
import thyyxxk.webserver.entity.yibao.ZyActpatient;
import thyyxxk.webserver.utils.*;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * <p>
 * 描述： 公共接口
 * </p>
 *
 * @author xc
 * @date 2021-09-17 10:54
 */
@Service
@Slf4j
public class PublicServer {
    private final PublicDao dao;

    private final TransferInOfExpensesDao transferInOfExpensesDao;


    public PublicServer(PublicDao dao, TransferInOfExpensesDao transferInOfExpensesDao) {
        this.dao = dao;
        this.transferInOfExpensesDao = transferInOfExpensesDao;
    }

    /**
     * 获取用户的角色信息
     *
     * @return 返回角色
     */
    public ResultVo<List<Integer>> getRoleCode() {
        return ResultVoUtil.success(dao.huoQuJueSe(TokenUtil.getTokenUserId()));
    }

    /**
     * @param jueSeBianMa 不需要限制的角色id
     * @return Boolean
     */
    public Boolean needRule(int[] jueSeBianMa) {
        return getaBoolean(jueSeBianMa, getRoleCode().getData());
    }

    public Boolean getaBoolean(int[] jueSeBianMa, List<Integer> roleCode) {
        if (ListUtil.isBlank(roleCode)) {
            return true;
        }
        if (roleCode.contains(1)) {
            return false;
        }
        for (Integer i : jueSeBianMa) {
            if (roleCode.contains(i)) {
                return false;
            }
        }
        return true;
    }

    /**
     * @param jueSeBianMa 不需要限制的角色id
     * @return Boolean
     */
    public Boolean needRule(List<Integer> role, int[] jueSeBianMa) {
        return getaBoolean(jueSeBianMa, role);
    }


    /**
     * 获取新的医嘱号
     *
     * @return 返回医嘱号
     */
    public float getActOrderNo() {
        dao.lockTable();
        float actOrderNo = dao.getActOrderNo() + 1;
        dao.updateActOrderNo(actOrderNo);
        return actOrderNo;
    }

    /**
     * 获取模板的编码
     *
     * @return 返回编码信息
     */
    public String getPatternCode() {
        dao.lockTable();
        Integer patternCode = dao.getPatternCode() + 1;
        dao.updatePatternCode(patternCode);
        return patternCode.toString();
    }

    public float getPatternOrderCode() {
        dao.lockTable();
        float patternOrderCode = dao.getPatternOrderCode() + 1;
        dao.updatePatternOrderCode(patternOrderCode);
        return patternOrderCode;
    }

    /**
     * @param inpatientNo 住院号
     * @return 返回婴儿标志
     */
    public int getInfantFlag(String inpatientNo) {
        if (StringUtil.isBlank(inpatientNo)) {
            return 0;
        }
        if (inpatientNo.contains("$")) {
            return 1;
        }
        return 0;
    }

    /**
     * 返回
     *
     * @param inpatientNo 住院号
     * @return 返回新住院号
     */
    public String getInpatientNo(String inpatientNo) {
        if (StringUtil.isBlank(inpatientNo)) {
            return "";
        }
        if (inpatientNo.contains("$")) {
            inpatientNo = inpatientNo.split("\\$")[0];
        }
        return inpatientNo;
    }


    /**
     * 获取最大流水号
     *
     * @param inpatientNo 住院号
     * @param admissTimes 住院次数
     * @return 返回 流水
     */
    public Integer getMaxDetailSn(String inpatientNo, Integer admissTimes) {
        return transferInOfExpensesDao.getMaxDetailSn(inpatientNo, admissTimes);
    }

    /**
     * 获取科室的子科室和本科
     *
     * @param deptCode 科室代码
     * @return 返回科室
     */
    public List<String> getKeShiLieBiaoList(String deptCode) {
        if (StringUtil.isBlank(deptCode) || deptCode.equals("3100000")) {
            return new ArrayList<>();
        }
        return dao.getKeShiLieBiao(deptCode);
    }

    /**
     * 获取科室的子科室和本科
     *
     * @param deptCodeList 科室代码
     * @return 返回科室
     */
    public List<String> getKeShiLieBiaoList(List<String> deptCodeList) {
        if (ListUtil.isBlank(deptCodeList)) {
            return new ArrayList<>();
        }
        return dao.getKeShiLieBiaoList(deptCodeList);
    }

    /**
     * 获取人员信息
     *
     * @param code 人员代码
     * @return 返回人员
     */
    public ResultVo<List<GetDropdownBox>> getRenYuan(String code) {
        return ResultVoUtil.success(dao.getRenYuan(StringUtil.isContainChinese(code)));
    }

    /**
     * 搜索项目信息
     *
     * @param pyCode 拼音码
     * @return 返回项目信息
     */
    public ResultVo<List<GetDropdownBox>> getChargeCode(String pyCode) {
        log.info("获取编码：{}", pyCode);
        return ResultVoUtil.success(dao.getChargeCode(StringUtil.isContainChinese(pyCode)));
    }

    /**
     * 获取科室信息
     *
     * @return 返回科室
     */
    public ResultVo<List<GetDropdownBox>> getDept() {
        return ResultVoUtil.success(dao.getDept());
    }

    /**
     * 获取这个人的账页号
     *
     * @param inpatientNo 住院号
     * @param admissTimes 住院次数
     * @return 返回有用的账页号
     */
    public Integer getLedgerSn(String inpatientNo, Integer admissTimes) {
        if (StringUtil.isBlank(inpatientNo) || admissTimes == null) {
            return 0;
        }
        inpatientNo = getInpatientNo(inpatientNo);
        return dao.getLedgerSn(inpatientNo, admissTimes);
    }

    /**
     * 更新患者的退费对应的正流水号
     *
     * @param inpatientNo 住院号
     * @param admissTimes 住院次数
     * @param ledger      账页号
     */
    public void genXingYuanLiuShuiBiaoZhi(String inpatientNo, Integer admissTimes, Integer ledger) {
        dao.chongZhiZhenLiuShui(inpatientNo, admissTimes, ledger);
        // 这里是重置 正流水号
        List<Integer> huoQuTuiFeiYuanLiuShui = dao.huoQuTuiFeiYuanLiuShui(inpatientNo, admissTimes, ledger);
        if (ListUtil.notBlank(huoQuTuiFeiYuanLiuShui)) {
            List<List<Integer>> fenGeFuLiuShui = ListUtils.partition(huoQuTuiFeiYuanLiuShui, 50);
            for (List<Integer> integers : fenGeFuLiuShui) {
                dao.genXingFuShuDuiYingZhenLiuShui(inpatientNo, admissTimes, ledger, integers);
            }
        }
        // 这里是判断正数的是否没有了,如果正数的没有了 那么负数的就要更新为空
        List<Integer> xuYaoQingKongDeFuLiuShui = new ArrayList<>();
        List<Integer> zhenShuLiuShuiMap = dao.zhenShuLiuShui(inpatientNo, admissTimes, ledger);
        List<Integer> fuShuLiuShui = dao.fuShuLiuShui(inpatientNo, admissTimes, ledger);
        for (Integer integer : fuShuLiuShui) {
            if (!zhenShuLiuShuiMap.contains(integer) && !xuYaoQingKongDeFuLiuShui.contains(integer)) {
                xuYaoQingKongDeFuLiuShui.add(integer);
            }
        }
        if (ListUtil.notBlank(xuYaoQingKongDeFuLiuShui)) {
            List<List<Integer>> list = ListUtils.partition(xuYaoQingKongDeFuLiuShui, 50);
            for (List<Integer> integers : list) {
                dao.chongZhiFuShuYuanLiuShui(inpatientNo, admissTimes, ledger, integers);
            }
        }
        // 这里判断是否重复退费，退多了
        Map<Integer, ZyDetailCharge> chongFuYuanLiuShuiMap = dao.chongFuTuiFeiLiuShui(inpatientNo, admissTimes, ledger).stream().collect(
                Collectors.toMap(ZyDetailCharge::getOriDetailSn, a -> a, (k1, k2) -> k1)
        );
        if (!chongFuYuanLiuShuiMap.isEmpty()) {
            List<ZyDetailCharge> chongFuTuiFeiZhenShu = dao.getZhenShuLiuShui(inpatientNo, admissTimes, ledger, chongFuYuanLiuShuiMap.keySet());
            List<Integer> xuYaoChongZhiLiuShui = new ArrayList<>();
            if (ListUtil.notBlank(chongFuTuiFeiZhenShu)) {
                for (ZyDetailCharge zyDetailCharge : chongFuTuiFeiZhenShu) {
                    ZyDetailCharge zy = chongFuYuanLiuShuiMap.get(zyDetailCharge.getDetailSn());
                    if (BigUtils.bigXiaoYu(zyDetailCharge.getChargeFee(), zy.getChargeFee().negate())) {
                        xuYaoChongZhiLiuShui.add(zyDetailCharge.getDetailSn());
                    }
                }
            }
            // 这里更新
            if (ListUtil.notBlank(xuYaoChongZhiLiuShui)) {
                dao.chongFuTuiFeiChongZhi(inpatientNo, admissTimes, ledger, xuYaoChongZhiLiuShui);
            }
        }
        // 这个是判断 trans_flag_yb = 2 费用相加 不为 0 的 就重置一下
        if (!BigUtils.dengYu(dao.zhenFuXingDiFeiYong(inpatientNo, admissTimes, ledger), 0)) {
            dao.chongXingZhengFuXiangDi(inpatientNo, admissTimes, ledger);
        }
    }

    /**
     * 获取员工信息
     *
     * @param code 编码
     * @return 返回
     */
    public UserInfo huoQuYuanGongXinXi(String code) {
        if (StringUtil.isBlank(code)) {
            return new UserInfo();
        }
        return dao.huoQuYuanGongBianMa(code);
    }


    public List<String> huoQuBingFangDeKeShi(String deptCode) {
        if (getRoleCode().getData().contains(1) || getRoleCode().getData().contains(8) || StringUtil.isBlank(deptCode)) {
            return new ArrayList<>();
        }
        List<String> keShiDaiMa = dao.bingFangSuoSuKeShi(deptCode);
        if (ListUtil.isBlank(keShiDaiMa)) {
            keShiDaiMa.add(deptCode);
        }
        return keShiDaiMa;
    }

    /**
     * 这里的住院号是没有 处理过得
     *
     * @param inpatientNo 住院号
     * @return 返回病人基本信息
     */
    public ZyActpatient huoQuHuanZheXinXi(String inpatientNo) {
        if (StringUtil.isBlank(inpatientNo)) {
            throw new BizException(ExceptionEnum.NULL_POINTER, "住院号为空。");
        }
        ZyActpatient zyActpatient = dao.getHuanZheJiBenXinXi(inpatientNo);
        log.info("查询患者的信息在院：住院号{}", inpatientNo);
        if (zyActpatient == null) {
            throw new BizException(ExceptionEnum.NULL_POINTER, "没有查询到患者的基本信息。");
        }
        zyActpatient.setInfantFlag(getInfantFlag(zyActpatient.getInpatientNo()));
        zyActpatient.setInpatientNo(getInpatientNo(zyActpatient.getInpatientNo()));
        return zyActpatient;
    }

    /**
     * 这里是重置流水
     *
     * @param patNo 住院号
     * @param times 住院次数
     */
    @Transactional(rollbackFor = Exception.class)
    public void chongZhiLiuShui(String patNo, Integer times) {
        List<ZyDetailCharge> paiXu = dao.huoQuZhongYeFeiYong(patNo, times);
        log.info("获取数据：{}", JSON.toJSONString(paiXu));
        int maxDetailSn = dao.maxDetailSn(patNo, times);

        List<List<ZyDetailCharge>> fenDuan = ListUtils.partition(paiXu, 100);
        for (List<ZyDetailCharge> zyDetailCharges : fenDuan) {
            dao.chongZhiLiuShui(patNo, times, zyDetailCharges, maxDetailSn);
        }

        for (List<ZyDetailCharge> zyDetailCharges : fenDuan) {
            dao.chongZhiLiuShui(patNo, times, zyDetailCharges, 0);
        }

    }

    /**
     * 获取麻醉方式
     *
     * @return 返回数据
     */
    public ResultVo<List<GetDropdownBox>> maZuiFangShi() {
        return ResultVoUtil.success(dao.maZuiFangShi());
    }

}