优化

liuhaonan

2022-07-21 38b60d99fc04db878c43cb9f6d03476a30979be6

优化

 ximon-admin/src/main/java/com/sandu/ximon/admin/dto/TerminalDto.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
package com.sandu.ximon.admin.dto;

import lombok.Data;

@Data
public class TerminalDto {
    //  ç»ˆç«¯å”¯ä¸€æ ‡è¯†ï¼ˆ>=1)
    private Integer id;
    //  ç»ˆç«¯ç±»åž‹æ ‡è¯†
    private Integer type;
    //  ç»ˆç«¯åç§°
    private String name;
    //  ç»ˆç«¯çŠ¶æ€ï¼ˆç©ºé—² 1、工作中 2 æˆ–者 4、断线 0，报 é”™ 8）
    private Integer status;
    //  ç»ˆç«¯ IP åœ°å€
    private String ip;
    //  ç»ˆç«¯éŸ³é‡(1-100)
    private Integer volumn;
    //  ç»ˆç«¯ç™»é™†çš„默认音量
    private Integer defaultVolumn;
    //  ç»ˆç«¯åŠŸæ”¾çŠ¶æ€(开为 1、关为 0）
    private Integer power;
    //  ç»ˆç«¯ç™»é™†çš„默认功放状态
    private Integer defaultPower;
    //  ç³»ç»Ÿä¿ç•™
    private String context;
    //  ç»ˆç«¯æœ€è¿‘一次登陆时间
    private Integer last;
    //  æ’­æ”¾æ—¶ï¼Œä»»åŠ¡çš„类型
    private Integer taskType;
    //  æ’­æ”¾æ—¶ï¼Œä»»åŠ¡çš„ ID
    private Long taskID;
    //  æ„Ÿåº”触发播放的音频，要终端有触发功能支持
    private String media;
    //  å‘¼å«ç­–ç•¥ ID，要终端有呼叫功能支持
    private Integer strategy_id;

}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/IpVolumeService.java

@@ -11,7 +11,7 @@
import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
import com.sandu.ximon.admin.utils.TerminalAPIUtils;
import com.sandu.ximon.admin.vo.EquipmentInfomation;
import com.sandu.ximon.admin.vo.TerminalVO;
import com.sandu.ximon.admin.dto.TerminalDto;
import com.sandu.ximon.dao.bo.BroadcastTerminalV2EntityBo;
import com.sandu.ximon.dao.domain.BroadcastTerminalV2Entity;
import com.sandu.ximon.dao.enums.AdministratorEnums;
@@ -36,7 +36,7 @@
    public void synchTerminal() {
        List<BroadcastTerminalV2Entity> server = broadcastTerminalV2EntityMapper.listAll();

        List<TerminalVO> list = TerminalAPIUtils.getTerminalList();
        List<TerminalDto> list = TerminalAPIUtils.getTerminalList();
        System.out.println(list);
        list.stream().forEach(item -> {
            //  éŸ³æŸ±æœåŠ¡å™¨ç»ˆç«¯ID
@@ -128,23 +128,23 @@
            }
        }

        List<TerminalVO> list = TerminalAPIUtils.getTerminalList();
        List<TerminalDto> 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());
            for (TerminalDto terminalDto : list) {
                if (bean.getId().equals(terminalDto.getId())) {
                    bean.setStatus(terminalDto.getStatus());
                    bean.setIp(terminalDto.getIp());
                    bean.setVolumn(terminalDto.getVolumn());
                    bean.setDefaultVolumn(terminalDto.getDefaultVolumn());
                    bean.setPower(terminalDto.getPower());
                    bean.setDefaultPower(terminalDto.getDefaultPower());
                    bean.setLast(terminalDto.getLast());
                    bean.setTaskType(terminalDto.getTaskType());
                    bean.setTaskID(terminalDto.getTaskID());

                    if (0 == broadcastTerminalV2Param.getWorkState() && 0 == terminalVO.getStatus()) {
                    if (0 == broadcastTerminalV2Param.getWorkState() && 0 == terminalDto.getStatus()) {
                        broadcastTerminalV2EntityBos_final.add(bean);
                    } else if (1 == broadcastTerminalV2Param.getWorkState() && 1 == terminalVO.getStatus()) {
                    } else if (1 == broadcastTerminalV2Param.getWorkState() && 1 == terminalDto.getStatus()) {
                        broadcastTerminalV2EntityBos_final.add(bean);
                    }
                    break;
@@ -164,19 +164,19 @@
        List<BroadcastTerminalV2EntityBo> broadcastTerminalV2EntityBos = broadcastTerminalV2EntityMapper.getListTerminalOnBind(SecurityUtils.getClientId(), keyword);


        List<TerminalVO> list = TerminalAPIUtils.getTerminalList();
        List<TerminalDto> 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());
            for (TerminalDto terminalDto : list) {
                if (bean.getId().equals(terminalDto.getId())) {
                    bean.setStatus(terminalDto.getStatus());
                    bean.setIp(terminalDto.getIp());
                    bean.setVolumn(terminalDto.getVolumn());
                    bean.setDefaultVolumn(terminalDto.getDefaultVolumn());
                    bean.setPower(terminalDto.getPower());
                    bean.setDefaultPower(terminalDto.getDefaultPower());
                    bean.setLast(terminalDto.getLast());
                    bean.setTaskType(terminalDto.getTaskType());
                    bean.setTaskID(terminalDto.getTaskID());
                    break;
                }
            }
@@ -245,7 +245,7 @@
            equipmentInfo.setEquipmentMac(id);
            equipmentInfo.setEquipmentName(one.getTerminalName());
        }
        TerminalVO terminalInfo = TerminalAPIUtils.getTerminalInfo(Integer.valueOf(id));
        TerminalDto terminalInfo = TerminalAPIUtils.getTerminalInfo(Integer.valueOf(id));
        if (terminalInfo != null) {
            //空闲 1、   å·¥ä½œä¸­ 2 æˆ–者 4、     æ–­çº¿ 0，    æŠ¥ é”™ 8
            switch (terminalInfo.getStatus()) {

 ximon-admin/src/main/java/com/sandu/ximon/admin/utils/TerminalAPIUtils.java

@@ -7,7 +7,11 @@
import com.sandu.ximon.admin.utils.response.CommonResponseVO;
import com.sandu.ximon.admin.utils.response.DataResponseVO;
import com.sandu.ximon.admin.vo.ListDataResponseVO;
import com.sandu.ximon.admin.dto.TerminalDto;
import com.sandu.ximon.admin.vo.TerminalVO;
import jodd.bean.BeanCopy;
import jodd.bean.BeanUtil;
import org.springframework.beans.BeanUtils;

import java.util.ArrayList;
import java.util.List;
@@ -20,7 +24,7 @@
     * @param terminalId
     * @return
     */
    public static TerminalVO getTerminalInfo(Integer terminalId) {
    public static TerminalDto getTerminalInfo(Integer terminalId) {
        DataResponseVO responseVO = JSON.parseObject(
                BroadcastPostUtils.Post(
                        new CommonRequestParams().put("id", terminalId).getParams(),
@@ -29,13 +33,22 @@
                DataResponseVO.class
        );

        return responseVO.convert(TerminalVO.class);
        TerminalVO bean = responseVO.convert(TerminalVO.class);

        TerminalDto terminalDto = new TerminalDto();
        BeanUtils.copyProperties(bean, terminalDto);
        //根据API上的更新字段做赋值修改
        terminalDto.setVolumn(bean.getVolume());
        terminalDto.setDefaultVolumn(bean.getFirstVol());
        terminalDto.setDefaultPower(bean.getFirstPower());

        return terminalDto;
    }

    /**
     * èŽ·å–终端服务器对象列表
     */
    public static List<TerminalVO> getTerminalList() {
    public static List<TerminalDto> getTerminalList() {
        ListDataResponseVO responseVO = JSON.parseObject(
                BroadcastPostUtils.Post(
                        new CommonRequestParams().getParams(),
@@ -43,8 +56,20 @@
                        CharUtils.GBK),
                ListDataResponseVO.class
        );
        return responseVO.covertTerminalList() == null ? new ArrayList<>() : responseVO.covertTerminalList();
//        return responseVO.covertTerminalList();

        List<TerminalDto> list = new ArrayList<>();
        if (responseVO.covertTerminalList() != null) {
            for (TerminalVO bean : responseVO.covertTerminalList()) {
                TerminalDto terminalDto = new TerminalDto();
                BeanUtils.copyProperties(bean, terminalDto);
                //根据API上的更新字段做赋值修改
                terminalDto.setVolumn(bean.getVolume());
                terminalDto.setDefaultVolumn(bean.getFirstVol());
                terminalDto.setDefaultPower(bean.getFirstPower());
                list.add(terminalDto);
            }
        }
        return list;
    }

    /**
@@ -106,7 +131,7 @@
     * @param defaultVolumn
     */
    public static boolean changeVol(Integer terminalId, Integer defaultVolumn) {
        TerminalVO terminalInfo = getTerminalInfo(terminalId);
        TerminalDto terminalInfo = getTerminalInfo(terminalId);
        if (terminalInfo == null) {
            throw new BusinessException("IP音柱硬件设备不存在");
        }

 ximon-admin/src/main/java/com/sandu/ximon/admin/vo/ListDataResponseVO.java

@@ -2,6 +2,7 @@

import com.google.common.reflect.TypeToken;
import com.google.gson.Gson;
import com.sandu.ximon.admin.dto.TerminalDto;
import com.sandu.ximon.admin.utils.response.CommonResponseVO;
import lombok.Data;


 ximon-admin/src/main/java/com/sandu/ximon/admin/vo/TerminalVO.java

@@ -15,13 +15,13 @@
    //  ç»ˆç«¯ IP åœ°å€
    private String ip;
    //  ç»ˆç«¯éŸ³é‡(1-100)
    private Integer volumn;
    private Integer volume;
    //  ç»ˆç«¯ç™»é™†çš„默认音量
    private Integer defaultVolumn;
    private Integer firstVol;
    //  ç»ˆç«¯åŠŸæ”¾çŠ¶æ€(开为 1、关为 0）
    private Integer power;
    //  ç»ˆç«¯ç™»é™†çš„默认功放状态
    private Integer defaultPower;
    private Integer firstPower;
    //  ç³»ç»Ÿä¿ç•™
    private String context;
    //  ç»ˆç«¯æœ€è¿‘一次登陆时间