From e87b711cc267567d8374315dc99ef9780cb25dd8 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期三, 26 三月 2025 17:55:57 +0800 Subject: [PATCH] 代码初始化 --- server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java | 110 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 109 insertions(+), 1 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java b/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java index 42d8d40..408a033 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java @@ -629,10 +629,118 @@ }catch (Exception e){ } - } + /** + * 鏈堝彴绛惧埌閫氱煡 + * @param wxNoticeConfigMapper + * @param platformJob + * @param objCode + * @param token + * @param openIds + */ + public void sendPlatformJobSignNotice(WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,String token, + List<String> openIds){ + try{ + if(CollectionUtils.isNotEmpty(openIds)){ + WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.platformJob) + .eq(WxNoticeConfig::getObjCode,objCode) + .eq(WxNoticeConfig::getStatus, Constants.ZERO) + .last(" limit 1") + ); + if(Objects.isNull(wxNoticeConfig)){ + return; + } + String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token; + //鏁翠綋鍙傛暟map + Map<String, Object> paramMap = new HashMap<String, Object>(); + //娑堟伅涓婚鏄剧ず鐩稿叧map + Map<String, Object> dataMap = new HashMap<String, Object>(); + //杞︾墝鍙� + Map<String, Object> car_number1 = new HashMap<String,Object>(); + car_number1.put("value",platformJob.getCarCodeFront()); + //鍙告満濮撳悕 + Map<String, Object> thing2 = new HashMap<String,Object>(); + thing2.put("value",platformJob.getDriverName()); + //绛惧埌鏃堕棿 + Map<String, Object> time5 = new HashMap<String,Object>(); + time5.put("value", DateUtil.getFomartDate(platformJob.getSignDate(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss")); + + dataMap.put("car_number1",car_number1); + dataMap.put("thing2",thing2); + dataMap.put("time5",time5); + for (String openId:openIds) { + paramMap.clear(); + paramMap.put("template_id", wxNoticeConfig.getTempId()); + paramMap.put("touser", openId); + paramMap.put("data", dataMap); + String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap)); + log.error("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭唴瀹癸細{}", JSONObject.toJSONString(paramMap)); + if(StringUtils.isBlank(response)){ + log.error("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触"); + }else{ + JSONObject json = JSONObject.parseObject(response); + log.error("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg")); + } + } + } + }catch (Exception e){ + + } + } + + public void sendUnFinishNotice(WxNoticeConfigMapper wxNoticeConfigMapper,Integer unFinishNum,String objCode,String token, + List<String> openIds){ + try{ + if(CollectionUtils.isNotEmpty(openIds)){ + WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.platformJob) + .eq(WxNoticeConfig::getObjCode,objCode) + .eq(WxNoticeConfig::getStatus, Constants.ZERO) + .last(" limit 1") + ); + if(Objects.isNull(wxNoticeConfig)){ + return; + } + String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token; + //鏁翠綋鍙傛暟map + Map<String, Object> paramMap = new HashMap<String, Object>(); + //娑堟伅涓婚鏄剧ず鐩稿叧map + Map<String, Object> dataMap = new HashMap<String, Object>(); + //杞︾墝鍙� + Map<String, Object> const1 = new HashMap<String,Object>(); + const1.put("value","浣滀笟浠诲姟鏈畬鎴�"); + //鍙告満濮撳悕 + Map<String, Object> thing2 = new HashMap<String,Object>(); + thing2.put("value",unFinishNum+"涓�"); + //绛惧埌鏃堕棿 + Map<String, Object> time3 = new HashMap<String,Object>(); + time3.put("value", DateUtil.getFomartDate(new Date(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss")); + + dataMap.put("const1",const1); + dataMap.put("thing2",thing2); + dataMap.put("time3",time3); + for (String openId:openIds) { + paramMap.clear(); + paramMap.put("template_id", wxNoticeConfig.getTempId()); + paramMap.put("touser", openId); + paramMap.put("data", dataMap); + String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap)); + log.error("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭唴瀹癸細{}", JSONObject.toJSONString(paramMap)); + if(StringUtils.isBlank(response)){ + log.error("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触"); + }else{ + JSONObject json = JSONObject.parseObject(response); + log.error("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg")); + } + } + } + }catch (Exception e){ + + } + } + + public void sendMeetTemplateNotice(SystemDictDataBiz systemDictDataBiz,SmsEmail smsEmail,String token){ try{ String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(), -- Gitblit v1.9.3