今天写了一个商品到货提醒的job任务，具体效果如下
这里用到了微信的发送订阅消息，主要代码是这一块的，最后我把发送了消息的订单存到表里，因为是定时任务，大家可不存
发送订阅消息 | 微信开放文档
/**
* 微信平台-商品到货通知
*/
public String uploadArrival(WxOrderArrivalDTO wxOrderArrivalDTO) throws ParseException {
String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + wechatManager.getaccessToken();
JSONObject body = new JSONObject();
JSONObject data = new JSONObject();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String date = sdf.format(DateUtil.now());
data.put("time4",new JSONObject().fluentPut("value",date));
data.put("character_string5", new JSONObject().fluentPut("value",wxOrderArrivalDTO.getPickupCode()));
data.put("amount6",new JSONObject().fluentPut("value",wxOrderArrivalDTO.getOrderAmount() + "元"));
data.put("thing7",new JSONObject().fluentPut("value",wxOrderArrivalDTO.getShopName()) );
data.put("short_thing8", new JSONObject().fluentPut("value","自提"));
body.put("data", data);
body.put("touser", wxOrderArrivalDTO.getOpenId());
body.put("miniprogram_state", "formal");
body.put("lang", "zh_CN");
body.put("template_id", "这里填模板id");
String result = null;
try {
result = HttpUtil.createPost(url).body(body.toJSONString()).execute().body();
log.info("通知微信平台 订单到货接口返回：" + result);
OrderPushMsgDTO orderPushMsgDTO = new OrderPushMsgDTO();
orderPushMsgDTO.setPushMsgId(UUIDUtils.getUUID());
orderPushMsgDTO.setOrderId(wxOrderArrivalDTO.getOrderId());
orderPushMsgDTO.setOrderType(CommonKey.CONSTANT_1);
JSONObject jsonObject = JSON.parseObject(result);
int errcode = jsonObject.getInteger("errcode");
orderPushMsgDTO.setErrCode(String.valueOf(errcode));
orderPushMsgBO.save(orderPushMsgDTO);
} catch (Exception e) {
throw new BizException(e.getMessage());
}
return result;
}这是微信公众号平台申请的模板，其中模板id填到上图中的template_id后面
这是微信官方文档的请求参数示例，主要是data里面的数据key是上图详细内容里的time4，thing7...
然后遇到一个问题，就是给data塞值的时候刚开始采用的是第二种方法，发现没塞进去，用下图框中的写法就可以了
后面又写了个公众号的，效果如下
这个用法的是微信的模板消息，大致写法都一样，就是tocken要用公众号的tocken，用小程序的tocken会报错48001，还有如果不是一个模板id代码里记得换，不然会报错40037。模板有数据是枚举的，拼接返回消息的时候要对应上
模板消息 | 微信开放文档
public String uploadArrivalOfficialAccountPush(WxOrderArrivalDTO wxOrderArrivalDTO){
WechatInfoDTO weChatAccessToken = authUtil.getWeChatAccessToken();
String url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + weChatAccessToken.getAccessToken();
List<OrderItemDTO> itemList= orderItemDao.queryListOrderItemByOrderIdList(Arrays.asList(wxOrderArrivalDTO.getOrderId()));
List<ShopGoodsDTO> shopGoodsDTOS = this.shopGoodsBo.queryGoodsByIdList(itemList.stream().map(OrderItemDTO::getGoodsId).collect(Collectors.toList()));
if (ObjectUtil.isNull(shopGoodsDTOS)) {
return null;
}
Map<String, ShopGoodsDTO> shopGoodsDTOMap = shopGoodsDTOS.stream().distinct().collect(Collectors.toMap(ShopGoodsDTO::getGoodsId, Function.identity(), (oldValue, newValue) -> oldValue));
List<ShopGoodsSpeciInfoDTO> speciInfoList= shopGoodsSpeciInfoBO.queryGoodsSpeciInfoByIdList(itemList.stream().map(OrderItemDTO::getGoodsSpeciId).collect(Collectors.toList()));
StringBuffer goodNames=new StringBuffer();
int size = speciInfoList.size();
for (int i = 0; i < size; i++) {
ShopGoodsSpeciInfoDTO temp = speciInfoList.get(i);
String goodsName = shopGoodsDTOMap.get(temp.getGoodsId()).getGoodsName();
goodNames.append(goodsName);
if (i < size - 1) {
goodNames.append("、");
}
}
if(goodNames.toString().length()>20){
wxOrderArrivalDTO.setItemDesc(goodNames.toString().substring(0,10)+ELLIPSIS_3);
}else{
wxOrderArrivalDTO.setItemDesc(goodNames.toString());
}
JSONObject body = new JSONObject();
JSONObject data = new JSONObject();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String date = sdf.format(DateUtil.now());
data.put("time1",new JSONObject().fluentPut("value",date));
data.put("thing2",new JSONObject().fluentPut("value",wxOrderArrivalDTO.getItemDesc()));
data.put("amount3",new JSONObject().fluentPut("value",wxOrderArrivalDTO.getOrderAmount() + "元"));
data.put("thing4",new JSONObject().fluentPut("value",wxOrderArrivalDTO.getShopName()) );
data.put("const5", new JSONObject().fluentPut("value",CommonKey.CONSTANT_3.equals(wxOrderArrivalDTO.getDeliveryMethod()) ? "用户自提" : "商家配送"));
body.put("data", data);
body.put("url", officialAccountPushUrl);
body.put("touser", wxOrderArrivalDTO.getOpenId());
body.put("template_id", "这里填模板id");
String result = null;
try {
result = HttpUtil.createPost(url).body(body.toJSONString()).execute().body();
log.info("通知微信平台 订单到货接口返回：" + result);
OrderPushMsgDTO orderPushMsgDTO = new OrderPushMsgDTO();
orderPushMsgDTO.setPushMsgId(UUIDUtils.getUUID());
orderPushMsgDTO.setOrderId(wxOrderArrivalDTO.getOrderId());
orderPushMsgDTO.setOrderType(CommonKey.CONSTANT_1);
JSONObject jsonObject = JSON.parseObject(result);
orderPushMsgDTO.setPushType(CommonKey.CONSTANT_2);
int errcode = jsonObject.getInteger("errcode");
orderPushMsgDTO.setErrCode(String.valueOf(errcode));
orderPushMsgBO.save(orderPushMsgDTO);
} catch (Exception e) {
throw new BizException(e.getMessage());
}
return result;
}获取公众号的tocken，要注意是url+json的形式
开始开发 / 获取 Stable Access token
public WechatInfoDTO getWeChatAccessToken() {
Map<String,Object> requestUrlParam=new HashMap<String,Object>();
//appId
requestUrlParam.put("appid", wechatAppId);
//appSecret
requestUrlParam.put("secret", wechatSecret);
//默认参数
requestUrlParam.put("grant_type", "client_credential");
ObjectMapper objectMapper = new ObjectMapper();
String json = null;
try {
json = objectMapper.writeValueAsString(requestUrlParam);
} catch (JsonProcessingException e) {
e.printStackTrace();
}
//发送post请求读取调用微信接口获取accessToken信息
String result = HttpUtil.post("https://api.weixin.qq.com/cgi-bin/stable_token", json);
JSONObject jsonObject = JSONObject.parseObject(result);
Integer errcode = jsonObject.getInteger("errcode");
if (errcode != null && errcode != 0) {
String errmsg = jsonObject.getString("errmsg");
log.error(result);
throw new BizException(ResultCode.FAIL,errmsg);
}
return new WechatInfoDTO().setAccessToken(jsonObject.getString("access_token"));
}
