From 6d85e681bb7a4c2aba7558b943f84741be1416bf Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期五, 07 三月 2025 18:34:06 +0800 Subject: [PATCH] 2.0新增 --- ManagementOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/task/jobs/AddNotice.java | 100 +++++++++++++++++++++++++------------------------- 1 files changed, 50 insertions(+), 50 deletions(-) diff --git a/ManagementOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/task/jobs/AddNotice.java b/ManagementOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/task/jobs/AddNotice.java index c4628ba..e88306d 100644 --- a/ManagementOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/task/jobs/AddNotice.java +++ b/ManagementOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/task/jobs/AddNotice.java @@ -33,56 +33,56 @@ System.err.println(("----定时1秒后生成公告记录-----")); TNotices tNotices = tNoticesService.selectById(noticeId); if (SinataUtil.isNotEmpty(tNotices)){ - if (tNotices.getIsUser() == 2){ - List<TUser> tUsers = tUserService.selectList(new EntityWrapper<TUser>().eq("state",1)); - //发送公告给用户 - for (TUser user : tUsers){ - TSystemNotice notice = new TSystemNotice(); - notice.setType(1); - notice.setUserType(1); - notice.setNoticesId(noticeId); - notice.setContent(tNotices.getContent()); - notice.setUserId(user.getId()); - notice.setInsertTime(new Date()); - notice.setRead(1); - tSystemNoticeService.insert(notice); - - /*Map<String,Object> map = new HashMap<String,Object>(); - map.put("sound", userInfo.getIsVoice()); //是否有声音 1=否 2=是 - map.put("vibrate", userInfo.getIsShake()); //是否有震动 1=否 2=是 - map.put("type", 2); //消息类型 1=互动 2=公告 - map.put("id", record.getId()); //对象ID - JpushUtil.SendPushWithCustomForTransmission(String.valueOf(userInfo.getId()),"【超级过客】提醒您,您有一条新的公告消息。","通知消息",map);*/ - } - } - if (tNotices.getIsDriver() == 2){ - List<TDriver> tDrivers = tDriverService.selectList(new EntityWrapper<TDriver>().eq("authState",2)); - //发送公告给用户 - for (TDriver driver : tDrivers){ - TSystemNotice notice = new TSystemNotice(); - notice.setType(1); - notice.setUserType(2); - notice.setNoticesId(noticeId); - notice.setContent(tNotices.getContent()); - notice.setUserId(driver.getId()); - notice.setInsertTime(new Date()); - notice.setRead(1); - tSystemNoticeService.insert(notice); - - /*Map<String,Object> map = new HashMap<String,Object>(); - map.put("sound", userInfo.getIsVoice()); //是否有声音 1=否 2=是 - map.put("vibrate", userInfo.getIsShake()); //是否有震动 1=否 2=是 - map.put("type", 2); //消息类型 1=互动 2=公告 - map.put("id", record.getId()); //对象ID - JpushUtil.SendPushWithCustomForTransmission(String.valueOf(userInfo.getId()),"【超级过客】提醒您,您有一条新的公告消息。","通知消息",map);*/ - - if (tNotices.getIsBroadcast() == 1){ - //增加极光推送 - JpushUtil.SendPushWithCustomForSh("DRIVER"+driver.getId().toString(),tNotices.getTitle(),"通知消息",null); - } - - } - } +// if (tNotices.getIsUser() == 2){ +// List<TUser> tUsers = tUserService.selectList(new EntityWrapper<TUser>().eq("state",1)); +// //发送公告给用户 +// for (TUser user : tUsers){ +// TSystemNotice notice = new TSystemNotice(); +// notice.setType(1); +// notice.setUserType(1); +// notice.setNoticesId(noticeId); +// notice.setContent(tNotices.getContent()); +// notice.setUserId(user.getId()); +// notice.setInsertTime(new Date()); +// notice.setRead(1); +// tSystemNoticeService.insert(notice); +// +// /*Map<String,Object> map = new HashMap<String,Object>(); +// map.put("sound", userInfo.getIsVoice()); //是否有声音 1=否 2=是 +// map.put("vibrate", userInfo.getIsShake()); //是否有震动 1=否 2=是 +// map.put("type", 2); //消息类型 1=互动 2=公告 +// map.put("id", record.getId()); //对象ID +// JpushUtil.SendPushWithCustomForTransmission(String.valueOf(userInfo.getId()),"【超级过客】提醒您,您有一条新的公告消息。","通知消息",map);*/ +// } +// } +// if (tNotices.getIsDriver() == 2){ +// List<TDriver> tDrivers = tDriverService.selectList(new EntityWrapper<TDriver>().eq("authState",2)); +// //发送公告给用户 +// for (TDriver driver : tDrivers){ +// TSystemNotice notice = new TSystemNotice(); +// notice.setType(1); +// notice.setUserType(2); +// notice.setNoticesId(noticeId); +// notice.setContent(tNotices.getContent()); +// notice.setUserId(driver.getId()); +// notice.setInsertTime(new Date()); +// notice.setRead(1); +// tSystemNoticeService.insert(notice); +// +// /*Map<String,Object> map = new HashMap<String,Object>(); +// map.put("sound", userInfo.getIsVoice()); //是否有声音 1=否 2=是 +// map.put("vibrate", userInfo.getIsShake()); //是否有震动 1=否 2=是 +// map.put("type", 2); //消息类型 1=互动 2=公告 +// map.put("id", record.getId()); //对象ID +// JpushUtil.SendPushWithCustomForTransmission(String.valueOf(userInfo.getId()),"【超级过客】提醒您,您有一条新的公告消息。","通知消息",map);*/ +// +// if (tNotices.getIsBroadcast() == 1){ +// //增加极光推送 +// JpushUtil.SendPushWithCustomForSh("DRIVER"+driver.getId().toString(),tNotices.getTitle(),"通知消息",null); +// } +// +// } +// } } } catch (Exception e) { e.printStackTrace(); -- Gitblit v1.7.1