smartor代码库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liusheng
8 天以前 9cc2f53b11205309754c2451be061ef5fc337f32 
 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java


@@ -1,8 +1,6 @@


package com.ruoyi.quartz.task;




import com.alibaba.fastjson2.JSON;


import com.alibaba.fastjson2.JSONObject;


import com.fasterxml.jackson.core.JsonParser;


import com.fasterxml.jackson.databind.JsonNode;


import com.fasterxml.jackson.databind.ObjectMapper;


import com.google.common.reflect.TypeToken;


@@ -10,19 +8,21 @@


import com.google.gson.JsonArray;


import com.google.gson.JsonObject;


import com.ruoyi.common.core.redis.RedisCache;


import com.ruoyi.common.enums.MsgLSEnum;


import com.ruoyi.common.enums.ServiceFromEnum;


import com.ruoyi.common.utils.DtoConversionUtils;


import com.ruoyi.common.enums.WxGZHEnum;


import com.ruoyi.common.exception.base.BaseException;


import com.ruoyi.common.utils.HttpUtil;


import com.ruoyi.common.utils.OkHttpExample;


import com.ruoyi.common.utils.RSAPublicKeyExample;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.common.utils.http.HttpUtils;


import com.smartor.common.SendService;


import com.smartor.common.LSHospTokenUtil;


import com.smartor.domain.*;


import com.smartor.mapper.ServiceSubtaskMapper;


import com.smartor.mapper.ServiceTaskMapper;


import com.smartor.mapper.SysUserImportMapper;


import com.smartor.service.*;


import com.sun.org.apache.bcel.internal.generic.NEW;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections4.CollectionUtils;


import org.apache.commons.lang3.ObjectUtils;


@@ -35,12 +35,12 @@


import java.io.File;


import java.io.FileWriter;


import java.io.IOException;


import java.io.UnsupportedEncodingException;


import java.lang.reflect.Type;


import java.net.URLEncoder;


import java.nio.charset.StandardCharsets;


import java.nio.file.Files;


import java.nio.file.Paths;


import java.security.MessageDigest;


import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.time.LocalDate;


@@ -50,6 +50,8 @@


import java.time.format.DateTimeFormatter;


import java.util.*;


import java.util.stream.Collectors;




import static cn.hutool.core.convert.Convert.toHex;




/**


 * 定时任务调度测试


@@ -97,9 +99,6 @@




    @Value("${pub_key}")


    private String pub_key;




    @Value("${thirdWXUrl}")


    private String thirdWXUrl;




    @Value("${req_path}")


    private String req_path;


@@ -477,10 +476,36 @@


                                sendMagParam.setPhone(serviceSubtask.getPhone());


                                sendMagParam.setUrl(ip + ":" + req_path + "/wt?p=" + format);


                                sendMagParam.setContent("【新华医院】您好，邀请您填写出院调查表，请点击" + sendMagParam.getUrl() + "填写。感谢您配合！");


                                Map<String, String> req = new HashMap<>();


                                req.put("phone", sendMagParam.getPhone());


                                req.put("content", sendMagParam.getContent());


                                String isSuccess = HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(req));


                                String isSuccess = null;


                                if (visitHosp == 1) {


                                    Map<String, String> req = new HashMap<>();


                                    req.put("phone", sendMagParam.getPhone());


                                    req.put("content", sendMagParam.getContent());


                                    isSuccess = HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(req));


                                } else if (visitHosp == 2) {


                                    //丽水的短信发送方式


                                    Map<String, String> map = MsgLSEnum.getAddressByCode(serviceSubtask.getOrgid());


                                    String token = LSHospTokenUtil.getToken(serviceSubtask.getOrgid());


                                    if (ObjectUtils.isNotEmpty(map) && StringUtils.isEmpty(map.get("address"))) {


                                        ServiceSubtask ss = new ServiceSubtask();


                                        ss.setResult("error");


                                        ss.setRemark("短信发送失败,该机构没有配置短信地址");


                                        ss.setSendstate(5L);


                                        ss.setId(serviceSubtask.getId());


                                        ss.setFinishtime(new Date());


                                        serviceSubtaskMapper.updateServiceSubtask(ss);


                                        continue;


                                    }


                                    log.error("---------丽水短信发送入参address：{},  sendMagParam:{},  orgid:{}-------", map.get("address"), sendMagParam, serviceSubtask.getOrgid());


                                    String dxCode = getDXCode(map.get("address"), sendMagParam.getPhone(), sendMagParam.getContent(), map.get("sendPersonId"), map.get("sendPersonName"), MsgLSEnum.getHeaderByCode(serviceSubtask.getOrgid()), token);


                                    log.error("---------丽水短信发送结果：{}-------", dxCode);


                                    ObjectMapper objectMapper = new ObjectMapper();


                                    Map<String, Object> textParam = objectMapper.readValue(dxCode, Map.class);


                                    String code = textParam.get("Code").toString();


                                    if (code.equals("0")) {


                                        isSuccess = "true";


                                    }


                                }


                                //任务发送记录


                                ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord();


                                serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString());


@@ -542,10 +567,32 @@


                                url = ip + ":" + req_path + "/outsideChainwt?param1=" + taskId + "&param2=" + patid + "&param3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "&param5=false";


//                                String wxCode = getWXCode(serviceSubtask.getSfzh(), url, serviceSubtask.getTaskName(), serviceSubtask.getTaskDesc(), "无");




                                String wxCode = getWXCode(serviceSubtask.getSfzh(), url, serviceSubtask.getTaskName(), serviceSubtask.getTaskDesc(), patArchive.getTelcode(), serviceSubtask.getSendname(), patArchive.getPatientno());


                                //获取微信公众号请求信息根据机构ID


                                List<String> wxqqxx = WxGZHEnum.getDescByCode(patArchive.getOrgid());


                                if (CollectionUtils.isEmpty(wxqqxx) || wxqqxx.size() < 4) {


                                    ServiceSubtask ss = new ServiceSubtask();


                                    ss.setResult("error");


                                    ss.setRemark("该机构的公众号配置信息不全，无法通过公众号发送");


                                    ss.setSendstate(5L);


                                    ss.setId(serviceSubtask.getId());


                                    ss.setFinishtime(new Date());


                                    serviceSubtaskMapper.updateServiceSubtask(ss);


                                    continue;


                                }




                                if (StringUtils.isEmpty(patArchive.getPatidHis())) {


                                    ServiceSubtask ss = new ServiceSubtask();


                                    ss.setResult("error");


                                    ss.setRemark("公众号发送失败,his系统的患者id为空");


                                    ss.setSendstate(5L);


                                    ss.setId(serviceSubtask.getId());


                                    ss.setFinishtime(new Date());


                                    serviceSubtaskMapper.updateServiceSubtask(ss);


                                    continue;


                                }


                                String wxCode = getWXCode(serviceSubtask.getSfzh(), url, serviceSubtask.getTaskName(), serviceSubtask.getTaskDesc(), patArchive.getTelcode(), serviceSubtask.getSendname(), patArchive.getPatidHis(), wxqqxx);




                                Map<String, Object> map = JSONObject.parseObject(wxCode, Map.class);




                                //任务发送记录


                                ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord();


                                serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString());


@@ -799,7 +846,38 @@


        return key;


    }




    private String getWXCode(String idcard, String url, String taskName, String taskDesc, String phone, String setPatientname, String setPatientid) {


    private String getDXCode(String address, String ShouJiHM, String FaSongNR, String FaSongRID, String FaSongRXM, Map<String, Object> headerMap, String token) {


        Map<String, Object> map = new LinkedHashMap<>();




        Map<String, Object> YeWuXX = new LinkedHashMap<>();


        Map<String, Object> DuanXinXX = new LinkedHashMap<>();


        DuanXinXX.put("ShouJiHM", ShouJiHM);


        DuanXinXX.put("FaSongNR", FaSongNR);


        DuanXinXX.put("FaSongRID", FaSongRID);


        DuanXinXX.put("FaSongRXM", FaSongRXM);


        YeWuXX.put("DuanXinXX", DuanXinXX);




        map.put("XiaoXiTou", headerMap);


        map.put("YeWuXX", YeWuXX);




        String body = new Gson().toJson(map);




//        String result = HttpUtils.sendPost(address, body);


        String result = null;


        try {


            result = OkHttpExample.sendPostRequest(address, body, token);


        } catch (IOException e) {


            e.printStackTrace();


        }


        log.error("--------result的值为：{}-----", result);




        JSONObject jsonObject = JSONObject.parseObject(result);


        String code = (String) jsonObject.toString();


        return code;


    }






    private String getWXCode(String idcard, String url, String taskName, String taskDesc, String phone, String setPatientname, String setPatientid, List<String> wxqqxx) {


        XinHuaWXReq xinHuaWXReq = new XinHuaWXReq();


        xinHuaWXReq.setIdcard(idcard);


        xinHuaWXReq.setUrl(url);


@@ -809,17 +887,31 @@


        xinHuaWXReq.setMedcardno(null);


        xinHuaWXReq.setTitlename(taskName);


        xinHuaWXReq.setContent(taskDesc);


        xinHuaWXReq.setAppid(appid);


        xinHuaWXReq.setAppid(wxqqxx.get(1));


        log.error("----getWXCode---xinHuaWXReq的出参为：{}", xinHuaWXReq);


        String result = HttpUtils.sendPost(thirdWXUrl, new Gson().toJson(xinHuaWXReq));


        String body = new Gson().toJson(xinHuaWXReq);


        String encode = encode(wxqqxx.get(2).concat(body));


        Map<String, String> headerMap = new HashMap<>();


        headerMap.put("sign", encode);


        String result = HttpUtils.sendPostByHeader(wxqqxx.get(3), body, headerMap);




        JSONObject jsonObject = JSONObject.parseObject(result);


        String code = (String) jsonObject.toString();


        return code;


    }


//    public static void main(String[] args) {


//        LocalDateTime originalDateTime = LocalDateTime.now();


//        LocalDateTime startOfDay = originalDateTime.with(LocalTime.MIN);


//        System.out.println("Original DateTime: " + originalDateTime);


//        System.out.println("Start of Day: " + startOfDay);


//    }






    public String encode(String arg) {


        if (arg == null) {


            arg = "";


        }


        MessageDigest md5 = null;


        try {


            md5 = MessageDigest.getInstance("MD5");


            md5.update(arg.getBytes("UTF-8"));


        } catch (Exception e) {


            e.printStackTrace();


        }


        return toHex(md5.digest());


    }


}