修改ecpm类型

yt-common/src/main/java/com/ytpm/advertise/view/ComprehensiveCommonView.java

@@ -15,7 +15,7 @@ public class ComprehensiveCommonView {
     /** 点击数 */
     private String click;
     /** ECPM */
-    private String ecpm;
+    private BigDecimal ecpm;
     /** 收益 */
     private BigDecimal revenue;
     /** 三方广告平台的展示数 */

yt-common/src/main/java/com/ytpm/app/model/YtDyzAdRecord.java

@@ -43,7 +43,7 @@ public class YtDyzAdRecord extends ComprehensiveCommonView {
     @ApiModelProperty("SDK返回json")
     private String resultJson;
     @ApiModelProperty("Taku预估eCPM 对应adsource_price")
-    private String ecpm;
+    private BigDecimal ecpm;
     @ApiModelProperty("广告源竞价中排序优先级")
     private int adSourceIndex;
     @ApiModelProperty("广告源类型")

yt-common/src/main/java/com/ytpm/app/param/DyzAdRecordParam.java

@@ -34,7 +34,7 @@ public class DyzAdRecordParam {
     @ApiModelProperty("当天观看广告次数")
     private int adCount;
     @ApiModelProperty("Taku预估eCPM 对应adsource_price")
-    private String ecpm;
+    private BigDecimal ecpm;
     @ApiModelProperty("广告源竞价中排序优先级")
     private int adSourceIndex;
     @ApiModelProperty("广告源类型")

yt-common/src/main/java/com/ytpm/app/view/YtUserEcpmListView.java

@@ -29,7 +29,7 @@ public class YtUserEcpmListView extends YtDyzAdRecord {
     private String click;
     /** ECPM */
     @ApiModelProperty("ECPM")
-    private String ecpm;
+    private BigDecimal ecpm;
     /** 收益 */
     @ApiModelProperty("收益")
     private BigDecimal revenue;

yt-risk/risk-manage/src/main/java/com/ytpm/service/impl/RiskServiceImpl.java

@@ -515,7 +515,7 @@ public class RiskServiceImpl extends ReflectUtil implements RiskService {
             //判断存在ecpm小于预设值 达到预设条数时触发风控
             int haveCount = Integer.parseInt(limitMap.get("haveCount"));
             long count = records.stream().filter(
-                    s -> (Integer.parseInt(s.getEcpm()) * 10) > haveCount).count();
+                    s -> (s.getEcpm().compareTo(BigDecimal.valueOf(haveCount))) > 0).count();
             int exact = Math.toIntExact(count);
             if(count>exact){
                 riskLockUser(userId, "742","激励视频ecpm值控制","用户已被风控，风控编码：742");