生物防控人员

huimv-admin/src/main/java/com/huimv/admin/controller/BaseSpecificVideoController.java

@@ -0,0 +1,69 @@
+package com.huimv.admin.controller;
+
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.huimv.admin.common.utils.Result;
+import com.huimv.admin.common.utils.ResultCode;
+import com.huimv.admin.entity.BaseSpecificVideo;
+import com.huimv.admin.entity.CameraBase;
+import com.huimv.admin.service.IBaseSpecificVideoService;
+import com.huimv.admin.service.ICameraBaseService;
+import javafx.scene.Camera;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * <p>
+ * 前端控制器
+ * </p>
+ *
+ * @author astupidcoder
+ * @since 2021-12-20
+ */
+@RestController
+@RequestMapping("/baseSpecificVideo")
+public class BaseSpecificVideoController {
+    @Autowired
+    IBaseSpecificVideoService baseSpecificVideoService;
+
+    @Autowired
+    ICameraBaseService cameraService;
+
+    @PostMapping("/add")
+    public Result add(@RequestBody BaseSpecificVideo baseFarmX) {
+        CameraBase byId = cameraService.getById(baseFarmX.getVideoId());
+        baseFarmX.setVideoName(byId.getCameraName());
+        baseSpecificVideoService.save(baseFarmX);
+        return new Result(ResultCode.SUCCESS);
+    }
+
+
+    @GetMapping("/remove")
+    public Result remove(@RequestParam(name = "id") Integer id) {
+        baseSpecificVideoService.removeById(id);
+        return new Result(ResultCode.SUCCESS);
+    }
+
+    @PostMapping("/update")
+    public Result update(@RequestBody BaseSpecificVideo baseFarmX) {
+        CameraBase byId = cameraService.getById(baseFarmX.getVideoId());
+        baseFarmX.setVideoName(byId.getCameraName());
+        baseSpecificVideoService.updateById(baseFarmX);
+        return new Result(ResultCode.SUCCESS);
+    }
+
+    @GetMapping("/list")
+    public Result list(@RequestParam(name = "farmId") Integer farmId) {
+
+        return new Result(ResultCode.SUCCESS, baseSpecificVideoService.list(new QueryWrapper<BaseSpecificVideo>().eq("farm_id", farmId)));
+    }
+
+    @GetMapping("/listSpecif")
+    public Result listSpecif(@RequestParam(name = "farmId") Integer farmId,
+                             @RequestParam(name = "type") Integer type) {
+
+        return new Result(ResultCode.SUCCESS, baseSpecificVideoService.listSpecif(farmId, type));
+    }
+
+
+}

huimv-admin/src/main/java/com/huimv/admin/entity/BaseSpecificVideo.java

@@ -0,0 +1,38 @@
+package com.huimv.admin.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author astupidcoder
+ * @since 2021-12-20
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+public class BaseSpecificVideo extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    private Integer videoId;
+
+    private Integer type;
+
+    private Integer farmId;
+
+    private String videoName;
+
+    private String selectVideo;
+
+}

huimv-admin/src/main/java/com/huimv/admin/entity/vo/CameraVo.java

@@ -17,4 +17,10 @@ public class CameraVo {
 //    private Integer lastId;
 //    private Integer nextId;
 //    private String httpUrl;
+private String wsUrl;
+    private String rtspUrl;
+    private String areaId;
+    private Integer lastId;
+    private Integer nextId;
+    private String httpUrl;
 }

huimv-admin/src/main/java/com/huimv/admin/mapper/BaseSpecificVideoMapper.java

@@ -0,0 +1,16 @@
+package com.huimv.admin.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huimv.admin.entity.BaseSpecificVideo;
+
+/**
+ * <p>
+ * Mapper 接口
+ * </p>
+ *
+ * @author astupidcoder
+ * @since 2021-12-20
+ */
+public interface BaseSpecificVideoMapper extends BaseMapper<BaseSpecificVideo> {
+
+}

huimv-admin/src/main/java/com/huimv/admin/service/IBaseSpecificVideoService.java

@@ -0,0 +1,19 @@
+package com.huimv.admin.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.huimv.admin.entity.BaseSpecificVideo;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 服务类
+ * </p>
+ *
+ * @author astupidcoder
+ * @since 2021-12-20
+ */
+public interface IBaseSpecificVideoService extends IService<BaseSpecificVideo> {
+
+    List listSpecif(Integer farmId, Integer type);
+}

huimv-admin/src/main/java/com/huimv/admin/service/impl/BaseSpecificVideoServiceImpl.java

@@ -0,0 +1,89 @@
+package com.huimv.admin.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huimv.admin.entity.BaseSpecificVideo;
+import com.huimv.admin.entity.CameraBase;
+import com.huimv.admin.entity.CameraBrand;
+import com.huimv.admin.entity.vo.CameraVo;
+import com.huimv.admin.mapper.BaseSpecificVideoMapper;
+import com.huimv.admin.mapper.CameraAreaMapper;
+import com.huimv.admin.mapper.CameraBaseMapper;
+import com.huimv.admin.mapper.CameraBrandMapper;
+import com.huimv.admin.service.IBaseSpecificVideoService;
+import javafx.scene.Camera;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+ * 服务实现类
+ * </p>
+ *
+ * @author astupidcoder
+ * @since 2021-12-20
+ */
+@Service
+public class BaseSpecificVideoServiceImpl extends ServiceImpl<BaseSpecificVideoMapper, BaseSpecificVideo> implements IBaseSpecificVideoService {
+    @Autowired
+    private CameraBaseMapper cameraMapper;
+
+    @Autowired
+    private CameraAreaMapper cameraAreaMapper;
+
+    @Autowired
+    private CameraBrandMapper cameraBrandMapper;
+
+    @Override
+    public List listSpecif(Integer farmId, Integer type) {
+        List<BaseSpecificVideo> list = this.list(new QueryWrapper<BaseSpecificVideo>().eq("farm_id", farmId).eq("type", type));
+
+        List list1 = new ArrayList();
+        for (BaseSpecificVideo baseSpecificVideo : list) {
+
+            CameraBase camera = cameraMapper.selectById(baseSpecificVideo.getVideoId());
+
+            list1.add(getCameraVo(camera));
+        }
+
+        return list1;
+    }
+
+
+    public CameraVo getCameraVo(CameraBase camera) {
+
+
+        String cameraAccount = camera.getAccount();
+        String cameraPassword = camera.getPassword();
+        String camerIp = camera.getCameraIp();
+        String cameraName = camera.getCameraName();
+        String areaId = camera.getRegionUuid();
+        String url = cameraAreaMapper.selectById(areaId).getPublicUrl();
+
+        String rtsp;
+        CameraBrand cameraBrand = cameraBrandMapper.selectById(camera.getBrandId());
+        Integer type = cameraBrand.getStreamType();
+        if (type == 0) {
+            rtsp = cameraBrand.getMainStream();
+        } else {
+            rtsp = cameraBrand.getAssistStream();
+        }
+
+
+        CameraVo cameraVo = new CameraVo();
+        cameraVo.setAreaId(areaId);
+        if (camera.getId() == 767){
+            cameraVo.setWsUrl("ws://" + url + "/camera_relay?tcpaddr=" + cameraAccount + "%3A" + cameraPassword + "%40" + camerIp);
+            cameraVo.setRtspUrl("rtsp://" + cameraAccount + ":" + cameraPassword + "@" + camerIp + "/cam/realmonitor?channel=2&subtype=0");
+        }else {
+            cameraVo.setWsUrl("ws://" + url + "/camera_relay?tcpaddr=" + cameraAccount + "%3A" + cameraPassword + "%40" + camerIp);
+            cameraVo.setRtspUrl("rtsp://" + cameraAccount + ":" + cameraPassword + "@" + camerIp + rtsp);
+        }
+
+        cameraVo.setCameraName(cameraName);
+        return cameraVo;
+    }
+}

huimv-admin/src/main/java/com/huimv/admin/service/impl/EnvDeviceServiceImpl.java

@@ -363,6 +363,17 @@ public class EnvDeviceServiceImpl extends ServiceImpl<EnvDeviceMapper, EnvDevice
         String s = null;
         try {
             s = HttpClientSSLUtils.doPost("https://yzwlw.loongk.com/mobile/login?username=华统&password=21218cca77804d2ba1922c33e0151105", JSON.toJSONString(map));
+            LoginDto loginDto = JSONUtil.toBean(s, LoginDto.class);
+            DataToken token = loginDto.getData().getToken();
+            String encode = Base64.encode(token.getUserId() + "_" + token.getToken());
+            HttpHeaders headers = new HttpHeaders();
+            headers.add("Authorization",encode);
+            HttpEntity<String> requestEntity = new HttpEntity<>(null, headers);
+            //
+            RestTemplate restTemplate = new RestTemplate();
+
+            ResponseEntity<String> exchangePeizhi = restTemplate.exchange("https://yzwlw.loongk.com/mobile/loadShackDatas/2c92083a871cf897018725a162130013", HttpMethod.GET, requestEntity, String.class);
+            System.out.println(exchangePeizhi.toString());
         } catch (Exception e) {
             e.printStackTrace();
         }

huimv-admin/src/main/java/com/huimv/admin/timer/ShenChanTimer.java

@@ -268,6 +268,31 @@ public class ShenChanTimer {
     }
 
 
+    public static void main(String[] args) throws Exception {
+        RestTemplate restTemplate = new RestTemplate();
+        StockLoginDto stockLoginDto = restTemplate.getForObject("http://test.htpig.cn/rest/user/login?user_name=test&password=e10adc3949ba59abbe56e057f20f883e&db_name=MSSQL", StockLoginDto.class);
+       String   token  = stockLoginDto.getToken();
+        String time = LocalDate.now().toString();
+        System.out.println(token);
+
+        String url = "http://test.htpig.cn/rest/db/storedproc";
+        Map<String, Object> map = new HashMap<String, Object>();
+        map.put("db_name","MSSQL");
+        map.put("proc_name","rep_yz_kc_hz");
+        map.put("method","open_proc");
+        HashMap<String, Object> maps = new HashMap<>();
+        List list = new ArrayList();
+        maps.put("name","@fdate");
+        maps.put("value",time);
+        list.add(maps);
+
+        map.put("params",list);
+        String params = JSON.toJSONString(map);
+        System.out.println(" ====== getStock请求参数：【" + params + "】");
+        String data = HttpClientSSLUtils.doPost(url+"?token="+token+"&data=", params);
+        ProdStockDto prodStockDto = JSONUtil.toBean(data, ProdStockDto.class);
+        System.out.println(prodStockDto.toString());
+    }
     private String login() throws Exception {
         StockLoginDto stockLoginDto = restTemplate.getForObject("http://test.htpig.cn/rest/user/login?user_name=test&password=e10adc3949ba59abbe56e057f20f883e&db_name=MSSQL", StockLoginDto.class);
         if (stockLoginDto.getStatus() != 0){