• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Profile类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.owera.xaps.dbi.Profile的典型用法代码示例。如果您正苦于以下问题:Java Profile类的具体用法?Java Profile怎么用?Java Profile使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Profile类属于com.owera.xaps.dbi包,在下文中一共展示了Profile类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: generateFromSyslog

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public Report<RecordProvisioning> generateFromSyslog(PeriodType periodType, Date start, Date end, List<Unittype> uts, List<Profile> prs, String unitId, Group group)
		throws NoAvailableConnectionException, SQLException, IOException {
	Map<String, Report<RecordProvisioning>> unitReportMap = generateFromSyslogImpl(periodType, start, end, uts, prs, unitId, group);
	Report<RecordProvisioning> endReport = new Report<RecordProvisioning>(RecordProvisioning.class, periodType);

	for (Report<RecordProvisioning> report : unitReportMap.values()) {
		for (RecordProvisioning record : report.getMap().values()) {
			RecordProvisioning endRecord = endReport.getRecord(record.getKey());
			if (endRecord == null)
				endReport.setRecord(record.getKey(), record);
			else
				endRecord.add(record);
		}
	}
	return endReport;
}
 
开发者ID:freeacs,项目名称:dbi,代码行数:17,代码来源:ReportProvisioningGenerator.java


示例2: generateFromSyslog

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public Report<RecordVoipCall> generateFromSyslog(PeriodType periodType, Date start, Date end, List<Unittype> uts, List<Profile> prs, String unitId, String line, Group group)
		throws NoAvailableConnectionException, SQLException, IOException {
	Report<RecordVoipCall> report = new Report<RecordVoipCall>(RecordVoipCall.class, periodType);
	logInfo("VoipCallReport", null, uts, prs, start, end);
	if (unitId != null)
		unitId = "^" + unitId + "$";
	List<SyslogEntry> entries = readSyslog(start, end, uts, prs, unitId, line);
	Map<String, Unit> unitsInGroup = getUnitsInGroup(group);
	for (SyslogEntry entry : entries) {
		if (group != null && unitsInGroup.get(entry.getUnitId()) == null)
			continue;
		addToReport(report, entry, periodType);
	}
	
	logger.info(logPrefix + "HardwareReport: Have read " + entries.size() + " rows from syslog, report is now " + report.getMap().size() + " entries");
	return report;
}
 
开发者ID:freeacs,项目名称:dbi,代码行数:18,代码来源:ReportVoipCallGenerator.java


示例3: readSyslog

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
private List<SyslogEntry> readSyslog(Date start, Date end, List<Unittype> uts, List<Profile> prs, String unitId, String line) throws SQLException, NoAvailableConnectionException {
	Syslog syslog = new Syslog(sysCp, id);
	SyslogFilter filter = new SyslogFilter();
	filter.setFacility(16); // Only messages from device
	if (line == null)
		filter.setMessage("MOS Report:");
	else
		filter.setMessage("MOS Report: Channel " + line);
	filter.setUnitId(unitId);
	filter.setProfiles(prs);
	filter.setUnittypes(uts);
	filter.setCollectorTmsStart(start);
	filter.setCollectorTmsEnd(end);
	filter.setFacilityVersion(swVersion);
	return syslog.read(filter, xaps);
}
 
开发者ID:freeacs,项目名称:dbi,代码行数:17,代码来源:ReportVoipCallGenerator.java


示例4: getProfileFromXAPS

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
/**
 * This method will return the object from DBI if it can find it. Reasons
 * for not finding it is wrong name specified by the clients or no access
 * to the object for this user. However, returning the object does not implicate
 * all actions are allowed on this object (like add/change/delete). This
 * permission check is performed in DBI, and will throw IllegalArgumentExceptions
 * if it occur. 
 * @param unittypeName
 * @param profileName
 * @return
 * @throws RemoteException
 */
protected Profile getProfileFromXAPS(String unittypeName, String profileName) throws RemoteException {
	Unittype unittype = getUnittypeFromXAPS(unittypeName);
	if (profileName == null)
		throw error("The profile name is not specified");
	Profile profile = unittype.getProfiles().getByName(profileName);
	if (profile == null)
		throw error("The profile " + profileName + " is not found/allowed in xAPS");
	//		Permissions permissions = id.getUser().getPermissions();
	//		if (permissions.getPermissions().length == 0) {
	//			
	//			return profile;
	//		}
	//		if (permissions.getByUnittypeProfile(unittype.getId(), profile.getId()) == null)
	//			if (permissions.getByUnittypeProfile(unittype.getId(), null) == null)
	//				throw error("The login " + id.getUser().getUsername() + " does not have full access to profile " + profileName);
	
	return profile;
}
 
开发者ID:freeacs,项目名称:ws,代码行数:31,代码来源:XAPSWS.java


示例5: writeUnitSessionParams

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public void writeUnitSessionParams(SessionData sessionData) throws TR069DatabaseException {
	try {
		List<ParameterValueStruct> parameterValuesToDB = sessionData.getToDB();
		Unittype unittype = sessionData.getUnittype();
		Profile profile = sessionData.getProfile();
		List<UnitParameter> unitSessionParameters = new ArrayList<UnitParameter>();
		for (ParameterValueStruct pvs : parameterValuesToDB) {
			UnittypeParameter utp = unittype.getUnittypeParameters().getByName(pvs.getName());
			if (utp != null) {
				UnitParameter up = new UnitParameter(utp, sessionData.getUnitId(), pvs.getValue(), profile);
				if (utp.getName().startsWith("Device.") || utp.getName().startsWith("InternetGatewayDevice."))
					unitSessionParameters.add(up);
			} else
				Log.warn(DBAccessSession.class, "\t" + pvs.getName() + " : does not exist, cannot write session value " + pvs.getValue());
		}
		if (unitSessionParameters.size() > 0) {
			XAPSUnit xapsUnit = DBAccess.getXAPSUnit(xaps);
			xapsUnit.addOrChangeSessionUnitParameters(unitSessionParameters, profile);
		}
	} catch (SQLException sqle) {
		throw new TR069DatabaseException("Not possible to write session parameters to database", sqle);
	}
}
 
开发者ID:freeacs,项目名称:tr069,代码行数:24,代码来源:DBAccessSessionTR069.java


示例6: logInfo

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
protected void logInfo(String reportType, String unitId, List<Unittype> uts, List<Profile> prs, Date start, Date end) {
	String msg = logPrefix + reportType + ": Will generate from syslog (";
	if (unitId != null)
		msg += "unitId: " + unitId + ", ";
	if (uts != null)
		msg += "unittypes: " + uts.size() + ", ";
	if (prs != null)
		msg += "profile: " + prs.size() + ", ";
	msg += start + " - " + end + ")";

	logger.info(msg);
}
 
开发者ID:freeacs,项目名称:dbi,代码行数:13,代码来源:ReportGenerator.java


示例7: getUnittypeForParameters

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
private Unittype getUnittypeForParameters(List<Profile> allowedProfiles) throws RemoteException {
	Unittype unittype = allowedProfiles.get(0).getUnittype();
	for (Profile p : allowedProfiles) {
		if (!p.getUnittype().getName().equals(unittype.getName()))
			throw XAPSWS.error(logger, "Cannot specify parameters or SerialNumber without specifying Unittype"); // there are more than 1 unittype - indicating no unittype has been specified
	}
	return unittype;
}
 
开发者ID:freeacs,项目名称:ws,代码行数:9,代码来源:GetUnits.java


示例8: validateParameters

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
private List<Parameter> validateParameters(com.owera.xapsws.Unit unitWS, List<Profile> allowedProfiles) throws RemoteException {
	if (allowedProfiles == null || allowedProfiles.size() == 0)
		throw XAPSWS.error(logger, "Unittype and profiles are not specified, not possible to make parameter-search");
	List<Parameter> parameters = new ArrayList<Parameter>();
	if (unitWS.getParameters() != null && unitWS.getParameters().getParameterArray() != null) {
		Unittype unittype = getUnittypeForParameters(allowedProfiles);
		for (com.owera.xapsws.Parameter pWS : unitWS.getParameters().getParameterArray()) {
			UnittypeParameter utp = unittype.getUnittypeParameters().getByName(pWS.getName());
			if (utp == null)
				throw XAPSWS.error(logger, "Unittype parameter " + pWS.getName() + " is not found in unittype " + unittype.getName());
			//				boolean equal = true;
			ParameterDataType pdt = ParameterDataType.TEXT;
			Operator op = Operator.EQ;
			if (pWS.getFlags() != null) {
				String[] opTypeArr = pWS.getFlags().split(",");
				try {
					op = Operator.getOperatorFromLiteral(opTypeArr[0]);
					if (opTypeArr.length == 2)
						pdt = ParameterDataType.getDataType(opTypeArr[1]);
				} catch (IllegalArgumentException iae) {
					throw XAPSWS.error(logger, "An error occurred in flag (" + pWS.getFlags() + "): " + iae.getMessage());
				}
			}
			Parameter pXAPS = new Parameter(utp, pWS.getValue(), op, pdt);
			parameters.add(pXAPS);
		}
	}
	//		if (unitWS.getSerialNumber() != null) {
	//			Unittype unittype = getUnittypeForParameters(allowedProfiles);
	//			UnittypeParameter serialNumberUtp = getSerialNumberUtp(unittype);
	//			if (serialNumberUtp == null)
	//				throw XAPSWS.error(logger, "SerialNumber unittype parameter does not exist!");
	//			parameters.add(new Parameter(serialNumberUtp, unitWS.getSerialNumber(), true));
	//		}
	return parameters;
}
 
开发者ID:freeacs,项目名称:ws,代码行数:37,代码来源:GetUnits.java


示例9: validateUnitId

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
private String validateUnitId(Unit unitWS, Unittype unittype, Profile profile) throws SQLException, NoAvailableConnectionException, RemoteException {
	if (unitWS.getUnitId() == null) {
		if (unitWS.getSerialNumber() != null) {
			com.owera.xaps.dbi.Unit unitXAPS = xapsWS.getUnitByMAC(xapsUnit, unittype, profile, unitWS.getSerialNumber());
			if (unitXAPS != null) {
				unitWS.setUnitId(unitXAPS.getId());
			}
		}
		if (unitWS.getUnitId() == null)
			XAPSWS.error(logger, "No unitId or serial number is supplied to the service");
	}
	return unitWS.getUnitId();
}
 
开发者ID:freeacs,项目名称:ws,代码行数:14,代码来源:AddOrChangeUnit.java


示例10: validateDeleteUnitParameters

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
private List<UnitParameter> validateDeleteUnitParameters(Unit unitWS, Unittype unittype, Profile profile) throws RemoteException {
	List<UnitParameter> unitParams = new ArrayList<UnitParameter>();
	Parameter[] parameters = unitWS.getParameters().getParameterArray();
	for (Parameter p : parameters) {
		UnittypeParameter utp = unittype.getUnittypeParameters().getByName(p.getName());
		if (utp == null) {
			throw XAPSWS.error(logger, "Unittype parameter " + p.getName() + " is not found in unittype " + unittype.getName());
		} else {
			if (p.getFlags() != null && p.getFlags().equals("D")) {
				unitParams.add(new UnitParameter(utp, unitWS.getUnitId(), p.getValue(), profile));
			}
		}
	}
	return unitParams;
}
 
开发者ID:freeacs,项目名称:ws,代码行数:16,代码来源:AddOrChangeUnit.java


示例11: validateAddOrChangeUnitParameters

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
private List<UnitParameter> validateAddOrChangeUnitParameters(Unit unitWS, Unittype unittype, Profile profile) throws RemoteException {
	List<UnitParameter> unitParams = new ArrayList<UnitParameter>();
	Parameter[] parameters = unitWS.getParameters().getParameterArray();
	for (Parameter p : parameters) {
		UnittypeParameter utp = unittype.getUnittypeParameters().getByName(p.getName());
		if (utp == null) {
			throw XAPSWS.error(logger, "Unittype parameter " + p.getName() + " is not found in unittype " + unittype.getName());
		} else {
			if (p.getFlags() == null || p.getFlags().equals("AC")) {
				unitParams.add(new UnitParameter(utp, unitWS.getUnitId(), p.getValue(), profile));
			}
		}
	}
	return unitParams;
}
 
开发者ID:freeacs,项目名称:ws,代码行数:16,代码来源:AddOrChangeUnit.java


示例12: getProfiles

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public GetProfilesResponse getProfiles(GetProfilesRequest gur) throws RemoteException {
	try {
		
		xapsWS = XAPSWSFactory.getXAPSWS(gur.getLogin());
		if (gur.getUnittype() == null || gur.getUnittype().getName() == null)
			throw XAPSWS.error(logger, "No unittype is specified");
		Unittype unittype = xapsWS.getUnittypeFromXAPS(gur.getUnittype().getName());
		com.owera.xapsws.Profile[] profileArray = null;
		if (gur.getProfile() == null || gur.getProfile().getName() == null) {
			Profile[] profileXAPSArr = unittype.getProfiles().getProfiles();
			//				List<Profile> allowedProfiles = xapsWS.getXAPS().getAllowedProfiles(unittype);
			//				profileArray = new com.owera.xapsws.Profile[allowedProfiles.size()];
			profileArray = new com.owera.xapsws.Profile[profileXAPSArr.length];
			int i = 0;
			for (Profile profileXAPS : profileXAPSArr)
				profileArray[i++] = ConvertXAPS2WS.convert(profileXAPS);
			//				for (int i = 0; i < allowedProfiles.size(); i++)
			//					profileArray[i] = ConvertXAPS2WS.convert(allowedProfiles.get(i));
		} else {
			profileArray = new com.owera.xapsws.Profile[1];
			Profile p = xapsWS.getProfileFromXAPS(unittype.getName(), gur.getProfile().getName());
			profileArray[0] = ConvertXAPS2WS.convert(p);
		}
		return new GetProfilesResponse(new ProfileList(profileArray));
	} catch (Throwable t) {
		if (t instanceof RemoteException)
			throw (RemoteException) t;
		else {
			throw XAPSWS.error(logger, t);
		}
	}

}
 
开发者ID:freeacs,项目名称:ws,代码行数:34,代码来源:GetProfiles.java


示例13: getUnittypeForParameters

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
private Unittype getUnittypeForParameters(List<Profile> allowedProfiles) throws RemoteException {
	Unittype unittype = allowedProfiles.get(0).getUnittype();
	for (Profile p : allowedProfiles) {
		if (!p.getUnittype().getName().equals(unittype.getName()))
			// there are more than 1 unittype - indicating no unittype has been specified
			throw XAPSWS.error(logger, "Cannot specify parameters or SerialNumber without specifying Unittype");
	}
	return unittype;
}
 
开发者ID:freeacs,项目名称:ws,代码行数:10,代码来源:GetUnitIds.java


示例14: deleteProfile

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public DeleteProfileResponse deleteProfile(DeleteProfileRequest dur) throws RemoteException {
	try {
		
		xapsWS = XAPSWSFactory.getXAPSWS(dur.getLogin());
		xaps = xapsWS.getXAPS();
		if (dur.getUnittype() == null)
			throw XAPSWS.error(logger, "No unittype is specified");
		Unittype unittype = xapsWS.getUnittypeFromXAPS(dur.getUnittype().getName());
		if (dur.getProfile() == null)
			throw XAPSWS.error(logger, "No profile name is specified");
		Profile profile = xapsWS.getProfileFromXAPS(unittype.getName(), dur.getProfile().getName());
		int rowsDeleted = unittype.getProfiles().deleteProfile(profile, xaps, true);
		if (rowsDeleted > 0)
			return new DeleteProfileResponse(true);
		else
			return new DeleteProfileResponse(false);
	} catch (Throwable t) {
		if (t instanceof RemoteException)
			throw (RemoteException) t;
		else {
			String msg = "An exception occurred: " + t.getMessage();
			logger.error(msg, t);
			throw new RemoteException(msg, t);
		}
	}

}
 
开发者ID:freeacs,项目名称:ws,代码行数:28,代码来源:DeleteProfile.java


示例15: getUnitByMAC

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
protected com.owera.xaps.dbi.Unit getUnitByMAC(XAPSUnit xapsUnit, Unittype unittype, Profile profile, String searchStr) throws RemoteException, SQLException, NoAvailableConnectionException {
	com.owera.xaps.dbi.Unit unitFoundByMac = xapsUnit.getUnitByValue(searchStr, unittype, profile);
	if (unitFoundByMac != null) {
		return unitFoundByMac;
	} else {
		throw error("The serialNumber/unique value was not found in xAPS on unittype " + unittype.getName() + " and profile " + profile.getName());
	}
}
 
开发者ID:freeacs,项目名称:ws,代码行数:9,代码来源:XAPSWS.java


示例16: writeProfileChange

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public void writeProfileChange(String unitId, Profile newProfile) throws SQLException{
	long start = System.currentTimeMillis();
	String method = "writeProfileChange";
	try {
		XAPSUnit xapsUnit = DBAccess.getXAPSUnit(xaps);
		List<String> uList = new ArrayList<String>();
		uList.add(unitId);
		xapsUnit.addUnits(uList, newProfile);
	} catch (Throwable t) {
		DBAccess.handleError(method, start, t);
	}

}
 
开发者ID:freeacs,项目名称:prov,代码行数:14,代码来源:DBAccessSession.java


示例17: writeUnitParams

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public static void writeUnitParams(SessionData sessionData) {
	List<ParameterValueStruct> parameterValuesToDB = sessionData.getToDB();
	List<UnitParameter> unitParameters = new ArrayList<UnitParameter>();
	Unittype unittype = sessionData.getUnittype();
	Profile profile = sessionData.getProfile();
	Unit unit = sessionData.getUnit();
	for (ParameterValueStruct pvs : parameterValuesToDB) {
		UnittypeParameter utp = unittype.getUnittypeParameters().getByName(pvs.getName());
		if (utp != null) {
			unitParameters.add(new UnitParameter(utp, sessionData.getUnitId(), pvs.getValue(), profile));
		} else
			Log.warn(DBAccessSession.class, "\t" + pvs.getName() + " : does not exist, cannot write value " + pvs.getValue());
	}
	DBAccessStatic.queueUnitParameters(unit, unitParameters, profile);
}
 
开发者ID:freeacs,项目名称:tr069,代码行数:16,代码来源:DBAccessSessionTR069.java


示例18: generateFromReport

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public Report<RecordSyslog> generateFromReport(PeriodType periodType, Date start, Date end, List<Unittype> uts, List<Profile> prs) throws NoAvailableConnectionException, SQLException, IOException {
	Connection xapsConnection = null;
	Connection sysConnection = null;
	PreparedStatement ps = null;
	ResultSet rs = null;
	SQLException sqle = null;
	try {
		boolean foundDataInReportTable = false;
		Report<RecordSyslog> report = new Report<RecordSyslog>(RecordSyslog.class, periodType);
		
		logger.debug(logPrefix + "SyslogReport: Reads from report_syslog table from " + start + " to " + end);
		xapsConnection = ConnectionProvider.getConnection(xapsCp, true);
		DynamicStatement ds = selectReportSQL("report_syslog", periodType, start, end, uts, prs);
		ps = ds.makePreparedStatement(xapsConnection);
		rs = ps.executeQuery();
		int counter = 0;
		while (rs.next()) {
			counter++;
			start = rs.getTimestamp("timestamp_");
			String unittypeName = rs.getString("unit_type_name");
			String profileName = rs.getString("profile_name");
			String severity = rs.getString("severity");
			String eventId = rs.getString("syslog_event_id");
			String facility = rs.getString("facility");
			RecordSyslog recordTmp = new RecordSyslog(start, periodType, unittypeName, profileName, severity, eventId, facility);
			Key key = recordTmp.getKey();
			RecordSyslog record = report.getRecord(key);
			if (record == null)
				record = recordTmp;
			record.getMessageCount().add(rs.getInt("unit_count"));
			report.setRecord(key, record);
			foundDataInReportTable = true;
		}
		if (foundDataInReportTable)
			logger.debug(logPrefix + "SyslogReport: Have read " + counter + " rows, last tms was " + start + ", report is now " + report.getMap().size() + " entries");
		return report;
	} catch (SQLException sqlex) {
		sqle = sqlex;
		throw sqlex;
	} finally {
		if (rs != null)
			rs.close();
		if (ps != null)
			ps.close();
		if (xapsConnection != null)
			ConnectionProvider.returnConnection(xapsConnection, sqle);
		if (sysConnection != null)
			ConnectionProvider.returnConnection(sysConnection, sqle);
	}

}
 
开发者ID:freeacs,项目名称:dbi,代码行数:52,代码来源:ReportSyslogGenerator.java


示例19: generateFromReport

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public Report<RecordProvisioning> generateFromReport(PeriodType periodType, Date start, Date end, List<Unittype> uts, List<Profile> prs) throws NoAvailableConnectionException, SQLException,
		IOException {
	Connection xapsConnection = null;
	Connection sysConnection = null;
	PreparedStatement ps = null;
	ResultSet rs = null;
	SQLException sqle = null;
	try {
		boolean foundDataInReportTable = false;
		Report<RecordProvisioning> report = new Report<RecordProvisioning>(RecordProvisioning.class, periodType);

		logger.debug(logPrefix + "ProvisioningReport: Reads from report_prov table from " + start + " to " + end);
		xapsConnection = ConnectionProvider.getConnection(xapsCp, true);
		DynamicStatement ds = selectReportSQL("report_prov", periodType, start, end, uts, prs);
		ps = ds.makePreparedStatement(xapsConnection);
		rs = ps.executeQuery();
		int counter = 0;
		while (rs.next()) {
			counter++;
			start = rs.getTimestamp("timestamp_");
			String unittypeName = rs.getString("unit_type_name");
			String profileName = rs.getString("profile_name");
			String softwareVersion = rs.getString("software_version");
			String output = rs.getString("prov_output");
			RecordProvisioning recordTmp = new RecordProvisioning(start, periodType, unittypeName, profileName, softwareVersion, output);
			Key key = recordTmp.getKey();
			RecordProvisioning record = report.getRecord(key);
			if (record == null)
				record = recordTmp;
			record.getProvisioningOkCount().add(rs.getInt("ok_count"));
			record.getProvisioningRescheduledCount().add(rs.getInt("rescheduled_count"));
			record.getProvisioningErrorCount().add(rs.getInt("error_count"));
			record.getProvisioningMissingCount().add(rs.getInt("missing_count"));
			record.getSessionLengthAvg().add(rs.getInt("session_length_avg"),
					record.getProvisioningOkCount().get() + record.getProvisioningRescheduledCount().get() + record.getProvisioningErrorCount().get() + record.getProvisioningMissingCount().get());
			report.setRecord(key, record);
			foundDataInReportTable = true;
		}
		if (foundDataInReportTable)
			logger.debug(logPrefix + "ProvisioningReport: Have read " + counter + " rows, last tms was " + start + ", report is now " + report.getMap().size() + " entries");
		return report;
	} catch (SQLException sqlex) {
		sqle = sqlex;
		throw sqlex;
	} finally {
		if (rs != null)
			rs.close();
		if (ps != null)
			ps.close();
		if (xapsConnection != null)
			ConnectionProvider.returnConnection(xapsConnection, sqle);
		if (sysConnection != null)
			ConnectionProvider.returnConnection(sysConnection, sqle);
	}
}
 
开发者ID:freeacs,项目名称:dbi,代码行数:56,代码来源:ReportProvisioningGenerator.java


示例20: generateFromReport

import com.owera.xaps.dbi.Profile; //导入依赖的package包/类
public Report<RecordVoip> generateFromReport(PeriodType periodType, Date start, Date end, List<Unittype> uts, List<Profile> prs) throws NoAvailableConnectionException, SQLException, IOException {
	Connection xapsConnection = null;
	Connection sysConnection = null;
	PreparedStatement ps = null;
	ResultSet rs = null;
	SQLException sqle = null;
	try {
		boolean foundDataInReportTable = false;
		Report<RecordVoip> report = new Report<RecordVoip>(RecordVoip.class, periodType);

		logger.debug(logPrefix + "VoipReport: Reads from report_voip table from " + start + " to " + end);
		xapsConnection = ConnectionProvider.getConnection(xapsCp, true);
		DynamicStatement ds = selectReportSQL("report_voip", periodType, start, end, uts, prs);
		ps = ds.makePreparedStatement(xapsConnection);
		rs = ps.executeQuery();
		int counter = 0;
		while (rs.next()) {
			counter++;
			start = rs.getTimestamp("timestamp_");
			String unittypeName = rs.getString("unit_type_name");
			String profileName = rs.getString("profile_name");
			String softwareVersion = rs.getString("software_version");
			String line = rs.getString("line");
			RecordVoip recordTmp = new RecordVoip(start, periodType, unittypeName, profileName, softwareVersion, line);
			Key key = recordTmp.getKey();
			RecordVoip record = report.getRecord(key);
			if (record == null)
				record = recordTmp;
			record.getIncomingCallCount().add(rs.getInt("incoming_call_count"));
			record.getCallLengthTotal().add(rs.getInt("call_length_total"));
			record.getOutgoingCallCount().add(rs.getInt("outgoing_call_count"));
			record.getAbortedCallCount().add(rs.getInt("aborted_call_count"));
			record.getCallLengthAvg().add(rs.getInt("call_length_avg"), record.getIncomingCallCount().get() + record.getOutgoingCallCount().get());
			//				record.getJitterAbove200msCount().add(rs.getInt("jitter_above200ms_count"));
			record.getJitterAvg().add(rs.getInt("jitter_avg"), record.getCallLengthTotal().get());
			record.getJitterMax().add(rs.getInt("jitter_max"), record.getCallLengthTotal().get());
			//				record.getMos12Count().add(rs.getInt("mos_1_2_count"));
			//				record.getMos23Count().add(rs.getInt("mos_2_3_count"));
			//				record.getMos34Count().add(rs.getInt("mos_3_4_count"));
			//				record.getMos45Count().add(rs.getInt("mos_4_5_count"));
			record.getMosAvg().add(rs.getInt("mos_avg"), record.getCallLengthTotal().get());
			record.getOutgoingCallFailedCount().add(rs.getInt("outgoing_call_failed_count"));
			//				record.getPercentLossAbove10Count().add(rs.getInt("percent_loss_above10_count"));
			record.getPercentLossAvg().add(rs.getInt("percent_loss_avg"), record.getCallLengthTotal().get());
			//				record.getSipRegisterFailedCount().add(rs.getInt("sip_reg_failed_count"));
			record.getNoSipServiceTime().add(rs.getInt("no_sip_service_time"));
			report.setRecord(key, record);
			foundDataInReportTable = true;
		}
		if (foundDataInReportTable)
			logger.debug(logPrefix + "VoipReport: Have read " + counter + " rows, last tms was " + start + ", report is now " + report.getMap().size() + " entries");
		return report;
	} catch (SQLException sqlex) {
		sqle = sqlex;
		throw sqlex;
	} finally {
		if (rs != null)
			rs.close();
		if (ps != null)
			ps.close();
		if (xapsConnection != null)
			ConnectionProvider.returnConnection(xapsConnection, sqle);
		if (sysConnection != null)
			ConnectionProvider.returnConnection(sysConnection, sqle);
	}

}
 
开发者ID:freeacs,项目名称:dbi,代码行数:68,代码来源:ReportVoipGenerator.java



注:本文中的com.owera.xaps.dbi.Profile类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java NumericWheelAdapter类代码示例发布时间:2022-05-22
下一篇:
Java EnumTypeDefinition类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap