From 689e1a1d87e74cede487e85e48e6921f32d938ec Mon Sep 17 00:00:00 2001 From: ky <592468495@qq.com> Date: Tue, 21 Jul 2020 15:53:57 +0800 Subject: [PATCH] p --- .../java/com/yhjd/handler/MenuHandler.java | 103 ++++++++++++++++++ .../java/com/yhjd/handler/MsgHandler.java | 25 ++++- .../yhjd/service/impl/MissonServiceImpl.java | 14 ++- src/main/resources/application-dev.yml | 4 +- 4 files changed, 133 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/yhjd/handler/MenuHandler.java b/src/main/java/com/yhjd/handler/MenuHandler.java index 9358ca3..db55c16 100644 --- a/src/main/java/com/yhjd/handler/MenuHandler.java +++ b/src/main/java/com/yhjd/handler/MenuHandler.java @@ -4,8 +4,12 @@ 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.message.WxMpXmlOutNewsMessage; +import me.chanjar.weixin.mp.builder.outxml.NewsBuilder; import org.springframework.stereotype.Component; +import java.util.ArrayList; +import java.util.List; import java.util.Map; import static me.chanjar.weixin.common.api.WxConsts.EventType; @@ -27,6 +31,105 @@ public class MenuHandler extends AbstractHandler { return null; } + if(wxMessage.getEventKey().equals("公司动态")){ + msg = "该系统需要认证才可使用 点我认证"; + } + if(wxMessage.getEventKey().equals("检修智库")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("检修智库"); + item.setDescription("点击进入检修智库"); + item.setPicUrl("http://zj220.emaylearningsh.com/static/zj/images/wechat/zhiku.jpg"); + item.setUrl("http://zj220.emaylearningsh.com/index.php/zhijian/zhiku?openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("聚焦QC创新")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("聚焦QC创新"); + item.setDescription("点击进入聚焦QC创新"); + item.setPicUrl(""); + item.setUrl("http://zj220.emaylearningsh.com/index.php/knowledge/index?cid=2&openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("聚焦管理创新")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("聚焦管理创新"); + item.setDescription("点击进入聚焦管理创新"); + item.setPicUrl(""); + item.setUrl("http://zj220.emaylearningsh.com/index.php/knowledge/index?cid=3&openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("聚焦人才培养")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("聚焦人才培养"); + item.setDescription("点击进入聚焦人才培养"); + item.setPicUrl(""); + item.setUrl("http://zj220.emaylearningsh.com/index.php/knowledge/index?cid=5&openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("聚焦技术创新")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("聚焦技术创新"); + item.setDescription("点击进入聚焦技术创新"); + item.setPicUrl(""); + item.setUrl("http://zj220.emaylearningsh.com/index.php/knowledge/index?cid=6&openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("龙虎榜单")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("龙虎榜单"); + item.setDescription("点击进入龙虎榜单"); + item.setPicUrl(""); + item.setUrl("http://zj220.emaylearningsh.com/index.php/zhijian/lhbcates?openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("积分商城")){ + msg = "该功能开发中，敬请期待"; + } + + if(wxMessage.getEventKey().equals("报名帖")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("报名帖"); + item.setDescription("点击进入报名帖"); + item.setPicUrl(""); + item.setUrl("http://zj220.emaylearningsh.com/index.php/zhijian/bmlist?openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("联系我们")){ + List articles = new ArrayList<>(); + WxMpXmlOutNewsMessage.Item item = new WxMpXmlOutNewsMessage.Item(); + item.setTitle("联系我们"); + item.setDescription("点击进入联系我们"); + item.setPicUrl(""); + item.setUrl("http://zj220.emaylearningsh.com/index.php/zhijian/tougao?openid=oWGAc6ALzFPO97N3Ea7QLlXO01dQ&from=singlemessage"); + articles.add(item); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); + } + + if(wxMessage.getEventKey().equals("我的地盘")){ + msg = "该系统需要认证才可使用 点我认证"; + } + return WxMpXmlOutMessage.TEXT().content(msg) .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()) .build(); diff --git a/src/main/java/com/yhjd/handler/MsgHandler.java b/src/main/java/com/yhjd/handler/MsgHandler.java index 034987e..e213afe 100644 --- a/src/main/java/com/yhjd/handler/MsgHandler.java +++ b/src/main/java/com/yhjd/handler/MsgHandler.java @@ -1,6 +1,5 @@ package com.yhjd.handler; -import com.yhjd.build.TextBuilder; import com.yhjd.entity.Misson; import com.yhjd.mapper.MissonMapper; import com.yhjd.util.JsonUtils; @@ -9,10 +8,14 @@ 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.message.WxMpXmlOutNewsMessage.Item; +import me.chanjar.weixin.mp.builder.outxml.NewsBuilder; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import java.util.ArrayList; +import java.util.List; import java.util.Map; import static me.chanjar.weixin.common.api.WxConsts.XmlMsgType; @@ -50,15 +53,25 @@ public class MsgHandler extends AbstractHandler { //TODO 组装回复消息 Misson misson = new Misson(); - misson.setKeyword(""); + misson.setKeyword(wxMessage.getContent()); Misson result = missonMapper.selectOne(misson); String name = result.getName(); wxMessage.setContent(name); - +// wxMessage.setMsgType("news"); +// wxMessage.setTitle(name); +// wxMessage.setDescription(result.getDescription()); +// wxMessage.setPicUrl(result.getPreviewUrl()); +// wxMessage.setUrl(result.getH5Url()); String content = "收到信息内容：" + JsonUtils.toJson(wxMessage); - - return new TextBuilder().build(content, wxMessage, weixinService); - + List articles = new ArrayList<>(); + Item item = new Item(); + item.setTitle(name); + item.setDescription(result.getDescription()); + item.setPicUrl(result.getPreviewUrl()); + item.setUrl(result.getH5Url()); + articles.add(item); +// return new TextBuilder().build(content, wxMessage, weixinService); + return new NewsBuilder().articles(articles).fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser()).build(); } } diff --git a/src/main/java/com/yhjd/service/impl/MissonServiceImpl.java b/src/main/java/com/yhjd/service/impl/MissonServiceImpl.java index 3123407..4dc22b3 100644 --- a/src/main/java/com/yhjd/service/impl/MissonServiceImpl.java +++ b/src/main/java/com/yhjd/service/impl/MissonServiceImpl.java @@ -15,9 +15,7 @@ import org.apache.ibatis.session.RowBounds; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import java.util.Date; -import java.util.List; -import java.util.UUID; +import java.util.*; /** *

@@ -52,7 +50,7 @@ public class MissonServiceImpl extends ServiceImpl impleme public JSONObject queryMisson(Integer pageNum, Integer pageSize,Long beginTime,Long endTime,String param){ - Integer count = missonMapper.selectCount(new EntityWrapper()); + Wrapper missonWrapper = new EntityWrapper().eq("1", "1"); if(!param.equals("")){ missonWrapper.like("name",param); @@ -61,8 +59,14 @@ public class MissonServiceImpl extends ServiceImpl impleme missonWrapper.ge("create_date",new Date(beginTime)); } if(null!=endTime){ - missonWrapper.le("create_date",new Date(endTime)); + Date current = new Date(endTime); + Calendar calendar = new GregorianCalendar(); + calendar.setTime(current); + calendar.add(calendar.DATE, 1); + current = calendar.getTime(); + missonWrapper.le("create_date",current); } + Integer count = missonMapper.selectCount(missonWrapper); List result = missonMapper.selectPage(new RowBounds((pageNum-1)*pageSize,pageSize), missonWrapper.orderBy("create_date", false)); JSONObject jsonObject = new JSONObject(); jsonObject.put("count",count); diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index ec2cc78..1734e53 100755 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -47,8 +47,8 @@ wx: configs: - appid: wx44742933fc151c65 secret: 6f315f3bc8949a428f3a24068476a7e7 - token: #微信小程序消息服务器配置的token - aesKey: #微信小程序消息服务器配置的EncodingAESKey + token: eMayx #微信小程序消息服务器配置的token + aesKey: hIsKGeHocUzks9ZVV2OEJZo4OCYpJ0aXGXDvwVyT6pB #微信小程序消息服务器配置的EncodingAESKey msgDataFormat: JSON oss: