GroupBy/04-程式設計/Trunk/GroupBuy/CounsellorBL.MEB/MemberListService.cs

using CounsellorBL.BLStructure;
using CounsellorBL.Common;
using CounsellorBL.Helper;
using CounsellorBL.ORD;
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.Net.Http;
using static CounsellorBL.Helper.FbRestHelper;

namespace CounsellorBL.MEB
{
    public class MemberListService : SingleDataTableTemplate<tb_meb_member>
    {
        protected class MemberModel : tb_meb_member
        {
            public string age { get; set; }
            public int return_count { get; set; }
            public int amount { get; set; }
        }


        public class FbToken
        {
            public string access_token { get; set; }
            public string token_type { get; set; }
            public bool is_valid { get; set; }
        }


        public class FbGetGroups
        {
            public List<Groups> data { get; set; }
            public JObject paging { get; set; }
        }


        public class Groups
        {
            public string name { get; set; }

            public string id { get; set; }

            public string privacy { get; set; }




        }

        private class CusMemberModel 
        {
            public string uid { get; set; }
            public string group_user_id { get; set; }
            public string group_id { get; set; }
            public string fb_pic { get; set; }
            public string user_token { get; set; }
        }

        private class BatchModel
        {
            public int code { get; set; }
            public string body { get; set; }
        }

        public class PictureModel
        {
            public Picture picture { get; set; }
            public string id { get; set; }

        public class Picture
        {
            public PictureData data { get; set; }

            public class PictureData
            {
                public string url { get; set; }
            }
        }
      }

        public MemberListService()
        {
            dgReadCommandGenerator = readCommandGenerator;
            dgReadCommandPostDataHandler = readCommandPostDataHandler;
        }



        public bool CheckUserIsInGroup(string group_id,string access_token)
        {
            var IsInGroup = false;
            do
            {
                try
                {
                    // 送出資料
                    string uri = "https://graph.facebook.com/v8.0/me/groups?limit=10000?";
                    var dicData = new Dictionary<string, string>()
                    {
                        { "limit", "10000" },
                        { "access_token",access_token}
                    };
                    APIHelper.BaseGet(uri, null, dicData, out HttpResponseMessage responseMessage);
                    if (responseMessage.IsSuccessStatusCode)
                    {
                        var fb_error = GetFbApiError(responseMessage);

                        if (!string.IsNullOrWhiteSpace(fb_error))
                        {
                            Logger.Error($"{nameof(CheckUserIsInGroup)} FB API response error message: {fb_error} ");
                            break;
                        }
                        var responseData = JsonConvert.DeserializeObject<FbGetGroups>(responseMessage.Content.ReadAsStringAsync().Result);
                        IsInGroup = responseData.data.Any(x => x.id == group_id);
                    }
                }
                catch (Exception ex)
                {

                    throw ex;
                }
            } while (false);
            return IsInGroup;

        }



        [Auth(false)]
        public new CResponseMessage ReadMemberInfo(CRequestMessage i_crmInput)
        {
            string sMsg;
            Command cRes = null;
            CResponseMessage crmRes = null;
            do
            {
                try
                {
                    Dictionary<string, string> dicObjCondition = GetQueryMasterFirstWhereData(i_crmInput).ToDictionary(x => x.Key, x => x.Value.ToString());
                    List<string> lsMainColumns = EntityBase.GetAllColumnName(typeof(tb_meb_member));   // 取得所有欄位名稱

                    QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
                    QueryJsonElement qjeMember = lBlocks.GetInst();
                    qjeMember.table = tb_meb_member.TABLENAME;
                    qjeMember.displaycols = lsMainColumns;

                    if (dicObjCondition != null && dicObjCondition.Any())
                    {
                        qjeMember.dicwherecols = dicObjCondition;
                    }
                    lBlocks.Add(qjeMember);

                    QueryJsonElement qjeBranch = lBlocks.GetInst();
                    qjeBranch.table = tb_grp_branch.TABLENAME;
                    qjeBranch.displaycols = new List<string> { tb_grp_branch .CN_BRANCH_NAME};
                    qjeBranch.jointable = qjeMember;
                    qjeBranch.joincols = new Dictionary<string, string> { { tb_grp_branch.CN_UID, tb_meb_member.CN_DEFAULT_BRANCH } };
                    lBlocks.Add(qjeBranch);



                    sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
                    if (sMsg != null)
                    {
                        break;
                    }
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cRes);

                    var qdsMember = ai.RunQueryDataSet(cRes);

                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    // 多傳一些參數到前端
                    crmRes.param.Add("member", new QueryResponse(qdsMember));
                }
                catch (Exception ex)
                {
                    sMsg = $"{nameof(ReadMemberInfo)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. ex={ex.Message}";
#if DEBUG
                    System.Diagnostics.Debug.WriteLine(sMsg);
#endif 
                }
            } while (false);

            if (!string.IsNullOrEmpty(sMsg))
            {
                crmRes = new CErrorResponseMessage(sMsg, i_crmInput);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }


            return crmRes;
        }







        [Auth(false)]
        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
                {
                    Dictionary<string, object> dicObjCondition = GetQueryMasterFirstWhereData(i_crmInput);
                    List<string> lsMainColumns = EntityBase.GetAllColumnName(typeof(tb_meb_member));   // 取得所有欄位名稱
                    var lsBranch = ProjectHelper.GetUserGroup(i_crmInput);   // 取得可讀取社團資料的社團uid清單
                    var lsMember = new List<string>();
                    if (dicObjCondition.ContainsKey(tb_meb_member.CN_UID))
                    {
                        var aMember = dicObjCondition[tb_meb_member.CN_UID] as JArray;
                        foreach (var member in aMember)
                        {
                            lsMember.Add(member.ToString());
                        }
                        dicObjCondition.Remove(tb_meb_member.CN_UID);
                    }

                    Dictionary<string, string> dicCondition = new Dictionary<string, string>();
                    foreach (var condition in dicObjCondition)
                    {
                        dicCondition.Add(condition.Key, condition.Value.ToString());
                    }

                    QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
                    QueryJsonElement qjeMember = lBlocks.GetInst();
                    qjeMember.table = tb_meb_member.TABLENAME;
                    qjeMember.displaycols = lsMainColumns;
                    qjeMember.aliascols = new Dictionary<string, List<string>>
                    {
                         { "'0'", new List<string>() { "return_count" } }
                    };
                    if (lsMember.Any())
                    {
                        qjeMember.wherecols = new WhereNode(tb_meb_member.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_meb_member), lsMember.ToArray());
                    }
                    if (dicCondition != null && dicCondition.Any())
                    {
                        qjeMember.dicwherecols = dicCondition;
                    }
                    lBlocks.Add(qjeMember);

                    QueryJsonElement qjeGroup = lBlocks.GetInst();
                    qjeGroup.table = tb_grp_group.TABLENAME;
                    qjeGroup.jointable = qjeMember;
                    qjeGroup.jointype = QueryJsonElement.LEFT_JOIN;
                    qjeGroup.joincols = new Dictionary<string, string>() {
                             {  tb_grp_group.CN_FB_GROUP_ID,tb_meb_member.CN_GROUP_ID }};
                    if (!dicCondition.ContainsKey(tb_meb_member.CN_GROUP_USER_ID))
                    {
                        qjeGroup.wherecols = new WhereNode(tb_grp_group.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_grp_group), lsBranch.ToArray());
                    }
                    lBlocks.Add(qjeGroup);

                    QueryJsonElement qjePurchase = lBlocks.GetInst();
                    qjePurchase.table = tb_ord_purchase.TABLENAME;
                    qjePurchase.jointype = QueryJsonElement.LEFT_JOIN;
                    qjePurchase.jointable = qjeMember;
                    qjePurchase.joincols = new Dictionary<string, string>() {
                             {  tb_ord_purchase.CN_MEMBER_UID,tb_meb_member.CN_UID }};
                    qjePurchase.aliascols = new Dictionary<string, List<string>>
                    {
                         { QueryJsonElement.SUM(tb_ord_purchase.CN_AMOUNT), new List<string>() { "amount" } },
                    };
                    lBlocks.Add(qjePurchase);

                    qjeMember.groupcols = new List<Tuple<QueryJsonElement, string>>
                    {
                       Tuple.Create(qjeMember, tb_meb_member.CN_UID),
                       Tuple.Create(qjeMember, tb_meb_member.CN_GROUP_ID),
                       Tuple.Create(qjeMember, tb_meb_member.CN_GROUP_USER_ID),
                       Tuple.Create(qjeMember, tb_meb_member.CN_MESSAGE_USER_ID),
                       Tuple.Create(qjeMember, tb_meb_member.CN_EMAIL),
                       Tuple.Create(qjeMember, tb_meb_member.CN_RANK),
                       Tuple.Create(qjeMember, tb_meb_member.CN_FB_PIC),
                       Tuple.Create(qjeMember, tb_meb_member.CN_NAME),
                       Tuple.Create(qjeMember, tb_meb_member.CN_NICKNAME),
                       Tuple.Create(qjeMember, tb_meb_member.CN_GENDER),
                       Tuple.Create(qjeMember, tb_meb_member.CN_JOB),
                       Tuple.Create(qjeMember, tb_meb_member.CN_BIRTHDAY),
                       Tuple.Create(qjeMember, tb_meb_member.CN_CELLPHONE),
                       Tuple.Create(qjeMember, tb_meb_member.CN_PHONE),
                       Tuple.Create(qjeMember, tb_meb_member.CN_LAST_CALL_MESSAGE),
                       Tuple.Create(qjeMember, tb_meb_member.CN_LINE_ID),
                       Tuple.Create(qjeMember, tb_meb_member.CN_AREA),
                       Tuple.Create(qjeMember, tb_meb_member.CN_ADDRESS),
                       Tuple.Create(qjeMember, tb_meb_member.CN_LINK),
                       Tuple.Create(qjeMember, tb_meb_member.CN_SHOPPING_ACCOUNT),
                       Tuple.Create(qjeMember, tb_meb_member.CN_STATUS_FLAG),
                       Tuple.Create(qjeMember, tb_meb_member.CN_DEFAULT_BRANCH),
                       Tuple.Create(qjeMember, tb_meb_member.CN_DELETE_FLAG),
                       Tuple.Create(qjeMember, tb_meb_member.CN_WPRICE_PAYMENT),
                       Tuple.Create(qjeMember, tb_meb_member.CN_CREATE_DATE),
                       Tuple.Create(qjeMember, tb_meb_member.CN_UPDATE_DATE),
                       Tuple.Create(qjeMember, tb_meb_member.CN_CREATE_USER_UID),
                       Tuple.Create(qjeMember, tb_meb_member.CN_UPDATE_USER_UID),
                       Tuple.Create(qjeMember, tb_meb_member.CN_RETURN_COUNT),
                       Tuple.Create(qjeMember, tb_meb_member.CN_FIREBASE_TOKEN),
                    };

                    sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
                    if (sMsg != null)
                    {
                        break;
                    }
                }
                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 readCommandPostDataHandler(CRequestMessage i_crmInput, ArsenalInterface i_aiArsenal, Command i_cCmd, JArray i_jaData, tb_sys_session i_sSessionUser, out object o_oReault,
            [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<MemberModel> oResultData = null;
            try
            {
                do
                {
                    Dictionary<string, object> dicCondition = GetQueryMasterFirstWhereData(i_crmInput);   // 取得condition
                    List<MemberModel> qds = i_aiArsenal.RunQueryList<MemberModel>(i_cCmd);

                    if (!i_cCmd.IsSuccess)
                    {
                        sMsg = i_cCmd.LastErrorCode;
                        break;
                    }

                    if (dicCondition.ContainsKey("birthdayMonth"))
                    {
                        qds = qds.Where(x => x.birthday.HasValue && x.birthday.Value.Month == Convert.ToInt32(dicCondition["birthdayMonth"])).ToList();
                    }
                    // 不顯示現貨銷售
                    if (dicCondition.ContainsKey("hideSpotSale"))
                    {
                        qds = qds.Where(x => x.name != "現貨銷售").ToList();
                    }

                    foreach (var data in qds)
                    {
                        if (data.birthday.HasValue)
                        {
                            var age = CalculateAgeCorrect(data.birthday.Value, DateTime.Now);
                            data.age = age == 0 ? "" : age.ToString();
                        }
                    }
                    oResultData = qds.OrderByDescending(x => x.create_date).ToList();
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex), i_nCodeLine, i_sMemberName, i_sSourcePath);
                sMsg = $"{nameof(readCommandPostDataHandler)} 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_oReault = oResultData;
            return sMsg;
        }

        public int CalculateAgeCorrect(DateTime birthDate, DateTime now)
        {
            int age = now.Year - birthDate.Year;
            if (now.Month < birthDate.Month || (now.Month == birthDate.Month && now.Day < birthDate.Day)) age--;
            return age;
        }

        /// <summary>
        /// 取得應用程式權杖
        /// </summary>
        /// <param name="authorizationToken"></param>
        /// <param name="client_id"></param>
        /// <param name="client_secret"></param>
        /// <returns></returns>
        public bool GetAppToken(string APP_ID, string CLIENT_SECRET, out FbToken responseData)
        {
            responseData = new FbToken();
            string uri = string.Format("https://graph.facebook.com/oauth/access_token?client_id={0}&client_secret={1}&grant_type=client_credentials", APP_ID, CLIENT_SECRET);
            APIHelper.BaseGet(uri, null, new Dictionary<string, string>(), out HttpResponseMessage responseMessage);
            if (responseMessage.IsSuccessStatusCode)
            {
                responseData = JsonConvert.DeserializeObject<FbToken>(responseMessage.Content.ReadAsStringAsync().Result);
            }
            return responseMessage.IsSuccessStatusCode;
        }




        public bool GetFBPagesID(string i_sASID, string PAGE_ID, string i_sToken, out string o_sPSID)
        {
            o_sPSID = null;
            string uri = string.Format("https://graph.facebook.com/{0}/ids_for_pages?page={1}&access_token={2}", i_sASID, PAGE_ID, i_sToken);
            APIHelper.BaseGet(uri, null, new Dictionary<string, string>(), out HttpResponseMessage responseMessage);
            if (responseMessage.IsSuccessStatusCode)
            {
                var sResponse = responseMessage.Content.ReadAsStringAsync().Result;
                Logger.Info(uri + " && " + sResponse);
                var joResult = JsonConvert.DeserializeObject(sResponse) as JObject;
                var oResult = joResult.ToObject<Dictionary<string, object>>();
                var jaData = oResult["data"] as JArray;
                if (jaData.Any())
                {
                    var joData = jaData.First() as JObject;
                    if (joData != null)
                    {
                        var objData = joData.ToObject<Dictionary<string, object>>();
                        o_sPSID = objData["id"].ToString();
                    }
                }
            }
            return responseMessage.IsSuccessStatusCode;
        }


        [Auth(false)]
        public CResponseMessage GetQrCode(CRequestMessage i_crmInput)
        {
            string sMsg = null;
            CResponseMessage crmRes = null;
            do
            {
                try
                {
                    Dictionary<string, object> dicCondition = GetQueryMasterFirstWhereData(i_crmInput);   // 取得condition

                    if (!string.IsNullOrEmpty(sMsg))
                    {
                        break;
                    }
                    var group_id = dicCondition[tb_meb_member.CN_GROUP_ID].ToString();
                    // 先查詢資料是否存在
                    tb_meb_member cMember = new tb_meb_member();
                    cMember.SetDirty(tb_meb_member.CN_UID, tb_meb_member.CN_GROUP_USER_ID);
                    tb_meb_member cMemberCon = new tb_meb_member() { group_user_id = dicCondition[tb_meb_member.CN_GROUP_USER_ID].ToString(), group_id = group_id };
                    Command cMemberSelect = Command.SetupSelectCmd(cMember, cMemberCon);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cMemberSelect);
                    tb_meb_member qdsMember = ai.RunQuerySingleORM<tb_meb_member>(cMemberSelect);

                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    // 多傳一些參數到前端
                    crmRes.param.Add("member", qdsMember);

                }
                catch (Exception ex)
                {
                    sMsg = $"{nameof(PatchMemberInfo)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. ex={ex.Message}";
#if DEBUG
                    System.Diagnostics.Debug.WriteLine(sMsg);
#endif
                }
            } while (false);

            if (!string.IsNullOrEmpty(sMsg))
            {
                crmRes = new CErrorResponseMessage(sMsg, i_crmInput);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }

        
        [Auth(false)]
        public CResponseMessage CheckTokenValid(CRequestMessage i_crmInput)
        {
            string sMsg = null;
            CResponseMessage crmRes = null;
            do
            {
                try
                {
                    Dictionary<string, object> dicCondition = GetQueryMasterFirstWhereData(i_crmInput);   // 取得condition
                    var fbHelper = new FbRestHelper();
                    sMsg = fbHelper.CallFbGetInformation(dicCondition["token"].ToString(), out UserInfo userInfo);

                    if (!string.IsNullOrEmpty(sMsg))
                    {
                        break;
                    }


                    var group_id = dicCondition[tb_meb_member.CN_GROUP_ID].ToString();
                    var groupData = GetGroupSettings(group_id);

                    string sPSID = null;
                    if (groupData == null)
                    {
                        sMsg = "社團資訊錯誤";
                        break;
                    }

                    #region 取得 pages_user_id <PSID> 到貨通知需要
                    var result = GetAppToken(groupData.app_id, groupData.client_secret, out FbToken resData);
                    if (result)
                    {
                        GetFBPagesID(userInfo.id, groupData.page_id, resData.access_token, out sPSID);
                    }
                    string privacy = null;
                    bool isSuccess  = getPrivacy(group_id, out privacy);

                    var IsOpen = false;
                    if (privacy == "OPEN")
                    {
                        IsOpen = true;
                    }



                    #endregion
                    var IsInGroups = CheckUserIsInGroup(group_id, dicCondition["token"].ToString());




                    // 更新會員資料
                    List<Command> lCmdUpdate = new List<Command>();

                    // 先查詢資料是否存在
                    tb_meb_member cMember = new tb_meb_member();
                    cMember.SetFullDirty();
                    tb_meb_member cMemberCon = new tb_meb_member() { group_user_id = userInfo.id, group_id = group_id };
                    Command cMemberSelect = Command.SetupSelectCmd(cMember, cMemberCon);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cMemberSelect);
                    tb_meb_member qdsMember = ai.RunQuerySingleORM<tb_meb_member>(cMemberSelect);
                    string asid = userInfo.id;


                    if (qdsMember == null)
                    {

                        // 新增
                        tb_meb_member mNew = new tb_meb_member() { };
                        mNew.message_user_id = sPSID;
                        mNew.group_user_id = asid;
                        mNew.last_call_message = DateTime.Now;
                        mNew.gender = userInfo.gender;
                        mNew.email = userInfo.email;
                        mNew.fb_pic = userInfo.picture.data.url;

                        if (DateTime.TryParse(userInfo.birthday, out DateTime birthday))
                        {
                            mNew.birthday = birthday;
                        }

                        mNew.group_user_id = userInfo.id;
                        mNew.group_id = dicCondition["group_id"].ToString();
                        lCmdUpdate.Add(Command.SetupInsertCmd(mNew));
                    }
                    else
                    {
                        // 更新
                        tb_meb_member mUpd = new tb_meb_member();
                        mUpd.message_user_id = sPSID;
                        if (qdsMember.last_call_message == null)   // 紀錄最後傳送時間
                        {
                            mUpd.last_call_message = DateTime.Now;
                        }
                        mUpd.message_user_id = sPSID;
                        mUpd.group_user_id = asid;
                        mUpd.last_call_message = DateTime.Now;
                        mUpd.gender = userInfo.gender;
                        mUpd.email = userInfo.email;
                        mUpd.fb_pic = userInfo.picture.data.url;
                        if (DateTime.TryParse(userInfo.birthday, out DateTime birthday))
                        {
                            mUpd.birthday = birthday;
                        }

                        mUpd.group_user_id = userInfo.id;


                        List<WhereNode> lswnMain = new List<WhereNode>();
                        lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), asid));
                        lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_id));

                        lCmdUpdate.Add(Command.SetupUpdateCmd(mUpd, new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMain.ToArray())));
                    }
                    ai = ArsenalDBMgr.GetInst(lCmdUpdate[0], GetDefaultSystemColumnInfo());
                    ai.RunEditCmds(lCmdUpdate);
                    sMsg = GetLastErrorCode(lCmdUpdate);

                    if (sMsg != null)
                    {
                        if (sMsg == "msg.sqlserver_2627") // 此錯誤為重複 Insert 相同 group_user_id and group_id 改為更新
                        {
                            List<Command> lCmdUpdateWhenErr = new List<Command>();
                            // 更新
                            tb_meb_member mUpdErr = new tb_meb_member();
                            mUpdErr.message_user_id = sPSID;
                            mUpdErr.message_user_id = sPSID;
                            mUpdErr.group_user_id = asid;
                            mUpdErr.last_call_message = DateTime.Now;
                            mUpdErr.gender = userInfo.gender;
                            mUpdErr.email = userInfo.email;
                            mUpdErr.fb_pic = userInfo.picture.data.url;
                            if (DateTime.TryParse(userInfo.birthday, out DateTime birthday))
                            {
                                mUpdErr.birthday = birthday;
                            }
                            mUpdErr.group_user_id = userInfo.id;
                            List<WhereNode> lswnMainErr = new List<WhereNode>();
                            lswnMainErr.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), asid));
                            lswnMainErr.Add(new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_id));

                            lCmdUpdateWhenErr.Add(Command.SetupUpdateCmd(mUpdErr, new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMainErr.ToArray())));

                            ArsenalInterface ai2 = ArsenalDBMgr.GetInst(lCmdUpdateWhenErr[0], GetDefaultSystemColumnInfo());
                            ai2.RunEditCmds(lCmdUpdateWhenErr);
                            sMsg = GetLastErrorCode(lCmdUpdateWhenErr);
                            // 傳必要參數至前端
                            crmRes.param.Add("psid", sPSID);
                            crmRes.param.Add("branch_status", 1);

                            break;
                        }
                        else
                        {
                            break;
                        }
                    }

                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    // 多傳一些參數到前端
                    crmRes.param.Add("psid", sPSID);

                    if (IsOpen == true)
                    {
                        crmRes.param.Add("joinGroups", "Y");
                    }
                    else
                    {
                        crmRes.param.Add("joinGroups",  IsInGroups == true ? "Y" : "N");
                    }

             
                    crmRes.param.Add("fbid", userInfo.id);

                    // 只顯示公開的分店
                    List<tb_grp_branch> branches = GetBranches(group_id);
                    var enabledBranches = branches.Where(x => x.public_status == (int)Enums.Flag.Enable).Select(x => new { value = x.uid, display = x.branch_name });

                    // 沒有預設分店
                    string default_branch = qdsMember?.default_branch;
                    int branch_status = 0;   // 0:未填寫  1:已填寫  -1:已填寫但分店消失
                    if (!string.IsNullOrEmpty(default_branch))
                    {
                        branch_status = enabledBranches.Any(x => x.value == default_branch) ? 1 : -1;
                        crmRes.param.Add("default_branch", enabledBranches.Where(x => x.value == default_branch).FirstOrDefault().display);
                    }
                    if (branch_status != 1)
                    {
                        crmRes.param.Add("branch_data", enabledBranches);
                    }
                    crmRes.param.Add("branch_status", branch_status);
                    Logger.Info($"group_id: {group_id}  group_user_id: {asid}  branch_status: {branch_status}  enabledBranches: {enabledBranches.Count()}");

                    // 紀錄是否第一次登入
                    if (qdsMember == null)
                    {
                        crmRes.param.Add("first_login", true);
                    }

                    //在查一次傳uid
                    cMember = new tb_meb_member();
                    cMember.SetFullDirty();
                    cMemberCon = new tb_meb_member() { group_user_id = userInfo.id, group_id = group_id };
                    cMemberSelect = Command.SetupSelectCmd(cMember, cMemberCon);
                    ai = ArsenalDBMgr.GetInst(cMemberSelect);
                    qdsMember = ai.RunQuerySingleORM<tb_meb_member>(cMemberSelect);
                    if (qdsMember == null)
                    {
                        crmRes.param.Add("uid", tb_meb_member.CN_UID);
                    }
                    crmRes.param.Add("token", Guid.NewGuid().ToString());


                    // 如果超過指定天數沒有按，提醒使用者
                    bool sendMessageAgain = qdsMember?.message_user_id != null && qdsMember?.last_call_message <= DateTime.Now.AddMonths(-1);
                    crmRes.param.Add("send_msg_again", sendMessageAgain);
                }
                catch (Exception ex)
                {
                    sMsg = $"{nameof(PatchMemberInfo)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. ex={ex.Message}";
#if DEBUG
                    System.Diagnostics.Debug.WriteLine(sMsg);
#endif
                }
            } while (false);

            if (!string.IsNullOrEmpty(sMsg))
            {
                crmRes = new CErrorResponseMessage(sMsg, i_crmInput);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }







        [Auth(false)]
        public CResponseMessage PatchMemberInfo(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;
                    }
                    if (jaDataArray.Count != 1 || jaDataArray[0] == null)
                    {
                        sMsg = MessageWording.PARAM_NOT_EXPECTED;
                        break;
                    }

                    JObject joData = jaDataArray[0] as JObject;
                    Dictionary<string, object> dicData = new Dictionary<string, object>();

                    if (joData != null)
                    {
                        dicData = joData.ToObject<Dictionary<string, object>>();
                    }
                    string sPSID = null;

                    var group_id = dicData[tb_meb_member.CN_GROUP_ID].ToString();
                    var groupData = GetGroupSettings(group_id);

                    if (groupData == null)
                    {
                        sMsg = "社團資訊錯誤";
                        break;
                    }

                    #region 取得 pages_user_id <PSID> 到貨通知需要
                    var result = GetAppToken(groupData.app_id, groupData.client_secret, out FbToken resData);
                    if (result)
                    {
                        GetFBPagesID(dicData[BLWording.ASID].ToString(), groupData.page_id, resData.access_token, out sPSID);
                    }
                    #endregion

                    // 更新會員資料
                    List<Command> lCmdUpdate = new List<Command>();

                    // 先查詢資料是否存在
                    tb_meb_member cMember = new tb_meb_member();
                    cMember.SetFullDirty();
                    tb_meb_member cMemberCon = new tb_meb_member() { group_user_id = dicData[BLWording.ASID].ToString(), group_id = group_id };
                    Command cMemberSelect = Command.SetupSelectCmd(cMember, cMemberCon);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cMemberSelect);
                    tb_meb_member qdsMember = ai.RunQuerySingleORM<tb_meb_member>(cMemberSelect);
                    string asid = dicData[BLWording.ASID].ToString();

                    if (qdsMember == null)
                    {
                        // 新增
                        tb_meb_member mNew = new tb_meb_member() { };
                        mNew.message_user_id = sPSID;
                        mNew.group_user_id = asid;
                        mNew.last_call_message = DateTime.Now;
                        mNew.FillData(dicData);
                        lCmdUpdate.Add(Command.SetupInsertCmd(mNew));
                    }
                    else
                    {
                        // 更新
                        dicData.Remove("group_id");
                        tb_meb_member mUpd = new tb_meb_member();
                        mUpd.message_user_id = sPSID;
                        if (qdsMember.last_call_message == null)   // 紀錄最後傳送時間
                        {
                            mUpd.last_call_message = DateTime.Now;
                        }
                        mUpd.FillData(dicData);
                        List<WhereNode> lswnMain = new List<WhereNode>();
                        lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), asid));
                        lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_id));

                        lCmdUpdate.Add(Command.SetupUpdateCmd(mUpd, new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMain.ToArray())));
                    }
                    ai = ArsenalDBMgr.GetInst(lCmdUpdate[0], GetDefaultSystemColumnInfo());
                    ai.RunEditCmds(lCmdUpdate);
                    sMsg = GetLastErrorCode(lCmdUpdate);

                    if (sMsg != null)
                    {
                        if (sMsg == "msg.sqlserver_2627") // 此錯誤為重複 Insert 相同 group_user_id and group_id 改為更新
                        {
                            List<Command> lCmdUpdateWhenErr = new List<Command>();
                            // 更新
                            dicData.Remove("group_id");
                            tb_meb_member mUpdErr = new tb_meb_member();
                            mUpdErr.message_user_id = sPSID;
                            mUpdErr.FillData(dicData);
                            List<WhereNode> lswnMainErr = new List<WhereNode>();
                            lswnMainErr.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), asid));
                            lswnMainErr.Add(new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_id));

                            lCmdUpdateWhenErr.Add(Command.SetupUpdateCmd(mUpdErr, new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMainErr.ToArray())));

                            ArsenalInterface ai2 = ArsenalDBMgr.GetInst(lCmdUpdateWhenErr[0], GetDefaultSystemColumnInfo());
                            ai2.RunEditCmds(lCmdUpdateWhenErr);
                            sMsg = GetLastErrorCode(lCmdUpdateWhenErr);
                            // 傳必要參數至前端
                            crmRes.param.Add("psid", sPSID);
                            crmRes.param.Add("branch_status", 1);

                            break;
                        }
                        else
                        {
                            break;
                        }
                    }

                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    // 多傳一些參數到前端
                    crmRes.param.Add("psid", sPSID);

                    // 只顯示公開的分店
                    List<tb_grp_branch> branches = GetBranches(group_id);
                    var enabledBranches = branches.Where(x => x.public_status == (int)Enums.Flag.Enable).Select(x => new { value = x.uid, display = $"{x.branch_name} - {x.address = x.address }" });

                    // 沒有預設分店
                    string default_branch = qdsMember?.default_branch;
                    int branch_status = 0;   // 0:未填寫  1:已填寫  -1:已填寫但分店消失
                    if (!string.IsNullOrEmpty(default_branch))
                    {
                        branch_status = enabledBranches.Any(x => x.value == default_branch) ? 1 : -1;
                        crmRes.param.Add("default_branch", enabledBranches.Where(x => x.value == default_branch).FirstOrDefault().display);
                    }
                    if (branch_status != 1)
                    {
                        crmRes.param.Add("branch_data", enabledBranches);
                    }
                    crmRes.param.Add("branch_status", branch_status);
                    Logger.Info($"group_id: {group_id}  group_user_id: {asid}  branch_status: {branch_status}  enabledBranches: {enabledBranches.Count()}");

                    // 紀錄是否第一次登入
                    if (qdsMember == null)
                    {
                        crmRes.param.Add("first_login", true);
                    }

                    // 如果超過指定天數沒有按，提醒使用者
                    bool sendMessageAgain = qdsMember?.message_user_id != null && qdsMember?.last_call_message <= DateTime.Now.AddMonths(-1);
                    crmRes.param.Add("send_msg_again", sendMessageAgain);
                }
                while (false);
            }
            catch (Exception ex)
            {
                sMsg = $"{nameof(PatchMemberInfo)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. ex={ex.Message}";
#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif 
            }

            if (string.IsNullOrEmpty(sMsg))
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                crmRes = new CErrorResponseMessage(sMsg, i_crmInput);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            return crmRes;
        }

        private List<tb_grp_branch> GetBranches(string group_id)
        {
            // 從group_id找到uid，再用uid去撈分店名稱跟分店uid
            QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
            QueryJsonElement qjeOrigin = lBlocks.GetInst();
            qjeOrigin.table = tb_grp_group.TABLENAME;
            qjeOrigin.displaycols = new List<string>() { tb_grp_group.CN_UID };
            qjeOrigin.wherecols = new WhereNode(tb_grp_group.CN_FB_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_group), group_id);
            lBlocks.Add(qjeOrigin);
            string sMsg = MakeSelectJoinByBlocks(lBlocks, out Command cRes);
            var ai = ArsenalDBMgr.GetInst(cRes);
            var group = ai.RunQuerySingleORM<tb_grp_group>(cRes);

            if (group == null)
            {
                return null;
            }

            lBlocks = new QueryJsonElementCollection();
            qjeOrigin = lBlocks.GetInst();
            qjeOrigin.table = tb_grp_branch.TABLENAME;
            qjeOrigin.displaycols = new List<string>() { tb_grp_branch.CN_UID, tb_grp_branch.CN_BRANCH_NAME, tb_grp_branch.CN_PUBLIC_STATUS, tb_grp_branch.CN_ADDRESS };
            qjeOrigin.wherecols = new WhereNode(tb_grp_branch.CN_GROUP_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_branch), group.uid);
            lBlocks.Add(qjeOrigin);
            sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
            ai = ArsenalDBMgr.GetInst(cRes);
            var data = ai.RunQueryList<tb_grp_branch>(cRes);

            return data;
        }

        public CResponseMessage GetMatchedMember(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;

            try
            {
                do
                {
                    tb_meb_member sDisplay = new tb_meb_member();
                    sDisplay.SetFullDirtyEx(EntityBaseExtension.EColumnFilter.ES_NO_SYSTEMCOLUMN);
                    Command cAllSetting = Command.SetupSelectCmd(sDisplay);

                    crmRes = this.simpleQuery(i_crmInput, BLWording.QRY_MASTER, null, cAllSetting);

                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(GetMatchedMember)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }
        public CResponseMessage GetMemberProfile(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            Command cRes = null;

            try
            {
                do
                {
                    Dictionary<string, string> dicCondition = GetQueryMasterFirstQJEDicwherecols(i_crmInput);

                    var lsBranch = ProjectHelper.GetUserGroup(i_crmInput);

                    QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
                    QueryJsonElement qjeMember = lBlocks.GetInst();
                    qjeMember.table = tb_meb_member.TABLENAME;
                    qjeMember.dicwherecols = dicCondition;
                    lBlocks.Add(qjeMember);

                    QueryJsonElement qjeGroup = lBlocks.GetInst();
                    qjeGroup.table = tb_grp_group.TABLENAME;
                    qjeGroup.jointable = qjeMember;
                    qjeGroup.jointype = QueryJsonElement.LEFT_JOIN;
                    qjeGroup.joincols = new Dictionary<string, string>() {
                             {  tb_grp_group.CN_FB_GROUP_ID,tb_meb_member.CN_GROUP_ID }};
                    if (!dicCondition.ContainsKey(tb_meb_member.CN_GROUP_USER_ID))
                    {
                        qjeGroup.wherecols = new WhereNode(tb_grp_group.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_grp_group), lsBranch.ToArray());
                    }
                    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
                    };
                    lBlocks.Add(qjeGroupUser);

                    sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cRes);
                    List<tb_grp_group> qds = ai.RunQueryList<tb_grp_group>(cRes);
                    var user_token = "";
                    foreach (var data in qds)
                    {
                        user_token = data.GetValue("user_token").ToString();
                    }
                    string uri = "";
                    if (dicCondition.ContainsKey(tb_meb_member.CN_GROUP_USER_ID))
                    {
                        uri = string.Format("https://graph.facebook.com/{0}?fields={1}&access_token={2}", dicCondition[tb_meb_member.CN_GROUP_USER_ID], "picture.type(normal)", user_token);
                    }
                    APIHelper.BaseGet(uri, null, new Dictionary<string, string>(), out HttpResponseMessage responseMessage);

                    if (responseMessage.IsSuccessStatusCode)
                    {
                        var joResult = JsonConvert.DeserializeObject(responseMessage.Content.ReadAsStringAsync().Result) as JObject;
                        var oResult = joResult.ToObject<Dictionary<string, object>>();
                        if (oResult.Any())
                        {
                            crmRes = new CSuccessResponseMessage(null, i_crmInput);
                            crmRes.param.Add("data", oResult);
                        }
                    }
                    else
                    {
                        LogHelper.DBLog("url獲取picture失敗:" + uri);
                        crmRes = new CErrorResponseMessage("獲取picture失敗");
                    }

                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(GetMemberProfile)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }


        public CResponseMessage RefreshAllMemberInfo(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            Command cRes = null;
            try
            {
                do
                {
                    Dictionary<string, object> dicCondition = GetQueryMasterFirstWhereData(i_crmInput);   
                    string[] aMemberUID = new string[0];
                    if (dicCondition.ContainsKey(tb_meb_member.CN_UID))
                    {
                        if (dicCondition[tb_meb_member.CN_UID] != null)
                        {
                            var jaMemberUID = dicCondition[tb_meb_member.CN_UID] as JArray;
                            aMemberUID = jaMemberUID.Select(x => x.ToString()).ToArray();
                        }
                    }
                    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_GROUP_USER_ID,
                      tb_meb_member.CN_GROUP_ID,
                      tb_meb_member.CN_FB_PIC
                    };
                    qjeMember.wherecols = new WhereNode(tb_meb_member.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_meb_member), aMemberUID.ToArray());
                    lBlocks.Add(qjeMember);

                    QueryJsonElement qjeGroup = lBlocks.GetInst();
                    qjeGroup.table = tb_grp_group.TABLENAME;
                    qjeGroup.jointable = qjeMember;
                    qjeGroup.jointype = QueryJsonElement.LEFT_JOIN;
                    qjeGroup.joincols = new Dictionary<string, string>() {
                             {  tb_grp_group.CN_FB_GROUP_ID,tb_meb_member.CN_GROUP_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
                    };
                    lBlocks.Add(qjeGroupUser);

                    sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cRes);
                    List<CusMemberModel> qds = ai.RunQueryList<CusMemberModel>(cRes);
                   
                    List<Command> lCmdUpdate = new List<Command>();
                    List<WhereNode> lswnMain = new List<WhereNode>();
                    var user_token = "";
                    if(qds.Count()>0)
                    {
                        user_token = qds[0].user_token.ToString();
                    }
                   
                    string strPostUrl = "https://graph.facebook.com/me";
                    var lsData = new List<APIHelper.DataContent>()
                        {
                            new APIHelper.DataContent { Key = "access_token" , Type = typeof(StringContent) , Content = user_token },
                            new APIHelper.DataContent { Key = "include_headers", Type = typeof(StringContent), Content =  "false" }
                        };
                    var listBacth = new List<Dictionary<string, string>>();
                    var dicBacth = new Dictionary<string, string>();
                    var iRowNO = 0;
                    foreach (CusMemberModel MemberData in qds)
                    {
                        iRowNO++;
                        dicBacth = new Dictionary<string, string>();
                        dicBacth.Add("method", "GET");
                        dicBacth.Add("relative_url", string.Format("{0}?fields={1}", MemberData.group_user_id, "picture.type(normal)"));
                        listBacth.Add(dicBacth);
                        try
                        {
                            //每50執行一次批次
                            if (iRowNO % 50 == 0 || iRowNO == qds.Count())
                            {
                                lsData.Add(new APIHelper.DataContent { Key = "batch", Type = typeof(StringContent), Content = JsonConvert.SerializeObject(listBacth) });
                                listBacth = new List<Dictionary<string, string>>();
                                APIHelper.BasePost(strPostUrl, null, lsData, out HttpResponseMessage responseMessage);
                                if (responseMessage.IsSuccessStatusCode)
                                {
                                    string sContent = responseMessage.Content.ReadAsStringAsync().Result;
                                    var lstReturn = JsonConvert.DeserializeObject<List<BatchModel>>(sContent);
                                    foreach (BatchModel BatchModel in lstReturn)
                                    {
                                        if (BatchModel.code == 200)
                                        {
                                            var PictureModel = JsonConvert.DeserializeObject<PictureModel>(BatchModel.body);
                                            var strPicurl = PictureModel.picture.data.url;
                                            if (!string.IsNullOrEmpty(strPicurl))
                                            {
                                                //更新
                                                tb_meb_member mUpd = new tb_meb_member();
                                                mUpd.fb_pic = strPicurl;
                                                mUpd.update_date = DateTime.Now;
                                                lswnMain = new List<WhereNode>();
                                                lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), PictureModel.id));
                                                lCmdUpdate.Add(Command.SetupUpdateCmd(mUpd, new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMain.ToArray())));
                                            }
                                        }
                                    }

                                }
                                else
                                {
                                    Logger.Error($"CallFbPostPushAPI f7");
                                    sMsg = JsonConvert.SerializeObject(responseMessage);
                                    Logger.Error($"CallFbPostPushAPI sMsg={sMsg}");
                                    break;
                                }
                            }

                        }
                        catch (Exception ex)
                        {
                            LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                            Logger.Error(MemberData.uid + "error");
                            sMsg = MemberData.uid + "error";

#if DEBUG
                            System.Diagnostics.Debug.WriteLine(sMsg);
#endif
                        }
                    }
                    // 更新fb_pic資料
                    if (lCmdUpdate.Count() > 0)
                    {
                        ai = ArsenalDBMgr.GetInst(lCmdUpdate[0], GetDefaultSystemColumnInfo());
                        ai.RunEditCmds(lCmdUpdate);
                        sMsg = GetLastErrorCode(lCmdUpdate);

                        if (sMsg != null)
                        {
                            break;
                        }
                    }
                    //查詢最新的fb_pic
                     lBlocks = new QueryJsonElementCollection();
                     qjeMember = lBlocks.GetInst();
                     qjeMember.table = tb_meb_member.TABLENAME;
                     qjeMember.displaycols = new List<string>()
                    { tb_meb_member.CN_UID,
                      tb_meb_member.CN_GROUP_USER_ID,
                      tb_meb_member.CN_GROUP_ID,
                      tb_meb_member.CN_FB_PIC
                    };
                    qjeMember.wherecols = new WhereNode(tb_meb_member.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_meb_member), aMemberUID.ToArray());
                    lBlocks.Add(qjeMember);
                    sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
                    ai = ArsenalDBMgr.GetInst(cRes);
                    qds = ai.RunQueryList<CusMemberModel>(cRes);
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    crmRes.param.Add(BLWording.DATA, qds);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(GetMemberProfile)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            return crmRes;
        }

        [Auth(false)]
        public CResponseMessage SetDefaultBranch(CRequestMessage i_crmInput)
        {
            return UpdateCommand(i_crmInput, (dicData) =>
            {
                var defaultBranch = dicData[tb_meb_member.CN_DEFAULT_BRANCH] as string;
                var group_user_id = dicData[tb_meb_member.CN_GROUP_USER_ID] as string;
                var group_id = dicData[tb_meb_member.CN_GROUP_ID] as string;

                // 更新預設分店
                tb_meb_member updateEntity = new tb_meb_member { default_branch = defaultBranch };
                tb_meb_member updateEntityCond = new tb_meb_member { group_user_id = group_user_id, group_id = group_id };
                return Command.SetupUpdateCmd(updateEntity, updateEntityCond);
            });
        }

        [Auth(false)]
        public CResponseMessage CallSendMessage(CRequestMessage i_crmInput)
        {
            return UpdateCommand(i_crmInput, (dicData) =>
            {
                var group_user_id = dicData[tb_meb_member.CN_GROUP_USER_ID] as string;
                var group_id = dicData[tb_meb_member.CN_GROUP_ID] as string;

                // 更新最後傳遞訊息時間
                tb_meb_member updateEntity = new tb_meb_member { last_call_message = DateTime.Now };
                tb_meb_member updateEntityCond = new tb_meb_member { group_user_id = group_user_id, group_id = group_id };
                return Command.SetupUpdateCmd(updateEntity, updateEntityCond);
            });
        }

        private CResponseMessage UpdateCommand(CRequestMessage i_crmInput, Func<Dictionary<string, object>, Command> func)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            Dictionary<string, object> dicData = (i_crmInput.param[BLWording.UPD_MASTER] as JObject).ToObject<Dictionary<string, object>>();

            try
            {
                do
                {
                    Command cmd = func(dicData);

                    var ai = ArsenalDBMgr.GetInst(cmd, GetDefaultSystemColumnInfo());
                    ai.RunEditSingleCmd(cmd);
                    sMsg = GetLastErrorCode(cmd);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(UpdateCommand)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                crmRes = new CSuccessResponseMessage(null, i_crmInput);
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }
        public CResponseMessage RefreshMemberInfo(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;
                    }
                    if (jaDataArray.Count != 1 || jaDataArray[0] == null)
                    {
                        sMsg = MessageWording.PARAM_NOT_EXPECTED;
                        break;
                    }

                    JObject joData = jaDataArray[0] as JObject;
                    Dictionary<string, object> dicData = new Dictionary<string, object>();

                    if (joData != null)
                    {
                        dicData = joData.ToObject<Dictionary<string, object>>();
                    }
                    string sPSID = null;
                    string fbGroupId = null;
                    if (dicData.ContainsKey(tb_meb_member.CN_GROUP_ID))
                    {
                        fbGroupId = dicData[tb_meb_member.CN_GROUP_ID].ToString();
                    }

                    var groupData = GetGroupSettings(fbGroupId);

                    var result = GetAppToken(groupData.app_id, groupData.client_secret, out FbToken resData);
                    if (result)
                    {
                        GetFBPagesID(dicData[BLWording.ASID].ToString(), groupData.page_id, resData.access_token, out sPSID);
                    }

                    // 更新會員資料
                    List<Command> lCmdUpdate = new List<Command>();

                    // 先查詢資料是否存在
                    tb_meb_member cMember = new tb_meb_member();
                    cMember.SetFullDirty();
                    tb_meb_member cMemberCon = new tb_meb_member() { group_user_id = dicData[BLWording.ASID].ToString(), group_id = fbGroupId };
                    Command cMemberSelect = Command.SetupSelectCmd(cMember, cMemberCon);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cMemberSelect);
                    tb_meb_member qdsMember = ai.RunQuerySingleORM<tb_meb_member>(cMemberSelect);
                    string asid = dicData[BLWording.ASID].ToString();
                    var group_id = fbGroupId;

                    // 更新
                    dicData.Remove(tb_grp_article.CN_GROUP_UID);
                    tb_meb_member mUpd = new tb_meb_member();
                    mUpd.message_user_id = sPSID;
                    mUpd.fb_pic = dicData[tb_meb_member.CN_FB_PIC].ToString();
                    List<WhereNode> lswnMain = new List<WhereNode>();
                    lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), asid));
                    lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_id));

                    lCmdUpdate.Add(Command.SetupUpdateCmd(mUpd, new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMain.ToArray())));

                    ai = ArsenalDBMgr.GetInst(lCmdUpdate[0], GetDefaultSystemColumnInfo());
                    ai.RunEditCmds(lCmdUpdate);
                    sMsg = GetLastErrorCode(lCmdUpdate);

                    if (sMsg != null)
                    {
                        break;
                    }

                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    crmRes.param.Add("psid", sPSID);
                }
                while (false);
            }
            catch (Exception ex)
            {
                sMsg = $"{nameof(RefreshMemberInfo)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. ex={ex.Message}";
#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif 
            }

            if (string.IsNullOrEmpty(sMsg))
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                crmRes = new CErrorResponseMessage(sMsg, i_crmInput);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            return crmRes;
        }
        public CResponseMessage GetAllMembers(CRequestMessage i_crmInput)
        {
            string sMsg;
            Command cRes = null;
            CResponseMessage crmRes = null;
            try
            {
                do
                {
                    Dictionary<string, object> dicObjCondition = GetQueryMasterFirstWhereData(i_crmInput);
                    List<string> lsMainColumns = EntityBase.GetAllColumnName(typeof(tb_meb_member));   // 取得所有欄位名稱
                    var lsBranch = ProjectHelper.GetUserGroup(i_crmInput);   // 取得可讀取社團資料的社團uid清單
                    var lsMember = new List<string>();
                    if (dicObjCondition.ContainsKey(tb_meb_member.CN_UID))
                    {
                        var aMember = dicObjCondition[tb_meb_member.CN_UID] as JArray;
                        foreach (var member in aMember)
                        {
                            lsMember.Add(member.ToString());
                        }
                        dicObjCondition.Remove(tb_meb_member.CN_UID);
                    }

                    Dictionary<string, string> dicCondition = new Dictionary<string, string>();
                    foreach (var condition in dicObjCondition)
                    {
                        dicCondition.Add(condition.Key, condition.Value.ToString());
                    }

                    QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
                    QueryJsonElement qjeMember = lBlocks.GetInst();
                    qjeMember.table = tb_meb_member.TABLENAME;
                    qjeMember.displaycols = lsMainColumns;
                    List<WhereNode> lswnMain = new List<WhereNode>();
                    if (lsMember.Any())
                    {
                        qjeMember.wherecols = new WhereNode(tb_meb_member.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_meb_member), lsMember.ToArray());
                    }
                    lBlocks.Add(qjeMember);

                    QueryJsonElement qjeGroup = lBlocks.GetInst();
                    qjeGroup.table = tb_grp_group.TABLENAME;
                    qjeGroup.jointable = qjeMember;
                    qjeGroup.jointype = QueryJsonElement.LEFT_JOIN;
                    qjeGroup.joincols = new Dictionary<string, string>() {
                             {  tb_grp_group.CN_FB_GROUP_ID,tb_meb_member.CN_GROUP_ID }};
                    if (dicObjCondition.ContainsKey(tb_meb_member.CN_GROUP_ID))
                    {
                        qjeGroup.wherecols = new WhereNode(tb_grp_group.CN_UID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_group), dicObjCondition[tb_meb_member.CN_GROUP_ID].ToString());
                    }
                    else
                    {
                        qjeGroup.wherecols = new WhereNode(tb_grp_group.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_grp_group), lsBranch.ToArray());
                    }
                    lBlocks.Add(qjeGroup);

                    sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cRes, GetDefaultSystemColumnInfo());
                    List<tb_meb_member> qds = ai.RunQueryList<tb_meb_member>(cRes);
                    sMsg = GetLastErrorCode(cRes);

                    if (sMsg != null)
                    {
                        break;
                    }
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    crmRes.param.Add("data", qds);
                }
                while (false);
            }
            catch (Exception ex)
            {
                sMsg = $"{nameof(GetAllMembers)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. ex={ex.Message}";
#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif 
            }
            return crmRes;
        }
        [Auth(false)]
        public CResponseMessage SetShoppingPoints(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            Command cRes = null;

            try
            {
                do
                {
                    sMsg = getCommonParameter(i_crmInput, BLWording.UPD_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;
                    }
                    JObject joData = jaDataArray[0] as JObject;

                    Dictionary<string, object> dicData = joData[BLWording.WHEREDATA].ToObject<Dictionary<string, object>>();


                    tb_meb_member cMember = new tb_meb_member();
                    cMember.SetDirty(tb_meb_member.CN_UID);
                    tb_meb_member cCon = new tb_meb_member()
                    {
                        group_user_id = dicData[tb_meb_member.CN_GROUP_USER_ID].ToString(),
                        group_id = dicData[tb_meb_member.CN_GROUP_ID].ToString()
                    };
                    Command cSelect = Command.SetupSelectCmd(cMember, cCon);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cSelect);
                    List<tb_meb_member> qdsMember = ai.RunQueryList<tb_meb_member>(cSelect);

                    List<Command> lCmdUpdate = new List<Command>();
                    string sNewArticleUid = Guid.NewGuid().ToString();

                    tb_meb_shopping_points_record mNew = new tb_meb_shopping_points_record() { };
                    mNew.uid = sNewArticleUid;
                    mNew.member_uid = qdsMember[0].uid;
                    mNew.amount = 30;
                    mNew.memo = "首登";
                    lCmdUpdate.Add(Command.SetupInsertCmd(mNew));

                    lCmdUpdate.Add(Command.SetupUpdateCmd(new tb_meb_member()
                    {
                        shopping_account = 30
                    }
                    , new tb_meb_member() { uid = qdsMember[0].uid }));

                    ai = ArsenalDBMgr.GetInst(lCmdUpdate[0], GetDefaultSystemColumnInfo());
                    ai.RunEditCmds(lCmdUpdate);
                    sMsg = GetLastErrorCode(lCmdUpdate);

                    if (sMsg != null)
                    {
                        break;
                    }
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(SetShoppingPoints)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }
        class ShoppingPointsModel : tb_meb_shopping_points_record
        {
            public string name { get; set; }
        }
        [Auth(false)]
        public CResponseMessage GetShoppingPoints(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            Command cRes = null;

            try
            {
                do
                {
                    Dictionary<string, object> dicObjCondition = GetQueryMasterFirstWhereData(i_crmInput);
                    string[] aMember = null;
                    string group_user_id = null;
                    string group_id = null;
                    if (dicObjCondition.ContainsKey(tb_meb_shopping_points_record.CN_MEMBER_UID))
                    {
                        var jaMember = dicObjCondition[tb_meb_shopping_points_record.CN_MEMBER_UID] as JArray;
                        aMember = jaMember.Select(x => x.ToString()).ToArray();
                    }
                    else if (dicObjCondition.ContainsKey(tb_meb_member.CN_GROUP_USER_ID))
                    {
                        group_user_id = dicObjCondition[tb_meb_member.CN_GROUP_USER_ID].ToString();
                        group_id = dicObjCondition[tb_meb_member.CN_GROUP_ID].ToString();
                    }
                    else
                    {
                        sMsg = "參數錯誤";
                        break;
                    }
                    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_SHOPPING_ACCOUNT,
                    };
                    if (aMember != null)
                    {
                        qjeMember.wherecols = new WhereNode(tb_meb_member.CN_UID, WhereNode.EColumnOperation.EOT_IN, typeof(tb_meb_member), aMember);
                    }
                    else if (group_user_id != null && group_id != null)
                    {
                        List<WhereNode> lswnMember = new List<WhereNode>();
                        lswnMember.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_user_id));
                        lswnMember.Add(new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_id));
                        qjeMember.wherecols = new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMember.ToArray());
                    }
                    lBlocks.Add(qjeMember);

                    sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cRes, GetDefaultSystemColumnInfo());
                    List<tb_meb_member> qds = ai.RunQueryList<tb_meb_member>(cRes);

                    sMsg = GetLastErrorCode(cRes);

                    if (sMsg != null)
                    {
                        break;
                    }
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    crmRes.param.Add("data", qds);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(GetShoppingPoints)} unknwon exception. Call from).";
#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif
            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }
        public CResponseMessage UpdateShoppingPoints(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            Command cRes = null;

            try
            {
                do
                {
                    sMsg = getCommonParameter(i_crmInput, BLWording.UPD_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;
                    }
                    JObject joData = jaDataArray[0] as JObject;

                    Dictionary<string, object> dicData = joData[BLWording.WHEREDATA].ToObject<Dictionary<string, object>>();
                    string memberUid = dicData[tb_meb_member.CN_UID].ToString();
                    int type = Convert.ToInt32(dicData["type"]);
                    int amount = type == 0 ? Convert.ToInt32(dicData[tb_meb_shopping_points_record.CN_AMOUNT]) : -Convert.ToInt32(dicData[tb_meb_shopping_points_record.CN_AMOUNT]);
                    string memo = dicData[tb_meb_shopping_points_record.CN_MEMO].ToString();

                    tb_meb_member cMember = new tb_meb_member();
                    cMember.SetDirty(tb_meb_member.CN_SHOPPING_ACCOUNT);
                    tb_meb_member cCon = new tb_meb_member()
                    {
                        uid = memberUid
                    };
                    Command cSelect = Command.SetupSelectCmd(cMember, cCon);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cSelect);
                    List<tb_meb_member> qdsMember = ai.RunQueryList<tb_meb_member>(cSelect);

                    List<Command> lCmdUpdate = new List<Command>();
                    string sNewArticleUid = Guid.NewGuid().ToString();

                    tb_meb_shopping_points_record mNew = new tb_meb_shopping_points_record() { };
                    mNew.uid = sNewArticleUid;
                    mNew.member_uid = memberUid;
                    mNew.amount = amount;
                    mNew.memo = string.IsNullOrEmpty(memo) ? null : memo;
                    lCmdUpdate.Add(Command.SetupInsertCmd(mNew));
                    // 更新member shopping_account
                    if (qdsMember[0].shopping_account + amount < 0)
                    {
                        sMsg = "購物金不得小於0";
                        break;
                    }
                    lCmdUpdate.Add(Command.SetupUpdateCmd(new tb_meb_member()
                    {
                        shopping_account = qdsMember[0].shopping_account + amount
                    }
                    , new tb_meb_member() { uid = memberUid }));

                    ai = ArsenalDBMgr.GetInst(lCmdUpdate[0], GetDefaultSystemColumnInfo());
                    ai.RunEditCmds(lCmdUpdate);
                    sMsg = GetLastErrorCode(lCmdUpdate);

                    if (sMsg != null)
                    {
                        break;
                    }
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(UpdateShoppingPoints)} unknwon exception. Call from).";
#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif
            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }
        public CResponseMessage ResetReturnCount(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            try
            {
                do
                {
                    tb_meb_member dicData = new tb_meb_member();

                    if (i_crmInput != null && i_crmInput.param != null && i_crmInput.param.ContainsKey(BLWording.UPD_MASTER))
                    {
                        JArray joData = i_crmInput.param[BLWording.UPD_MASTER] as JArray;

                        if (joData.Any())
                        {
                            dicData = joData[0][BLWording.WHEREDATA].ToObject<tb_meb_member>();
                        }
                    }


                    Command cCmd = Command.SetupUpdateCmd(new tb_meb_member()
                    {
                        return_count = 0
                    }
                    , new tb_meb_member() { uid = dicData.uid });

                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cCmd, GetDefaultSystemColumnInfo());
                    ai.RunEditSingleCmd(cCmd);
                    string sErrorCode = GetLastErrorCode(cCmd);

                    if (sErrorCode != null)
                    {
                        sMsg = sErrorCode;
                    }

                    if (sMsg != null)
                    {
                        break;
                    }
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(ResetReturnCount)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }
        [Auth(false)]
        public CResponseMessage VerifyFirebaseToken(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;
                    }

                    JObject joData = jaDataArray[0][BLWording.WHEREDATA] as JObject;
                    Dictionary<string, object> dicData = new Dictionary<string, object>();

                    if (joData != null)
                    {
                        dicData = joData.ToObject<Dictionary<string, object>>();
                    }
                    string firebaseToken = dicData[tb_meb_member.CN_FIREBASE_TOKEN].ToString();
                    string group_id = dicData[tb_meb_member.CN_GROUP_ID].ToString();
                    string asid = dicData[tb_meb_member.CN_GROUP_USER_ID].ToString();

                    // 查詢Token
                    tb_meb_member cMember = new tb_meb_member();
                    cMember.SetFullDirty();
                    tb_meb_member cMemberCon = new tb_meb_member() { group_user_id = asid, group_id = group_id };
                    Command cMemberSelect = Command.SetupSelectCmd(cMember, cMemberCon);
                    ArsenalInterface ai = ArsenalDBMgr.GetInst(cMemberSelect);
                    tb_meb_member qdsMember = ai.RunQuerySingleORM<tb_meb_member>(cMemberSelect);

                    // 更新會員資料
                    List<Command> lCmdUpdate = new List<Command>();

                    if (qdsMember.firebase_token == null || firebaseToken != qdsMember.firebase_token)
                    {
                        // 更新
                        tb_meb_member mUpd = new tb_meb_member();
                        mUpd.firebase_token = firebaseToken;
                        List<WhereNode> lswnMain = new List<WhereNode>();
                        lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_USER_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), asid));
                        lswnMain.Add(new WhereNode(tb_meb_member.CN_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_meb_member), group_id));

                        lCmdUpdate.Add(Command.SetupUpdateCmd(mUpd, new WhereNode(WhereNode.ENodeOperation.ENO_AND, lswnMain.ToArray())));
                        ai = ArsenalDBMgr.GetInst(lCmdUpdate[0], GetDefaultSystemColumnInfo());
                        ai.RunEditCmds(lCmdUpdate);
                        string sErrorCode = GetLastErrorCode(lCmdUpdate);

                        if (sErrorCode != null)
                        {
                            sMsg = sErrorCode;
                        }

                        if (sMsg != null)
                        {
                            sMsg = "已偵測裝置變更";
                        }
                    }



                    crmRes = new CSuccessResponseMessage(sMsg, i_crmInput);
                }
                while (false);
            }
            catch (Exception ex)
            {
                sMsg = $"{nameof(VerifyFirebaseToken)} unknwon exception. i_crmInput={JsonConvert.SerializeObject(i_crmInput)}. ex={ex.Message}";
#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif 
            }

            if (string.IsNullOrEmpty(sMsg))
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                crmRes = new CErrorResponseMessage(sMsg, i_crmInput);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            return crmRes;
        }
        protected class tokenModel
        {
            public string group_id { get; set; }
            public string code { get; set; }
            public string redirect_uri { get; set; }
            public string access_token { get; set; }
        }
        [Auth(false)]
        public CResponseMessage GetAccessToken(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            try
            {
                do
                {
                    tokenModel dicData = new tokenModel();
                    tokenModel rawResult = null;
                    if (i_crmInput != null && i_crmInput.param != null && i_crmInput.param.ContainsKey(BLWording.UPD_MASTER))
                    {
                        JArray joData = i_crmInput.param[BLWording.UPD_MASTER] as JArray;

                        if (joData.Any())
                        {
                            dicData = joData[0][BLWording.WHEREDATA].ToObject<tokenModel>();
                        }
                    }

                    var groupData = GetGroupSettings(dicData.group_id);

                    string uri = string.Format("https://graph.facebook.com/v3.2/oauth/access_token?client_id={0}&redirect_uri={1}&code={2}&client_secret={3}", groupData.app_id, dicData.redirect_uri, dicData.code, groupData.client_secret);
                    APIHelper.BaseGet(uri, null, new Dictionary<string, string>(), out HttpResponseMessage responseMessage);
                    if (responseMessage.IsSuccessStatusCode)
                    {
                        rawResult = JsonConvert.DeserializeObject<tokenModel>(responseMessage.Content.ReadAsStringAsync().Result);
                        if (string.IsNullOrEmpty(rawResult.access_token))
                        {
                            sMsg = "獲取token失敗";
                        }
                    }

                    if (sMsg != null)
                    {
                        break;
                    }
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                    crmRes.param.Add("access_token", rawResult.access_token);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(GetAccessToken)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }
        protected class checkedTokenModel
        {
            public Data data { get; set; }
            public class Data
            {
                public string user_id { get; set; }
                public string app_id { get; set; }
                public bool is_valid { get; set; }
            }
        }
        [Auth(false)]
        public CResponseMessage CheckAccessToken(CRequestMessage i_crmInput)
        {
            CResponseMessage crmRes = null;
            string sMsg = null;
            try
            {
                do
                {
                    tokenModel dicData = new tokenModel();
                    checkedTokenModel rawResult = null;
                    if (i_crmInput != null && i_crmInput.param != null && i_crmInput.param.ContainsKey(BLWording.UPD_MASTER))
                    {
                        JArray joData = i_crmInput.param[BLWording.UPD_MASTER] as JArray;

                        if (joData.Any())
                        {
                            dicData = joData[0][BLWording.WHEREDATA].ToObject<tokenModel>();
                        }
                    }
                    var groupData = GetGroupSettings(dicData.group_id);
                    var result = GetAppToken(groupData.app_id, groupData.client_secret, out FbToken responseData);

                    string uri = string.Format("https://graph.facebook.com/debug_token?input_token={0}&access_token={1}", dicData.access_token, responseData.access_token);
                    APIHelper.BaseGet(uri, null, new Dictionary<string, string>(), out HttpResponseMessage responseMessage);
                    if (responseMessage.IsSuccessStatusCode)
                    {
                        rawResult = JsonConvert.DeserializeObject<checkedTokenModel>(responseMessage.Content.ReadAsStringAsync().Result);
                        if (!rawResult.data.is_valid)
                        {
                            sMsg = "驗證token失敗";
                            break;
                        }
                    }
                    else
                    {
                        sMsg = "驗證token失敗";
                        break;
                    }

                    if (sMsg != null)
                    {
                        break;
                    }
                    crmRes = new CSuccessResponseMessage(null, i_crmInput);
                }
                while (false);
            }
            catch (Exception ex)
            {
                LogHelper.DBLog(Util.GetLastExceptionMsg(ex));
                sMsg = $"{nameof(GetAccessToken)} unknwon exception. Call from).";

#if DEBUG
                System.Diagnostics.Debug.WriteLine(sMsg);
#endif

            }

            if (sMsg != null)
            {
                crmRes = new CErrorResponseMessage(sMsg);
                Logger.Error(JsonConvert.SerializeObject(i_crmInput));
                Logger.Error(JsonConvert.SerializeObject(crmRes));
            }
            else
            {
                //Logger.Info(JsonConvert.SerializeObject(i_crmInput));
                //Logger.Info(JsonConvert.SerializeObject(crmRes));
            }

            return crmRes;
        }

        public bool getPrivacy(string group_id,out string privacy)
        {
            var result = false;

            privacy = null;
            string sMsg = null;

            QueryJsonElementCollection lBlocks = new QueryJsonElementCollection();
            QueryJsonElement qjeGroups = lBlocks.GetInst();
            qjeGroups.table = tb_grp_group.TABLENAME;
            qjeGroups.wherecols = new WhereNode(tb_grp_group.CN_FB_GROUP_ID, WhereNode.EColumnOperation.EOT_EQ, typeof(tb_grp_group2user), group_id);
            lBlocks.Add(qjeGroups);

            QueryJsonElement qjeGroupUser = lBlocks.GetInst();
            qjeGroupUser.table = tb_grp_group2user.TABLENAME;
            qjeGroupUser.jointable = qjeGroups;
            qjeGroupUser.displaycols = new List<string>() { tb_grp_group2user.CN_USER_TOKEN };
            qjeGroupUser.jointype = QueryJsonElement.LEFT_JOIN;
            qjeGroupUser.joincols = new Dictionary<string, string>() {
                             {  tb_grp_group2user.CN_GROUP_UID,tb_grp_group.CN_UID }};


            lBlocks.Add(qjeGroupUser);

            Command cRes = null;
            sMsg = MakeSelectJoinByBlocks(lBlocks, out cRes);
            ArsenalInterface ai = ArsenalDBMgr.GetInst(cRes);
            tb_grp_group2user qdsGroups = ai.RunQuerySingleORM<tb_grp_group2user>(cRes);

            if (qdsGroups != null)
            {

              var groupsInfo =   GetPrivacy(group_id, qdsGroups.user_token);
                privacy = groupsInfo.privacy;
                result = true;
            }

            return result;


        }

        public Groups GetPrivacy(string group_id, string access_token)
        {
            Groups GroupInfo = null;
            do
            {
                try
                {
                    // 送出資料
                    string uri = $"https://graph.facebook.com/v8.0/{group_id}?";
                    var dicData = new Dictionary<string, string>()
                    {
                        { "access_token",access_token},
                        { "fields","privacy"}
                    };
                    APIHelper.BaseGet(uri, null, dicData, out HttpResponseMessage responseMessage);
                    if (responseMessage.IsSuccessStatusCode)
                    {
                        var fb_error = GetFbApiError(responseMessage);

                        if (!string.IsNullOrWhiteSpace(fb_error))
                        {
                            Logger.Error($"{nameof(GetPrivacy)} FB API response error message: {fb_error} ");
                            break;
                        }
                        GroupInfo = JsonConvert.DeserializeObject<Groups>(responseMessage.Content.ReadAsStringAsync().Result);
                    }
                }
                catch (Exception ex)
                {

                    throw ex;
                }
            } while (false);
            return GroupInfo;

        }




        private tb_grp_group GetGroupSettings(string group_id)
        {
            // 獲得該社團的token, app id, client secret
            tb_grp_group cGroup = new tb_grp_group();
            cGroup.SetDirty(tb_grp_group.CN_APP_ID, tb_grp_group.CN_PAGE_ID, tb_grp_group.CN_CLIENT_SECRET);
            tb_grp_group cCon = new tb_grp_group() { fb_group_id = group_id };
            Command cSelect = Command.SetupSelectCmd(cGroup, cCon);
            ArsenalInterface ai2 = ArsenalDBMgr.GetInst(cSelect);
            tb_grp_group qds2 = ai2.RunQuerySingleORM<tb_grp_group>(cSelect);

            return qds2;
        }







    }
}