二道门，人员进出记录发送led大屏

danger-manage-admin/src/main/java/com/zehong/web/controller/system/Bx06Controller.java

@@ -2,21 +2,22 @@ package com.zehong.web.controller.system;
 
 import com.zehong.common.core.domain.AjaxResult;
 import com.zehong.system.domain.vo.Bx06Vo;
+import com.zehong.system.service.ITEntranceGuardPersonInfoService;
 import com.zehong.system.service.impl.LedserviceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import org.springframework.web.bind.annotation.PutMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
 
 @Api("大屏推送")
 @RestController
 @RequestMapping("bx")
 public class Bx06Controller {
-
+    @Autowired
+    private ITEntranceGuardPersonInfoService tEntranceGuardPersonInfoService;
     @ApiOperation("测试推送")
-    @PutMapping("/send")
-    public AjaxResult send (Bx06Vo bx06Vo)throws Exception
+    @PostMapping("/send")
+    public AjaxResult send (@RequestBody Bx06Vo bx06Vo)throws Exception
     {
         if(bx06Vo.getContents()==null||bx06Vo.getContents().length<1){
             return AjaxResult.error("请至少发送一行数据");
@@ -27,4 +28,12 @@ public class Bx06Controller {
         LedserviceImpl.SendProgram(bx06Vo);
         return AjaxResult.success();
     }
+
+//    @ApiOperation("测试推送2")
+//    @PostMapping("/testsend")
+//    public void testsend ()throws Exception
+//    {
+//        tEntranceGuardPersonInfoService.send2Led();
+//    }
+
 }

danger-manage-admin/src/main/java/com/zehong/web/controller/videomonitor/SubscriptionEventController.java

@@ -150,6 +150,8 @@ public class SubscriptionEventController {
             tEntranceGuardPersonInfo.setActionTime(happenTime);
             tEntranceGuardPersonInfoService.insertTEntranceGuardPersonInfo(tEntranceGuardPersonInfo);
         }
+        //发送到led屏
+        tEntranceGuardPersonInfoService.send2Led();
     }
 
     /**

danger-manage-system/src/main/java/com/zehong/system/domain/vo/Bx06Vo.java

@@ -5,7 +5,7 @@ import lombok.Data;
 @Data
 public class Bx06Vo {
    private String[] contents;
-   private String content ="柏坡正元欢迎您";
+   private String content ="";
    private Integer width = 192;
    private Integer height = 96;
    private Integer colorType =1;

danger-manage-system/src/main/java/com/zehong/system/mapper/TEntranceGuardPersonInfoMapper.java

@@ -79,4 +79,9 @@ public interface TEntranceGuardPersonInfoMapper
      */
     List<TEntranceGuardPersonInfo> lastImportAndExportData();
 
+    /**
+     * 获取最近5条通过信息
+     * @return
+     */
+    List<TEntranceGuardPersonInfo> lastImportOrExportData();
 }

danger-manage-system/src/main/java/com/zehong/system/service/ITEntranceGuardPersonInfoService.java

@@ -65,4 +65,6 @@ public interface ITEntranceGuardPersonInfoService
      * 二道门人员信息初始化
      */
     Map<String,Object> getEntranceGuardPersonInfo();
+
+    public void send2Led();
 }

danger-manage-system/src/main/java/com/zehong/system/service/impl/TEntranceGuardPersonInfoServiceImpl.java

 package com.zehong.system.service.impl;
 
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.MalformedURLException;
+import java.net.URL;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import com.alibaba.fastjson.JSONObject;
 import com.zehong.common.utils.DateUtils;
+import com.zehong.common.utils.StringUtils;
+import com.zehong.system.domain.vo.Bx06Vo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.zehong.system.mapper.TEntranceGuardPersonInfoMapper;
@@ -128,4 +135,123 @@ public class TEntranceGuardPersonInfoServiceImpl implements ITEntranceGuardPerso
         return result;
 
     }
+
+    /**
+     * 发送到Led大屏
+     */
+    @Override
+    public void send2Led() {
+        String []contents=new String[6];
+        contents[0]=" 石家庄柏坡正元化肥有限公司";
+        //查询场内人数
+        String cnrs=tEntranceGuardPersonInfoMapper.statisticsStayInPersons();
+        contents[1]="企业人数:864人 厂内人数:"+cnrs+"人";
+        List <TEntranceGuardPersonInfo>lastImportOrExportData=tEntranceGuardPersonInfoMapper.lastImportOrExportData();
+        int i=0;
+        String crc="";
+        for(TEntranceGuardPersonInfo tEntranceGuardPersonInfo : lastImportOrExportData){
+            if(i>2){
+                return;
+            }
+            if("0".equals(tEntranceGuardPersonInfo.getActionType())){
+                crc="入场";
+            }else if("1".equals(tEntranceGuardPersonInfo.getActionType())){
+                crc="出场";
+            }
+
+            contents[i+2]=tEntranceGuardPersonInfo.getPersonName()+" "+crc+" "+DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS,tEntranceGuardPersonInfo.getActionTime());
+            i++;
+        }
+        contents[5]="      "+DateUtils.getDate();//展示当日日期
+        //执行发送
+        send(contents);
+
+    }
+    private void send(String[] contents){
+        System.out.println("开始发送数据...");
+        String pathUrl="http://218.207.92.101:8908/dangerManage/bx/send";
+//        String pathUrl="http://127.0.0.1:8908/dangerManage/bx/send";
+        Bx06Vo bv=new Bx06Vo();
+        bv.setContents(contents);
+
+        //发送数据
+        doPostOrGet(pathUrl,JSONObject.toJSONString(bv));
+
+    }
+
+    //发送数据
+    public static void doPostOrGet(String pathUrl, String data) {
+
+        OutputStreamWriter out = null;
+        BufferedReader br = null;
+
+        String result = "";
+
+        try {
+            URL url = new URL(pathUrl);
+
+            //打开和url之间的连接
+            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+
+            //请求方式
+            conn.setRequestMethod("POST");
+
+            //conn.setRequestMethod("GET");
+            //设置通用的请求属性
+            conn.setRequestProperty("accept", "*/*");
+
+            conn.setRequestProperty("connection", "Keep-Alive");
+
+            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
+
+            conn.setRequestProperty("Content-Type", "application/json;charset=utf-8");
+
+            //DoOutput设置是否向httpUrlConnection输出，DoInput设置是否从httpUrlConnection读入，此外发送post请求必须设置这两个
+
+            conn.setDoOutput(true);
+            conn.setDoInput(true);
+
+            /**
+             * 下面的三句代码，就是调用第三方http接口
+             */
+            //获取URLConnection对象对应的输出流
+            out = new OutputStreamWriter(conn.getOutputStream(), "UTF-8");
+            //发送请求参数即数据
+            out.write(data);
+            //flush输出流的缓冲
+            out.flush();
+            /**
+             * 下面的代码相当于，获取调用第三方http接口后返回的结果
+             */
+            //获取URLConnection对象对应的输入流
+            InputStream is = conn.getInputStream();
+
+            //构造一个字符流缓存
+            br = new BufferedReader(new InputStreamReader(is));
+            String str = "";
+            while ((str = br.readLine()) != null) {
+                result += str;
+            }
+            System.out.println(result);
+            //关闭流
+            is.close();
+
+            //断开连接，disconnect是在底层tcp socket链接空闲时才切断，如果正在被其他线程使用就不切断。
+            conn.disconnect();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (out != null) {
+                    out.close();
+                }
+                if (br != null) {
+                    br.close();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+    }
 }

danger-manage-system/src/main/resources/mapper/system/TEntranceGuardPersonInfoMapper.xml

@@ -162,4 +162,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         GROUP BY
             present.action_type
     </select>
+
+    <select id="lastImportOrExportData"  resultMap="TEntranceGuardPersonInfoResult">
+            SELECT
+                DATE_FORMAT(action_time,'%Y-%m-%d %H:%i:%s') action_time,person_name,action_type
+            FROM
+                t_entrance_guard_person_info
+            ORDER BY action_time DESC LIMIT 3
+    </select>
 </mapper>
\ No newline at end of file