1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.kuali.mobility.push.service;
17
18 import javax.ws.rs.GET;
19 import javax.ws.rs.Path;
20 import org.apache.log4j.Logger;
21 import javax.ws.rs.QueryParam;
22 import net.sf.json.JSONSerializer;
23 import org.kuali.mobility.push.dao.PushDao;
24 import org.kuali.mobility.push.entity.Device;
25 import org.kuali.mobility.push.entity.Push;
26 import org.kuali.mobility.push.entity.PushDeviceTuple;
27 import org.kuali.mobility.push.service.send.SendServiceDelegator;
28 import org.springframework.beans.factory.annotation.Autowired;
29 import org.springframework.beans.factory.annotation.Qualifier;
30 import org.springframework.transaction.annotation.Transactional;
31
32 import java.util.Iterator;
33 import java.util.List;
34
35
36
37
38
39
40
41
42 public class PushServiceImpl implements PushService {
43
44
45 private static final Logger LOG = Logger.getLogger(PushServiceImpl.class);
46
47
48 @Autowired
49 @Qualifier("sendServiceDelegator")
50 private SendServiceDelegator sendService;
51
52
53 @Autowired
54 private DeviceService deviceService;
55
56
57 @Autowired
58 private PushDeviceTupleService pdtService;
59
60
61 @Autowired
62 private PushDao pushDao;
63
64
65
66
67
68 @Override
69 @Transactional
70 public void savePush(Push push){
71 pushDao.savePush(push);
72 }
73
74
75
76
77
78
79 @Override
80 @Transactional
81 public boolean removePush(Push push){
82 return pushDao.removePush(push);
83 }
84
85
86
87
88
89
90 @Override
91 @Transactional
92 public void savePush(Push push, List<Device> devices){
93 pushDao.savePush(push, devices);
94 }
95
96
97
98
99
100 @Transactional
101 public Push findPushById(Long id){
102 return pushDao.findPushById(id);
103 }
104
105
106
107
108
109 @Transactional
110 public List<Device> findDevicesForPush(Push push){
111 return pushDao.findDevicesForPush(push);
112 }
113
114
115
116
117
118 @Transactional
119 public List<PushDeviceTuple> findUnsentPushTuples(){
120 return pushDao.findUnsentPushTuples();
121 }
122
123
124
125
126
127 @Transactional
128 public List<Push> findAllPush() {
129 return pushDao.findAllPush();
130 }
131
132
133
134
135
136 @Transactional
137 public int countPushes() {
138 return pushDao.countPushes();
139 }
140
141
142
143
144
145 public int sendPush(Push push, Device device){
146 this.getSendService().sendPush(push, device);
147 return -1;
148 }
149
150
151
152
153
154
155 public int sendPush(Push push, List<Device> devices){
156 this.getSendService().sendPush(push, devices);
157 return -1;
158 }
159
160
161
162
163
164 @Transactional
165 public int sendPush(List<PushDeviceTuple> tuples){
166 Iterator<PushDeviceTuple> i = tuples.iterator();
167 Push p = null;
168 Device d = null;
169 while(i.hasNext()){
170 PushDeviceTuple pdt = (PushDeviceTuple)i.next();
171 LOG.info("Push id : " + pdt.getPushId() + " Device id: " + pdt.getDeviceId());
172 p = this.findPushById(pdt.getPushId());
173 LOG.info("Push Title: " + p.getTitle());
174 d = getDeviceService().findDeviceById(pdt.getDeviceId());
175 LOG.info("Device Name:" + d.getDeviceName());
176 getPdtService().markTupleAsSent(pdt);
177 }
178 return 0;
179 }
180
181 @Override
182 @GET
183 @Path("/getUserDetails")
184 public String getUserDetails(@QueryParam("pushId") final String id) {
185 Push push = new Push();
186 long pushId = 0;
187 try {
188 pushId = Long.parseLong(id);
189 } catch (NumberFormatException nfe) {
190 LOG.error( "Number Format Exception: "+ nfe.getMessage() );
191 }
192 push = findPushById(pushId);
193 String value = "pushJSON('" + JSONSerializer.toJSON(push).toString() + "');";
194 return value;
195 }
196
197
198
199
200
201
202 public void setPushDao(PushDao dao) {
203 this.pushDao = dao;
204 }
205
206
207
208
209
210 public PushDao getPushDao() {
211 return pushDao;
212 }
213
214
215
216
217
218 public SendServiceDelegator getSendService() {
219 return sendService;
220 }
221
222
223
224
225
226 public void setSendService(SendServiceDelegator sendService) {
227 this.sendService = sendService;
228 }
229
230
231 public DeviceService getDeviceService() {
232 return deviceService;
233 }
234
235
236
237
238
239 public void setDeviceService(DeviceService deviceService) {
240 this.deviceService = deviceService;
241 }
242
243
244 public PushDeviceTupleService getPdtService() {
245 return pdtService;
246 }
247
248
249
250
251
252 public void setPdtService(PushDeviceTupleService pdtService) {
253 this.pdtService = pdtService;
254 }
255 }