From 747a195a7f5d6b74a87f34a32b7cc0dde69fbd82 Mon Sep 17 00:00:00 2001 From: yk Date: Tue, 25 Jul 2023 11:39:52 +0800 Subject: [PATCH] init --- .gitignore | 52 ++++ Dockerfile | 9 + pom.xml | 126 ++++++++++ src/main/java/com/lecoo/wechat/App.java | 13 + .../lecoo/wechat/builder/AbstractBuilder.java | 17 ++ .../com/lecoo/wechat/builder/TextBuilder.java | 22 ++ .../lecoo/wechat/config/SmsProperties.java | 33 +++ .../wechat/config/WxMpConfiguration.java | 129 ++++++++++ .../lecoo/wechat/config/WxMpProperties.java | 105 ++++++++ .../wechat/controller/IndexController.java | 74 ++++++ .../com/lecoo/wechat/entity/SmsReqEntity.java | 39 +++ .../lecoo/wechat/entity/WxMsgReqEntity.java | 42 ++++ .../lecoo/wechat/handler/AbstractHandler.java | 12 + .../handler/ControllerExceptionHandler.java | 52 ++++ .../wechat/handler/KfSessionHandler.java | 25 ++ .../lecoo/wechat/handler/LocationHandler.java | 44 ++++ .../com/lecoo/wechat/handler/LogHandler.java | 25 ++ .../com/lecoo/wechat/handler/MenuHandler.java | 35 +++ .../com/lecoo/wechat/handler/MsgHandler.java | 51 ++++ .../com/lecoo/wechat/handler/NullHandler.java | 24 ++ .../com/lecoo/wechat/handler/ScanHandler.java | 24 ++ .../handler/StoreCheckNotifyHandler.java | 27 ++ .../wechat/handler/SubscribeHandler.java | 71 ++++++ .../wechat/handler/UnsubscribeHandler.java | 27 ++ .../com/lecoo/wechat/service/SmsService.java | 234 ++++++++++++++++++ .../com/lecoo/wechat/utils/JsonUtils.java | 17 ++ .../java/com/lecoo/wechat/utils/SendUtil.java | 61 +++++ src/main/resources/config/application.yml | 63 +++++ 28 files changed, 1453 insertions(+) create mode 100644 .gitignore create mode 100644 Dockerfile create mode 100644 pom.xml create mode 100644 src/main/java/com/lecoo/wechat/App.java create mode 100644 src/main/java/com/lecoo/wechat/builder/AbstractBuilder.java create mode 100644 src/main/java/com/lecoo/wechat/builder/TextBuilder.java create mode 100644 src/main/java/com/lecoo/wechat/config/SmsProperties.java create mode 100644 src/main/java/com/lecoo/wechat/config/WxMpConfiguration.java create mode 100644 src/main/java/com/lecoo/wechat/config/WxMpProperties.java create mode 100644 src/main/java/com/lecoo/wechat/controller/IndexController.java create mode 100644 src/main/java/com/lecoo/wechat/entity/SmsReqEntity.java create mode 100644 src/main/java/com/lecoo/wechat/entity/WxMsgReqEntity.java create mode 100644 src/main/java/com/lecoo/wechat/handler/AbstractHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/ControllerExceptionHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/KfSessionHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/LocationHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/LogHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/MenuHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/MsgHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/NullHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/ScanHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/StoreCheckNotifyHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/SubscribeHandler.java create mode 100644 src/main/java/com/lecoo/wechat/handler/UnsubscribeHandler.java create mode 100644 src/main/java/com/lecoo/wechat/service/SmsService.java create mode 100644 src/main/java/com/lecoo/wechat/utils/JsonUtils.java create mode 100644 src/main/java/com/lecoo/wechat/utils/SendUtil.java create mode 100644 src/main/resources/config/application.yml diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..8ac3f62 --- /dev/null +++ b/.gitignore @@ -0,0 +1,52 @@ +###################################################################### +# Build Tools + +.gradle +/build/ +!gradle/wrapper/gradle-wrapper.jar + +target/ +xueyi-ui/ +!.mvn/wrapper/maven-wrapper.jar + +###################################################################### +# IDE + +### STS ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans + +### IntelliJ IDEA ### +.idea/ +.vscode/ +*.iws +*.iml +*.ipr + +### JRebel ### +rebel.xml +### NetBeans ### +nbproject/private/ +build/* +nbbuild/ +dist/ +nbdist/ +.nb-gradle/ + +###################################################################### +# Others +*.log +*.xml.versionsBackup +*.swp +.DS_Store +.idea/ + +!*/build/*.java +!*/build/*.html +!*/build/*.xml +logs/ +**/target */ diff --git a/Dockerfile b/Dockerfile new file mode 100644 index 0000000..3d739bf --- /dev/null +++ b/Dockerfile @@ -0,0 +1,9 @@ +FROM openjdk:8 +MAINTAINER yangkai +ADD target/sms-msg-sender-1.0-SNAPSHOT.jar sms-msg-sender.jar +COPY application.yml / +RUN /bin/cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime +EXPOSE 8080 +ENTRYPOINT ["java","-jar","sms-msg-sender.jar","--spring.config.location=/application.yml"] + +# docker run -d --restart=always --name dg-sms-sender -p 9950:9950 dg-sms-sender:v1 //运行镜像 \ No newline at end of file diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..3ca679c --- /dev/null +++ b/pom.xml @@ -0,0 +1,126 @@ + + + 4.0.0 + + org.example + sms-msg-sender + 1.0-SNAPSHOT + + + 8 + 8 + 0.2.10 + 0.2.1 + + + + + org.springframework.boot + spring-boot-starter-web + 2.0.3.RELEASE + + + com.fasterxml.jackson.core + jackson-databind + + + + + + org.projectlombok + lombok + provided + true + 1.16.22 + + + + + org.springframework.boot + spring-boot-starter-test + test + 2.0.6.RELEASE + + + + redis.clients + jedis + 3.3.0 + + + + com.github.binarywang + weixin-java-mp + 4.1.0 + + + + com.aliyun + dysmsapi20170525 + 2.0.5 + + + + com.alibaba + fastjson + 1.2.44 + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + 2.0.1.RELEASE + + + + + org.springframework.cloud + spring-cloud-starter-config + 2.0.1.RELEASE + + + + + + src/main/resources + true + + + + + org.springframework.boot + spring-boot-maven-plugin + 2.0.6.RELEASE + + + + repackage + + + + + + + + + + dev + + true + + + dev + + + + prod + + prod + + + + + \ No newline at end of file diff --git a/src/main/java/com/lecoo/wechat/App.java b/src/main/java/com/lecoo/wechat/App.java new file mode 100644 index 0000000..7ca5ecd --- /dev/null +++ b/src/main/java/com/lecoo/wechat/App.java @@ -0,0 +1,13 @@ +package com.lecoo.wechat; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.client.discovery.EnableDiscoveryClient; + +@SpringBootApplication +@EnableDiscoveryClient +public class App { + public static void main(String[] args) { + SpringApplication.run(App.class,args); + } +} diff --git a/src/main/java/com/lecoo/wechat/builder/AbstractBuilder.java b/src/main/java/com/lecoo/wechat/builder/AbstractBuilder.java new file mode 100644 index 0000000..3cf0d9e --- /dev/null +++ b/src/main/java/com/lecoo/wechat/builder/AbstractBuilder.java @@ -0,0 +1,17 @@ +package com.lecoo.wechat.builder; + +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +public abstract class AbstractBuilder { + protected final Logger logger = LoggerFactory.getLogger(getClass()); + + public abstract WxMpXmlOutMessage build(String content, + WxMpXmlMessage wxMessage, WxMpService service); +} diff --git a/src/main/java/com/lecoo/wechat/builder/TextBuilder.java b/src/main/java/com/lecoo/wechat/builder/TextBuilder.java new file mode 100644 index 0000000..6058e84 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/builder/TextBuilder.java @@ -0,0 +1,22 @@ +package com.lecoo.wechat.builder; + +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutTextMessage; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +public class TextBuilder extends AbstractBuilder { + + @Override + public WxMpXmlOutMessage build(String content, WxMpXmlMessage wxMessage, + WxMpService service) { + WxMpXmlOutTextMessage m = WxMpXmlOutMessage.TEXT().content(content) + .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()) + .build(); + return m; + } + +} diff --git a/src/main/java/com/lecoo/wechat/config/SmsProperties.java b/src/main/java/com/lecoo/wechat/config/SmsProperties.java new file mode 100644 index 0000000..342a9c6 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/config/SmsProperties.java @@ -0,0 +1,33 @@ +package com.lecoo.wechat.config; + +import com.alibaba.nacos.api.config.ConfigType; +import com.alibaba.nacos.api.config.annotation.NacosConfigurationProperties; +import lombok.Data; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.stereotype.Component; + +/** + * sms properties + */ +@Data +@Component +@ConfigurationProperties(prefix = "sys.mms") +//@NacosConfigurationProperties(prefix = "sys.mms", dataId = "ali-sms",type = ConfigType.YAML, groupId = "DEFAULT_GROUP", autoRefreshed = true) +public class SmsProperties { + private String accessKeyId; + private String accessKeySecrect; + private String endpoint; + private String signName; + private String signNameFront; + private String signNameVisitor; + private String template; + private String carTemplate; + private String fixedTemplate; + private String codeTemplate; + private String meetingOrderTemplate; + private String meetingQuitTemplate; + private String meetingRemindTemplate; + private String defaultRemindTemplate; + private String robotName; + private String receptionPhones; +} diff --git a/src/main/java/com/lecoo/wechat/config/WxMpConfiguration.java b/src/main/java/com/lecoo/wechat/config/WxMpConfiguration.java new file mode 100644 index 0000000..abf6a9d --- /dev/null +++ b/src/main/java/com/lecoo/wechat/config/WxMpConfiguration.java @@ -0,0 +1,129 @@ +package com.lecoo.wechat.config; + +import com.lecoo.wechat.handler.*; +import lombok.AllArgsConstructor; +import me.chanjar.weixin.common.redis.JedisWxRedisOps; +import me.chanjar.weixin.mp.api.WxMpMessageRouter; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl; +import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl; +import me.chanjar.weixin.mp.config.impl.WxMpRedisConfigImpl; +import org.springframework.boot.context.properties.EnableConfigurationProperties; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import redis.clients.jedis.JedisPool; +import redis.clients.jedis.JedisPoolConfig; + +import java.util.List; +import java.util.stream.Collectors; + +import static me.chanjar.weixin.common.api.WxConsts.EventType; +import static me.chanjar.weixin.common.api.WxConsts.EventType.SUBSCRIBE; +import static me.chanjar.weixin.common.api.WxConsts.EventType.UNSUBSCRIBE; +import static me.chanjar.weixin.common.api.WxConsts.XmlMsgType; +import static me.chanjar.weixin.common.api.WxConsts.XmlMsgType.EVENT; +import static me.chanjar.weixin.mp.constant.WxMpEventConstants.CustomerService.*; +import static me.chanjar.weixin.mp.constant.WxMpEventConstants.POI_CHECK_NOTIFY; + +/** + * wechat mp configuration + * + * @author Binary Wang(https://github.com/binarywang) + */ +@AllArgsConstructor +@Configuration +@EnableConfigurationProperties(WxMpProperties.class) +public class WxMpConfiguration { + private final LogHandler logHandler; + private final NullHandler nullHandler; + private final KfSessionHandler kfSessionHandler; + private final StoreCheckNotifyHandler storeCheckNotifyHandler; + private final LocationHandler locationHandler; + private final MenuHandler menuHandler; + private final MsgHandler msgHandler; + private final UnsubscribeHandler unsubscribeHandler; + private final SubscribeHandler subscribeHandler; + private final ScanHandler scanHandler; + private final WxMpProperties properties; + + @Bean + public WxMpService wxMpService() { + // 代码里 getConfigs()处报错的同学，请注意仔细阅读项目说明，你的IDE需要引入lombok插件！！！！ + final List configs = this.properties.getConfigs(); + if (configs == null) { + throw new RuntimeException("大哥，拜托先看下项目首页的说明（readme文件），添加下相关配置，注意别配错了！"); + } + + WxMpService service = new WxMpServiceImpl(); + service.setMultiConfigStorages(configs + .stream().map(a -> { + WxMpDefaultConfigImpl configStorage; + if (this.properties.isUseRedis()) { + final WxMpProperties.RedisConfig redisConfig = this.properties.getRedisConfig(); + JedisPoolConfig poolConfig = new JedisPoolConfig(); + JedisPool jedisPool = new JedisPool(poolConfig, redisConfig.getHost(), redisConfig.getPort(), + redisConfig.getTimeout(), redisConfig.getPassword()); + configStorage = new WxMpRedisConfigImpl(new JedisWxRedisOps(jedisPool), a.getAppId()); + } else { + configStorage = new WxMpDefaultConfigImpl(); + } + + configStorage.setAppId(a.getAppId()); + configStorage.setSecret(a.getSecret()); + configStorage.setToken(a.getToken()); + configStorage.setAesKey(a.getAesKey()); + return configStorage; + }).collect(Collectors.toMap(WxMpDefaultConfigImpl::getAppId, a -> a, (o, n) -> o))); + return service; + } + + @Bean + public WxMpMessageRouter messageRouter(WxMpService wxMpService) { + final WxMpMessageRouter newRouter = new WxMpMessageRouter(wxMpService); + + // 记录所有事件的日志 （异步执行） + newRouter.rule().handler(this.logHandler).next(); + + // 接收客服会话管理事件 + newRouter.rule().async(false).msgType(EVENT).event(KF_CREATE_SESSION) + .handler(this.kfSessionHandler).end(); + newRouter.rule().async(false).msgType(EVENT).event(KF_CLOSE_SESSION) + .handler(this.kfSessionHandler).end(); + newRouter.rule().async(false).msgType(EVENT).event(KF_SWITCH_SESSION) + .handler(this.kfSessionHandler).end(); + + // 门店审核事件 + newRouter.rule().async(false).msgType(EVENT).event(POI_CHECK_NOTIFY).handler(this.storeCheckNotifyHandler).end(); + + // 自定义菜单事件 + newRouter.rule().async(false).msgType(EVENT).event(EventType.CLICK).handler(this.menuHandler).end(); + + // 点击菜单连接事件 + newRouter.rule().async(false).msgType(EVENT).event(EventType.VIEW).handler(this.nullHandler).end(); + + // 关注事件 + newRouter.rule().async(false).msgType(EVENT).event(SUBSCRIBE).handler(this.subscribeHandler).end(); + + // 取消关注事件 + newRouter.rule().async(false).msgType(EVENT).event(UNSUBSCRIBE).handler(this.unsubscribeHandler).end(); + + // 上报地理位置事件 + newRouter.rule().async(false).msgType(EVENT).event(EventType.LOCATION).handler(this.locationHandler).end(); + + // 接收地理位置消息 + newRouter.rule().async(false).msgType(XmlMsgType.LOCATION).handler(this.locationHandler).end(); + + // 扫码事件 + newRouter.rule().async(false).msgType(EVENT).event(EventType.SCAN).handler(this.scanHandler).end(); + + // 默认 + newRouter.rule().async(false).handler(this.msgHandler).end(); + + return newRouter; + } + + + public WxMpProperties getWxMpProperties(){ + return this.properties; + } +} diff --git a/src/main/java/com/lecoo/wechat/config/WxMpProperties.java b/src/main/java/com/lecoo/wechat/config/WxMpProperties.java new file mode 100644 index 0000000..d15bdcb --- /dev/null +++ b/src/main/java/com/lecoo/wechat/config/WxMpProperties.java @@ -0,0 +1,105 @@ +package com.lecoo.wechat.config; + +import com.alibaba.nacos.api.config.ConfigType; +import com.alibaba.nacos.api.config.annotation.NacosConfigurationProperties; +import lombok.Data; +import org.springframework.boot.context.properties.ConfigurationProperties; + +import java.util.List; + +/** + * wechat mp properties + * + * @author Binary Wang(https://github.com/binarywang) + */ +@Data +@ConfigurationProperties(prefix = "wx.mp") +//@NacosConfigurationProperties(prefix = "wx.mp", dataId = "ali-sms",type = ConfigType.YAML, groupId = "DEFAULT_GROUP", autoRefreshed = true) +public class WxMpProperties { + /** + * 是否使用redis存储access token + */ + private boolean useRedis; + + /** + * redis 配置 + */ + private RedisConfig redisConfig; + + @Data + public static class RedisConfig { + /** + * redis服务器 主机地址 + */ + private String host; + + /** + * redis服务器 端口号 + */ + private Integer port; + + /** + * redis服务器 密码 + */ + private String password; + + /** + * redis 服务连接超时时间 + */ + private Integer timeout; + } + + /** + * 多个公众号配置信息 + */ + private List configs; + + @Data + public static class MpConfig { + /** + * 设置微信公众号的appid + */ + private String appId; + + /** + * 设置微信公众号的app secret + */ + private String secret; + + /** + * 设置微信公众号的token + */ + private String token; + + /** + * 设置微信公众号的EncodingAESKey + */ + private String aesKey; + + + private String auditTemplateId; + + private String pushMsgTemplateId; + + private String regAuditTemplateId; + + private String url; + } + + @Override + public String toString() { + return ""; + } + + public List getConfigs() { + return configs; + } + + public boolean isUseRedis() { + return useRedis; + } + + public RedisConfig getRedisConfig() { + return redisConfig; + } +} diff --git a/src/main/java/com/lecoo/wechat/controller/IndexController.java b/src/main/java/com/lecoo/wechat/controller/IndexController.java new file mode 100644 index 0000000..717f7d2 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/controller/IndexController.java @@ -0,0 +1,74 @@ +package com.lecoo.wechat.controller; + +import com.alibaba.fastjson.JSONObject; +import com.aliyun.dysmsapi20170525.models.SendSmsResponse; +import com.lecoo.wechat.entity.SmsReqEntity; +import com.lecoo.wechat.entity.WxMsgReqEntity; +import com.lecoo.wechat.service.SmsService; +import com.lecoo.wechat.utils.SendUtil; +import me.chanjar.weixin.common.error.WxErrorException; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.RestController; + +@RestController +@RequestMapping("/notification/api") +public class IndexController { + @Autowired + SendUtil sendUtil; + + @Autowired + SmsService smsService; + + @RequestMapping(value = "/sendMsg", method = RequestMethod.POST, produces = "application/json;charset=UTF-8") + public JSONObject sendMsg(@RequestBody WxMsgReqEntity wxMsgReqEntity) { + + JSONObject json = wxMsgReqEntity.toJson(); + System.err.println(json); + + + JSONObject result = new JSONObject(); + result.put("status", 0); + result.put("message", "send success!"); + + try { + sendUtil.sendWxTemplateMsg(json); + } catch (WxErrorException e) { + result.put("status", -1); + result.put("message", e.getMessage()); + e.printStackTrace(); + } + return result; + } + + @RequestMapping(value = "/sendSms", method = RequestMethod.POST, produces = "application/json;charset=UTF-8") + public JSONObject sendSms(@RequestBody SmsReqEntity smsReqEntity) { + System.err.println("receive a new req for send sms"); + JSONObject result = new JSONObject(); + result.put("status", 0); + result.put("message", "send success!"); + System.err.println(smsReqEntity.toJson().toJSONString()); + try { + SendSmsResponse sendSmsResponse = smsService.sendTempMmsMeeting(smsReqEntity); + System.err.println(sendSmsResponse.getBody().getMessage()); + System.err.println(sendSmsResponse.getBody().getCode()); + System.err.println(sendSmsResponse.getBody().getCode()); + if (sendSmsResponse.getBody().code.equalsIgnoreCase("ok")) { + return result; + } else { + result.put("status", -1); + result.put("message", sendSmsResponse.getBody().getMessage()); + return result; + } + } catch (Exception e) { + result.put("status", -1); + result.put("message", e.getMessage()); + e.printStackTrace(); + } + System.err.println(result.toJSONString()); + System.err.println("send sms end..."); + return result; + } +} diff --git a/src/main/java/com/lecoo/wechat/entity/SmsReqEntity.java b/src/main/java/com/lecoo/wechat/entity/SmsReqEntity.java new file mode 100644 index 0000000..7d135f0 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/entity/SmsReqEntity.java @@ -0,0 +1,39 @@ +package com.lecoo.wechat.entity; + +import com.alibaba.fastjson.JSONObject; +import com.lecoo.wechat.utils.JsonUtils; +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import java.util.Map; + +@Data +public class SmsReqEntity { + @NotBlank(message = "phone不能为空") + private String phone; + + @NotBlank(message = "template不能为空") + private String template; + + private String dataMap; + + public JSONObject toJson(){ + JSONObject json = new JSONObject(true); + json.put("phone", phone); + json.put("template", template); + + if(dataMap!= null && dataMap.length() > 0){ + JSONObject jsonObject = JSONObject.parseObject(dataMap); + jsonObject.forEach((key, item)->{ + json.put(key, item); + }); + } + + return json; + } + + public String mapToString(){ + JSONObject jsonObject = JSONObject.parseObject(dataMap); + return jsonObject ==null ? "" : jsonObject.toJSONString(); + } +} diff --git a/src/main/java/com/lecoo/wechat/entity/WxMsgReqEntity.java b/src/main/java/com/lecoo/wechat/entity/WxMsgReqEntity.java new file mode 100644 index 0000000..65a3487 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/entity/WxMsgReqEntity.java @@ -0,0 +1,42 @@ +package com.lecoo.wechat.entity; + +import com.alibaba.fastjson.JSONObject; +import lombok.Data; + +import javax.validation.constraints.NotBlank; + +@Data +public class WxMsgReqEntity { + @NotBlank(message = "openid不能为空") + private String openid; + @NotBlank(message = "url不能为空") + private String url; + @NotBlank(message = "templateId不能为空") + private String templateId; + private String first; + private String second; + private String three; + private String four; + private String five; + private String six; + + public JSONObject toJson(){ + JSONObject json = new JSONObject(true); + json.put("openid", openid); + json.put("url", url); + json.put("templateId", templateId); + if (null != first) + json.put("first", first); + if (null != second) + json.put("second", second); + if (null != three) + json.put("three", three); + if (null != four) + json.put("four", four); + if (null != five) + json.put("five", five); + if (null != six) + json.put("six", six); + return json; + } +} diff --git a/src/main/java/com/lecoo/wechat/handler/AbstractHandler.java b/src/main/java/com/lecoo/wechat/handler/AbstractHandler.java new file mode 100644 index 0000000..7ad0e15 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/AbstractHandler.java @@ -0,0 +1,12 @@ +package com.lecoo.wechat.handler; + +import me.chanjar.weixin.mp.api.WxMpMessageHandler; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +public abstract class AbstractHandler implements WxMpMessageHandler { + protected Logger logger = LoggerFactory.getLogger(getClass()); +} diff --git a/src/main/java/com/lecoo/wechat/handler/ControllerExceptionHandler.java b/src/main/java/com/lecoo/wechat/handler/ControllerExceptionHandler.java new file mode 100644 index 0000000..5e8db1a --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/ControllerExceptionHandler.java @@ -0,0 +1,52 @@ +package com.lecoo.wechat.handler; + +import com.alibaba.fastjson.JSONObject; +import org.springframework.http.HttpStatus; +import org.springframework.validation.BindException; +import org.springframework.validation.FieldError; +import org.springframework.web.bind.MethodArgumentNotValidException; +import org.springframework.web.bind.annotation.ControllerAdvice; +import org.springframework.web.bind.annotation.ExceptionHandler; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.ResponseStatus; + +@ControllerAdvice +public class ControllerExceptionHandler { + + @ExceptionHandler(Exception.class) + @ResponseStatus(value = HttpStatus.INTERNAL_SERVER_ERROR) + @ResponseBody + public JSONObject exceptionHandler(Exception exception) { + exception.printStackTrace(); + JSONObject jsonObject = new JSONObject(); + if (exception instanceof MethodArgumentNotValidException) { + JSONObject temp = new JSONObject(); + ((MethodArgumentNotValidException) exception).getBindingResult().getAllErrors().forEach((error) -> { + String fieldName = ((FieldError) error).getField(); + String errorMessage = error.getDefaultMessage(); + temp.put(fieldName, errorMessage); + }); + jsonObject.put("status", 500); + jsonObject.put("errors", temp); + return jsonObject; + } else if (exception instanceof BindException) { + JSONObject temp = new JSONObject(); + ((BindException) exception).getBindingResult().getAllErrors().forEach((error) -> { + String fieldName = ((FieldError) error).getField(); + String errorMessage = error.getDefaultMessage(); + temp.put(fieldName, errorMessage); + }); + jsonObject.put("status", 500); + jsonObject.put("errors", temp); + return jsonObject; + } else { + } + + JSONObject temp = new JSONObject(); + temp.put("message", exception.getMessage()); + + jsonObject.put("status", 500); + jsonObject.put("errors", temp); + return jsonObject; + } +} diff --git a/src/main/java/com/lecoo/wechat/handler/KfSessionHandler.java b/src/main/java/com/lecoo/wechat/handler/KfSessionHandler.java new file mode 100644 index 0000000..757457e --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/KfSessionHandler.java @@ -0,0 +1,25 @@ +package com.lecoo.wechat.handler; + +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class KfSessionHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService wxMpService, + WxSessionManager sessionManager) { + //TODO 对会话做处理 + return null; + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/LocationHandler.java b/src/main/java/com/lecoo/wechat/handler/LocationHandler.java new file mode 100644 index 0000000..e346e4d --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/LocationHandler.java @@ -0,0 +1,44 @@ +package com.lecoo.wechat.handler; + +import com.lecoo.wechat.builder.TextBuilder; +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +import static me.chanjar.weixin.common.api.WxConsts.XmlMsgType; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class LocationHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService wxMpService, + WxSessionManager sessionManager) { + if (wxMessage.getMsgType().equals(XmlMsgType.LOCATION)) { + //TODO 接收处理用户发送的地理位置消息 + try { + String content = "感谢反馈，您的的地理位置已收到！"; + return new TextBuilder().build(content, wxMessage, null); + } catch (Exception e) { + this.logger.error("位置消息接收处理失败", e); + return null; + } + } + + //上报地理位置事件 + this.logger.info("上报地理位置，纬度 : {}，经度 : {}，精度 : {}", + wxMessage.getLatitude(), wxMessage.getLongitude(), String.valueOf(wxMessage.getPrecision())); + + //TODO 可以将用户地理位置信息保存到本地数据库，以便以后使用 + + return null; + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/LogHandler.java b/src/main/java/com/lecoo/wechat/handler/LogHandler.java new file mode 100644 index 0000000..656d254 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/LogHandler.java @@ -0,0 +1,25 @@ +package com.lecoo.wechat.handler; + +import com.lecoo.wechat.utils.JsonUtils; +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class LogHandler extends AbstractHandler { + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService wxMpService, + WxSessionManager sessionManager) { + this.logger.info("\n接收到请求消息，内容：{}", JsonUtils.toJson(wxMessage)); + return null; + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/MenuHandler.java b/src/main/java/com/lecoo/wechat/handler/MenuHandler.java new file mode 100644 index 0000000..43f478b --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/MenuHandler.java @@ -0,0 +1,35 @@ +package com.lecoo.wechat.handler; + +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +import static me.chanjar.weixin.common.api.WxConsts.EventType; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class MenuHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService weixinService, + WxSessionManager sessionManager) { + String msg = String.format("type:%s, event:%s, key:%s", + wxMessage.getMsgType(), wxMessage.getEvent(), + wxMessage.getEventKey()); + if (EventType.VIEW.equals(wxMessage.getEvent())) { + return null; + } + + return WxMpXmlOutMessage.TEXT().content(msg) + .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()) + .build(); + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/MsgHandler.java b/src/main/java/com/lecoo/wechat/handler/MsgHandler.java new file mode 100644 index 0000000..5c25cba --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/MsgHandler.java @@ -0,0 +1,51 @@ +package com.lecoo.wechat.handler; + +import com.lecoo.wechat.builder.TextBuilder; +import me.chanjar.weixin.common.error.WxErrorException; +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Component; + +import java.util.Map; + +import static me.chanjar.weixin.common.api.WxConsts.XmlMsgType; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class MsgHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService weixinService, + WxSessionManager sessionManager) { + + if (!wxMessage.getMsgType().equals(XmlMsgType.EVENT)) { + //TODO 可以选择将消息保存到本地 + } + + //当用户输入关键词如“你好”，“客服”等，并且有客服在线时，把消息转发给在线客服 + try { + if (StringUtils.startsWithAny(wxMessage.getContent(), "你好", "客服") + && weixinService.getKefuService().kfOnlineList() + .getKfOnlineList().size() > 0) { + return WxMpXmlOutMessage.TRANSFER_CUSTOMER_SERVICE() + .fromUser(wxMessage.getToUser()) + .toUser(wxMessage.getFromUser()).build(); + } + } catch (WxErrorException e) { + e.printStackTrace(); + } + + //TODO 组装回复消息 + String content = "收到信息内容：好的，已收到您的回复"; + + return new TextBuilder().build(content, wxMessage, weixinService); + + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/NullHandler.java b/src/main/java/com/lecoo/wechat/handler/NullHandler.java new file mode 100644 index 0000000..2acd720 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/NullHandler.java @@ -0,0 +1,24 @@ +package com.lecoo.wechat.handler; + +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class NullHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService wxMpService, + WxSessionManager sessionManager) { + return null; + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/ScanHandler.java b/src/main/java/com/lecoo/wechat/handler/ScanHandler.java new file mode 100644 index 0000000..7de7f46 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/ScanHandler.java @@ -0,0 +1,24 @@ +package com.lecoo.wechat.handler; + +import me.chanjar.weixin.common.error.WxErrorException; +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class ScanHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMpXmlMessage, Map map, + WxMpService wxMpService, WxSessionManager wxSessionManager) throws WxErrorException { + // 扫码事件处理 + return null; + } +} diff --git a/src/main/java/com/lecoo/wechat/handler/StoreCheckNotifyHandler.java b/src/main/java/com/lecoo/wechat/handler/StoreCheckNotifyHandler.java new file mode 100644 index 0000000..c52e776 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/StoreCheckNotifyHandler.java @@ -0,0 +1,27 @@ +package com.lecoo.wechat.handler; + +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * 门店审核事件处理 + * + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class StoreCheckNotifyHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService wxMpService, + WxSessionManager sessionManager) { + // TODO 处理门店审核事件 + return null; + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/SubscribeHandler.java b/src/main/java/com/lecoo/wechat/handler/SubscribeHandler.java new file mode 100644 index 0000000..8f77d79 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/SubscribeHandler.java @@ -0,0 +1,71 @@ +package com.lecoo.wechat.handler; + +import com.lecoo.wechat.builder.TextBuilder; +import me.chanjar.weixin.common.error.WxErrorException; +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import me.chanjar.weixin.mp.bean.result.WxMpUser; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class SubscribeHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService weixinService, + WxSessionManager sessionManager) throws WxErrorException { + + this.logger.info("新关注用户 OPENID: " + wxMessage.getFromUser()); + + // 获取微信用户基本信息 + try { + WxMpUser userWxInfo = weixinService.getUserService() + .userInfo(wxMessage.getFromUser(), null); + if (userWxInfo != null) { + // TODO 可以添加关注用户到本地数据库 + System.out.println(userWxInfo); + } + } catch (WxErrorException e) { + if (e.getError().getErrorCode() == 48001) { + this.logger.info("该公众号没有获取用户信息权限！"); + } + } + + + WxMpXmlOutMessage responseResult = null; + try { + responseResult = this.handleSpecial(wxMessage); + } catch (Exception e) { + this.logger.error(e.getMessage(), e); + } + + if (responseResult != null) { + return responseResult; + } + + try { + return new TextBuilder().build("感谢关注", wxMessage, weixinService); + } catch (Exception e) { + this.logger.error(e.getMessage(), e); + } + + return null; + } + + /** + * 处理特殊请求，比如如果是扫码进来的，可以做相应处理 + */ + private WxMpXmlOutMessage handleSpecial(WxMpXmlMessage wxMessage) + throws Exception { + //TODO + return null; + } + +} diff --git a/src/main/java/com/lecoo/wechat/handler/UnsubscribeHandler.java b/src/main/java/com/lecoo/wechat/handler/UnsubscribeHandler.java new file mode 100644 index 0000000..2ec0f25 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/handler/UnsubscribeHandler.java @@ -0,0 +1,27 @@ +package com.lecoo.wechat.handler; + +import me.chanjar.weixin.common.session.WxSessionManager; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +@Component +public class UnsubscribeHandler extends AbstractHandler { + + @Override + public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, + Map context, WxMpService wxMpService, + WxSessionManager sessionManager) { + String openId = wxMessage.getFromUser(); + this.logger.info("取消关注用户 OPENID: " + openId); + // TODO 可以更新本地数据库为取消关注状态 + return null; + } + +} diff --git a/src/main/java/com/lecoo/wechat/service/SmsService.java b/src/main/java/com/lecoo/wechat/service/SmsService.java new file mode 100644 index 0000000..1200dd9 --- /dev/null +++ b/src/main/java/com/lecoo/wechat/service/SmsService.java @@ -0,0 +1,234 @@ +package com.lecoo.wechat.service; + +import com.alibaba.fastjson.JSONObject; +import com.aliyun.dysmsapi20170525.models.SendSmsRequest; +import com.aliyun.dysmsapi20170525.models.SendSmsResponse; +import com.aliyun.teaopenapi.models.Config; +import com.lecoo.wechat.config.SmsProperties; +import com.lecoo.wechat.entity.SmsReqEntity; +import lombok.AllArgsConstructor; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.Map; +import java.util.Set; + +/** + * spring sms 工具类 + * + * @author xueyi + **/ +@Component +@AllArgsConstructor +@SuppressWarnings(value = {"unchecked", "rawtypes"}) +public class SmsService { + @Autowired + private SmsProperties sendMmsProperties; + + + public String getReceptionPhones(){ + return sendMmsProperties.getReceptionPhones(); + } + + + public SendSmsResponse sendTempMms(String phone, String paramStr, boolean hasCar) throws Exception { + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(sendMmsProperties.getAccessKeyId()) + // 您的AccessKey Secret + .setAccessKeySecret(sendMmsProperties.getAccessKeySecrect()); + // 访问的域名 + config.endpoint = sendMmsProperties.getEndpoint(); + com.aliyun.dysmsapi20170525.Client client = new com.aliyun.dysmsapi20170525.Client(config); + + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(phone) + .setSignName(sendMmsProperties.getSignNameVisitor()) + .setTemplateCode(hasCar?sendMmsProperties.getCarTemplate():sendMmsProperties.getTemplate()) + .setTemplateParam(paramStr); + // 复制代码运行请自行打印 API 的返回值 + SendSmsResponse res = client.sendSms(sendSmsRequest); + + return res; + } + + public SendSmsResponse sendTempMmsFixed(String phone, String paramStr) throws Exception { + + + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(sendMmsProperties.getAccessKeyId()) + // 您的AccessKey Secret + .setAccessKeySecret(sendMmsProperties.getAccessKeySecrect()); + // 访问的域名 + config.endpoint = sendMmsProperties.getEndpoint(); + com.aliyun.dysmsapi20170525.Client client = new com.aliyun.dysmsapi20170525.Client(config); + + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(phone) + .setSignName(sendMmsProperties.getSignNameVisitor()) + .setTemplateCode(sendMmsProperties.getFixedTemplate()) + .setTemplateParam(paramStr); + // 复制代码运行请自行打印 API 的返回值 + SendSmsResponse res = client.sendSms(sendSmsRequest); + + return res; + } + + + public SendSmsResponse sendTempMmsCode(String phone, String code) throws Exception { + + + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(sendMmsProperties.getAccessKeyId()) + // 您的AccessKey Secret + .setAccessKeySecret(sendMmsProperties.getAccessKeySecrect()); + // 访问的域名 + config.endpoint = sendMmsProperties.getEndpoint(); + com.aliyun.dysmsapi20170525.Client client = new com.aliyun.dysmsapi20170525.Client(config); + + JSONObject json = new JSONObject(); + json.put("code", code); + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(phone) + .setSignName(sendMmsProperties.getSignName()) + .setTemplateCode(sendMmsProperties.getCodeTemplate()) + .setTemplateParam(json.toJSONString()); + // 复制代码运行请自行打印 API 的返回值 + SendSmsResponse res = client.sendSms(sendSmsRequest); + + return res; + } + + public void test(){ + System.out.println(sendMmsProperties); + } + + public SendSmsResponse sendTempMmsMeeting(String phone, Integer type, Map dataMap) throws Exception { + + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(sendMmsProperties.getAccessKeyId()) + // 您的AccessKey Secret + .setAccessKeySecret(sendMmsProperties.getAccessKeySecrect()); + // 访问的域名 + config.endpoint = sendMmsProperties.getEndpoint(); + com.aliyun.dysmsapi20170525.Client client = new com.aliyun.dysmsapi20170525.Client(config); + + String template = ""; + if (type == 1) { + template = sendMmsProperties.getMeetingOrderTemplate(); + } else if (type == 2) { + template = sendMmsProperties.getMeetingQuitTemplate(); + } else { + template = sendMmsProperties.getMeetingRemindTemplate(); + } + + JSONObject json = new JSONObject(); + Set kSet = dataMap.keySet(); + + for (String key : kSet) { + json.put(key, dataMap.get(key)); + } +// json.put("name", meetingRoomOrder.getOrderByEmp()); +// json.put("dateStr", meetingRoomOrder.getOrderData()); + json.put("rebotName", sendMmsProperties.getRobotName()); + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(phone) + .setSignName(sendMmsProperties.getSignName()) + .setTemplateCode(template) + .setTemplateParam(json.toJSONString()); + // 复制代码运行请自行打印 API 的返回值 + SendSmsResponse res = client.sendSms(sendSmsRequest); + + return res; + } + + + public SendSmsResponse sendTempMmsMeeting(SmsReqEntity smsReqEntity) throws Exception { + + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(sendMmsProperties.getAccessKeyId()) + // 您的AccessKey Secret + .setAccessKeySecret(sendMmsProperties.getAccessKeySecrect()); + // 访问的域名 + config.endpoint = sendMmsProperties.getEndpoint(); + com.aliyun.dysmsapi20170525.Client client = new com.aliyun.dysmsapi20170525.Client(config); + + String template = smsReqEntity.getTemplate(); + + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(smsReqEntity.getPhone()) + .setSignName(sendMmsProperties.getSignName()) + .setTemplateCode(template) + .setTemplateParam(smsReqEntity.mapToString()); + // 复制代码运行请自行打印 API 的返回值 + SendSmsResponse res = client.sendSms(sendSmsRequest); + + return res; + } + + /*public SendSmsResponse sendTempMmsMeeting(String phone, MeetingRoomOrder meetingRoomOrder, Integer type) throws Exception { + + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(sendMmsProperties.getAccessKeyId()) + // 您的AccessKey Secret + .setAccessKeySecret(sendMmsProperties.getAccessKeySecrect()); + // 访问的域名 + config.endpoint = sendMmsProperties.getEndpoint(); + com.aliyun.dysmsapi20170525.Client client = new com.aliyun.dysmsapi20170525.Client(config); + + String template = ""; + if (type == 1) { + template = sendMmsProperties.getMeetingOrderTemplate(); + } else if (type == 2) { + template = sendMmsProperties.getMeetingQuitTemplate(); + } else { + template = sendMmsProperties.getMeetingRemindTemplate(); + } + + JSONObject json = new JSONObject(); + json.put("name", meetingRoomOrder.getOrderByEmp()); + json.put("dateStr", meetingRoomOrder.getOrderData()); + json.put("rebotName", sendMmsProperties.getRobotName()); + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(phone) + .setSignName(sendMmsProperties.getSignName()) + .setTemplateCode(template) + .setTemplateParam(json.toJSONString()); + // 复制代码运行请自行打印 API 的返回值 + SendSmsResponse res = client.sendSms(sendSmsRequest); + + return res; + }*/ + + public SendSmsResponse sendMmsToDefault(String phone) throws Exception{ + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(sendMmsProperties.getAccessKeyId()) + // 您的AccessKey Secret + .setAccessKeySecret(sendMmsProperties.getAccessKeySecrect()); + // 访问的域名 + config.endpoint = sendMmsProperties.getEndpoint(); + com.aliyun.dysmsapi20170525.Client client = new com.aliyun.dysmsapi20170525.Client(config); + + String template = sendMmsProperties.getDefaultRemindTemplate(); + + JSONObject json = new JSONObject(); + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(phone) + .setSignName(sendMmsProperties.getSignName()) + .setTemplateCode(template) + .setTemplateParam(json.toJSONString()); + // 复制代码运行请自行打印 API 的返回值 + SendSmsResponse res = client.sendSms(sendSmsRequest); + + return res; + } +} + + + diff --git a/src/main/java/com/lecoo/wechat/utils/JsonUtils.java b/src/main/java/com/lecoo/wechat/utils/JsonUtils.java new file mode 100644 index 0000000..9ee736f --- /dev/null +++ b/src/main/java/com/lecoo/wechat/utils/JsonUtils.java @@ -0,0 +1,17 @@ +package com.lecoo.wechat.utils; + +import com.google.gson.Gson; +import com.google.gson.GsonBuilder; + +/** + * @author Binary Wang(https://github.com/binarywang) + */ +public class JsonUtils { + public static String toJson(Object obj) { + Gson gson = new GsonBuilder() + .setPrettyPrinting() + .disableHtmlEscaping() + .create(); + return gson.toJson(obj); + } +} diff --git a/src/main/java/com/lecoo/wechat/utils/SendUtil.java b/src/main/java/com/lecoo/wechat/utils/SendUtil.java new file mode 100644 index 0000000..2810e2a --- /dev/null +++ b/src/main/java/com/lecoo/wechat/utils/SendUtil.java @@ -0,0 +1,61 @@ +/** + * @project AppService + * @filename SignUtil.java + * @date 2016年8月31日 + * @author KeShanqiang + */ + +package com.lecoo.wechat.utils; + +import com.alibaba.fastjson.JSONObject; +import com.lecoo.wechat.config.WxMpProperties; +import lombok.AllArgsConstructor; +import me.chanjar.weixin.common.error.WxErrorException; +import me.chanjar.weixin.mp.api.WxMpService; +import me.chanjar.weixin.mp.bean.template.WxMpTemplateData; +import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.Set; + +@AllArgsConstructor +@Component +public class SendUtil { + @Autowired + private final WxMpService wxService; + + + + + public String sendWxTemplateMsg(JSONObject jsonObject) throws WxErrorException { + + if (jsonObject.size()<4) { + return "不合法的参数。。。。"; + } + Set keySet = jsonObject.keySet(); + Object[] keyAry = keySet.toArray(); + Integer i = 0, j = 1; + String openid = (String) jsonObject.get(keyAry[i++]); + String url = (String) jsonObject.get(keyAry[i++]); + String templateId = (String) jsonObject.get(keyAry[i++]); + + WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder() + .toUser(openid) + .templateId(templateId) + .url(url) + .build(); + + templateMessage.addData(new WxMpTemplateData("first", (String) jsonObject.get(keyAry[i++]), "#FF00FF")); + while (i