From e4e220916dd2a4aa649a9b0162e5b5ed0dc9d7e5 Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期二, 20 五月 2025 10:36:54 +0800 Subject: [PATCH] 代码提交 --- ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java | 50 ++++++++++++++++++++++++++------------------------ 1 files changed, 26 insertions(+), 24 deletions(-) diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java index d35f49d..c6eb5c5 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java @@ -13,9 +13,11 @@ 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.LSHospTokenUtil; import com.smartor.domain.*; import com.smartor.mapper.ServiceSubtaskMapper; import com.smartor.mapper.ServiceTaskMapper; @@ -305,23 +307,15 @@ * @return */ public boolean isDateToday(Date date) { - //濡傛灉缁欑殑鏃ユ湡灏忎簬褰撳墠鏃ユ湡锛屼篃鐩存帴鍙戦�� - LocalDateTime localDateTime = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime(); - if (localDateTime.isBefore(LocalDateTime.now())) { - return true; + if (date == null) { + return false; } - // 鑾峰彇褰撳墠鏃ユ湡 - Calendar calendarNow = Calendar.getInstance(); - int todayYear = calendarNow.get(Calendar.YEAR); - int todayMonth = calendarNow.get(Calendar.MONTH); - int todayDay = calendarNow.get(Calendar.DAY_OF_MONTH); - - // 鍒涘缓涓�涓� Calendar 瀹炰緥鐢ㄤ簬妫�鏌ョ殑鏃ユ湡 - Calendar calendarToCheck = Calendar.getInstance(); - calendarToCheck.setTime(date); - - // 姣旇緝骞淬�佹湀鍜屾棩 - return (calendarToCheck.get(Calendar.YEAR) == todayYear && calendarToCheck.get(Calendar.MONTH) == todayMonth && calendarToCheck.get(Calendar.DAY_OF_MONTH) == todayDay); + // 灏� Date 杞负 LocalDate + LocalDate localDate = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDate(); + // 鑾峰彇浠婂ぉ鐨� LocalDate + LocalDate today = LocalDate.now(); + // 濡傛灉鏃ユ湡鏃╀簬鎴栫瓑浜庝粖澶╋紝杩斿洖 true + return !localDate.isAfter(today); } public void sfHandlle(CommonTaskcallMQ commonTaskcallMQ, String ip) { @@ -482,8 +476,9 @@ isSuccess = HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(req)); } else if (visitHosp == 2) { //涓芥按鐨勭煭淇″彂閫佹柟寮� - String address = MsgLSEnum.getAddressByCode(serviceSubtask.getOrgid()); - if (StringUtils.isEmpty(address)) { + 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("鐭俊鍙戦�佸け璐�,璇ユ満鏋勬病鏈夐厤缃煭淇″湴鍧�"); @@ -493,12 +488,12 @@ serviceSubtaskMapper.updateServiceSubtask(ss); continue; } - log.error("---------涓芥按鐭俊鍙戦�佸叆鍙俛ddress锛歿}, sendMagParam:{}, orgid:{}-------", address,sendMagParam,serviceSubtask.getOrgid()); - String dxCode = getDXCode(address, sendMagParam.getPhone(), sendMagParam.getContent(), "", "", MsgLSEnum.getHeaderByCode(serviceSubtask.getOrgid())); + log.error("---------涓芥按鐭俊鍙戦�佸叆鍙俛ddress锛歿}, 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(); + String code = textParam.get("Code").toString(); if (code.equals("0")) { isSuccess = "true"; } @@ -607,6 +602,7 @@ if ((Boolean) map.get("succ") == true) { serviceSubtask.setResult("success"); } else { + log.error("serviceSubtask1231313鐨勫�间负锛歿}", serviceSubtask); serviceSubtask.setResult("error"); serviceSubtask.setSendstate(5L); serviceSubtask.setRemark(map.get("msg").toString()); @@ -843,7 +839,7 @@ return key; } - private String getDXCode(String address, String ShouJiHM, String FaSongNR, String FaSongRID, String FaSongRXM, Map<String, Object> headerMap) { + 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<>(); @@ -855,11 +851,17 @@ YeWuXX.put("DuanXinXX", DuanXinXX); map.put("XiaoXiTou", headerMap); - map.put("DuanXinXX", DuanXinXX); + map.put("YeWuXX", YeWuXX); String body = new Gson().toJson(map); - String result = HttpUtils.sendPost(address, body); +// 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); -- Gitblit v1.9.3