| New file | 
 |  |  | 
 |  |  | package com.dy.rtuMw.server.forTcp; | 
 |  |  |  | 
 |  |  | import org.apache.logging.log4j.*; | 
 |  |  |  | 
 |  |  | import com.dy.rtuMw.resource.ResourceUnit; | 
 |  |  | import com.dy.rtuMw.resource.rtuLog.RtuLogNode; | 
 |  |  |  | 
 |  |  |  | 
 |  |  | public class RtuLogDealer { | 
 |  |  |    private static Logger log = LogManager.getLogger(RtuLogDealer.class.getName()) ; | 
 |  |  |    /** | 
 |  |  |     * 记录Rtu日志 | 
 |  |  |     * @param rtuAddr | 
 |  |  |     * @param content | 
 |  |  |     */ | 
 |  |  |    public static void log(String rtuAddr, String content){ | 
 |  |  |       if(rtuAddr == null || rtuAddr.trim().equals("")){ | 
 |  |  |          log.error("严重错误,记录Rtu日志时,rtu地址未提供!") ; | 
 |  |  |          return ; | 
 |  |  |       } | 
 |  |  |       if(content == null || content.equals("")){ | 
 |  |  |          log.error("严重错误,记录Rtu日志时,日志内容未提供!") ; | 
 |  |  |          return ; | 
 |  |  |       } | 
 |  |  |       RtuLogNode logNode = new RtuLogNode(rtuAddr, content) ; | 
 |  |  | 		 | 
 |  |  |       ResourceUnit.getInstance().rtuLog(logNode); | 
 |  |  |    } | 
 |  |  |    /** | 
 |  |  |     * 记录Rtu日志 | 
 |  |  |     * @param devId | 
 |  |  |     * @param content | 
 |  |  |     */ | 
 |  |  |    public static void log4Mqtt(String devId, String content){ | 
 |  |  |       if(devId == null || devId.trim().equals("")){ | 
 |  |  |          log.error("严重错误,记录Mqtt设备日志时,设备地址未提供!") ; | 
 |  |  |          return ; | 
 |  |  |       } | 
 |  |  |       if(content == null || content.equals("")){ | 
 |  |  |          log.error("严重错误,记录Mqtt设备日志时,日志内容未提供!") ; | 
 |  |  |          return ; | 
 |  |  |       } | 
 |  |  |       RtuLogNode logNode = new RtuLogNode(devId, content) ; | 
 |  |  |  | 
 |  |  |       ResourceUnit.getInstance().rtuLog(logNode); | 
 |  |  |    } | 
 |  |  |  | 
 |  |  | } |