From 5b8b7dd6f6fe94cdc5903fcb1fb2cdaffe57db78 Mon Sep 17 00:00:00 2001
From: pansen <pansen626@sina.com>
Date: 星期一, 15 四月 2019 14:45:16 +0800
Subject: [PATCH] 添加注释

---
 QiaoJiaSystem/DataManagerServer/http_configserver.cpp |   30 ++++++++-
 syncDBTool/ErlangDbTool.h                             |   19 ++++-
 QiaoJiaSystem/DataManagerServer/http_configserver.h   |   40 +++++++++++++
 syncDBTool/ErlangDbTool.cpp                           |   53 +++++++++--------
 4 files changed, 108 insertions(+), 34 deletions(-)

diff --git a/QiaoJiaSystem/DataManagerServer/http_configserver.cpp b/QiaoJiaSystem/DataManagerServer/http_configserver.cpp
index d5dd971..e6b8e72 100644
--- a/QiaoJiaSystem/DataManagerServer/http_configserver.cpp
+++ b/QiaoJiaSystem/DataManagerServer/http_configserver.cpp
@@ -1761,6 +1761,13 @@
     return out;
 }
 
+//{
+//	"cookie": "abc",                        //闆嗙兢cookie
+//	"fatherNodeName": "main@192.168.1.186", //寮曞鑺傜偣鍚嶇О,娣诲姞寮曞鑺傜偣鏃惰鍊间负" "(鍐呬负绌烘牸)
+//	"culID" : "uuid",                       //闆嗙兢id
+//	"culName" : "name",                     //闆嗙兢鍚嶇О
+//	"devID" : "uuid"                        //璁惧id
+//}
 std::string devHttpServer_c::addNode(std::string ip, unsigned int port, std::string content, PResponse &response) {
     DBG("ip:" << ip << "; port:" << port);
     DBG("content: " << content);
@@ -1773,25 +1780,32 @@
         //#todo nodes have counter?
         //#todo nodeName Automatic generated?
         //#todo devId+num
+        // 鐢熸垚鑺傜偣id - uuid
         std::string uuid = GetUUId::getUUID();
 
+        // 鑾峰彇褰撳墠鏈哄櫒ip
         unsigned char ip_old[15] = {0};
         std::string str_netIfName = appConfig.getStringProperty("netIfName");
         GetIpAddress(str_netIfName.c_str(), ip_old);
         std::string str_ip((char *) ip_old);
+        // 鑺傜偣鍚嶇О
         std::string nodeName = uuid.append("@" + str_ip);
 
         std::string cookie = value["cookie"].asString();
+        // 寮曞鑺傜偣
         std::string FatherNodeName = value["fatherNodeName"].asString();
 
         //#todo ClusterID ClusterName
+        // 闆嗙兢id
         std::string clusterID = value["culID"].asString();
+        // 涓虹┖鍒欑敓鎴�,鍚﹀垯鐩存帴浣跨敤
         clusterID = clusterID.size() > 0 ? clusterID : GetUUId::getUUID();
         std::string clusterName = value["culName"].asString();
+
         std::string devID = value["devID"].asString();
         std::string devName = value["devName"].asString();
 
-
+        // erlang鑺傜偣淇濆瓨璺緞/opt/erlang/${uuid}
         std::string path = std::string("/opt/erlang/").append(nodeName.substr(0, nodeName.find("@")));
         if (erlangDbTool != nullptr) {
             //gaunbi node
@@ -1803,6 +1817,7 @@
 
         if (cookie.size() > 0 && (clusterID.size() > 0 || clusterName.size() > 0)) {
 //            erlangDbTool = new ErlangTool::ErlangDbTool(path, nodeName, cookie);
+            // #todo 杩涚▼鍚� -> get from argv[0]
             string str_tmp = "DataWebserver";
             erlangDbTool = new ErlangTool::ErlangDbTool(path, nodeName, cookie, clusterID, clusterName, str_tmp);
             bool ret = erlangDbTool->initErlang();
@@ -1811,6 +1826,7 @@
             ret = erlangDbTool->startNodeDb(FatherNodeName, devID);
 
             if (ret) {
+                //濡傛灉鎴愬姛鍒欐洿鏂伴厤缃枃浠�
                 appConfig.setStringProperty("erlNode", nodeName);
                 appConfig.setStringProperty("erlCookie", cookie);
                 appConfig.setStringProperty("erlPath", path);
@@ -1823,6 +1839,7 @@
                 runAllApp();
 //                sleep(4);
             } else {
+                // 鍚﹀垯鍒欑疆绌洪厤缃枃浠�
                 appConfig.setStringProperty("erlNode", "");
                 appConfig.setStringProperty("erlCookie", "");
                 appConfig.setStringProperty("erlPath", "");
@@ -1855,6 +1872,7 @@
 
         ret = erlangDbTool->removeNode();
 
+        // 缃┖閰嶇疆鏂囦欢
         appConfig.setStringProperty("erlNode", "");
         appConfig.setStringProperty("erlCookie", "");
         appConfig.setStringProperty("erlPath", "");
@@ -1972,15 +1990,20 @@
         std::string Uuid = value["uuid"].asString();
         std::string TableType = value["TableType"].asString();
         std::string TableName = value["TableName"].asString();
+        //  闆嗙兢鍐呭悓姝�
         int SyncType = atoi(value["SyncType"].asCString());
         std::string BwType = value["BwType"].asString();
         std::string StartTime = value["StartTime"].asString();
         std::string EndTime = value["EndTime"].asString();
 
+        // 鏄惁涓婁紶
         std::string UploadFlag = value["IsSync"].asString();
         UploadFlag = UploadFlag.empty() ? "0" : UploadFlag;
+
+        // 搴曞簱闃堝��
         std::string CmpThreshold = value["threshold"].asString();
         CmpThreshold = CmpThreshold.empty() ? "60" : CmpThreshold;
+        // 鏄惁鍚敤
         std::string Enabled = value["enabled"].asString();
         Enabled = Enabled.empty() ? "1" : Enabled;
 
@@ -2012,9 +2035,7 @@
         fieldValues.insert(std::make_pair("bwType", BwType));
         fieldValues.insert(std::make_pair("startTime", StartTime));
         fieldValues.insert(std::make_pair("endTime", EndTime));
-//        #todo
         fieldValues.insert(std::make_pair("create_by", createBy));
-
         fieldValues.insert(std::make_pair("uploadFlag", UploadFlag));
         fieldValues.insert(std::make_pair("cmpThreshold", CmpThreshold));
         fieldValues.insert(std::make_pair("enabled", Enabled));
@@ -2039,7 +2060,6 @@
             return "";
         }
 
-
 ////            #todo 涓婁紶銆備粎榛戝悕鍗曘��
 ////            #TODO 鏍规嵁createBy鍒ゆ柇鏄惁闇�瑕佷笂浼�
 //        if (createBy == "analyDev" && BwType == "1") {
@@ -2050,7 +2070,7 @@
 //                                      Enabled);
 //        }
 
-
+        // send message to other CNode
         erlangDbTool->sendMessage();
         std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
         return str_result;
diff --git a/QiaoJiaSystem/DataManagerServer/http_configserver.h b/QiaoJiaSystem/DataManagerServer/http_configserver.h
index cec426b..00fff1c 100644
--- a/QiaoJiaSystem/DataManagerServer/http_configserver.h
+++ b/QiaoJiaSystem/DataManagerServer/http_configserver.h
@@ -78,16 +78,56 @@
     std::string netconfig_show(std::string ip, unsigned int port, std::string content, PResponse &response);
 
 
+    /***
+     * 鍒涘缓闆嗙兢鑺傜偣
+     * @param ip
+     * @param port
+     * @param content
+     * @param response
+     * @return
+     */
     std::string addNode(std::string ip, unsigned int port, std::string content, PResponse &response);
 
+    /***
+     * 鏌ヨ鍦ㄧ嚎鑺傜偣
+     * @param ip
+     * @param port
+     * @param content
+     * @param response
+     * @return
+     */
     std::string searchNode(std::string ip, unsigned int port, std::string content, PResponse &response);
 
     std::string modifyCluName(std::string ip, unsigned int port, std::string content, PResponse &response);
 
+    /***
+     * 閫�鍑洪泦缇�
+     * @param ip
+     * @param port
+     * @param content
+     * @param response
+     * @return
+     */
     std::string removeNode(std::string ip, unsigned int port, std::string content, PResponse &response);
 
+    /**
+     *鍒涘缓鏁版嵁搴曞簱
+     * @param ip
+     * @param port
+     * @param content
+     * @param response
+     * @return
+     */
     std::string createDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
 
+    /**
+     *
+     * @param ip
+     * @param port
+     * @param content
+     * @param response
+     * @return
+     */
     std::string deleteDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
 
     std::string updateDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
diff --git a/syncDBTool/ErlangDbTool.cpp b/syncDBTool/ErlangDbTool.cpp
index b3cdeea..173fd83 100755
--- a/syncDBTool/ErlangDbTool.cpp
+++ b/syncDBTool/ErlangDbTool.cpp
@@ -71,6 +71,7 @@
     return true;
 }
 
+// 妫�娴嬭繑鍥炵殑鏁版嵁鐨勬暟鎹被鍨�
 static int ErlangTool::checkETERMType(ETERM *elemen) {
     if (elemen == NULL) {
         return -1;
@@ -187,9 +188,10 @@
     g_syncDbFile.setDatabaseName(str_SyncDbFile.c_str());
     g_syncDbFile.open();
 
+    // c erlang init
     erl_init(NULL, 0);
+
     struct in_addr addr;
-    //#todo
     addr.s_addr = inet_addr("127.0.0.1");
 
     m_pName.append(std::to_string((int) getpid()));
@@ -198,6 +200,8 @@
     t_cNodeName.append("@127.0.0.1");
     m_cNodeName.swap(t_cNodeName);
     //m_pName
+    //int erl_connect_init(number, cookie, creation)int erl_connect_xinit(host, alive, node, addr, cookie, creation)
+    // https://cloud.tencent.com/developer/section/1123179
     if (erl_connect_xinit(const_cast<char *>(m_pName.c_str()), const_cast<char *>(m_pName.c_str()),
                           const_cast<char *>(m_cNodeName.c_str()), &addr,
                           const_cast<char *>(m_cookie.c_str()), 0) == -1) {
@@ -214,16 +218,20 @@
         ERR("m_nodeName is null ");
         return 3;
     }
+    // 鍒ゆ柇鑺傜偣鏄惁鍚姩
     m_ret = pingNode(m_nodeName, m_cookie);
     if (!m_ret) {
         if (dir_file_exists(m_path, true)) {
+            // 鍚姩erlang鑺傜偣鐨刡ash鍛戒护
             std::string cmd = std::string("cd " + m_path + " && erl -name " + m_nodeName + " -setcookie  "
                                           + m_cookie + " -mnesia dir '\"" + m_path +
                                           "\"' -detached -noshell");// >>log
             std::cout << cmd << std::endl;
             system(cmd.c_str());
             std::cout << m_ret << std::endl;
+            // 鍒ゆ柇鑺傜偣鏄惁鍚姩鎴愬姛
             m_ret = waitNode();
+//            erl_close_connection(m_fd);
             resetConn();
             return m_ret;
         } else {
@@ -264,7 +272,7 @@
     }
 
     ErlMessage emsg;    /* Incoming message */
-    //hanshu canshu
+    // 鎷兼帴鍑芥暟鍙傛暟
     ETERM *arrlist[5];
     arrlist[0] = erl_mk_atom(m_nodeName.c_str());
     arrlist[1] = erl_mk_atom(FatherNodeName.c_str());
@@ -282,6 +290,8 @@
         //erl_close_connection(m_fd);
 //                m_mutex.unlock();
         if (ret == ERL_MSG) {
+            // 娑堟伅瑙f瀽
+            // 娑堟伅浣撲负閾捐〃缁撴瀯
             std::map<std::string, std::string> t_results;
             ETERM *key, *value;
             ETERM *tuplep[6];
@@ -313,7 +323,7 @@
                     INFO("item is " << item.first << "  " << item.second);
                 }
             }
-        }//ret == ERL_MSG end
+        } //ret == ERL_MSG end
         else {
             ERR(" ret is " << ret);
 
@@ -329,18 +339,14 @@
 //            m_mutex.lock();
     m_ret = resetConn();
     if (!m_ret) {
-        //#todo error message
-        std::cout << __FILE__ << __FUNCTION__ << __LINE__ << " error " << m_ret << "  " << m_fd << std::endl;
+        ERR(" error " << m_ret << "  " << m_fd);
         return false;
     }
     int ret = -1;
     ErlMessage emsg;    /* Incoming message */
-    //hanshu canshu
-//            ETERM *arrlist[1];
-//            arrlist[0] = erl_mk_atom(m_nodeName.c_str());
+
     ETERM *list = erl_mk_empty_list();// (arrlist, 0);
 
-//            std::cout << __FILE__ << __FUNCTION__ <<__LINE__ << "  " << m_fd << std::endl;
     ret = erl_rpc_to(m_fd, "syncDB", "removeNode", list);
     if (ret == ERL_TICK) {
         ret = erl_rpc_from(m_fd, TIMEOUT, &emsg);
@@ -364,7 +370,7 @@
                     break;
                 }
                 default:
-                    printf("error add case todo \n\r");
+                    ERR("error add case todo \n\r");
             }
             auto it = t_results.find("atomic");
             if (t_results.size() > 0 && t_results.end() != it && it->second == "ok") {
@@ -471,9 +477,7 @@
     map_DevDataCache devDataCache;
     int ret = -1;
     ErlMessage emsg;    /* Incoming message */
-    //hanshu canshu
-//            ETERM *arrlist[0];
-//            arrlist[0] = erl_mk_atom(m_nodeName.c_str());
+
     ETERM *list = erl_mk_empty_list();//erl_mk_list(arrlist, 0);
 
     ret = erl_rpc_to(m_fd, "syncDB", "findAllNode", list);
@@ -534,7 +538,7 @@
                             erlangFreeEterm(3, key, value, tuplep[j]);
                         }
 //                            printf("\none list end\n\n\n\n");
-                        // #todo this is have a bug
+                        // #todo this is have a bug 鍐呭瓨娉勯湶?鎴栬�呭湴鍧�绌洪棿瓒婄晫?
 //                                device_info.create_by = "";
                         devDataCache.insert(std::make_pair(device_info.uuid, device_info));
                         erlangFreeEterm(1, tail_tuple);
@@ -1686,13 +1690,14 @@
 bool ErlangTool::ErlangDbTool::resetConn() {
     //#todo
     if (m_pName.size() <= 0) {
+        // 鏍规嵁褰撳墠鏃堕棿璁剧疆绉嶅瓙,绉掔骇
         srand(time(0));
+        // 鐢熸垚闅忔満鏁�
         m_loop = rand() % 1000;
 
         int ret = -1;
         erl_init(NULL, 0);
-//            m_loop %= 10;
-//            m_loop++;
+        // 鏍规嵁闅忔満鏁扮敓鎴恈鑺傜偣
         ret = erl_connect_init(m_loop, const_cast<char *>(m_cookie.c_str()), 0);
         DBG("node name is   " << m_loop);
         if (-1 == ret) {
@@ -1700,26 +1705,22 @@
             return false;
         }
 
-//            std::cout << __FILE__ << __FUNCTION__ <<__LINE__ << "  " << m_fd << std::endl;
+        // 鍏抽棴涓婃閾炬帴鐨勬枃浠舵弿杩扮 #TODO 绗竴娆″垱寤鸿妭鐐规湁姒傜巼鍑虹幇鐭椂闂村唴鏃犳硶鏌ヨ鐨刡ug
         erl_close_connection(m_fd);
-//            std::cout << __FILE__ << __FUNCTION__ <<__LINE__ << "  " << m_fd << std::endl;
         m_fd = erl_connect(const_cast<char *>(m_nodeName.c_str()));
-//            std::cout << __FILE__ << __FUNCTION__ <<__LINE__ << "  " << m_fd << std::endl;
         if (0 > m_fd) {
 //            erl_err_quit("erl_connect");
             return false;
         }
         return true;
     } else {
+        // 璁剧疆浜� mPName
         erl_close_connection(m_fd);
         m_fd = erl_connect(const_cast<char *>(m_nodeName.c_str()));
         if (0 > m_fd) {
-//            erl_err_quit("erl_connect");
-//            std::cout << __FILE__ << __FUNCTION__ <<__LINE__ << " error " << fd << std::endl;
             ERR("m_fd is   " << m_fd << " m_nodeName is" << m_nodeName);
             return false;
         }
-//        std::cout << __FILE__ << __FUNCTION__ <<__LINE__ << "  " << fd << std::endl;
         INFO("m_fd is   " << m_fd << " m_nodeName is" << m_nodeName);
         return true;
     }
@@ -1738,15 +1739,17 @@
             loop++;
         }
     }
-    std::cout << "start waitNode" << std::endl;
+    INFO("start waitNode");
     return m_ret;
 }
 
 void ErlangTool::ErlangDbTool::test(pthread_cond_t *t_pthcon, pthread_mutex_t *t_pthmut) {
     bool ret = setCNodeName();
     {
+        // 鐩戝惉socket鐨勭嚎绋�
         std::thread th1([&] {
             int res;
+            // 澶栭儴浼犲叆鐨勪俊鍙峰拰閿�
             pthread_cond_t *t_pthCon = t_pthcon;
             pthread_mutex_t *t_pthMut = t_pthmut;
 
@@ -1786,7 +1789,8 @@
                 } else if (got == ERL_ERROR) {
                     if ((fd = erl_accept(listen, &conn)) == ERL_ERROR)
                         erl_err_quit("erl_accept");
-                    INFO("Connected to " << conn.nodename);
+                    else
+                        INFO("Connected to " << conn.nodename);
                 } else {
 
                     if (emsg.type == ERL_REG_SEND) {
@@ -1803,6 +1807,7 @@
                             pthread_cond_signal(t_pthCon);
                             pthread_mutex_unlock(t_pthMut);
                             //call back func
+                            //#TODO 娑堟伅瑙f瀽
                         } else {
                             ERR("message not is  update");
                         }
diff --git a/syncDBTool/ErlangDbTool.h b/syncDBTool/ErlangDbTool.h
index 72cebcd..f738219 100755
--- a/syncDBTool/ErlangDbTool.h
+++ b/syncDBTool/ErlangDbTool.h
@@ -136,17 +136,18 @@
     private:
         void initCNode();
 
+        // 鍚慹rlang绔洿鎺ュ彂閫乻ql璇彞
         bool getExecSqlResult(const std::string &strSql);
 
     public:
-        //#todo setCNodeName
 
+        // 灏哻鑺傜偣鍚嶇О璁剧疆缁檈rlang浣垮叾鍙互鍦ㄦ帴鏀跺埌娑堟伅鏃�,鑳介�氱煡鍒版湰鑺傜偣
         bool setCNodeName();
 
+        // 鍚慹rlang鍙戦�佹秷鎭�, #TODO 鐩墠浠呭疄鐜颁簡淇″彿,寰呭疄鐜版秷鎭綋
         bool sendMessage();
 
-        //#todo sendMessage
-
+        // 璁剧疆鍖垮悕c鑺傜偣鎺ュ彈erlang鑺傜偣鍚慶鑺傜偣鍙戦�佺殑娑堟伅
         void test(pthread_cond_t *, pthread_mutex_t *);
 
         /***
@@ -174,7 +175,12 @@
          */
         bool removeNode();
 
-
+        /**
+         * 淇敼闆嗙兢鍚嶇О
+         * @param CluId
+         * @param CluName
+         * @return
+         */
         bool modifyCluName(std::string CluId, std::string CluName);
 
 
@@ -303,7 +309,7 @@
                                           std::string PerPicUrl, std::string PerFea);
 //    private:
         /***
-         * 閲嶆柊杩炴帴鑺傜偣
+         * 涓轰簡闃叉杩囬暱鏃堕棿杩炴帴琚叧闂�,涓诲姩閲嶆柊杩炴帴鑺傜偣
          * @return 杩炴帴鐘舵��
          */
         bool resetConn();
@@ -319,8 +325,11 @@
     private:
         //瀛樺偍璺緞
         std::string m_path;
+        // erlang 鑺傜偣鍚嶇О
         std::string m_nodeName;
+        // 绋嬪簭鍐呯殑c鑺傜偣鍚嶇О   杩涚▼鍚�+pid@127.0.0.1
         std::string m_cNodeName;
+        // 杩涚▼鍚�+pid?#TODO
         std::string m_pName;
         std::string m_cookie;
 

--
Gitblit v1.8.0