YOHOBUY / yohobuy-union · Commits

Go to a project

Authored by linlong
Commit 5295933abca650de384b8dd55e6f67b30c57dd2f 1 parent 5dd117dd

update

Inline Side-by-side
Showing 6 changed files with 282 additions and 0 deletions
package com.yoho.unions.dal;
import com.yoho.unions.dal.model.UnionCallbackLogs;
public interface IUnionCallbackLogsDAO {
int deleteByPrimaryKey(Integer id);
int insert(UnionCallbackLogs record);
int insertSelective(UnionCallbackLogs record);
UnionCallbackLogs selectByPrimaryKey(Integer id);
int updateByPrimaryKeySelective(UnionCallbackLogs record);
int updateByPrimaryKey(UnionCallbackLogs record);
}
\ No newline at end of file
... ...
package com.yoho.unions.dal.model;
public class UnionCallbackLogs {
private Integer id;
private String unionType;
private String unionName;
private String url;
private String result;
private String idfa;
private String imei;
private String udid;
private Integer createtime;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getUnionType() {
return unionType;
}
public void setUnionType(String unionType) {
this.unionType = unionType == null ? null : unionType.trim();
}
public String getUnionName() {
return unionName;
}
public void setUnionName(String unionName) {
this.unionName = unionName == null ? null : unionName.trim();
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url == null ? null : url.trim();
}
public String getResult() {
return result;
}
public void setResult(String result) {
this.result = result == null ? null : result.trim();
}
public String getIdfa() {
return idfa;
}
public void setIdfa(String idfa) {
this.idfa = idfa == null ? null : idfa.trim();
}
public String getImei() {
return imei;
}
public void setImei(String imei) {
this.imei = imei == null ? null : imei.trim();
}
public String getUdid() {
return udid;
}
public void setUdid(String udid) {
this.udid = udid == null ? null : udid.trim();
}
public Integer getCreatetime() {
return createtime;
}
public void setCreatetime(Integer createtime) {
this.createtime = createtime;
}
}
\ No newline at end of file
... ...
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.yoho.unions.dal.IUnionCallbackLogsDAO" >
<resultMap id="BaseResultMap" type="com.yoho.unions.dal.model.UnionCallbackLogs" >
<id column="id" property="id" jdbcType="INTEGER" />
<result column="union_type" property="unionType" jdbcType="VARCHAR" />
<result column="union_name" property="unionName" jdbcType="VARCHAR" />
<result column="url" property="url" jdbcType="VARCHAR" />
<result column="result" property="result" jdbcType="VARCHAR" />
<result column="idfa" property="idfa" jdbcType="VARCHAR" />
<result column="imei" property="imei" jdbcType="VARCHAR" />
<result column="udid" property="udid" jdbcType="VARCHAR" />
<result column="createTime" property="createtime" jdbcType="INTEGER" />
</resultMap>
<sql id="Base_Column_List" >
id, union_type, union_name, url, result, idfa, imei, udid, createTime
</sql>
<select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
select
<include refid="Base_Column_List" />
from union_callback_logs
where id = #{id,jdbcType=INTEGER}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
delete from union_callback_logs
where id = #{id,jdbcType=INTEGER}
</delete>
<insert id="insert" parameterType="com.yoho.unions.dal.model.UnionCallbackLogs" >
insert into union_callback_logs (id, union_type, union_name,
url, result, idfa,
imei, udid, createTime
)
values (#{id,jdbcType=INTEGER}, #{unionType,jdbcType=VARCHAR}, #{unionName,jdbcType=VARCHAR},
#{url,jdbcType=VARCHAR}, #{result,jdbcType=VARCHAR}, #{idfa,jdbcType=VARCHAR},
#{imei,jdbcType=VARCHAR}, #{udid,jdbcType=VARCHAR}, #{createtime,jdbcType=INTEGER}
)
</insert>
<insert id="insertSelective" parameterType="com.yoho.unions.dal.model.UnionCallbackLogs" >
insert into union_callback_logs
<trim prefix="(" suffix=")" suffixOverrides="," >
<if test="id != null" >
id,
</if>
<if test="unionType != null" >
union_type,
</if>
<if test="unionName != null" >
union_name,
</if>
<if test="url != null" >
url,
</if>
<if test="result != null" >
result,
</if>
<if test="idfa != null" >
idfa,
</if>
<if test="imei != null" >
imei,
</if>
<if test="udid != null" >
udid,
</if>
<if test="createtime != null" >
createTime,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides="," >
<if test="id != null" >
#{id,jdbcType=INTEGER},
</if>
<if test="unionType != null" >
#{unionType,jdbcType=VARCHAR},
</if>
<if test="unionName != null" >
#{unionName,jdbcType=VARCHAR},
</if>
<if test="url != null" >
#{url,jdbcType=VARCHAR},
</if>
<if test="result != null" >
#{result,jdbcType=VARCHAR},
</if>
<if test="idfa != null" >
#{idfa,jdbcType=VARCHAR},
</if>
<if test="imei != null" >
#{imei,jdbcType=VARCHAR},
</if>
<if test="udid != null" >
#{udid,jdbcType=VARCHAR},
</if>
<if test="createtime != null" >
#{createtime,jdbcType=INTEGER},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.yoho.unions.dal.model.UnionCallbackLogs" >
update union_callback_logs
<set >
<if test="unionType != null" >
union_type = #{unionType,jdbcType=VARCHAR},
</if>
<if test="unionName != null" >
union_name = #{unionName,jdbcType=VARCHAR},
</if>
<if test="url != null" >
url = #{url,jdbcType=VARCHAR},
</if>
<if test="result != null" >
result = #{result,jdbcType=VARCHAR},
</if>
<if test="idfa != null" >
idfa = #{idfa,jdbcType=VARCHAR},
</if>
<if test="imei != null" >
imei = #{imei,jdbcType=VARCHAR},
</if>
<if test="udid != null" >
udid = #{udid,jdbcType=VARCHAR},
</if>
<if test="createtime != null" >
createTime = #{createtime,jdbcType=INTEGER},
</if>
</set>
where id = #{id,jdbcType=INTEGER}
</update>
<update id="updateByPrimaryKey" parameterType="com.yoho.unions.dal.model.UnionCallbackLogs" >
update union_callback_logs
set union_type = #{unionType,jdbcType=VARCHAR},
union_name = #{unionName,jdbcType=VARCHAR},
url = #{url,jdbcType=VARCHAR},
result = #{result,jdbcType=VARCHAR},
idfa = #{idfa,jdbcType=VARCHAR},
imei = #{imei,jdbcType=VARCHAR},
udid = #{udid,jdbcType=VARCHAR},
createTime = #{createtime,jdbcType=INTEGER}
where id = #{id,jdbcType=INTEGER}
</update>
</mapper>
\ No newline at end of file
... ...
... ... @@ -91,6 +91,9 @@ public class UnionServiceImpl implements IUnionService,ApplicationEventPublisher
IUnionLogsDAO unionLogsDAO;
@Resource
IUnionCallbackLogsDAO unionCallbackLogsDAO;
@Resource
IAppActivateIdfaListDAO appActivateIdfaListDAO;
@Resource
... ... @@ -546,6 +549,22 @@ public class UnionServiceImpl implements IUnionService,ApplicationEventPublisher
activeUnion.info("activateUnion in call url={}", url);
//改成httpclient方式调用
Pair<Integer, String> pair = HttpUtils.httpGet(url);
try{
UnionCallbackLogs unionCallbackLogs = new UnionCallbackLogs();
unionCallbackLogs.setUnionName(mktMarketingUrl.getName());
unionCallbackLogs.setUnionType(click.getUnion_type());
unionCallbackLogs.setUdid(request.getUdid());
unionCallbackLogs.setUrl(url);
unionCallbackLogs.setIdfa(request.getIdfa());
unionCallbackLogs.setImei(request.getImei());
unionCallbackLogs.setResult(pair.toString());
unionCallbackLogs.setCreatetime(DateUtils.getCurrentTimeSecond());
saveUnionCallbackLogs(unionCallbackLogs);
}catch (Exception e){
log.warn("save union_callback_logs e={}", e.getMessage());
}
activeUnion.info("activateUnion call union success url={}, and result={}", url, pair);
if (pair.getLeft() != 200) {
log.warn("callback error with request={}", request);
... ... @@ -573,6 +592,16 @@ public class UnionServiceImpl implements IUnionService,ApplicationEventPublisher
}
private void saveUnionCallbackLogs(UnionCallbackLogs unionCallbackLogs) {
taskExecutor.execute(new Runnable() {
@Override
public void run()
{
unionCallbackLogsDAO.insertSelective(unionCallbackLogs);
}
});
}
@Override
public PageActivateDeviceIdRspBO queryActivateDeviceId(ActivateDeviceIdReqBO activateDeviceIdReqBO) {
log.info("enter queryActivateDeviceId. param activateDeviceIdReqBO={}", activateDeviceIdReqBO);
... ...
... ... @@ -16,6 +16,7 @@ datasources:
- com.yoho.unions.dal.IUnionLogsDAO
- com.yoho.unions.dal.IUnionClickLogsDAO
- com.yoho.unions.dal.IUnionActivityLogsDAO
- com.yoho.unions.dal.IUnionCallbackLogsDAO
app:
servers:
... ...
... ... @@ -16,6 +16,7 @@ datasources:
- com.yoho.unions.dal.IUnionLogsDAO
- com.yoho.unions.dal.IUnionClickLogsDAO
- com.yoho.unions.dal.IUnionActivityLogsDAO
- com.yoho.unions.dal.IUnionCallbackLogsDAO
app:
... ...