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();
}
}
}