jiangjiazhi / yimiao

Download as
Browse Code »

Commit f4cea12db69f17ccbbabbeaac7ba05abbc2eb625

Authored by landong2015
1 parent 7e3d68f44d
Exists in master

新增消息推送

Showing 7 changed files with 308 additions and 0 deletions

mainData/src/main/java/com/lymsh/yimiao/main/data/dao/YmPushMessagesMapper.java View file @ f4cea12
  1 +package com.lymsh.yimiao.main.data.dao;
  2 +
  3 +import com.lymsh.yimiao.main.data.model.YmPushMessages;
  4 +import com.lymsh.yimiao.main.data.model.YmPushMessagesQuery;
  5 +
  6 +import java.util.List;
  7 +
  8 +public interface YmPushMessagesMapper {
  9 + public void addYmPushMessages(YmPushMessages obj);
  10 +
  11 + public void updateYmPushMessages(YmPushMessages obj);
  12 +
  13 + public void deleteYmPushMessages(Integer id);
  14 +
  15 + public YmPushMessages getYmPushMessages(Integer id);
  16 +
  17 + public int queryYmPushMessagesCount(YmPushMessagesQuery query);
  18 +
  19 + public List<YmPushMessages> queryYmPushMessages(YmPushMessagesQuery query);
  20 +
  21 +}
mainData/src/main/java/com/lymsh/yimiao/main/data/model/YmPushMessages.java View file @ f4cea12
  1 +package com.lymsh.yimiao.main.data.model;
  2 +
  3 +import java.util.Date;
  4 +
  5 +public class YmPushMessages {
  6 + private Integer id;
  7 +
  8 + public Integer getYn() {
  9 + return yn;
  10 + }
  11 +
  12 + public void setYn(Integer yn) {
  13 + this.yn = yn;
  14 + }
  15 +
  16 + private Integer yn;
  17 + private String content;
  18 + private Date created;
  19 +
  20 + public Integer getReceptionId() {
  21 + return receptionId;
  22 + }
  23 +
  24 + public void setReceptionId(Integer receptionId) {
  25 + this.receptionId = receptionId;
  26 + }
  27 +
  28 + public Date getCreated() {
  29 + return created;
  30 + }
  31 +
  32 + public void setCreated(Date created) {
  33 + this.created = created;
  34 + }
  35 +
  36 + public String getContent() {
  37 + return content;
  38 + }
  39 +
  40 + public void setContent(String content) {
  41 + this.content = content;
  42 + }
  43 +
  44 + public Integer getId() {
  45 + return id;
  46 + }
  47 +
  48 + public void setId(Integer id) {
  49 + this.id = id;
  50 + }
  51 +
  52 + private Integer receptionId;
  53 +
  54 +
  55 +}
mainData/src/main/java/com/lymsh/yimiao/main/data/model/YmPushMessagesQuery.java View file @ f4cea12
  1 +package com.lymsh.yimiao.main.data.model;
  2 +
  3 +
  4 +import java.util.Date;
  5 +
  6 +import com.lymsh.mommybaby.basecommon.base.BaseQuery;
  7 +
  8 +
  9 +public class YmPushMessagesQuery extends BaseQuery {
  10 + private Integer id;
  11 + private String content;
  12 + private Date created;
  13 + private Integer yn;
  14 +
  15 + public Integer getYn() {
  16 + return yn;
  17 + }
  18 +
  19 + public void setYn(Integer yn) {
  20 + this.yn = yn;
  21 + }
  22 +
  23 + public Integer getReceptionId() {
  24 + return receptionId;
  25 + }
  26 +
  27 + public void setReceptionId(Integer receptionId) {
  28 + this.receptionId = receptionId;
  29 + }
  30 +
  31 + public Date getCreated() {
  32 + return created;
  33 + }
  34 +
  35 + public void setCreated(Date created) {
  36 + this.created = created;
  37 + }
  38 +
  39 + public String getContent() {
  40 + return content;
  41 + }
  42 +
  43 + public void setContent(String content) {
  44 + this.content = content;
  45 + }
  46 +
  47 + public Integer getId() {
  48 + return id;
  49 + }
  50 +
  51 + public void setId(Integer id) {
  52 + this.id = id;
  53 + }
  54 +
  55 + private Integer receptionId;
  56 +}
mainData/src/main/java/com/lymsh/yimiao/main/data/service/YmPushMessagesService.java View file @ f4cea12
  1 +package com.lymsh.yimiao.main.data.service;
  2 +
  3 +import com.lymsh.yimiao.main.data.model.YmPushMessages;
  4 +import com.lymsh.yimiao.main.data.model.YmPushMessagesQuery;
  5 +
  6 +import java.util.List;
  7 +
  8 +public interface YmPushMessagesService {public void addYmPushMessages(YmPushMessages obj);public void updateYmPushMessages(YmPushMessages obj);public void deleteYmPushMessages(Integer id);public YmPushMessages getYmPushMessages(Integer id);public int queryYmPushMessagesCount(YmPushMessagesQuery query);public List<YmPushMessages> queryYmPushMessages(YmPushMessagesQuery query);
  9 +
  10 +}
mainData/src/main/java/com/lymsh/yimiao/main/data/service/impl/YmPushMessagesServiceImpl.java View file @ f4cea12
  1 +package com.lymsh.yimiao.main.data.service.impl;
  2 +
  3 +import com.lymsh.yimiao.main.data.dao.YmPushMessagesMapper;
  4 +import com.lymsh.yimiao.main.data.model.YmPushMessages;
  5 +import com.lymsh.yimiao.main.data.model.YmPushMessagesQuery;
  6 +import com.lymsh.yimiao.main.data.service.YmPushMessagesService;
  7 +import org.springframework.beans.factory.annotation.Autowired;
  8 +import org.springframework.stereotype.Service;
  9 +
  10 +import java.util.Date;
  11 +import java.util.List;
  12 +
  13 +@Service
  14 +public class YmPushMessagesServiceImpl implements YmPushMessagesService {
  15 +
  16 +@Autowired
  17 +private YmPushMessagesMapper ymPushMessagesMapper;
  18 +
  19 +@Override
  20 +public void addYmPushMessages(YmPushMessages obj){ymPushMessagesMapper.addYmPushMessages(obj);}
  21 +@Override
  22 +public void updateYmPushMessages(YmPushMessages obj){ymPushMessagesMapper.updateYmPushMessages(obj);}
  23 +@Override
  24 +public void deleteYmPushMessages (Integer id){ymPushMessagesMapper.deleteYmPushMessages(id);}
  25 +@Override
  26 +public YmPushMessages getYmPushMessages (Integer id){return ymPushMessagesMapper.getYmPushMessages(id);}
  27 +@Override
  28 +public int queryYmPushMessagesCount (YmPushMessagesQuery query){return ymPushMessagesMapper.queryYmPushMessagesCount(query);}
  29 +@Override
  30 +public List<YmPushMessages> queryYmPushMessages (YmPushMessagesQuery query){if (query.getNeed() != null) {query.mysqlBuild(ymPushMessagesMapper.queryYmPushMessagesCount(query));}return ymPushMessagesMapper.queryYmPushMessages(query);}
  31 +
  32 +}
mainData/src/main/java/com/lymsh/yimiao/main/data/util/JPushUtil.java View file @ f4cea12
  1 +package com.lymsh.yimiao.main.data.util;
  2 +
  3 +import cn.jpush.api.push.model.Platform;
  4 +import cn.jpush.api.push.model.PushPayload;
  5 +import cn.jpush.api.push.model.audience.Audience;
  6 +import cn.jpush.api.push.model.notification.Notification;
  7 +import org.springframework.stereotype.Service;
  8 +
  9 +/**
  10 + * Created by Administrator on 2016/5/25 0025.
  11 + */
  12 +@Service
  13 +public class JPushUtil {
  14 +
  15 + /**
  16 + * 所有平台
  17 + * alias 别名
  18 + * alert 内容
  19 + * @return
  20 + */
  21 + public static PushPayload buildPushObject_all_alias_alert(String alias,String alert) {
  22 + return PushPayload.newBuilder()
  23 + .setPlatform(Platform.all())
  24 + .setAudience(Audience.alias(alias))
  25 + .setNotification(Notification.alert(alert))
  26 + .build();
  27 + }
  28 +}
mainData/src/main/resources/mainOrm/YmPushMessages.xml View file @ f4cea12
  1 +<?xml version="1.0" encoding="UTF-8" ?>
  2 +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
  3 +<mapper namespace="com.lymsh.yimiao.main.data.dao.YmPushMessagesMapper">
  4 +
  5 +<resultMap id="YmPushMessagesResultMap" type="com.lymsh.yimiao.main.data.model.YmPushMessages">
  6 +<id column="id" property="id" jdbcType="INTEGER" />
  7 +<result column="content" property="content" jdbcType="VARCHAR" />
  8 +<result column="created" property="created" jdbcType="TIMESTAMP" />
  9 +<result column="reception_id" property="receptionId" jdbcType="INTEGER" />
  10 +<result column="YN" property="yn" jdbcType="INTEGER" />
  11 +</resultMap>
  12 +
  13 +
  14 +
  15 +<insert id="addYmPushMessages" keyProperty="id" useGeneratedKeys="false" parameterType="com.lymsh.yimiao.main.data.model.YmPushMessages">
  16 + <selectKey resultType="int" keyProperty="id" order="BEFORE">
  17 + SELECT MESSAGE_SEQ.nextval AS id
  18 + FROM dual
  19 + </selectKey>
  20 +insert into YM_PUSH_MESSAGES (id,content,created,reception_id,yn) values (#{id,jdbcType=INTEGER},#{content,jdbcType=VARCHAR},#{created,jdbcType=TIMESTAMP},#{receptionId,jdbcType=INTEGER}
  21 + ,#{yn,jdbcType=INTEGER})
  22 +</insert>
  23 +
  24 +
  25 +
  26 +<update id="updateYmPushMessages" parameterType="com.lymsh.yimiao.main.data.model.YmPushMessages">
  27 +update ym_push_messages <set><if test="content != null and content != ''">
  28 + content = #{content,jdbcType=VARCHAR},
  29 +</if>
  30 +<if test="created != null">
  31 + created = #{created,jdbcType=TIMESTAMP},
  32 +</if>
  33 +<if test="receptionId != null and receptionId >= 0">
  34 + reception_id = #{receptionId,jdbcType=INTEGER},
  35 +</if>
  36 + <if test="yn != null and yn >= 0">
  37 + yn = #{yn,jdbcType=INTEGER},
  38 + </if>
  39 +</set>
  40 +where id = #{id,jdbcType=INTEGER}
  41 +</update>
  42 +
  43 +
  44 +<delete id="deleteYmPushMessages" parameterType="java.lang.Integer">
  45 +delete from ym_push_messages where id = #{id,jdbcType=INTEGER}
  46 +</delete>
  47 +
  48 +
  49 +
  50 +<select id="getYmPushMessages" resultMap="YmPushMessagesResultMap" parameterType="java.lang.Integer">
  51 +select id,content,created,reception_id,yn
  52 + from ym_push_messages where id = #{id,jdbcType=INTEGER}
  53 +</select>
  54 +
  55 +
  56 +<sql id="orderAndLimit">
  57 +<if test="sort != null and sort != '' ">
  58 +order by ${sort}
  59 +<if test="need != null">
  60 +limit #{offset, jdbcType=INTEGER} , #{limit, jdbcType=INTEGER}
  61 +</if>
  62 +</if>
  63 +</sql>
  64 +
  65 +
  66 +
  67 +<sql id="YmPushMessagesCondition">
  68 +<where>
  69 + 1 = 1
  70 +<if test="id != null and id >= 0">
  71 +and id = #{id,jdbcType=INTEGER}
  72 +</if>
  73 +<if test="content != null and content != ''">
  74 +and content = #{content,jdbcType=VARCHAR}
  75 +</if>
  76 +<if test="created != null">
  77 +and created = #{created,jdbcType=TIMESTAMP}
  78 +</if>
  79 +<if test="receptionId != null and receptionId >= 0">
  80 +and reception_id = #{receptionId,jdbcType=INTEGER}
  81 +</if>
  82 + <if test="yn != null and yn >= 0">
  83 + and yn = #{yn,jdbcType=INTEGER}
  84 + </if>
  85 +</where>
  86 +</sql>
  87 +
  88 +
  89 +
  90 +<select id="queryYmPushMessages" resultMap="YmPushMessagesResultMap" parameterType="com.lymsh.yimiao.main.data.model.YmPushMessagesQuery">
  91 +select id,content,created,reception_id,yn
  92 + from ym_push_messages
  93 +<include refid="YmPushMessagesCondition" />
  94 +<include refid="orderAndLimit" />
  95 +</select>
  96 +
  97 +
  98 +
  99 +<select id="queryYmPushMessagesCount" resultType="int" parameterType="com.lymsh.yimiao.main.data.model.YmPushMessagesQuery">
  100 +select count(1) from ym_push_messages
  101 +<include refid="YmPushMessagesCondition" />
  102 +</select>
  103 +
  104 +
  105 +
  106 +</mapper>