Authored by gemingdan

头条上报ufo订单

... ... @@ -24,6 +24,7 @@ public class AppYohoToutiaoNewUid {
private Integer createTime;
private Integer dateId;
private Integer isUfo;
public String getOrderCode() {
return orderCode;
... ... @@ -120,4 +121,12 @@ public class AppYohoToutiaoNewUid {
public void setDateId(Integer dateId) {
this.dateId = dateId;
}
public Integer getIsUfo() {
return isUfo;
}
public void setIsUfo(Integer isUfo) {
this.isUfo = isUfo;
}
}
\ No newline at end of file
... ...
... ... @@ -27,6 +27,8 @@ public class UnionCallbackOrder {
private Integer isCallback;
private Integer isUfo;
public String getOrderCode() {
return orderCode;
}
... ... @@ -130,4 +132,12 @@ public class UnionCallbackOrder {
public void setIsCallback(Integer isCallback) {
this.isCallback = isCallback;
}
public Integer getIsUfo() {
return isUfo;
}
public void setIsUfo(Integer isUfo) {
this.isUfo = isUfo;
}
}
\ No newline at end of file
... ...
... ... @@ -14,10 +14,11 @@
<result column="source" property="source" jdbcType="INTEGER" />
<result column="create_time" property="createTime" jdbcType="INTEGER" />
<result column="date_id" property="dateId" jdbcType="INTEGER" />
<result column="is_ufo" property="isUfo" jdbcType="INTEGER" />
</resultMap>
<sql id="Base_Column_List" >
order_code, wakeup_date, udid, client_type, idfa, imei, order_time, uid, union_type,
source, create_time, date_id
source, create_time, date_id,is_ufo
</sql>
<select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.String" >
select
... ... @@ -44,12 +45,12 @@
insert into app_yoho_toutiao_new_uid (order_code, wakeup_date, udid,
client_type, idfa, imei,
order_time, uid, union_type,
source, create_time, date_id
source, create_time, date_id,is_ufo
)
values (#{orderCode,jdbcType=VARCHAR}, #{wakeupDate,jdbcType=INTEGER}, #{udid,jdbcType=VARCHAR},
#{clientType,jdbcType=INTEGER}, #{idfa,jdbcType=VARCHAR}, #{imei,jdbcType=VARCHAR},
#{orderTime,jdbcType=INTEGER}, #{uid,jdbcType=INTEGER}, #{unionType,jdbcType=VARCHAR},
#{source,jdbcType=INTEGER}, #{createTime,jdbcType=INTEGER}, #{dateId,jdbcType=INTEGER}
#{source,jdbcType=INTEGER}, #{createTime,jdbcType=INTEGER}, #{dateId,jdbcType=INTEGER}, #{isUfo,jdbcType=INTEGER}
)
</insert>
<insert id="insertSelective" parameterType="com.yoho.unions.dal.model.AppYohoToutiaoNewUid" >
... ... @@ -91,6 +92,9 @@
<if test="dateId != null" >
date_id,
</if>
<if test="isUfo != null" >
is_ufo,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides="," >
<if test="orderCode != null" >
... ... @@ -129,6 +133,9 @@
<if test="dateId != null" >
#{dateId,jdbcType=INTEGER},
</if>
<if test="isUfo != null" >
#{isUfo,jdbcType=INTEGER},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.yoho.unions.dal.model.AppYohoToutiaoNewUid" >
... ... @@ -167,6 +174,9 @@
<if test="dateId != null" >
date_id = #{dateId,jdbcType=INTEGER},
</if>
<if test="isUfo != null" >
is_ufo = #{isUfo,jdbcType=INTEGER},
</if>
</set>
where order_code = #{orderCode,jdbcType=VARCHAR}
</update>
... ... @@ -182,6 +192,7 @@
union_type = #{unionType,jdbcType=VARCHAR},
source = #{source,jdbcType=INTEGER},
create_time = #{createTime,jdbcType=INTEGER},
is_ufo = #{isUfo,jdbcType=INTEGER},
date_id = #{dateId,jdbcType=INTEGER}
where order_code = #{orderCode,jdbcType=VARCHAR}
</update>
... ...
... ... @@ -15,10 +15,11 @@
<result column="create_time" property="createTime" jdbcType="INTEGER" />
<result column="callback_time" property="callbackTime" jdbcType="INTEGER" />
<result column="is_callback" property="isCallback" jdbcType="INTEGER" />
<result column="is_ufo" property="isUfo" jdbcType="INTEGER" />
</resultMap>
<sql id="Base_Column_List" >
order_code, date_id, uid, udid, client_type, idfa, order_time, wakeup_date,
union_type, source, create_time, callback_time, is_callback
union_type, source, create_time, callback_time, is_callback,is_ufo
</sql>
<select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.String" >
select
... ... @@ -43,12 +44,12 @@
udid, client_type, idfa,
order_time, wakeup_date,
union_type, source, create_time,
callback_time, is_callback)
callback_time, is_callback, is_ufo)
values (#{orderCode,jdbcType=VARCHAR}, #{dateId,jdbcType=INTEGER}, #{uid,jdbcType=INTEGER},
#{udid,jdbcType=VARCHAR}, #{clientType,jdbcType=INTEGER}, #{idfa,jdbcType=VARCHAR},
#{orderTime,jdbcType=INTEGER}, #{wakeupDate,jdbcType=INTEGER},
#{unionType,jdbcType=VARCHAR}, #{source,jdbcType=INTEGER}, #{createTime,jdbcType=INTEGER},
#{callbackTime,jdbcType=INTEGER}, #{isCallback,jdbcType=INTEGER})
#{callbackTime,jdbcType=INTEGER}, #{isCallback,jdbcType=INTEGER}, #{is_ufo,jdbcType=INTEGER})
</insert>
<insert id="insertSelective" parameterType="com.yoho.unions.dal.model.UnionCallbackOrder" >
insert into union_callback_order
... ... @@ -92,6 +93,9 @@
<if test="isCallback != null" >
is_callback,
</if>
<if test="isUfo != null" >
is_ufo,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides="," >
<if test="orderCode != null" >
... ... @@ -133,6 +137,9 @@
<if test="isCallback != null" >
#{isCallback,jdbcType=INTEGER},
</if>
<if test="isUfo != null" >
#{isUfo,jdbcType=INTEGER},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.yoho.unions.dal.model.UnionCallbackOrder" >
... ... @@ -174,6 +181,9 @@
<if test="isCallback != null" >
is_callback = #{isCallback,jdbcType=INTEGER},
</if>
<if test="isUfo != null" >
is_ufo = #{isUfo,jdbcType=INTEGER},
</if>
</set>
where order_code = #{orderCode,jdbcType=VARCHAR}
</update>
... ... @@ -190,6 +200,7 @@
source = #{source,jdbcType=INTEGER},
create_time = #{createTime,jdbcType=INTEGER},
callback_time = #{callbackTime,jdbcType=INTEGER},
is_ufo = #{isUfo,jdbcType=INTEGER},
is_callback = #{isCallback,jdbcType=INTEGER}
where order_code = #{orderCode,jdbcType=VARCHAR}
</update>
... ...
... ... @@ -61,12 +61,17 @@ public class TouTiaoServiceImpl extends UnionServiceImpl implements IUnionServic
public Pair<Integer, String> visitCallbackUrl(String url, ClickUnionRequestBO clickBO, int type){
try {
//目前只有次留上报走此
if (type != 1) {
return Pair.of(503, "TouTiaoServiceImpl visitCallbackUrl 参数异常");
}
String callbackurl = clickBO.getCallbackurl();
if (StringUtils.isBlank(callbackurl)) {
activeUnion.warn("TouTiaoServiceImpl.visitCallbackUrl end,callbackurl is null,clickBO is {}.",clickBO);
return Pair.of(500, "TouTiaoServiceImpl Callback callbackurl异常");
}
url = callbackurl + "&event_type=6";//6: 次留
activeUnion.info("TouTiaoServiceImpl.visitCallbackUrl,url is {},clickBO is {}.",url,clickBO);
return HttpUtils.httpGet(url);
} catch (Exception e) {
activeUnion.warn("TouTiaoServiceImpl Callback error,clickBO is {},url is {},type is {}.",clickBO,url,type);
... ...