changes

liuhaonan

2022-09-06 4791362c19d2d27a51593d625abb24173d1c63f2

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

@@ -1,13 +1,19 @@
package com.sandu.ximon.admin.utils;

import com.alibaba.fastjson.JSON;
import com.sandu.common.execption.BusinessException;
import com.sandu.ximon.admin.config.BroadcastAPI;
import com.sandu.ximon.admin.utils.request.CommonRequestParams;
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;

public class TerminalAPIUtils {
@@ -18,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(),
@@ -27,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(),
@@ -41,7 +56,20 @@
                        CharUtils.GBK),
                ListDataResponseVO.class
        );
        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;
    }

    /**
@@ -102,8 +130,11 @@
     * @param terminalId
     * @param defaultVolumn
     */
    public static boolean changeVol(Integer terminalId, Integer defaultVolumn, Long userId) {
        TerminalVO terminalInfo = getTerminalInfo(terminalId);
    public static boolean changeVol(Integer terminalId, Integer defaultVolumn) {
        TerminalDto terminalInfo = getTerminalInfo(terminalId);
        if (terminalInfo == null) {
            throw new BusinessException("IP音柱硬件设备不存在");
        }
        terminalInfo.setDefaultVolumn(defaultVolumn);
        terminalInfo.setVolumn(defaultVolumn);
        CommonResponseVO responseVO = JSON.parseObject(
@@ -117,10 +148,8 @@
                CommonResponseVO.class
        );
        if (responseVO.isOK()) {
//            log("修改播放终端音量(id:"+terminalId+")",userId,null);
            return true;
        }
//        logError("修改播放终端音量失败!(id:"+terminalId+")",userId,null);
        return false;
    }