package com.ruoyi.web.controller.smartor.tools;
|
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.ruoyi.common.core.controller.BaseController;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.smartor.domain.WeChatSendVo;
|
import com.smartor.service.WeChatService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import me.chanjar.weixin.common.exception.WxErrorException;
|
import me.chanjar.weixin.mp.api.WxMpInMemoryConfigStorage;
|
import me.chanjar.weixin.mp.api.WxMpService;
|
import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
|
import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
|
import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;
|
import okhttp3.OkHttpClient;
|
import okhttp3.Request;
|
import okhttp3.Response;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.context.annotation.PropertySource;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.io.IOException;
|
import java.util.HashMap;
|
import java.util.List;
|
|
/**
|
* 微信接口
|
*
|
* @author liusheng
|
* @date 2023-05-15
|
*/
|
@Api(description = "微信接口")
|
@RestController
|
@RequestMapping("/smartor/wechat")
|
@PropertySource(value = {"classpath:application-druid.yml"})
|
public class WeChatController extends BaseController {
|
|
@Value("${appid}")
|
private String appid;
|
|
@Value("${appSecret}")
|
private String appSecret;
|
|
@Autowired
|
private WeChatService weChatService;
|
|
|
/**
|
* 获取模板信息
|
*
|
* @return
|
*/
|
@ApiOperation("获取模板信息")
|
@GetMapping("/getTemplateList")
|
public JSONArray getTemplateList() {
|
String url = "https://api.weixin.qq.com/cgi-bin/template/get_all_private_template?access_token=" + getAccessToken();
|
OkHttpClient httpClient = new OkHttpClient();
|
Request request = new Request.Builder().url(url).build();
|
try {
|
Response response = httpClient.newCall(request).execute();
|
JSONObject jsonObject = JSONObject.parseObject(response.body().string());
|
return jsonObject.getJSONArray("template_list");
|
} catch (IOException e) {
|
e.printStackTrace();
|
return null;
|
}
|
}
|
|
|
/**
|
* 微信公众号信息发送
|
*
|
* @param weChatSendVo
|
* @return
|
*/
|
// @ApiOperation("微信公众号信息发送")
|
// @PostMapping("/sendMessageToFollowers")
|
// public AjaxResult sendMessageToFollowers(@RequestBody WeChatSendVo weChatSendVo) {
|
// return toAjax(weChatService.sendMessageToFollowers(weChatSendVo));
|
// }
|
|
|
/**
|
* 获取 access_token
|
*/
|
public String getAccessToken() {
|
String accessTokenUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appid + "&secret=" + appSecret;
|
OkHttpClient httpClient = new OkHttpClient();
|
Request request = new Request.Builder().url(accessTokenUrl).build();
|
try {
|
Response response = httpClient.newCall(request).execute();
|
JSONObject jsonObject = JSONObject.parseObject(response.body().string());
|
return jsonObject.getString("access_token");
|
} catch (IOException e) {
|
e.printStackTrace();
|
return null;
|
}
|
}
|
|
|
}
|
