金汇大屏居家养老模块

lidongdong

2023-11-06 8972041db02afc3fe0b9ec957ba85d1a2dcf92b1

金汇大屏居家养老模块

 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/JinHuiCommnuityApi.java

@@ -933,19 +933,17 @@
        return communityBraceletService.WXdispose(braceletEarlyWarningDO);
    }



    /**
     * 微信我的预警数据
     * @return
     */
    @GetMapping("/braceletApi/getEarlyWarningList")
    public R getList(@RequestParam("pageNum") Integer pageNum,
              @RequestParam("pageSize") Integer pageSize,
              @RequestParam(value = "equipmentNumber",required = false)  String equipmentNumber,
              @RequestParam(value = "type",required = false)  String type,
              @RequestParam(value = "userName",required = false)  String userName,
              @RequestParam(value = "phone",required = false)  String phone)
                     @RequestParam("pageSize") Integer pageSize,
                     @RequestParam(value = "equipmentNumber",required = false)  String equipmentNumber,
                     @RequestParam(value = "type",required = false)  String type,
                     @RequestParam(value = "userName",required = false)  String userName,
                     @RequestParam(value = "phone",required = false)  String phone)
    {
        return communityBraceletService.getList(pageNum,pageSize,getCommunityId()+"",equipmentNumber,
                getUserId()+"",type,userName,phone);

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/jinhui/JinhuiAllOldManVO.java

New file
@@ -0,0 +1,52 @@
package com.panzhihua.common.model.vos.jinhui;

import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.Date;
import java.util.List;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇老人手环大屏")
public class JinhuiAllOldManVO implements Serializable {
    private static final long serialVersionUID = -70884515430727555L;

    @ApiModelProperty(value = "已处理数量")
    private String processedNum="0";

    @ApiModelProperty(value = "未处理数量")
    private String untreatedNum="0";

    @ApiModelProperty(value = "已处理列表")
    private List<JinhuiOldManVO> processedList;

    @ApiModelProperty(value = "未处理列表")
    private List<JinhuiOldManVO> untreatedList;

    //总数
    @ApiModelProperty(value = "总数")
    private String braceletUserNum="0";
    //男
    @ApiModelProperty(value = "男人数量")
    private String braceletUserManNum="0";
    //女
    @ApiModelProperty(value = "女人数量")
    private String braceletUserWomanNum="0";


    @ApiModelProperty(value = "折线统计")
    private List<JinhuiOldManBrokenLineVO> lsit;

    @ApiModelProperty(value = "用户位置以及状态信息")
    private List<JinhuiOldManUserDateVO> oldManUserDates;

}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/jinhui/JinhuiOldManBrokenLineVO.java

New file
@@ -0,0 +1,30 @@
package com.panzhihua.common.model.vos.jinhui;

import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.Date;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇老人手环大屏折线统计图")
public class JinhuiOldManBrokenLineVO implements Serializable {
    private static final long serialVersionUID = -70884515430727555L;

    @ApiModelProperty(value = "月份")
    private String filed;

    @ApiModelProperty(value = "新增数量")
    private String num;

    @ApiModelProperty(value = "累计数量")
    private String totalNum;
}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/jinhui/JinhuiOldManUserDateVO.java

New file
@@ -0,0 +1,35 @@
package com.panzhihua.common.model.vos.jinhui;


import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇老人手环定位详情大屏")
public class JinhuiOldManUserDateVO implements Serializable {
    private static final long serialVersionUID = -70884515430727555L;

    @ApiModelProperty(value = "设备id")
    private String deviceId;

    @ApiModelProperty(value = "经度")
    private String lng;

    @ApiModelProperty(value = "纬度")
    private String lat;

    @ApiModelProperty(value = "是否正常 （0 正常   1异常  2 待服务）")
    private String isAbnormal;



}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/jinhui/JinhuiOldManVO.java

New file
@@ -0,0 +1,43 @@
package com.panzhihua.common.model.vos.jinhui;

import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.Date;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇老人手环大屏")
public class JinhuiOldManVO implements Serializable {
    private static final long serialVersionUID = -70884515430727555L;


    @ApiModelProperty(value = "处理状态（1 未处理   2 已处理   3处理中  4 忽略）")
    private String dispose_type;


    @ApiModelProperty(value = "地址")
    private String address;

    @ApiModelProperty(value = "详细地址")
    private String detail_address;

    @ApiModelProperty(value = "用户名")
    private String user_name;

    @ApiModelProperty(value = "创建时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date creationTime;

    @ApiModelProperty(value = "处理时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date dispose_time;
}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/jinhui/JinhuiCommunityService.java

@@ -1136,6 +1136,11 @@
    @GetMapping("/JinhuiLargeScreen/getCommunityServices")
    public R getCommunityServices();


    /**
     * 金汇居家养老
     * @return
     */
    @GetMapping("/JinhuiLargeScreen/getOldMan")
    public R getOldMan();

}

 springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/JinhuiLargeScreenAppi.java

@@ -59,4 +59,16 @@
        return jinhuiCommunityService.getCommunityServices();
    }


    /**
     * 金汇居家养老
     * @return
     */
    @GetMapping("/getOldMan")
    public R getOldMan()
    {
        return jinhuiCommunityService.getOldMan();
    }


}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_community/src/main/java/com/panzhihua/service_jinhui_community/api/JinhuiLargeScreenApi.java

@@ -103,4 +103,63 @@
    }


    @GetMapping("/getOldMan")
    public R getOldMan()
    {
        JinhuiAllOldManVO allOldManVO=new JinhuiAllOldManVO();
        /**
         * 老人手环异常列表数量统计
         * @return
         */

        //已处理数量
        String processedNum=screenService.getEarlyWarningNum("2",getCommunityId()+"");
        //未处理数量
        String untreatedNum=screenService.getEarlyWarningNum("1",getCommunityId()+"");

        allOldManVO.setProcessedNum(processedNum);
        allOldManVO.setUntreatedNum(untreatedNum);
        /**
         * 老人手环异常列表
         */
        List<JinhuiOldManVO> processedList=screenService.getEarlyWarningList("2",getCommunityId()+"");
        List<JinhuiOldManVO> untreatedList=screenService.getEarlyWarningList("1",getCommunityId()+"");

        allOldManVO.setProcessedList(processedList);
        allOldManVO.setUntreatedList(untreatedList);
        /**
         * 老人手环用户数量  1 男    2 女
         * @return
         */
        //总数
        String braceletUserNum=screenService.getBraceletUser(null,getCommunityId()+"");
        //男
        String braceletUserManNum=screenService.getBraceletUser("1",getCommunityId()+"");
        //女
        String braceletUserWomanNum=screenService.getBraceletUser("2",getCommunityId()+"");

        allOldManVO.setBraceletUserNum(braceletUserNum);
        allOldManVO.setBraceletUserManNum(braceletUserManNum);
        allOldManVO.setBraceletUserWomanNum(braceletUserWomanNum);


        /**
         * 新增折线数据
         * @return
         */
        List<JinhuiOldManBrokenLineVO> lsit=screenService.getEventAddPolylineData(getCommunityId()+"");
        allOldManVO.setLsit(lsit);


        List<JinhuiOldManUserDateVO> oldManUserDates=screenService.getOldManUserDate(getCommunityId()+"");
        allOldManVO.setOldManUserDates(oldManUserDates);

        return R.ok(allOldManVO);
    }






}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_community/src/main/java/com/panzhihua/service_jinhui_community/dao/JinhuiLargeScreenDao.java

@@ -1,9 +1,7 @@
package com.panzhihua.service_jinhui_community.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.panzhihua.common.model.vos.jinhui.JinhuiCommunityServicesVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiIndexInfoVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiMerchantTypeVO;
import com.panzhihua.common.model.vos.jinhui.*;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

@@ -81,4 +79,62 @@
                          @Param("type") String type);


    /******************************************************************************************************************
     *
     *
     *                               手环列表
     *
     *
     ****************************************************************************************************************/


    /**
     * 老人手环异常列表数量统计
     * @return
     */
    String getEarlyWarningNum(@Param("disposeType") String disposeType,@Param("communityId") String communityId);


    /**
     * 老人手环异常列表
     */
    List<JinhuiOldManVO> getEarlyWarningList(@Param("disposeType") String disposeType,@Param("communityId") String communityId);

    /**
     * 老人手环用户数量
     * @return
     */
    String getBraceletUser(@Param("sex") String  sex,@Param("communityId") String communityId);


    /**
     * 新增折线数据
     * @return
     */
    List<JinhuiOldManBrokenLineVO> getEventAddPolylineData(@Param("communityId") String  communityId);

    /**
     * 累计折线数据
     */
    String getEventTotalPolylineDate(@Param("communityId") String communityId,@Param("date") String date);


    /**
     * 获取用户定位  状态
     * @param communityId
     * @return
     */
    List<JinhuiOldManUserDateVO> getOldManUserDate(@Param("communityId") String communityId);

    /**
     * 获取单独用户状态
     * @param communityId
     * @param equipmentNumber
     * @return
     */
    String getEarlyNewDate(@Param("communityId") String communityId,@Param("equipmentNumber") String equipmentNumber);




}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_community/src/main/java/com/panzhihua/service_jinhui_community/service/JinhuiLargeScreenService.java

@@ -1,9 +1,7 @@
package com.panzhihua.service_jinhui_community.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.panzhihua.common.model.vos.jinhui.JinhuiCommunityServicesVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiIndexInfoVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiMerchantTypeVO;
import com.panzhihua.common.model.vos.jinhui.*;
import org.apache.ibatis.annotations.Param;

import java.util.List;
@@ -60,7 +58,7 @@
     * 空间预约
     * @return
     */
    String getInterspaceApplyNum(@Param("state") String state);
    String getInterspaceApplyNum(String state);


    /**
@@ -68,17 +66,72 @@
     * @param cancelType
     * @return
     */
    String getShoppingOrderNum(@Param("cancelType") String cancelType);
    String getShoppingOrderNum(String cancelType);

    /**
     * 获取社区工作者
     * @param communityId
     * @return
     */
    String getServiceTeam(@Param("communityId") String communityId,
                          @Param("type") String type);
    String getServiceTeam(String communityId,String type);



    /******************************************************************************************************************
     *
     *
     *                               手环列表
     *
     *
     ****************************************************************************************************************/


    /**
     * 老人手环异常列表数量统计
     * @return
     */
    String getEarlyWarningNum(String disposeType,String communityId);


    /**
     * 老人手环异常列表
     */
    List<JinhuiOldManVO> getEarlyWarningList(String disposeType,String communityId);

    /**
     * 老人手环用户数量
     * @return
     */
    String getBraceletUser(String  sex,String communityId);


    /**
     * 新增折线数据
     * @return
     */
    List<JinhuiOldManBrokenLineVO> getEventAddPolylineData(String  communityId);

    /**
     * 累计折线数据
     */
    String getEventTotalPolylineDate(String communityId,String date);



    /**
     * 获取用户定位  状态
     * @param communityId
     * @return
     */
    List<JinhuiOldManUserDateVO> getOldManUserDate(@Param("communityId") String communityId);

    /**
     * 获取单独用户状态
     * @param communityId
     * @param equipmentNumber
     * @return
     */
    String getEarlyNewDate(@Param("communityId") String communityId,@Param("equipmentNumber") String equipmentNumber);


}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_community/src/main/java/com/panzhihua/service_jinhui_community/service/impl/JinhuiLargeScreenImpl.java

@@ -1,12 +1,12 @@
package com.panzhihua.service_jinhui_community.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.vos.jinhui.JinhuiCommunityServicesVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiIndexInfoVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiMerchantTypeVO;
import com.panzhihua.common.model.vos.jinhui.*;
import com.panzhihua.common.utlis.StringUtils;
import com.panzhihua.service_jinhui_community.dao.JinhuiLargeScreenDao;
import com.panzhihua.service_jinhui_community.service.JinhuiLargeScreenService;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Service;

import java.util.List;
@@ -69,4 +69,68 @@
    {
        return baseMapper.getServiceTeam(communityId,type);
    }

    @Override
    public String getEarlyWarningNum(String disposeType, String communityId) {
        return baseMapper.getEarlyWarningNum(disposeType,communityId);
    }

    @Override
    public List<JinhuiOldManVO> getEarlyWarningList(String disposeType, String communityId) {
        return baseMapper.getEarlyWarningList(disposeType,communityId);
    }

    @Override
    public String getBraceletUser(String  sex, String communityId) {
        return baseMapper.getBraceletUser(sex,communityId);
    }

    @Override
    public List<JinhuiOldManBrokenLineVO> getEventAddPolylineData(String communityId)
    {
        List<JinhuiOldManBrokenLineVO> list=baseMapper.getEventAddPolylineData(communityId);
        list.forEach(e -> {
            String temp = baseMapper.getEventTotalPolylineDate(communityId, e.getFiled());
            e.setTotalNum(temp);
        });

        return list;
    }

    @Override
    public String getEventTotalPolylineDate(String communityId,String date) {
        return baseMapper.getEventTotalPolylineDate(communityId,date);
    }

    @Override
    public List<JinhuiOldManUserDateVO> getOldManUserDate(String communityId)
    {
        List<JinhuiOldManUserDateVO> list=baseMapper.getOldManUserDate(communityId);
        list.forEach(e -> {
            //判断是否异常
            if(StringUtils.equals("1",e.getIsAbnormal()))
            {
                //是否正常 （0 正常   1异常  2 待服务）
                String temp = baseMapper.getEarlyNewDate(communityId, e.getDeviceId());
                //处理状态（1 未处理   2 已处理   3处理中  4 忽略）
                if(StringUtils.equals("3",temp))
                {
                    e.setIsAbnormal("2");
                }
                else if(StringUtils.equals("2",temp) || StringUtils.equals("4",temp) )
                {
                    e.setIsAbnormal("0");
                }
            }

        });
        return list;
    }

    @Override
    public String getEarlyNewDate(String communityId, String equipmentNumber) {
        return baseMapper.getEarlyNewDate(communityId,equipmentNumber);
    }


}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_community/src/main/resources/mapper/JinhuiLargeScreenMapper.xml

@@ -107,4 +107,126 @@
    </select>


    <!--  老人手环异常列表数量统计  -->
    <select id="getEarlyWarningNum" resultType="String">
        SELECT
        count(id) as number
        from bracelet_early_warning
        <where>
            1=1
            <if test="disposeType != null and disposeType !=''">
                and dispose_type=#{disposeType}
            </if>
            <if test="communityId != null and communityId !=''">
                and community_id=#{communityId}
            </if>
        </where>
    </select>

    <!--  老人手环异常列表  -->
    <select id="getEarlyWarningList" resultType="com.panzhihua.common.model.vos.jinhui.JinhuiOldManVO">
        SELECT
            bew.dispose_time,
            bew.creationTime,
            bew.dispose_type,
            bud.address,
            bud.detail_address,
            bud.user_name
        from bracelet_early_warning as bew
        left join bracelet_user_data as bud on bew.equipment_number=bud.device_id
        <where>
            1=1
            <if test="disposeType != null and disposeType !=''">
                and bew.dispose_type=#{disposeType}
            </if>
            <if test="communityId != null and communityId !=''">
                and bew.community_id=#{communityId}
            </if>
        </where>
    </select>


    <!--  老人手环用户数据  -->
    <select id="getBraceletUser" resultType="String">
        SELECT
            count(bew.id) as number
        from bracelet_user_data as bew
        <where>
            1=1
            <if test="sex != null and sex !=''">
                and bew.sex=#{sex}
            </if>
            <if test="communityId != null and communityId !=''">
                and bew.community_id=#{communityId}
            </if>
        </where>
    </select>


    <!-- 新增折线数据 -->
    <select id="getEventAddPolylineData"
            resultType="com.panzhihua.common.model.vos.jinhui.JinhuiOldManBrokenLineVO">
        SELECT filed, SUM(num) AS num FROM (
           SELECT DATE_FORMAT( e.creation_time, '%Y-%m' ) AS filed, COUNT(e.id) AS num
           FROM `bracelet_user_data` AS e
           WHERE  e.community_id = #{communityId}
             AND DATE_FORMAT( e.creation_time, '%Y-%m' ) > DATE_FORMAT(date_sub(curdate(),
                 interval 12 month),'%Y-%m')
           GROUP BY filed
           UNION ALL SELECT * FROM
               (
                   SELECT DATE_FORMAT(curdate(),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 1 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 2 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 3 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 4 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 5 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 6 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 7 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 8 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 9 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 10 month),'%Y-%m') AS filed, 0 AS num union
                   SELECT DATE_FORMAT(date_sub(curdate(), interval 11 month),'%Y-%m') AS filed, 0 AS num
               ) temT
       ) temp GROUP BY filed ORDER BY filed ASC
    </select>

    <!--  累计折线数据  -->
    <select id="getEventTotalPolylineDate" resultType="String">
        SELECT SUM(num) AS num
        FROM (
            SELECT COUNT(e.id) AS num
            FROM `bracelet_user_data` AS e
            WHERE e.community_id = #{communityId}
            AND DATE_FORMAT( e.creation_time, '%Y-%m' ) &lt;=#{date}
        ) temp
    </select>




    <select id="getOldManUserDate" resultType="com.panzhihua.common.model.vos.jinhui.JinhuiOldManUserDateVO">
        SELECT
            device_id,
            lng,
            lat,
            is_abnormal
        FROM bracelet_user_data
        WHERE community_id = #{communityId}
    </select>


    <select id="getEarlyNewDate" resultType="String">
        SELECT
            dispose_type
        FROM bracelet_early_warning
        WHERE community_id = #{communityId} AND equipment_number=#{equipmentNumber}
        order by creation_time desc
        LIMIT 1
    </select>





</mapper>