WinTeachTeam
/
IESExtension
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

up：单次发送订阅

Browse Source
develop
PL 2 weeks ago
parent 1bae224374
commit 6f2c55ce26
10 changed files with 1028 additions and 0 deletions
Show Stats Download Patch File Download Diff File

149
src/main/java/cn/teammodel/controller/frontend/WechatController.java
Unescape View File

@ -0,0 +1,149 @@
package cn.teammodel.controller.frontend;
import cn.hutool.json.JSONObject;
import cn.teammodel.common.R;
import cn.teammodel.manager.wx.WechatUtilService;
import cn.teammodel.model.dto.Wechat.*;
import cn.teammodel.model.vo.WechatResponseMsgVo;
import cn.teammodel.service.WechatService;
import com.alibaba.fastjson2.JSON;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.HashMap;
import java.util.Map;
@RestController
@RequestMapping("/wechat")
@Api(tags = "对接微信开放平台接口")
public class WechatController {
@Resource
private WechatUtilService wechatUtilService;
@Resource
private WechatService wechatService;
/**
* 获取openId
* @param reqDto
* @return
*/
@PostMapping("openId")
@ApiOperation("发送订阅消息")
public R<String> GetOpenId(@RequestBody @Valid BaseInfoReqDto reqDto){
String openIdReq = wechatUtilService.GetOpenId(reqDto.getCode());
JSONObject jsonObject = new JSONObject(openIdReq);
String openId = jsonObject.getStr("openid");
return R.success(openId);
}
/**
* 评价完成通知
* @param appraiseDto
* @return
*/
@PostMapping("send/appraise/message")
@ApiOperation("发送评价模板订阅消息")
public WechatResponseMsgVo SendAppraiseSubscriptionMessage(@RequestBody @Valid AppraiseReqDto appraiseDto) {
WechatResponseMsgVo wechatResponseMsgVo = wechatService.AppraisePushMsg(appraiseDto);
//WechatResponseMsgVo wechatResponseMsgVo = JSON.parseObject(sendMsg, WechatResponseMsgVo.class);
return wechatResponseMsgVo;
}
/**
* 考试成绩通知
* @param examReqDto
* @return
*/
@PostMapping("send/exam/message")
@ApiOperation("发送考试成绩订阅消息")
public WechatResponseMsgVo SendExamSubscriptionMessage(@RequestBody @Valid ExamReqDto examReqDto) {
WechatResponseMsgVo sendMsg = wechatService.ExamPushMsg(examReqDto);
return sendMsg;
}
/**
* 报告生成通知
* @param reportReqDto
* @return
*/
@PostMapping("send/report/message")
@ApiOperation("发送报告生成订阅消息")
public WechatResponseMsgVo SendReportSubscriptionMessage(@RequestBody @Valid ReportReqDto reportReqDto) {
WechatResponseMsgVo sendMsg = wechatService.ReportPushMsg(reportReqDto);
return sendMsg;
}
/**
* 职业测试报告通知
* @param vocationalReqDto
* @return
*/
@PostMapping("send/vocational/message")
@ApiOperation("发送职业测试报告订阅消息")
public WechatResponseMsgVo SendVocationalSubscriptionMessage(@RequestBody @Valid VocationalReqDto vocationalReqDto) {
WechatResponseMsgVo sendMsg = wechatService.VocationalPushMsg(vocationalReqDto);
return sendMsg;
}
/**
* 发送订阅消息
* @return
*/
@PostMapping("test/send/subscription/message")
@ApiOperation("测试发送订阅消息")
public String TestSendSubscriptionMessage() {
//String userId = ((TmdUserDetail) SecurityUtil.getAuthentication().getPrincipal()).getClaims().getSubject();
String token = wechatUtilService.GetToken();
String accessToken = wechatUtilService.GetAccessToken();
// 处理微信推送数据结构
JSONObject mapData = new JSONObject();
Map<String, Object> map1 = new HashMap<>();
map1.put("value", "用户-PL");
mapData.set("name1", map1);
Map<String, Object> map2 = new HashMap<>();
map2.put("value", "2022-04-14 14:55:00");
mapData.set("time2", map2);
Map<String, Object> map3 = new HashMap<>();
map3.put("value", "测评名称-标准能力测评");
mapData.set("thing3", map3);
Map<String, Object> map4 = new HashMap<>();
map4.put("value", 88);
mapData.set("number4", map4);
Map<String, String> data = new HashMap<>();
data.put("name1", "PL");
data.put("time2", "2025-04-10 16:00:00");
data.put("thing3", "测试");
data.put("number4", "88");
// 发送订阅消息
//String openId = wechatService.GetOpenId1("0f3R2lll2Gfspf4c7Uml2hLmOS3R2llI");
String openId2 = wechatUtilService.GetOpenId("0d38dTll2jsBnf4JZyol2D9ybg38dTlH");
JSONObject jsonObject = new JSONObject(openId2);
String openId = jsonObject.getStr("openid");
String templateId = "tmMsJJSh3bVhbCh34x15pTqNwPXIL52mk7r64Z8BnZs";
String pushMsg = wechatUtilService.PushMsg(templateId,openId,mapData,"pages/teacher/home");
//String openId = wechatService.GetOpenId("PDLost");
// String result = wechatHttpUtils.pushMsg(token);
//
// Map<String, Object> message = new HashMap<>();
// message.put("name1", openId); // 用户的OpenID，需要从前端获取或者数据库中获取
// message.put("time2", new Date()); // 完成时间
// message.put("thing3", "测试"); //测评名称
// message.put("number4", 50); // 成绩
// wechatHttpUtils.sendSubscribeMessage0("",message);
return pushMsg;
}
}

463
src/main/java/cn/teammodel/manager/wx/WechatUtilService.java
Unescape View File

@ -0,0 +1,463 @@
package cn.teammodel.manager.wx;
//import cn.binarywang.wx.miniapp.api.WxMaService;
import cn.hutool.json.JSONObject;
import cn.teammodel.model.vo.WechatResponseMsgVo;
import com.alibaba.fastjson2.JSON;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
//import com.rabbitmq.client.Channel;
//import com.rabbitmq.client.Connection;
//import com.rabbitmq.client.ConnectionFactory;
//import com.rabbitmq.client.DeliverCallback;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.*;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.*;
import org.apache.http.util.EntityUtils;
import org.springframework.stereotype.Service;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.*;
import java.util.stream.Collectors;
@Service
@Slf4j
public class WechatUtilService {
/**
* 模板:职业测试报告通知
*/
public static final String TEMPLATE_Vocational = "tmMsJJSh3bVhbCh34x15pTqNwPXIL52mk7r64Z8BnZs";
/**
* 模板:评价完成通知
*/
public static final String TEMPLATE_Appraise = "VQTP-d1mH7yrcFd6pKCdsy8LJpYrYrFcedEfxY0QpaU";
/**
* 模板:评价完成通知
*/
public static final String TEMPLATE_Report = "fkQA1Lz3Qx0RYWhtomLCiiu6EWJCMFIznU8SN2C_kFM";
/**
* 模板:考核成绩发布通知
*/
public static final String TEMPLATE_Eexam = "0U5YXarjYpMRLiKwgSlHO48iotjIeXOTDh2dyJwR-_8";
private static final String APP_ID = "wx5705da8747c77cfe";
private static final String APP_SECRET = "d5adf260a866ca43e74fbb40cec00799";
private static final String TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + APP_ID + "&secret=" + APP_SECRET;
/**
* 给用户发送消息
*/
private static final String SEND_MSG_URL = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=";
private final static String QUEUE_NAME = "test_queue";
/**
* 获取微信用户唯一标识OpenID
*/
private static final String CODE2SESSION_GET = "https://api.weixin.qq.com/sns/jscode2session?";
/**
* 获取访问令牌 方法1
* 获取接口调用凭据
* 方案 一
* @return
*/
public String GetAccessToken() {
CloseableHttpClient client = HttpClients.createDefault();
HttpPost post = new HttpPost(TOKEN_URL);
String token = null;
try {
String result = EntityUtils.toString(client.execute(post).getEntity());
// 从响应中解析JSON，获取access_token
JSONObject jsonResponse = new JSONObject(result);
if (jsonResponse.containsKey("access_token")) {
token = jsonResponse.getStr("access_token");
}
client.close();
} catch (Exception e) {
log.error("处理获取access_token请求时发生错误", e);
}
return token; // 返回结果中包含access_token，需要解析出来使用
}
/**
* description: 获取token，返回结果为 JSON 自行转 map
* 方案 二
* create by: Mr.Fang *
*
* @return: java.lang.String
* @date: 2023/4/3 17:46
*/
public String GetToken() {
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
Map<String, Object> params = new HashMap<>();
params.put("appid", APP_ID);
params.put("secret", APP_SECRET);
params.put("grant_type", "client_credential");
String url = HandleParams("https://api.weixin.qq.com/cgi-bin/token", params);
HttpGet httpGet = new HttpGet(url);
String token = null;
try {
CloseableHttpResponse response = httpClient.execute(httpGet);
HttpEntity entity = response.getEntity(); // 响应结果
String content = EntityUtils.toString(entity, "UTF-8");
// 从响应中解析JSON，获取access_token
JSONObject jsonResponse = new JSONObject(content);
if (jsonResponse.containsKey("access_token")) {
token = jsonResponse.getStr("access_token");
}
} catch (IOException e) {
log.error("处理获取token 请求时发生错误", e);
}
return token;
}
/**
* description: 获取 open id，返回结果为 JSON 自行转 map
* create by: Mr.Fang
* 方案一
* @param: [code]
* @return: java.lang.String
* @date: 2023/4/3 17:46
*/
public String GetOpenId(String code){
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
Map<String, Object> params = new HashMap<>();
params.put("appid", APP_ID);
params.put("secret", APP_SECRET);
params.put("js_code", code);
params.put("grant_type", "authorization_code");
String url = HandleParams("https://api.weixin.qq.com/sns/jscode2session", params);
HttpGet httpGet = new HttpGet(url);
String openId = null;
try {
CloseableHttpResponse response = httpClient.execute(httpGet);
HttpEntity entity = response.getEntity(); // 响应结果
openId = EntityUtils.toString(entity, "UTF-8");
}catch (IOException e) {
log.error("处理获取开放id请求时发生错误", e);
}
return openId;
}
/**
* 获取用户id
* 方案二
* @param code
* @return
*/
public String GetOpenId1(String code) {
String openId = null;
try {
String urlString = "https://api.weixin.qq.com/sns/jscode2session?appid=" + APP_ID +
"&secret=" + APP_SECRET +
"&js_code=" + code +
"&grant_type=authorization_code";
URL url = new URL(urlString);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
connection.connect();
int responseCode = connection.getResponseCode();
if (responseCode == HttpURLConnection.HTTP_OK) { // 200 OK
BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8));
String inputLine;
StringBuilder response = new StringBuilder();
while ((inputLine = in.readLine()) != null) {
response.append(inputLine);
}
in.close();
// 解析JSON响应来获取openID等数据
// 这里可以使用如org.json等库来解析JSON字符串
// 例如：JSONObject jsonObject = new JSONObject(response.toString());
// return jsonObject.getString("openid");
JSONObject jsonObject = new JSONObject(response.toString());
openId = jsonObject.getStr("openid");
} else {
System.out.println("GET请求失败");
}
} catch (Exception e) {
e.printStackTrace();
}
return openId;
}
/**
* 发送订阅消息
* 处理微信推送数据结构
* JSONObject mapData = new JSONObject();
* Map<String, Object> map1 = new HashMap<>();
* map1.put("value", "用户-PL");
* mapData.put("name1", map1);
* Map<String, Object> map2 = new HashMap<>();
* map2.put("value", "2022-04-03 10:00:00");
* mapData.put("time2", map2);
* Map<String, Object> map3 = new HashMap<>();
* map3.put("value", "测评名称-标准能力测评");
* mapData.put("thing3", map3);
* Map<String, Object> map4 = new HashMap<>();
* map4.put("value", 88);
* mapData.put("number4", map4);
*
* @param data
* @return
*/
public String PushMsg(String templateId,String openId,Map<String, Object> data,String page) {
String token = GetToken();
try {
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
Map<String, Object> params = new HashMap<>();
params.put("template_id", templateId);// 模板 id
params.put("touser", openId); // open id
params.put("data", data); // 数据
params.put("page", page); // 点击模板卡片后的跳转页面，仅限本小程序内的页面。支持带参数,（示例index?foo=bar）。该字段不填则模板无跳转
params.put("miniprogram_state", "trial"); //developer为开发版；trial为体验版；formal为正式版；默认为正式版
params.put("lang", "zh_CN"); //
HttpPost httpPost = new HttpPost(SEND_MSG_URL + token);
httpPost.addHeader("ContentTyp", "application/json");
// 参数转 JSON 格式
String json = objToStr(params);
StringEntity stringEntity = new StringEntity(json,"UTF-8");
stringEntity.setContentEncoding("UTF-8");
httpPost.setEntity(stringEntity);
CloseableHttpResponse response = httpClient.execute(httpPost);
HttpEntity entity = response.getEntity(); // 响应结果
return EntityUtils.toString(entity, "UTF-8");
}catch (Exception e){
log.error("处理获取openId请求时发生错误", e);
return e.getMessage();
}
}
/**
* 发送订阅消息 返回实体类
* @param templateId
* @param openId
* @param data
* @param page
* @return
*/
public WechatResponseMsgVo PushMsgResponse(String templateId, String openId, Map<String, Object> data, String page) {
String token = GetToken();
WechatResponseMsgVo wechatResponseMsgVo = null;
try {
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
Map<String, Object> params = new HashMap<>();
params.put("template_id", templateId);// 模板 id
params.put("touser", openId); // open id
params.put("data", data); // 数据
params.put("page", page); // 点击模板卡片后的跳转页面，仅限本小程序内的页面。支持带参数,（示例index?foo=bar）。该字段不填则模板无跳转
params.put("miniprogram_state", "trial"); //developer为开发版；trial为体验版；formal为正式版；默认为正式版
params.put("lang", "zh_CN"); //
HttpPost httpPost = new HttpPost(SEND_MSG_URL + token);
httpPost.addHeader("ContentTyp", "application/json");
// 参数转 JSON 格式
String json = objToStr(params);
StringEntity stringEntity = new StringEntity(json,"UTF-8");
stringEntity.setContentEncoding("UTF-8");
httpPost.setEntity(stringEntity);
CloseableHttpResponse response = httpClient.execute(httpPost);
HttpEntity entity = response.getEntity(); // 响应结果
wechatResponseMsgVo = JSON.parseObject(EntityUtils.toString(response.getEntity(), "UTF-8"), WechatResponseMsgVo.class);
}catch (Exception e){
log.error("处理获取openId请求时发生错误", e);
wechatResponseMsgVo = new WechatResponseMsgVo(500, e.getMessage());
}
return wechatResponseMsgVo;
}
// /**
// * 列队发送消息
// *
// * @param code
// * @return
// */
// public String MessageSend(String code) {
// ConnectionFactory factory = new ConnectionFactory();
// factory.setHost("localhost");
//
// try (Connection connection = factory.newConnection();
// Channel channel = connection.createChannel()) {
// channel.queueDeclare(QUEUE_NAME, false, false, false, null);
// System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
//
// DeliverCallback deliverCallback = (consumerTag, delivery) -> {
// String message = new String(delivery.getBody(), "UTF-8");
// System.out.println(" [x] Received '" + message + "'");
// };
// channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {
// });
// } catch (Exception e) {
// throw new RuntimeException(e);
// }
// return null;
// }
/**
* description 1.获取用户的临时code
* param [appid, redirectUrl]
* return java.lang.String
* authorlgb
* createTime 2021/8/27 17:30
**/
public String getUserUathUrl(String redirectUrl) throws UnsupportedEncodingException {
StringBuffer getcodeUrl = new StringBuffer()
.append("https://open.weixin.qq.com/connect/oauth2/authorize")
.append("?appid=" + APP_ID)
.append("&redirect_uri=" + com.sun.deploy.net.URLEncoder.encode(redirectUrl, "utf-8"))
.append("&response_type=code")
.append("&scope=snsapi_userinfo")
.append("&state=" + System.currentTimeMillis())
.append("#wechat_redirect");
return getcodeUrl.toString();
}
/**
* description 3.根据openid 获取用户的信息
* param [accessToken, openid]
* return java.lang.String
* author
* createTime 2021/8/27 17:31
**/
public String getBaseUserInfoUrl(String openid) {
StringBuffer baseUserInfoUrl = new StringBuffer()
.append("https://api.weixin.qq.com/sns/userinfo")
.append("?access_token=" + GetAccessToken())
.append("&openid=" + openid)
.append("&lang=zh_CN");
return baseUserInfoUrl.toString();
}
/**
* description 4检验授权凭证（access_token）是否有效
* param [openid, accessToken]
* return java.lang.String
* author
* createTime 2021/11/29 10:16
**/
public String checkAccessToken(String openid, String accessToken) {
StringBuffer stringBuffer = new StringBuffer().append(" https://api.weixin.qq.com/sns/auth")
.append("?access_token=" + accessToken)
.append("&openid=" + openid);
return stringBuffer.toString();
}
/**
* description 微信小程序登录，通过code获取session_key和openid
* param [appid, secret, code]
* return java.lang.String
* author
* createTime 2021/8/30 10:15
**/
public String getCode2Session(String code) {
StringBuffer code2Session = new StringBuffer()
.append("ttps://api.weixin.qq.com/sns/jscode2session")
.append("?appid=" + APP_ID)
.append("&secret=" + APP_SECRET)
.append("&js_code=" + code)
.append("&grant_type=authorization_code");
return code2Session.toString();
}
/**
* description: map 转 URL 地址拼接
* create by: Mr.Fang
*
* @param: [url, params]
* @return: java.lang.String
* @date: 2023/4/3 17:45
*/
public String HandleParams(String url, Map<String, Object> params) {
if (params.size() != 0) {
Set<Map.Entry<String, Object>> entries = params.entrySet();
String paramsString = entries.stream().map((e) -> {
try {
StringBuilder sb = new StringBuilder();
sb.append(URLEncoder.encode(e.getKey(), "UTF-8"));
sb.append("=");
if (Objects.nonNull(e.getValue())) {
sb.append(URLEncoder.encode(e.getValue().toString(), "UTF-8"));
}
return sb.toString();
} catch (UnsupportedEncodingException var2) {
var2.printStackTrace();
return null;
}
}).collect(Collectors.joining("&"));
return url + "?" + paramsString;
}
return url;
}
/**
* description: 对象转 字符串
* create by: Mr.Fang
*
* @param: [obj]
* @return: java.lang.String
* @date: 2023/4/3 17:45
*/
public String objToStr(Object obj) {
ObjectMapper objectMapper = new ObjectMapper();
if (Objects.nonNull(obj)) {
try {
String jsonStr = objectMapper.writeValueAsString(obj);
return jsonStr;
} catch (JsonProcessingException var2) {
var2.printStackTrace();
}
}
return null;
}
}

29
src/main/java/cn/teammodel/model/dto/Wechat/AppraiseReqDto.java
Unescape View File

@ -0,0 +1,29 @@
package cn.teammodel.model.dto.Wechat;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* 评价完成通知 请求参数
*/
@Data
public class AppraiseReqDto extends BaseInfoReqDto {
@ApiModelProperty("微信openId")
public String openId;
@ApiModelProperty("跳转页面")
public String page = "pages/parent/home";
@ApiModelProperty("被评价用户")
public String name;
@ApiModelProperty("评价内容")
public String content;
@ApiModelProperty("评价时间")
public String appraiseTime;
@ApiModelProperty("评价人")
public String appraiseUser;
}

11
src/main/java/cn/teammodel/model/dto/Wechat/BaseInfoReqDto.java
Unescape View File

@ -0,0 +1,11 @@
package cn.teammodel.model.dto.Wechat;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class BaseInfoReqDto {
@ApiModelProperty("微信登录code")
public String code;
}

30
src/main/java/cn/teammodel/model/dto/Wechat/ExamReqDto.java
Unescape View File

@ -0,0 +1,30 @@
package cn.teammodel.model.dto.Wechat;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* 考核成绩发布通知 请求参数
*/
@Data
public class ExamReqDto extends BaseInfoReqDto{
@ApiModelProperty("微信openId")
public String openId;
@ApiModelProperty("跳转页面")
public String page = "pages/parent/home";
@ApiModelProperty("用户信息")
public String thing3;
@ApiModelProperty("考试名称")
public String thing1;
@ApiModelProperty("考试成绩")
public int number2 = -1;
@ApiModelProperty("考试时间")
public String time5;
}

26
src/main/java/cn/teammodel/model/dto/Wechat/ReportReqDto.java
Unescape View File

@ -0,0 +1,26 @@
package cn.teammodel.model.dto.Wechat;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* 报告生成通知 请求参数
*/
@Data
public class ReportReqDto extends BaseInfoReqDto {
@ApiModelProperty("微信openId")
public String openId;
@ApiModelProperty("跳转页面")
public String page = "pages/parent/home";
@ApiModelProperty("用户名称")
public String thing8;
@ApiModelProperty("综合、德智体美劳任意")
public String thing1;
@ApiModelProperty("报告生成时间")
public String time2;
}

29
src/main/java/cn/teammodel/model/dto/Wechat/VocationalReqDto.java
Unescape View File

@ -0,0 +1,29 @@
package cn.teammodel.model.dto.Wechat;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* 职业测试报告通知 请求参数
*/
@Data
public class VocationalReqDto extends BaseInfoReqDto {
@ApiModelProperty("微信openId")
public String openId;
@ApiModelProperty("跳转页面")
public String page = "pages/parent/home";
@ApiModelProperty("用户")
public String name;
@ApiModelProperty("时间")
public String time2;
@ApiModelProperty("测评名称")
public String thing3;
@ApiModelProperty("测评的分数/出成绩")
public int number4;
}

18
src/main/java/cn/teammodel/model/vo/WechatResponseMsgVo.java
Unescape View File

@ -0,0 +1,18 @@
package cn.teammodel.model.vo;
import lombok.Data;
/**
* 微信推送消息响应结构体
*/
@Data
public class WechatResponseMsgVo {
private int errcode;
private String errmsg;
private long msgid;
public WechatResponseMsgVo(int errcode, String errmsg) {
this.errcode = errcode;
this.errmsg = errmsg;
}
}

37
src/main/java/cn/teammodel/service/WechatService.java
Unescape View File

@ -0,0 +1,37 @@
package cn.teammodel.service;
import cn.teammodel.model.dto.Wechat.*;
import cn.teammodel.model.vo.WechatResponseMsgVo;
/**
* 模板消息推送
*/
public interface WechatService {
/**
* 发送评价订阅消息
* @param appraiseDto
* @return
*/
WechatResponseMsgVo AppraisePushMsg(AppraiseReqDto appraiseDto);
/**
* 考核成绩发布通知
* @param examReqDto
* @return
*/
WechatResponseMsgVo ExamPushMsg(ExamReqDto examReqDto);
/**
* 职业测试报告通知
* @param vocationalReqDto
* @return
*/
WechatResponseMsgVo VocationalPushMsg(VocationalReqDto vocationalReqDto);
/**
* 报告
* @param reportReqDto
* @return
*/
WechatResponseMsgVo ReportPushMsg(ReportReqDto reportReqDto);
}

236
src/main/java/cn/teammodel/service/impl/WechatServiceImpl.java
Unescape View File

@ -0,0 +1,236 @@
package cn.teammodel.service.impl;
import cn.hutool.json.JSONObject;
import cn.teammodel.manager.wx.WechatUtilService;
import cn.teammodel.model.dto.Wechat.AppraiseReqDto;
import cn.teammodel.model.dto.Wechat.ExamReqDto;
import cn.teammodel.model.dto.Wechat.ReportReqDto;
import cn.teammodel.model.dto.Wechat.VocationalReqDto;
import cn.teammodel.model.vo.WechatResponseMsgVo;
import cn.teammodel.service.WechatService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
@Service
public class WechatServiceImpl implements WechatService{
@Resource
private WechatUtilService wechatUtilService;
/**
* 发送评价订阅消息
* @param appraiseDto
* @return
*/
@Override
public WechatResponseMsgVo AppraisePushMsg(AppraiseReqDto appraiseDto){
WechatResponseMsgVo sendMsg = null;
String openId = null;
if (appraiseDto.getCode() != null){
String openId2 = wechatUtilService.GetOpenId(appraiseDto.getCode());
JSONObject jsonObject = new JSONObject(openId2);
openId = jsonObject.getStr("openid");
}
if (appraiseDto.getOpenId() != null){
openId = appraiseDto.getOpenId();
}
// 处理微信推送数据结构
JSONObject mapData = new JSONObject();
if (appraiseDto.getName() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", appraiseDto.getName());
mapData.set("thing5", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"用户不能为空");
return sendMsg;
}
if (appraiseDto.getContent() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", appraiseDto.getContent());
mapData.set("thing2", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"评价内容");
return sendMsg;
}
if (appraiseDto.getAppraiseTime() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", appraiseDto.getAppraiseTime());
mapData.set("time6", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"评价时间不能为空");
return sendMsg;
}
if (appraiseDto.getAppraiseUser() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", appraiseDto.getAppraiseUser());
mapData.set("thing7", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"评价人不能为空");
return sendMsg;
}
sendMsg = wechatUtilService.PushMsgResponse(WechatUtilService.TEMPLATE_Appraise,openId,mapData,appraiseDto.page);
return sendMsg;
}
/**
* 考核成绩发布通知
* @param examReqDto
* @return
*/
public WechatResponseMsgVo ExamPushMsg(ExamReqDto examReqDto){
WechatResponseMsgVo sendMsg = null;
String openId = null;
if (examReqDto.getCode() != null){
String openId2 = wechatUtilService.GetOpenId(examReqDto.getCode());
JSONObject jsonObject = new JSONObject(openId2);
openId = jsonObject.getStr("openid");
}
if (examReqDto.getOpenId() != null){
openId = examReqDto.getOpenId();
}
// 处理微信推送数据结构
JSONObject mapData = new JSONObject();
if (examReqDto.getThing3() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", examReqDto.getThing3());
mapData.set("thing3", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"用户不能为空");
return sendMsg;
}
if (examReqDto.getThing1() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", examReqDto.getThing1());
mapData.set("thing1", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"评价内容");
return sendMsg;
}
if (examReqDto.getNumber2() != 0){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", examReqDto.getNumber2());
mapData.set("number2", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"考试分数");
return sendMsg;
}
if (examReqDto.getTime5() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", examReqDto.getTime5());
mapData.set("time5", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"考试时间不能为空");
return sendMsg;
}
return wechatUtilService.PushMsgResponse(WechatUtilService.TEMPLATE_Eexam,openId,mapData,examReqDto.page);
}
/**
* 考核成绩发布通知
* @param reportReqDto
* @return
*/
public WechatResponseMsgVo ReportPushMsg(ReportReqDto reportReqDto){
WechatResponseMsgVo sendMsg = null;
String openId = null;
if (reportReqDto.getCode() != null){
String openId2 = wechatUtilService.GetOpenId(reportReqDto.getCode());
JSONObject jsonObject = new JSONObject(openId2);
openId = jsonObject.getStr("openid");
}
if (reportReqDto.getOpenId() != null){
openId = reportReqDto.getOpenId();
}
// 处理微信推送数据结构
JSONObject mapData = new JSONObject();
if (reportReqDto.getThing8() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", reportReqDto.getThing8());
mapData.set("thing8", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"用户不能为空");
return sendMsg;
}
if (reportReqDto.getThing1() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", reportReqDto.getThing1());
mapData.set("thing1", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"报告类型");
return sendMsg;
}
if (reportReqDto.getTime2() != null){
Map<String, Object> map1 = new HashMap<>();
map1.put("value", reportReqDto.getTime2());
mapData.set("time2", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"考试时间不能为空");
return sendMsg;
}
return wechatUtilService.PushMsgResponse(WechatUtilService.TEMPLATE_Report,openId,mapData,reportReqDto.page);
}
/**
* 职业测试报告通知
* @param vocationalReqDto
* @return
*/
public WechatResponseMsgVo VocationalPushMsg(VocationalReqDto vocationalReqDto){
WechatResponseMsgVo sendMsg = null;
String openId = null;
if (vocationalReqDto.getCode() != null){
String openId2 = wechatUtilService.GetOpenId(vocationalReqDto.getCode());
JSONObject jsonObject = new JSONObject(openId2);
openId = jsonObject.getStr("openid");
}
if (vocationalReqDto.getOpenId() != null){
openId = vocationalReqDto.getOpenId();
}
// 处理微信推送数据结构
JSONObject mapData = new JSONObject();
if (vocationalReqDto.getName() != null) {
Map<String, Object> map1 = new HashMap<>();
map1.put("value", vocationalReqDto.getName());
mapData.set("name1", map1);
}else {
sendMsg = new WechatResponseMsgVo(400,"用户不能为空");
return sendMsg;
}
if (vocationalReqDto.getTime2() != null) {
Map<String, Object> map2 = new HashMap<>();
map2.put("value", vocationalReqDto.getTime2());
mapData.set("time2", map2);
}else {
sendMsg = new WechatResponseMsgVo(400,"评测时间不能为空");
return sendMsg;
}
if (vocationalReqDto.getThing3() != null) {
Map<String, Object> map3 = new HashMap<>();
map3.put("value", vocationalReqDto.getThing3());
mapData.set("thing3", map3);
}else {
sendMsg = new WechatResponseMsgVo(400,"测评名称不能为空");
return sendMsg;
}
if (vocationalReqDto.getNumber4() != 0) {
Map<String, Object> map4 = new HashMap<>();
map4.put("value", vocationalReqDto.getNumber4());
mapData.set("number4", map4);
}else {
sendMsg = new WechatResponseMsgVo(400,"测评成绩不能为空");
return sendMsg;
}
return wechatUtilService.PushMsgResponse(WechatUtilService.TEMPLATE_Vocational,openId,mapData,vocationalReqDto.page);
}
}
Write Preview
Loading…
Cancel
Save