utils/dnp3_src/cpp/examples/outstation/main.cpp - master - tisit/OpenPLC_v3

utils/dnp3_src/cpp/examples/outstation/main.cpp
166 строк5 KB
thiagoralves
First commit. OpenPLC v3 beta 1
14 июн 2018, 20:43
14 июн 2018, 20:431b10e97
/*
 * Licensed to Green Energy Corp (www.greenenergycorp.com) under one or
 * more contributor license agreements. See the NOTICE file distributed
 * with this work for additional information regarding copyright ownership.
 * Green Energy Corp licenses this file to you under the Apache License,
 * Version 2.0 (the "License"); you may not use this file except in
 * compliance with the License.  You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * This project was forked on 01/01/2013 by Automatak, LLC and modifications
 * may have been made to this file. Automatak, LLC licenses these modifications
 * to you under the terms of the License.
 */
#include <asiodnp3/DNP3Manager.h>
#include <asiodnp3/PrintingSOEHandler.h>
#include <asiodnp3/PrintingChannelListener.h>
#include <asiodnp3/ConsoleLogger.h>
#include <asiodnp3/UpdateBuilder.h>

#include <asiopal/UTCTimeSource.h>
#include <opendnp3/outstation/SimpleCommandHandler.h>

#include <opendnp3/outstation/IUpdateHandler.h>

#include <opendnp3/LogLevels.h>

#include <string>
#include <thread>
#include <iostream>

using namespace std;
using namespace opendnp3;
using namespace openpal;
using namespace asiopal;
using namespace asiodnp3;

void ConfigureDatabase(DatabaseConfig& config)
{
	// example of configuring analog index 0 for Class2 with floating point variations by default
	config.analog[0].clazz = PointClass::Class2;
	config.analog[0].svariation = StaticAnalogVariation::Group30Var5;
	config.analog[0].evariation = EventAnalogVariation::Group32Var7;
}

struct State
{
	uint32_t count = 0;
	double value = 0;
	bool binary = false;
	DoubleBit dbit = DoubleBit::DETERMINED_OFF;
};

void AddUpdates(UpdateBuilder& builder, State& state, const std::string& arguments);



int main(int argc, char* argv[])
{

	// Specify what log levels to use. NORMAL is warning and above
	// You can add all the comms logging by uncommenting below.
	const uint32_t FILTERS = levels::NORMAL | levels::ALL_COMMS;

	// This is the main point of interaction with the stack
	// Allocate a single thread to the pool since this is a single outstation
	// Log messages to the console
	DNP3Manager manager(1, ConsoleLogger::Create());

	// Create a TCP server (listener)
	auto channel = manager.AddTCPServer("server", FILTERS, ChannelRetry::Default(), "0.0.0.0", 20000, PrintingChannelListener::Create());

	// The main object for a outstation. The defaults are useable,
	// but understanding the options are important.
	OutstationStackConfig config(DatabaseSizes::AllTypes(10));

	// Specify the maximum size of the event buffers
	config.outstation.eventBufferConfig = EventBufferConfig::AllTypes(10);

	// you can override an default outstation parameters here
	// in this example, we've enabled the oustation to use unsolicted reporting
	// if the master enables it
	config.outstation.params.allowUnsolicited = true;

	// You can override the default link layer settings here
	// in this example we've changed the default link layer addressing
	config.link.LocalAddr = 10;
	config.link.RemoteAddr = 1;

	config.link.KeepAliveTimeout = openpal::TimeDuration::Max();

	// You can optionally change the default reporting variations or class assignment prior to enabling the outstation
	ConfigureDatabase(config.dbConfig);

	// Create a new outstation with a log level, command handler, and
	// config info this	returns a thread-safe interface used for
	// updating the outstation's database.
	auto outstation = channel->AddOutstation("outstation", SuccessCommandHandler::Create(), DefaultOutstationApplication::Create(), config);

	// Enable the outstation and start communications
	outstation->Enable();

	// variables used in example loop
	string input;
	State state;

	while (true)
	{
		std::cout << "Enter one or more measurement changes then press <enter>" << std::endl;
		std::cout << "c = counter, b = binary, d = doublebit, a = analog, 'quit' = exit" << std::endl;
		std::cin >> input;

		if (input == "quit") return 0; // DNP3Manager destructor cleanups up everything automatically
		else
		{
			// update measurement values based on input string
			UpdateBuilder builder;
			AddUpdates(builder, state, input);
			outstation->Apply(builder.Build());
		}
	}

	return 0;
}

void AddUpdates(UpdateBuilder& builder, State& state, const std::string& arguments)
{
	for (const char& c : arguments)
	{
		switch (c)
		{
		case('c'):
			{
				builder.Update(Counter(state.count), 0);
				++state.count;
				break;
			}
		case('a'):
			{
				builder.Update(Analog(state.value), 0);
				state.value += 1;
				break;
			}
		case('b'):
			{
				builder.Update(Binary(state.binary), 0);
				state.binary = !state.binary;
				break;
			}
		case('d'):
			{
				builder.Update(DoubleBitBinary(state.dbit), 0);
				state.dbit = (state.dbit == DoubleBit::DETERMINED_OFF) ? DoubleBit::DETERMINED_ON : DoubleBit::DETERMINED_OFF;
				break;
			}
		default:
			break;
		}
	}
}