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.
967 lines
43 KiB
967 lines
43 KiB
namespace CounsellorBL.BLStructure.SYS
|
|
{
|
|
using CounsellorBL.GROUP.Helper;
|
|
using CounsellorBL.Helper;
|
|
using MonumentDefine;
|
|
using Newtonsoft.Json;
|
|
using Newtonsoft.Json.Linq;
|
|
using OT.COM.ArsenalDB;
|
|
using OT.COM.LogisticsUtil;
|
|
using OT.COM.SignalerMessage;
|
|
using SoldierData.EnterprizeV4;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Text.RegularExpressions;
|
|
using static CounsellorBL.GROUP.Helper.FbHelper;
|
|
|
|
public class CommentManageService : SingleDataTableTemplate<tb_grp_comment>
|
|
{
|
|
private class CommentViewModel
|
|
{
|
|
public string uid { get; set; }
|
|
public string article_uid { get; set; }
|
|
public string origin_comment { get; set; }
|
|
public string comment { get; set; }
|
|
public DateTime comment_time { get; set; }
|
|
public string group_user_id { get; set; }
|
|
public int status { get; set; }
|
|
public string fb_name { get; set; }
|
|
public string fb_pic { get; set; }
|
|
public string fb_comment_id { get; set; }
|
|
public string group_id { get; set; }
|
|
public string user_name { get; set; }
|
|
public string user_picture { get; set; }
|
|
public string member_uid { get; set; }
|
|
public int status_flag { get; set; }
|
|
public string parent_comment_id { get; set; }
|
|
public string default_branch { get; set; }
|
|
}
|
|
|
|
private class GroupViewModel2
|
|
{
|
|
public string fb_article_id { get; set; }
|
|
public string user_token { get; set; }
|
|
public string client_secret { get; set; }
|
|
public string app_id { get; set; }
|
|
}
|
|
|
|
public CommentManageService()
|
|
{
|
|
EditMustConditionKeys.Add(tb_grp_comment.CN_ARTICLE_UID);
|
|
dgReadCommandGenerator = readCommandGenerator;
|
|
dgDeleteCommandGenerator = deleteCommandGenerator;
|
|
}
|
|
|
|
public new CResponseMessage Read(CRequestMessage i_crmInput) => base.Read(i_crmInput);
|
|
|
|
protected string readCommandGenerator(CRequestMessage i_crmInput, JArray i_jaData, tb_sys_session i_sSessionUser, out Command o_c,
|
|
[System.Runtime.CompilerServices.CallerLineNumber] int i_nCodeLine = 0,
|
|
[System.Runtime.CompilerServices.CallerMemberName] string i_sMemberName = "",
|
|
[System.Runtime.CompilerServices.CallerFilePath] string i_sSourcePath = "")
|
|
{
|
|
string sMsg;
|
|
Command cRes = null;
|
|
try
|
|
{
|
|
do
|
|
{
|
|
// 取得condition
|
|
Dictionary<string, string> dicCondition = GetQueryMasterFirstQJEDicwherecols(i_crmInput);
|
|
var lsBranch = ProjectHelper.GetUserGroup(i_crmInput);
|
|
/**開始組指令**/
|
|
QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
|
|
QueryJsonElement qjeArticle = lBlocks.GetInst();
|
|
qjeArticle.table = tb_grp_article.TABLENAME;
|
|
qjeArticle.displaycols = new List<string>()
|
|
{
|
|
tb_grp_article.CN_UID,
|
|
tb_grp_article.CN_NAME,
|
|
tb_grp_article.CN_GROUP_UID,
|
|
tb_grp_article.CN_MESSAGE,
|
|
tb_grp_article.CN_FB_ARTICLE_ID,
|
|
tb_grp_article.CN_STATUS_FLAG,
|
|
tb_grp_article.CN_RELEASE_DATE,
|
|
tb_grp_article.CN_REMARK,
|
|
tb_grp_article.CN_CLOSE_DATE,
|
|
tb_grp_article.CN_POST_DATE
|
|
};
|
|
List<WhereNode> wnQuery = new List<WhereNode>();
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_STATUS_FLAG, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), BLWording.STATUS_FLAG_ON));
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_STATUS_COMMENT, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), BLWording.STATUS_FLAG_ON));
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_FB_ARTICLE_ID, WhereNode.EColumnOperation.EOT_ISNOTNULL, typeof(tb_grp_article)));
|
|
|
|
// 搜尋社團
|
|
if (dicCondition.ContainsKey(tb_grp_article.CN_GROUP_UID))
|
|
{
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_GROUP_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), dicCondition[tb_grp_article.CN_GROUP_UID]));
|
|
}
|
|
if (dicCondition.ContainsKey(tb_grp_article.CN_CLOSE_DATE))
|
|
{
|
|
if (dicCondition[tb_grp_article.CN_CLOSE_DATE] == "1")
|
|
{
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_CLOSE_DATE, WhereNode.EColumnOperation.EOT_GTEQ, typeof(tb_grp_article), DateTime.Today));
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_CLOSE_DATE, WhereNode.EColumnOperation.EOT_LT, typeof(tb_grp_article), DateTime.Today.AddDays(1)));
|
|
}
|
|
}
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_TYPE, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), (int)Enums.ArticleType.Article));
|
|
wnQuery.Add(new WhereNode(tb_grp_article.CN_GROUP_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_grp_article), lsBranch.ToArray()));
|
|
if (wnQuery.Any())
|
|
{
|
|
qjeArticle.wherecols = new WhereNode(WhereNode.ENodeOperation.ENO_AND, wnQuery.ToArray());
|
|
}
|
|
qjeArticle.ordercols = new List<Tuple<QueryJsonElement, string, string>> {
|
|
Tuple.Create(qjeArticle, tb_grp_article.CN_POST_DATE, BLWording.ORDER_DESC),
|
|
};
|
|
|
|
lBlocks.Add(qjeArticle);
|
|
|
|
sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
|
|
}
|
|
while (false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
LogHelper.DBLog(Util.GetLastExceptionMsg(ex), i_nCodeLine, i_sMemberName, i_sSourcePath);
|
|
sMsg = $"{nameof(readCommandGenerator)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. Call from {i_sMemberName} {i_sSourcePath}({i_nCodeLine}).";
|
|
#if DEBUG
|
|
System.Diagnostics.Debug.WriteLine(sMsg);
|
|
#endif
|
|
}
|
|
o_c = cRes;
|
|
return sMsg;
|
|
}
|
|
|
|
protected string deleteCommandGenerator(CRequestMessage i_crmInput, JArray i_jaItems, tb_sys_session i_sSessionUser, out List<Command> o_lcResult, List<string> i_saQryContainKeys,
|
|
[System.Runtime.CompilerServices.CallerLineNumber] int i_nCodeLine = 0,
|
|
[System.Runtime.CompilerServices.CallerMemberName] string i_sMemberName = "",
|
|
[System.Runtime.CompilerServices.CallerFilePath] string i_sSourcePath = "")
|
|
{
|
|
string sMsg = null;
|
|
List<Command> lcCmds = new List<Command>();
|
|
|
|
try
|
|
{
|
|
do
|
|
{
|
|
foreach (JToken jtkItem in i_jaItems)
|
|
{
|
|
Dictionary<string, object> dicItem = jtkItem.ToObject<Dictionary<string, object>>();
|
|
|
|
sMsg = getManualLog(i_crmInput, dicItem, BLWording.LOG_ACTION_NAME_DELETESQL, out Command cLog);
|
|
|
|
if (sMsg != null)
|
|
{
|
|
break;
|
|
}
|
|
|
|
if (cLog != null)
|
|
{
|
|
lcCmds.Add(cLog);
|
|
}
|
|
|
|
string sMstUID = null;
|
|
if (dicItem.ContainsKey(BLWording.WHEREDATA) && dicItem[BLWording.WHEREDATA] is JObject wheredata)
|
|
{
|
|
Dictionary<string, object> wheredataDic = wheredata.ToObject<Dictionary<string, object>>();
|
|
if (wheredataDic.ContainsKey(BLWording.UID))
|
|
{
|
|
sMstUID = wheredataDic[BLWording.UID].ToString();
|
|
|
|
tb_grp_article t = new tb_grp_article()
|
|
{
|
|
status_comment = BLWording.STATUS_FLAG_OFF
|
|
};
|
|
|
|
List<WhereNode> wnQuery = new List<WhereNode>();
|
|
wnQuery.Add(new WhereNode(tb_grp_comment.CN_STATUS, WhereNode.EColumnOperation.EOT_NEQ, typeof(tb_grp_comment), 9));
|
|
wnQuery.Add(new WhereNode(tb_grp_comment.CN_ARTICLE_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_comment), sMstUID));
|
|
WhereNode wn = new WhereNode(WhereNode.ENodeOperation.ENO_AND, wnQuery.ToArray());
|
|
Command c = Command.SetupDeleteCmd(wn);
|
|
Command tt = Command.SetupUpdateCmd(t, new WhereNode(tb_grp_article.CN_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), sMstUID));
|
|
lcCmds.Add(c);
|
|
if (!wheredataDic.ContainsKey("type"))
|
|
{
|
|
lcCmds.Add(tt);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
while (false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
LogHelper.DBLog(Util.GetLastExceptionMsg(ex), i_crmInput);
|
|
sMsg = $"{nameof(deleteCommandGenerator)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. Call from {i_sMemberName} {i_sSourcePath}({i_nCodeLine}).";
|
|
#if DEBUG
|
|
System.Diagnostics.Debug.WriteLine(sMsg);
|
|
#endif
|
|
|
|
}
|
|
|
|
o_lcResult = lcCmds;
|
|
return sMsg;
|
|
}
|
|
|
|
private void SaveFbComment(string article_id)
|
|
{
|
|
// 取回文章ID跟UserToken
|
|
QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
|
|
QueryJsonElement qjeArticle = lBlocks.GetInst();
|
|
qjeArticle.table = tb_grp_article.TABLENAME;
|
|
qjeArticle.displaycols = new List<string>()
|
|
{
|
|
tb_grp_article.CN_FB_ARTICLE_ID
|
|
};
|
|
qjeArticle.wherecols = new WhereNode(tb_grp_article.CN_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), article_id);
|
|
lBlocks.Add(qjeArticle);
|
|
|
|
QueryJsonElement qjeGroup = lBlocks.GetInst();
|
|
qjeGroup.table = tb_grp_group.TABLENAME;
|
|
qjeGroup.jointable = qjeArticle;
|
|
qjeGroup.jointype = QueryJsonElement.LEFT_JOIN;
|
|
qjeGroup.joincols = new Dictionary<string, string> { { tb_grp_group.CN_UID, tb_grp_article.CN_GROUP_UID } };
|
|
qjeGroup.displaycols = new List<string>()
|
|
{
|
|
tb_grp_group.CN_CLIENT_SECRET,
|
|
tb_grp_group.CN_APP_ID
|
|
};
|
|
lBlocks.Add(qjeGroup);
|
|
|
|
QueryJsonElement qjeGroupUser = lBlocks.GetInst();
|
|
qjeGroupUser.table = tb_grp_group2user.TABLENAME;
|
|
qjeGroupUser.jointable = qjeGroup;
|
|
qjeGroupUser.jointype = QueryJsonElement.LEFT_JOIN;
|
|
qjeGroupUser.joincols = new Dictionary<string, string> { { tb_grp_group2user.CN_GROUP_UID, tb_grp_group.CN_UID } };
|
|
qjeGroupUser.displaycols = new List<string>()
|
|
{
|
|
tb_grp_group2user.CN_USER_TOKEN
|
|
};
|
|
qjeGroupUser.wherecols = new WhereNode(tb_grp_group2user.CN_STATUS_FLAG, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), BLWording.STATUS_FLAG_ON);
|
|
lBlocks.Add(qjeGroupUser);
|
|
|
|
string sMsg = MakeSelectJoinByBlocks(lBlocks, out Command cRes);
|
|
|
|
if (sMsg != null)
|
|
{
|
|
return;
|
|
}
|
|
ArsenalInterface ai = ArsenalDBMgr.GetInst(cRes);
|
|
List<GroupViewModel2> qdArticle = ai.RunQueryList<GroupViewModel2>(cRes);
|
|
|
|
string isValid = new FbHelper().CallFbCheckTokenGetAPI(qdArticle.First().user_token, qdArticle.First().app_id, qdArticle.First().client_secret, out int status);
|
|
if (isValid != null)
|
|
{
|
|
sMsg = isValid;
|
|
if (status == 2)
|
|
{
|
|
return;
|
|
}
|
|
}
|
|
bool success = new FbHelper().CallFbCommentGetAPI(article_id, qdArticle.First().user_token, qdArticle.First().fb_article_id, out List<tb_grp_comment> comments);
|
|
if (success) // 成功抓取資料
|
|
{
|
|
if (comments == null || comments.Count == 0) // 無留言
|
|
{
|
|
|
|
}
|
|
else // 有留言
|
|
{
|
|
|
|
}
|
|
}
|
|
else // 無法從FB抓取資料
|
|
{
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 傳回商品資訊
|
|
/// </summary>
|
|
/// <param name="i_crmInput"></param>
|
|
/// <returns></returns>
|
|
public CResponseMessage FetchCommentFromFB(CRequestMessage i_crmInput)
|
|
{
|
|
string sMsg = null;
|
|
CResponseMessage crmRes = null;
|
|
try
|
|
{
|
|
do
|
|
{
|
|
sMsg = getCommonParameter(i_crmInput, BLWording.QRY_MASTER, out JArray jaDataArray, out tb_sys_session sUserSession);
|
|
if (sMsg != null)
|
|
{
|
|
break;
|
|
}
|
|
if (jaDataArray.Count != 1 || jaDataArray[0] == null)
|
|
{
|
|
sMsg = MessageWording.PARAM_NOT_EXPECTED;
|
|
break;
|
|
}
|
|
|
|
var article_uid = jaDataArray[0][BLWording.WHEREDATA][BLWording.UID].ToString();
|
|
|
|
SaveFbComment(article_uid);
|
|
}
|
|
while (false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
sMsg = $"{nameof(FetchCommentFromFB)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(ex)}.";
|
|
Logger.Error(ex);
|
|
Logger.Error($"{nameof(FetchCommentFromFB)} sMsg: " + sMsg);
|
|
#if DEBUG
|
|
System.Diagnostics.Debug.WriteLine(sMsg);
|
|
#endif
|
|
}
|
|
|
|
if (sMsg != null)
|
|
{
|
|
crmRes = new CErrorResponseMessage(sMsg, null);
|
|
}
|
|
else
|
|
{
|
|
crmRes = ReadComment(i_crmInput);
|
|
}
|
|
|
|
return crmRes;
|
|
}
|
|
class ReadCommentModel : tb_grp_article
|
|
{
|
|
public string fb_group_id { get; set; }
|
|
}
|
|
/// <summary>
|
|
/// 傳回商品資訊
|
|
/// </summary>
|
|
/// <param name="i_crmInput"></param>
|
|
/// <returns></returns>
|
|
public CResponseMessage ReadComment(CRequestMessage i_crmInput)
|
|
{
|
|
string sMsg = null;
|
|
CResponseMessage crmRes = null;
|
|
try
|
|
{
|
|
do
|
|
{
|
|
sMsg = getCommonParameter(i_crmInput, BLWording.QRY_MASTER, out JArray jaDataArray, out tb_sys_session sUserSession);
|
|
if (sMsg != null)
|
|
{
|
|
break;
|
|
}
|
|
if (jaDataArray.Count != 1 || jaDataArray[0] == null)
|
|
{
|
|
sMsg = MessageWording.PARAM_NOT_EXPECTED;
|
|
break;
|
|
}
|
|
|
|
var article_uid = jaDataArray[0][BLWording.WHEREDATA][BLWording.UID].ToString();
|
|
|
|
// 取得貼文的post_status與group_id
|
|
QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
|
|
QueryJsonElement qjeArticle = lBlocks.GetInst();
|
|
qjeArticle.table = tb_grp_article.TABLENAME;
|
|
qjeArticle.displaycols = new List<string>()
|
|
{
|
|
tb_grp_article.CN_POST_STATUS,
|
|
};
|
|
qjeArticle.wherecols = new WhereNode(tb_grp_article.CN_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_article), article_uid);
|
|
lBlocks.Add(qjeArticle);
|
|
|
|
// 需判斷該會員是否為此社團
|
|
QueryJsonElement qjeGroup = lBlocks.GetInst();
|
|
qjeGroup.table = tb_grp_group.TABLENAME;
|
|
qjeGroup.jointable = qjeArticle;
|
|
qjeGroup.jointype = QueryJsonElement.LEFT_JOIN;
|
|
qjeGroup.joincols = new Dictionary<string, string>() {
|
|
{ tb_grp_group.CN_UID, tb_grp_article.CN_GROUP_UID }};
|
|
qjeGroup.displaycols = new List<string>()
|
|
{
|
|
tb_grp_group.CN_FB_GROUP_ID,
|
|
};
|
|
lBlocks.Add(qjeGroup);
|
|
|
|
sMsg = MakeSelectJoinByBlocks(lBlocks, out Command cResArticle);
|
|
|
|
ArsenalInterface ai = ArsenalDBMgr.GetInst(cResArticle);
|
|
List<ReadCommentModel> articles = ai.RunQueryList<ReadCommentModel>(cResArticle);
|
|
|
|
/**開始組指令**/
|
|
lBlocks = new QueryJsonElementCollection();
|
|
|
|
QueryJsonElement qjeArticleToProduct = lBlocks.GetInst();
|
|
qjeArticleToProduct.table = tb_grp_comment.TABLENAME;
|
|
qjeArticleToProduct.displaycols = new List<string>()
|
|
{
|
|
tb_grp_comment.CN_UID,
|
|
tb_grp_comment.CN_ARTICLE_UID,
|
|
tb_grp_comment.CN_ORIGIN_COMMENT,
|
|
tb_grp_comment.CN_COMMENT,
|
|
tb_grp_comment.CN_COMMENT_TIME,
|
|
tb_grp_comment.CN_GROUP_USER_ID,
|
|
tb_grp_comment.CN_STATUS,
|
|
tb_grp_comment.CN_USER_NAME,
|
|
tb_grp_comment.CN_USER_PICTURE,
|
|
tb_grp_comment.CN_FB_COMMENT_ID,
|
|
tb_grp_comment.CN_PARENT_COMMENT_ID,
|
|
};
|
|
List<WhereNode> wnCommentQuery = new List<WhereNode>
|
|
{
|
|
new WhereNode(tb_grp_comment.CN_ARTICLE_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_comment), article_uid),
|
|
new WhereNode(tb_grp_comment.CN_STATUS, WhereNode.EColumnOperation.EOT_NEQ, typeof(tb_grp_comment), (int)FbHelper.CommentStatus.TransferOrder),
|
|
new WhereNode(tb_grp_comment.CN_STATUS_FLAG, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_comment), BLWording.STATUS_FLAG_ON)
|
|
};
|
|
qjeArticleToProduct.wherecols = new WhereNode(WhereNode.ENodeOperation.ENO_AND, wnCommentQuery.ToArray());
|
|
// Sort
|
|
List<Tuple<QueryJsonElement, string, string>> qjeArticleToProductOrder = new List<Tuple<QueryJsonElement, string, string>>() {
|
|
Tuple.Create(qjeArticle, tb_grp_comment.CN_COMMENT_TIME, BLWording.ORDER_ASC)
|
|
};
|
|
qjeArticleToProduct.ordercols = qjeArticleToProductOrder;
|
|
|
|
lBlocks.Add(qjeArticleToProduct);
|
|
|
|
QueryJsonElement qjeMember = lBlocks.GetInst();
|
|
qjeMember.table = tb_meb_member.TABLENAME;
|
|
qjeMember.jointable = qjeArticleToProduct;
|
|
qjeMember.jointype = QueryJsonElement.LEFT_JOIN;
|
|
qjeMember.joincols = new Dictionary<string, string>() {
|
|
{ tb_meb_member.CN_GROUP_USER_ID, tb_grp_comment.CN_GROUP_USER_ID }};
|
|
qjeMember.displaycols = new List<string>()
|
|
{
|
|
tb_meb_member.CN_NAME,
|
|
tb_meb_member.CN_FB_PIC,
|
|
tb_meb_member.CN_STATUS_FLAG,
|
|
tb_meb_member.CN_GROUP_ID,
|
|
tb_meb_member.CN_DEFAULT_BRANCH
|
|
};
|
|
qjeMember.aliascols = new Dictionary<string, List<string>>
|
|
{
|
|
{ tb_meb_member.CN_UID, new List<string>() { "member_uid" } }
|
|
};
|
|
List<WhereNode> wnMemberQuery = new List<WhereNode>
|
|
{
|
|
new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), articles[0].fb_group_id),
|
|
new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_ISNULL, typeof(tb_meb_member))
|
|
};
|
|
qjeMember.wherecols = new WhereNode(WhereNode.ENodeOperation.ENO_OR, wnMemberQuery.ToArray());
|
|
lBlocks.Add(qjeMember);
|
|
|
|
sMsg = MakeSelectJoinByBlocks(lBlocks, out Command cRes);
|
|
|
|
if (sMsg != null)
|
|
{
|
|
break;
|
|
}
|
|
ai = ArsenalDBMgr.GetInst(cRes);
|
|
List<CommentViewModel> qdArticle = ai.RunQueryList<CommentViewModel>(cRes);
|
|
var parentData = qdArticle.GroupBy(x => x.parent_comment_id);
|
|
if (!cRes.IsSuccess)
|
|
{
|
|
sMsg = cRes.LastErrorCode;
|
|
break;
|
|
}
|
|
|
|
crmRes = new CSuccessResponseMessage(null, i_crmInput);
|
|
// 填寫回傳
|
|
crmRes.param.Add(BLWording.DATA, parentData);
|
|
crmRes.param.Add("post_status", articles);
|
|
}
|
|
while (false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
sMsg = $"{nameof(ReadComment)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}.";
|
|
#if DEBUG
|
|
System.Diagnostics.Debug.WriteLine(sMsg);
|
|
#endif
|
|
}
|
|
|
|
if (sMsg != null)
|
|
{
|
|
crmRes = new CErrorResponseMessage(sMsg, null);
|
|
}
|
|
|
|
return crmRes;
|
|
}
|
|
public CResponseMessage DeleteComment(CRequestMessage i_crmInput)
|
|
{
|
|
string sMsg = null;
|
|
CResponseMessage crmRes = null;
|
|
List<Command> lcCmds = new List<Command>();
|
|
try
|
|
{
|
|
do
|
|
{
|
|
sMsg = getCommonParameter(i_crmInput, BLWording.DEL_MASTER, out JArray jaDataArray, out tb_sys_session sUserSession);
|
|
if (sMsg != null)
|
|
{
|
|
break;
|
|
}
|
|
if (jaDataArray.Count != 1 || jaDataArray[0] == null)
|
|
{
|
|
sMsg = MessageWording.PARAM_NOT_EXPECTED;
|
|
break;
|
|
}
|
|
|
|
var uid = jaDataArray[0][BLWording.WHEREDATA][BLWording.UID].ToString();
|
|
tb_grp_comment u = new tb_grp_comment()
|
|
{
|
|
status_flag = BLWording.STATUS_FLAG_OFF
|
|
};
|
|
Command c = Command.SetupUpdateCmd(u, new WhereNode(tb_grp_comment.CN_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_comment), uid));
|
|
lcCmds.Add(c);
|
|
ArsenalInterface ai = ArsenalDBMgr.GetInst(lcCmds[0], GetDefaultSystemColumnInfo());
|
|
ai.RunEditCmds(lcCmds);
|
|
sMsg = GetLastErrorCode(lcCmds);
|
|
if (sMsg != null)
|
|
{
|
|
crmRes = new CErrorResponseMessage(sMsg, null);
|
|
}
|
|
else
|
|
{
|
|
crmRes = new CSuccessResponseMessage(null, i_crmInput);
|
|
}
|
|
}
|
|
while (false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
sMsg = $"{nameof(DeleteComment)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}.";
|
|
#if DEBUG
|
|
System.Diagnostics.Debug.WriteLine(sMsg);
|
|
#endif
|
|
}
|
|
|
|
if (sMsg != null)
|
|
{
|
|
crmRes = new CErrorResponseMessage(sMsg, null);
|
|
}
|
|
|
|
return crmRes;
|
|
}
|
|
public CResponseMessage CreateComment(CRequestMessage i_crmInput)
|
|
{
|
|
string sMsg = null;
|
|
CResponseMessage crmRes = null;
|
|
try
|
|
{
|
|
do
|
|
{
|
|
sMsg = getCommonParameter(i_crmInput, BLWording.ADD_MASTER, out JArray jaDataArray, out tb_sys_session sUserSession);
|
|
if (sMsg != null)
|
|
{
|
|
break;
|
|
}
|
|
|
|
var article = jaDataArray[0][BLWording.DATA]["article_data"].ToObject<tb_grp_article>();
|
|
var member = jaDataArray[0][BLWording.DATA]["member_data"].ToObject<tb_meb_member>();
|
|
var comment = jaDataArray[0][BLWording.DATA][BLWording.DATA].ToString();
|
|
List<Command> lCmds = new List<Command>();
|
|
var comments = new List<tb_grp_comment>();
|
|
|
|
// 取回該社團可以取貨的地點
|
|
var branches = GetBranches(article.group_uid).Select(x => x.branch_name).ToList();
|
|
var products = GetProducts(article.uid);
|
|
var productInfos = GetProductInfos(products);
|
|
|
|
Logger.Info($"開始解析貼文 文章ID: {article.uid} 設定: {JsonConvert.SerializeObject(productInfos)}");
|
|
|
|
var parser = new GroupBuyParser.GroupBuyParser
|
|
{
|
|
Settings = new GroupBuyParser.ParserSettings
|
|
{
|
|
Products = productInfos,
|
|
Branches = branches
|
|
}
|
|
};
|
|
|
|
if(member == null)
|
|
{
|
|
return new CErrorResponseMessage("沒有設定會員名稱", null);
|
|
}
|
|
|
|
// 如果取不回fb_id(使用者沒有允許應用程式查看貼文)仍要處理
|
|
string group_user_id = member.group_user_id;
|
|
|
|
string json = "";
|
|
int status = 0;
|
|
var parseData = parser.Parse(comment);
|
|
if (parseData.Success)
|
|
{
|
|
bool isProductCorrect = true;
|
|
foreach (var product in parseData.Product)
|
|
{
|
|
if (product.Name == "I")
|
|
{
|
|
isProductCorrect = false;
|
|
break;
|
|
}
|
|
}
|
|
if (isProductCorrect) // 名稱有I 不Insert進資料庫
|
|
{
|
|
json = JsonConvert.SerializeObject(parseData.Product);
|
|
status = (int)CommentStatus.OK;
|
|
}
|
|
else
|
|
{
|
|
status = (int)CommentStatus.InvalidFormat;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
status = (int)CommentStatus.InvalidFormat;
|
|
// 增加log紀錄確認解析失敗的原因
|
|
Logger.Info($"解析貼文失敗 姓名: {member.name} 內容: {comment} 原因: {parseData.ErrorMessage} 貼文ID: {article.uid}");
|
|
}
|
|
if (string.IsNullOrEmpty(group_user_id))
|
|
{
|
|
status = (int)CommentStatus.UnknownMember;
|
|
}
|
|
|
|
tb_grp_comment cNew = new tb_grp_comment
|
|
{
|
|
uid = Guid.NewGuid().ToString(),
|
|
article_uid = article.uid,
|
|
origin_comment = comment,
|
|
comment = json,
|
|
group_user_id = group_user_id,
|
|
comment_time = DateTime.Now,
|
|
fb_comment_id = null,
|
|
status = status,
|
|
user_name = member.name,
|
|
user_picture = member.fb_pic
|
|
};
|
|
comments.Add(cNew);
|
|
|
|
// 沒有任何留言就不處理
|
|
if (comments.Count == 0)
|
|
{
|
|
return null;
|
|
}
|
|
lCmds.AddRange(comments.Select(x => Command.SetupInsertCmd(x)));
|
|
|
|
var ai = ArsenalDBMgr.GetInst(lCmds[0], GetDefaultSystemColumnInfo());
|
|
ai.RunEditCmds(lCmds);
|
|
sMsg = GetLastErrorCode(lCmds);
|
|
if (sMsg != null)
|
|
{
|
|
crmRes = new CErrorResponseMessage(sMsg, null);
|
|
}
|
|
else
|
|
{
|
|
crmRes = new CSuccessResponseMessage(null, i_crmInput);
|
|
}
|
|
}
|
|
while (false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
sMsg = $"{nameof(DeleteComment)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}.";
|
|
#if DEBUG
|
|
System.Diagnostics.Debug.WriteLine(sMsg);
|
|
#endif
|
|
Logger.Error(ex.ToString());
|
|
}
|
|
|
|
if (sMsg != null)
|
|
{
|
|
crmRes = new CErrorResponseMessage(sMsg, null);
|
|
}
|
|
|
|
return crmRes;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 參考 CreateComment
|
|
/// </summary>
|
|
/// <param name="i_crmInput"></param>
|
|
/// <returns></returns>
|
|
public CResponseMessage ImportComment(CRequestMessage i_crmInput)
|
|
{
|
|
string sMsg = null;
|
|
CResponseMessage crmRes = null;
|
|
var logInfos = new StringBuilder();
|
|
|
|
try
|
|
{
|
|
do
|
|
{
|
|
sMsg = getCommonParameter(i_crmInput, BLWording.ADD_MASTER, out JArray jaDataArray, out tb_sys_session sUserSession);
|
|
if (sMsg != null) break;
|
|
|
|
var article = jaDataArray[0][BLWording.DATA]["article_data"].ToObject<tb_grp_article>();
|
|
var comments = jaDataArray[0][BLWording.DATA][BLWording.DATA].ToString().Split('\n');
|
|
var tb_grp_comment_List = new List<tb_grp_comment>();
|
|
var misMatchMembers = new StringBuilder();
|
|
List<Command> lCmds = new List<Command>();
|
|
|
|
// 取回該社團可以取貨的地點
|
|
var branches = GetBranches(article.group_uid);
|
|
var products = GetProducts(article.uid);
|
|
var members = GetMembers(article.group_uid);
|
|
var productInfos = GetProductInfos(products);// 將名稱以['A', 'B'...]這樣依序產生，如果產品有3個，就要放入['A', 'B', 'C']
|
|
|
|
logInfos.AppendLine($"{nameof(ImportComment)} 開始解析貼文留言 文章ID: {article.uid} 設定: {JsonConvert.SerializeObject(productInfos)}");
|
|
var parser = new GroupBuyParser.GroupBuyParser
|
|
{
|
|
Settings = new GroupBuyParser.ParserSettings
|
|
{
|
|
Products = productInfos,
|
|
Branches = branches.Select(x => x.branch_name).ToList()
|
|
}
|
|
};
|
|
|
|
// 去除匯入留言前面的空白行
|
|
var blankLineCount = 0;
|
|
foreach (var comment in comments)
|
|
{
|
|
if (!string.IsNullOrWhiteSpace(comment)) break;
|
|
|
|
blankLineCount++;
|
|
}
|
|
comments = comments[(blankLineCount)..(comments.Count())];
|
|
|
|
var sortMillsecond = 0;// 累加毫秒數, 用來排序正確留言順序
|
|
List<(string member, string orders)> membersAndOrders = new List<(string, string)>();
|
|
|
|
// Parse comment
|
|
for (int i = 1; i < comments.Length; i++)
|
|
{
|
|
var parserData = ParserComment(parser, comments[i], branches.First().branch_name);
|
|
|
|
if (!parserData.Success) continue;
|
|
|
|
string orders = parserData.Text;
|
|
string member = comments[i - 1];// 往上抓客人名稱
|
|
|
|
// 往下抓可能有多行的訂單
|
|
for (++i; i < comments.Length; i++)
|
|
{
|
|
parserData = ParserComment(parser, comments[i], branches.First().branch_name);
|
|
|
|
if (!parserData.Success) break;
|
|
|
|
orders += parserData.Text;
|
|
}
|
|
|
|
membersAndOrders.Add((member, orders));
|
|
}
|
|
|
|
// Match member & default branch
|
|
foreach (var memberAndOrders in membersAndOrders)
|
|
{
|
|
var member = members.Find(item => item.name == memberAndOrders.member);
|
|
|
|
if (member == null)// 沒匹配的會員名稱
|
|
{
|
|
misMatchMembers.AppendLine($"[{memberAndOrders.orders}] ");
|
|
continue;
|
|
}
|
|
|
|
int status = (int)CommentStatus.UnknownMember;
|
|
var json = "";
|
|
var parseData = ParserComment(parser, memberAndOrders.orders, $"{branches.Find(x => x.uid == member.default_branch)?.branch_name}");// 匯入留言後面加上預設分店中文名稱
|
|
if (parseData.Success)
|
|
{
|
|
bool isProductCorrect = true;
|
|
isProductCorrect = parseData.Product.Find(x => x.Name == "I") == null ? true : false;
|
|
|
|
if (isProductCorrect) // 名稱有I 不Insert進資料庫
|
|
{
|
|
var Branch = branches.Find(item => item.uid == member.default_branch)?.branch_name;// Parser解析Branch會為null, 經討論後都放預設分店
|
|
parseData.Product.ForEach(item => item.Branch = Branch);
|
|
json = JsonConvert.SerializeObject(parseData.Product);
|
|
status = (int)CommentStatus.OK;
|
|
}
|
|
else
|
|
{
|
|
status = (int)CommentStatus.InvalidFormat;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
status = (int)CommentStatus.InvalidFormat;
|
|
logInfos.AppendLine($"{nameof(ImportComment)} 解析貼文失敗 內容: {memberAndOrders.orders} 原因: {parseData.ErrorMessage} 貼文ID: {article.uid}");
|
|
}
|
|
|
|
tb_grp_comment cNew = new tb_grp_comment
|
|
{
|
|
uid = Guid.NewGuid().ToString(),
|
|
article_uid = article.uid,
|
|
origin_comment = memberAndOrders.orders,
|
|
comment = string.IsNullOrWhiteSpace(json) ? "" : json,
|
|
group_user_id = member.group_user_id,
|
|
comment_time = DateTime.Now.AddMilliseconds(sortMillsecond++),
|
|
fb_comment_id = null,
|
|
status = status,
|
|
user_name = member.name,
|
|
user_picture = member.fb_pic,
|
|
};
|
|
tb_grp_comment_List.Add(cNew);
|
|
}
|
|
|
|
if (tb_grp_comment_List.Count == 0)
|
|
{
|
|
sMsg = "沒有要匯入的留言";
|
|
break;
|
|
}
|
|
lCmds.AddRange(tb_grp_comment_List.Select(x => Command.SetupInsertCmd(x)));
|
|
|
|
var ai2 = ArsenalDBMgr.GetInst(lCmds[0], GetDefaultSystemColumnInfo());
|
|
ai2.RunEditCmds(lCmds);
|
|
sMsg = GetLastErrorCode(lCmds);
|
|
if (sMsg != null)
|
|
{
|
|
break;
|
|
}
|
|
|
|
if (!string.IsNullOrWhiteSpace(misMatchMembers.ToString()))
|
|
{
|
|
misMatchMembers.Insert(0, "以下下單會員資料查詢不到, 不匯入系統: ");
|
|
}
|
|
|
|
crmRes = new CSuccessResponseMessage(misMatchMembers.Insert(0, "匯入成功 ").ToString(), i_crmInput);
|
|
}
|
|
while (false);
|
|
}
|
|
catch(Exception ex)
|
|
{
|
|
sMsg = $"{nameof(DeleteComment)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}.";
|
|
#if DEBUG
|
|
System.Diagnostics.Debug.WriteLine(sMsg);
|
|
#endif
|
|
Logger.Error(ex.ToString());
|
|
}
|
|
finally
|
|
{
|
|
Logger.Info(logInfos.ToString());
|
|
}
|
|
|
|
if (sMsg != null)
|
|
{
|
|
crmRes = new CErrorResponseMessage(sMsg, null);
|
|
}
|
|
|
|
return crmRes;
|
|
}
|
|
|
|
private List<tb_prd_article2product> GetProducts(string article_uid)
|
|
{
|
|
/**開始組指令**/
|
|
QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
|
|
|
|
QueryJsonElement qjeArticleToProduct = lBlocks.GetInst();
|
|
qjeArticleToProduct.table = tb_prd_article2product.TABLENAME;
|
|
qjeArticleToProduct.displaycols = new List<string>()
|
|
{
|
|
tb_prd_article2product.CN_UID,
|
|
tb_prd_article2product.CN_NAME,
|
|
tb_prd_article2product.CN_PRICE,
|
|
tb_prd_article2product.CN_SEQ,
|
|
tb_prd_article2product.CN_SPECIFICATION
|
|
};
|
|
qjeArticleToProduct.wherecols = new WhereNode(tb_prd_article2product.CN_ARTICLE_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_prd_article2product), article_uid);
|
|
lBlocks.Add(qjeArticleToProduct);
|
|
|
|
QueryJsonElement qjeProduct = lBlocks.GetInst();
|
|
qjeProduct.table = tb_prd_product.TABLENAME;
|
|
qjeProduct.jointable = qjeArticleToProduct;
|
|
qjeProduct.joincols = new Dictionary<string, string>()
|
|
{
|
|
{ tb_prd_product.CN_UID, tb_prd_article2product.CN_PRD_UID }
|
|
};
|
|
lBlocks.Add(qjeProduct);
|
|
|
|
var sMsg = MakeSelectJoinByBlocks(lBlocks, out Command cRes);
|
|
var ai = ArsenalDBMgr.GetInst(cRes);
|
|
List<tb_prd_article2product> data = ai.RunQueryList<tb_prd_article2product>(cRes);
|
|
|
|
return data.ToList();
|
|
}
|
|
private List<tb_grp_branch> GetBranches(string group_uid)
|
|
{
|
|
tb_grp_branch cDisplay = new tb_grp_branch();
|
|
cDisplay.SetFullDirty();
|
|
var whereNode = new WhereNode(tb_grp_branch.CN_GROUP_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_comment), group_uid);
|
|
var cSelect = Command.SetupSelectCmd(cDisplay, whereNode);
|
|
var ai = ArsenalDBMgr.GetInst(cSelect);
|
|
var data = ai.RunQueryList<tb_grp_branch>(cSelect);
|
|
|
|
return data;
|
|
}
|
|
|
|
public List<tb_meb_member> GetMembers(string group_uid_)
|
|
{
|
|
QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
|
|
|
|
QueryJsonElement qjeMember = lBlocks.GetInst();
|
|
qjeMember.table = tb_meb_member.TABLENAME;
|
|
qjeMember.displaycols = new List<string>()
|
|
{
|
|
tb_meb_member.CN_UID,
|
|
tb_meb_member.CN_NAME,
|
|
tb_meb_member.CN_GROUP_ID,
|
|
tb_meb_member.CN_DEFAULT_BRANCH,
|
|
tb_meb_member.CN_GROUP_USER_ID,
|
|
tb_meb_member.CN_FB_PIC
|
|
};
|
|
//qjeMember.wherecols = new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), article.group_uid);
|
|
lBlocks.Add(qjeMember);
|
|
|
|
QueryJsonElement qjeProduct = lBlocks.GetInst();
|
|
qjeProduct.table = tb_grp_group.TABLENAME;
|
|
qjeProduct.jointable = qjeMember;
|
|
qjeProduct.joincols = new Dictionary<string, string>()
|
|
{
|
|
{ tb_grp_group.CN_FB_GROUP_ID, tb_meb_member.CN_GROUP_ID }
|
|
};
|
|
qjeProduct.wherecols = new WhereNode(tb_grp_group.CN_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_uid_);
|
|
lBlocks.Add(qjeProduct);
|
|
|
|
var sMsg = MakeSelectJoinByBlocks(lBlocks, out Command cRes);
|
|
|
|
if (!string.IsNullOrWhiteSpace(sMsg))
|
|
{
|
|
throw new Exception(sMsg);
|
|
}
|
|
|
|
var ai = ArsenalDBMgr.GetInst(cRes);
|
|
return ai.RunQueryList<tb_meb_member>(cRes);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 使用原本解析器, 加上隨意的預設分店防止錯誤訊息跳出
|
|
/// </summary>
|
|
/// <param name="branch_name"></param>
|
|
/// <param name="comment"></param>
|
|
/// <param name="parser"></param>
|
|
/// <returns></returns>
|
|
private GroupBuyParser.ParserData ParserComment(GroupBuyParser.GroupBuyParser parser, string comment, string branch_name)
|
|
{
|
|
var parserData = new GroupBuyParser.ParserData() { DefaultBranch = branch_name };
|
|
parserData.Text = comment;
|
|
parser.Parse(parserData);
|
|
|
|
return parserData;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 條列A~Z項目時要忽略I項目, Example: ABCDEFGH >>> JKL, 屬於客製化設計
|
|
/// </summary>
|
|
/// <param name="products"></param>
|
|
/// <returns></returns>
|
|
private List<GroupBuyParser.ProductInfo> GetProductInfos(List<tb_prd_article2product> products)
|
|
{
|
|
return products.Select((x, i) => new GroupBuyParser.ProductInfo
|
|
{
|
|
Name = ((char)('A' + (i < 8 ? i : i + 1))).ToString(),// Jump over product items [ I ], Name = ABCDEFGHJ.....etc
|
|
Specifications = string.IsNullOrEmpty(x.specification) ? null : x.specification.Split(',', StringSplitOptions.RemoveEmptyEntries)
|
|
}).ToList();
|
|
}
|
|
}
|
|
}
|