Skip to content

张云鹏 / moss-statistic

Go to a project
Toggle navigation
Toggle navigation pinning
Commit 2a47b6b5 2a47b6b5f21cfde481bfef408726c79c5a1e4fc4 by xianghan
Options

init1

1 parent 7fbec8e7
Inline Side-by-side
Showing 3 changed files with 110 additions and 51 deletions
......@@ -194,13 +194,19 @@ public class ActivityBtnClickPvUcCalculateTask {
log.info("hourPv ==>> {}", hourPv);
log.info("hourUv ==>> {}", hourUv);
if (hourPv != 0 && hourUv != 0) {
activityBtnPvUvHour_.setPv(hourPv);
activityBtnPvUvHour_.setUv(hourUv);
activityBtnPvUvHour_.setUpdateTime(TimestampUtil.now());
this.activityBtnPvUvHourService.update(activityBtnPvUvHour_);
if (activityBtnPvUvHour_.getPv() >= hourPv) {
hourPv = activityBtnPvUvHour_.getPv();
}
if (activityBtnPvUvHour_.getUv() >= hourUv) {
hourUv = activityBtnPvUvHour_.getUv();
}
activityBtnPvUvHour_.setPv(hourPv);
activityBtnPvUvHour_.setUv(hourUv);
activityBtnPvUvHour_.setUpdateTime(TimestampUtil.now());
this.activityBtnPvUvHourService.update(activityBtnPvUvHour_);
}
// day pv、uv值
......@@ -230,13 +236,19 @@ public class ActivityBtnClickPvUcCalculateTask {
Integer dayUv = this.getDayUV(marktingActivityCode, activityCode, paramValueId);
log.info("dayPv ==>> {}", dayPv);
log.info("dayUv ==>> {}", dayUv);
if (dayPv != 0 && dayUv != 0) {
pvUvDay1.setPv(dayPv);
pvUvDay1.setUv(dayUv);
pvUvDay1.setUpdateTime(TimestampUtil.now());
this.activityBtnPvUvDayService.update(pvUvDay1);
if (pvUvDay1.getPv() >= dayPv) {
dayPv = pvUvDay1.getPv();
}
if (pvUvDay1.getUv() >= dayUv) {
dayUv = pvUvDay1.getUv();
}
pvUvDay1.setPv(dayPv);
pvUvDay1.setUv(dayUv);
pvUvDay1.setUpdateTime(TimestampUtil.now());
this.activityBtnPvUvDayService.update(pvUvDay1);
}
// all
......@@ -267,12 +279,18 @@ public class ActivityBtnClickPvUcCalculateTask {
log.info("allPV ==>> {}", allPV);
log.info("allUv ==>> {}", allUv);
if (allPV != 0 && allUv != 0) {
pvUv1.setPv(allPV);
pvUv1.setUv(allUv);
pvUv1.setUpdateTime(TimestampUtil.now());
this.activityBtnPvUvService.update(pvUv1);
if (pvUv1.getPv() >= allPV) {
allPV = pvUv1.getPv();
}
if (pvUv1.getUv() >= allUv) {
allUv = pvUv1.getUv();
}
pvUv1.setPv(allPV);
pvUv1.setUv(allUv);
pvUv1.setUpdateTime(TimestampUtil.now());
this.activityBtnPvUvService.update(pvUv1);
}
}
......
......@@ -110,13 +110,20 @@ public class PvUvCalculateTask {
Integer hourUv = this.getHourUV(code);
log.info("hourPv ==>> {}", hourPv);
log.info("hourUv ==>> {}", hourUv);
if (hourPv != 0 && hourUv != 0) {
pvUvHour1.setPv(hourPv);
pvUvHour1.setUv(hourUv);
pvUvHour1.setUpdateTime(TimestampUtil.now());
this.pvUvHourService.updateByMarketingActivityCodeAndDayAndHour(pvUvHour1);
if (pvUvHour1.getPv() >= hourPv) {
hourPv = pvUvHour1.getPv();
}
if (pvUvHour1.getUv() >= hourUv) {
hourUv = pvUvHour1.getUv();
}
pvUvHour1.setPv(hourPv);
pvUvHour1.setUv(hourUv);
pvUvHour1.setUpdateTime(TimestampUtil.now());
this.pvUvHourService.updateByMarketingActivityCodeAndDayAndHour(pvUvHour1);
}
// day pv、uv值
......@@ -143,12 +150,18 @@ public class PvUvCalculateTask {
log.info("dayPv ==>> {}", dayPv);
log.info("dayUv ==>> {}", dayUv);
if (dayPv != 0 && dayUv != 0) {
pvUvDay1.setPv(dayPv);
pvUvDay1.setUv(dayUv);
pvUvDay1.setUpdateTime(TimestampUtil.now());
this.pvUvDayService.update(pvUvDay1);
if (pvUvDay1.getPv() >= dayPv) {
dayPv = pvUvDay1.getPv();
}
if (pvUvDay1.getUv() >= dayUv) {
dayUv = pvUvDay1.getUv();
}
pvUvDay1.setPv(dayPv);
pvUvDay1.setUv(dayUv);
pvUvDay1.setUpdateTime(TimestampUtil.now());
this.pvUvDayService.update(pvUvDay1);
}
// all
......@@ -174,12 +187,18 @@ public class PvUvCalculateTask {
log.info("allPV ==>> {}", allPV);
log.info("allUv ==>> {}", allUv);
if (allPV != 0 && allUv != 0) {
pvUv1.setPv(allPV);
pvUv1.setUv(allUv);
pvUv1.setUpdateTime(TimestampUtil.now());
this.pvUvService.update(pvUv1);
if (pvUv1.getPv() >= allPV) {
allPV = pvUvDay1.getPv();
}
if (pvUv1.getUv() >= allUv) {
allUv = pvUvDay1.getUv();
}
pvUv1.setPv(allPV);
pvUv1.setUv(allUv);
pvUv1.setUpdateTime(TimestampUtil.now());
this.pvUvService.update(pvUv1);
}
}
......
......@@ -288,15 +288,23 @@ public class SubscribeCalculateTask {
Long hourBtnClickUV = this.getHourBtnClickUV(code, packageId);
log.info("subscribe ==>> hourBtnClickUV ==>> {}", hourBtnClickUV);
if (hourBtnClickPV != 0 && hourBtnClickUV != 0) {
subscribePvUvHour.setBtnClickUv(hourBtnClickUV);
subscribePvUvHour.setBtnClickPv(hourBtnClickPV);
subscribePvUvHour.setSubscribeNum(hourSubscribeNum);
subscribePvUvHour.setUpdateTime(TimestampUtil.now());
log.info("subscribe ==>> subscribePvUvHour ==>> {}", subscribePvUvHour);
this.subscribePvUvHourService.update(subscribePvUvHour);
if (subscribePvUvHour.getBtnClickPv() >= hourBtnClickPV) {
hourBtnClickPV = subscribePvUvHour.getBtnClickPv();
}
if (subscribePvUvHour.getBtnClickUv() >= hourBtnClickUV) {
hourBtnClickUV = subscribePvUvHour.getBtnClickUv();
}
subscribePvUvHour.setBtnClickUv(hourBtnClickUV);
subscribePvUvHour.setBtnClickPv(hourBtnClickPV);
subscribePvUvHour.setSubscribeNum(hourSubscribeNum);
subscribePvUvHour.setUpdateTime(TimestampUtil.now());
log.info("subscribe ==>> subscribePvUvHour ==>> {}", subscribePvUvHour);
this.subscribePvUvHourService.update(subscribePvUvHour);
}
// 天订购转换值
......@@ -340,15 +348,22 @@ public class SubscribeCalculateTask {
Long dayBtnClickUV = this.getDayBtnClickUV(code, packageId);
log.info("subscribe ==>> dayBtnClickUV ==>> {}", dayBtnClickUV);
if (dayBtnClickUV != 0 && dayBtnClickPV != 0) {
subscribePvUvDay.setSubscribeNum(daySubscribeNum);
subscribePvUvDay.setBtnClickUv(dayBtnClickUV);
subscribePvUvDay.setBtnClickPv(dayBtnClickPV);
subscribePvUvDay.setUpdateTime(TimestampUtil.now());
log.info("subscribe ==>> subscribePvUvDay ==>> {}", subscribePvUvDay);
this.subscribePvUvDayService.update(subscribePvUvDay);
if (subscribePvUvDay.getBtnClickPv() >= dayBtnClickPV) {
dayBtnClickPV = subscribePvUvDay.getBtnClickPv();
}
if (subscribePvUvDay.getBtnClickUv() >= dayBtnClickUV) {
dayBtnClickUV = subscribePvUvDay.getBtnClickUv();
}
subscribePvUvDay.setSubscribeNum(daySubscribeNum);
subscribePvUvDay.setBtnClickUv(dayBtnClickUV);
subscribePvUvDay.setBtnClickPv(dayBtnClickPV);
subscribePvUvDay.setUpdateTime(TimestampUtil.now());
log.info("subscribe ==>> subscribePvUvDay ==>> {}", subscribePvUvDay);
this.subscribePvUvDayService.update(subscribePvUvDay);
}
// 总订购转换值
......@@ -389,15 +404,22 @@ public class SubscribeCalculateTask {
Long allBtnClickUV = this.getAllBtnClickUV(code, packageId);
log.info("subscribe ==>> allBtnClickUV ==>> {}", allBtnClickUV);
if (allBtnClickUV != 0 && allBtnClickPV != 0) {
subscribePvUv.setBtnClickUv(allBtnClickUV);
subscribePvUv.setSubscribeNum(allSubscribeNum);
subscribePvUv.setBtnClickPv(allBtnClickPV);
subscribePvUv.setUpdateTime(TimestampUtil.now());
log.info("subscribe ==>> subscribePvUv ==>> {}", subscribePvUv);
this.subscribePvUvService.update(subscribePvUv);
if (subscribePvUv.getBtnClickPv() >= allBtnClickPV) {
allBtnClickPV = subscribePvUv.getBtnClickPv();
}
if (subscribePvUv.getBtnClickUv() >= allBtnClickUV) {
allBtnClickUV = subscribePvUv.getBtnClickUv();
}
subscribePvUv.setBtnClickUv(allBtnClickUV);
subscribePvUv.setSubscribeNum(allSubscribeNum);
subscribePvUv.setBtnClickPv(allBtnClickPV);
subscribePvUv.setUpdateTime(TimestampUtil.now());
log.info("subscribe ==>> subscribePvUv ==>> {}", subscribePvUv);
this.subscribePvUvService.update(subscribePvUv);
}
}
......