Skip to content

M
marketing
Commit 16e6136a authored by 宋新宇's avatar 宋新宇
Browse files
Options

Merge branch '7-短剧app关键行为优化' into 'dev' 

Resolve "短剧app关键行为优化"

See merge request !37
parents 52a2ad0e 870c5e6d
Hide whitespace changes
Inline Side-by-side
Showing with 528 additions and 371 deletions
src/main/java/com/lwby/marketing/att/BehavoirType.java 0 → 100644
View file @ 16e6136a
package com.lwby.marketing.att;
import com.lwby.marketing.vo.AppChannelVO;
import java.util.Objects;
import java.util.function.Function;
public enum BehavoirType {
MOTIVATEMODELCOUNT("motivateModelCount",(a) -> Objects.nonNull(a.getMotivationCount()) ? a.getMotivationCount().intValue() : null),
ECPMAVGMODELCOUNT("ecpmAvgModelCount", (a) -> Objects.nonNull(a.getEcpmAvgCount()) ? a.getEcpmAvgCount().intValue() : null),
PECPMMODELCOUNT("pecpmModelCount",(a) -> Objects.nonNull(a.getEcpmPerCount()) ? a.getEcpmPerCount().intValue() : null),
ARPUMODELCOUNT("arpuModelCount",(a) -> Objects.nonNull(a.getArpuCount()) ? a.getArpuCount().doubleValue() : null);
private String value;
private Function<AppChannelVO,Number> fun;
BehavoirType(String value, Function<AppChannelVO,Number> fun) {
this.value = value;
this.fun = fun;
}
public String getValue() {
return this.value;
}
public Number getBehavoirType(AppChannelVO appChannel){
return fun.apply(appChannel);
}
}
\ No newline at end of file
src/main/java/com/lwby/marketing/att/bystory/CallBackType.java → src/main/java/com/lwby/marketing/att/CallBackType.java
View file @ 16e6136a
package com.lwby.marketing.att.bystory;
import com.lwby.marketing.att.AttributionStatus;
package com.lwby.marketing.att;
/**
* @author songxinyu
......
src/main/java/com/lwby/marketing/att/bystory/DyStoryUniversalProcess.java
View file @ 16e6136a
......@@ -4,15 +4,19 @@ import com.alibaba.fastjson.JSONObject;
import com.alicp.jetcache.anno.CacheRefresh;
import com.alicp.jetcache.anno.CacheType;
import com.alicp.jetcache.anno.Cached;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.UniversalProcess;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.novel.AttributionType;
import com.lwby.marketing.vo.AttributeRule;
import com.lwby.marketing.vo.DeliveryDeviceInfo;
import com.lwby.marketing.vo.StoryNovelAction;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.kafka.support.SendResult;
import org.springframework.stereotype.Component;
import org.springframework.util.concurrent.ListenableFuture;
......@@ -65,7 +69,7 @@ public class DyStoryUniversalProcess extends UniversalProcess {
}
public String getFirstCheckerKey(StoryNovelAction action) {
return Objects.equals(action.getType(),CallBackType.active.getType())
return Objects.equals(action.getType(), CallBackType.active.getType())
? String.format("fc_%d_%d_%s_%s", action.getUserId(), action.getPlatformId(),action.getMediaName(),action.getCurrentDateStr())
: String.format("fc_%d_%d_%s", action.getUserId(), action.getPlatformId(),action.getMediaName());
}
......@@ -73,11 +77,13 @@ public class DyStoryUniversalProcess extends UniversalProcess {
/******************************************** JDBC *************************************************************/
@Cached(name="attribute_rule_store_novel", cacheType = CacheType.LOCAL)
@Cached(name="attribute_rule_story_novel", cacheType = CacheType.LOCAL)
@CacheRefresh(refresh = 300)
public String getAttributeRuleByPlatformIdAndChannelId(int platformId,Long channelId) {
public AttributeRule getAttributeRuleByPlatformIdAndChannelId(int platformId, Long channelId) {
try {
return lwbyJdbcTemplate.queryForObject(String.format("select shave_make_call from attribute_rule where channel_id=%d and platform_id=%d",channelId,platformId),String.class);
RowMapper<AttributeRule> rowMapper = BeanPropertyRowMapper.newInstance(AttributeRule.class);
return lwbyJdbcTemplate.queryForObject(String.format("select shave_make_call,callback_type from attribute_rule where channel_id=%d and platform_id=%d",channelId,platformId),rowMapper);
} catch (EmptyResultDataAccessException e) {
return null;
}
......
src/main/java/com/lwby/marketing/att/bystory/handle/ParameterSetupStoryNovelFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.bystory.handle;
import com.alibaba.fastjson.JSONObject;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.notify.Media;
......@@ -34,7 +33,7 @@ public class ParameterSetupStoryNovelFlow extends NodeFlow<StoryNovelAction> {
DeliveryDeviceInfo deliveryDeviceInfo = null;
//String s = "{\"creativeId\":\"112331\",\"creativeType\":\"3\",\"adid\":\"12321\","
// + "\"clickId\":\"12312143232\",\"channel\":\"216011231\",\"bookId\":\"4322111\","
// + "\"clickId\":\"12312143232\",\"channel\":\"21221021\",\"bookId\":\"4322111\","
// + "\"media\":\"jrtt\",\"clickTime\":123123123,\"code\":\"12ede3e231\"}";;
//StoryLogin storyLogin = JSONObject.parseObject(s,StoryLogin.class);
//匹配OpenId
......@@ -61,6 +60,7 @@ public class ParameterSetupStoryNovelFlow extends NodeFlow<StoryNovelAction> {
deliveryDeviceInfo.setDj_channel(storyLogin.getChannel());
deliveryDeviceInfo.setPromotion_id(storyLogin.getAdid());
deliveryDeviceInfo.setBook_id(storyLogin.getBookId());
deliveryDeviceInfo.setMedia(storyLogin.getMedia());
action.setDeliveryDeviceInfo(deliveryDeviceInfo);
action.setChannelId(NumberUtils.parseLong(storyLogin.getChannel()));
action.setPlanId(NumberUtils.parseLong((storyLogin.getAdid())));
......
src/main/java/com/lwby/marketing/att/bystory/handle/PaySpduFlow.java
View file @ 16e6136a
......@@ -2,9 +2,11 @@ package com.lwby.marketing.att.bystory.handle;
import com.alibaba.fastjson.JSON;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.novel.AttributionType;
import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
import com.lwby.marketing.flow.NodeSwitchFlow;
import com.lwby.marketing.vo.AttributeRule;
import com.lwby.marketing.vo.StoryNovelAction;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
......@@ -16,6 +18,7 @@ import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.ThreadLocalRandom;
/**
......@@ -40,8 +43,8 @@ public class PaySpduFlow extends NodeSwitchFlow<StoryNovelAction> {
public void process(StoryNovelAction action) {
int platformId = action.getPlatformId();
Long channelId = action.getChannelId();
String shaveMakeCall = up.getAttributeRuleByPlatformIdAndChannelId(platformId,channelId);
if (StringUtils.isEmpty(shaveMakeCall)) {
AttributeRule attributeRule = up.getAttributeRuleByPlatformIdAndChannelId(platformId,channelId);
if (Objects.isNull(attributeRule) || StringUtils.isEmpty(attributeRule.getShaveMakeCall())) {
//直接回传,走回传流
DYSTORY_SYS_LOG.info("PaySpduFlow process0 attribute is null,platformId={},channelId={}",action.getPlatformId(),action.getChannelId());
return;
......@@ -56,7 +59,9 @@ public class PaySpduFlow extends NodeSwitchFlow<StoryNovelAction> {
* "4" : 100
* }
*/
//在这里设置回传类型
action.setCallbackTypeStory(attributeRule.getCallbackType());
String shaveMakeCall = attributeRule.getShaveMakeCall();
Map<String, Integer> map = JSON.parseObject(shaveMakeCall, Map.class);
Integer sprDedu = 0;
......@@ -75,6 +80,14 @@ public class PaySpduFlow extends NodeSwitchFlow<StoryNovelAction> {
return;
}
if (sprDedu == 0) {
DYSTORY_SYS_LOG.info("PaySpduFlow process0 attribute.sprDeduChannel 0,platformId={},channelId={}",action.getPlatformId(),action.getChannelId());
up.notifyResult(action,Objects.equals(action.getCallbackTypeStory(),3)? CallBackType.behavior.getTopic():CallBackType.pay.getTopic(), AttributionStatus.NORMAL_DEDUCTION_CALLBACK);
up.set(up.getFirstCheckerKey(action),60 * 60 * 24,"1");
action.stop(true);
return;
}
//总数
String channelTotal = up.getTotalCountKey(AttributionType.CHANNEL, action.getPlatformId(), action.getChannelId(),goodId, sprDedu, action.getCurrentDateStr());
//回传
......@@ -92,7 +105,7 @@ public class PaySpduFlow extends NodeSwitchFlow<StoryNovelAction> {
"PaySpduFlow.process0.deduction doing dynamic, platformId = {}, channel = {}, sprDedu = {}, goodId = {}, channelTotalCount = {}, channelCallbackCount = {}, v = {}",
platformId, channelId, sprDedu, goodId, channelTotalCount, channelCallbackCount, 1);
} else {
up.notifyResult(action,"ocpc_pay", AttributionStatus.NORMAL_DEDUCTION_CALLBACK);
up.notifyResult(action,Objects.equals(action.getCallbackTypeStory(),3)? CallBackType.behavior.getTopic():CallBackType.pay.getTopic(), AttributionStatus.NORMAL_DEDUCTION_CALLBACK);
up.set(up.getFirstCheckerKey(action),60 * 60 * 24,"1");
DYSTORY_SYS_LOG.info(
"PaySpduFlow.process0.deduction doing dynamic, platformId = {}, channel = {}, sprDedu = {}, goodId = {}, channelTotalCount = {}, channelCallbackCount = {}, v = {}",
......
src/main/java/com/lwby/marketing/att/bystory/handle/StoreDyStoryAttributionFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.bystory.handle;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.vo.StoryNovelAction;
......
src/main/java/com/lwby/marketing/att/bystory/handle/UploadCallFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.bystory.handle;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.vo.StoryNovelAction;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Objects;
/**
* @author songxinyu
......@@ -24,7 +25,12 @@ public class UploadCallFlow extends NodeFlow<StoryNovelAction> {
boolean success = action.getMedia().notify(action);
if (success) {
up.notifyResult(action, type.getTopic(),type.getStatus());
if (type.getType().equals(CallBackType.active.getType())) {
up.notifyResult(action, type.getTopic(),type.getStatus());
} else {
up.notifyResult(action, Objects.equals(action.getCallbackTypeStory(),3) ? CallBackType.behavior.getTopic() : CallBackType.pay.getTopic(),
Objects.equals(action.getCallbackTypeStory(),3) ? CallBackType.behavior.getStatus() : CallBackType.pay.getStatus());
}
up.set(up.getFirstCheckerKey(action),60 * 60 * 24,"1");
}
}
......
src/main/java/com/lwby/marketing/att/dyvideo/DyVideoBehavoirConsumer.java
View file @ 16e6136a
......@@ -66,6 +66,7 @@ public class DyVideoBehavoirConsumer {
event.getUserUploadEvent());
executorByDyVideoBehavoir.execute(action);
DYVIDEO_SYS_LOG.info("media.behavoir.dyVideo.end,topic={}, bookStoreEvent={}", data.topic(), JSON.toJSONString(event));
} catch (Throwable e) {
DYVIDEO_ERROR_LOG.error("dy.video.behavoir.onMessage failed, data={}, costTime={} ms", data.value(),
System.currentTimeMillis() - begin, e);
......
src/main/java/com/lwby/marketing/att/dyvideo/DyVideoUniversalProcess.java
View file @ 16e6136a
package com.lwby.marketing.att.dyvideo;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alicp.jetcache.anno.CacheRefresh;
......@@ -8,15 +7,18 @@ import com.alicp.jetcache.anno.CacheType;
import com.alicp.jetcache.anno.Cached;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.UniversalProcess;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.novel.AttributionType;
import com.lwby.marketing.po.ThirdAccountDy;
import com.lwby.marketing.util.CacheKeyUtils;
import com.lwby.marketing.util.HttpUtil;
import com.lwby.marketing.vo.AppChannelVO;
import com.lwby.marketing.vo.DeliveryDeviceInfo;
import com.lwby.marketing.vo.StoryNovelAction;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.env.Environment;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
......@@ -26,9 +28,8 @@ import org.springframework.stereotype.Component;
import org.springframework.util.concurrent.ListenableFuture;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.TimeUnit;
@Slf4j
......@@ -42,6 +43,14 @@ public class DyVideoUniversalProcess extends UniversalProcess {
@Resource
private RedisTemplate<String,String> oldMarketRedisTemplate;
SimpleDateFormat dfh = new SimpleDateFormat("yyyy-MM-dd");//设置日期格式
private static final String url = "https://open.douyin.com/api/traffic/v1/rt_ecpm/query/";
private static final String tokenDyDevUrl = "https://open-sandbox.douyin.com/oauth/client_token/";
private static final String tokenDyProdUrl = "https://open.douyin.com/oauth/client_token/";
/**
* 通知处理结果
*/
......@@ -64,7 +73,7 @@ public class DyVideoUniversalProcess extends UniversalProcess {
ddi.setDevice_id(String.valueOf(action.getUserId()));
ddi.setActive_time(System.currentTimeMillis());
ddi.setChannel(String.valueOf(action.getChannelId()));
ddi.setUserId(action.getUserId());
ddi.setOpenId(action.getOpenId());
String jsonString = JSONObject.toJSONString(ddi);
ListenableFuture<SendResult<String, String>> active_result = novelKafkaTemplate.send(topic, jsonString);
......@@ -87,10 +96,18 @@ public class DyVideoUniversalProcess extends UniversalProcess {
oldMarketRedisTemplate.opsForValue().set(key,value,expires, TimeUnit.SECONDS);
}
public boolean existsOld(String key) {
return Boolean.TRUE.equals(oldMarketRedisTemplate.hasKey(key));
}
public void delToken(String key) {
oldMarketRedisTemplate.delete(key);
}
public void hsetNew(String key, String field, int expire, String value) {
oldMarketRedisTemplate.opsForHash().put(key,field,value);
oldMarketRedisTemplate.expire(key,expire,TimeUnit.SECONDS);
}
public String getTotalCountKey(AttributionType attributionType, int platformId, Long channelOrPlanId ,int sprDedu, String dateStr) {
......@@ -161,4 +178,86 @@ public class DyVideoUniversalProcess extends UniversalProcess {
return null;
}
}
public Map<String,Integer> getResultCountList(Date day, String openid, String accessToken, Integer tvcCount, Integer motivateCount, Integer pecpmCount, Integer pecpmModelCount, Long userId, String tokenDy, List<String> dyMarketPlatformAppIdList,
Environment env) {
int pageNumer = 1;
Map<String,Integer> resultCountMap = new HashMap<>();
String upcBehaviorKey = CacheKeyUtils.getVideoBehavoirKey(userId);
String cursor = null;
for (int i=1 ; i<= pageNumer ; i++) {
Map<String,Object> mp = new HashMap<>();
mp.put("open_id",openid);
mp.put("date_hour",dfh.format(day));
if (cursor != null) {
mp.put("cursor",cursor);
}
String mapAction = JSONObject.toJSONString(mp);
try {
String result = HttpUtil.postDy(url, mapAction,accessToken);
Integer resultCode = (Integer) JSON.parseObject(result).get("err_no");
if (resultCode == 0) {
Map dataMap = (Map) JSON.parseObject(result).get("data");
List<JSONObject> records = (List<JSONObject>)dataMap.get("records");
String next_cursor = (String)dataMap.get("next_cursor");
if (records != null && records.size()>0) {
if (Objects.isNull(tvcCount)) {
tvcCount = 0;
}
if (Objects.isNull(motivateCount)) {
motivateCount = 0;
}
if (Objects.isNull(pecpmCount)) {
pecpmCount = 0;
}
motivateCount += records.size();
for(JSONObject jsonObject : records) {
String cost = jsonObject.getString("cost");
Integer costI = Integer.parseInt(cost);
Double c = (double)(costI / 100);
int ct = c.intValue();
if (pecpmModelCount != null) {
if (ct>=pecpmModelCount) {
pecpmCount ++;
}
}
tvcCount += costI;
}
hsetNew(upcBehaviorKey,"tvc",60 * 60 * 24 * 3,JSON.toJSONString(tvcCount));
hsetNew(upcBehaviorKey,"mvc",60 * 60 * 24 * 3,JSON.toJSONString(motivateCount));
hsetNew(upcBehaviorKey,"vec",60 * 60 * 24 * 3,JSON.toJSONString(pecpmCount));
}
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow.douyin code succ,userId={},result={}",userId,JSON.toJSONString(result));
if (records != null && records.size() == 500) {
pageNumer ++;
cursor = next_cursor;
}
} else {
DYVIDEO_SYS_LOG.info("DouyinBehaviorKafkaConsumer.douyin code error,userId={},result={}",userId,JSON.toJSONString(result));
if (resultCode == 28001008) {
//删除授权过期token
delToken(tokenDy);
getDyAccessToken(dyMarketPlatformAppIdList.get(0), dyMarketPlatformAppIdList.get(1), Objects.equals(env.getActiveProfiles()[0],"prod") ? tokenDyProdUrl : tokenDyDevUrl);
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow.douyin code auth token expired,userId={},result={}",userId,JSON.toJSONString(result));
}
return null;
}
resultCountMap.put("tvc",tvcCount);
resultCountMap.put("motivate",motivateCount);
resultCountMap.put("pecpm",pecpmCount);
} catch (Throwable e) {
e.printStackTrace();
}
}
return resultCountMap;
}
}
src/main/java/com/lwby/marketing/att/dyvideo/handle/DyvideoBehaviorFlow.java
View file @ 16e6136a
......@@ -3,7 +3,8 @@ package com.lwby.marketing.att.dyvideo.handle;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.BehavoirType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.dyvideo.DyVideoUniversalProcess;
import com.lwby.marketing.att.novel.AttributionType;
import com.lwby.marketing.flow.NodeSwitchFlow;
......@@ -12,6 +13,7 @@ import com.lwby.marketing.po.VideoUpload;
import com.lwby.marketing.util.CacheKeyUtils;
import com.lwby.marketing.util.HttpUtil;
import com.lwby.marketing.vo.AppChannelVO;
import com.lwby.marketing.vo.DeliveryDeviceInfo;
import com.lwby.marketing.vo.StoryNovelAction;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
......@@ -51,11 +53,6 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
private static final String tokenDyProdUrl = "https://open.douyin.com/oauth/client_token/";
SimpleDateFormat dfh = new SimpleDateFormat("yyyy-MM-dd");//设置日期格式
private static final String url = "https://open.douyin.com/api/traffic/v1/rt_ecpm/query/";
@Override
public boolean checked(StoryNovelAction action) {
return action.getType() == 3;
......@@ -69,10 +66,11 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
long activeTime = videoUpload.getActiveTime();
long currentTime = System.currentTimeMillis();
DeliveryDeviceInfo deliveryDeviceInfo = action.getDeliveryDeviceInfo();
long hour = TimeUnit.MILLISECONDS.toHours(currentTime - activeTime);
if (hour > 6) {
log.info("DyvideoBehaviorFlow expeed six hour ,videoUpload={},userId={}",JSON.toJSONString(videoUpload),userId);
//action.stop(true);
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow expeed six hour ,videoUpload={},userId={}",JSON.toJSONString(videoUpload),userId);
return;
}
int platformId = action.getPlatformId();
......@@ -80,29 +78,8 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
AppChannelVO appChannel = up.getAppChannelByPlatformAndChannel(platformId,channelId);
//处理关键行为上报
Integer ecpmAvgModelCount = null ;
Integer pecpmModelCount = null;
Integer motivateModelCount = null ;
String media = action.getMediaName();
String openId = action.getOpenId();
if (Objects.nonNull(appChannel) && ((Objects.nonNull(appChannel.getEcpmAvgCount()) && Objects.nonNull(appChannel.getMotivationCount()))
|| (Objects.nonNull(appChannel.getEcpmPerCount()) && Objects.nonNull(appChannel.getMotivationCount())))) {
if (Objects.nonNull(appChannel.getEcpmAvgCount()) && Objects.nonNull(appChannel.getMotivationCount())) {
ecpmAvgModelCount = appChannel.getEcpmAvgCount().intValue();
motivateModelCount = appChannel.getMotivationCount().intValue();
}
if (Objects.nonNull(appChannel.getEcpmPerCount()) && Objects.nonNull(appChannel.getMotivationCount())) {
pecpmModelCount = appChannel.getEcpmPerCount().intValue();
motivateModelCount = appChannel.getMotivationCount().intValue();
}
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow.cacheModel in table is set value,djChanel={},userId={},ecpmAvgModelCount={},pecpmModelCount={},motivateModelCount={}",channelId,userId,ecpmAvgModelCount,pecpmModelCount,motivateModelCount);
} else {
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow.cacheModel in table is not set value,djChanel={},userId={}",channelId,userId);
//action.stop(true);
return;
}
JSONObject dyMarketPlatformAppIdJson = JSON.parseObject(
"{\n"
+ " \"400\": \"ttf2f6844b6dc9702901_d4ac08a22f80f73256836fdd9655dbb0b6e6de7c\",\n"
......@@ -117,7 +94,8 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
dyMarketPlatformAppIdList = Arrays.asList(dyMarketPlatformAppId.split("_"));
String tokenDy = "token_dy_" + dyMarketPlatformAppIdList.get(0);
ThirdAccountDy thirdAccountDy = null;
if (up.exists(tokenDy)) {
DYVIDEO_SYS_LOG.info("thirdAccountDy url={}",Objects.equals(env.getActiveProfiles()[0],"prod") ? tokenDyProdUrl : tokenDyDevUrl);
if (up.existsOld(tokenDy)) {
thirdAccountDy = up.get(ThirdAccountDy.class, tokenDy);
} else {
thirdAccountDy = up.getDyAccessToken(dyMarketPlatformAppIdList.get(0), dyMarketPlatformAppIdList.get(1),
......@@ -125,13 +103,13 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
}
if (thirdAccountDy != null) {
//平均ecpm次数
Integer ecpmAvgCount = null;
Integer ecpmAvgCount = 0;
//每次ecpm次数
Integer pecpmCount = null;
Integer pecpmCount = 0;
//激励视频次数
Integer motivateCount = null;
Integer motivateCount = 0;
//激励视频总ecpm次数
Integer tvcCount = null;
Integer tvcCount = 0;
LocalDateTime now = LocalDateTime.now(); // 获取当前日期时间
LocalTime six = LocalTime.of(6, 0, 0); // 获取当天6点的时间
......@@ -145,8 +123,8 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
calendar.setTime(date); // 设置时间
calendar.add(Calendar.DAY_OF_MONTH, -1); // 将时间减去一天
Date day = calendar.getTime();
resultCountMap = getResultCountList(day, openId, accessToken, tvcCount, motivateCount, pecpmCount,
pecpmModelCount, userId, tokenDy, dyMarketPlatformAppIdList);
resultCountMap = up.getResultCountList(day, openId, accessToken, tvcCount, motivateCount, pecpmCount,
BehavoirType.PECPMMODELCOUNT.getBehavoirType(appChannel).intValue(), userId, tokenDy, dyMarketPlatformAppIdList,env);
if (resultCountMap != null && resultCountMap.size() != 0) {
tvcCount = resultCountMap.get("tvc");
if (tvcCount != null) {
......@@ -157,8 +135,8 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
}
}
//查询今天的ecpm指标
resultCountMap = getResultCountList(date, openId, accessToken, tvcCount, motivateCount, pecpmCount,
pecpmModelCount, userId, tokenDy, dyMarketPlatformAppIdList);
resultCountMap = up.getResultCountList(date, openId, accessToken, tvcCount, motivateCount, pecpmCount,
BehavoirType.PECPMMODELCOUNT.getBehavoirType(appChannel).intValue(), userId, tokenDy, dyMarketPlatformAppIdList,env);
if (resultCountMap != null && resultCountMap.size() != 0) {
tvcCount = resultCountMap.get("tvc");
if (tvcCount != null) {
......@@ -168,67 +146,48 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
pecpmCount = resultCountMap.get("pecpm");
}
if (Objects.nonNull(tvcCount) && Objects.nonNull(motivateCount)) {
if (Objects.nonNull(pecpmCount)) {
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow pecpmcount not null,tvcCount={},motivateCount={},pecpmCount={},djChanel={},userId={}", tvcCount,
motivateCount, pecpmCount, channelId, userId);
}
Double ecpmAvgCountD = (double) tvcCount / motivateCount;
if ((tvcCount != 0 && motivateCount != 0)) {
Double ecpmAvgCountD = (double)tvcCount / motivateCount;
ecpmAvgCount = ecpmAvgCountD.intValue();
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow.ecpm success,tvcCount={},motivateCount={},djChanel={},userId={}", tvcCount, motivateCount, channelId,
userId);
DYVIDEO_SYS_LOG.info("ecpmAvgCount success,ecpmAvgCount={},tvcCount={},motivateCount={},djChanel={},userId={}",ecpmAvgCount,tvcCount,motivateCount,channelId,userId);
} else {
if (Objects.nonNull(pecpmCount) && Objects.nonNull(motivateCount)) {
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow pempcount and motivate not null,tvcCount={},motivateCount={},pecpmCount={},djChanel={},userId={}",
tvcCount, motivateCount, pecpmCount, channelId, userId);
} else {
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow tvcandmo not up to the standard,tvcCount={},motivateCount={},djChanel={},userId={}", tvcCount,
motivateCount, channelId, userId);
//action.stop(true);
return;
}
}
if (Objects.nonNull(motivateModelCount) && Objects.nonNull(motivateCount)) {
if (motivateCount < motivateModelCount) {
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow motivate not up to the standard,motivateCount={},motivateModelCount={},djChanel={},userId={}",
motivateCount, motivateModelCount, channelId, userId);
//action.stop(true);
return;
}
videoUpload.setMotivateCount(String.valueOf(motivateCount));
DYVIDEO_SYS_LOG.info("behavoir not receive data,tvcCount={},motivateCount={},djChanel={},userId={}",tvcCount,motivateCount,channelId,userId);
action.stop(true);
return;
}
if (Objects.nonNull(ecpmAvgModelCount) && Objects.nonNull(ecpmAvgCount)) {
if ((ecpmAvgCount < ecpmAvgModelCount)) {
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow ecpm not up to the standard,ecpmAvgCount={},ecpmAvgModelCount={},djChanel={},userId={}",
ecpmAvgCount, ecpmAvgModelCount, channelId, userId);
//action.stop(true);
return;
}
videoUpload.setEcpmAvgCount(String.valueOf(ecpmAvgCount));
}
for (BehavoirType type : BehavoirType.values()) {
Number behavoirVal = type.getBehavoirType(appChannel);
if (null != behavoirVal && behavoirVal instanceof Integer) {
if (type.getValue().startsWith(BehavoirType.MOTIVATEMODELCOUNT.getValue()) && null != motivateCount) {
if (motivateCount < behavoirVal.intValue()) {
DYVIDEO_SYS_LOG.info("motivate not up to the standard,motivateCount={},motivateModelCount={},djChanel={},userId={}",motivateCount,behavoirVal,channelId,userId);
action.stop(true);
break;
}
deliveryDeviceInfo.setMotivateCount(String.valueOf(motivateCount));
continue;
}
if (type.getValue().startsWith(BehavoirType.ECPMAVGMODELCOUNT.getValue()) && null != ecpmAvgCount) {
if (ecpmAvgCount < behavoirVal.intValue()) {
DYVIDEO_SYS_LOG.info("ecpm not up to the standard,ecpmAvgCount={},ecpmAvgModelCount={},djChanel={},userId={}",ecpmAvgCount,behavoirVal,channelId,userId);
action.stop(true);
break;
}
deliveryDeviceInfo.setEcpmAvgCount(String.valueOf(ecpmAvgCount));
continue;
}
if (type.getValue().startsWith(BehavoirType.PECPMMODELCOUNT.getValue()) && null != pecpmCount) {
if (pecpmCount < BehavoirType.MOTIVATEMODELCOUNT.getBehavoirType(appChannel).intValue()) {
DYVIDEO_SYS_LOG.info("pecpmCount not up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},userId={}",behavoirVal,pecpmCount,BehavoirType.MOTIVATEMODELCOUNT.getBehavoirType(appChannel),motivateCount,channelId,userId);
action.stop(true);
break;
}
if (Objects.nonNull(pecpmModelCount) && Objects.nonNull(motivateModelCount) && Objects.nonNull(motivateCount)) {
if (Objects.nonNull(pecpmCount)) {
if (pecpmCount < motivateModelCount) {
DYVIDEO_SYS_LOG.info(
"DyvideoBehaviorFlow pecpmCount not up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},userId={}",
pecpmModelCount, pecpmCount, motivateModelCount, motivateCount, channelId, userId);
//action.stop(true);
return;
deliveryDeviceInfo.setPecpmCount(String.valueOf(behavoirVal));
deliveryDeviceInfo.setPerecpmSize(String.valueOf(pecpmCount));
break;
}
videoUpload.setPecpmCount(String.valueOf(pecpmModelCount));
videoUpload.setPerecpmSize(String.valueOf(pecpmCount));
DYVIDEO_SYS_LOG.info(
"DyvideoBehaviorFlow pecpmCount up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},userId={}",
pecpmModelCount, pecpmCount, motivateModelCount, motivateCount, channelId, userId);
} else {
DYVIDEO_SYS_LOG.info(
"DyvideoBehaviorFlow pecpmCount is null not to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},userId={}",
pecpmModelCount, pecpmCount, motivateModelCount, motivateCount, channelId, userId);
//action.stop(true);
return;
}
}
......@@ -270,94 +229,11 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
"ChannelAttributionFlow.process0.deduction doing dynamic, platformId = {}, channel = {}, planId={}, sprDedu = {}, channelTotalCount = {}, channelCallbackCount = {}, v = {}",
action.getPlatformId(), action.getChannelId(),action.getPlanId(), sprDedu, channelTotalCount, channelCallbackCount, 0);
}
//action.stop(true);
} else {
//action.stop(true);
}
} else {
//action.stop(true);
}
}
public Map<String,Integer> getResultCountList(Date day,String openid,String accessToken,Integer tvcCount,Integer motivateCount,Integer pecpmCount,Integer pecpmModelCount,Long userId,String tokenDy,List<String> dyMarketPlatformAppIdList) {
int pageNumer = 1;
Map<String,Integer> resultCountMap = new HashMap<>();
String upcBehaviorKey = CacheKeyUtils.getVideoBehavoirKey(userId);
String cursor = null;
for (int i=1 ; i<= pageNumer ; i++) {
Map<String,Object> mp = new HashMap<>();
mp.put("open_id",openid);
mp.put("date_hour",dfh.format(day));
if (cursor != null) {
mp.put("cursor",cursor);
}
String mapAction = JSONObject.toJSONString(mp);
try {
String result = HttpUtil.postDy(url, mapAction,accessToken);
Integer resultCode = (Integer) JSON.parseObject(result).get("err_no");
if (resultCode == 0) {
Map dataMap = (Map) JSON.parseObject(result).get("data");
List<JSONObject> records = (List<JSONObject>)dataMap.get("records");
String next_cursor = (String)dataMap.get("next_cursor");
if (records != null && records.size()>0) {
if (Objects.isNull(tvcCount)) {
tvcCount = 0;
}
if (Objects.isNull(motivateCount)) {
motivateCount = 0;
}
if (Objects.isNull(pecpmCount)) {
pecpmCount = 0;
}
motivateCount += records.size();
for(JSONObject jsonObject : records) {
String cost = jsonObject.getString("cost");
Integer costI = Integer.parseInt(cost);
Double c = (double)(costI / 100);
int ct = c.intValue();
if (pecpmModelCount != null) {
if (ct>=pecpmModelCount) {
pecpmCount ++;
}
}
tvcCount += costI;
}
up.hset(upcBehaviorKey,"tvc",60 * 60 * 24 * 3,JSON.toJSONString(tvcCount));
up.hset(upcBehaviorKey,"mvc",60 * 60 * 24 * 3,JSON.toJSONString(motivateCount));
up.hset(upcBehaviorKey,"vec",60 * 60 * 24 * 3,JSON.toJSONString(pecpmCount));
}
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow.douyin code succ,userId={},result={}",userId,JSON.toJSONString(result));
if (records != null && records.size() == 500) {
pageNumer ++;
cursor = next_cursor;
}
} else {
DYVIDEO_SYS_LOG.info("DouyinBehaviorKafkaConsumer.douyin code error,userId={},result={}",userId,JSON.toJSONString(result));
if (resultCode == 28001008) {
//删除授权过期token
up.delToken(tokenDy);
up.getDyAccessToken(dyMarketPlatformAppIdList.get(0), dyMarketPlatformAppIdList.get(1), Objects.equals(env.getActiveProfiles()[0],"prod") ? tokenDyProdUrl : tokenDyDevUrl);
DYVIDEO_SYS_LOG.info("DyvideoBehaviorFlow.douyin code auth token expired,userId={},result={}",userId,JSON.toJSONString(result));
}
return null;
}
resultCountMap.put("tvc",tvcCount);
resultCountMap.put("motivate",motivateCount);
resultCountMap.put("pecpm",pecpmCount);
} catch (Throwable e) {
e.printStackTrace();
}
}
return resultCountMap;
}
private boolean isCallback(long channelTotalCount, long channelCallbackCount, Integer sprDedu) {
if (channelTotalCount == 0) {
......
src/main/java/com/lwby/marketing/att/dyvideo/handle/ParameterSetupDyVideoFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.dyvideo.handle;
import com.alibaba.fastjson.JSONObject;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.dyvideo.DyVideoUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.notify.Media;
......@@ -35,11 +34,11 @@ public class ParameterSetupDyVideoFlow extends NodeFlow<StoryNovelAction> {
//VO对像
DeliveryDeviceInfo deliveryDeviceInfo = null;
String s = "{\"activeTime\":1711439536879,\"adid\":\"7347520002541764646\",\"channel\":\"214122006\",\"clickId\":\"B.1SLXpxqLP8EXNpAqlfUjsQvppp7bkeHT9LpYmfnxMwxH61cZtBGopyXg3glnl8880WYw3XUYfeh21oLLnT9ovSPFtvFp5faNJQbetTFwBfZiesPw0IpoWF2GtLeJW66Bf8vMnUilTWN7sUlexUfVKQiAefYso0MEqhkcUJhpqzz21B\",\"clickTime\":1711394346686,\"code\":\"FN1za8huKsDQ3TyZYhtyzFgjFTDt-ddTEAzYFwrEpYGMyF6NBImpXtzv9ZTZVnoaI6nSyHU4hQ0kjnwNFsXwLV02x0cpIiod-3L9G35DyTOh_K5LQd6Nvs2FQ20\",\"creativeId\":\"1793848259919929\",\"creativeType\":\"15\",\"media\":\"jrtt\",\"videoResourceId\":\"100013\"}";
//String s = "{\"activeTime\":1711439536879,\"adid\":\"7347520002541764646\",\"channel\":\"214122006\",\"clickId\":\"B.1SLXpxqLP8EXNpAqlfUjsQvppp7bkeHT9LpYmfnxMwxH61cZtBGopyXg3glnl8880WYw3XUYfeh21oLLnT9ovSPFtvFp5faNJQbetTFwBfZiesPw0IpoWF2GtLeJW66Bf8vMnUilTWN7sUlexUfVKQiAefYso0MEqhkcUJhpqzz21B\",\"clickTime\":1711394346686,\"code\":\"FN1za8huKsDQ3TyZYhtyzFgjFTDt-ddTEAzYFwrEpYGMyF6NBImpXtzv9ZTZVnoaI6nSyHU4hQ0kjnwNFsXwLV02x0cpIiod-3L9G35DyTOh_K5LQd6Nvs2FQ20\",\"creativeId\":\"1793848259919929\",\"creativeType\":\"15\",\"media\":\"jrtt\",\"videoResourceId\":\"100013\"}";
//StoryLogin storyLogin = JSONObject.parseObject(s,StoryLogin.class);
//匹配OpenId
VideoUpload videoUpload = JSONObject.parseObject(s,VideoUpload.class);
// VideoUpload videoUpload = up.get(VideoUpload.class,assembleKey(openId));
//VideoUpload videoUpload = JSONObject.parseObject(s,VideoUpload.class);
VideoUpload videoUpload = up.get(VideoUpload.class,assembleKey(openId));
action.setVideoUpload(videoUpload);
//StoryNovelAction对像参数填充
......@@ -61,6 +60,7 @@ public class ParameterSetupDyVideoFlow extends NodeFlow<StoryNovelAction> {
deliveryDeviceInfo.setUuid(UUID.randomUUID().toString());
deliveryDeviceInfo.setDj_channel(videoUpload.getChannel());
deliveryDeviceInfo.setPromotion_id(videoUpload.getAdid());
deliveryDeviceInfo.setMedia(videoUpload.getMedia());
deliveryDeviceInfo.setVideoResourceId(videoUpload.getVideoResourceId());
action.setDeliveryDeviceInfo(deliveryDeviceInfo);
action.setChannelId(NumberUtils.parseLong(videoUpload.getChannel()));
......
src/main/java/com/lwby/marketing/att/dyvideo/handle/StoreDyVideoAttributionFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.dyvideo.handle;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.dyvideo.DyVideoUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.vo.StoryNovelAction;
......
src/main/java/com/lwby/marketing/att/dyvideo/handle/UploadDyVideoCallFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.dyvideo.handle;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.dyvideo.DyVideoUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.vo.StoryNovelAction;
......
src/main/java/com/lwby/marketing/att/videoapp/VideoAppBehavoirConsumer.java
View file @ 16e6136a
......@@ -38,27 +38,27 @@ public class VideoAppBehavoirConsumer {
long begin = System.currentTimeMillis();
if (VIDEO_SYS_LOG.isInfoEnabled()) {
VIDEO_SYS_LOG.info("media.active.onMessage start ,size = {}", datas.size());
VIDEO_SYS_LOG.info("media.behavoir.onMessage start ,size = {}", datas.size());
}
for (ConsumerRecord<String, String> data : datas) {
try {
if (data == null) {
VIDEO_SYS_LOG.warn("media.active.story.onMessage listen 消费数据为null");
VIDEO_SYS_LOG.warn("media.behavoir.story.onMessage listen 消费数据为null");
return;
}
VIDEO_SYS_LOG.info("media.active.onMessage start, data={}", data == null ? null : data.value());
VIDEO_SYS_LOG.info("media.behavoir.onMessage start, data={}", data == null ? null : data.value());
StoreUserUploadEventBO event = JSON.parseObject(data.value(), StoreUserUploadEventBO.class);
VIDEO_SYS_LOG.info("media.active.topic={}, bookStoreEvent={}", data.topic(), JSON.toJSONString(event));
VIDEO_SYS_LOG.info("media.behavoir.topic={}, bookStoreEvent={}", data.topic(), JSON.toJSONString(event));
NovelAction action = new NovelAction(event.getClientInfo(), data.value(),event.getUserUploadEvent());
videoAppFlowExecutor.getExecutorByStory().execute(action);
} catch (Throwable e) {
VIDEO_ERROR_LOG.info("media.active.onMessage failed, data={}, costTime={} ms", data.value(),
VIDEO_ERROR_LOG.info("media.behavoir.onMessage failed, data={}, costTime={} ms", data.value(),
System.currentTimeMillis() - begin, e);
}
}
......
src/main/java/com/lwby/marketing/att/videoapp/VideoAppUniversalProcess.java
View file @ 16e6136a
package com.lwby.marketing.att.videoapp;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alicp.jetcache.anno.CacheRefresh;
......@@ -8,7 +7,7 @@ import com.alicp.jetcache.anno.CacheType;
import com.alicp.jetcache.anno.Cached;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.UniversalProcess;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.novel.AttributionType;
import com.lwby.marketing.vo.*;
import lombok.extern.slf4j.Slf4j;
......@@ -77,6 +76,10 @@ public class VideoAppUniversalProcess extends UniversalProcess {
return null;
}
public boolean existsOld(String key) {
return Boolean.TRUE.equals(oldMarketRedisTemplate.hasKey(key));
}
public <T> Map<String,T> hgetAllOldMarket(Class<T> clazz,String key) {
Map<Object, Object> json = oldMarketRedisTemplate.opsForHash().entries(key);
......@@ -98,8 +101,8 @@ public class VideoAppUniversalProcess extends UniversalProcess {
public String getFirstCheckerKey(NovelAction action) {
return Objects.equals(action.getType(), CallBackType.active.getType())
? String.format("fc_%d_%d_%s_%s", action.getDeviceId(), action.getPlatformId(),action.getMediaName(),action.getCurrentDateStr())
: String.format("fc_%d_%d_%s", action.getDeviceId(), action.getPlatformId(),action.getMediaName());
? String.format("fc_%s_%d_%s_%s", action.getDeviceId(), action.getPlatformId(),action.getMediaName(),action.getCurrentDateStr())
: String.format("fc_%s_%d_%s", action.getDeviceId(), action.getPlatformId(),action.getMediaName());
}
public int getExpire(NovelAction action) {
......
src/main/java/com/lwby/marketing/att/videoapp/handle/ParameterSetupVideoAppFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.videoapp.handle;
import cn.hutool.crypto.SecureUtil;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.videoapp.DeviceVideoType;
import com.lwby.marketing.att.videoapp.VideoAppUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
......
src/main/java/com/lwby/marketing/att/videoapp/handle/StoreVideoAppAttributionFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.videoapp.handle;
import com.lwby.marketing.att.AttributionStatus;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.videoapp.VideoAppUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.vo.NovelAction;
......
src/main/java/com/lwby/marketing/att/videoapp/handle/UploadVideoAppCallFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.videoapp.handle;
import com.lwby.marketing.att.bystory.CallBackType;
import com.lwby.marketing.att.CallBackType;
import com.lwby.marketing.att.videoapp.VideoAppUniversalProcess;
import com.lwby.marketing.flow.NodeFlow;
import com.lwby.marketing.vo.NovelAction;
......
src/main/java/com/lwby/marketing/att/videoapp/handle/VideoAppBehaviorFlow.java
View file @ 16e6136a
package com.lwby.marketing.att.videoapp.handle;
import com.lwby.marketing.att.BehavoirType;
import com.lwby.marketing.att.videoapp.VideoAppUniversalProcess;
import com.lwby.marketing.flow.NodeSwitchFlow;
import com.lwby.marketing.util.CacheKeyUtils;
......@@ -42,54 +43,27 @@ public class VideoAppBehaviorFlow extends NodeSwitchFlow<NovelAction> {
long userId = action.getUserId();
DeliveryDeviceInfo deliveryDeviceInfo = action.getDeliveryDeviceInfo();
AppChannelVO appChannel = up.getAppChannelByPlatformAndChannel(platformId,channelId);
Integer ecpmAvgModelCount = null ;
Integer pecpmModelCount = null;
Integer motivateModelCount = null ;
Double arpuModelCount = null ;
if (Objects.nonNull(appChannel) && ((Objects.nonNull(appChannel.getEcpmAvgCount()) && Objects.nonNull(appChannel.getMotivationCount()))
|| (Objects.nonNull(appChannel.getEcpmPerCount()) && Objects.nonNull(appChannel.getMotivationCount()))
|| (Objects.nonNull(appChannel.getArpuCount()) && Objects.nonNull(appChannel.getMotivationCount())))) {
if (Objects.nonNull(appChannel.getEcpmAvgCount()) && Objects.nonNull(appChannel.getMotivationCount())) {
ecpmAvgModelCount = appChannel.getEcpmAvgCount().intValue();
motivateModelCount = appChannel.getMotivationCount().intValue();
}
if (Objects.nonNull(appChannel.getEcpmPerCount()) && Objects.nonNull(appChannel.getMotivationCount())) {
pecpmModelCount = appChannel.getEcpmPerCount().intValue();
motivateModelCount = appChannel.getMotivationCount().intValue();
}
if (Objects.nonNull(appChannel.getArpuCount()) && Objects.nonNull(appChannel.getMotivationCount())) {
arpuModelCount = appChannel.getArpuCount();
motivateModelCount = appChannel.getMotivationCount().intValue();
}
VIDEOAPP_SYS_LOG.info("cacheModel in table is set value,djChanel={},deviceId={},userId={},ecpmAvgModelCount={},pecpmModelCount={},motivateModelCount={},arpuModelCount={}",channelId,deviceId,userId,ecpmAvgModelCount,pecpmModelCount,motivateModelCount,arpuModelCount);
} else {
if (Objects.isNull(appChannel)) {
VIDEOAPP_SYS_LOG.info("cacheModel in table is not set value,djChanel={},deviceId={},userId={}",channelId,deviceId,userId);
action.stop(true);
return;
}
// 取缓存算是否触发关键行为
//总ecpm次数
Integer tcpmCount = null ;
//曝光次数
Integer expCount = null ;
//平均ecpm次数
Integer ecpmAvgCount = null ;
Integer ecpmAvgCount = 0 ;
//每次ecpm次数
Integer pecpmCount = null ;
Integer pecpmCount = 0 ;
//激励视频次数
Integer motivateCount = null ;
Integer motivateCount = 0 ;
//激励视频总ecpm次数
Integer tvcCount = null;
Double arpuCount = null ;
Integer tvcCount = 0;
Double arpuCount = 0.0 ;
String upcBehaviorKey = CacheKeyUtils.getBehavoirKey(userId);
if (up.exists(upcBehaviorKey)) {
if (up.existsOld(upcBehaviorKey)) {
Map<String, Integer> behaviorMap = up.hgetAllOldMarket(Integer.class, upcBehaviorKey);
for (Map.Entry<String,Integer> entry : behaviorMap.entrySet()) {
switch (entry.getKey()) {
case "tc": tcpmCount = entry.getValue()/100;break;
case "ec": expCount = entry.getValue();break;
case "tc": arpuCount = (double)entry.getValue()/100000;break;
case "tvc": tvcCount = entry.getValue()/100;break;
case "mvc":motivateCount = entry.getValue();break;
case "vec":pecpmCount = entry.getValue();break;
......@@ -98,129 +72,78 @@ public class VideoAppBehaviorFlow extends NodeSwitchFlow<NovelAction> {
}
}
if (Objects.nonNull(tvcCount) && Objects.nonNull(motivateCount)) {
if(Objects.nonNull(pecpmCount)) {
VIDEOAPP_SYS_LOG.info("pecpmcount not null,tcpmCount={},expCount={},arpuCount={},tvcCount={},motivateCount={},pecpmCount={},djChanel={},deviceId={},userId={}",tcpmCount,expCount,arpuCount,tvcCount,motivateCount,pecpmCount,channelId,deviceId,userId);
}
if ((tvcCount != 0 && motivateCount != 0)) {
Double ecpmAvgCountD = (double)tvcCount / motivateCount;
ecpmAvgCount = ecpmAvgCountD.intValue();
arpuCount = (double)tcpmCount / 1000;
VIDEOAPP_SYS_LOG.info("arpuecpm success,tcpmCount={},expCount={},arpuCount={},tvcCount={},motivateCount={},djChanel={},deviceId={},userId={}",tcpmCount,expCount,arpuCount,tvcCount,motivateCount,channelId,deviceId,userId);
VIDEOAPP_SYS_LOG.info("ecpmAvgCount success,ecpmAvgCount={},arpucount={},tvcCount={},motivateCount={},djChanel={},deviceId={},userId={}",ecpmAvgCount,arpuCount,tvcCount,motivateCount,channelId,deviceId,userId);
} else {
if (Objects.nonNull(tcpmCount) && Objects.nonNull(motivateCount)) {
arpuCount = (double)tcpmCount / 1000;
VIDEOAPP_SYS_LOG.info("arpuset success,tcpmCount={},expCount={},arpuCount={},tvcCount={},motivateCount={},djChanel={},deviceId={},userId={}",tcpmCount,expCount,arpuCount,tvcCount,motivateCount,channelId,deviceId,userId);
} else if (Objects.nonNull(pecpmCount) && Objects.nonNull(motivateCount)) {
if (Objects.nonNull(tcpmCount)) {
arpuCount = (double)tcpmCount / 1000;
}
VIDEOAPP_SYS_LOG.info("pempcount and motivate not null,tcpmCount={},expCount={},arpuCount={},tvcCount={},motivateCount={},pecpmCount={},djChanel={},deviceId={},userId={}",tcpmCount,expCount,arpuCount,tvcCount,motivateCount,pecpmCount,channelId,deviceId,userId);
} else {
VIDEOAPP_SYS_LOG.info("tvcandmo not up to the standard,tcpmCount={},expCount={},tvcCount={},motivateCount={},djChanel={},deviceId={},userId={}",tcpmCount,expCount,tvcCount,motivateCount,channelId,deviceId,userId);
action.stop(true);
return;
}
}
if (Objects.nonNull(motivateModelCount) && Objects.nonNull(motivateCount)) {
if (motivateCount < motivateModelCount) {
VIDEOAPP_SYS_LOG.info("motivate not up to the standard,motivateCount={},motivateModelCount={},djChanel={},deviceId={},userId={}",motivateCount,motivateModelCount,channelId,deviceId,userId);
action.stop(true);
return;
}
deliveryDeviceInfo.setMotivateCount(String.valueOf(motivateCount));
VIDEOAPP_SYS_LOG.info("behavoir not receive data,tvcCount={},motivateCount={},djChanel={},deviceId={},userId={}",tvcCount,motivateCount,channelId,deviceId,userId);
action.stop(true);
return;
}
if (Objects.nonNull(ecpmAvgModelCount) && Objects.nonNull(ecpmAvgCount)) {
if (Objects.isNull(arpuModelCount)) {
if ((ecpmAvgCount < ecpmAvgModelCount)) {
VIDEOAPP_SYS_LOG.info("ecpm not up to the standard,ecpmAvgCount={},ecpmAvgModelCount={},djChanel={},deviceId={},userId={}",ecpmAvgCount,ecpmAvgModelCount,channelId,deviceId,userId);
action.stop(true);
return;
}
deliveryDeviceInfo.setEcpmAvgCount(String.valueOf(ecpmAvgCount));
} else {
//当arpu也配置时，则
if ((ecpmAvgCount < ecpmAvgModelCount)) {
VIDEOAPP_SYS_LOG.info("ecpm and arpu not up to the standard,ecpmAvgCount={},ecpmAvgModelCount={},djChanel={},deviceId={},userId={}",ecpmAvgCount,ecpmAvgModelCount,channelId,deviceId,userId);
} else {
deliveryDeviceInfo.setEcpmAvgCount(String.valueOf(ecpmAvgCount));
}
int conditionNum = 0;
for (BehavoirType type : BehavoirType.values()) {
Number behavoirVal = type.getBehavoirType(appChannel);
if (null != behavoirVal) {
conditionNum ++;
}
}
if (Objects.nonNull(pecpmModelCount) && Objects.nonNull(motivateModelCount) && Objects.nonNull(motivateCount)) {
if (Objects.isNull(arpuModelCount)) {
if (Objects.nonNull(pecpmCount)) {
if (pecpmCount < motivateModelCount) {
VIDEOAPP_SYS_LOG.info("pecpmCount not up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},deviceId={},userId={}",pecpmModelCount,pecpmCount,motivateModelCount,motivateCount,channelId,deviceId,userId);
for (BehavoirType type : BehavoirType.values()) {
Number behavoirVal = type.getBehavoirType(appChannel);
if (null != behavoirVal && behavoirVal instanceof Integer) {
if (type.getValue().startsWith(BehavoirType.MOTIVATEMODELCOUNT.getValue()) && null != motivateCount) {
if (motivateCount < behavoirVal.intValue()) {
VIDEOAPP_SYS_LOG.info("motivate not up to the standard,motivateCount={},motivateModelCount={},djChanel={},deviceId={},userId={},conditionNum={}",motivateCount,behavoirVal,channelId,deviceId,userId,conditionNum);
action.stop(true);
return;
break;
}
deliveryDeviceInfo.setPecpmCount(String.valueOf(pecpmModelCount));
deliveryDeviceInfo.setPerecpmSize(String.valueOf(pecpmCount));
VIDEOAPP_SYS_LOG.info("pecpmCount up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},deviceId={},userId={}",pecpmModelCount,pecpmCount,motivateModelCount,motivateCount,channelId,deviceId,userId);
} else {
VIDEOAPP_SYS_LOG.info("pecpmCount is null not to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},deviceId={},userId={}",pecpmModelCount,pecpmCount,motivateModelCount,motivateCount,channelId,deviceId,userId);
action.stop(true);
return;
deliveryDeviceInfo.setMotivateCount(String.valueOf(motivateCount));
continue;
}
} else {
if (Objects.nonNull(pecpmCount)) {
if (pecpmCount < motivateModelCount) {
VIDEOAPP_SYS_LOG.info("pecpmCount and arpu not up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},deviceId={},userId={}",pecpmModelCount,pecpmCount,motivateModelCount,motivateCount,channelId,deviceId,userId);
} else {
deliveryDeviceInfo.setPecpmCount(String.valueOf(pecpmModelCount));
deliveryDeviceInfo.setPerecpmSize(String.valueOf(pecpmCount));
VIDEOAPP_SYS_LOG.info("pecpmCount and arpu up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},deviceId={},userId={}",pecpmModelCount,pecpmCount,motivateModelCount,motivateCount,channelId,deviceId,userId);
if (type.getValue().startsWith(BehavoirType.ECPMAVGMODELCOUNT.getValue()) && null != ecpmAvgCount) {
if (ecpmAvgCount < behavoirVal.intValue()) {
VIDEOAPP_SYS_LOG.info("ecpm not up to the standard,ecpmAvgCount={},ecpmAvgModelCount={},djChanel={},deviceId={},userId={},conditionNum={}",ecpmAvgCount,behavoirVal,channelId,deviceId,userId,conditionNum);
if (Objects.equals(conditionNum,3)) {
continue;
}
action.stop(true);
break;
}
deliveryDeviceInfo.setEcpmAvgCount(String.valueOf(ecpmAvgCount));
if (Objects.equals(conditionNum,3)) {
break;
}
} else {
VIDEOAPP_SYS_LOG.info("pecpmCount and arpu is null not to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},deviceId={},userId={}",pecpmModelCount,pecpmCount,motivateModelCount,motivateCount,channelId,deviceId,userId);
continue;
}
}
}
if (Objects.nonNull(arpuModelCount) && Objects.nonNull(arpuCount)) {
if (Objects.nonNull(ecpmAvgModelCount)) {
//配置了 平均ecpm 三个条件 arpu+平均ecpm + 激励视频
if (Objects.isNull(deliveryDeviceInfo.getEcpmAvgCount())) {
// 平均ecpm没达标，看arpu达标没
if (arpuCount < arpuModelCount) {
VIDEOAPP_SYS_LOG.info("arpu ecpmAvgModelCount not up to the standard,arpuCount={},arpuModelCount={},ecpmAvgCount={},djChanel={},deviceId={},userId={}",arpuCount,arpuModelCount,deliveryDeviceInfo.getEcpmAvgCount(),channelId,deviceId,userId);
if (type.getValue().startsWith(BehavoirType.PECPMMODELCOUNT.getValue()) && null != pecpmCount) {
if (pecpmCount < BehavoirType.MOTIVATEMODELCOUNT.getBehavoirType(appChannel).intValue()) {
VIDEOAPP_SYS_LOG.info("pecpmCount not up to the standard,pecpmModelCount={},pecpmCount={},motivateModelCount={},motivateCount={},djChanel={},deviceId={},userId={},conditionNum={}",behavoirVal,pecpmCount,BehavoirType.MOTIVATEMODELCOUNT.getBehavoirType(appChannel),motivateCount,channelId,deviceId,userId,conditionNum);
if (Objects.equals(conditionNum,3)) {
continue;
}
action.stop(true);
return;
} else {
deliveryDeviceInfo.setEcpmAvgCount(String.valueOf(ecpmAvgCount));
break;
}
deliveryDeviceInfo.setPecpmCount(String.valueOf(behavoirVal));
deliveryDeviceInfo.setPerecpmSize(String.valueOf(pecpmCount));
if (Objects.equals(conditionNum,3)) {
break;
}
continue;
}
VIDEOAPP_SYS_LOG.info("arpu ecpmAvgModelCount up to the standard,arpuCount={},arpuModelCount={},ecpmAvgCount={},djChanel={},deviceId={},userId={}",arpuCount,arpuModelCount,deliveryDeviceInfo.getEcpmAvgCount(),channelId,deviceId,userId);
} else if (Objects.nonNull(pecpmModelCount)) {
//配置了 每次ecpm 三个条件 arpu+每次ecpm + 激励视频
if (Objects.isNull(deliveryDeviceInfo.getPecpmCount())) {
// 平均ecpm没达标，看arpu达标没
if (arpuCount < arpuModelCount) {
VIDEOAPP_SYS_LOG.info("arpu pecpmModelCount not up to the standard,arpuCount={},arpuModelCount={},pecpmCount={},djChanel={},deviceId={},userId={}",arpuCount,arpuModelCount,deliveryDeviceInfo.getPecpmCount(),channelId,deviceId,userId);
} else if (null != behavoirVal && behavoirVal instanceof Double) {
if (type.getValue().startsWith(BehavoirType.ARPUMODELCOUNT.getValue()) && null != arpuCount) {
if (arpuCount < behavoirVal.intValue()) {
VIDEOAPP_SYS_LOG.info("arpu ecpmAvgModelCount not up to the standard,arpuCount={},arpuModelCount={},ecpmAvgCount={},djChanel={},deviceId={},userId={},conditionNum={}",arpuCount,behavoirVal,deliveryDeviceInfo.getEcpmAvgCount(),channelId,deviceId,userId,conditionNum);
action.stop(true);
return;
} else {
deliveryDeviceInfo.setPecpmCount(String.valueOf(pecpmModelCount));
deliveryDeviceInfo.setPerecpmSize(String.valueOf(pecpmCount));
break;
}
}
VIDEOAPP_SYS_LOG.info("arpu pecpmModelCount up to the standard,arpuCount={},arpuModelCount={},pecpmCount={},djChanel={},deviceId={},userId={}",arpuCount,arpuModelCount,deliveryDeviceInfo.getPecpmCount(),channelId,deviceId,userId);
} else {
//只配两个条件的走原来逻辑 arpu+激励视频
if (arpuCount < arpuModelCount) {
VIDEOAPP_SYS_LOG.info("arpu not up to the standard,arpuCount={},arpuModelCount={},djChanel={},deviceId={},userId={}",arpuCount,arpuModelCount,channelId,deviceId,userId);
action.stop(true);
return;
deliveryDeviceInfo.setEcpmAvgCount(String.valueOf(ecpmAvgCount));
}
}
deliveryDeviceInfo.setArpuCount(String.valueOf(arpuCount));
VIDEOAPP_SYS_LOG.info("arpu up to the standard,arpuCount={},arpuModelCount={},djChanel={},deviceId={},userId={}",arpuCount,arpuModelCount,channelId,deviceId,userId);
}
}
}
}
src/main/java/com/lwby/marketing/conf/OldMarketRedisConfig.java
View file @ 16e6136a
......@@ -34,6 +34,9 @@ public class OldMarketRedisConfig {
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
template.setKeySerializer(stringRedisSerializer);
template.setValueSerializer(stringRedisSerializer);
template.setHashKeySerializer(stringRedisSerializer);
template.setHashValueSerializer(stringRedisSerializer);
template.setConnectionFactory(redisConnectionFactory);
return template;
}
......
src/main/java/com/lwby/marketing/controller/AttrController.java
View file @ 16e6136a
......@@ -10,10 +10,7 @@ import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
import com.lwby.marketing.att.novel.AttributionType;
import com.lwby.marketing.po.CrossCallback;
import com.lwby.marketing.util.DateTimUtils;
import com.lwby.marketing.vo.CrossPlatformAccount;
import com.lwby.marketing.vo.DeliveryDeviceInfo;
import com.lwby.marketing.vo.StoryNovelAction;
import com.lwby.marketing.vo.StoreUserUploadEventBO;
import com.lwby.marketing.vo.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
......@@ -87,8 +84,8 @@ public class AttrController {
System.out.println(sprDedu);
}
System.out.println(sprDedu);
String shaveMakeCall = up.getAttributeRuleByPlatformIdAndChannelId(platformId,channelId);
if (StringUtils.isEmpty(shaveMakeCall)) {
AttributeRule attributeRule = up.getAttributeRuleByPlatformIdAndChannelId(platformId,channelId);
if (Objects.isNull(attributeRule) || StringUtils.isEmpty(attributeRule.getShaveMakeCall())) {
//直接回传,走回传流
return;
}
......@@ -102,7 +99,7 @@ public class AttrController {
* "4" : 100
* }
*/
String shaveMakeCall = attributeRule.getShaveMakeCall();
Map<String, Integer> map = JSON.parseObject(shaveMakeCall, Map.class);
String goodId = "1";
......@@ -152,8 +149,8 @@ public class AttrController {
@RequestMapping("/sendPay")
public void testSendPay() {
String msg = "{\"clientInfo\":{\"channel\":214120503,\"clientIp\":\"183.219.7.180\",\"pkv\":1,\"platformGroupId\":412,"
+ "\"platformId\":412,\"sessionid\":\"undefined\",\"ua\":\"Mozilla/5.0 (Linux; Android 12; OXF-AN00 Build/HUAWEIOXF-AN00;"
String msg = "{\"clientInfo\":{\"channel\":214120503,\"clientIp\":\"183.219.7.180\",\"pkv\":1,\"platformGroupId\":601,"
+ "\"platformId\":601,\"sessionid\":\"undefined\",\"ua\":\"Mozilla/5.0 (Linux; Android 12; OXF-AN00 Build/HUAWEIOXF-AN00;"
+ " wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/117.0.0.0 Mobile Safari/537.36 aweme.lite/28.9.0 "
+ "ToutiaoMicroApp/3.14.0 PluginVersion/28909073\",\"version\":\"2.0.0\",\"xClient\":\"version=2.0.0;platformId=412;"
+ "equipment=android\"},\"createTime\":1709533439693,\"extraData\":{},\"id\":\"93857260-8130-442f-bc92-b549dbf28ef0\","
......@@ -249,6 +246,15 @@ public class AttrController {
@RequestMapping("/sendVideoApp")
public void testSendVideoapp() {
com.alibaba.fastjson.JSONObject dyMarketPlatformAppIdJson = JSON.parseObject(
"{\n"
+ " \"400\": \"ttf2f6844b6dc9702901_d4ac08a22f80f73256836fdd9655dbb0b6e6de7c\",\n"
+ " \"412\": \"ttd3dda5604ce230b401_5aac82a8c76db9c54f187dea7b43b58b233459db\"\n"
+ "}");
String platformKey = String.valueOf(412);
//走平台
String dyMarketPlatformAppId = dyMarketPlatformAppIdJson.getString(platformKey);
String msg = "{\"clientInfo\":{\"channel\":682000,\"clientIp\":\"183.226.74.112\","
+ "\"dID\":\"2705A240-1875-4C38-9529-0343B56B6C49\",\"fixVersion\":4,\"idfa\":\"00000000-0000-0000-0000-000000000000\","
+ "\"language\":\"zh\",\"mainVersion\":1,\"oaid\":\"2705A240-1875-4C38-9529-0343B56B6C49\",\"os\":\"1\","
......
src/main/java/com/lwby/marketing/notify/media/jrtt/StoryJRTTNotify.java
View file @ 16e6136a
......@@ -3,20 +3,28 @@ package com.lwby.marketing.notify.media.jrtt;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
import com.lwby.marketing.notify.DYNotify;
import com.lwby.marketing.notify.media.jrtt.dto.JrttAttributeRequest;
import com.lwby.marketing.vo.AttributeRule;
import com.lwby.marketing.vo.DeliveryDeviceInfo;
import com.lwby.marketing.vo.StoryNovelAction;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.annotation.Resource;
import java.util.Objects;
@Slf4j
public class StoryJRTTNotify extends DYNotify {
public static final String ATTRIBUTE_URL = "https://analytics.oceanengine.com/api/v2/conversion";
private static final Logger DYSTORY_SYS_LOG = LoggerFactory.getLogger("dystory.sys");
@Resource
DyStoryUniversalProcess up;
@Override
public boolean active(StoryNovelAction na) {
return notify(na,"active");
......@@ -24,12 +32,12 @@ public class StoryJRTTNotify extends DYNotify {
@Override
public boolean pay(StoryNovelAction na) {
return notify(na,"active_pay");
return Objects.equals(na.getCallbackTypeStory(),3) ? behavior(na) : notify(na,"active_pay");
}
@Override
public boolean behavior(StoryNovelAction na) {
return false;
return notify(na,"game_addiction");
}
public boolean notify(StoryNovelAction na,String eventType) {
......
src/main/java/com/lwby/marketing/notify/media/jrtt/VideoAppJRTTNotify.java
View file @ 16e6136a
package com.lwby.marketing.notify.media.jrtt;
import cn.hutool.crypto.SecureUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.lwby.marketing.notify.MobileNotify;
import com.lwby.marketing.notify.media.jrtt.dto.JrttAttributeRequest;
import com.lwby.marketing.util.HttpUtil;
import com.lwby.marketing.util.Signature;
import com.lwby.marketing.vo.ClientInfo;
import com.lwby.marketing.vo.DeliveryDeviceInfo;
import com.lwby.marketing.vo.NovelAction;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import java.io.IOException;
import java.util.HashMap;
import java.util.Objects;
@Slf4j
public class VideoAppJRTTNotify extends MobileNotify {
public static final String ATTRIBUTE_URL = "https://analytics.oceanengine.com/api/v2/conversion";
public static final String uploadAndroidUrl = "https://www.csjplatform.com/growth_dispatcher/api/attribution_callback_self_built/276cbd93-aae4-9b66-68be-b086f7a419d1/android?pg_site_id=5385181&signature=";
public static final String uploadIosUrl = "https://www.csjplatform.com/growth_dispatcher/api/attribution_callback_self_built/155005fb-6940-4134-8729-f7eb9fb993d6/ios?pg_site_id=5443881&signature=";
@Override
public boolean android(NovelAction na) {
return na.getType() == 0 ? android(na,"active") :android(na,"game_addiction");
return Objects.equals(na.getType(),0) ? android(na,"active") :android(na,"game_addiction");
}
@Override
public boolean ios(NovelAction na) {
return na.getType() == 0 ? android(na,"active") :android(na,"game_addiction");
return Objects.equals(na.getType(),0) ? ios(na,"active") :ios(na,"game_addiction");
}
public boolean android(NovelAction na,String eventType){
......@@ -48,6 +62,9 @@ public class VideoAppJRTTNotify extends MobileNotify {
// Integer resultCode = (Integer) JSON.parseObject(result).get("code");
// return resultCode == 0;
log.info("VideoAppJRTTNotify android Callback info:{}",userJson);
//if (Objects.equals(na.getType(),0)) {
// sendAutoAttribute(ci,ddi,uploadAndroidUrl);
//}
return true;
} catch (Exception e) {
return false;
......@@ -79,9 +96,96 @@ public class VideoAppJRTTNotify extends MobileNotify {
// Integer resultCode = (Integer) JSON.parseObject(result).get("code");
// return resultCode == 0;
log.info("VideoAppJRTTNotify ios Callback info:{}",userJson);
//if (Objects.equals(na.getType(),0)) {
// sendAutoAttribute(ci,ddi,uploadIosUrl);
//}
return true;
} catch (Exception e) {
return false;
}
}
private void sendAutoAttribute(ClientInfo clientInfo, DeliveryDeviceInfo deliveryDeviceInfo,String url) {
try {
String clientIp = clientInfo.getClientIp();
String ua = clientInfo.getUa();
HashMap<String, Object> map = new HashMap<String, Object>();
map.put("time_ts",System.currentTimeMillis());
map.put("ad_platform","toutiao_v2");
if ("0".equals(clientInfo.getOs())) {
if (StringUtils.isNotEmpty(clientInfo.getImei())) {
map.put("imei",clientInfo.getImei());
map.put("imei_md5",SecureUtil.md5(clientInfo.getImei()));
}
if (StringUtils.isNotEmpty(clientInfo.getOaid())) {
map.put("oaid",clientInfo.getOaid());
map.put("oaid_md5",SecureUtil.md5(clientInfo.getOaid()));
}
if (StringUtils.isNotEmpty(clientInfo.getDID())) {
map.put("android_id",clientInfo.getDID());
map.put("android_id_md5", SecureUtil.md5(clientInfo.getDID()));
}
} else if ("1".equals(clientInfo.getOs())){
if (StringUtils.isNotEmpty(clientInfo.getIdfa()) && !"00000000-0000-0000-0000-000000000000".equals(clientInfo.getIdfa())) {
map.put("idfa",clientInfo.getIdfa());
map.put("idfa_md5",SecureUtil.md5(clientInfo.getIdfa()));
} else {
map.put("idfa",clientInfo.getDID());
map.put("idfa_md5",SecureUtil.md5(clientInfo.getDID()));
}
if (StringUtils.isNotEmpty(clientIp) && StringUtils.isNotEmpty(ua)) {
map.put("ip",clientIp);
map.put("ua",ua);
}
}
map.put("ad_id",deliveryDeviceInfo.getPromotion_id());
map.put("ad_name",deliveryDeviceInfo.getPromotion_name());
map.put("campaign_id",deliveryDeviceInfo.getProject_id());
map.put("campaign_name",deliveryDeviceInfo.getProject_name());
map.put("ad_account_id",deliveryDeviceInfo.getAdvertiser_id());
if (StringUtils.isNotBlank(deliveryDeviceInfo.getMid1())) {
map.put("mid1",deliveryDeviceInfo.getMid1());
}
if (StringUtils.isNotBlank(deliveryDeviceInfo.getMid2())) {
map.put("mid2",deliveryDeviceInfo.getMid2());
}
if (StringUtils.isNotBlank(deliveryDeviceInfo.getMid3())) {
map.put("mid3",deliveryDeviceInfo.getMid3());
}
if (StringUtils.isNotBlank(deliveryDeviceInfo.getMid4())) {
map.put("mid4",deliveryDeviceInfo.getMid4());
}
if (StringUtils.isNotBlank(deliveryDeviceInfo.getMid5())) {
map.put("mid5",deliveryDeviceInfo.getMid5());
}
if (StringUtils.isNotBlank(deliveryDeviceInfo.getMid6())) {
map.put("mid6",deliveryDeviceInfo.getMid6());
}
String signature = Signature.getSignature(map);
String mapAction = JSONObject.toJSONString(map);
try {
String result = HttpUtil.post(url+signature, mapAction);
JSONObject bresp = (JSONObject) JSON.parseObject(result).get("base_resp");
Integer resultCode = (Integer) bresp.get("status");
if (resultCode == 0) {
log.info("JrttFreeVideoActiveImpl.sendAutoAttribute success, clientInfo = {}, deliveryDeviceInfo = {}",
JSON.toJSONString(clientInfo),JSON.toJSONString(deliveryDeviceInfo));
} else {
log.info("JrttFreeVideoActiveImpl.sendAutoAttribute fail, result={}, clientInfo = {} , deliveryDeviceInfo = {}",
result,JSON.toJSONString(clientInfo),JSON.toJSONString(deliveryDeviceInfo));
}
} catch (IOException e) {
e.printStackTrace();
}
} catch (Throwable e) {
log.info("JrttFreeVideoActiveImpl.sendAutoAttribute error,clientInfo={}",JSON.toJSONString(clientInfo),e);
}
}
}
src/main/java/com/lwby/marketing/util/HttpUtil.java
View file @ 16e6136a
......@@ -15,6 +15,22 @@ import java.io.*;
*/
public class HttpUtil {
public static String post (String url, String toJson) throws IOException {
HttpClient httpClient = new HttpClient();
PostMethod postMethod = new PostMethod(url);
RequestEntity se = new StringRequestEntity(toJson ,"application/json" ,"UTF-8");
postMethod.setRequestEntity(se);
postMethod.setRequestHeader("Content-Type","application/json");
//默认的重试策略
postMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER, new DefaultHttpMethodRetryHandler());
postMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT, 5000);//设置超时时间
int httpStatus = httpClient.executeMethod(postMethod);
InputStream bodystreams = postMethod.getResponseBodyAsStream();
String body = convertStreamToString(bodystreams);
return body;
}
public static String postDy (String url, String toJson,String token) throws IOException {
HttpClient httpClient = new HttpClient();
......
src/main/java/com/lwby/marketing/util/Signature.java 0 → 100644
View file @ 16e6136a
package com.lwby.marketing.util;
import org.apache.commons.codec.digest.DigestUtils;
import java.util.HashMap;
import java.util.Map;
import java.util.TreeMap;
/**
* @author songxinyu
* @version Signature.java, v 0.1 2023年06月28日 11:28 songxinyu Exp $
*/
public class Signature {
private static final String apiKey = "436a49808b0ed157";
private static final String apiKeyIos = "1749844bed13f705";
public static String getSignature(Map<String, Object> data) {
TreeMap<String, Object> sorted = new TreeMap<>();
sorted.putAll(data);
String dataBeforeMD5 = "";
for(Map.Entry<String, Object> entry : sorted.entrySet()) {
if(!"".equals(entry.getValue())) {
dataBeforeMD5 += entry.getKey() + "=" + entry.getValue() + "&";
}
}
dataBeforeMD5 += "secretKey=" + apiKey;
String signature = DigestUtils.md5Hex(dataBeforeMD5.getBytes());
System.out.println(dataBeforeMD5);
return signature;
}
public static String getSignatureIos(Map<String, Object> data) {
TreeMap<String, Object> sorted = new TreeMap<>();
sorted.putAll(data);
String dataBeforeMD5 = "";
for(Map.Entry<String, Object> entry : sorted.entrySet()) {
if(!"".equals(entry.getValue())) {
dataBeforeMD5 += entry.getKey() + "=" + entry.getValue() + "&";
}
}
dataBeforeMD5 += "secretKey=" + apiKeyIos;
String signature = DigestUtils.md5Hex(dataBeforeMD5.getBytes());
System.out.println(dataBeforeMD5);
return signature;
}
public static void main(String[] args) {
Map<String, Object> data = new HashMap<>();
data.put("paramC", "c");
data.put("paramD", "");
data.put("paramE", "e");
data.put("paramA", "a");
data.put("paramB", "b");
System.out.println(data);
System.out.println(getSignature(data));
}
}
src/main/java/com/lwby/marketing/vo/AttributeRule.java
View file @ 16e6136a
......@@ -57,4 +57,6 @@ public class AttributeRule implements Serializable {
private String link;
private Integer callbackType;
}
src/main/java/com/lwby/marketing/vo/DeliveryDeviceInfo.java
View file @ 16e6136a
......@@ -122,4 +122,7 @@ public class DeliveryDeviceInfo {
private String mid4;
private String mid5;
private String mid6;
private String openId;
}
src/main/java/com/lwby/marketing/vo/StoryNovelAction.java
View file @ 16e6136a
......@@ -29,6 +29,7 @@ public class StoryNovelAction extends Action {
Media media;
String currentDateStr;
String goodId;
Integer callbackTypeStory;
public StoryNovelAction(ClientInfo clientInfo, Long userId, String openId, Integer type){
......
src/main/resources/application-prod.yml
View file @ 16e6136a
......@@ -22,7 +22,7 @@ spring:
initialSize: 2
minIdle: 2
video-inland:
jdbc-url: jdbc:mysql://rm-2zeo09186ukqa8zh1.mysql.rds.aliyuncs.com:3306/video-inland?zeroDateTimeBehavior=CONVERT_TO_NULL&characterEncoding=utf8&autoReconnect=true
jdbc-url: jdbc:mysql://rm-2zeyw42052h06f905.mysql.rds.aliyuncs.com:3306/video-inland?zeroDateTimeBehavior=CONVERT_TO_NULL&characterEncoding=utf8&serverTimezone=Asia/Shanghai&autoReconnect=true
username: video
password: hdTImXLlzOEbP5bk
driver-class-name: com.mysql.cj.jdbc.Driver
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment