Commit 8b9a52a8 8b9a52a8086e877791aabcc99e3390ca5b16a538 by 张云鹏

点击和访问次数未改变的时候不更新

1 parent c230ae90
...@@ -151,18 +151,22 @@ public class ActivityBtnClickPvUcCalculateTask { ...@@ -151,18 +151,22 @@ public class ActivityBtnClickPvUcCalculateTask {
151 log.info("hourPv ==>> {}", hourPv); 151 log.info("hourPv ==>> {}", hourPv);
152 log.info("hourUv ==>> {}", hourUv); 152 log.info("hourUv ==>> {}", hourUv);
153 153
154 if (activityBtnPvUvHour_.getPv() >= hourPv) { 154 log.info("按钮每小时点击更新 redisPV: {}, dbPV: {}, redisUV: {}, dbUV: {}", hourPv, activityBtnPvUvHour_.getPv(), hourUv, activityBtnPvUvHour_.getUv());
155 hourPv = activityBtnPvUvHour_.getPv();
156 }
157 155
158 if (activityBtnPvUvHour_.getUv() >= hourUv) { 156 if (activityBtnPvUvHour_.getPv() != hourPv || activityBtnPvUvHour_.getUv() != hourUv) {
159 hourUv = activityBtnPvUvHour_.getUv(); 157 if (activityBtnPvUvHour_.getPv() >= hourPv) {
160 } 158 hourPv = activityBtnPvUvHour_.getPv();
159 }
161 160
162 activityBtnPvUvHour_.setPv(hourPv); 161 if (activityBtnPvUvHour_.getUv() >= hourUv) {
163 activityBtnPvUvHour_.setUv(hourUv); 162 hourUv = activityBtnPvUvHour_.getUv();
164 activityBtnPvUvHour_.setUpdateTime(TimestampUtil.now()); 163 }
165 this.activityBtnPvUvHourService.update(activityBtnPvUvHour_); 164
165 activityBtnPvUvHour_.setPv(hourPv);
166 activityBtnPvUvHour_.setUv(hourUv);
167 activityBtnPvUvHour_.setUpdateTime(TimestampUtil.now());
168 this.activityBtnPvUvHourService.update(activityBtnPvUvHour_);
169 }
166 170
167 } 171 }
168 172
...@@ -191,21 +195,23 @@ public class ActivityBtnClickPvUcCalculateTask { ...@@ -191,21 +195,23 @@ public class ActivityBtnClickPvUcCalculateTask {
191 195
192 Integer dayPv = this.getDayPV(subjectCode, paramValueId); 196 Integer dayPv = this.getDayPV(subjectCode, paramValueId);
193 Integer dayUv = this.getDayUV(subjectCode, paramValueId); 197 Integer dayUv = this.getDayUV(subjectCode, paramValueId);
194 log.info("dayPv ==>> {}", dayPv);
195 log.info("dayUv ==>> {}", dayUv);
196 198
197 if (pvUvDay1.getPv() >= dayPv) { 199 log.info("按钮每日点击更新 redisPV: {}, dbPV: {}, redisUV: {}, dbUV: {}", dayPv, pvUvDay1.getPv(), dayUv, pvUvDay1.getUv());
198 dayPv = pvUvDay1.getPv();
199 }
200 200
201 if (pvUvDay1.getUv() >= dayUv) { 201 if (pvUvDay1.getPv() != dayPv || pvUvDay1.getUv() != dayUv) {
202 dayUv = pvUvDay1.getUv(); 202 if (pvUvDay1.getPv() >= dayPv) {
203 } 203 dayPv = pvUvDay1.getPv();
204 }
204 205
205 pvUvDay1.setPv(dayPv); 206 if (pvUvDay1.getUv() >= dayUv) {
206 pvUvDay1.setUv(dayUv); 207 dayUv = pvUvDay1.getUv();
207 pvUvDay1.setUpdateTime(TimestampUtil.now()); 208 }
208 this.activityBtnPvUvDayService.update(pvUvDay1); 209
210 pvUvDay1.setPv(dayPv);
211 pvUvDay1.setUv(dayUv);
212 pvUvDay1.setUpdateTime(TimestampUtil.now());
213 this.activityBtnPvUvDayService.update(pvUvDay1);
214 }
209 } 215 }
210 216
211 // all 217 // all
...@@ -233,21 +239,23 @@ public class ActivityBtnClickPvUcCalculateTask { ...@@ -233,21 +239,23 @@ public class ActivityBtnClickPvUcCalculateTask {
233 239
234 Integer allPV = this.getAllPV(subjectCode, paramValueId); 240 Integer allPV = this.getAllPV(subjectCode, paramValueId);
235 Integer allUv = this.getAllUV(subjectCode, paramValueId); 241 Integer allUv = this.getAllUV(subjectCode, paramValueId);
236 log.info("allPV ==>> {}", allPV);
237 log.info("allUv ==>> {}", allUv);
238 242
239 if (pvUv1.getPv() >= allPV) { 243 log.info("按钮总点击更新 redisPV: {}, dbPV: {}, redisUV: {}, dbUV: {}", allPV, pvUv1.getPv(), allUv, pvUv1.getUv());
240 allPV = pvUv1.getPv();
241 }
242 244
243 if (pvUv1.getUv() >= allUv) { 245 if (pvUv1.getPv() != allPV || pvUv1.getUv() != allUv) {
244 allUv = pvUv1.getUv(); 246 if (pvUv1.getPv() >= allPV) {
245 } 247 allPV = pvUv1.getPv();
248 }
246 249
247 pvUv1.setPv(allPV); 250 if (pvUv1.getUv() >= allUv) {
248 pvUv1.setUv(allUv); 251 allUv = pvUv1.getUv();
249 pvUv1.setUpdateTime(TimestampUtil.now()); 252 }
250 this.activityBtnPvUvService.update(pvUv1); 253
254 pvUv1.setPv(allPV);
255 pvUv1.setUv(allUv);
256 pvUv1.setUpdateTime(TimestampUtil.now());
257 this.activityBtnPvUvService.update(pvUv1);
258 }
251 } 259 }
252 260
253 } 261 }
......
...@@ -88,21 +88,24 @@ public class PvUvCalculateTask { ...@@ -88,21 +88,24 @@ public class PvUvCalculateTask {
88 88
89 Integer hourPv = this.getHourPV(code); 89 Integer hourPv = this.getHourPV(code);
90 Integer hourUv = this.getHourUV(code); 90 Integer hourUv = this.getHourUV(code);
91 log.info("hourPv ==>> {}", hourPv);
92 log.info("hourUv ==>> {}", hourUv);
93 91
94 if (pvUvHour1.getPv() >= hourPv) { 92 log.info("访问每小时次数更新 redisPV: {}, dbPV: {}, redisUV: {}, dbUV: {}", hourPv, pvUvHour1.getPv(), hourUv, pvUvHour1.getUv());
95 hourPv = pvUvHour1.getPv();
96 }
97 93
98 if (pvUvHour1.getUv() >= hourUv) { 94 if (pvUvHour1.getPv() != hourPv || pvUvHour1.getUv() != hourUv) {
99 hourUv = pvUvHour1.getUv(); 95
100 } 96 if (pvUvHour1.getPv() >= hourPv) {
97 hourPv = pvUvHour1.getPv();
98 }
101 99
102 pvUvHour1.setPv(hourPv); 100 if (pvUvHour1.getUv() >= hourUv) {
103 pvUvHour1.setUv(hourUv); 101 hourUv = pvUvHour1.getUv();
104 pvUvHour1.setUpdateTime(TimestampUtil.now()); 102 }
105 this.pvUvHourService.updateByMarketingActivityCodeAndDayAndHour(pvUvHour1); 103
104 pvUvHour1.setPv(hourPv);
105 pvUvHour1.setUv(hourUv);
106 pvUvHour1.setUpdateTime(TimestampUtil.now());
107 this.pvUvHourService.updateByMarketingActivityCodeAndDayAndHour(pvUvHour1);
108 }
106 109
107 } 110 }
108 111
...@@ -131,18 +134,24 @@ public class PvUvCalculateTask { ...@@ -131,18 +134,24 @@ public class PvUvCalculateTask {
131 log.info("dayPv ==>> {}", dayPv); 134 log.info("dayPv ==>> {}", dayPv);
132 log.info("dayUv ==>> {}", dayUv); 135 log.info("dayUv ==>> {}", dayUv);
133 136
134 if (pvUvDay1.getPv() >= dayPv) { 137 log.info("访问每日次数更新 redisPV: {}, dbPV: {}, redisUV: {}, dbUV: {}", dayPv, pvUvDay1.getPv(), dayUv, pvUvDay1.getUv());
135 dayPv = pvUvDay1.getPv(); 138
136 } 139 if (pvUvDay1.getPv() != dayPv || pvUvDay1.getUv() != dayUv) {
137 140
138 if (pvUvDay1.getUv() >= dayUv) { 141 if (pvUvDay1.getPv() >= dayPv) {
139 dayUv = pvUvDay1.getUv(); 142 dayPv = pvUvDay1.getPv();
143 }
144
145 if (pvUvDay1.getUv() >= dayUv) {
146 dayUv = pvUvDay1.getUv();
147 }
148
149 pvUvDay1.setPv(dayPv);
150 pvUvDay1.setUv(dayUv);
151 pvUvDay1.setUpdateTime(TimestampUtil.now());
152 this.pvUvDayService.update(pvUvDay1);
140 } 153 }
141 154
142 pvUvDay1.setPv(dayPv);
143 pvUvDay1.setUv(dayUv);
144 pvUvDay1.setUpdateTime(TimestampUtil.now());
145 this.pvUvDayService.update(pvUvDay1);
146 } 155 }
147 156
148 // all 157 // all
...@@ -166,21 +175,25 @@ public class PvUvCalculateTask { ...@@ -166,21 +175,25 @@ public class PvUvCalculateTask {
166 175
167 Integer allPV = this.getAllPV(code); 176 Integer allPV = this.getAllPV(code);
168 Integer allUv = this.getAllUV(code); 177 Integer allUv = this.getAllUV(code);
169 log.info("allPV ==>> {}", allPV);
170 log.info("allUv ==>> {}", allUv);
171 178
172 if (pvUv1.getPv() >= allPV) { 179 log.info("访问总次数更新 redisPV: {}, dbPV: {}, redisUV: {}, dbUV: {}", allPV, pvUv1.getPv(), allUv, pvUv1.getUv());
173 allPV = pvUv1.getPv(); 180
174 } 181 if (pvUv1.getPv() != allPV || pvUv1.getUv() != allUv) {
182
183 if (pvUv1.getPv() >= allPV) {
184 allPV = pvUv1.getPv();
185 }
186
187 if (pvUv1.getUv() >= allUv) {
188 allUv = pvUv1.getUv();
189 }
175 190
176 if (pvUv1.getUv() >= allUv) { 191 pvUv1.setPv(allPV);
177 allUv = pvUv1.getUv(); 192 pvUv1.setUv(allUv);
193 pvUv1.setUpdateTime(TimestampUtil.now());
194 this.pvUvService.update(pvUv1);
178 } 195 }
179 196
180 pvUv1.setPv(allPV);
181 pvUv1.setUv(allUv);
182 pvUv1.setUpdateTime(TimestampUtil.now());
183 this.pvUvService.update(pvUv1);
184 } 197 }
185 } 198 }
186 199
......