新增视频2.0接口

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/MaterialinventoryTimed.java

@@ -48,7 +48,7 @@ public class MaterialinventoryTimed implements Job {
     /**设置定时器功能
      * */
 //    @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//     @Scheduled(fixedDelay = 1000*60)
+     @Scheduled(fixedDelay = 1000*60)
     public void Materialinventory() throws IOException, ParseException {
          iMaterialinventoryService.synchronization(null);
     }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/PhysicalIDTimed.java

@@ -24,7 +24,7 @@ public class PhysicalIDTimed implements Job {
 
     /**测试定时*/
 //     @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//     @Scheduled(fixedDelay = 1000*60)
+     @Scheduled(fixedDelay = 1000*60)
     public void Materialinventory() throws IOException, ParseException {
          physicalIDService.synchronization(null);
 

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/ProductInventoryTimed.java

@@ -28,7 +28,7 @@ public class ProductInventoryTimed  implements Job {
 
     /**测试定时*/
 //    @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//     @Scheduled(fixedDelay = 1000*60)
+     @Scheduled(fixedDelay = 1000*60)
     public void Materialinventory() throws IOException, ParseException {
         productInventoryService.synchronization(null);
 

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/ProductionOrderTimed.java

@@ -16,7 +16,7 @@ public class ProductionOrderTimed {
     @Autowired
     IProductionOrderService productionOrderService;
 //    @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//    @Scheduled(fixedDelay = 1000*60)
+    @Scheduled(fixedDelay = 1000*60)
     public void job() throws ParseException {
         productionOrderService.synchronization(null);
     }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/ProductionSchedulingTimed.java

@@ -16,7 +16,7 @@ public class ProductionSchedulingTimed {
     @Autowired
     IProductionSchedulingService productionSchedulingService;
 //    @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//    @Scheduled(fixedDelay = 1000*60)
+    @Scheduled(fixedDelay = 1000*60)
     public void job() throws ParseException {
         productionSchedulingService.synchronization(null);
     }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/PurchaseorderTimed.java

@@ -26,7 +26,7 @@ public class PurchaseorderTimed implements Job {
      * 测试定时
      */
 //     @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//    @Scheduled(fixedDelay = 1000 * 60)
+    @Scheduled(fixedDelay = 1000 * 60)
     public void Materialinventory() throws IOException, ParseException {
         iPurchaseorderService.synchronizationList(null);
 

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/ReserveStockTimed.java

@@ -30,7 +30,7 @@ public class ReserveStockTimed implements Job {
      * 测试定时
      */
 //    @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//    @Scheduled(fixedDelay = 1000 * 60)
+    @Scheduled(fixedDelay = 1000 * 60)
     public void Materialinventory() throws IOException, ParseException {
         reserveStockService.synchronization(null);
 

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/SalesOrderTimed.java

@@ -24,7 +24,7 @@ public class SalesOrderTimed {
     @Autowired
     ISalesOrderService salesOrderService;
 //    @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//    @Scheduled(fixedDelay = 1000*60)
+    @Scheduled(fixedDelay = 1000*60)
     public void job() throws ParseException {
         salesOrderService.synchronization(null);
     }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/TimedTask/SupplylistTimed.java

@@ -25,7 +25,7 @@ public class SupplylistTimed implements Job {
     @Autowired
     ISupplyListIService supplyListIService;
 //    @Scheduled(cron = "0 0 1 * * ?")//cron表达式每天凌晨一点
-//    @Scheduled(fixedDelay = 1000*60)
+    @Scheduled(fixedDelay = 1000*60)
     public void Materialinventory() throws IOException, ParseException {
       supplyListIService.synchronization(null);
 

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/controller/video/HlsAlterController.java

+package org.jeecg.modules.iost.API.controller.video;//package org.jeecg.modules.iost.API.controller.view;
+
+import io.swagger.annotations.Api;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.InetAddress;
+import java.net.URL;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+
+@RequestMapping("/asAlter")
+@Slf4j
+@Api(tags = "请求金蝶日志")
+@RestController
+public class HlsAlterController {
+    private Map<String, InputStream> urlPath = new HashMap<>();
+    @Value("${server.port}")
+    private int port;
+    @Value("${server.servlet.context-path}")
+    private String path;
+    private String ip = InetAddress.getLocalHost().getHostAddress();
+
+
+    public HlsAlterController() throws UnknownHostException {
+    }
+
+
+    @GetMapping("/GetFile.m3u8")
+    public void getFile(HttpServletRequest request, HttpServletResponse response) throws Exception {
+//        urlPath=null;
+//        读取路径下面的文件
+        String originUrlpath = "https://hls01open.ys7.com/openlive/6e0b2be040a943489ef0b9bb344b96b8.hd.m3u8";
+        //文件流返回格式设为.m3u8
+        response.setContentType("application/vnd.apple.mpegurl");
+        //读取指定路径下面的文件
+        String indexStr = getIndexFile(originUrlpath);//解析originUrlpath 返回为文本
+        List urlList = analysisIndex(indexStr);//解析indexStr获取.ts文件地址
+        String inIp="192.168.2.209";
+        String localPath = "http://" + inIp + ":" + port + path + "/";
+        Map<String, InputStream> urlPathMap = new HashMap<>();
+        for (int i = 0; i < urlList.size(); i++) {
+            String url = urlList.get(i).toString();//
+            InputStream fileInputStream = getFileInputStream(url);
+            String tsUrl = System.nanoTime() + ".ts";//文件后缀，key
+            String localPathTs = localPath + "asAlter/GetTs/" + tsUrl;
+            String resultA = indexStr.replaceAll(url, localPathTs);//文本中的“url”替换为“localPathTs”
+            urlPathMap.put(tsUrl, fileInputStream);
+            indexStr = resultA;
+        }
+        urlPath = urlPathMap;
+        InputStream in = new ByteArrayInputStream(indexStr.getBytes());
+
+        OutputStream outputStream = new BufferedOutputStream(response.getOutputStream());
+        //创建存放文件内容的数组
+        byte[] buff = new byte[1024];
+        //所读取的内容使用n来接收
+        int n;
+        //当没有读取完时,继续读取,循环
+        while ((n = in.read(buff)) != -1) {
+            //将字节数组的数据全部写入到输出流中
+            outputStream.write(buff, 0, n);
+        }
+        //强制将缓存区的数据进行输出
+        outputStream.flush();
+        //关流
+        outputStream.close();
+        in.close();
+    }
+
+    public String getIndexFile(String urlpath) throws Exception {
+        URL url = new URL(urlpath);
+        //下载资源
+        BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream(), "UTF-8"));
+
+        String content = "";
+        String line;
+        while ((line = in.readLine()) != null) {
+            content += line + "\n";
+        }
+        in.close();
+        return content;
+    }
+
+    /* 解析索引文件 */
+    public List analysisIndex(String content) throws Exception {
+        Pattern pattern = Pattern.compile(".*ts");
+        Matcher ma = pattern.matcher(content);
+        List<String> list = new ArrayList<String>();
+
+        while (ma.find()) {
+            list.add(ma.group());
+        }
+
+        return list;
+    }
+
+    /*读取网络文件*/
+    @GetMapping("/GetTs/{path}")
+    public void getFileInputStream(@PathVariable() String path, HttpServletResponse response) {
+        InputStream in = urlPath.get(path);
+        try {
+
+            response.setContentType("application/x-linguist");
+            OutputStream outputStream = new BufferedOutputStream(response.getOutputStream());
+            //创建存放文件内容的数组
+            byte[] buff = new byte[1024];
+            //所读取的内容使用n来接收
+            int n;
+            //当没有读取完时,继续读取,循环
+            while ((n = in.read(buff)) != -1) {
+                //将字节数组的数据全部写入到输出流中
+                outputStream.write(buff, 0, n);
+            }
+            //强制将缓存区的数据进行输出
+            outputStream.flush();
+            //关流
+            outputStream.close();
+            in.close();
+        } catch (Exception e) {
+            System.out.println("读取网络文件异常:" + path);
+//            logger.error("读取网络文件异常:"+path);
+        }finally {
+            urlPath.remove(path);
+        }
+
+    }
+
+    /*测试推流*/
+    /*读取网络文件*/
+    public InputStream getFileInputStream(String path) {
+        URL url = null;
+        try {
+            url = new URL(path);
+            HttpURLConnection conn = (HttpURLConnection)url.openConnection();
+            //设置超时间为3秒
+            conn.setConnectTimeout(3*1000);
+            //防止屏蔽程序抓取而返回403错误
+            conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
+            //得到输入流
+            return conn.getInputStream();
+        } catch (Exception e) {
+            System.out.println("读取网络文件异常:"+path);
+//            logger.error("读取网络文件异常:"+path);
+        }
+        return null;
+    }
+
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/API/controller/video/HlsController.java

@@ -53,10 +53,12 @@ public class HlsController {
         //读取指定路径下面的文件
         String indexStr = getIndexFile(originUrlpath);//解析originUrlpath 返回为文本
         List urlList = analysisIndex(indexStr);//解析indexStr获取.ts文件地址
-        String localPath = "http://" + ip + ":" + port + path + "/";
+        String inIp="192.168.2.209";
+        String localPath = "http://" + inIp + ":" + port + path + "/";
         System.out.println(urlList);
         Map<String, String> urlPathMap = new HashMap<String, String>();
         for (int i = 0; i < urlList.size(); i++) {
+
             String tsUrl = i + ".ts";//文件后缀，key
             String localPathTs = localPath + "as/GetTs/" + tsUrl;
             String url = urlList.get(i).toString();//
@@ -153,4 +155,59 @@ public class HlsController {
         }
 
     }
+
+    /*测试推流*/
+    @GetMapping("/setStr.ts")
+    public void setStr(HttpServletRequest request, HttpServletResponse response) throws Exception {
+//        读取路径下面的文件
+        File file = new File("D:\\test\\");
+        File picFile = null;
+        for (File f : file.listFiles()) {
+            if (f.getName().contains("DEMO.ts")) {
+                //根据路径获取文件
+                picFile = new File(f.getPath());
+                System.out.println("picFile" + picFile);
+                //获取文件后缀名格式
+                String ext = picFile.getName().substring(picFile.getName().indexOf("."));
+                System.out.println("ext" + ext);
+                //判断图片格式,设置相应的输出文件格式
+                if (ext.equals("jpg")) {
+                    response.setContentType("image/jpeg");
+                } else if (ext.equals("JPG")) {
+                    response.setContentType("image/jpeg");
+                } else if (ext.equals("png")) {
+                    response.setContentType("image/png");
+                } else if (ext.equals("PNG")) {
+                    response.setContentType("image/png");
+                } else if (ext.equals("txt")) {
+                    response.setContentType("text/plain");
+                } else if (ext.equals("ts")) {
+                    response.setContentType("application/x-linguist");
+                }
+            }
+        }
+
+        InputStream in = new FileInputStream(picFile);
+        System.out.println("in" + in);
+        OutputStream outputStream = new BufferedOutputStream(response.getOutputStream());
+        //创建存放文件内容的数组
+        byte[] buff = new byte[1024];
+        //所读取的内容使用n来接收
+        int n;
+        //当没有读取完时,继续读取,循环
+        while ((n = in.read(buff)) != -1) {
+            //将字节数组的数据全部写入到输出流中
+            System.out.println();
+            System.out.println("文件内容的数组" + buff);
+            System.out.println("读取的内容" + n);
+            outputStream.write(buff, 0, n);
+        }
+        //强制将缓存区的数据进行输出
+        outputStream.flush();
+        System.out.println(outputStream);
+        //关流
+        outputStream.close();
+        in.close();
+    }
+
 }