You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
116 lines
5.1 KiB
116 lines
5.1 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using Utils.Datas;
|
|
using WeighBusiness.BO;
|
|
using WeighBusiness.Utils.SqlUtils;
|
|
|
|
namespace WeighBusiness.Utils
|
|
{
|
|
public class SynchronousLogQueryUtil
|
|
{
|
|
#region 用于查询时显示同步信息。如果改回不显示同步信息，还需要修改相应的调用这些方法的方法。
|
|
private const string selectHeadAndSynchronousLogSql =
|
|
@"select {0} o.ID,o.IsChecked,o.CreateDateTime,o.CarNumber,o.Number,o.HeadWeight,o.Remote_Weigh_ID,s.SynchronousMessage
|
|
from {1} o left join {2} s on o.ID = s.terminalbillid
|
|
{3}
|
|
order by o.id desc";
|
|
///// <summary>
|
|
///// 查询称重表头数据、对应的同步数据。
|
|
///// </summary>
|
|
///// <param name="isTop">是否前10条</param>
|
|
///// <param name="isSynchronous">是否同步。为空：所有数据</param>
|
|
///// <param name="isChecked">是否已审核。为空：所有数据</param>
|
|
//public static List<System.Tuple<Weigh, SynchronousLog>> GetAllLocalWeighHeads_Synchronous(bool isTop, bool? isSynchronous, bool? isChecked)
|
|
//{
|
|
// var topString = isTop ? "first (10)" : string.Empty;
|
|
// var whereString = string.Empty;
|
|
// if (isSynchronous.HasValue) {
|
|
// if (isSynchronous.Value)
|
|
// whereString = "where o.Remote_Weigh_ID > 0";
|
|
// else
|
|
// whereString = "where (o.Remote_Weigh_ID = 0 or o.Remote_Weigh_ID is null)";
|
|
// }
|
|
// if (isChecked.HasValue) {
|
|
// if (whereString.IsNullOrEmpty())
|
|
// whereString = "where o.IsChecked = '" + isChecked + "'";
|
|
// else
|
|
// whereString += " and o.IsChecked = '" + isChecked + "'";
|
|
// }
|
|
// return GetAllLocalWeighHeads_Synchronous(topString, whereString);
|
|
//}
|
|
|
|
//private static List<Tuple<Weigh, SynchronousLog>> GetAllLocalWeighHeads_Synchronous(string topString, string whereString)
|
|
//{
|
|
// var billInfos = new List<Tuple<Weigh, SynchronousLog>>();
|
|
// var querySql = selectHeadAndSynchronousLogSql.FormatWith(topString, TableNames.称重表, TableNames.同步日志, whereString);
|
|
// var table = SqlHelperEx.DoQuery(querySql);
|
|
// foreach (DataRow row in table.Rows) {
|
|
// var newWeigh = new Weigh() {
|
|
// ID = DataTypeUtil.GetLongNum(row["ID"]),
|
|
// IsChecked = DataTypeUtil.GetBoolData(table.Rows[0]["IsChecked"]),
|
|
// CreateDateTime = DataTypeUtil.GetDateTimeNullData(row["CreateDateTime"]),
|
|
// CarNumber = DataTypeUtil.GetIntNullNum(row["CarNumber"]),
|
|
// Number = DataTypeUtil.GetIntNullNum(row["Number"]),
|
|
// HeadWeight = DataTypeUtil.GetDecimalNullNum(row["HeadWeight"]),
|
|
// Remote_Weigh_ID = DataTypeUtil.GetLongNullNum(row["Remote_Weigh_ID"]),
|
|
// };
|
|
// var newlog = new SynchronousLog() {
|
|
// //RemoteBillID = DataTypeUtil.GetLongNum(row["RemoteBillID"]),
|
|
// SynchronousMessage = row["SynchronousMessage"].ToString(),
|
|
// };
|
|
// billInfos.Add(new Tuple<Weigh, SynchronousLog>(newWeigh, newlog));
|
|
// }
|
|
|
|
// return billInfos;
|
|
//}
|
|
#endregion
|
|
|
|
public static SynchronousLog GetLocalSynchronousLog(long id)
|
|
{
|
|
string querySql = @"select ID,BillTypeID,TerminalBillID,RemoteBillID,SynchronousMessage from {0} where ID = ".FormatWith(TableNames.同步日志) + id;
|
|
var table = SqlHelperEx.DoQuery(querySql);
|
|
if (table.Rows.Count == 0)
|
|
return null;
|
|
var result = new SynchronousLog() {
|
|
ID = id,
|
|
BillTypeID = DataTypeUtil.GetShortNum(table.Rows[0]["BillTypeID"]),
|
|
TerminalBillID = DataTypeUtil.GetLongNum(table.Rows[0]["TerminalBillID"]),
|
|
RemoteBillID = DataTypeUtil.GetLongNum(table.Rows[0]["RemoteBillID"]),
|
|
SynchronousMessage = DataTypeUtil.ToStringEmptyIfNull(table.Rows[0]["SynchronousMessage"]),//为null时，赋值为string.Empty
|
|
};
|
|
return result;
|
|
}
|
|
|
|
public static SynchronousLog GetLocalSynchronousLogFromBillID(short billTypeID, long terminalBillID)
|
|
{
|
|
string querySql = @"select first 1 ID,BillTypeID,TerminalBillID,RemoteBillID,SynchronousMessage from {0} where BillTypeID = ".FormatWith(TableNames.同步日志) + billTypeID + " and TerminalBillID = " + terminalBillID + " order by ID desc";
|
|
var table = SqlHelperEx.DoQuery(querySql);
|
|
if (table.Rows.Count == 0)
|
|
return null;
|
|
var result = new SynchronousLog() {
|
|
ID = DataTypeUtil.GetLongNum(table.Rows[0]["ID"]),
|
|
BillTypeID = billTypeID,
|
|
TerminalBillID = terminalBillID,
|
|
RemoteBillID = DataTypeUtil.GetLongNum(table.Rows[0]["RemoteBillID"]),
|
|
SynchronousMessage = DataTypeUtil.ToStringEmptyIfNull(table.Rows[0]["SynchronousMessage"]),//为null时，赋值为string.Empty
|
|
};
|
|
return result;
|
|
}
|
|
|
|
public static long[] GetAllNotSynchronousBillIDs(short billTypeID)
|
|
{
|
|
string querySql = @"select TerminalBillID from {0} where BillTypeID = ".FormatWith(TableNames.同步日志) + billTypeID + " and RemoteBillID < 1 order by ID";
|
|
var table = SqlHelperEx.DoQuery(querySql);
|
|
if (table.Rows.Count == 0)
|
|
return null;
|
|
List<long> result = new List<long>();
|
|
foreach (DataRow row in table.Rows)
|
|
result.Add(DataTypeUtil.GetLongNum(row["TerminalBillID"]));
|
|
return result.ToArray();
|
|
}
|
|
|
|
}
|
|
}
|