message

CODE/smart-community/app-api/src/main/java/com/community/huiju/controller/MessageController.java

@@ -1,10 +1,22 @@
 package com.community.huiju.controller;
 
+import com.community.commom.mode.ResponseBean;
+import com.community.huiju.model.ToCommunities;
+import com.community.huiju.service.MessageServiceI;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * @author FXF
  * @date 2018-10-22
@@ -14,5 +26,16 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/")
 @Api("app端消息相关的API")
 public class MessageController {
-
+	
+	@Autowired
+	private MessageServiceI messageService;
+	
+	@ApiOperation(value = "根据小区名获取小区列表", notes = "根据小区名获取小区列表")
+	@RequestMapping(value = "/message/total",method = RequestMethod.GET)
+	public ResponseBean getMessageTotal(){
+		ResponseBean responseBean = new ResponseBean();
+		Map<String,Object> totalMap = messageService.getMessageTotal();
+		responseBean.addSuccess(totalMap);
+		return responseBean;
+	}
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/dao/TpMessageMapper.java

@@ -0,0 +1,24 @@
+package com.community.huiju.dao;
+
+import com.community.huiju.model.TpMessage;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Map;
+
+@Mapper
+public interface TpMessageMapper {
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(TpMessage record);
+
+    int insertSelective(TpMessage record);
+
+    TpMessage selectByPrimaryKey(Integer id);
+
+    int updateByPrimaryKeySelective(TpMessage record);
+
+    int updateByPrimaryKey(TpMessage record);
+    
+    Map<String, Object> getMessageTotal(@Param(value="userId") Integer userId);
+}

CODE/smart-community/app-api/src/main/java/com/community/huiju/model/TpMessage.java

@@ -0,0 +1,175 @@
+package com.community.huiju.model;
+
+import java.util.Date;
+
+public class TpMessage {
+    private Integer id;
+
+    private Integer communityId;
+
+    private String messageType;
+
+    private String adviceType;
+
+    private String modelType;
+
+    private Integer uuid;
+
+    private String uuidType;
+
+    private String source;
+
+    private String messageContent;
+
+    private String status;
+
+    private String result;
+
+    private String meaasgeTypeId;
+
+    private String readStatus;
+
+    private Integer createUser;
+
+    private Date createDate;
+
+    private Integer updateUser;
+
+    private Date updateDate;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getCommunityId() {
+        return communityId;
+    }
+
+    public void setCommunityId(Integer communityId) {
+        this.communityId = communityId;
+    }
+
+    public String getMessageType() {
+        return messageType;
+    }
+
+    public void setMessageType(String messageType) {
+        this.messageType = messageType == null ? null : messageType.trim();
+    }
+
+    public String getAdviceType() {
+        return adviceType;
+    }
+
+    public void setAdviceType(String adviceType) {
+        this.adviceType = adviceType == null ? null : adviceType.trim();
+    }
+
+    public String getModelType() {
+        return modelType;
+    }
+
+    public void setModelType(String modelType) {
+        this.modelType = modelType == null ? null : modelType.trim();
+    }
+
+    public Integer getUuid() {
+        return uuid;
+    }
+
+    public void setUuid(Integer uuid) {
+        this.uuid = uuid;
+    }
+
+    public String getUuidType() {
+        return uuidType;
+    }
+
+    public void setUuidType(String uuidType) {
+        this.uuidType = uuidType == null ? null : uuidType.trim();
+    }
+
+    public String getSource() {
+        return source;
+    }
+
+    public void setSource(String source) {
+        this.source = source == null ? null : source.trim();
+    }
+
+    public String getMessageContent() {
+        return messageContent;
+    }
+
+    public void setMessageContent(String messageContent) {
+        this.messageContent = messageContent == null ? null : messageContent.trim();
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status == null ? null : status.trim();
+    }
+
+    public String getResult() {
+        return result;
+    }
+
+    public void setResult(String result) {
+        this.result = result == null ? null : result.trim();
+    }
+
+    public String getMeaasgeTypeId() {
+        return meaasgeTypeId;
+    }
+
+    public void setMeaasgeTypeId(String meaasgeTypeId) {
+        this.meaasgeTypeId = meaasgeTypeId == null ? null : meaasgeTypeId.trim();
+    }
+
+    public String getReadStatus() {
+        return readStatus;
+    }
+
+    public void setReadStatus(String readStatus) {
+        this.readStatus = readStatus == null ? null : readStatus.trim();
+    }
+
+    public Integer getCreateUser() {
+        return createUser;
+    }
+
+    public void setCreateUser(Integer createUser) {
+        this.createUser = createUser;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Integer getUpdateUser() {
+        return updateUser;
+    }
+
+    public void setUpdateUser(Integer updateUser) {
+        this.updateUser = updateUser;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+}

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/MessageServiceI.java

@@ -0,0 +1,7 @@
+package com.community.huiju.service;
+
+import java.util.Map;
+
+public interface MessageServiceI {
+	Map<String, Object> getMessageTotal();
+}

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/impl/MessageServiceImpl.java

@@ -0,0 +1,25 @@
+package com.community.huiju.service.impl;
+
+import com.community.huiju.dao.TpMessageMapper;
+import com.community.huiju.service.MessageServiceI;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+
+/**
+ * @author FXF
+ * @date 2018-10-22
+ */
+@Service("messageService")
+public class MessageServiceImpl implements MessageServiceI {
+	
+	@Autowired
+	private TpMessageMapper tpMessageMapper;
+	
+	@Override
+	public Map<String, Object> getMessageTotal() {
+		Integer userId = 1;
+		return tpMessageMapper.getMessageTotal(userId);
+	}
+}

CODE/smart-community/app-api/src/main/resources/mapper/TpMessageMapper.xml

@@ -0,0 +1,248 @@
+<?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.community.huiju.dao.TpMessageMapper" >
+  <resultMap id="BaseResultMap" type="com.community.huiju.model.TpMessage" >
+    <id column="id" property="id" jdbcType="INTEGER" />
+    <result column="community_id" property="communityId" jdbcType="INTEGER" />
+    <result column="message_type" property="messageType" jdbcType="CHAR" />
+    <result column="advice_type" property="adviceType" jdbcType="CHAR" />
+    <result column="model_type" property="modelType" jdbcType="CHAR" />
+    <result column="uuid" property="uuid" jdbcType="INTEGER" />
+    <result column="uuid_type" property="uuidType" jdbcType="CHAR" />
+    <result column="source" property="source" jdbcType="CHAR" />
+    <result column="message_content" property="messageContent" jdbcType="VARCHAR" />
+    <result column="status" property="status" jdbcType="CHAR" />
+    <result column="result" property="result" jdbcType="VARCHAR" />
+    <result column="meaasge_type_id" property="meaasgeTypeId" jdbcType="VARCHAR" />
+    <result column="read_status" property="readStatus" jdbcType="CHAR" />
+    <result column="create_user" property="createUser" jdbcType="INTEGER" />
+    <result column="create_date" property="createDate" jdbcType="TIMESTAMP" />
+    <result column="update_user" property="updateUser" jdbcType="INTEGER" />
+    <result column="update_date" property="updateDate" jdbcType="TIMESTAMP" />
+  </resultMap>
+  <sql id="Base_Column_List" >
+    id, community_id, message_type, advice_type, model_type, uuid, uuid_type, source, 
+    message_content, status, result, meaasge_type_id, read_status, create_user, create_date, 
+    update_user, update_date
+  </sql>
+  <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
+    select 
+    <include refid="Base_Column_List" />
+    from tp_message
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
+    delete from tp_message
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.community.huiju.model.TpMessage" >
+    insert into tp_message (id, community_id, message_type, 
+      advice_type, model_type, uuid, 
+      uuid_type, source, message_content, 
+      status, result, meaasge_type_id, 
+      read_status, create_user, create_date, 
+      update_user, update_date)
+    values (#{id,jdbcType=INTEGER}, #{communityId,jdbcType=INTEGER}, #{messageType,jdbcType=CHAR}, 
+      #{adviceType,jdbcType=CHAR}, #{modelType,jdbcType=CHAR}, #{uuid,jdbcType=INTEGER}, 
+      #{uuidType,jdbcType=CHAR}, #{source,jdbcType=CHAR}, #{messageContent,jdbcType=VARCHAR}, 
+      #{status,jdbcType=CHAR}, #{result,jdbcType=VARCHAR}, #{meaasgeTypeId,jdbcType=VARCHAR}, 
+      #{readStatus,jdbcType=CHAR}, #{createUser,jdbcType=INTEGER}, #{createDate,jdbcType=TIMESTAMP}, 
+      #{updateUser,jdbcType=INTEGER}, #{updateDate,jdbcType=TIMESTAMP})
+  </insert>
+  <insert id="insertSelective" parameterType="com.community.huiju.model.TpMessage" >
+    insert into tp_message
+    <trim prefix="(" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        id,
+      </if>
+      <if test="communityId != null" >
+        community_id,
+      </if>
+      <if test="messageType != null" >
+        message_type,
+      </if>
+      <if test="adviceType != null" >
+        advice_type,
+      </if>
+      <if test="modelType != null" >
+        model_type,
+      </if>
+      <if test="uuid != null" >
+        uuid,
+      </if>
+      <if test="uuidType != null" >
+        uuid_type,
+      </if>
+      <if test="source != null" >
+        source,
+      </if>
+      <if test="messageContent != null" >
+        message_content,
+      </if>
+      <if test="status != null" >
+        status,
+      </if>
+      <if test="result != null" >
+        result,
+      </if>
+      <if test="meaasgeTypeId != null" >
+        meaasge_type_id,
+      </if>
+      <if test="readStatus != null" >
+        read_status,
+      </if>
+      <if test="createUser != null" >
+        create_user,
+      </if>
+      <if test="createDate != null" >
+        create_date,
+      </if>
+      <if test="updateUser != null" >
+        update_user,
+      </if>
+      <if test="updateDate != null" >
+        update_date,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="communityId != null" >
+        #{communityId,jdbcType=INTEGER},
+      </if>
+      <if test="messageType != null" >
+        #{messageType,jdbcType=CHAR},
+      </if>
+      <if test="adviceType != null" >
+        #{adviceType,jdbcType=CHAR},
+      </if>
+      <if test="modelType != null" >
+        #{modelType,jdbcType=CHAR},
+      </if>
+      <if test="uuid != null" >
+        #{uuid,jdbcType=INTEGER},
+      </if>
+      <if test="uuidType != null" >
+        #{uuidType,jdbcType=CHAR},
+      </if>
+      <if test="source != null" >
+        #{source,jdbcType=CHAR},
+      </if>
+      <if test="messageContent != null" >
+        #{messageContent,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null" >
+        #{status,jdbcType=CHAR},
+      </if>
+      <if test="result != null" >
+        #{result,jdbcType=VARCHAR},
+      </if>
+      <if test="meaasgeTypeId != null" >
+        #{meaasgeTypeId,jdbcType=VARCHAR},
+      </if>
+      <if test="readStatus != null" >
+        #{readStatus,jdbcType=CHAR},
+      </if>
+      <if test="createUser != null" >
+        #{createUser,jdbcType=INTEGER},
+      </if>
+      <if test="createDate != null" >
+        #{createDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateUser != null" >
+        #{updateUser,jdbcType=INTEGER},
+      </if>
+      <if test="updateDate != null" >
+        #{updateDate,jdbcType=TIMESTAMP},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.community.huiju.model.TpMessage" >
+    update tp_message
+    <set >
+      <if test="communityId != null" >
+        community_id = #{communityId,jdbcType=INTEGER},
+      </if>
+      <if test="messageType != null" >
+        message_type = #{messageType,jdbcType=CHAR},
+      </if>
+      <if test="adviceType != null" >
+        advice_type = #{adviceType,jdbcType=CHAR},
+      </if>
+      <if test="modelType != null" >
+        model_type = #{modelType,jdbcType=CHAR},
+      </if>
+      <if test="uuid != null" >
+        uuid = #{uuid,jdbcType=INTEGER},
+      </if>
+      <if test="uuidType != null" >
+        uuid_type = #{uuidType,jdbcType=CHAR},
+      </if>
+      <if test="source != null" >
+        source = #{source,jdbcType=CHAR},
+      </if>
+      <if test="messageContent != null" >
+        message_content = #{messageContent,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null" >
+        status = #{status,jdbcType=CHAR},
+      </if>
+      <if test="result != null" >
+        result = #{result,jdbcType=VARCHAR},
+      </if>
+      <if test="meaasgeTypeId != null" >
+        meaasge_type_id = #{meaasgeTypeId,jdbcType=VARCHAR},
+      </if>
+      <if test="readStatus != null" >
+        read_status = #{readStatus,jdbcType=CHAR},
+      </if>
+      <if test="createUser != null" >
+        create_user = #{createUser,jdbcType=INTEGER},
+      </if>
+      <if test="createDate != null" >
+        create_date = #{createDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateUser != null" >
+        update_user = #{updateUser,jdbcType=INTEGER},
+      </if>
+      <if test="updateDate != null" >
+        update_date = #{updateDate,jdbcType=TIMESTAMP},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.community.huiju.model.TpMessage" >
+    update tp_message
+    set community_id = #{communityId,jdbcType=INTEGER},
+      message_type = #{messageType,jdbcType=CHAR},
+      advice_type = #{adviceType,jdbcType=CHAR},
+      model_type = #{modelType,jdbcType=CHAR},
+      uuid = #{uuid,jdbcType=INTEGER},
+      uuid_type = #{uuidType,jdbcType=CHAR},
+      source = #{source,jdbcType=CHAR},
+      message_content = #{messageContent,jdbcType=VARCHAR},
+      status = #{status,jdbcType=CHAR},
+      result = #{result,jdbcType=VARCHAR},
+      meaasge_type_id = #{meaasgeTypeId,jdbcType=VARCHAR},
+      read_status = #{readStatus,jdbcType=CHAR},
+      create_user = #{createUser,jdbcType=INTEGER},
+      create_date = #{createDate,jdbcType=TIMESTAMP},
+      update_user = #{updateUser,jdbcType=INTEGER},
+      update_date = #{updateDate,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+
+  <select id="getMessageTotal" resultType="map" parameterType="java.lang.Integer" >
+    SELECT
+        count( CASE WHEN model_type = 1 AND read_status = 0 THEN 1 ELSE NULL END ) AS messageTotal,
+        count( CASE WHEN model_type = 2 THEN 1 ELSE NULL END ) AS toDoTotal
+    FROM
+        tp_message
+    WHERE
+        uuid_type = 1
+        AND uuid = #{userId,jdbcType=INTEGER}
+        AND STATUS = 1
+        AND advice_type = 1
+  </select>
+</mapper>