takephoto.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113
  1. package camera
  2. import (
  3. "fmt"
  4. "os"
  5. "os/exec"
  6. "syscall"
  7. "time"
  8. "github.com/vishvananda/netlink"
  9. "hnyfkj.com.cn/rtu/linux/baseapp"
  10. "hnyfkj.com.cn/rtu/linux/hk_takephoto"
  11. )
  12. // 相机模块的名称
  13. const MODULE_NAME = "Camera"
  14. // 配置连接网口相机的网卡ip
  15. func SetupEth1ForGigeCamera(cidr string) error {
  16. link, err := netlink.LinkByName("eth1")
  17. if err != nil {
  18. return err
  19. }
  20. if err = netlink.LinkSetUp(link); err != nil {
  21. return err
  22. }
  23. addr, err := netlink.ParseAddr(cidr)
  24. if err != nil {
  25. return err
  26. }
  27. if err = netlink.AddrAdd(link, addr); err != nil && err != syscall.EEXIST {
  28. return err
  29. }
  30. return nil
  31. }
  32. // 打开或关闭网口相机的电源
  33. func PowerOnGigeCamera(on bool) error {
  34. _ = os.WriteFile("/sys/class/gpio/unexport", []byte("22"), 0644)
  35. if err := os.WriteFile("/sys/class/gpio/export", []byte("22"), 0644); err != nil {
  36. return err
  37. }
  38. time.Sleep(50 * time.Millisecond)
  39. if err := os.WriteFile("/sys/class/gpio/gpio22/direction", []byte("out"), 0644); err != nil {
  40. return err
  41. }
  42. val := "0"
  43. if on {
  44. val = "1"
  45. }
  46. if err := os.WriteFile("/sys/class/gpio/gpio22/value", []byte(val), 0644); err != nil {
  47. return err
  48. }
  49. return nil
  50. }
  51. func PingOnce(host string, timeoutSec int) error {
  52. cmd := exec.Command("ping", "-c", "1", "-W", fmt.Sprint(timeoutSec), host)
  53. return cmd.Run()
  54. }
  55. func ModuleInit(supportsGigeCamera bool, eth1CIDR, gigeCameraIP string) bool {
  56. var err error
  57. if !supportsGigeCamera {
  58. goto initOK
  59. }
  60. if err := SetupEth1ForGigeCamera(eth1CIDR); err != nil {
  61. baseapp.Logger.Errorf("[%s] 网口相机初始化失败: 设置\"eth1\"地址失败: %v!!", MODULE_NAME, err)
  62. return false
  63. }
  64. err = PingOnce(gigeCameraIP, 1)
  65. if err == nil {
  66. goto initOK
  67. }
  68. PowerOnGigeCamera(false)
  69. err = PowerOnGigeCamera(true)
  70. if err != nil {
  71. baseapp.Logger.Errorf("[%s] 网口相机初始化失败: 通过 GPIO22 上电失败: %v!!", MODULE_NAME, err)
  72. return false
  73. }
  74. for range 15 {
  75. if baseapp.IsExit1() {
  76. return false
  77. }
  78. err = PingOnce(gigeCameraIP, 1)
  79. if err == nil {
  80. break
  81. }
  82. time.Sleep(1 * time.Second)
  83. }
  84. if err != nil {
  85. baseapp.Logger.Errorf("[%s] 网口相机初始化失败: 连通性检测(ping)失败: %v!!", MODULE_NAME, err)
  86. return false
  87. }
  88. initOK:
  89. if !hk_takephoto.ModuleInit() {
  90. return false
  91. }
  92. return true
  93. }