parent
ab10eefb66
commit
9ea0a1fad8
Binary file not shown.
@ -0,0 +1,357 @@
|
||||
package com.baiyee.adcallback.api.callback;
|
||||
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import com.baiyee.adcallback.api.common.CommonResponse;
|
||||
import com.baiyee.adcallback.api.vo.*;
|
||||
import com.baiyee.adcallback.service.AdOriginalityManageService;
|
||||
import com.baiyee.adcallback.service.AdTFPackageService;
|
||||
import com.baiyee.adcallback.tools.CheckPlatPointParamsUtil;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RequestParam;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
/**
|
||||
* 更新时间 2023-5-18
|
||||
*
|
||||
* 监测互联网回值的基本类
|
||||
*
|
||||
* 涉及:
|
||||
* 巨量广告, 广电通, 快手, 百度
|
||||
*
|
||||
* @author q
|
||||
*/
|
||||
@RestController
|
||||
@RequestMapping(value = ("/api"))
|
||||
@Slf4j
|
||||
public class MobileMonitorCallbackNewAPI {
|
||||
|
||||
|
||||
private final AdOriginalityManageService originalityManageService;
|
||||
|
||||
|
||||
private final AdTFPackageService adTFPackageService;
|
||||
|
||||
public MobileMonitorCallbackNewAPI(AdOriginalityManageService originalityManageService, AdTFPackageService adTFPackageService) {
|
||||
this.originalityManageService = originalityManageService;
|
||||
this.adTFPackageService = adTFPackageService;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* V2-仅巨量广告体验版
|
||||
*
|
||||
* 【宏参数】
|
||||
* promotion_id=__PROMOTION_ID__&project_id=__PROJECT_ID__&promotion_name=__PROMOTION_NAME__&project_name=__PROJECT_NAME__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__&mid6=__MID6__&csite=__CSITE__&convert_id=__CONVERT_ID__&request_id=__REQUEST_ID__&track_id=__TRACK_ID__&os=__OS__&ua=__UA__&geo=__GEO__&ts=__TS__&model=__MODEL__&imei=__IMEI__&idfa=__IDFA__&idfa_md5=__IDFA_MD5__&oaid=__OAID__&oaid_md5=__OAID_MD5__&mac=__MAC__&callback_param=__CALLBACK_PARAM__&callback_url=__CALLBACK_URL__&advertiser_id=__ADVERTISER_ID__&tag=&vpoint=
|
||||
*/
|
||||
@RequestMapping(value = "/jl/new/monitor/v2")
|
||||
public CommonResponse<String> jlMonitorUrlCallbackReqUrlV2(
|
||||
@RequestParam(value = "promotion_id",defaultValue = "") String promotionId,
|
||||
@RequestParam(value = "project_id",defaultValue = "") String projectId,
|
||||
@RequestParam(value = "promotion_name",defaultValue = "") String promotionName,
|
||||
@RequestParam(value = "project_name",defaultValue = "") String projectName,
|
||||
@RequestParam(value = "mid1",defaultValue = "") String mid1,
|
||||
@RequestParam(value = "mid2",defaultValue = "") String mid2,
|
||||
@RequestParam(value = "mid3",defaultValue = "") String mid3,
|
||||
@RequestParam(value = "mid4",defaultValue = "") String mid4,
|
||||
@RequestParam(value = "mid5",defaultValue = "") String mid5,
|
||||
@RequestParam(value = "mid6",defaultValue = "") String mid6,
|
||||
@RequestParam(value = "csite",defaultValue = "") String csite,
|
||||
@RequestParam(value = "convert_id",defaultValue = "") String convertId,
|
||||
@RequestParam(value = "request_id",defaultValue = "") String requestId,
|
||||
@RequestParam(value = "track_id",defaultValue = "") String trackId,
|
||||
@RequestParam(value = "os",defaultValue = "") String os,
|
||||
@RequestParam(value = "ua",defaultValue = "") String ua,
|
||||
@RequestParam(value = "geo",defaultValue = "") String geo,
|
||||
@RequestParam(value = "ts",defaultValue = "") String ts,
|
||||
@RequestParam(value = "model",defaultValue = "") String model,
|
||||
@RequestParam(value = "imei",defaultValue = "") String imei,
|
||||
@RequestParam(value = "idfa",defaultValue = "") String idfa,
|
||||
@RequestParam(value = "idfa_md5",defaultValue = "") String idfaMD5,
|
||||
@RequestParam(value = "oaid",defaultValue = "") String oaid,
|
||||
@RequestParam(value = "oaid_md5",defaultValue = "") String oaidMD5,
|
||||
@RequestParam(value = "mac",defaultValue = "") String mac,
|
||||
@RequestParam(value = "callback_param",defaultValue = "") String callbackParam,
|
||||
@RequestParam(value = "callback_url",defaultValue = "") String callbackUrl,
|
||||
@RequestParam(value = "advertiser_id",defaultValue = "") String advertiserId,
|
||||
@RequestParam(value = "tag",defaultValue = "") String tag,
|
||||
@RequestParam(value = "vpoint",defaultValue = "") int vpoint
|
||||
){
|
||||
|
||||
// 映射
|
||||
JuliangMobileMonitorCallbackRequestNewV2VO vo = new JuliangMobileMonitorCallbackRequestNewV2VO(
|
||||
promotionId,projectId,promotionName,projectName,mid1,mid2,mid3,mid4,mid5,mid6,
|
||||
csite,convertId,requestId,trackId,os,ua,geo,ts,model,
|
||||
imei,idfa,idfaMD5,oaid,oaidMD5,mac,
|
||||
callbackParam,callbackUrl,advertiserId
|
||||
);
|
||||
|
||||
// 映射 - Base 参数
|
||||
if (StrUtil.isNotBlank(tag) && vpoint >= 0){
|
||||
vo.setTag(tag);
|
||||
vo.setVpoint(vpoint);
|
||||
}
|
||||
|
||||
// 重点参数校验规则 - 通过则入监控回流Source库 - 较完整字段
|
||||
if (CheckPlatPointParamsUtil.checkJLPlatPointV2Param(vo.getOs(), vo.getImei(), vo.getIdfa(), vo.getIdfaMD5())) {
|
||||
originalityManageService.handleNewJLV2MonitorUrlCallbackDataThenSave(vo);
|
||||
}
|
||||
|
||||
// 校验以下参数是否存在 - 入投放包库 - 部分字段
|
||||
if (CheckPlatPointParamsUtil.checkMainParamForPut(vo.getOaid(), vo.getOaidMD5(), vo.getImei(), null,vo.getIdfa(), vo.getIdfaMD5(), vo.getMac())){
|
||||
adTFPackageService.loadJLTFV2PackageData(vo);
|
||||
}
|
||||
|
||||
return CommonResponse.createBySuccess();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* V1-巨量广告1.0
|
||||
*
|
||||
* 【宏参数】
|
||||
* aid=__AID__&aid_name=__AID_NAME__&cid=__CID__&cid_name=__CID_NAME__&campaign_id=__CAMPAIGN_ID__&campaign_name=__CAMPAIGN_NAME__&ctype=__CTYPE__&csite=__CSITE__&convert_id=__CONVERT_ID__&request_id=__REQUEST_ID__&track_id=__TRACK_ID__&os=__OS__&ua=__UA__&geo=__GEO__&ts=__TS__&model=__MODEL__&imei=__IMEI__&idfa=__IDFA__&idfa_md5=__IDFA_MD5__&oaid=__OAID__&oaid_md5=__OAID_MD5__&mac=__MAC__&callback_param=__CALLBACK_PARAM__&callback_url=__CALLBACK_URL__&advertiser_id=__ADVERTISER_ID__&tag=&vpoint=
|
||||
*/
|
||||
@RequestMapping(value = "/jl/new/monitor/v1")
|
||||
public CommonResponse<String> jlMonitorUrlCallbackReqUrlV1(
|
||||
@RequestParam(value = "aid",defaultValue = "") String aid,
|
||||
@RequestParam(value = "aid_name",defaultValue = "") String aidName,
|
||||
@RequestParam(value = "cid",defaultValue = "") String cid,
|
||||
@RequestParam(value = "cid_name",defaultValue = "") String cidName,
|
||||
@RequestParam(value = "campaign_id",defaultValue = "") String campaignId,
|
||||
@RequestParam(value = "campaign_name",defaultValue = "") String campaignName,
|
||||
@RequestParam(value = "ctype",defaultValue = "") String ctype,
|
||||
@RequestParam(value = "csite",defaultValue = "") String csite,
|
||||
@RequestParam(value = "convert_id",defaultValue = "") String convertId,
|
||||
@RequestParam(value = "request_id",defaultValue = "") String requestId,
|
||||
@RequestParam(value = "track_id",defaultValue = "") String trackId,
|
||||
@RequestParam(value = "os",defaultValue = "") String os,
|
||||
@RequestParam(value = "ua",defaultValue = "") String ua,
|
||||
@RequestParam(value = "geo",defaultValue = "") String geo,
|
||||
@RequestParam(value = "ts",defaultValue = "") String ts,
|
||||
@RequestParam(value = "model",defaultValue = "") String model,
|
||||
@RequestParam(value = "imei",defaultValue = "") String imei,
|
||||
@RequestParam(value = "idfa",defaultValue = "") String idfa,
|
||||
@RequestParam(value = "idfa_md5",defaultValue = "") String idfaMD5,
|
||||
@RequestParam(value = "oaid",defaultValue = "") String oaid,
|
||||
@RequestParam(value = "oaid_md5",defaultValue = "") String oaidMD5,
|
||||
@RequestParam(value = "mac",defaultValue = "") String mac,
|
||||
@RequestParam(value = "callback_param",defaultValue = "") String callbackParam,
|
||||
@RequestParam(value = "callback_url",defaultValue = "") String callbackUrl,
|
||||
@RequestParam(value = "advertiser_id",defaultValue = "") String advertiserId,
|
||||
@RequestParam(value = "tag",defaultValue = "") String tag,
|
||||
@RequestParam(value = "vpoint",defaultValue = "") Integer vpoint
|
||||
){
|
||||
// 映射
|
||||
JuliangMobileMonitorCallbackRequestNewV1VO vo = new JuliangMobileMonitorCallbackRequestNewV1VO(
|
||||
aid,aidName,cid,cidName,campaignId,campaignName,ctype,
|
||||
csite,convertId,requestId,trackId,os,ua,geo,ts,model,
|
||||
imei,idfa,idfaMD5,oaid,oaidMD5,mac,
|
||||
callbackParam,callbackUrl,advertiserId
|
||||
);
|
||||
|
||||
// 映射 - Base 参数
|
||||
if (StrUtil.isNotBlank(tag) && vpoint >= 0){
|
||||
vo.setTag(tag);
|
||||
vo.setVpoint(vpoint);
|
||||
}
|
||||
|
||||
// 重点参数校验规则 - 通过则入监控回流Source库 - 较完整字段
|
||||
if (CheckPlatPointParamsUtil.checkJLPlatPointV2Param(vo.getOs(), vo.getImei(), vo.getIdfa(), vo.getIdfaMD5())) {
|
||||
originalityManageService.handleNewJLV1MonitorUrlCallbackDataThenSave(vo);
|
||||
}
|
||||
|
||||
// 校验以下参数是否存在 - 入投放包库 - 部分字段
|
||||
if (CheckPlatPointParamsUtil.checkMainParamForPut(vo.getOaid(), vo.getOaidMD5(), vo.getImei(), null,vo.getIdfa(), vo.getIdfaMD5(), vo.getMac())){
|
||||
adTFPackageService.loadJLTFV1PackageData(vo);
|
||||
}
|
||||
|
||||
return CommonResponse.createBySuccess();
|
||||
}
|
||||
|
||||
/**
|
||||
* 快手连接监测
|
||||
*
|
||||
* https://developers.e.kuaishou.com/docs?docType=DSP&documentId=1938
|
||||
*/
|
||||
@RequestMapping(value = "/ks/new/monitor")
|
||||
public CommonResponse<String> ksMonitorUrlCallbackReqUrl(
|
||||
@RequestParam(value = "accountid", defaultValue = "") String accountId,
|
||||
@RequestParam(value = "aid", defaultValue = "") String aid,
|
||||
@RequestParam(value = "cid", defaultValue = "") String cid,
|
||||
@RequestParam(value = "did", defaultValue = "") String did,
|
||||
@RequestParam(value = "dname", defaultValue = "") String dName,
|
||||
@RequestParam(value = "photoid", defaultValue = "")String photoId,
|
||||
@RequestParam(value = "oaid", defaultValue = "") String oaid,
|
||||
@RequestParam(value = "imei", defaultValue = "") String imei,
|
||||
@RequestParam(value = "imeiHash", defaultValue = "") String imeiHash,
|
||||
@RequestParam(value = "idfa", defaultValue = "") String idfa,
|
||||
@RequestParam(value = "idfaHash", defaultValue = "") String idfaHash,
|
||||
@RequestParam(value = "macBak", defaultValue = "") String macBak,
|
||||
@RequestParam(value = "mac", defaultValue = "") String mac,
|
||||
@RequestParam(value = "ts", defaultValue = "") String ts,
|
||||
@RequestParam(value = "ua", defaultValue = "") String ua,
|
||||
@RequestParam(value = "os", defaultValue = "") String os,
|
||||
@RequestParam(value = "model", defaultValue = "") String model,
|
||||
@RequestParam(value = "callback", defaultValue = "") String callBack,
|
||||
@RequestParam(value = "ip", defaultValue = "") String ip,
|
||||
@RequestParam(value = "csite", defaultValue = "") String csite,
|
||||
@RequestParam(value = "ac_creative", defaultValue = "") String acCreative,
|
||||
@RequestParam(value = "win_for_id", defaultValue = "") String winForId,
|
||||
@RequestParam(value = "vpoint", defaultValue = "") int vpoint,
|
||||
@RequestParam(value = "tag", defaultValue = "") String tag
|
||||
){
|
||||
KSNewMobileMonitorCallbackRequestVO vo = new KSNewMobileMonitorCallbackRequestVO(
|
||||
accountId,aid,cid,did,dName,photoId,
|
||||
oaid,imei,imeiHash,idfa,idfaHash,macBak,mac,
|
||||
ts,ua,os,model,callBack,ip,csite,acCreative,winForId
|
||||
);
|
||||
|
||||
// 映射 - Base 参数
|
||||
if (StrUtil.isNotBlank(tag) && vpoint >= 0){
|
||||
vo.setTag(tag);
|
||||
vo.setVpoint(vpoint);
|
||||
}
|
||||
|
||||
// 重点参数校验规则 - 通过则入监控回流Source库 - 较完整字段
|
||||
if (CheckPlatPointParamsUtil.checkKSPlatPointParam(vo.getOs(), vo.getOaid(), vo.getImei(), vo.getImeiHash(), vo.getIdfa(),vo.getIdfaHash())) {
|
||||
originalityManageService.handleNewKSMonitorUrlCallbackDataThenSave(vo);
|
||||
}
|
||||
|
||||
// 校验以下参数是否存在 - 入投放包库 - 部分字段
|
||||
if (CheckPlatPointParamsUtil.checkMainParamForPut(vo.getOaid(), null, vo.getImei(), null,vo.getIdfa(), null, vo.getMac())){
|
||||
adTFPackageService.loadKSTFPackageData(vo);
|
||||
}
|
||||
|
||||
return CommonResponse.createBySuccess();
|
||||
}
|
||||
|
||||
/**
|
||||
* 百度链接监测
|
||||
*
|
||||
* http://www.test.com/notice?tag=test123&imei_md5={{IMEI_MD5}}&os={{OS}}&ip={{IP}}&ua={{UA}}&ts={{TS}}&userid={{USER_ID}}&pid={{PLAN_ID}}&uid={{UNIT_ID}}&aid={{IDEA_ID}}&click_id={{CLICK_ID}}&callback_url={{CALLBACK_URL}}
|
||||
*/
|
||||
@RequestMapping(value = "/bd/new/monitor")
|
||||
public CommonResponse<String> bdMonitorUrlCallbackReqUrl(
|
||||
@RequestParam(value = "akey", defaultValue = "") String akey,
|
||||
@RequestParam(value = "sign", defaultValue = "") String sign,
|
||||
@RequestParam(value = "userid", defaultValue = "") String userId,
|
||||
@RequestParam(value = "aid", defaultValue = "") String aid,
|
||||
@RequestParam(value = "pid", defaultValue = "") String pid,
|
||||
@RequestParam(value = "uid", defaultValue = "") String uid,
|
||||
@RequestParam(value = "callback_url", defaultValue = "") String callbackUrl,
|
||||
@RequestParam(value = "click_id", defaultValue = "") String clickId,
|
||||
@RequestParam(value = "idfa", defaultValue = "") String idfa,
|
||||
@RequestParam(value = "imei", defaultValue = "") String imei,
|
||||
@RequestParam(value = "oaidMD5", defaultValue = "") String oaidMD5,
|
||||
@RequestParam(value = "oaid", defaultValue = "") String oaid,
|
||||
@RequestParam(value = "mac", defaultValue = "") String mac,
|
||||
@RequestParam(value = "ip", defaultValue = "") String ip,
|
||||
@RequestParam(value = "ua", defaultValue = "") String ua,
|
||||
@RequestParam(value = "os_type", defaultValue = "") String osType,
|
||||
@RequestParam(value = "ts", defaultValue = "") Long ts,
|
||||
@RequestParam(value = "interactionsType", defaultValue = "") String interactionsType,
|
||||
@RequestParam(value = "ext_info", defaultValue = "") String extInfo,
|
||||
@RequestParam(value = "vpoint", defaultValue = "") int vpoint,
|
||||
@RequestParam(value = "tag", defaultValue = "") String tag
|
||||
){
|
||||
BDMobileMonitorCallbackRequestNewVO vo = new BDMobileMonitorCallbackRequestNewVO(
|
||||
akey,sign,
|
||||
userId,aid,pid,uid,callbackUrl,extInfo,clickId,
|
||||
idfa,imei,oaidMD5,oaid,mac,
|
||||
ip,ua,osType,ts,null,interactionsType
|
||||
);
|
||||
|
||||
// 映射 - Base 参数
|
||||
if (StrUtil.isNotBlank(tag) && vpoint >= 0){
|
||||
vo.setTag(tag);
|
||||
vo.setVpoint(vpoint);
|
||||
}
|
||||
|
||||
// 重点参数校验规则 - 通过则入监控回流Source库
|
||||
if (CheckPlatPointParamsUtil.checkBDPlatPointParam(vo.getOsType(), vo.getIdfa(), vo.getImei(), vo.getOaidMD5(), vo.getOaid())) {
|
||||
originalityManageService.handleNewBDTMonitorUrlCallbackDataThenSave(vo);
|
||||
}
|
||||
|
||||
// 校验以下参数是否存在 - 入投放包库 - 部分字段
|
||||
if (CheckPlatPointParamsUtil.checkMainParamForPut(vo.getOaid(), vo.getOaidMD5(), null, vo.getImei(),vo.getIdfa(), null, vo.getMac())){
|
||||
adTFPackageService.loadBDPackageData(vo);
|
||||
}
|
||||
|
||||
return CommonResponse.createBySuccess();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 广电通链接监测
|
||||
*
|
||||
* API文档地址 : https://developers.e.qq.com/docs/guide/conversion/new_version/dianjijiance
|
||||
*/
|
||||
@RequestMapping(value = "/gdt/new/monitor")
|
||||
public CommonResponse<String> gdtMonitorUrlCallbackReqUrl(
|
||||
@RequestParam(value = "account_id", defaultValue = "") String accountId,
|
||||
@RequestParam(value = "click_id", defaultValue = "") String clickId,
|
||||
@RequestParam(value = "click_time", defaultValue = "") String clickTime,
|
||||
@RequestParam(value = "impression_time", defaultValue = "") String impressionTime,
|
||||
@RequestParam(value = "campaign_id", defaultValue = "") String campaignId,
|
||||
@RequestParam(value = "adgroup_id", defaultValue = "") String adgroupId,
|
||||
@RequestParam(value = "ad_id", defaultValue = "") String adId,
|
||||
@RequestParam(value = "ad_platform_type", defaultValue = "") String adPlatformType,
|
||||
@RequestParam(value = "ad_type", defaultValue = "") String adType,
|
||||
@RequestParam(value = "agency_id", defaultValue = "") String agencyId,
|
||||
@RequestParam(value = "click_sku_id", defaultValue = "") String clickSkuId,
|
||||
@RequestParam(value = "billing_event", defaultValue = "") String billingEvent,
|
||||
@RequestParam(value = "deeplink_url", defaultValue = "") String deeplinkUrl,
|
||||
@RequestParam(value = "universal_link", defaultValue = "") String universalLink,
|
||||
@RequestParam(value = "page_url", defaultValue = "") String pageUrl,
|
||||
@RequestParam(value = "device_os_type", defaultValue = "") String deviceOsType,
|
||||
@RequestParam(value = "process_time", defaultValue = "") String processTime,
|
||||
@RequestParam(value = "promoted_object_id", defaultValue = "") String promotedObjectId,
|
||||
@RequestParam(value = "promoted_object_type", defaultValue = "") String promotedObjectType,
|
||||
@RequestParam(value = "real_cost", defaultValue = "") String realCost,
|
||||
@RequestParam(value = "request_id", defaultValue = "") String requestId,
|
||||
@RequestParam(value = "impression_id", defaultValue = "") String impressionId,
|
||||
@RequestParam(value = "muid", defaultValue = "") String muid,
|
||||
@RequestParam(value = "hash_mac", defaultValue = "") String mac,
|
||||
@RequestParam(value = "hash_android_id", defaultValue = "") String hashAndroidId,
|
||||
@RequestParam(value = "ip", defaultValue = "") String ip,
|
||||
@RequestParam(value = "user_agent", defaultValue = "") String userAgent,
|
||||
@RequestParam(value = "callback", defaultValue = "") String callback,
|
||||
@RequestParam(value = "encrypted_position_id", defaultValue = "") String encryptedPositionId,
|
||||
@RequestParam(value = "hash_oaid", defaultValue = "") String oaid,
|
||||
@RequestParam(value = "caid", defaultValue = "") String caid,
|
||||
@RequestParam(value = "adgroup_name", defaultValue = "") String adgroupName,
|
||||
@RequestParam(value = "site_set_name", defaultValue = "") String siteSetName,
|
||||
@RequestParam(value = "campaign_name", defaultValue = "") String campaignName,
|
||||
@RequestParam(value = "ad_name", defaultValue = "") String adName,
|
||||
@RequestParam(value = "model", defaultValue = "") String model,
|
||||
@RequestParam(value = "vpoint", defaultValue = "") int vpoint,
|
||||
@RequestParam(value = "tag", defaultValue = "") String tag
|
||||
){
|
||||
GdtMobileMonitorCallbackRequestNewVO vo = new GdtMobileMonitorCallbackRequestNewVO(
|
||||
accountId,clickId,clickTime,deviceOsType,
|
||||
muid,oaid,mac,
|
||||
campaignId,adgroupId,adId,promotedObjectId,ip,userAgent,callback,promotedObjectType
|
||||
);
|
||||
|
||||
// 映射 - Base 参数
|
||||
if (StrUtil.isNotBlank(tag) && vpoint >= 0){
|
||||
vo.setTag(tag);
|
||||
vo.setVpoint(vpoint);
|
||||
}
|
||||
|
||||
// 重点参数校验规则 - 通过则入监控回流Source库
|
||||
if (CheckPlatPointParamsUtil.checkGDTPlatPointParam(vo.getDeviceOsType(), vo.getMuid(), vo.getOaid())) {
|
||||
originalityManageService.handleNewGDTMonitorUrlCallbackDataThenSave(vo);
|
||||
}
|
||||
|
||||
// 校验以下参数是否存在 - 入投放包库 - 部分字段
|
||||
if (CheckPlatPointParamsUtil.checkMainParamForPut(vo.getOaid(), null, vo.getMuid(), null,vo.getMuid(), null, vo.getMac())){
|
||||
adTFPackageService.loadGDTPackageData(vo);
|
||||
}
|
||||
|
||||
return CommonResponse.createBySuccess();
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,18 @@
|
||||
package com.baiyee.adcallback.api.constants;
|
||||
|
||||
public class SpecialCheckParmConstant {
|
||||
|
||||
|
||||
/*
|
||||
* 巨量特殊的字符标识
|
||||
*/
|
||||
public static final String ZERO_JL_IMEI = "000000000000000";
|
||||
|
||||
public static final String ZERO_JL_IMEI_MD5 = "5284047f4ffb4e04824a2fd1d1f0cd62";
|
||||
|
||||
public static final String ZERO_JL_IDFA = "00000000-0000-0000-0000-000000000000";
|
||||
|
||||
public static final String ZERO_JL_IDFA_MD5 = "9f89c84a559f573636a47ff8daed0d33";
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,59 @@
|
||||
package com.baiyee.adcallback.api.constants;
|
||||
|
||||
/**
|
||||
* Vpoint 枚举类
|
||||
*/
|
||||
public enum VpointEnum {
|
||||
|
||||
|
||||
/**
|
||||
* 视频类广告相关参数
|
||||
*/
|
||||
SHOW("展示"),EFFECTIVE_POINT("有效触点"),VIDEO_PLAY("视频播放"),VIDEO_FINISH("完播"), EFFECTIVE_PLAY("有效播放"),
|
||||
/**
|
||||
* 广告位展示广告
|
||||
*/
|
||||
EFFECTIVE_WEBSITE_POINT("平台有效点击"), WEBSITE_SHOW("平台有效曝光")
|
||||
;
|
||||
|
||||
|
||||
private final String status;
|
||||
VpointEnum(String status) {
|
||||
this.status = status;
|
||||
}
|
||||
|
||||
public String getStatus() {
|
||||
return status;
|
||||
}
|
||||
|
||||
public static String vPointCodeConvertStatus(int vPointCode){
|
||||
String backStatus = "";
|
||||
switch (vPointCode){
|
||||
case 1:
|
||||
backStatus = SHOW.status;
|
||||
break;
|
||||
case 2:
|
||||
backStatus = EFFECTIVE_POINT.status;
|
||||
break;
|
||||
case 3:
|
||||
backStatus = VIDEO_PLAY.status;
|
||||
break;
|
||||
case 4:
|
||||
backStatus = VIDEO_FINISH.status;
|
||||
break;
|
||||
case 5:
|
||||
backStatus = EFFECTIVE_PLAY.status;
|
||||
break;
|
||||
case 6:
|
||||
backStatus = EFFECTIVE_WEBSITE_POINT.status;
|
||||
break;
|
||||
case 7:
|
||||
backStatus = WEBSITE_SHOW.status;
|
||||
break;
|
||||
default:
|
||||
System.out.println("wrong number!");
|
||||
}
|
||||
return backStatus;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,32 @@
|
||||
package com.baiyee.adcallback.repository;
|
||||
|
||||
import cn.hutool.core.date.DateTime;
|
||||
import com.baiyee.adcallback.api.dto.PlateFormDTO;
|
||||
import com.baiyee.adcallback.repository.entity.TbBdBackdataEntity;
|
||||
import com.baiyee.adcallback.repository.entity.TbBdNewBackdataEntity;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.data.repository.query.Param;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Repository
|
||||
public interface TbBDNewBackdataEntityRepository extends JpaRepository<TbBdNewBackdataEntity, Long> {
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 查询数据
|
||||
* @param imeiStrFirst
|
||||
* @param imeiSecond
|
||||
* @param startDate
|
||||
* @param endDate
|
||||
* @param tag
|
||||
* @return
|
||||
*/
|
||||
@Query("select new com.baiyee.adcallback.api.dto.PlateFormDTO(imei as imei,tag as tag) from " +
|
||||
" TbBdBackdataEntity where imei != :imeiStrFirst and imei != :imeiSecond " +
|
||||
"and gmtCreate >= :startDate and gmtCreate < :endDate and tag in :tag group by imei,tag")
|
||||
List<PlateFormDTO> queryPlateFormDTO(@Param("imeiStrFirst") String imeiStrFirst, @Param("imeiSecond") String imeiSecond, @Param("startDate") DateTime startDate, @Param("endDate") DateTime endDate, @Param("tag") List<String> tag);
|
||||
}
|
||||
@ -0,0 +1,32 @@
|
||||
package com.baiyee.adcallback.repository;
|
||||
|
||||
import cn.hutool.core.date.DateTime;
|
||||
import com.baiyee.adcallback.api.dto.PlateFormDTO;
|
||||
import com.baiyee.adcallback.repository.entity.TbGdtBackdataEntity;
|
||||
import com.baiyee.adcallback.repository.entity.TbGdtNewBackdataEntity;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.data.repository.query.Param;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Repository
|
||||
public interface TbGdtNewBackdataEntityRepository extends JpaRepository<TbGdtNewBackdataEntity, Long> {
|
||||
|
||||
|
||||
/**
|
||||
* 查询数据
|
||||
* @param imeiStrFirst
|
||||
* @param imeiSecond
|
||||
* @param startDate
|
||||
* @param endDate
|
||||
* @param models
|
||||
* @param tag
|
||||
* @return
|
||||
*/
|
||||
@Query("select new com.baiyee.adcallback.api.dto.PlateFormDTO(muid as imei,tag as tag) from " +
|
||||
" TbGdtBackdataEntity where muid != :imeiStrFirst and muid != :imeiSecond " +
|
||||
"and gmtCreate >= :startDate and gmtCreate < :endDate and tag in :tag and deviceOsType = :models group by muid,tag")
|
||||
List<PlateFormDTO> queryPlateFormDTO(@Param("imeiStrFirst") String imeiStrFirst, @Param("imeiSecond") String imeiSecond, @Param("startDate") DateTime startDate, @Param("endDate") DateTime endDate, @Param("tag") List<String> tag,@Param("models") String models);
|
||||
}
|
||||
@ -0,0 +1,39 @@
|
||||
package com.baiyee.adcallback.repository;
|
||||
|
||||
import cn.hutool.core.date.DateTime;
|
||||
import com.baiyee.adcallback.api.dto.PlateFormDTO;
|
||||
import com.baiyee.adcallback.repository.entity.TbJLBackDataV1Entity;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.data.repository.query.Param;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@Repository
|
||||
public interface TbJLV1BackdataEntityRepository extends JpaRepository<TbJLBackDataV1Entity, Long> {
|
||||
|
||||
|
||||
@Query(value = "SELECT imei FROM tb_jl_v1_backdata WHERE imei != '' AND imei != '__IMEI__'", nativeQuery = true)
|
||||
List<String> queryAllImeis();
|
||||
|
||||
|
||||
@Query(value = "SELECT imei FROM tb_jl_v1backdata WHERE imei != '' AND imei != '__IMEI__' AND gmt_create > :startDate AND gmt_create < :endDate", nativeQuery = true)
|
||||
List<String> queryAllImeiByDate(Date startDate, Date endDate);
|
||||
|
||||
/**
|
||||
* 查询数据
|
||||
* @param imeiStrFirst
|
||||
* @param imeiSecond
|
||||
* @param startDate
|
||||
* @param endDate
|
||||
* @param tag
|
||||
* @return
|
||||
*/
|
||||
@Query("select new com.baiyee.adcallback.api.dto.PlateFormDTO(imei as imei,tag as tag) from " +
|
||||
" TbJlBackdataEntity where imei != :imeiStrFirst and imei != :imeiSecond " +
|
||||
"and gmtCreate >= :startDate and gmtCreate < :endDate and tag in :tag group by imei,tag")
|
||||
List<PlateFormDTO> queryPlateFormDTO(@Param("imeiStrFirst") String imeiStrFirst, @Param("imeiSecond") String imeiSecond, @Param("startDate") DateTime startDate, @Param("endDate") DateTime endDate, @Param("tag") List<String> tag);
|
||||
|
||||
}
|
||||
@ -0,0 +1,33 @@
|
||||
package com.baiyee.adcallback.repository;
|
||||
|
||||
import cn.hutool.core.date.DateTime;
|
||||
import com.baiyee.adcallback.api.dto.PlateFormDTO;
|
||||
import com.baiyee.adcallback.repository.entity.TbJLBackDataV2Entity;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.data.repository.query.Param;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@Repository
|
||||
public interface TbJLV2BackdataEntityRepository extends JpaRepository<TbJLBackDataV2Entity, Long> {
|
||||
|
||||
@Query(value = "SELECT imei FROM tb_jl_v2_backdata WHERE imei != '' AND imei != '__IMEI__'", nativeQuery = true)
|
||||
List<String> queryAllImeis();
|
||||
|
||||
|
||||
@Query(value = "SELECT imei FROM tb_jl_v2_backdata WHERE imei != '' AND imei != '__IMEI__' AND gmt_create > :startDate AND gmt_create < :endDate", nativeQuery = true)
|
||||
List<String> queryAllImeiByDate(Date startDate, Date endDate);
|
||||
|
||||
|
||||
/**
|
||||
* 查询数据
|
||||
*/
|
||||
@Query("select new com.baiyee.adcallback.api.dto.PlateFormDTO(imei as imei,tag as tag) from " +
|
||||
" TbJlBackdataEntity where imei != :imeiStrFirst and imei != :imeiSecond " +
|
||||
"and gmtCreate >= :startDate and gmtCreate < :endDate and tag in :tag group by imei,tag")
|
||||
List<PlateFormDTO> queryPlateFormDTO(@Param("imeiStrFirst") String imeiStrFirst, @Param("imeiSecond") String imeiSecond, @Param("startDate") DateTime startDate, @Param("endDate") DateTime endDate, @Param("tag") List<String> tag);
|
||||
|
||||
}
|
||||
@ -0,0 +1,31 @@
|
||||
package com.baiyee.adcallback.repository;
|
||||
|
||||
import cn.hutool.core.date.DateTime;
|
||||
import com.baiyee.adcallback.api.dto.PlateFormDTO;
|
||||
import com.baiyee.adcallback.repository.entity.TbKSNewBackdataEntity;
|
||||
import com.baiyee.adcallback.repository.entity.TbKsBackdataEntity;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.data.repository.query.Param;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Repository
|
||||
public interface TbKSNewBackdataEntityRepository extends JpaRepository<TbKSNewBackdataEntity, Long> {
|
||||
|
||||
|
||||
/**
|
||||
* 查询数据
|
||||
* @param imeiStrFirst
|
||||
* @param imeiSecond
|
||||
* @param startDate
|
||||
* @param endDate
|
||||
* @param tag
|
||||
* @return
|
||||
*/
|
||||
@Query("select new com.baiyee.adcallback.api.dto.PlateFormDTO(imei as imei,tag as tag) from " +
|
||||
" TbKsBackdataEntity where imei != :imeiStrFirst and imei != :imeiSecond " +
|
||||
"and gmtCreate >= :startDate and gmtCreate < :endDate and tag in :tag group by imei,tag")
|
||||
List<PlateFormDTO> queryPlateFormDTO(@Param("imeiStrFirst") String imeiStrFirst, @Param("imeiSecond") String imeiSecond, @Param("startDate") DateTime startDate, @Param("endDate") DateTime endDate, @Param("tag") List<String> tag);
|
||||
}
|
||||
@ -0,0 +1,114 @@
|
||||
package com.baiyee.adcallback.repository.entity;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import lombok.Data;
|
||||
import org.springframework.data.annotation.CreatedDate;
|
||||
import org.springframework.data.annotation.LastModifiedBy;
|
||||
import org.springframework.data.annotation.LastModifiedDate;
|
||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
||||
import javax.persistence.*;
|
||||
import java.sql.Timestamp;
|
||||
|
||||
@Data
|
||||
@Entity
|
||||
@Table(name = "tb_bd_new_backdata", schema = "db_ad", catalog = "")
|
||||
@EntityListeners(AuditingEntityListener.class)
|
||||
public class TbBdNewBackdataEntity {
|
||||
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||
@Id
|
||||
@Column(name = "id", nullable = false)
|
||||
private long id;
|
||||
|
||||
@CreatedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Column(name = "gmt_create", nullable = false)
|
||||
private Timestamp gmtCreate;
|
||||
|
||||
@LastModifiedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Column(name = "gmt_modify", nullable = false)
|
||||
private Timestamp gmtModify;
|
||||
|
||||
@LastModifiedBy
|
||||
@Column(name = "operator", nullable = false, length = 255)
|
||||
private String operator;
|
||||
@Basic
|
||||
@Column(name = "userid", nullable = false, length = 255)
|
||||
private String userid;
|
||||
@Basic
|
||||
@Column(name = "aid", nullable = false, length = 255)
|
||||
private String aid;
|
||||
@Basic
|
||||
@Column(name = "pid", nullable = false, length = 255)
|
||||
private String pid;
|
||||
@Basic
|
||||
@Column(name = "uid", nullable = false, length = 255)
|
||||
private String uid;
|
||||
@Basic
|
||||
@Column(name = "callback_url", nullable = false, length = -1)
|
||||
private String callbackUrl;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ext_info", nullable = false, length = -1)
|
||||
private String extInfo;
|
||||
|
||||
@Basic
|
||||
@Column(name = "click_id", nullable = false, length = 255)
|
||||
private String clickId;
|
||||
@Basic
|
||||
@Column(name = "idfa", nullable = false, length = 255)
|
||||
private String idfa;
|
||||
@Basic
|
||||
@Column(name = "imei", nullable = false, length = 255)
|
||||
private String imei;
|
||||
|
||||
@Basic
|
||||
@Column(name = "oaid_MD5", nullable = false, length = 255)
|
||||
private String oaidMD5;
|
||||
@Basic
|
||||
@Column(name = "oaid", nullable = false, length = 255)
|
||||
private String oaid;
|
||||
@Basic
|
||||
@Column(name = "mac", nullable = false, length = 255)
|
||||
private String mac;
|
||||
@Basic
|
||||
@Column(name = "ip", nullable = false, length = 255)
|
||||
private String ip;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ua", nullable = false, length = 255)
|
||||
private String ua;
|
||||
@Basic
|
||||
@Column(name = "os_type", nullable = false, length = 255)
|
||||
private String osType;
|
||||
@Basic
|
||||
@Column(name = "ts", nullable = false)
|
||||
private long ts;
|
||||
@Basic
|
||||
@Column(name = "device_info", nullable = false, length = 255)
|
||||
private String deviceInfo;
|
||||
@Basic
|
||||
@Column(name = "interactions_type", nullable = false, length = 255)
|
||||
private String interactionsType;
|
||||
|
||||
@Basic
|
||||
@Column(name = "tag", nullable = false, length = 255)
|
||||
private String tag;
|
||||
|
||||
/**
|
||||
* 用于区分广告配置的地方
|
||||
* 巨量
|
||||
* 展示 - 1
|
||||
* 有效触点 - 2
|
||||
* 视频播放 - 3
|
||||
* 完播 - 4
|
||||
* 有效播放 - 5
|
||||
*/
|
||||
@Basic
|
||||
@Column(name = "vpoint", nullable = false)
|
||||
private Integer vpoint;
|
||||
}
|
||||
@ -0,0 +1,126 @@
|
||||
package com.baiyee.adcallback.repository.entity;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import lombok.Data;
|
||||
import org.springframework.data.annotation.CreatedDate;
|
||||
import org.springframework.data.annotation.LastModifiedBy;
|
||||
import org.springframework.data.annotation.LastModifiedDate;
|
||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
||||
import javax.persistence.*;
|
||||
import java.sql.Timestamp;
|
||||
|
||||
@Entity
|
||||
@Table(name = "tb_gdt_new_backdata", schema = "db_ad", catalog = "")
|
||||
@EntityListeners(AuditingEntityListener.class)
|
||||
@Data
|
||||
public class TbGdtNewBackdataEntity {
|
||||
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||
@Id
|
||||
@Column(name = "id", nullable = false)
|
||||
private long id;
|
||||
|
||||
@CreatedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Basic
|
||||
@Column(name = "gmt_create", nullable = false)
|
||||
private Timestamp gmtCreate;
|
||||
|
||||
@LastModifiedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Basic
|
||||
@Column(name = "gmt_modify", nullable = false)
|
||||
private Timestamp gmtModify;
|
||||
|
||||
@LastModifiedBy
|
||||
@Basic
|
||||
@Column(name = "operator", nullable = false, length = 255)
|
||||
private String operator;
|
||||
|
||||
@Basic
|
||||
@Column(name = "account_id", nullable = false, length = 255)
|
||||
private String accountId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "click_id", nullable = false, length = 255)
|
||||
private String clickId;
|
||||
@Basic
|
||||
@Column(name = "click_time", nullable = false, length = 255)
|
||||
private String clickTime;
|
||||
|
||||
@Basic
|
||||
@Column(name = "campaign_id", nullable = false, length = 255)
|
||||
private String campaignId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "adgroup_id", nullable = false, length = 255)
|
||||
private String adgroupId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ad_id", nullable = false, length = 255)
|
||||
private String adId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "device_os_type", nullable = false, length = 255)
|
||||
private String deviceOsType;
|
||||
|
||||
|
||||
@Basic
|
||||
@Column(name = "promoted_object_id", nullable = false, length = 255)
|
||||
private String promotedObjectId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "promoted_object_type", nullable = false, length = 255)
|
||||
private String promotedObjectType;
|
||||
|
||||
@Basic
|
||||
@Column(name = "imei", nullable = false, length = 255)
|
||||
private String imei;
|
||||
|
||||
|
||||
@Basic
|
||||
@Column(name = "idfa", nullable = false, length = 255)
|
||||
private String idfa;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mac", nullable = false, length = 255)
|
||||
private String mac;
|
||||
|
||||
|
||||
@Basic
|
||||
@Column(name = "ip", nullable = false, length = 255)
|
||||
private String ip;
|
||||
|
||||
@Basic
|
||||
@Column(name = "user_agent", nullable = false, length = 512)
|
||||
private String userAgent;
|
||||
|
||||
@Basic
|
||||
@Column(name = "callback", nullable = false, length = 255)
|
||||
private String callback;
|
||||
|
||||
@Basic
|
||||
@Column(name = "oaid", nullable = false, length = 255)
|
||||
private String oaid;
|
||||
|
||||
|
||||
@Basic
|
||||
@Column(name = "tag", nullable = false, length = 255)
|
||||
private String tag;
|
||||
|
||||
/**
|
||||
* 用于区分广告配置的地方
|
||||
* 巨量
|
||||
* 展示 - 1
|
||||
* 有效触点 - 2
|
||||
* 视频播放 - 3
|
||||
* 完播 - 4
|
||||
* 有效播放 - 5
|
||||
*/
|
||||
@Basic
|
||||
@Column(name = "vpoint", nullable = false)
|
||||
private Integer vpoint;
|
||||
}
|
||||
@ -0,0 +1,169 @@
|
||||
package com.baiyee.adcallback.repository.entity;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import lombok.Data;
|
||||
import org.springframework.data.annotation.CreatedDate;
|
||||
import org.springframework.data.annotation.LastModifiedBy;
|
||||
import org.springframework.data.annotation.LastModifiedDate;
|
||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
||||
import javax.persistence.*;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* 结核病jl backdata实体
|
||||
*
|
||||
* @author q
|
||||
* @date 2022/01/07
|
||||
*/
|
||||
@Entity
|
||||
@Table(name = "tb_jl_v1_backdata", schema = "db_ad", catalog = "")
|
||||
@Data
|
||||
@EntityListeners(AuditingEntityListener.class)
|
||||
public class TbJLBackDataV1Entity {
|
||||
|
||||
|
||||
@Id
|
||||
@Column(name = "id", nullable = false)
|
||||
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||
private long id;
|
||||
|
||||
@CreatedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Column(name = "gmt_create", nullable = false)
|
||||
private Date gmtCreate;
|
||||
|
||||
@LastModifiedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Column(name = "gmt_modify", nullable = false)
|
||||
private Date gmtModify;
|
||||
|
||||
@LastModifiedBy
|
||||
@Column(name = "operator", nullable = false, length = 255)
|
||||
private String operator;
|
||||
|
||||
@Basic
|
||||
@Column(name = "aid", nullable = false, length = 255)
|
||||
private String aid;
|
||||
|
||||
@Basic
|
||||
@Column(name = "aid_name", nullable = false, length = 255)
|
||||
private String aidName;
|
||||
|
||||
@Basic
|
||||
@Column(name = "cid", nullable = false, length = 255)
|
||||
private String cid;
|
||||
|
||||
@Basic
|
||||
@Column(name = "cid_name", nullable = false, length = 255)
|
||||
private String cidName;
|
||||
|
||||
@Basic
|
||||
@Column(name = "campaign_id", nullable = false, length = 255)
|
||||
private String campaignId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "campaign_name", nullable = false, length = 255)
|
||||
private String campaignName;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ctype", nullable = false, length = 255)
|
||||
private String ctype;
|
||||
@Basic
|
||||
@Column(name = "csite", nullable = false, length = 255)
|
||||
private String csite;
|
||||
|
||||
@Basic
|
||||
@Column(name = "convert_id", nullable = false, length = 255)
|
||||
private String convertId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "request_id", nullable = false, length = 255)
|
||||
private String requestId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "track_id", nullable = false, length = 255)
|
||||
private String trackId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "os", nullable = false, length = 255)
|
||||
private String os;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ua", nullable = false, length = 255)
|
||||
private String ua;
|
||||
|
||||
@Basic
|
||||
@Column(name = "geo", nullable = false, length = 255)
|
||||
private String geo;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ts", nullable = false, length = 255)
|
||||
private String ts;
|
||||
|
||||
@Basic
|
||||
@Column(name = "model", nullable = false, length = 255)
|
||||
private String model;
|
||||
|
||||
@Basic
|
||||
@Column(name = "imei", nullable = false, length = 255)
|
||||
private String imei;
|
||||
|
||||
@Basic
|
||||
@Column(name = "idfa", nullable = false, length = 255)
|
||||
private String idfa;
|
||||
|
||||
@Basic
|
||||
@Column(name = "idfa_md5", nullable = false, length = 255)
|
||||
private String idfaMD5;
|
||||
|
||||
@Basic
|
||||
@Column(name = "oaid", nullable = false, length = 255)
|
||||
private String oaid;
|
||||
|
||||
@Basic
|
||||
@Column(name = "oaid_md5", nullable = false, length = 255)
|
||||
private String oaidMD5;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mac", nullable = false, length = 255)
|
||||
private String mac;
|
||||
|
||||
@Basic
|
||||
@Column(name = "callback_param", nullable = false, length = 255)
|
||||
private String callbackParam;
|
||||
|
||||
@Basic
|
||||
@Column(name = "callback_url", nullable = false, length = 255)
|
||||
private String callbackUrl;
|
||||
|
||||
@Basic
|
||||
@Column(name = "advertiser_id", nullable = false, length = 255)
|
||||
private String advertiserId;
|
||||
|
||||
|
||||
/**
|
||||
* 用于监测链接的自定义带参格式 - 一个公司一个业务一个 tag
|
||||
*/
|
||||
@Basic
|
||||
@Column(name = "tag", nullable = false, length = 255)
|
||||
private String tag;
|
||||
|
||||
|
||||
/**
|
||||
* 用于区分广告配置的地方
|
||||
* 巨量
|
||||
* 展示 - 1
|
||||
* 有效触点 - 2
|
||||
* 视频播放 - 3
|
||||
* 完播 - 4
|
||||
* 有效播放 - 5
|
||||
*/
|
||||
@Basic
|
||||
@Column(name = "vpoint", nullable = false)
|
||||
private Integer vpoint;
|
||||
|
||||
}
|
||||
@ -0,0 +1,179 @@
|
||||
package com.baiyee.adcallback.repository.entity;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import lombok.Data;
|
||||
import org.springframework.data.annotation.CreatedDate;
|
||||
import org.springframework.data.annotation.LastModifiedBy;
|
||||
import org.springframework.data.annotation.LastModifiedDate;
|
||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
||||
import javax.persistence.*;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author q
|
||||
*/
|
||||
@Entity
|
||||
@Table(name = "tb_jl_v2_backdata", schema = "db_ad", catalog = "")
|
||||
@Data
|
||||
@EntityListeners(AuditingEntityListener.class)
|
||||
public class TbJLBackDataV2Entity {
|
||||
|
||||
@Id
|
||||
@Column(name = "id", nullable = false)
|
||||
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||
private long id;
|
||||
|
||||
@CreatedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Column(name = "gmt_create", nullable = false)
|
||||
private Date gmtCreate;
|
||||
|
||||
@LastModifiedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Column(name = "gmt_modify", nullable = false)
|
||||
private Date gmtModify;
|
||||
|
||||
@LastModifiedBy
|
||||
@Column(name = "operator", nullable = false, length = 255)
|
||||
private String operator;
|
||||
|
||||
@Basic
|
||||
@Column(name = "promotion_id", nullable = false, length = 255)
|
||||
private String promotionId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "project_id", nullable = false, length = 255)
|
||||
private String projectId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "promotion_name", nullable = false, length = 255)
|
||||
private String promotionName;
|
||||
|
||||
@Basic
|
||||
@Column(name = "project_name", nullable = false, length = 255)
|
||||
private String projectName;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mid1", nullable = false, length = 255)
|
||||
private String mid1;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mid2", nullable = false, length = 255)
|
||||
private String mid2;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mid3", nullable = false, length = 255)
|
||||
private String mid3;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mid4", nullable = false, length = 255)
|
||||
private String mid4;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mid5", nullable = false, length = 255)
|
||||
private String mid5;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mid6", nullable = false, length = 255)
|
||||
private String mid6;
|
||||
|
||||
@Basic
|
||||
@Column(name = "csite", nullable = false, length = 255)
|
||||
private String csite;
|
||||
|
||||
@Basic
|
||||
@Column(name = "convert_id", nullable = false, length = 255)
|
||||
private String convertId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "request_id", nullable = false, length = 255)
|
||||
private String requestId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "track_id", nullable = false, length = 255)
|
||||
private String trackId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "os", nullable = false, length = 255)
|
||||
private String os;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ua", nullable = false, length = 255)
|
||||
private String ua;
|
||||
|
||||
@Basic
|
||||
@Column(name = "geo", nullable = false, length = 255)
|
||||
private String geo;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ts", nullable = false, length = 255)
|
||||
private String ts;
|
||||
|
||||
@Basic
|
||||
@Column(name = "model", nullable = false, length = 255)
|
||||
private String model;
|
||||
|
||||
@Basic
|
||||
@Column(name = "imei", nullable = false, length = 255)
|
||||
private String imei;
|
||||
|
||||
@Basic
|
||||
@Column(name = "idfa", nullable = false, length = 255)
|
||||
private String idfa;
|
||||
|
||||
@Basic
|
||||
@Column(name = "idfa_md5", nullable = false, length = 255)
|
||||
private String idfaMD5;
|
||||
|
||||
@Basic
|
||||
@Column(name = "oaid", nullable = false, length = 255)
|
||||
private String oaid;
|
||||
|
||||
@Basic
|
||||
@Column(name = "oaid_md5", nullable = false, length = 255)
|
||||
private String oaidMD5;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mac", nullable = false, length = 255)
|
||||
private String mac;
|
||||
|
||||
@Basic
|
||||
@Column(name = "callback_param", nullable = false, length = 255)
|
||||
private String callbackParam;
|
||||
|
||||
@Basic
|
||||
@Column(name = "callback_url", nullable = false, length = 255)
|
||||
private String callbackUrl;
|
||||
|
||||
@Basic
|
||||
@Column(name = "advertiser_id", nullable = false, length = 255)
|
||||
private String advertiserId;
|
||||
|
||||
|
||||
/**
|
||||
* 用于监测链接的自定义带参格式 - 一个公司一个业务一个 tag
|
||||
*/
|
||||
@Basic
|
||||
@Column(name = "tag", nullable = false, length = 255)
|
||||
private String tag;
|
||||
|
||||
|
||||
/**
|
||||
* 用于区分广告配置的地方
|
||||
* 巨量
|
||||
* 展示 - 1
|
||||
* 有效触点 - 2
|
||||
* 视频播放 - 3
|
||||
* 完播 - 4
|
||||
* 有效播放 - 5
|
||||
*/
|
||||
@Basic
|
||||
@Column(name = "vpoint", nullable = false)
|
||||
private Integer vpoint;
|
||||
|
||||
}
|
||||
@ -0,0 +1,141 @@
|
||||
package com.baiyee.adcallback.repository.entity;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import lombok.Data;
|
||||
import org.springframework.data.annotation.CreatedDate;
|
||||
import org.springframework.data.annotation.LastModifiedBy;
|
||||
import org.springframework.data.annotation.LastModifiedDate;
|
||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
||||
import javax.persistence.*;
|
||||
import java.sql.Timestamp;
|
||||
|
||||
@Entity
|
||||
@Table(name = "tb_ks_new_backdata", schema = "db_ad", catalog = "")
|
||||
@EntityListeners(AuditingEntityListener.class)
|
||||
@Data
|
||||
public class TbKSNewBackdataEntity {
|
||||
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||
@Id
|
||||
@Column(name = "id", nullable = false)
|
||||
private long id;
|
||||
|
||||
@CreatedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Basic
|
||||
@Column(name = "gmt_create", nullable = false)
|
||||
private Timestamp gmtCreate;
|
||||
|
||||
@LastModifiedDate
|
||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
@Basic
|
||||
@Column(name = "gmt_modify", nullable = false)
|
||||
private Timestamp gmtModify;
|
||||
|
||||
@LastModifiedBy
|
||||
@Basic
|
||||
@Column(name = "operation", nullable = false, length = 255)
|
||||
private String operation;
|
||||
@Basic
|
||||
@Column(name = "account_id", nullable = false, length = 255)
|
||||
private String accountId;
|
||||
@Basic
|
||||
@Column(name = "aid", nullable = false, length = 255)
|
||||
private String aid;
|
||||
@Basic
|
||||
@Column(name = "cid", nullable = false, length = 255)
|
||||
private String cid;
|
||||
@Basic
|
||||
@Column(name = "did", nullable = false, length = 255)
|
||||
private String did;
|
||||
@Basic
|
||||
@Column(name = "dname", nullable = false, length = 255)
|
||||
private String dName;
|
||||
|
||||
@Basic
|
||||
@Column(name = "photo_id", nullable = false, length = 255)
|
||||
private String photoId;
|
||||
|
||||
@Basic
|
||||
@Column(name = "oaid", nullable = false, length = 255)
|
||||
private String oaid;
|
||||
@Basic
|
||||
@Column(name = "imei", nullable = false, length = 255)
|
||||
private String imei;
|
||||
|
||||
@Basic
|
||||
@Column(name = "imei_hash", nullable = false, length = 255)
|
||||
private String imeiHash;
|
||||
|
||||
@Basic
|
||||
@Column(name = "idfa", nullable = false, length = 255)
|
||||
private String idfa;
|
||||
|
||||
@Basic
|
||||
@Column(name = "idfa_hash", nullable = false, length = 255)
|
||||
private String idfaHash;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mac_bak", nullable = false, length = 255)
|
||||
private String macBak;
|
||||
|
||||
@Basic
|
||||
@Column(name = "mac", nullable = false, length = 255)
|
||||
private String mac;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ts", nullable = false, length = 255)
|
||||
private String ts;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ua", nullable = false, length = 255)
|
||||
private String ua;
|
||||
|
||||
@Basic
|
||||
@Column(name = "os", nullable = false, length = 255)
|
||||
private String os;
|
||||
|
||||
@Basic
|
||||
@Column(name = "model", nullable = false, length = 255)
|
||||
private String model;
|
||||
|
||||
@Basic
|
||||
@Column(name = "call_back", nullable = false, length = 255)
|
||||
private String callBack;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ip", nullable = false, length = 255)
|
||||
private String ip;
|
||||
|
||||
@Basic
|
||||
@Column(name = "csite", nullable = false, length = 255)
|
||||
private String csite;
|
||||
|
||||
@Basic
|
||||
@Column(name = "ac_creative", nullable = false, length = 255)
|
||||
private String acCreative;
|
||||
|
||||
@Basic
|
||||
@Column(name = "win_for_id", nullable = false, length = 255)
|
||||
private String winForId;
|
||||
@Basic
|
||||
@Column(name = "tag", nullable = false, length = 255)
|
||||
private String tag;
|
||||
|
||||
/**
|
||||
* 用于区分广告配置的地方
|
||||
* 巨量
|
||||
* 展示 - 1
|
||||
* 有效触点 - 2
|
||||
* 视频播放 - 3
|
||||
* 完播 - 4
|
||||
* 有效播放 - 5
|
||||
*/
|
||||
@Basic
|
||||
@Column(name = "vpoint", nullable = false)
|
||||
private Integer vpoint;
|
||||
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
package com.baiyee.adcallback.service;
|
||||
|
||||
import com.baiyee.adcallback.api.vo.*;
|
||||
|
||||
public interface AdTFPackageService {
|
||||
|
||||
void loadBDPackageData(BDMobileMonitorCallbackRequestNewVO vo);
|
||||
|
||||
void loadGDTPackageData(GdtMobileMonitorCallbackRequestNewVO vo);
|
||||
|
||||
void loadJLTFV1PackageData(JuliangMobileMonitorCallbackRequestNewV1VO vo);
|
||||
|
||||
|
||||
void loadJLTFV2PackageData(JuliangMobileMonitorCallbackRequestNewV2VO vo);
|
||||
|
||||
void loadKSTFPackageData(KSNewMobileMonitorCallbackRequestVO vo);
|
||||
}
|
||||
@ -0,0 +1,54 @@
|
||||
package com.baiyee.adcallback.service.impl;
|
||||
|
||||
import com.baiyee.adcallback.api.constants.VpointEnum;
|
||||
import com.baiyee.adcallback.api.vo.*;
|
||||
import com.baiyee.adcallback.service.AdTFPackageService;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
@Slf4j
|
||||
public class AdJLTFPackageServiceImpl implements AdTFPackageService {
|
||||
|
||||
@Override
|
||||
public void loadBDPackageData(BDMobileMonitorCallbackRequestNewVO vo) {
|
||||
// log - 埋点
|
||||
log.info("================================= [finish check, do data loading, AdJLTFPackageServiceImpl|loadBDPackageData, tag is {} , vpoint is {}] =================================",
|
||||
vo.getTag(), VpointEnum.vPointCodeConvertStatus(vo.getVpoint()));
|
||||
// TODO: 2023/5/26 0026
|
||||
}
|
||||
@Override
|
||||
public void loadKSTFPackageData(KSNewMobileMonitorCallbackRequestVO vo) {
|
||||
// log - 埋点
|
||||
log.info("================================= [finish check, do data loading, AdJLTFPackageServiceImpl|loadKSTFPackageData, tag is {} , vpoint is {}] =================================",
|
||||
vo.getTag(), VpointEnum.vPointCodeConvertStatus(vo.getVpoint()));
|
||||
// TODO: 2023/5/26 0026
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void loadGDTPackageData(GdtMobileMonitorCallbackRequestNewVO vo) {
|
||||
// log - 埋点
|
||||
log.info("================================= [finish check, do data loading, AdJLTFPackageServiceImpl|loadGDTPackageData, tag is {} , vpoint is {}] =================================",
|
||||
vo.getTag(), VpointEnum.vPointCodeConvertStatus(vo.getVpoint()));
|
||||
// TODO: 2023/5/26 0026
|
||||
}
|
||||
|
||||
@Override
|
||||
public void loadJLTFV1PackageData(JuliangMobileMonitorCallbackRequestNewV1VO vo) {
|
||||
// log - 埋点
|
||||
log.info("================================= [finish check, do data loading, AdJLTFPackageServiceImpl|loadJLTFV1PackageData, tag is {} , vpoint is {}] =================================",
|
||||
vo.getTag(), VpointEnum.vPointCodeConvertStatus(vo.getVpoint()));
|
||||
// TODO: 2023/5/18 0018
|
||||
}
|
||||
|
||||
@Override
|
||||
public void loadJLTFV2PackageData(JuliangMobileMonitorCallbackRequestNewV2VO vo) {
|
||||
// log - 埋点
|
||||
log.info("================================= [finish check, do data loading, AdJLTFPackageServiceImpl|loadJLTFV2PackageData, tag is {} , vpoint is {}] =================================",
|
||||
vo.getTag(), VpointEnum.vPointCodeConvertStatus(vo.getVpoint()));
|
||||
// TODO: 2023/5/18 0018
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue