修改MQ消息发送

pull/4/head
fangjiakai 2024-01-11 16:37:22 +08:00
parent 0683b752b6
commit d91e162379
1 changed files with 37 additions and 25 deletions

View File

@ -20,7 +20,10 @@
f.MARK_NAME, f.MARK_NAME,
f.MESSAGE, f.MESSAGE,
f.CREATE_TIME, f.CREATE_TIME,
f.MESSAGE_LOG_ID f.MESSAGE_LOG_ID,
f.TYPE,
f.DIGESTION_FLAG,
f.PLAN_TIME
</sql> </sql>
<!-- 字段用于新增 --> <!-- 字段用于新增 -->
@ -31,7 +34,10 @@
MARK_NAME, MARK_NAME,
MESSAGE, MESSAGE,
CREATE_TIME, CREATE_TIME,
MESSAGE_LOG_ID MESSAGE_LOG_ID,
TYPE,
DIGESTION_FLAG,
PLAN_TIME
</sql> </sql>
<!-- 字段值 --> <!-- 字段值 -->
@ -42,17 +48,20 @@
#{MARK_NAME}, #{MARK_NAME},
#{MESSAGE}, #{MESSAGE},
#{CREATE_TIME}, #{CREATE_TIME},
#{MESSAGE_LOG_ID} #{MESSAGE_LOG_ID},
#{TYPE},
#{DIGESTION_FLAG},
#{PLAN_TIME}
</sql> </sql>
<!-- 新增--> <!-- 新增-->
<insert id="save" parameterType="pd"> <insert id="save" parameterType="pd">
insert into insert into
<include refid="tableName"></include> <include refid="tableName"></include>
( (
<include refid="Field2"></include> <include refid="Field2"></include>
) values ( ) values (
<include refid="FieldValue"></include> <include refid="FieldValue"></include>
) )
</insert> </insert>
@ -61,7 +70,7 @@
delete from delete from
<include refid="tableName"></include> <include refid="tableName"></include>
where where
MESSAGE_LOG_ID = #{MESSAGE_LOG_ID} MESSAGE_LOG_ID = #{MESSAGE_LOG_ID}
</delete> </delete>
<!-- 修改 --> <!-- 修改 -->
@ -69,15 +78,18 @@
update update
<include refid="tableName"></include> <include refid="tableName"></include>
set set
ID = #{ID}, ID = #{ID},
PRODUCER_NAME = #{PRODUCER_NAME}, PRODUCER_NAME = #{PRODUCER_NAME},
MARK = #{MARK}, MARK = #{MARK},
MARK_NAME = #{MARK_NAME}, MARK_NAME = #{MARK_NAME},
MESSAGE = #{MESSAGE}, MESSAGE = #{MESSAGE},
CREATE_TIME = #{CREATE_TIME}, CREATE_TIME = #{CREATE_TIME},
MESSAGE_LOG_ID = MESSAGE_LOG_ID TYPE = #{TYPE},
DIGESTION_FLAG = #{DIGESTION_FLAG},
PLAN_TIME = #{PLAN_TIME},
MESSAGE_LOG_ID = MESSAGE_LOG_ID
where where
MESSAGE_LOG_ID = #{MESSAGE_LOG_ID} MESSAGE_LOG_ID = #{MESSAGE_LOG_ID}
</update> </update>
<!-- 通过ID获取数据 --> <!-- 通过ID获取数据 -->
@ -87,7 +99,7 @@
from from
<include refid="tableName"></include> f <include refid="tableName"></include> f
where where
f.MESSAGE_LOG_ID = #{MESSAGE_LOG_ID} f.MESSAGE_LOG_ID = #{MESSAGE_LOG_ID}
</select> </select>
<!-- 列表 --> <!-- 列表 -->
@ -99,13 +111,13 @@
where 1=1 where 1=1
<if test="pd.KEYWORDS != null and pd.KEYWORDS != ''"><!-- 关键词检索 --> <if test="pd.KEYWORDS != null and pd.KEYWORDS != ''"><!-- 关键词检索 -->
and and
( (
<!-- 根据需求自己加检索条件 <!-- 根据需求自己加检索条件
字段1 LIKE '%'+ #{pd.KEYWORDS}+'%' 字段1 LIKE '%'+ #{pd.KEYWORDS}+'%'
or or
字段2 LIKE '%'+ #{pd.KEYWORDS}+'%' 字段2 LIKE '%'+ #{pd.KEYWORDS}+'%'
--> -->
) )
</if> </if>
</select> </select>
@ -122,9 +134,9 @@
delete from delete from
<include refid="tableName"></include> <include refid="tableName"></include>
where where
MESSAGE_LOG_ID in MESSAGE_LOG_ID in
<foreach item="item" index="index" collection="array" open="(" separator="," close=")"> <foreach item="item" index="index" collection="array" open="(" separator="," close=")">
#{item} #{item}
</foreach> </foreach>
</delete> </delete>