|
|
@@ -3,6 +3,7 @@ package flink.zanxiangnet.ad.monitoring.process;
|
|
|
import flink.zanxiangnet.ad.monitoring.pojo.entity.AdStatOfHourDWD;
|
|
|
import flink.zanxiangnet.ad.monitoring.pojo.entity.CostHourDM;
|
|
|
import flink.zanxiangnet.ad.monitoring.util.DateUtil;
|
|
|
+import flink.zanxiangnet.ad.monitoring.util.NumberUtil;
|
|
|
import org.apache.flink.api.common.state.MapState;
|
|
|
import org.apache.flink.api.common.state.MapStateDescriptor;
|
|
|
import org.apache.flink.api.common.typeinfo.Types;
|
|
|
@@ -186,7 +187,7 @@ public class CostHourProcess extends KeyedProcessFunction<Long, AdStatOfHourDWD,
|
|
|
//小时-总平均转化率
|
|
|
costHourDM.setConversionsRateHour(hourDWD.getConversionsRateHour().doubleValue());
|
|
|
//总首日下单roi
|
|
|
- Double tmpFirstDayOrderRoiTotal = hourDWD.getCostTotal() == 0 ? 0.0 : (double) hourDWD.getFirstDayOrderAmountTotal() / hourDWD.getCostTotal();
|
|
|
+ Double tmpFirstDayOrderRoiTotal = NumberUtil.divideForAd(hourDWD.getFirstDayOrderAmountTotal() , hourDWD.getCostTotal()).doubleValue();
|
|
|
costHourDM.setFirstDayOrderRoiTotal(tmpFirstDayOrderRoiTotal);
|
|
|
//天-总首日下单roi
|
|
|
costHourDM.setFirstDayOrderRoiDay(0);
|
