卖猪接口

huimv-farm-video/src/main/java/com/huimv/video/dhicc/controller/BaseController/VideoRecorController.java

@@ -53,6 +53,7 @@ public class VideoRecorController {
         LambdaQueryWrapper<IccChannel> wrapper3 = Wrappers.lambdaQuery();
         wrapper3.eq(IccChannel::getChannelName, channelNmae);
         IccChannel iccChannel = iccChannelMapper.selectOne(wrapper3);
+        System.out.println(iccChannel);
         String URL = "/evo-apigw/admin/API/SS/Playback/StartPlaybackByTime";  //获取事件URL    post请求
         IClient iClient = new DefaultClient();
         GeneralRequest generalRequest = new GeneralRequest(URL, Method.POST);
@@ -88,6 +89,7 @@ public class VideoRecorController {
         //发起请求处理应答
         GeneralResponse generalResponse = iClient.doAction(generalRequest, generalRequest.getResponseClass());
         JSONObject jsonObject = JSONObject.fromObject(generalResponse.getResult());
+        System.out.println(jsonObject.toString());
         Object data = jsonObject.get("data");
         String url = (String) JSONObject.fromObject(data).get("url");
         String token = (String) JSONObject.fromObject(data).get("token");

huimv-farm-video/src/main/java/com/huimv/video/dhicc/controller/ClientController/ClientMaiZhuController.java

@@ -0,0 +1,116 @@
+package com.huimv.video.dhicc.controller.ClientController;
+
+import com.alibaba.fastjson.JSON;
+import com.dahuatech.hutool.http.Method;
+import com.dahuatech.icc.exception.ClientException;
+import com.dahuatech.icc.oauth.http.DefaultClient;
+import com.dahuatech.icc.oauth.http.IClient;
+import com.dahuatech.icc.oauth.model.v202010.GeneralRequest;
+import com.dahuatech.icc.oauth.model.v202010.GeneralResponse;
+import com.huimv.common.utils.StringUtilsWork;
+import com.huimv.video.dhicc.icc.CommonConstant;
+import com.huimv.video.dhicc.result.R;
+import com.huimv.video.dhicc.service.ISysTelecomEventService;
+import net.sf.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+
+//其实可以整合到一起去了
+@RestController
+@RequestMapping("/event")
+public class ClientMaiZhuController {
+
+    //所有的事件接口
+    @RequestMapping("/maiZhuEvent")
+    public R SiZhuList(@RequestBody Map<String, Object> params1) throws ClientException, ParseException {
+        Integer farmId= (int) params1.get("farmId");
+        if(farmId!=1){
+            return R.ok("当前牧场无设备").put("data",null  );
+        }
+        return R.ok("请求成功").put("data", getEventList( params1  )).put("total" , CountTimes(params1));
+    }
+
+
+    //熏蒸事件
+    public GeneralResponse getEventList(Map<String, Object> params1) throws ClientException {
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Calendar c = Calendar.getInstance();
+        Date date = new Date();
+        c.setTime(date);
+        c.set(Calendar.HOUR, 0);
+        c.set(Calendar.MINUTE, 0);
+        c.set(Calendar.SECOND, 0);
+        Date A = c.getTime();
+        String formatA = format.format(A);
+        c.set(Calendar.HOUR, +24);
+        Date d = c.getTime();
+        String formatD = format.format(d);
+        Map<String, Object> params = new HashMap<>();
+        params.put("alarmStartDateString",formatA);
+        params.put("alarmEndDateString",formatD);
+        if (StringUtilsWork.isNotEmpty( (String) params1.get("alarmStartDateString"))){
+            params.put("alarmStartDateString",(String) params1.get("alarmStartDateString"));
+            params.put("alarmEndDateString",(String) params1.get("alarmEndDateString"));
+        }
+        params.put("pageNum",(Integer)params1.get("pageNum"));
+        params.put("pageSize",(Integer)params1.get("pageSize"));
+        params.put("alarmType",303);
+        params.put("dbType",0);
+        params.put("deviceCategory",1);
+        String[]  nodeCodeList= CommonConstant.MaiZhuChannle;
+        params.put("nodeCodeList",nodeCodeList);
+        String URL = "/evo-apigw/evo-event/1.2.0/alarm-record/page";  //获取事件URL    post请求
+        IClient iClient = new DefaultClient();
+        GeneralRequest generalRequest = new GeneralRequest(URL, Method.POST);
+        generalRequest.header("Content-Type", " application/json");
+        generalRequest.body(JSON.toJSONString(params));
+        GeneralResponse generalResponse = iClient.doAction(generalRequest, generalRequest.getResponseClass());
+        return    generalResponse;
+    }
+
+
+    public String CountTimes(Map<String, Object> params1 ) throws ClientException {
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Calendar c = Calendar.getInstance();
+        Date date = new Date();
+        c.setTime(date);
+        c.set(Calendar.HOUR, 0);
+        c.set(Calendar.MINUTE, 0);
+        c.set(Calendar.SECOND, 0);
+        Date A = c.getTime();
+        String formatA = format.format(A);
+        c.set(Calendar.HOUR, +24);
+        Date d = c.getTime();
+        String formatD = format.format(d);
+        Map<String, Object> params = new HashMap<>();
+        params.put("alarmStartDateString",formatA);
+        params.put("alarmEndDateString",formatD);
+        if (StringUtilsWork.isNotEmpty( (String) params1.get("alarmStartDateString"))){
+            params.put("alarmStartDateString", params1.get("alarmStartDateString"));
+            params.put("alarmEndDateString", params1.get("alarmEndDateString"));
+        }
+        params.put("alarmType",303);
+        params.put("dbType",0);
+        params.put("deviceCategory",1);
+        String[]  nodeCodeList= CommonConstant.MaiZhuChannle;
+        params.put("nodeCodeList",nodeCodeList);
+        String URL = "/evo-apigw/evo-event/1.0.0/alarm-record/count-num";  //获取事件URL    post请求
+        IClient iClient = new DefaultClient();
+        GeneralRequest generalRequest = new GeneralRequest(URL, Method.POST);
+        generalRequest.header("Content-Type", " application/json");
+        generalRequest.body(JSON.toJSONString(params));
+        JSONObject jsonObject = JSONObject.fromObject(JSONObject.fromObject(iClient.doAction(generalRequest, generalRequest.getResponseClass()).getResult()).get("data"));
+        return jsonObject.get("value").toString();
+    }
+}
+

huimv-farm-video/src/main/java/com/huimv/video/dhicc/controller/ClientController/ClientXixiaoController.java

@@ -10,7 +10,6 @@ import com.dahuatech.icc.oauth.model.v202010.GeneralResponse;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
-
 import java.util.Map;
 
 //其实可以整合到一起去了

huimv-farm-video/src/main/java/com/huimv/video/dhicc/controller/ClientController/ClientXunZhengController.java

@@ -16,7 +16,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
-
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Calendar;

huimv-farm-video/src/main/java/com/huimv/video/dhicc/icc/CommonConstant.java

@@ -12,6 +12,8 @@ public class CommonConstant {
     //熏蒸
     public static final String[] XunZhengChannle =  {"1003444$1$0$0"};
 
+    //卖猪
+    public static final String[] MaiZhuChannle =  {"1003444$1$0$0"};
 
     //洗消通道
     public static final String[] XixiaoChannle =  {"1002871$1$0$0","1002872$1$0$0","1002873$1$0$0"};