眼科医保结算流程

business/base-service/pom.xml

@@ -84,6 +84,11 @@
            <groupId>com.yihu.jw</groupId>
            <artifactId>common-util</artifactId>
        </dependency>
        <dependency>
            <groupId>com.nuonuo</groupId>
            <artifactId>open-sdk</artifactId>
            <version>1.0.5.2</version>
        </dependency>
        <!--   poi xml导入导出工具 end -->
        <!-- mq消息 start -->

business/base-service/src/main/java/com/yihu/jw/hospital/healthCare/YlzMedicailRelationDao.java

@@ -21,6 +21,9 @@ public interface YlzMedicailRelationDao extends PagingAndSortingRepository<YlzMe
    @Query("from YlzMedicalRelationDO a where   a.relationCode = ?1 and a.state=1 ")
    List<YlzMedicalRelationDO> findByOutpatientStatus(String outpatientId);
    @Query("from YlzMedicalRelationDO a where   a.relationCode = ?1  ")
    List<YlzMedicalRelationDO> findByOutpatientNoStatus(String outpatientId);
    @Query("from YlzMedicalRelationDO a where   a.relationCode = ?1 and a.state=1 and a.pageCode=?2 ")
    YlzMedicalRelationDO findByOutpatientPageCode(String outpatientId,String code);

business/base-service/src/main/java/com/yihu/jw/hospital/healthCare/YlzMedicailRelationInvoiceDao.java

@@ -0,0 +1,20 @@
package com.yihu.jw.hospital.healthCare;
import com.yihu.jw.entity.hospital.healthCare.YlzMedicalMxDO;
import com.yihu.jw.entity.hospital.healthCare.YlzMedicalRelationInvoiceDO;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import java.util.List;
/**
 * Created by wangzhinan 20211003
 */
public interface YlzMedicailRelationInvoiceDao extends PagingAndSortingRepository<YlzMedicalRelationInvoiceDO, String>, JpaSpecificationExecutor<YlzMedicalRelationInvoiceDO> {
    @Query("from YlzMedicalRelationInvoiceDO a where a.medicalId = ?1 ")
    YlzMedicalRelationInvoiceDO findByMedicalId(String medicalId);
}

business/base-service/src/main/java/com/yihu/jw/hospital/prescription/service/PrescriptionService.java

@@ -7453,7 +7453,7 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
                    " base_doctor d " +
                    " JOIN base_doctor_hospital h ON d.id= h.doctor_code " +
                    " WHERE  " +
                    " h.org_code ='" + codes + "'";
                    " h.org_code ='" + codes + "' and d.del=1 ";
            List<Map<String, Object>> doctors = jdbcTemplate.queryForList(sql);
            List<WlyyDoctorWorkTimeDO> workTimeDOs = makeDoctorWorkTimeDOList(doctors, wlyyDoctorWorkTimeDOs);
            saveDoctorWorkTime(workTimeDOs, date, doctors);
@@ -7470,7 +7470,7 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
                    " base_doctor d " +
                    " JOIN base_doctor_hospital h ON d.id= h.doctor_code " +
                    " WHERE  " +
                    " h.dept_code in (" + sqlCode(codes) + ")";
                    " h.dept_code in (" + sqlCode(codes) + ") and d.del=1 ";
            List<Map<String, Object>> doctors = jdbcTemplate.queryForList(sql);
            List<WlyyDoctorWorkTimeDO> workTimeDOs = makeDoctorWorkTimeDOList(doctors, wlyyDoctorWorkTimeDOs);
            saveDoctorWorkTime(workTimeDOs, date, doctors);
@@ -7486,7 +7486,7 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
                    " base_doctor d " +
                    " JOIN base_doctor_hospital h ON d.id= h.doctor_code " +
                    " WHERE  " +
                    " d.id in (" + sqlCode(codes) + ")";
                    " d.id in (" + sqlCode(codes) + ") and d.del=1 ";
            List<Map<String, Object>> doctors = jdbcTemplate.queryForList(sql);
            List<WlyyDoctorWorkTimeDO> workTimeDOs = makeDoctorWorkTimeDOList(doctors, wlyyDoctorWorkTimeDOs);
            saveDoctorWorkTime(workTimeDOs, date, doctors);
@@ -7641,7 +7641,7 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
                if (!workMonths.contains(workMonth)) {
                    workMonths.add(workMonth);
                    List<WlyyDoctorWorkTimeDO> oldTimes = doctorWorkTimeDao.findDoctorWorkTimeByMonth(time.getDoctor(), "%" + time.getDate().substring(0, 7) + "%");
                    doctorWorkTimeDao.delete(oldTimes);
                    deleteWorkTime(oldTimes);
                }
            }
            doctorWorkTimeDao.save(workTimeDOs);
@@ -7652,7 +7652,7 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
                for (String dt : d) {
                    for (Map<String, Object> doc : doctors) {
                        List<WlyyDoctorWorkTimeDO> oldTimes = doctorWorkTimeDao.findDoctorWorkTimeByMonth((String) doc.get("id"), "%" + dt + "%");
                        doctorWorkTimeDao.delete(oldTimes);
                        deleteWorkTime(oldTimes);
                    }
                }
            }
@@ -7660,6 +7660,10 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
        return true;
    }
    public void deleteWorkTime(List<WlyyDoctorWorkTimeDO> doctorWorkTimeDOS){
        doctorWorkTimeDao.delete(doctorWorkTimeDOS);
    }
    /**
     * 更新医生
@@ -14792,11 +14796,11 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
                object.put("getSettleInfo", ylzMedicalRelationDO);
                return object;
            }
            try {
          /*  try {*/
                ylzMedicalRelationDO = hcyyPrescriptionService.getSettlementInfo(outpatientDO.getCardNo(), outpatientDO.getId());
            } catch (Exception e) {
        /*    } catch (Exception e) {
                throw new Exception(e.getMessage());
            }
            }*/
            if (ylzMedicalRelationDO==null){
                throw new Exception("无待结算信息");
            }

business/base-service/src/main/java/com/yihu/jw/hospital/prescription/service/YkyyPrescriptionService.java

@@ -1,6 +1,7 @@
package com.yihu.jw.hospital.prescription.service;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.ObjectMapper;
@@ -22,18 +23,23 @@ import com.yihu.jw.entity.hospital.consult.WlyyHospitalWaitingRoomDO;
import com.yihu.jw.entity.hospital.dict.WlyyChargeDictDO;
import com.yihu.jw.entity.hospital.doctor.WlyyPatientRegisterTimeDO;
import com.yihu.jw.entity.hospital.family.WlyyPatientFamilyMemberDO;
import com.yihu.jw.entity.hospital.healthCare.YlzMedicalMxDO;
import com.yihu.jw.entity.hospital.healthCare.YlzMedicalRelationDO;
import com.yihu.jw.entity.hospital.healthCare.YlzMedicalRelationInvoiceDO;
import com.yihu.jw.entity.hospital.mapping.DoctorMappingDO;
import com.yihu.jw.entity.hospital.mapping.PatientMappingDO;
import com.yihu.jw.entity.hospital.prescription.*;
import com.yihu.jw.entity.order.BusinessOrderDO;
import com.yihu.jw.entity.util.StringFStringEncryptConverter;
import com.yihu.jw.hospital.consult.dao.HospitalWaitingRoomDao;
import com.yihu.jw.hospital.dict.WlyyChargeDictDao;
import com.yihu.jw.hospital.dict.WlyyHospitalSysDictDao;
import com.yihu.jw.hospital.doctor.dao.PatientRegisterTimeDao;
import com.yihu.jw.hospital.drugstore.dao.BaseDrugStoreDao;
import com.yihu.jw.hospital.family.dao.WlyyPatientFamilyMemberDao;
import com.yihu.jw.hospital.healthCare.YlzMedicailMxDao;
import com.yihu.jw.hospital.healthCare.YlzMedicailRelationDao;
import com.yihu.jw.hospital.healthCare.YlzMedicailRelationInvoiceDao;
import com.yihu.jw.hospital.mapping.dao.DoctorMappingDao;
import com.yihu.jw.hospital.mapping.dao.PatientMappingDao;
import com.yihu.jw.hospital.mapping.service.PatientMappingService;
@@ -46,6 +52,7 @@ import com.yihu.jw.patient.dao.BasePatientDao;
import com.yihu.jw.patient.dao.BasePatientMedicareCardDao;
import com.yihu.jw.restmodel.hospital.prescription.WlyyOutpatientVO;
import com.yihu.jw.restmodel.hospital.prescription.WlyyPrescriptionVO;
import com.yihu.jw.rm.base.BaseRequestMapping;
import com.yihu.jw.util.common.IdCardUtil;
import com.yihu.jw.util.date.DateUtil;
import com.yihu.jw.util.http.HttpClientUtil;
@@ -57,6 +64,8 @@ import com.yihu.mysql.query.BaseJpaService;
import com.yihu.utils.network.HttpResponse;
import com.yihu.utils.network.HttpUtils;
import com.yihu.utils.security.MD5;
import jdk.nashorn.internal.ir.IfNode;
import nuonuo.open.sdk.NNOpenSDK;
import org.apache.commons.collections.map.HashedMap;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
@@ -66,11 +75,7 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.*;
/**
 * Created by Trick on 2019/5/17.
@@ -145,6 +150,7 @@ public class YkyyPrescriptionService extends BaseJpaService<WlyyPrescriptionDO,
    private PrescriptionLogDao prescriptionLogDao;
    private final static String saveUrl="http://192.168.20.55:10023/ykyy/save";
    private final static String url="http://192.168.20.55:10023/ykyy/createSQLQuery";
    @Value("${demo.flag}")
@@ -163,6 +169,21 @@ public class YkyyPrescriptionService extends BaseJpaService<WlyyPrescriptionDO,
    private YkyySMSService ykyySMSService;
    @Autowired
    private PrescriptionService prescriptionService;
    private static String dzfpToken;
    private static String saleraddress;
    private static String saleraccount;
    private static String salertaxnum;
    private static String salertel;
    private static String dzfpAppKey;
    private static String dzfpAppSecret;
    private static String goodsname;
    private static String taxrate;
    @Autowired
    private YlzMedicailMxDao ylzMedicailMxDao;
    @Autowired
    private YlzMedicailRelationInvoiceDao ylzMedicailRelationInvoiceDao;
    /**
     * 获取居民就诊记录接口
     * @param patient
@@ -1259,7 +1280,25 @@ public class YkyyPrescriptionService extends BaseJpaService<WlyyPrescriptionDO,
            boolean flag = true;
            if (ylzMedicalRelationDO.getMedicalState()==null||(ylzMedicalRelationDO.getMedicalState()!=null&&ylzMedicalRelationDO.getMedicalState()==0)){
                flag=true;
                YlzMedicalRelationInvoiceDO invoiceDO = new YlzMedicalRelationInvoiceDO();
                try {
                    logger.info("=================电子发票开具开始=================");
                    requestBillingNew(outpatientId,1);
                    invoiceDO = queryInvoiceResult(outpatientId);
                    logger.info("=================电子发票开具结束=================");
                }catch (Exception e){
                    e.printStackTrace();
                }
            }else {
                YlzMedicalRelationInvoiceDO invoiceDO = new YlzMedicalRelationInvoiceDO();
                try {
                    logger.info("=================电子发票开具开始=================");
                    requestBillingNew(outpatientId,1);
                    invoiceDO = queryInvoiceResult(outpatientId);
                    logger.info("=================电子发票开具结束=================");
                }catch (Exception e){
                    e.printStackTrace();
                }
                HlwMzybjsDO hlwMzybjsDO = new HlwMzybjsDO();
                hlwMzybjsDO.setInsuranceSerial(ylzMedicalRelationDO.getInsuranceSerial());
                hlwMzybjsDO.setAccountBalance(Double.parseDouble(ylzMedicalRelationDO.getAccountBalance()));
@@ -1308,6 +1347,7 @@ public class YkyyPrescriptionService extends BaseJpaService<WlyyPrescriptionDO,
                hlwMzybjsDO.setPayTime(DateUtil.dateToShortStrHh(ylzMedicalRelationDO.getPayDate()));
                hlwMzybjsDO.setCollector(ylzMedicalRelationDO.getCollector());
                hlwMzybjsDO.setJsrq(new Date());
                hlwMzybjsDO.setFphm(invoiceDO.getInvoiceNo());
                String jsonString1 = JSONObject.toJSONString(hlwMzybjsDO);
                logger.info("医保结算============");
                Map<String,Object> params1 = new HashedMap();
@@ -1420,13 +1460,7 @@ public class YkyyPrescriptionService extends BaseJpaService<WlyyPrescriptionDO,
                        realOrder = prescriptionDO.getRealOrder();
                    }
                }
                try {
                    /*logger.info("=================电子发票开具开始=================");
                    hcyyEntranceService.OutpatientInvoicing(ylzMedicalRelationDO.getHisBillSerial(),"lb");
                    logger.info("=================电子发票开具结束=================");*/
                }catch (Exception e){
                    e.printStackTrace();
                }
                return "结算成功！";
            }else {
@@ -1440,29 +1474,232 @@ public class YkyyPrescriptionService extends BaseJpaService<WlyyPrescriptionDO,
   //============================电子发票=========================
    public String dzfp() throws Exception {
        String url = "http://10.110.98.135:8090/dataReport/services/HipService?wsdl";
        String namespace="OutPatientBilling";
        String api="OutPatientBilling";
        String msgHeader ="<Sender>HIS</Sender>\n" +
                "<MsgType>MR_0101</MsgType>\n" +
                "<MsgVersion>3.0</MsgVersion>";
        String param = "\t<ClerkId>王云海</ClerkId>\n" +
                "\t<BuyerName>王云海</BuyerName>\n" +
                "\t<BuyerTaxNum></BuyerTaxNum>\n" +
                "\t<BuyerTel>13850005761</BuyerTel>\n" +
                "\t<BuyerAddress></BuyerAddress>\n" +
                "\t<BuyerAccount></BuyerAccount>\n" +
                "\t<PushMode>1</PushMode>\n" +
                "\t<BuyerPhone></BuyerPhone>\n" +
                "\t<Email></Email>\n" +
                "\t<PatientId>569768</PatientId>\n" +
                "\t<BillNo>123456</BillNo>\n" +
                "\t<Extra></Extra>";
        Map<String,String> params = new HashedMap();
        String parameter= "<BSXml>"+msgHeader+param+"</BSXml>";
        params.put("parameter",parameter);
        return WebserviceUtil.postYk(url,api,params);
    /**
     * 初始化电子发票固定参数
     * @throws Exception
     */
    public void getHisDzfpInfo() throws Exception {
        if (!demoFlag){
            salertaxnum = "110000999999003";
            dzfpAppKey="23760028";
            dzfpAppSecret="45591CA66F8D4589";
            dzfpToken="44d50530356519e60973b70cwqn46acs";
            salertaxnum="110000999999003";
            saleraddress="福建省厦门市厦禾路336号";
            saleraccount="建行厦门市厦禾支行 35101561001052502781";
            salertel = "0592-2109113 2109829";
            goodsname = "医疗费用";
            taxrate = "0";
        }else {
            String sql = "select saleraddress as \"saleraddress\",saleraccount as \"saleraccount\",salertaxnum as \"salertaxnum\",salertel as \"salertel\",goodsname as \"goodsname\",taxrate as \"taxrate\" from V_HLWYY_DZFP_HEAD ";
            JSONArray array = new JSONArray();
            Map<String,Object> params = new HashedMap();
            params.put("sql",sql);
            logger.info("getHisDzfpInfo："+sql);
            HttpResponse response = HttpUtils.doGet(url,params);
            String content = response.getContent();
            logger.info("response:"+content);
            JSONObject rs = JSON.parseObject(content);
            Integer status = rs.getInteger("status");
            if (status==200){
                array = rs.getJSONArray("detailModelList");
                if (array!=null&&array.size()!=0){
                    JSONObject object = array.getJSONObject(0);
                    salertaxnum = object.getString("salertaxnum");
                    dzfpAppKey="13680495";
                    dzfpAppSecret="391834ED4EEC429F";
                    dzfpToken="9f279f9cd5adca46fc6b220cxt1sr1qs";
                    saleraddress=object.getString("saleraddress");
                    saleraccount=object.getString("saleraccount");
                    salertel = object.getString("salertel");
                    goodsname = object.getString("goodsname");
                    taxrate = object.getString("taxrate");
                }
            }
        }
    }
    /**
     *
     * @param outpatientId
     * @param flag 1蓝票2红票
     * @return
     * @throws Exception
     */
    public String requestBillingNew(String outpatientId,Integer flag) throws Exception {
        getHisDzfpInfo();
        NNOpenSDK sdk = NNOpenSDK.getIntance();
        String taxnum = salertaxnum; // 授权企业税号
        String appKey = dzfpAppKey;
        String appSecret = dzfpAppSecret;
        String method = "nuonuo.ElectronInvoice.requestBillingNew"; // API方法名
        List<YlzMedicalRelationDO> medicalRelationDOS = ylzMedicailRelationDao.findByOutpatientNoStatus(outpatientId);
        YlzMedicalRelationDO medicalRelationDO = new YlzMedicalRelationDO();
        if (medicalRelationDOS!=null&&medicalRelationDOS.size()!=0){
            medicalRelationDO = medicalRelationDOS.get(0);
        }
        List<YlzMedicalMxDO> medicalMxDOS = ylzMedicailMxDao.findByMedicalId(medicalRelationDO.getId());
        YlzMedicalRelationInvoiceDO ylzMedicalRelationInvoiceDO = ylzMedicailRelationInvoiceDao.findByMedicalId(medicalRelationDO.getId());
        if (ylzMedicalRelationInvoiceDO==null){
            ylzMedicalRelationInvoiceDO = new YlzMedicalRelationInvoiceDO();
        }
        String token = dzfpToken; // 访问令
        String content = "";
        JSONObject object = new JSONObject();
        JSONObject order = new JSONObject();
        order.put("buyerName","王云海");
        order.put("buyerTaxNum",salertaxnum);
        order.put("buyerTel",salertel);
        order.put("buyerAddress",saleraddress);
        order.put("buyerAccount",saleraccount);
        order.put("salerTaxNum",salertaxnum);
        order.put("salerTel",salertel);
        order.put("salerAddress",saleraddress);
        order.put("salerAccount",saleraccount);
        order.put("orderNo",medicalRelationDO.getHisSettleNo());
        order.put("invoiceDate","2022-01-13 12:30:00");//订单时间
        order.put("clerkId","2527");
        order.put("clerk","互联网医院");
        order.put("pushMode","-1");//推送方式：-1,不推送;0,邮箱;1,手机（默认）;2,邮箱、手机
        order.put("buyerPhone","13850005761");//购方手机（pushMode为1或2时，此项为必填，同时受企业资质是否必填控制）
        if (flag==1){
            order.put("invoiceType","1");//开票类型：1:蓝票;2:红票 （全电发票暂不支持红票）
            ylzMedicalRelationInvoiceDO.setStatus(1);
        }else {
            if (!StringUtils.isNoneBlank(ylzMedicalRelationInvoiceDO.getInvoiceCode())){
                throw new Exception("发票代码为空，不能冲红");
            }
            order.put("invoiceType","2");//开票类型：1:蓝票;2:红票 （全电发票暂不支持红票）
            order.put("invoiceCode","");//
            order.put("invoiceNum","");//
            ylzMedicalRelationInvoiceDO.setStatus(2);
        }
        order.put("invoiceLine","p");
        order.put("specificFactor","0");
        order.put("proxyInvoiceFlag","0");
        JSONArray array = new JSONArray();
        for (YlzMedicalMxDO mxDO:medicalMxDOS){
            JSONObject invoice = new JSONObject();
            if (flag==2){
                invoice.put("taxExcludedAmount","-"+mxDO.getTotalMoney());
                invoice.put("taxIncludedAmount","-"+mxDO.getTotalMoney());
                invoice.put("num","-"+mxDO.getAmount());//数量
            }else {
                invoice.put("taxExcludedAmount",mxDO.getTotalMoney());
                invoice.put("taxIncludedAmount",mxDO.getTotalMoney());
                invoice.put("num",mxDO.getAmount());//数量
            }
            invoice.put("goodsName",goodsname);
            invoice.put("withTaxFlag",0);//单价含税标志：0:不含税,1:含税
            invoice.put("taxRate",taxrate);//税率
            invoice.put("invoiceLineProperty",0);//发票行性质：0,正常行;1,折扣行;2,被折扣行，红票只有正常行
            invoice.put("price",mxDO.getTotalMoney());//单价（精确到小数点后8位），当单价(price)为空时，数量(num)也必须为空；(price)为空时，含税金额(taxIncludedAmount)、不含税金额(taxExcludedAmount)、税额(tax)都不能为空
            invoice.put("unit",mxDO.getChargeUnit());//单位
            invoice.put("specType",mxDO.getSpecificationType());//规格型号
            invoice.put("tax",0);//
            invoice.put("zeroRateFlag",3);//
            invoice.put("deduction",0);
            array.add(invoice);
        }
        order.put("invoiceDetail",array);
        object.put("order",order);
        content = object.toJSONString();
        String url = "https://sdk.nuonuo.com/open/v1/services"; // SDK请求地址
        String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
        logger.info("开具电子发票入参数"+content+"=============="+"url:"+url+"token:"+token+"taxnum:"+taxnum+"appKey:"+appKey+"appSecret:"+appSecret);
        String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
        JSONObject jsonObject = JSONObject.parseObject(result);
        if (jsonObject.getString("code").equalsIgnoreCase("E0000")){
            JSONObject res = jsonObject.getJSONObject("result");
            ylzMedicalRelationInvoiceDO.setInvoiceSerialNum(res.getString("invoiceSerialNum"));
            ylzMedicalRelationInvoiceDO.setUpdateTime(new Date());
            ylzMedicalRelationInvoiceDO.setMedicalId(medicalRelationDO.getId());
            ylzMedicailRelationInvoiceDao.save(ylzMedicalRelationInvoiceDO);
        }
        System.out.println("开具电子发票结果："+result);
        return result;
    }
    /**
     * 用户作废已开票成功的发票
     *
     * @return
     */
    public String invoiceCancellation(String invoiceId,String invoiceNo,String invoiceCode) throws Exception {
        getHisDzfpInfo();
        NNOpenSDK sdk = NNOpenSDK.getIntance();
        String taxnum = salertaxnum; // 授权企业税号
        String appKey = dzfpAppKey;
        String appSecret = dzfpAppSecret;
        String method = "nuonuo.electronInvoice.invoiceCancellation"; // API方法名
        String token = dzfpToken; // 访问令牌
        JSONObject object = new JSONObject();
        object.put("invoiceId",invoiceId);//发票流水号
        object.put("invoiceNo",invoiceNo);//发票代码
        object.put("invoiceCode",invoiceCode);//发票号码
        String content = object.toJSONString();
        String url = "https://sdk.nuonuo.com/open/v1/services"; // SDK请求地址
        String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
        logger.info("作废电子发票入参数"+content+"=============="+"url:"+url+"token:"+token+"taxnum:"+taxnum+"appKey:"+appKey+"appSecret:"+appSecret);
        String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
        System.out.println("作废电子发票结果："+result);
        return result;
    }
    /**
     * 调用该接口获取发票开票结果等有关发票信息，部分字段需要配置才返回
     * @return
     */
    public YlzMedicalRelationInvoiceDO queryInvoiceResult(String outpatientId) throws Exception {
        List<YlzMedicalRelationDO> medicalRelationDOS = ylzMedicailRelationDao.findByOutpatientNoStatus(outpatientId);
        YlzMedicalRelationDO medicalRelationDO = new YlzMedicalRelationDO();
        if (medicalRelationDOS!=null&&medicalRelationDOS.size()!=0){
            medicalRelationDO = medicalRelationDOS.get(0);
        }
        YlzMedicalRelationInvoiceDO ylzMedicalRelationInvoiceDO = ylzMedicailRelationInvoiceDao.findByMedicalId(medicalRelationDO.getId());
        if (ylzMedicalRelationInvoiceDO==null){
            ylzMedicalRelationInvoiceDO = new YlzMedicalRelationInvoiceDO();
            ylzMedicalRelationInvoiceDO.setMedicalId(medicalRelationDO.getId());
            ylzMedicalRelationInvoiceDO.setStatus(1);
        }
        getHisDzfpInfo();
        NNOpenSDK sdk = NNOpenSDK.getIntance();
        String taxnum = salertaxnum; // 授权企业税号
        String appKey = dzfpAppKey;
        String appSecret = dzfpAppSecret;
        String token = dzfpToken; // 访问令牌
        String method = "nuonuo.ElectronInvoice.queryInvoiceResult"; // API方法名
        JSONObject object = new JSONObject();
        object.put("isOfferInvoiceDetail",1);//是否需要提供明细(不填默认false)
        JSONArray orderNos= new JSONArray();
        orderNos.add(medicalRelationDO.getHisSettleNo());
        object.put("orderNos",orderNos);//订单编号
        JSONArray serialNos = new JSONArray();
        object.put("serialNos",serialNos);//发票流水号，两字段二选一，同时存在以流水号为准
        String content = object.toJSONString();
        String url = "https://sdk.nuonuo.com/open/v1/services"; // SDK请求地址
        String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
        logger.info("查询电子发票入参数"+content+"=============="+"url:"+url+"token:"+token+"taxnum:"+taxnum+"appKey:"+appKey+"appSecret:"+appSecret);
        String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
        System.out.println("查询电子发票结果"+result);
        JSONObject jsonObject = JSONObject.parseObject(result);
        if (jsonObject.getString("code").equalsIgnoreCase("E0000")){
            JSONArray array = jsonObject.getJSONArray("result");
            if (array!=null&&array.size()!=0){
                JSONObject res = array.getJSONObject(0);
                ylzMedicalRelationInvoiceDO.setInvoiceCode(res.getString("invoiceCode"));
                ylzMedicalRelationInvoiceDO.setInvoicePdf(res.getString("pdfUrl"));
                ylzMedicalRelationInvoiceDO.setInvoiceNo(res.getString("invoiceNo"));
                ylzMedicalRelationInvoiceDO.setResult(result);
                ylzMedicalRelationInvoiceDO.setCreateTime(new Date());
                ylzMedicailRelationInvoiceDao.save(ylzMedicalRelationInvoiceDO);
            }
        }
        return ylzMedicalRelationInvoiceDO;
    }
}

business/base-service/src/main/java/com/yihu/jw/utils/WebserviceUtil.java

@@ -2,9 +2,9 @@ package com.yihu.jw.utils;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import org.apache.axis.message.SOAPHeaderElement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import javax.xml.namespace.QName;
import java.util.Map;
@@ -70,64 +70,4 @@ public class WebserviceUtil {
        }
    }
    /**
     * webservice 调用接口
     */
    public static String postYk(String urlString,String api, Map<String,String> params) throws Exception {
        try {
            logger.info("url:"+urlString);
            logger.info("service:"+api);
            Service service = new Service();
            logger.info("=======>通过service创建call对象");
            Call call = (Call) service.createCall();// 通过service创建call对象
            logger.info("=======>设置service所在URL");
            // 设置service所在URL
            call.setTargetEndpointAddress(new java.net.URL(urlString));
            call.setOperationName(new QName(api));
            call.setUseSOAPAction(true);
            Object[] objs = new Object[1];
            logger.info("=======>组装参数:"+params.size());
            SOAPHeaderElement header = new SOAPHeaderElement("", "AuthenticationToken");
            header.setPrefix("");
            header.addChildElement("urid").addTextNode("HIS");
            header.addChildElement("pwd").addTextNode("HIS");
            call.addHeader(header);
            call.addParameter(new QName("parameter"), org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);//接口的参数
            logger.info("=======>参数值:"+params.get("parameter"));
            objs[0]=params.get("parameter");
           /* if(params!=null && params.size()>0)
            {
                logger.info("=======>遍历参数");
                objs = new Object[params.size()];
                int i=0;
                for(String key : params.keySet())
                {
                    logger.info("=======>参数key:"+key);
                    logger.info("=======>接口参数:"+key);
                    call.addParameter(new QName(key), org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);//接口的参数
                    logger.info("=======>参数值:"+params.get(key));
                    objs[i] = params.get(key);
                    i++;
                }
            }*/
            logger.info("=======>设置返回类型");
            call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);//设置返回类型
            logger.info("=======>开始请求");
            String  ret = (String)call.invoke(objs);
            logger.info("=======>请求结果："+ret);
            logger.info("=======>请求结果.toString()："+ret.toString());
            return ret.toString();
        } catch (Exception e) {
            logger.info("=======>CA请求报错："+e.getMessage());
            e.printStackTrace();
            throw e;
        }
    }
}

common/common-entity/src/main/java/com/yihu/jw/entity/hospital/healthCare/YlzMedicalRelationInvoiceDO.java

@@ -0,0 +1,81 @@
package com.yihu.jw.entity.hospital.healthCare;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.yihu.jw.entity.UuidIdentityEntity;
import com.yihu.jw.entity.UuidIdentityEntityWithOperator;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import java.util.Date;
/**
 * Created by wangzhinan on 20211003
 */
@Entity
@Table(name = "base_ylz_relaiton_invoice")
public class YlzMedicalRelationInvoiceDO extends UuidIdentityEntityWithOperator {
    private String medicalId;
    private String invoiceSerialNum;//发票流水号
    private String invoiceCode;//发票代码
    private String invoiceNo;//发票号码
    private String invoicePdf;//发票pdf
    private Integer status;//0开具失败1开具成功2作废
    private String result;//发票查询结果
    public String getMedicalId() {
        return medicalId;
    }
    public void setMedicalId(String medicalId) {
        this.medicalId = medicalId;
    }
    public String getInvoiceSerialNum() {
        return invoiceSerialNum;
    }
    public void setInvoiceSerialNum(String invoiceSerialNum) {
        this.invoiceSerialNum = invoiceSerialNum;
    }
    public String getInvoiceCode() {
        return invoiceCode;
    }
    public void setInvoiceCode(String invoiceCode) {
        this.invoiceCode = invoiceCode;
    }
    public String getInvoiceNo() {
        return invoiceNo;
    }
    public void setInvoiceNo(String invoiceNo) {
        this.invoiceNo = invoiceNo;
    }
    public String getInvoicePdf() {
        return invoicePdf;
    }
    public void setInvoicePdf(String invoicePdf) {
        this.invoicePdf = invoicePdf;
    }
    public Integer getStatus() {
        return status;
    }
    public void setStatus(Integer status) {
        this.status = status;
    }
    public String getResult() {
        return result;
    }
    public void setResult(String result) {
        this.result = result;
    }
}

server/svr-authentication/src/main/resources/application.yml

@@ -718,7 +718,7 @@ testPattern:
  remote_inner_url: 172.16.100.240:10023/open/fileUpload/upload_stream
wechat:
  id: xm_zsyy_wx
  id: xm_znyg_wx
im:
  im_list_get: http://172.26.0.105:3000/

svr/svr-internet-hospital/pom.xml

@@ -11,7 +11,7 @@
    </parent>
    <groupId>com.yihu.jw</groupId>
    <artifactId>svr-internet-hospital</artifactId>
    <artifactId>svr-internet-hospital-test</artifactId>
    <packaging>jar</packaging>
    <version>${parent.version}</version>
@@ -59,6 +59,7 @@
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
        <dependency>
            <groupId>org.json</groupId>
            <artifactId>json</artifactId>
@@ -267,7 +268,7 @@
    </dependencies>
    <build>
        <finalName>svr-internet-hospital</finalName>
        <finalName>svr-internet-hospital-test</finalName>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>

svr/svr-internet-hospital/src/main/java/com/yihu/jw/hospital/endpoint/ykyy/YkyyController.java

@@ -536,14 +536,44 @@ public class YkyyController extends EnvelopRestEndpoint {
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "dzfp", method = RequestMethod.POST)
    @ApiOperation("电子病历")
    public ObjEnvelop dzfp() throws Exception {
    @RequestMapping(value = "requestBillingNew", method = RequestMethod.POST)
    @ApiOperation("开具电子发票")
    public ObjEnvelop requestBillingNew(@ApiParam(name = "outpatientId", value = "outpatientId", required = true)
                                            @RequestParam(required = true)String outpatientId,
                                        @ApiParam(name = "flag", value = "1蓝票2红票", required = true)
                                        @RequestParam(required = true)Integer flag) throws Exception {
        try {
            ykyyPrescriptionService.dzfp();
            return ObjEnvelop.getSuccess("ok","");
            return ObjEnvelop.getSuccess("ok",ykyyPrescriptionService.requestBillingNew(outpatientId,flag));
        } catch (Exception e) {
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @RequestMapping(value = "queryInvoiceResult", method = RequestMethod.POST)
    @ApiOperation("电子发票结果查询" )
    public ObjEnvelop queryInvoiceResult(@ApiParam(name = "outpatientId", value = "outpatientId", required = true)
                                             @RequestParam(required = true)String outpatientId) throws Exception {
        try {
            return ObjEnvelop.getSuccess("ok",ykyyPrescriptionService.queryInvoiceResult(outpatientId));
        } catch (Exception e) {
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @RequestMapping(value = "invoiceCancellation", method = RequestMethod.POST)
    @ApiOperation("电子发票作废")
    public ObjEnvelop invoiceCancellation(@ApiParam(name = "invoiceId", value = "invoiceId", required = true)
                                              @RequestParam(required = true)String invoiceId,
                                          @ApiParam(name = "invoiceNo", value = "invoiceNo", required = true)
                                          @RequestParam(required = true)String invoiceNo,
                                          @ApiParam(name = "invoiceCode", value = "invoiceCode", required = true)
                                              @RequestParam(required = true)String invoiceCode) throws Exception {
        try {
            return ObjEnvelop.getSuccess("ok",ykyyPrescriptionService.invoiceCancellation(invoiceId,invoiceNo,invoiceCode));
        } catch (Exception e) {
            return ObjEnvelop.getError(e.getMessage());
        }
    }
}