bug修复

liuhaonan

2022-04-26 d8bd5680f12b212d740ba7b8f5d641e3a327faca

bug修复

 dao/src/main/java/com/sandu/ximon/dao/mapper/AirDataMapper.java

@@ -18,6 +18,8 @@
    List<Long> listAirId(String keyword, Long userid);

    List<AirDataBo> listAirDataByIds(List<Long> airIdList);

    String getCodeByPoleId(Long poleId ,Long userId);
}



 dao/src/main/resources/mapper/AirDataMapper.xml

@@ -32,10 +32,8 @@
    </resultMap>

    <select id="listAirEquipmentMAC" resultType="java.lang.String">
            SELECT DISTINCT
            device_mac
            FROM
             air_data
        SELECT DISTINCT device_mac
        FROM air_data
    </select>


@@ -77,4 +75,15 @@
            </foreach>
        </where>
    </select>
    <select id="getCodeByPoleId" resultType="java.lang.String">
        select t1.device_code
        from pole_binding t1
        left join pole t2 on t1.pole_id = t2.id
        where t1.device_type = 3
        t1.pole_id = #{poleId}
        <if test="userId != null">
            AND (t2.user_id = #{clientId} OR t2.client_id = #{clientId})
        </if>

</select>
</mapper>

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

@@ -5,11 +5,12 @@
import com.github.pagehelper.PageHelper;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.common.util.ResUtils;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5AtmosphereHeartbeatReportInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.AtmoFunctionCode;
import com.sandu.ximon.admin.security.SecurityUtils;
import com.sandu.ximon.admin.utils.RedisUtils;
import com.sandu.ximon.dao.bo.AirDataBo;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5AtmosphereHeartbeatReportInnerFrame;
import com.sandu.ximon.dao.domain.AirData;
import com.sandu.ximon.dao.domain.AirEquipment;
import com.sandu.ximon.dao.mapper.AirDataMapper;
@@ -75,4 +76,19 @@
        return airDataMapper.listAirEquipmentMAC();
    }

    /**
     * +
     * 根据灯杆id查询大气数据
     */
    public AirData listAirDataByLightPoleId(Long poleId) {
        String code;
        if (SecurityUtils.getClientId() != null) {
            code = baseMapper.getCodeByPoleId(poleId, SecurityUtils.getUserId());
        } else {
            code = baseMapper.getCodeByPoleId(poleId, null);
        }
        AirData airData = RedisUtils.getBean().get(code, AirData.class);
        return airData;
    }

}

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

@@ -223,4 +223,10 @@
    }


    /**
     * 推送大气数据到熙讯LED
     */



}