| | |
|---|
| | | if(!comActActivityDO.getActivityAddr().equals(comActActivityVO.getActivityAddr()) || !comActActivityDO.getBeginAt().equals(comActActivityVO.getBeginAt())){ |
|---|
| | | //修改活动开始时间与活动地点需要推送订阅消息给用户 |
|---|
| | | ActivitySignVO activitySignVO = new ActivitySignVO(); |
|---|
| | | activitySignVO.setId(comActActivityVO.getId()); |
|---|
| | | activitySignVO.setActivityId(comActActivityVO.getId()); |
|---|
| | | List<ActivitySignVO> activitySignVOS = comActActSignDAO.listActivitySigns(activitySignVO); |
|---|
| | | if(!activitySignVOS.isEmpty()){ |
|---|
| | | try { |
|---|
| | |
|---|
| | | public R timedTaskActivityNotice(){ |
|---|
| | | //查询所有即将开始的活动 |
|---|
| | | List<ComActActivityDO> actActivityList = comActActivityDAO.selectList(new QueryWrapper<ComActActivityDO>().lambda() |
|---|
| | | .le(ComActActivityDO::getBeginAt, DateUtils.addDays(new Date(),1))); |
|---|
| | | .le(ComActActivityDO::getBeginAt, DateUtils.addDays(new Date(),1)) |
|---|
| | | .ge(ComActActivityDO::getBeginAt,new Date())); |
|---|
| | | if(!actActivityList.isEmpty()){ |
|---|
| | | WxXCXTempSend util = new WxXCXTempSend(); |
|---|
| | | try { |
|---|
| | |
|---|
| | | WxUtil.sendSubscribeHDJJKS(openid,accessToken,actActivity.getActivityName() |
|---|
| | | , com.panzhihua.common.utlis.DateUtils.format(actActivity.getBeginAt() |
|---|
| | | ,com.panzhihua.common.utlis.DateUtils.ymdhms_format),actActivity.getActivityAddr() |
|---|
| | | ,actSignList.size()+""); |
|---|
| | | ,actSignList.size()+"人"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | }); |
|---|
