C# 实现视频监控系统(附源码)

　　去过工厂或者仓库的都知道，在工厂或仓库里面，会有很多不同的流水线，大部分的工厂或仓库，都会在不同流水线的不同工位旁边安装一台电脑，一方面便于工位上的师傅把产品的重要信息录入系统，便于公司系统数据采集分析。另一方面严谨的工厂或仓库也会在每个工位上安装摄像头，用于采集或监控流水线上工人的操(是)作（否）习（偷）惯（懒）。

　　好了，闲话少说，咱们直入主题吧！

　　本系统监控系统，主要核心是使用aforge.net提供的接口和插件（dll），感兴趣的朋友也可以去他们官网查看文档

　　talk is cheap,show me the code!

　　系统初始化时，首先检查工位的机台是否开启了摄像头，具体检测代码如下：

/// <summary>
/// 监控bind
/// </summary>
private void bind()
{
  try
  {
    filterinfocollection videodevices = new filterinfocollection(filtercategory.videoinputdevice);
    if (videodevices.count <= 0)
    {
      messagebox.show("请连接摄像头");
      return;
    }
    else
    {
      closecapturedevice();
      if (!directory.exists(path)) directory.createdirectory(path);
 
      videosource = new videocapturedevice(videodevices[0].monikerstring);
      videosource.videoresolution = videosource.videocapabilities[0];
      sourceplayer.videosource = videosource;
      sourceplayer.start();
    }
  }
  catch (exception ex)
  {
    messagebox.show(ex.message);
  }
}

　　好了，摄像头没问题，咱在检查网络是否正常（这事儿可以交给运维，当然也可以通过程序控制，具体校验网络代码比比皆是，此处忽略，如有兴趣的朋友可以在公众号call我一起探讨），至于为什么要校验网络，一部分是用于机台系统的数据采集，另一部分就是录制的视频文件不可能存储在工位机台上，不然流水线和工位足够多，岂不是一个工位一个几天的查看视频监控嘛！咱这都是智能化时代，录制的视频可以保存在本地，不过为了方便起见，需要定时清理，定时上传到服务器便于领导审查。视频上传到服务器一般用到最多的莫非两种情况，1.网络足够稳定，足够快的可以直接和服务器开个磁盘映射（共享目录），视频录制完后系统直接剪切到服务器保存即可。2.把不同时段录制的视频先存储到本地，然后单独开发个定时任务ftp定时上传即可。今天先跟大家分享下第一种方法，第二种方法也比较简单，有兴趣的朋友可以公众号call我一起探讨。

　　不知不觉又扯了一堆废话，都是实在人，直接上源码吧：

/// <summary>
/// 开启或者关闭程序后将多余文件copy到相应目录，并开启磁盘映射上传到共享目录
/// </summary>
private void copyfilestoserver()
{
  try
  {
    //遍历 当前pc文件夹外是否存在视频文件，如存在，移动到目标目录 
    string newpath = path + macaddresspath + @"-video\";
    if (!directory.exists(newpath)) directory.createdirectory(newpath);
    //将上一次最后一个视频文件转入目录
    var files = directory.getfiles(path, "*.wmv");
    foreach (var file in files)
    {
      fileinfo fi = new fileinfo(file);
      string filesname = file.split(new string[] { "\\" }, stringsplitoptions.removeemptyentries).lastordefault();
      fi.moveto(newpath + filesname);
    } 
  }
  catch (exception ex)
  {
    //todo:异常抛出
  }
  finally
  {
    uint state = 0;
    if (!directory.exists("z:"))
    {
      //计算机名
      string computername = system.net.dns.gethostname();
      //为网络共享目录添加磁盘映射 
      state = wnethelper.wnetaddconnection(computername + @"\" + networkuser, networkpwd, networkpath, "z:");
    }
    if (state.equals(0))
    {
      //本地磁盘视频文件copy到网络共享目录
      copyfolder(path + macaddresspath + @"-video\", zpath); 
    }
    else
    {
      wnethelper.winexec("net use * /delete /y", 0);
      throw new exception("添加网络驱动器错误，错误号：" + state.tostring());
    }
  }
}

　　其中copyfolder方法代码如下：

#region 通过共享网络磁盘映射的方式，讲文件copy到指定网盘
 /// <summary>
 /// 通过共享网络磁盘映射的方式，讲文件copy到指定网盘
 /// </summary>
 /// <param name="strfrompath"></param>
 /// <param name="strtopath"></param>
 public static void copyfolder(string strfrompath, string strtopath)
 {
   //如果源文件夹不存在，则创建
   if (!directory.exists(strfrompath))
   {
     directory.createdirectory(strfrompath);
   } 
   if (!directory.exists(strtopath))
   {
     directory.createdirectory(strtopath);
   } 
   //直接剪切moveto，本地不留副本
   string[] strfiles = directory.getfiles(strfrompath);
   //循环剪切文件,此处循环是考虑每日工作站最后一个文件无法存储到根目录，导致出现两个视频文件的问题
   for (int i = 0; i < strfiles.length; i++)
   {
     //取得文件名，只取文件名，地址截掉。
     string strfilename = strfiles[i].substring(strfiles[i].lastindexof("\\") + 1, strfiles[i].length - strfiles[i].lastindexof("\\") - 1);
     file.move(strfiles[i], strtopath + "dt-" + strfilename);
   } 
 }
 #endregion

　　 做完机台检查工作，也做好了视频传输的工作，接下来就是视频录制的主角戏了，完整录制视频源码如下

/// <summary>
    /// videosouceplayer 录像
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="image"></param>
    private void sourceplayer_newframe(object sender, ref bitmap image)
    {
      try
      { 
        //写到屏幕上的时间
        g = graphics.fromimage(image);
        solidbrush drawbrush = new solidbrush(color.yellow);

        font drawfont = new font("arial", 6, system.drawing.fontstyle.bold, graphicsunit.millimeter);
        int xpos = image.width - (image.width - 15);
        int ypos = 10;

        string drawdate = datetime.now.tostring("yyyy-mm-dd hh:mm:ss");
        g.drawstring(drawdate, drawfont, drawbrush, xpos, ypos);

        //save content
        string videofilename = dt.tostring("yyyy-mm-dd hhmm") + ".wmv";

        if (testdriveinfo(videofilename)) //检测硬盘空间足够
        {
          if (!stoprec)
          {
            stoprec = true;
            createnewfile = true; //这里要设置为true表示要创建新文件
            if (videowriter != null) videowriter.close();
          }
          else
          {
            //开始录像
            if (createnewfile)
            {
              //第二次录像不一定是第二次开启软件时间(比如：连续多小时录制)，所以应该重新给新录制视频文件重新赋值命名
              dt = datetime.now;
              videofilefullpath = path + dt.tostring("yyyy-mm-dd hhmm") + ".wmv";//videofilename;

              createnewfile = false;
              if (videowriter != null)
              {
                videowriter.close();
                videowriter.dispose();
              }

              videowriter = new videofilewriter();
              //这里必须是全路径，否则会默认保存到程序运行根据录下了
              videowriter.open(videofilefullpath, image.width, image.height, 30, videocodec.wmv1);
              videowriter.writevideoframe(image);
            }
            else
            {
              if (videowriter.isopen)
              {
                videowriter.writevideoframe(image);
              }
              if (dt.addminutes(1) <= datetime.now)
              { 
                createnewfile = true;
                //modify by stephen,每次写入视频文件后，即刻更新结束时间戳，并存入指定文件夹(目的：如果只有关闭的时候处理此操作，就会出现大于1小时的视频文件无法更新结束时间戳，且无法转入指定文件夹)
                if (videowriter != null)
                {
                  videowriter.close();
                  videowriter.dispose();
                }
                string newpath = path + macaddresspath + @"-video\";
                if (!directory.exists(newpath)) directory.createdirectory(newpath);
                string newstr = newpath + dt.tostring("yyyymmddhhmm") + "-" + datetime.now.tostring("yyyymmddhhmm") + ".wmv";
                fileinfo fi = new fileinfo(videofilefullpath);
                fi.moveto(newstr); 
                ////转移到网路目录
                //copyfilestoserver();
              }
            }
          }
        }

      }
      catch (exception ex)
      {
        videowriter.close();
        videowriter.dispose();
      }
      finally
      {

        if (this.g != null) this.g.dispose();
      }

    }

　　    其中testdriveinfo方法是用来获取保存视频的磁盘信息的，具体代码如下：

#region 获取保存视频的磁盘信息
 /// <summary>
 /// 获取保存视频的磁盘信息
 /// </summary>
 bool testdriveinfo(string n)
 {
   try
   {
     driveinfo d = driveinfo.getdrives().where(a => a.name == path.substring(0, 3).toupper()).firstordefault();
     int64 i = d.totalfreespace, ti = unchecked(50 * 1024 * 1024 * 1024);
     if (i < ti)
     {
       directoryinfo folder = new directoryinfo(path + macaddresspath + @"-video\");
       //modify by stephen，验证当前指定文件夹是否存在元素
       if (folder.exists)
       { 
         var fislist = folder.getfiles("*.wmv").orderby(a => a.creationtime); 
         if (fislist.any())
         {
           list<fileinfo> fis = fislist.tolist();
           if (fis.count > 0 && fis[0].name != n)
           {
             file.delete(fis[0].fullname);
           }
         }
       } 
     }
   }
   catch (exception ex)
   {
     messagebox.show(ex.message, "处理硬盘信息出错");
     return false;
   }
   return true;
 }
 #endregion

　　  当然，如果工位师傅录入产品信息有疑问的话，也可以利用系统截图来保留证据，这个是我自己画蛇添足的功能，反正是为了方便嘛，别耽误了工位师傅的办事效率，利用摄像头截图代码如下:

try
{ 
  string pathp = $@"{environment.getfolderpath(environment.specialfolder.mypictures)}\";
  if (!directory.exists(pathp)) directory.createdirectory(pathp);
  if (sourceplayer.isrunning)
  {
    bitmapsource bitmapsource = system.windows.interop.imaging.createbitmapsourcefromhbitmap(
   sourceplayer.getcurrentvideoframe().gethbitmap(),
   intptr.zero,
   int32rect.empty,
   bitmapsizeoptions.fromemptyoptions());
    pngbitmapencoder pe = new pngbitmapencoder();
    pe.frames.add(bitmapframe.create(bitmapsource));
    string picname = $"{pathp}{datetime.now.tostring("yyyymmddhhmmssffffff")}.jpg";
    if (file.exists(picname))
    {
      file.delete(picname);
    }
    using (stream stream = file.create(picname))
    {
      pe.save(stream);
    }
  }
}
catch (exception ex)
{
  messagebox.show(ex.message);
}

　　  代码比较简单，就不写备注了。当然部署系统的时候也不是一帆风顺，有的工厂或者仓库会购买第三方的摄像头，碍于工位环境，摄像头有可能与机台角度偏差较大，所以我又画蛇添足的了校验摄像头的小功能，可以左右90°上下180°画面翻转，具体代码如下：

#region 设置摄像头旋转调整
 if (image != null)
 {
   rotatefliptype ptype = rotatefliptype.rotatenoneflipnone;
   if (dangle == 0)
   {
     ptype = rotatefliptype.rotatenoneflipnone;
   }
   else if (dangle == 90)
   {
     ptype = rotatefliptype.rotate90flipnone;
   }
   else if (dangle == 180)
   {
     ptype = rotatefliptype.rotate180flipnone;
   }
   else if (dangle == 270)
   {
     ptype = rotatefliptype.rotate270flipnone;
   } 
   // 实时按角度绘制
   image.rotateflip(ptype);
 }
 #endregion

　　当然，站在公司角度，为了防止工位师傅手误（诚心）关掉视频监控程序，我们也可以从程序的角度来防患于未然，比如禁用程序的关闭按钮，禁用工具栏右键程序图标关闭程序的操作。

　　 我们可以重写窗口句柄来防止，具体代码如下：

#region 窗口句柄重写，禁用窗体的关闭按钮   
private const int cp_noclose_button = 0x200;
protected override createparams createparams
{
  get
  {
    createparams mycp = base.createparams;
    mycp.classstyle = mycp.classstyle | cp_noclose_button;
    return mycp;
  }
}

　　至此，系统代码告一段路，一起来看看软件效果吧！请自动忽略视频内容，以及笔记本摄像头带来的渣渣像素

作者：stephen-kzx
出处：

源码下载:https://pan.baidu.com/s/1qxbxl4nn7io0sj-myc861q 提取码:b9f7