feature: report msg

opencv-motion-detect/evmlmotion.cpp

@@ -761,6 +761,7 @@ protected:
 
         auto start = chrono::system_clock::now();
         auto pktCntLast = pktCnt;
+        bool bStatsSent = false;
         while(true) {
             if(checkStop() == true) {
                 bStopSig = true;
@@ -807,6 +808,7 @@ protected:
                 data["msg"] = msg;
                 data["modId"] = selfId;
                 data["type"] = EV_MSG_META_TYPE_REPORT;
+                data["catId"] = EV_MSG_REPORT_CATID_AVWRITEPIPE;
                 data["level"] = EV_MSG_META_VALUE_REPORT_LEVEL_ERROR;
                 data["time"] = chrono::duration_cast<chrono::seconds>(chrono::system_clock::now().time_since_epoch()).count();
                 data["status"] = "active";
@@ -814,6 +816,24 @@ protected:
                 meta["value"] = EV_MSG_META_VALUE_REPORT_LEVEL_ERROR;
                 z_send(pDaemon, "evcloudsvc", meta.dump(), data.dump());
                 spdlog::error(msg);
+            }else{
+                if(!bStatsSent) {
+                    bStatsSent = true;
+                    string msg = fmt::format("evmlmotion {} successfully decode packet", selfId);
+                    json meta;
+                    json data;
+                    data["msg"] = msg;
+                    data["modId"] = selfId;
+                    data["type"] = EV_MSG_META_TYPE_REPORT;
+                    data["catId"] = EV_MSG_REPORT_CATID_AVWRITEPIPE;
+                    data["level"] = EV_MSG_META_VALUE_REPORT_LEVEL_INFO;
+                    data["time"] = chrono::duration_cast<chrono::seconds>(chrono::system_clock::now().time_since_epoch()).count();
+                    data["status"] = "recover";
+                    meta["type"] = EV_MSG_META_TYPE_REPORT;
+                    meta["value"] = EV_MSG_META_VALUE_REPORT_LEVEL_INFO;
+                    z_send(pDaemon, "evcloudsvc", meta.dump(), data.dump());
+                    spdlog::info(msg);
+                }
             }
 
             if((pktCnt  - pktCntLast ) == 18) {

opencv-motion-detect/evpuller.cpp

@@ -339,7 +339,7 @@ protected:
             data["time"] = chrono::duration_cast<chrono::seconds>(chrono::system_clock::now().time_since_epoch()).count();
             data["status"] = "recover";
             meta["type"] = EV_MSG_META_TYPE_REPORT;
-            meta["value"] = EV_MSG_META_VALUE_REPORT_LEVEL_FATAL;
+            meta["value"] = EV_MSG_META_VALUE_REPORT_LEVEL_INFO;
             z_send(pDaemon, "evcloudsvc", meta.dump(), data.dump());
             spdlog::info(msg);
         }

opencv-motion-detect/evpusher.cpp

@@ -309,12 +309,13 @@ private:
         while(ret < 0)
         {
             if(cnt > 3) {
-                string msg = fmt::format("evpusher {} failed to write stream \"{}\": {}, {}", selfId, urlOut, ret, av_err2str(ret));
+                string msg = fmt::format("evpusher {} failed to write output header \"{}\": {}, {}", selfId, urlOut, ret, av_err2str(ret));
                 json meta;
                 json data;
                 data["msg"] = msg;
                 data["modId"] = selfId;
                 data["type"] = EV_MSG_META_TYPE_REPORT;
+                data["catId"] = EV_MSG_REPORT_CATID_AVWRITEHEADER;
                 data["level"] = EV_MSG_META_VALUE_REPORT_LEVEL_FATAL;
                 data["time"] = chrono::duration_cast<chrono::seconds>(chrono::system_clock::now().time_since_epoch()).count();
                 data["status"] = "active";
@@ -395,6 +396,7 @@ private:
                     data["msg"] = msg;
                     data["modId"] = selfId;
                     data["type"] = EV_MSG_META_TYPE_REPORT;
+                    data["catId"] = EV_MSG_REPORT_CATID_AVOPENOUTPUT;
                     data["level"] = EV_MSG_META_VALUE_REPORT_LEVEL_FATAL;
                     data["time"] = chrono::duration_cast<chrono::seconds>(chrono::system_clock::now().time_since_epoch()).count();
                     data["status"] = "active";
@@ -403,6 +405,21 @@ private:
                     z_send(pDaemon, "evcloudsvc", meta.dump(), data.dump());
                     spdlog::error(msg);
                     exit(1);
+                }else{
+                    string msg = fmt::format("evpusher {} successfully open output \"{}\"", selfId, urlOut);
+                    json meta;
+                    json data;
+                    data["msg"] = msg;
+                    data["modId"] = selfId;
+                    data["type"] = EV_MSG_META_TYPE_REPORT;
+                    data["catId"] = EV_MSG_REPORT_CATID_AVOPENOUTPUT;
+                    data["level"] = EV_MSG_META_VALUE_REPORT_LEVEL_INFO;
+                    data["time"] = chrono::duration_cast<chrono::seconds>(chrono::system_clock::now().time_since_epoch()).count();
+                    data["status"] = "recover";
+                    meta["type"] = EV_MSG_META_TYPE_REPORT;
+                    meta["value"] = EV_MSG_META_VALUE_REPORT_LEVEL_INFO;
+                    z_send(pDaemon, "evcloudsvc", meta.dump(), data.dump());
+                    spdlog::info(msg);
                 }
             }
 
@@ -417,6 +434,20 @@ private:
         }
 
 
+        string msg = fmt::format("evpusher {} successfullywrite output header \"{}\": {}, {}", selfId, urlOut, ret, av_err2str(ret));
+        json meta;
+        json data;
+        data["msg"] = msg;
+        data["modId"] = selfId;
+        data["type"] = EV_MSG_META_TYPE_REPORT;
+        data["catId"] = EV_MSG_REPORT_CATID_AVWRITEHEADER;
+        data["level"] = EV_MSG_META_VALUE_REPORT_LEVEL_INFO;
+        data["time"] = chrono::duration_cast<chrono::seconds>(chrono::system_clock::now().time_since_epoch()).count();
+        data["status"] = "recover";
+        meta["type"] = EV_MSG_META_TYPE_REPORT;
+        meta["value"] = EV_MSG_META_VALUE_REPORT_LEVEL_INFO;
+        z_send(pDaemon, "evcloudsvc", meta.dump(), data.dump());
+    
         return ret;
     }
 

opencv-motion-detect/inc/zmqhelper.hpp

@@ -38,6 +38,7 @@ namespace zmqhelper {
 
 #define EV_MSG_META_TYPE_REPORT "report"
 #define EV_MSG_REPORT_CATID_AVOPENINPUT "AV_OPENINPUT"
+#define EV_MSG_REPORT_CATID_AVOPENOUTPUT "AV_OPENOUTPUT"
 #define EV_MSG_REPORT_CATID_AVWRITEHEADER "AV_WRITEHEADER"
 #define EV_MSG_REPORT_CATID_AVEOF "AV_EOF"
 #define EV_MSG_REPORT_CATID_AVWRITEPIPE "AV_WRITEPIPE"