|
|
|
@ -53,22 +53,34 @@ namespace BWP.B3WeChat.Rpcs |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// 返回消息状态
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="messageID"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
[Rpc] |
|
|
|
public static short QueryMessageState(string messageID) |
|
|
|
public static Dictionary<string, short> QueryApproveResult(string[] messageIDList) |
|
|
|
{ |
|
|
|
if (messageIDList.Length == 0) |
|
|
|
{ |
|
|
|
return new Dictionary<string, short>(0); |
|
|
|
} |
|
|
|
var query = new DQueryDom(new JoinAlias(typeof(ApproveMessage))); |
|
|
|
query.Where.Conditions.Add(DQCondition.EQ("ID", messageID)); |
|
|
|
query.Where.Conditions.Add(DQCondition.InList(DQExpression.Field("ID"), |
|
|
|
messageIDList.Select((item) => DQExpression.Value(item)).ToArray())); |
|
|
|
query.Columns.Add(DQSelectColumn.Field("ID")); |
|
|
|
query.Columns.Add(DQSelectColumn.Field("ApproveResult")); |
|
|
|
query.Range = SelectRange.Top(1); |
|
|
|
var state = query.EExecuteScalar<NamedValue<审批状态>?>() ?? 审批状态.已删除; |
|
|
|
return state.Value; |
|
|
|
|
|
|
|
var dic = query.EExecuteList<string, NamedValue<审批状态>>() |
|
|
|
.ToDictionary((item) => item.Item1, (item) => item.Item2.Value); |
|
|
|
|
|
|
|
foreach (var messasgeID in messageIDList) |
|
|
|
{ |
|
|
|
if (!dic.ContainsKey(messasgeID)) |
|
|
|
{ |
|
|
|
dic.Add(messasgeID, 审批状态.已删除.Value); |
|
|
|
} |
|
|
|
} |
|
|
|
return dic; |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
[Rpc] |
|
|
|
public static void Delete(string messageID) |
|
|
|
{ |
|
|
|
|