|
|
@@ -15,8 +15,6 @@ namespace UAS_PLCDataReader.PublicMethod
|
|
|
public LogicHandler() { }
|
|
|
|
|
|
static DataHelper dh = SystemInf.dh;
|
|
|
- //用于拼接SQL
|
|
|
- static StringBuilder sql = new StringBuilder();
|
|
|
//用于存放批量执行的SQL
|
|
|
static List<string> sqls = new List<string>();
|
|
|
/// <summary>
|
|
|
@@ -102,6 +100,7 @@ namespace UAS_PLCDataReader.PublicMethod
|
|
|
/// </summary>
|
|
|
public static void DoDeviceDataDiffLog(string iDeCode, string iDeName, string iCommand, string iCommandFrom, string iMan)
|
|
|
{
|
|
|
+ StringBuilder sql = new StringBuilder();
|
|
|
sql.Clear();
|
|
|
sql.Append("insert into DeviceRunRecord(drr_id,drr_decode,drr_dename,drr_command,drr_commandfrom,drr_date,drr_doman,drr_remark)");
|
|
|
sql.Append("values(DeviceRunRecord_seq.nextval,'" + iDeCode + "','" + iDeName + "','" + iCommand + "','" + iCommandFrom + "',sysdate,'" + iMan + "','')");
|
|
|
@@ -117,6 +116,7 @@ namespace UAS_PLCDataReader.PublicMethod
|
|
|
/// <param name="iOnLine">上线或者离线</param>
|
|
|
public static void DoDevicePollingLog(string iDeCode, bool iOnLine)
|
|
|
{
|
|
|
+ StringBuilder sql = new StringBuilder();
|
|
|
sql.Clear();
|
|
|
sql.Append("update DEVICEPOLLINGLOG set ");
|
|
|
if (iOnLine)
|
|
|
@@ -141,6 +141,7 @@ namespace UAS_PLCDataReader.PublicMethod
|
|
|
/// <param name="iOnLine">上线或者离线</param>
|
|
|
public static void DoDevicePollingLog(string iDeCode, string iSendDataSize, string iReceiveDataSize, bool iOnLine)
|
|
|
{
|
|
|
+ StringBuilder sql = new StringBuilder();
|
|
|
sql.Clear();
|
|
|
sql.Append("update DEVICEPOLLINGLOG set dpg_senddatasize=nvl(dpg_senddatasize,0)+" + iSendDataSize);
|
|
|
sql.Append(",dpg_receivedatasize=nvl(dpg_receivedatasize,0)+" + iReceiveDataSize + ",dpg_count=nvl(dpg_count,0)+1 ");
|
|
|
@@ -164,6 +165,7 @@ namespace UAS_PLCDataReader.PublicMethod
|
|
|
/// <param name="iReceiveDataSize">接收数据大小</param>
|
|
|
public static void DoDevicePollingLog(string iDeCode, string iSendDataSize, string iReceiveDataSize)
|
|
|
{
|
|
|
+ StringBuilder sql = new StringBuilder();
|
|
|
sql.Clear();
|
|
|
sql.Append("update DEVICEPOLLINGLOG set dpg_status='running',dpg_senddatasize=nvl(dpg_senddatasize,0)+" + iSendDataSize);
|
|
|
sql.Append(",dpg_receivedatasize=nvl(dpg_receivedatasize,0)+" + iReceiveDataSize + ",dpg_count=nvl(dpg_count,0)+1 ");
|
|
|
@@ -212,6 +214,7 @@ namespace UAS_PLCDataReader.PublicMethod
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
+ StringBuilder sql = new StringBuilder();
|
|
|
sql.Clear();
|
|
|
sql.Append("update DeviceRunstatus set dr_qty={0},dr_okqty={1},dr_TEMPERATURE={2},");
|
|
|
sql.Append("dr_value1={3},dr_value2={4},dr_value3={5},dr_updatedate=sysdate where dr_decode='" + Decode + "'");
|
|
|
@@ -227,6 +230,7 @@ namespace UAS_PLCDataReader.PublicMethod
|
|
|
/// <param name="iDestatus"></param>
|
|
|
public static void UpdateDeviceStatus(string iDecode, string iDename, string iDestatus)
|
|
|
{
|
|
|
+ StringBuilder sql = new StringBuilder();
|
|
|
sql.Clear();
|
|
|
sql.Append("MERGE INTO DeviceRunstatus alias1 USING (select '" + iDecode + "' dr_decode from dual) alias2 ");
|
|
|
sql.Append("ON (alias1.dr_decode=alias2.dr_decode) WHEN MATCHED THEN UPDATE SET dr_startdate =sysdate,Dr_runstatus='" + iDestatus + "' ");
|