smartor代码库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liusheng
2025-04-27 cd8795008a6c7cf0046ecb7ee794e43032bfb798 
 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java


@@ -72,6 +72,9 @@


    private IPatMedInhospService iPatMedInhospService;




    @Autowired


    private IPatMedOuthospService iPatMedOuthospService;




    @Autowired


    private IPatMedOperationService iPatMedOperationService;




    @Autowired


@@ -100,6 +103,9 @@




    @Value("${req_path}")


    private String req_path;




    @Value("${visitHosp}")


    private Integer visitHosp;




    @Autowired


    private ServiceTaskMapper serviceTaskMapper;


@@ -133,6 +139,9 @@




    @Value("${hosp_info_url}")


    private String hospInfoUrl;




    @Value("${appid}")


    private String appid;




    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {


        System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));


@@ -220,7 +229,7 @@


    public void dealHisData2() {


        //将患者信息、出院、门诊数据全部采集


        // 指定的开始日期


        LocalDate endDate = LocalDate.of(2024, 9, 1);


        LocalDate endDate = LocalDate.of(2025, 3, 3);


        // 当前日期


        LocalDate currentDate = LocalDate.now();


        // 定义日期格式


@@ -239,7 +248,12 @@


     * 处理患者信息，进入子任务表


     */


    public void dealOutHospInfo() {


        //出院表


        iPatMedInhospService.dealOutHospInfo();


        //门诊表


        if (visitHosp != 1) {


            iPatMedOuthospService.dealOutpatientInfo();


        }


    }






@@ -335,6 +349,14 @@


                            //如何任务被“暂停”或“终止”


                            break;


                        }


                        if (org.apache.commons.lang3.StringUtils.isEmpty(serviceSubtask.getPhone())) {


                            serviceSubtask.setRemark("手机号为空");


                            serviceSubtask.setSendstate(4L);


                            serviceSubtask.setResult("error");


                            serviceSubtask.setFinishtime(new Date());


                            serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);


                            continue;


                        }


                        boolean dateToday = isDateToday(serviceSubtask.getLongSendTime());


                        //说明是立即发送(先把消息放到cache-0中，   displayNo不知道怎么配置)


                        if (dateToday) {


@@ -404,6 +426,8 @@


                            ssvo.setCreateStartTime(startOfDayDate);


                            ssvo.setCreateEndTime(endOfDayDate);


                            ssvo.setCreateBy(serviceSubtask.getCreateBy());


                            ssvo.setSendname(serviceSubtask.getSendname());


                            ssvo.setSfzh(serviceSubtask.getSfzh());


                            List<ServiceSubtask> serviceSubtaskListByCreateTime = serviceSubtaskMapper.selectServiceSubtaskListByCreateTime(ssvo);


                            if (CollectionUtils.isEmpty(serviceSubtaskListByCreateTime))


                                serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);


@@ -509,7 +533,10 @@


                                String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);


                                String url = null;


                                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(), "无");




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




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




                                //任务发送记录


@@ -590,7 +617,7 @@


        String filename = null;


        if (cry.equals("0")) filename = "入院信息" + System.currentTimeMillis();


        if (cry.equals("1")) filename = "出院信息" + System.currentTimeMillis();


        File file = new File("D:\\public\\华卓集成平台数据\\" + filename);


        File file = new File("D:\\public\\HIS数据采集\\" + filename);


        if (!file.exists()) {


            // 如果文件不存在，则创建新文件


            try {


@@ -643,7 +670,7 @@


                    patArchive.setPlaceOfResidence(StringUtils.isNotEmpty(thiedInhospInfo.getPatiHomeAddr()) ? thiedInhospInfo.getPatiHomeAddr().replace("null", "") : "");


                    try {


                        if (StringUtils.isNotEmpty(thiedInhospInfo.getPatiBirthday()))


                            patArchive.setBirthdate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(thiedInhospInfo.getPatiBirthday()));


                            patArchive.setBirthdate(new SimpleDateFormat("yyyy-MM-dd").parse(thiedInhospInfo.getPatiBirthday()));


                    } catch (ParseException e) {


                        e.printStackTrace();


                    }


@@ -672,6 +699,7 @@


                patMedInhosp.setNurseId(thiedInhospInfo.getNurseId());


                patMedInhosp.setNurseName(thiedInhospInfo.getNurseName());


                patMedInhosp.setSerialnum(thiedInhospInfo.getInpatientId());


                patMedInhosp.setFuflag("1");


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


                    patMedInhosp.setInhospstate("0");


                } else if (cry.equals("1")) {


@@ -764,22 +792,23 @@


        return key;


    }




    private String getWXCode(String idcard, String url, String taskName, String taskDesc, String submitprompt) {


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


        XinHuaWXReq xinHuaWXReq = new XinHuaWXReq();


        xinHuaWXReq.setIdcard(idcard);


        xinHuaWXReq.setUrl(url);


        xinHuaWXReq.setKeyword1("浙中医大二院出院随访");


        xinHuaWXReq.setKeyword2(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));


        xinHuaWXReq.setKeyword3(taskName);


        xinHuaWXReq.setKeyword4("疾病康复注意事项");




        xinHuaWXReq.setPatientid(setPatientid);


        xinHuaWXReq.setPatientname(setPatientname);


        xinHuaWXReq.setMobile(phone);


        xinHuaWXReq.setMedcardno(null);


        xinHuaWXReq.setTitlename(taskName);


        xinHuaWXReq.setContent(taskDesc);


        xinHuaWXReq.setAppid(appid);


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


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


        JSONObject jsonObject = JSONObject.parseObject(result);


        log.error("jsonObject的数据为：{}", jsonObject.toString());


//        String code = (String) jsonObject.get("code");


        return jsonObject.toString();


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


        return code;


    }




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


//        LocalDateTime originalDateTime = LocalDateTime.now();


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