HEGII.ss.mes.export/wwwroot/Api/export02.ashx

<%@ WebHandler Language="C#" Class="export02" %>

using System;
using System.Web;
using System.Data;
using Curtain.DataAccess;
using DK.XuWei.WebMes;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

public class export02 : IHttpHandler
{

	public void ProcessRequest(HttpContext context)
	{
		context.Response.ContentType = "text/plain";

		using (IDataAccess conn = DataAccess.Create())
		{
			DataTable dtDevice = conn.ExecuteDatatable(@"
			SELECT
				'HGQ' || p.PLC_ID AS deviceCode,
				'烘干区' || P.PLC_NAME AS name 
			FROM
				T_XT_PLC_V V
				INNER JOIN T_XT_PLC P ON P.PLC_ID = V.PLC_ID 
			WHERE
				V.CREATETIME >= to_date( to_char( SYSDATE, 'yyyy-mm-dd hh' ), 'yyyy-mm-dd hh:mi:ss' ) 
				AND V.CREATETIME < to_date( to_char( SYSDATE + 1 / 24, 'yyyy-mm-dd hh' ), 'yyyy-mm-dd hh:mi:ss' ) 
			GROUP BY
				p.PLC_ID,
				P.PLC_NAME 
			ORDER BY
				P.PLC_NAME"
			);

			DataTable dtDeviceData = conn.ExecuteDatatable(@"
			SELECT
				t.deviceCode,
				t.name,
				t.FNTEMPERATURE_房内温度,
				t.SDTEMPERATURE_设定温度,
				t.FNHUMIDITY_房内湿度,
				t.SDHUMIDITY_设定湿度,
				t.RSSTEMPERATURE_燃烧室温度,
				t.YRTEMPERATURE_余热温度 
			FROM
				(
				SELECT
					'HGQ' || p.PLC_ID AS deviceCode,
					'烘干区' || P.PLC_NAME AS name,
					nvl( V.V100, 0 ) AS FNTEMPERATURE_房内温度,
					nvl( V.V104, 0 ) AS SDTEMPERATURE_设定温度,
					nvl( V.V108, 0 ) AS FNHUMIDITY_房内湿度,
					nvl( V.V112, 0 ) AS SDHUMIDITY_设定湿度,
					nvl( V.V120, 0 ) AS RSSTEMPERATURE_燃烧室温度,
					nvl( V.V124, 0 ) AS YRTEMPERATURE_余热温度,
					rank ( ) over ( PARTITION BY P.PLC_ID ORDER BY V.VID DESC ) AS rk 
				FROM
					T_XT_PLC_V V
					INNER JOIN T_XT_PLC P ON P.PLC_ID = V.PLC_ID 
				WHERE
					V.CREATETIME >= to_date( to_char( SYSDATE, 'yyyy-mm-dd hh' ), 'yyyy-mm-dd hh:mi:ss' ) 
					AND V.CREATETIME < to_date( to_char( SYSDATE + 1 / 24, 'yyyy-mm-dd hh' ), 'yyyy-mm-dd hh:mi:ss' ) 
				) t 
			WHERE
				t.rk <= 1 
			ORDER BY
				t.name"
			);

			if (dtDevice.Rows.Count == 0 || dtDeviceData.Rows.Count == 0)
			{
				context.Response.Write("当前时段无数据");
				return;
			}

			// 拼接主体
			JObject data = new JObject();
			data.Add(new JProperty("industryName", "广东区域"));
			data.Add(new JProperty("companyName", "佛山恒洁卫浴有限公司"));
			data.Add(new JProperty("productName", "烘干区"));
			data.Add(new JProperty("productCode", "FSHJHGQ"));
			data.Add(new JProperty("protocol", "HTTP"));
			data.Add(new JProperty("classfy", "陶瓷生产设备"));
			data.Add(new JProperty("lever", "低端"));
			data.Add(new JProperty("dimension", "工业品"));

			// 拼接device
			JArray arrDevice = new JArray();
			JObject device = null;
			foreach (DataRow row in dtDevice.Rows)
			{
				device = new JObject();
				device.Add(new JProperty("name", row["name"]));
				device.Add(new JProperty("deviceCode", "FSHJ" + row["deviceCode"]));
				device.Add(new JProperty("province", "广东省"));
				device.Add(new JProperty("city", "佛山市"));
				device.Add(new JProperty("address", "三水区乐平镇中油大道 3 号"));
				device.Add(new JProperty("worth", "0"));
				device.Add(new JProperty("latitude", "0"));
				device.Add(new JProperty("longitude", "0"));
				device.Add(new JProperty("manufacture", "2021-10-13"));
				arrDevice.Add(device);
			}
			data.Add("device", arrDevice);

			// 拼接deviceData
			JArray arrDeviceData = new JArray();
			JObject deviceData = null;
			string[] colNames;

			// 时间戳
			TimeSpan ts = DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0);
			string timestamp = Convert.ToInt64(ts.TotalMilliseconds).ToString();

			foreach (DataRow row in dtDeviceData.Rows)
			{
				foreach (DataColumn col in dtDeviceData.Columns)
				{
					if (col.ColumnName.Equals("DEVICECODE") || col.ColumnName.Equals("NAME"))
					{
						continue;
					}

					colNames = col.ColumnName.Split('_');
					deviceData = new JObject();
					deviceData.Add(new JProperty("deviceCode", "FSHJ" + row["deviceCode"]));
					deviceData.Add(new JProperty("name", colNames[1]));
					deviceData.Add(new JProperty("mark", colNames[0]));
					deviceData.Add(new JProperty("value", row[col].ToString()));
					deviceData.Add(new JProperty("timestamp", timestamp));
					arrDeviceData.Add(deviceData);
				}
			}

			data.Add("deviceData", arrDeviceData);

			//上报数据
			//string url = "http://edge.cosmoplat.com:30152/company/device/access";// 测试
			string url = "http://edge.cosmoplat.com:30032/company/device/access";// 生产
			string message = JsonClient.Post(url, data.ToString());
			context.Response.Write(message);

			context.Response.Write(data.ToString());
		}
	}

	public bool IsReusable
	{
		get
		{
			return false;
		}
	}

}