银医通下载代码变更

src/main/java/com/yihu/wlyy/controller/MqSdkController.java

@@ -424,10 +424,12 @@ public class MqSdkController /*extends EnvelopRestEndpoint */{
    @GetMapping(value = "/yytDown")
    @ApiOperation(value = " 银医通下载 ")
    public String yytDown() {
    public String yytDown(
            @ApiParam(name = "cardNo", value = "卡号", required = true)
            @RequestParam(value = "cardNo") String cardNo) {
        try {
            String  obj="";
           obj= caService.callYYTServerService();
           obj= caService.callYYTServerService(cardNo);
//            System.out.println("obj=="+obj);
        } catch (Exception e) {
            e.printStackTrace();

src/main/java/com/yihu/wlyy/service/CAService.java

@@ -3,6 +3,9 @@ package com.yihu.wlyy.service;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yihu.wlyy.util.StringUtil;
import com.yihu.wlyy.util.WebserviceUtil;
import net.sf.json.JSON;
import net.sf.json.JSONObject;
import net.sf.json.xml.XMLSerializer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -51,23 +54,14 @@ public class CAService {
    /**
     * 银医通下载
     **/
    public String callYYTServerService() throws Exception {
    public String callYYTServerService(String cardNo) throws Exception {
        String re = "";
        String action = YYT_DOWN;
        String info_xml = "<?xml version=\"1.0\" encoding=\"utf-16\"?>\n" +
                "<root>\n" +
                "<ip>172.16.50.40</ip>\n" +
                "<port>5516</port>\n" +
                "<compress_encode_flag>1</compress_encode_flag>\n" +
                "</root>\n";
        String reqmsg_xml = "<?xml version=\"1.0\" encoding=\"utf-16\"?>\n" +
                "<root><sick_id>DB8687139</sick_id>\n" +
                "<cus_card_no>DB8687139</cus_card_no>\n" +
                "<req_type>2001</req_type><\n" +
                "trade_type>2001</trade_type>\n" +
                "<req_oper>8644</req_oper>\n" +
                "<req_term>192001019019</req_term>\n" +
                "<win_no>6</win_no></root>\n";
        String info_xml = "<?xml version=\"1.0\" encoding=\"utf-16\"?>" +
                "<root><ip>172.16.50.40</ip><port>5516</port></root>";
        String reqmsg_xml = "<?xml version=\"1.0\" encoding=\"utf-16\"?>" +
                "<root><sick_id>"+cardNo+"</sick_id><cus_card_no>"+cardNo+"</cus_card_no>" +
                "<req_type>2001</req_type><trade_type>2001</trade_type><req_oper>8644</req_oper><req_term>192001019019</req_term><win_no>6</win_no></root>";
        try {
            Map<String, String> params = new HashMap<>();
            params.put("ServerInfo", info_xml);
@@ -75,6 +69,18 @@ public class CAService {
            String urlString = "http://172.16.50.40:80/ZyXmyytRequestService/ZyXmyytRequestServiceWs.dll?Handler=ZyXmyytRequestServiceWsService";
            String namespace = "zysoft";
            re= WebserviceUtil.post(urlString,namespace,action,params);
            XMLSerializer xmlSerializer = new XMLSerializer();
            JSON json = xmlSerializer.read(re);
            Object errorCode=  ((JSONObject) json).get("error_code");
            if("ok".equals(errorCode)){
                JSON json2 = xmlSerializer.read(((JSONObject) json).get("response").toString());
                System.out.println("银医通下载response:"+json2.toString(1));
            }else {
                Object errorMsg=((JSONObject) json).get("error_msg");
                //{"error_type":"0","error_code":"10002","error_msg":"卡号无效"}
               throw new Exception("银医通下载失败，"+errorMsg);
            }
            System.out.println("json="+json.toString(1));
            if (StringUtil.isEmpty(re)) {
                throw new Exception("返回为空！");
            } else {

src/main/java/com/yihu/wlyy/service/EntranceService.java

@@ -7,6 +7,7 @@ import org.json.JSONArray;
import org.json.JSONObject;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -511,6 +512,18 @@ public class EntranceService {
        if (StringUtils.isNotBlank(doctor)) {
            sbs.append("<query compy=\"=\" item=\"CON_DOC\" splice=\"and\" value=\"'" + doctor + "'\"/>");
        }
        //获取当前时间 查询当前时间往前推24小时是否有挂号 （医保当天有效，自费24小时有效）
      String now=  DateUtil.dateToStr(DateUtil.getNowDate(),DateUtil.YYYY_MM_DD_HH_MM_SS);
      System.out.println("new="+now);
      String preday=  DateUtil.dateToStr(DateUtil.getPreDays(DateUtil.getNowDate(),-1),DateUtil.YYYY_MM_DD_HH_MM_SS);
        System.out.println("preDay="+preday);
//        if (StringUtils.isNotBlank(preday)) {
//            sbs.append("<query compy=\"&gt;\" item=\"ADM_DAT\" splice=\"and\" value=\"'" + preday + "'\"/>");
//        }
//        if (StringUtils.isNotBlank(now)) {
//            sbs.append("<query compy=\"&lt;\" item=\"ADM_DAT\" splice=\"and\" value=\"'" + now + "'\"/>");
//        }
        sbs.append("<order item=\"ADM_DAT\" sort=\"desc\"/>");
        //查询信息结束
        sbs.append("</MsgInfo></ESBEntry>");
        String resp = MqSdkUtil.putReqAndGetRespByQueryStr(sbs.toString(), fid);