初始化推送记录表结构

2 years ago · d92f547e93
parent 3a0c91c7dd
commit d92f547e93
3 changed files with 179 additions and 0 deletions
--- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/dao/PushInfoRecordMapper.java
+++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/dao/PushInfoRecordMapper.java
@ -0,0 +1,19 @@
+package com.dxhy.order.consumer.dao;
+
+import com.dxhy.order.consumer.model.PushInfoRecord;
+
+public interface PushInfoRecordMapper {
+    int deleteByPrimaryKey(Long id);
+
+    int insert(PushInfoRecord record);
+
+    int insertSelective(PushInfoRecord record);
+
+    PushInfoRecord selectByPrimaryKey(Long id);
+
+    int updateByPrimaryKeySelective(PushInfoRecord record);
+
+    int updateByPrimaryKeyWithBLOBs(PushInfoRecord record);
+
+    int updateByPrimaryKey(PushInfoRecord record);
+}
--- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/model/PushInfoRecord.java
+++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/model/PushInfoRecord.java
@ -0,0 +1,24 @@
+package com.dxhy.order.consumer.model;
+
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class PushInfoRecord {
+    private Long id;
+
+    private String interfacePushType;
+
+    private String qyType;
+
+    private String pushStatus;
+
+    private Date createTime;
+
+    private String pushContent;
+
+    private String result;
+
+    private String failReason;
+}
--- a/order-management-consumer/src/main/resources/mybatis/mapper/PushInfoRecordMapper.xml
+++ b/order-management-consumer/src/main/resources/mybatis/mapper/PushInfoRecordMapper.xml
@ -0,0 +1,136 @@
+<?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.dxhy.order.consumer.dao.PushInfoRecordMapper" >
+  <resultMap id="BaseResultMap" type="com.dxhy.order.consumer.model.PushInfoRecord" >
+    <id column="id" property="id" jdbcType="BIGINT" />
+    <result column="interface_push_type" property="interfacePushType" jdbcType="VARCHAR" />
+    <result column="qy_type" property="qyType" jdbcType="VARCHAR" />
+    <result column="push_status" property="pushStatus" jdbcType="VARCHAR" />
+    <result column="create_time" property="createTime" jdbcType="TIMESTAMP" />
+    <result column="push_content" property="pushContent" jdbcType="LONGVARCHAR" />
+    <result column="result" property="result" jdbcType="LONGVARCHAR" />
+    <result column="fail_reason" property="failReason" jdbcType="LONGVARCHAR" />
+  </resultMap>
+  <sql id="Base_Column_List" >
+    id, interface_push_type, qy_type, push_status, create_time,push_content, result, fail_reason
+  </sql>
+  <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Long" >
+    select 
+    <include refid="Base_Column_List" />
+    from push_info_record
+    where id = #{id,jdbcType=BIGINT}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long" >
+    delete from push_info_record
+    where id = #{id,jdbcType=BIGINT}
+  </delete>
+  <insert id="insert" parameterType="com.dxhy.order.consumer.model.PushInfoRecord" >
+    insert into push_info_record (id, interface_push_type, qy_type, 
+      push_status, create_time, push_content, 
+      result, fail_reason)
+    values (#{id,jdbcType=BIGINT}, #{interfacePushType,jdbcType=VARCHAR}, #{qyType,jdbcType=VARCHAR}, 
+      #{pushStatus,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP}, #{pushContent,jdbcType=LONGVARCHAR}, 
+      #{result,jdbcType=LONGVARCHAR}, #{failReason,jdbcType=LONGVARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.dxhy.order.consumer.model.PushInfoRecord" >
+    insert into push_info_record
+    <trim prefix="(" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        id,
+      </if>
+      <if test="interfacePushType != null" >
+        interface_push_type,
+      </if>
+      <if test="qyType != null" >
+        qy_type,
+      </if>
+      <if test="pushStatus != null" >
+        push_status,
+      </if>
+      <if test="createTime != null" >
+        create_time,
+      </if>
+      <if test="pushContent != null" >
+        push_content,
+      </if>
+      <if test="result != null" >
+        result,
+      </if>
+      <if test="failReason != null" >
+        fail_reason,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        #{id,jdbcType=BIGINT},
+      </if>
+      <if test="interfacePushType != null" >
+        #{interfacePushType,jdbcType=VARCHAR},
+      </if>
+      <if test="qyType != null" >
+        #{qyType,jdbcType=VARCHAR},
+      </if>
+      <if test="pushStatus != null" >
+        #{pushStatus,jdbcType=VARCHAR},
+      </if>
+      <if test="createTime != null" >
+        #{createTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="pushContent != null" >
+        #{pushContent,jdbcType=LONGVARCHAR},
+      </if>
+      <if test="result != null" >
+        #{result,jdbcType=LONGVARCHAR},
+      </if>
+      <if test="failReason != null" >
+        #{failReason,jdbcType=LONGVARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.dxhy.order.consumer.model.PushInfoRecord" >
+    update push_info_record
+    <set >
+      <if test="interfacePushType != null" >
+        interface_push_type = #{interfacePushType,jdbcType=VARCHAR},
+      </if>
+      <if test="qyType != null" >
+        qy_type = #{qyType,jdbcType=VARCHAR},
+      </if>
+      <if test="pushStatus != null" >
+        push_status = #{pushStatus,jdbcType=VARCHAR},
+      </if>
+      <if test="createTime != null" >
+        create_time = #{createTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="pushContent != null" >
+        push_content = #{pushContent,jdbcType=LONGVARCHAR},
+      </if>
+      <if test="result != null" >
+        result = #{result,jdbcType=LONGVARCHAR},
+      </if>
+      <if test="failReason != null" >
+        fail_reason = #{failReason,jdbcType=LONGVARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+  <update id="updateByPrimaryKeyWithBLOBs" parameterType="com.dxhy.order.consumer.model.PushInfoRecord" >
+    update push_info_record
+    set interface_push_type = #{interfacePushType,jdbcType=VARCHAR},
+      qy_type = #{qyType,jdbcType=VARCHAR},
+      push_status = #{pushStatus,jdbcType=VARCHAR},
+      create_time = #{createTime,jdbcType=TIMESTAMP},
+      push_content = #{pushContent,jdbcType=LONGVARCHAR},
+      result = #{result,jdbcType=LONGVARCHAR},
+      fail_reason = #{failReason,jdbcType=LONGVARCHAR}
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.dxhy.order.consumer.model.PushInfoRecord" >
+    update push_info_record
+    set interface_push_type = #{interfacePushType,jdbcType=VARCHAR},
+      qy_type = #{qyType,jdbcType=VARCHAR},
+      push_status = #{pushStatus,jdbcType=VARCHAR},
+      create_time = #{createTime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+</mapper>