2021与蓝度共同重构项目,服务端
liuhaonan
2022-05-27 c0359a005dab3c7b168ed25db2fa4dfc67c7546a
排序
已修改7个文件
96 ■■■■ 文件已修改
dao/src/main/java/com/sandu/ximon/dao/mapper/IPBroadcastMapper.java 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/java/com/sandu/ximon/dao/mapper/MonitorMapper.java 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/resources/mapper/IPBroadcastMapper.xml 21 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/resources/mapper/MonitorMapper.xml 22 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ximon-admin/src/main/java/com/sandu/ximon/admin/controller/GetListOnBindingController.java 14 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ximon-admin/src/main/java/com/sandu/ximon/admin/service/IpVolumeFileService.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ximon-admin/src/main/java/com/sandu/ximon/admin/service/IpVolumeService.java 27 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/java/com/sandu/ximon/dao/mapper/IPBroadcastMapper.java
@@ -20,6 +20,8 @@
//    int insert(BroadcastTerminalV2Entity b);
    List<BroadcastTerminalV2EntityBo> getBroadcastTerminalList(String keyword, Long userid, int bindingState);
    List<BroadcastTerminalV2EntityBo> newListTerminalOnBind(Long userid,String keyword);
}
dao/src/main/java/com/sandu/ximon/dao/mapper/MonitorMapper.java
@@ -12,7 +12,9 @@
    List<MonitorBo> listMonitorByIds(List<String> list, int equipmentState);
    List<MonitorBo> listMonitorDeviceSerial1(Long userid, String keyword, int bindingState,String orderBy);
    List<MonitorBo> listMonitorDeviceSerial1(Long userid, String keyword, int bindingState, String orderBy);
    List<MonitorBo> newListMonitorOnBind(Long userid, String keyword);
}
dao/src/main/resources/mapper/IPBroadcastMapper.xml
@@ -17,6 +17,26 @@
        ,terminal_name,streetlight_id,
        bind_states,exist
    </sql>
    <select id="newListTerminalOnBind" parameterType="java.lang.String">
        SELECT
        t1.*, t2.pole_id,
        t3.pole_name
        FROM
        broadcast_v2_terminal t1
        LEFT JOIN pole_binding t2 ON t1.id = t2.device_code
        AND t2.device_type = 5
        LEFT JOIN pole t3 ON t3.id = t2.pole_id
        <where>
            <if test="keyword != null and keyword != ''">
                AND t1.id LIKE CONCAT(CONCAT('%', #{keyword}), '%')
                OR t1.terminal_name LIKE CONCAT(CONCAT('%', #{keyword}), '%')
            </if>
            <if test="userid != null">
                AND (t3.user_id = #{userid} OR t3.client_id = #{userid})
            </if>
        </where>
    </select>
    <select id="listAll" resultType="com.sandu.ximon.dao.domain.BroadcastTerminalV2Entity">
        SELECT
        t1.*, t3.pole_name
@@ -28,7 +48,6 @@
    </select>
    <select id="getBroadcastTerminalList" resultType="com.sandu.ximon.dao.bo.BroadcastTerminalV2EntityBo">
        SELECT
        t1.*, t2.pole_id,
        t3.pole_name
dao/src/main/resources/mapper/MonitorMapper.xml
@@ -18,6 +18,28 @@
        <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
        <result property="netAddress" column="net_address" jdbcType="VARCHAR"/>
    </resultMap>
    <select id="newListMonitorOnBind" resultType="com.sandu.ximon.dao.bo.MonitorBo">
        SELECT
        t1.*, t2.pole_id,
        t3.pole_name, t3.province,t3.city,t3.region,t3.address
        FROM
        monitor t1
        LEFT JOIN pole_binding t2 ON t1.device_serial = t2.device_code
        AND t2.device_type = 7
        LEFT JOIN pole t3 ON t3.id = t2.pole_id
        <where>
            <if test="userid != null">
                AND (t3.user_id = #{userid} OR t3.client_id = #{userid})
            </if>
            <if test="keyword != null and keyword != ''">
                AND (
                t1.device_serial LIKE CONCAT(CONCAT('%', #{keyword}), '%')
                OR t1.note LIKE CONCAT(CONCAT('%', #{keyword}), '%')
                OR t1.id LIKE CONCAT(CONCAT('%', #{keyword}), '%'))
            </if>
        </where>
    </select>
    <select id="listMonitorByIds" resultType="com.sandu.ximon.dao.bo.MonitorBo">
        SELECT
ximon-admin/src/main/java/com/sandu/ximon/admin/controller/GetListOnBindingController.java
@@ -215,13 +215,13 @@
    private final MonitorMapper monitorMapper;
    @GetMapping("/getMonitorList")
    public ResponseVO<Object> getMonitorList() {
    public ResponseVO<Object> getMonitorList(@RequestParam(required = false, value = "keyword") String keyword) {
        List<MonitorBo> monitorBos;
        //超管
        if (SecurityUtils.getClientId() == null) {
            monitorBos = monitorMapper.listMonitorDeviceSerial1(null, null, 2, null);
            monitorBos = monitorMapper.newListMonitorOnBind(null, keyword);
        } else {
            monitorBos = monitorMapper.listMonitorDeviceSerial1(SecurityUtils.getUserId(), null, 2, null);
            monitorBos = monitorMapper.newListMonitorOnBind(SecurityUtils.getUserId(), keyword);
        }
        List<Map> mapList = new ArrayList<>();
        Map map;
@@ -244,12 +244,12 @@
    private final IpVolumeService ipVolumeService;
    @GetMapping("/getIpVolumeList")
    public ResponseVO<Object> getIpVolumeList() {
    public ResponseVO<Object> getIpVolumeList(@RequestParam(required = false, value = "keyword") String keyword) {
        BroadcastTerminalV2Param param = new BroadcastTerminalV2Param();
        param.setBindingState(2);
        param.setKeyword(null);
        param.setWorkState(2);
        List<BroadcastTerminalV2EntityBo> broadcastTerminalList = ipVolumeService.getBroadcastTerminalList(null, null, null, param);
        List<BroadcastTerminalV2EntityBo> broadcastTerminalList = ipVolumeService.newIpTerminalList(keyword);
        List<Map> mapList = new ArrayList<>();
        Map map;
        for (BroadcastTerminalV2EntityBo bean : broadcastTerminalList) {
@@ -271,8 +271,8 @@
    private final IpVolumeFileService ipVolumeFileService;
    @GetMapping("/getIpFileList")
    public ResponseVO<Object> getIpFileList() {
        List<IpVolumeFile> ipVolumeFiles = ipVolumeFileService.listFiles();
    public ResponseVO<Object> getIpFileList(@RequestParam(required = false, value = "keyword") String keyword) {
        List<IpVolumeFile> ipVolumeFiles = ipVolumeFileService.listFiles(keyword);
        List<Map> mapList = new ArrayList<>();
        Map map;
        for (IpVolumeFile bean : ipVolumeFiles) {
ximon-admin/src/main/java/com/sandu/ximon/admin/service/IpVolumeFileService.java
@@ -1,6 +1,7 @@
package com.sandu.ximon.admin.service;
import com.alibaba.fastjson.JSON;
import com.alipay.service.schema.util.StringUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
@@ -134,7 +135,7 @@
        return list;
    }
    public List<IpVolumeFile> listFiles() {
    public List<IpVolumeFile> listFiles(String keyword) {
        LambdaQueryWrapper<IpVolumeFile> wrapper = Wrappers.lambdaQuery(IpVolumeFile.class);
        //不是超管
@@ -144,6 +145,9 @@
                        file.eq(IpVolumeFile::getUserId, SecurityUtils.getUserId());
                    });
        }
        if (keyword != null && !StringUtil.isEmpty(keyword)) {
            wrapper.like(IpVolumeFile::getFileName, keyword);
        }
        return list(wrapper);
    }
ximon-admin/src/main/java/com/sandu/ximon/admin/service/IpVolumeService.java
@@ -157,6 +157,33 @@
        }
    }
    public List<BroadcastTerminalV2EntityBo> newIpTerminalList(String keyword) {
        List<BroadcastTerminalV2EntityBo> broadcastTerminalV2EntityBos = broadcastTerminalV2EntityMapper.newListTerminalOnBind(SecurityUtils.getClientId(), keyword);
        List<TerminalVO> list = TerminalAPIUtils.getTerminalList();
        for (BroadcastTerminalV2EntityBo bean : broadcastTerminalV2EntityBos) {
            for (TerminalVO terminalVO : list) {
                if (bean.getId().equals(terminalVO.getId())) {
                    bean.setStatus(terminalVO.getStatus());
                    bean.setIp(terminalVO.getIp());
                    bean.setVolumn(terminalVO.getVolumn());
                    bean.setDefaultVolumn(terminalVO.getDefaultVolumn());
                    bean.setPower(terminalVO.getPower());
                    bean.setDefaultPower(terminalVO.getDefaultPower());
                    bean.setLast(terminalVO.getLast());
                    bean.setTaskType(terminalVO.getTaskType());
                    bean.setTaskID(terminalVO.getTaskID());
                    break;
                }
            }
        }
        return broadcastTerminalV2EntityBos;
    }
    /**
     * 修改设备绑定状态
     *