Сфера грузоперевозок

if (Qso2 < 35 && Qso2 >0) { Qso2 = 35; }

if (Qso2 > 3000) { Qso2 = 300; }

//int Chart1 = 60000 - 10 * Qso1;

//int Chart2 = 60000 - 10 * Qso2;

SolidBrush brush2 = new SolidBrush(Color.Aqua);

Rectangle rect1 = new Rectangle(w, panel1.Height - Qso2, 50, (Qso2-30));

graph.FillRectangle(brush2, rect1);

brush.Color = Color.Black;

graph.DrawString(Qso1.ToString(), arial3, brush, w, panel1.Height-20);

graph.DrawString(Convert.ToString(Math.Round(Convert.ToDouble(items[i].ToString()), 5)), arial3, brush, w, 10);

/* SolidBrush brush2 = new SolidBrush(Color.AliceBlue);

Rectangle rect2 = new Rectangle(170, w, 50, (Qso2));

graph.FillRectangle(brush2, rect2);*/

}

}

}

}

private void button11_Click(object sender, EventArgs e)

{

StreamWriter sw; // объект потока для записи

StringBuilder builder; // построитель строк

builder = new StringBuilder();

// добавляем текст

/*if (textBox1.Text == "")

{

MessageBox.Show("Введите ставку дисконтирования!");

return;

}*/

if ((comboBox1.Text == "") || (comboBox2.Text == ""))

{

MessageBox.Show("Необходимо выбрать клиента и товар!");

return;

}

/*string strSQL = "select POWER((1+ " + textBox1.Text + " ),number(*)) /sum((A.sum_in - A.sum_out)) as r2, year " +

" from res A where A.id_c = " + id1[comboBox2.SelectedIndex] + " and A.id_k = " + id1[comboBox1.SelectedIndex] + " group by year ";// "select sum(r2) from #t1 drop table #T1";

*/

string strSQL = "Select C.Id_res, c.name, B.Name, A.Name, C.price,C.date_sale from kinds A, Clients B, Res C where A.id = C. id_k and B.Id = Id_c " +

" and c.id_c = " + id1[comboBox2.SelectedIndex] +

" and c.id_k = " + id1[comboBox1.SelectedIndex] +

" order by B.name";

ArrayList arrList = clientThread.doQuery(strSQL);

builder.Append("Отчет для клиента " + comboBox2.Text + " для " + comboBox1.Text + " .");

builder.AppendLine();

foreach (ArrayList items in arrList)

{

//a++;

//builder.Append(a.ToString() + ". ");

string[] strItems = new string[items.Count];

for (int i = 0; i < items.Count; i++)

{

builder.Append(items[i].ToString() + " ");

if (i == 0) { builder.Append(" ");}

else { builder.Append(" ");

builder.AppendLine();

}

}

}

// builder.AppendLine();

builder.AppendFormat("Сегодня: {0:F}.", DateTime.Now);

// создаем поток для записи - file.txt с добавлением в конец файла, кодировка UTF8

using (sw = new StreamWriter(@"file.txt", true, Encoding.UTF8))

{

//sw.WriteLine("Начинаем запись"); // запись строки

sw.Write(builder.ToString()); // запись сформированного списка строк

// сбрасываем буфера и даем доступ к файлу

sw.Close();

}

MessageBox.Show("Файл сохранен в " + @"file.txt");

}

// private Rectangle RcDraw;

private float PenWidth = 5;

private void panel1_Paint(object sender, PaintEventArgs e)

{

//e.Graphics.DrawRectangle(new Pen(Color.Blue, PenWidth), RcDraw);

}

private void panel1_MouseUp(object sender, MouseEventArgs e)

{

}

private void listView1_SelectedIndexChanged(object sender, EventArgs e)

{

}

}

}

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Text;

using System.Windows.Forms;

using System.Collections;

namespace client

{

public partial class Form2 : Form

{

public Form2(ClientWorkingThread clientThread)

{

InitializeComponent();

this.clientThread = clientThread;

}

ClientWorkingThread clientThread = null;

int selectedItem = 0;

private void Form2_Load(object sender, EventArgs e)

{

try

{

initData();

}

catch(Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void initData()

{

listView1.Items.Clear();

textBox1.Clear();

textBox2.Clear();

textBox3.Clear();

ArrayList arrList = clientThread.doQuery("SELECT ID, Name, contact FROM DBA.clients");

foreach (ArrayList items in arrList)

{

string[] strItems = new string[items.Count];

for (int i = 0; i < items.Count; i++)

strItems[i] = items[i].ToString();

System.Windows.Forms.ListViewItem listViewItem1 = new System.Windows.Forms.ListViewItem(strItems, -1);

listView1.Items.Add(listViewItem1);

}

}

private void button3_Click(object sender, EventArgs e)

{

try

{

ArrayList arrList = clientThread.doQuery("select max(id)+1 from DBA.clients");

foreach (ArrayList items in arrList)

{

string[] strItems = new string[items.Count];

for (int i = 0; i < items.Count; i++)

{

strItems[i] = items[i].ToString();

string strSQL = "INSERT INTO DBA.clients VALUES (" + strItems[i] + ", '" + textBox1.Text + "'" +

", '" + textBox3.Text + "')";

clientThread.doSimpeQuery(strSQL);

}

}

initData();

}

catch(Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void listView1_ColumnClick(object sender, ColumnClickEventArgs e)

{

SortOrder order = SortOrder.Ascending;

order = (listView1.Sorting == SortOrder.Ascending) ? SortOrder.Descending : SortOrder.Ascending;

this.listView1.Sorting = order;

this.listView1.Sort();

}

private void listView1_ItemSelectionChanged(object sender, ListViewItemSelectionChangedEventArgs e)

{

this.textBox2.Text = e.Item.SubItems[0].Text;

this.textBox1.Text = e.Item.SubItems[1].Text;

//this.textBox3.Text = e.Item.SubItems[2].Text;

selectedItem = e.ItemIndex;

}

private void button4_Click(object sender, EventArgs e)

{

try

{

string strSQL = "DELETE FROM DBA.clients WHERE ID = " + listView1.Items[selectedItem].Text;

clientThread.doSimpeQuery(strSQL);

initData();

}

catch (Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void button5_Click(object sender, EventArgs e)

{

try

{

string strSQL = "UPDATE DBA.clients SET Name = '" +

this.textBox1.Text + "', contact = '" +

textBox3.Text +

"' WHERE ID = " + listView1.Items[selectedItem].Text;

clientThread.doSimpeQuery(strSQL);

initData();

}

catch (Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void listView1_SelectedIndexChanged(object sender, EventArgs e)

{

}

}

}

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Text;

using System.Windows.Forms;

using System.Collections;

namespace client

{

public partial class Form3 : Form

{

public Form3(ClientWorkingThread clientThread)

{

InitializeComponent();

this.clientThread = clientThread;

}

ClientWorkingThread clientThread = null;

int selectedItem = 0;

private void Form3_Load(object sender, EventArgs e)

{

try

{

initData();

}

catch(Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void initData()

{

listView1.Items.Clear();

textBox1.Clear();

textBox2.Clear();

// textBox3.Clear();

// textBox4.Clear();

ArrayList arrList = clientThread.doQuery("SELECT ID, Name FROM DBA.kinds ");

foreach (ArrayList items in arrList)

{

string[] strItems = new string[items.Count];

for (int i = 0; i < items.Count; i++)

strItems[i] = items[i].ToString();

System.Windows.Forms.ListViewItem listViewItem3 = new System.Windows.Forms.ListViewItem(strItems, -1);

listView1.Items.Add(listViewItem3);

}

}

private void listView1_ColumnClick(object sender, ColumnClickEventArgs e)

{

SortOrder order = SortOrder.Ascending;

order = (listView1.Sorting == SortOrder.Ascending) ? SortOrder.Descending : SortOrder.Ascending;

this.listView1.Sorting = order;

this.listView1.Sort();

}

private void button3_Click(object sender, EventArgs e)

{

try

{

ArrayList arrList = clientThread.doQuery("select max(id)+1 from DBA.kinds");

foreach (ArrayList items in arrList)

{

string[] strItems = new string[items.Count];

for (int i = 0; i < items.Count; i++)

{

strItems[i] = items[i].ToString();

string strSQL = "INSERT INTO DBA.kinds VALUES (" + strItems[i] + " , '" + textBox1.Text + ")";

clientThread.doSimpeQuery(strSQL);

}

}

initData();

}

catch (Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void button4_Click(object sender, EventArgs e)

{

try

{

string strSQL = "DELETE FROM DBA.kinds WHERE ID = " + listView1.Items[selectedItem].Text;

clientThread.doSimpeQuery(strSQL);

initData();

}

catch (Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void button5_Click(object sender, EventArgs e)

{

try

{

string strSQL = "UPDATE DBA.kinds SET Name = '" +

this.textBox1.Text + "' WHERE ID = " + listView1.Items[selectedItem].Text;

clientThread.doSimpeQuery(strSQL);

initData();

}

catch (Exception ex)

{

MessageBox.Show(ex.Message);

}

}

private void listView1_ItemSelectionChanged(object sender, ListViewItemSelectionChangedEventArgs e)

{

this.textBox2.Text = e.Item.SubItems[0].Text;

this.textBox1.Text = e.Item.SubItems[1].Text;

// this.textBox3.Text = e.Item.SubItems[2].Text;

//this.textBox4.Text = e.Item.SubItems[3].Text;

// this.textBox3.Text = e.Item.SubItems[2].Text;

selectedItem = e.ItemIndex;

}

private bool nonNumberEntered = false;

private void textBox3_KeyPress(object sender, KeyPressEventArgs e)

{

if (nonNumberEntered == true)

{

// Stop the character from being entered into the control since it is non-numerical.

e.Handled = true;

}

}

private void textBox3_KeyDown(object sender, KeyEventArgs e)

{

nonNumberEntered = false;

// Determine whether the keystroke is a number from the top of the keyboard.

if (e.KeyCode < Keys.D0 || e.KeyCode > Keys.D9)

{

// Determine whether the keystroke is a number from the keypad.

if (e.KeyCode < Keys.NumPad0 || e.KeyCode > Keys.NumPad9)

{

// Determine whether the keystroke is a backspace.

if (e.KeyCode != Keys.Back)

{

// A non-numerical keystroke was pressed.

// Set the flag to true and evaluate in KeyPress event.

nonNumberEntered = true;

}

}

}

//If shift key was pressed, it's not a number.

if (Control.ModifierKeys == Keys.Shift)

{

nonNumberEntered = true;

}

}

private void listView1_SelectedIndexChanged(object sender, EventArgs e)

{

}

}

}

using System;

using System.Collections.Generic;

using System.Text;

using System.IO;

using System.Net.Sockets;

using System.Threading;

using System.Collections;

using System.Runtime.Serialization.Formatters.Binary;

namespace server

{

class ServerWorkingThread

{

private DBProcess dbProcess;

private NetworkStream networkStream;

private BinaryReader streamReader;

private BinaryWriter streamWriter;

public ServerWorkingThread(TcpClient tcpClient)

{

dbProcess = new DBProcess();

//get a Network stream from the server

networkStream = tcpClient.GetStream();

streamReader = new BinaryReader(networkStream);

streamWriter = new BinaryWriter(networkStream);

Thread tidWorking = new Thread(new ThreadStart(WorkingThread));

tidWorking.Start();

}

private int getCommand()

{

return streamReader.ReadInt32();

}

private void chooseAction(int command)

{

try

{

switch (command)

{

case 0:

dbProcess.executeSimpleQuery(streamReader.ReadString());

break;

case 1:

ArrayList resQuery = dbProcess.executeQuery(streamReader.ReadString());

BinaryFormatter formatter = new BinaryFormatter();

formatter.Serialize(networkStream, resQuery);

//streamWriter.Write((string)resQuery); //запись вектора в выходной поток

//streamWriter.Flush(); //очистка выходного потока

break;

}

}

catch (Exception e)

{

Console.WriteLine(e.Message);

}

}

public void WorkingThread()

{

try

{

int command;

do

{

try

{

command = getCommand();

chooseAction(command);

}

catch (IOException e)

{

Console.WriteLine(e.Message);

command = -1;

}

} while (command != -1);

streamReader.Close();

streamWriter.Close();

networkStream.Close();

}

catch (Exception e)

{

Console.WriteLine(e.Message);

}

}

}

}

using System;

using System.Collections.Generic;

using System.Text;

using System.Net.Sockets;

using System.Net;

namespace server

{

class ServerMain

{

static int _port = 1234;

static void Main(string[] args)

{

TcpListener listener = new TcpListener(IPAddress.Parse("127.0.0.1"), _port);

listener.Start();

Console.WriteLine("Server started.");

Console.WriteLine("Port : " + _port);

try

{

while (true)

{

Console.WriteLine("Waiting client connection...");

TcpClient client = listener.AcceptTcpClient();

try

{

ServerWorkingThread workThread = new ServerWorkingThread(

client);

Console.WriteLine("Client is connected");

}

catch (SocketException e)

{

Console.WriteLine(e.Message);

client.Close();

}

}

}

finally

{

listener.Stop();

}

}

}

}

using System;

using System.Collections.Generic;

using System.Text;

using System.Data.Odbc;

using System.Collections;

namespace server

{

class DBProcess

{

private OdbcConnection dbConnection;

public DBProcess()

{

try

{

dbConnection = new OdbcConnection(GetConnectionString());

dbConnection.Open();

}

catch (Exception e)

{

Console.WriteLine(e.Message);

}

}

private ArrayList getArrayFromQuery(String sqlQuery)

{

ArrayList res = new ArrayList();

try {

OdbcCommand command = new OdbcCommand(sqlQuery, dbConnection);

OdbcDataReader reader = command.ExecuteReader();

while ( reader.Read() )

{

ArrayList row = new ArrayList();

for (int i = 0; i < reader.FieldCount; i++) {

row.Add(reader[i]);

}

res.Add(row);

}

} catch (Exception e)

{

Console.WriteLine(e.Message);

}

return res;

}

public void executeSimpleQuery(String sqlQuery)

{

try

{

OdbcCommand command = new OdbcCommand(sqlQuery, dbConnection);

command.ExecuteNonQuery();

}

catch (Exception e)

{

Console.WriteLine(e.Message);

}

}

public ArrayList executeQuery(String sqlQuery)

{

try

{

return getArrayFromQuery(sqlQuery);

}

catch (Exception e)

{

Console.WriteLine(e.Message);

}

return null;

}

static private string GetConnectionString()

{

// To avoid storing the connection string in your code,

// you can retrieve it from a configuration file.

return "ODBC;Driver=Sybase SQL Anywhere 9.0;Uid=dba;Pwd=sql;Dsn=base";

}

}

}

Размещено на Allbest.ru

...