0
点赞
收藏
分享

微信扫一扫

149-gat1400对接(作为上级，与下级对接)

菜菜捞捞 2022-12-19 阅读 64
jsonDatajava编程语言yyds干货盘点
加载失败

作为上级，要支持下级的注册、保活、注销、校时的请求。

提供的url路径：

序号 功能 URI 请求方法
1 注册 /VIID/System/Register POST
2 注销 /VIID/System/UnRegister POST
3 保活 /VIID/System/Keepalive POST
4 校时 /VIID/System/Time GET

application-dev.yml

server:
  port: 10005

server1400:
  dahua:
    ip: 44.160.252.68
    port: 9400
    code: 35070000005031000001
  username: ADMIN
  password: ADMIN999
  myip: 44.110.2.21
  receiveAddr: http://${server1400.myip}:${server.port}
  applicantName: 管理员
  applicantOrg: xx公司
  code: 35070000005031000155

会话管理接口 java 程序实现：

@Api(tags = GAT/1400 会话管理接口)
@RestController
@RequestMapping(/VIID/System)
@Slf4j
public class SessionController {

	@Autowired
    private RestTemplate restTemplate;
	
	@Value(${server1400.username})
    private String username;
	
	@Value(${server1400.password})
    private String password;
	
	@Value(${server1400.dahua.code:})
    private String dahuaCode;

	String registerUrl, unRegisterUrl, keepaliveUrl, timeUrl;
	public SessionController(
            @Value(${server1400.dahua.ip}) String ip,
            @Value(${server1400.dahua.port}) String port) {
        registerUrl = http:// + ip + : + port + /VIID/System/Register;
        unRegisterUrl = http:// + ip + : + port + /VIID/System/UnRegister;
        keepaliveUrl = http:// + ip + : + port + /VIID/System/Keepalive;
        timeUrl = http:// + ip + : + port + /VIID/System/Time;
    }
	
	
	@PostMapping(/Register)
    @ApiOperation(value = 注册, httpMethod = POST)
    public Result register(@RequestBody String json) {
        log.warn(json={},json);
        // 请求头设置
        RegisterRequestObject obj = JSONObject.parseObject(json,RegisterRequestObject.class);
        String deviceId = obj.getRegisterObject().getDeviceID();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.parseMediaType(application/json; charset=UTF-8));
        headers.set(User-Identify, deviceId);
        headers.setConnection(keepalive);
        // 请求参数设置
        RegisterRequestObject registerRequestObject = new RegisterRequestObject();
        RegisterRequestObject.RegisterObject registerObject = new RegisterRequestObject.RegisterObject();
        registerObject.setDeviceID(deviceId);
        registerRequestObject.setRegisterObject(registerObject);

        HttpEntity<String> httpEntity = new HttpEntity<>(JSONUtil.toJsonStr(registerRequestObject), headers);
        // 第一次请求
        ResponseEntity<String> responseEntity = restTemplate.exchange(registerUrl, HttpMethod.POST, httpEntity, String.class);
        int code = responseEntity.getStatusCode().value();
        if (org.apache.http.HttpStatus.SC_UNAUTHORIZED == code) {
            HttpHeaders responseEntityHeaders = responseEntity.getHeaders();
            String authenticate = responseEntityHeaders.get(WWW-Authenticate).get(0);
            String[] children = authenticate.split(,);
            
            String realm = null, qop = null, nonce = null, opaque = null, method = POST;
            for (int i = 0; i < children.length; i++) {
                String item = children[i];
                String[] itemEntry = item.split(=);
                if (itemEntry[0].equals(Digest realm)) {
                    realm = itemEntry[1].replaceAll(\, );
                } else if (itemEntry[0].equals(qop)) {
                    qop = itemEntry[1].replaceAll(\, );
                } else if (itemEntry[0].equals(nonce)) {
                    nonce = itemEntry[1].replaceAll(\, );
                }
            }
            String nc = 00000001;
            String cnonce = DigestUtils.generateSalt2(8);
            String response = DigestUtils.getResponse(username, realm, password, nonce, nc, cnonce, qop, method, registerUrl);
            String authorization = DigestUtils.getAuthorization(username, realm, nonce, registerUrl, qop, nc, cnonce, response, opaque);
            headers.set(Authorization, authorization);

            // 第二次请求
            httpEntity = new HttpEntity<>(JSONUtil.toJsonStr(registerRequestObject), headers);
            responseEntity = restTemplate.exchange(registerUrl, HttpMethod.POST, httpEntity, String.class);
            code = responseEntity.getStatusCode().value();
            if (org.apache.http.HttpStatus.SC_OK == code) {
                String body = responseEntity.getBody();
                return Result.success();
            }
        }
        return Result.failed(注册失败);

    }
	
	
	
	@AuthIgnore
    @PostMapping(/Keepalive)
    @ApiOperation(value = 保活, httpMethod = POST)
    public Result keepalive(@RequestBody String json) {
        log.warn(json={},json);
        KeepaliveRequestObject obj = JSONObject.parseObject(json,KeepaliveRequestObject.class);
        String deviceId = obj.getKeepaliveObject().getDeviceID();

        // 请求头设置
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.parseMediaType(application/json; charset=UTF-8));
        headers.set(User-Identify, deviceId);
        headers.setConnection(keepalive);
        // 请求参数设置
        KeepaliveRequestObject keepaliveRequestObject = new KeepaliveRequestObject();
        KeepaliveRequestObject.KeepaliveObject keepaliveObject = new KeepaliveRequestObject.KeepaliveObject();
        keepaliveObject.setDeviceID(deviceId);
        keepaliveRequestObject.setKeepaliveObject(keepaliveObject);
        log.warn(保活请求 url:{} ,参数：{}, keepaliveUrl, keepaliveRequestObject);

        HttpEntity<KeepaliveRequestObject> httpEntity = new HttpEntity<>(keepaliveRequestObject, headers);
        // 请求执行
        ResponseEntity<String> responseEntity = restTemplate.exchange(keepaliveUrl, HttpMethod.POST, httpEntity, String.class);
        if (org.apache.http.HttpStatus.SC_OK == responseEntity.getStatusCode().value()) {
            return Result.success();
        }
        return Result.failed(保活失败);
    }
	
	
	@AuthIgnore
    @PostMapping(/UnRegister)
    @ApiOperation(value = 注销, httpMethod = POST)
    public Result unregister(@RequestBody String json) {
        log.warn(json={},json);
        UnRegisterRequestObject obj = JSONObject.parseObject(json,UnRegisterRequestObject.class);
        String deviceId = obj.getUnRegisterObject().getDeviceID();
        // 请求头设置
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.parseMediaType(application/json; charset=UTF-8));
        headers.set(User-Identify, deviceId);
        headers.setConnection(keepalive);
        // 请求参数设置
        UnRegisterRequestObject unRegisterRequestObject = new UnRegisterRequestObject();
        UnRegisterRequestObject.UnRegisterObject unRegisterObject = new UnRegisterRequestObject.UnRegisterObject();
        unRegisterObject.setDeviceID(dahuaCode);
        unRegisterRequestObject.setUnRegisterObject(unRegisterObject);

        HttpEntity<String> httpEntity = new HttpEntity<>(JSONUtil.toJsonStr(unRegisterRequestObject), headers);
        // 第一次请求
        ResponseEntity<String> responseEntity = restTemplate.exchange(unRegisterUrl, HttpMethod.POST, httpEntity, String.class);
        if (org.apache.http.HttpStatus.SC_UNAUTHORIZED == responseEntity.getStatusCode().value()) {
            HttpHeaders responseEntityHeaders = responseEntity.getHeaders();
            String authenticate = responseEntityHeaders.get(WWW-Authenticate).get(0);
            String[] children = authenticate.split(,);
            // Digest realm=myrealm,qop=auth,nonce=dmktZGlnZXN0OjQzNTQyNzI3Nzg=
            String realm = null, qop = null, nonce = null, opaque = null, method = POST;
            ;
            for (int i = 0; i < children.length; i++) {
                String item = children[i];
                String[] itemEntry = item.split(=);
                if (itemEntry[0].equals(Digest realm)) {
                    realm = itemEntry[1].replaceAll(\, );
                } else if (itemEntry[0].equals(qop)) {
                    qop = itemEntry[1].replaceAll(\, );
                } else if (itemEntry[0].equals(nonce)) {
                    nonce = itemEntry[1].replaceAll(\, );
                }
            }
            String nc = 00000001;
            String cnonce = DigestUtils.generateSalt2(8);
            String response = DigestUtils.getResponse(username, realm, password, nonce, nc, cnonce, qop, method, unRegisterUrl);
            String authorization = DigestUtils.getAuthorization(username, realm, nonce, unRegisterUrl, qop, nc, cnonce, response, opaque);
            headers.set(Authorization, authorization);

            // 第二次请求
            httpEntity = new HttpEntity<>(JSONUtil.toJsonStr(unRegisterRequestObject), headers);
            responseEntity = restTemplate.exchange(unRegisterUrl, HttpMethod.POST, httpEntity, String.class);
            if (org.apache.http.HttpStatus.SC_OK == responseEntity.getStatusCode().value()) {
                return Result.success();
            }
        }
        return Result.failed(注销失败);
    }
	
	
	@AuthIgnore
    @GetMapping(/Time)
    @ApiOperation(value = 校时, httpMethod = GET)
    public Result time(@RequestBody String json) {
        log.warn(json={},json);
        UnRegisterRequestObject obj = JSONObject.parseObject(json,UnRegisterRequestObject.class);
        String deviceId = obj.getUnRegisterObject().getDeviceID();
        // 请求头设置
        HttpHeaders headers = new HttpHeaders();
        headers.set(User-Identify, deviceId);
        headers.setConnection(keepalive);
        HttpEntity<Object> httpEntity = new HttpEntity<>(null, headers);

        ResponseEntity<SystemTimeObject> entity = restTemplate.getForEntity(timeUrl, SystemTimeObject.class, httpEntity);
        SystemTimeObject.SystemTime systemTime = entity.getBody().getSystemTime();

        String time = DateTimeFormatter.ofPattern(yyyy-MM-dd HH:mm:ss).format(LocalDateTime.now());
        return Result.success(time);
    }
	
	
}

涉及到的实体类：

RegisterObject.java

@Data
public class RegisterRequestObject {

    private RegisterObject RegisterObject;
    @Data
    public static class RegisterObject {
        private String DeviceID;
    }
}

KeepaliveRequestObject.java

@Data
public class KeepaliveRequestObject {

    private KeepaliveObject KeepaliveObject;
    @Data
    public static class KeepaliveObject {
        private String DeviceID;
    }
}

UnRegisterRequestObject.java

@Data
public class UnRegisterRequestObject {
    private UnRegisterObject UnRegisterObject;

    @Data
    public static class UnRegisterObject {
        private String DeviceID;
    }
}

SystemTimeObject.java

@Data
public class SystemTimeObject {

    private SystemTime SystemTime;

    @Data
    public class SystemTime{
        private String VIIDServerID;
        private String TimeMode;
        private String LocalTime;

        private String TimeZone;
    }

}

Result.java

@Data
public class Result<T> implements Serializable {

    private String code;

    private T data;

    private String msg;

    @JsonInclude(JsonInclude.Include.NON_NULL)
    private Long total;

    public static <T> Result<T> success() {
        return success(null);
    }

    public static <T> Result<T> success(T data) {
        ResultCode rce = ResultCode.SUCCESS;
        if (data instanceof Boolean && Boolean.FALSE.equals(data)) {
            rce = ResultCode.SYSTEM_EXECUTION_ERROR;
        }
        return result(rce, data);
    }


    public static <T> Result<T> failed() {
        return result(ResultCode.SYSTEM_EXECUTION_ERROR.getCode(), ResultCode.SYSTEM_EXECUTION_ERROR.getMsg(), null);
    }

    public static <T> Result<T> failed(String msg) {
        return result(ResultCode.SYSTEM_EXECUTION_ERROR.getCode(), msg, null);
    }

    public static <T> Result<T> status(boolean status) {
        if (status) {
            return success();
        } else {
            return failed();
        }
    }

    public static <T> Result<T> failed(IResultCode resultCode) {
        return result(resultCode.getCode(), resultCode.getMsg(), null);
    }

    private static <T> Result<T> result(IResultCode resultCode, T data) {
        return result(resultCode.getCode(), resultCode.getMsg(), data);
    }

    private static <T> Result<T> result(String code, String msg, T data) {
        Result<T> result = new Result<T>();
        result.setCode(code);
        result.setData(data);
        result.setMsg(msg);
        return result;
    }

    public static <T> Result<T> success(T data, Long total) {
        Result<T> result = new Result();
        result.setCode(ResultCode.SUCCESS.getCode());
        result.setMsg(ResultCode.SUCCESS.getMsg());
        result.setData(data);
        result.setTotal(total);
        return result;
    }

}

IResultCode.java

public interface IResultCode {

    String getCode();

    String getMsg();

}

ResultCode.java

public enum ResultCode implements IResultCode, Serializable {

    SUCCESS(00000,一切ok),
    SYSTEM_EXECUTION_ERROR(B0001,系统执行出错);
    
    @Override
    public String getCode() {
        return code;
    }

    @Override
    public String getMsg() {
        return msg;
    }

    private String code;

    private String msg;
    
}

SubscribeReq.java

@ApiModel
@Data
public class SubscribeReq {
    @ApiModelProperty(value = 设备ID, example = 13030421191190201061, required = true)
    private String deviceId;
    private String type;
}

订阅与接收

@Api(tags = GAT/1400 订阅接口)
@RestController
@RequestMapping(/v1/subscribe)
@Slf4j
public class SubscribeController {
	@Autowired
    private RestTemplate restTemplate;
	
	@Value(${server1400.receiveAddr:})
    private String receiveAddr;
	
	@Value(${server1400.applicantName:})
    private String applicantName;
	
    @Value(${server1400.applicantOrg:})
    private String applicantOrg;
	
	@Value(${server1400.dahua.code:})
    private String dahuaCode;
	
	//订阅后接收通知的时间间隔
	@Value(${server1400.reportInterval:10})
    private int reportInterval;
	
	private int days = 300;
	
	String subscribeUrl;
	
	public SubscribeController(
            @Value(${server1400.dahua.ip}) String ip,
            @Value(${server1400.dahua.port}) String port) {
        subscribeUrl = http:// + ip + : + port + /VIID/Subscribes;
    }
	
	
	@PostMapping
    @ApiOperation(value = 订阅, httpMethod = POST)
    @RequestMapping(/subByType)
    public Result subByType(@RequestBody SubscribeReq subscribeReq) {
        String title = ;
        String receiveUrl = receiveAddr+/v1/subscribe/receiveXtml;
        String subscribeDetail = subscribeReq.getType();; // 订阅类别
        String ResultImageDeclare = -1;
        String ResultFeatureDeclare = -1;
        switch (subscribeDetail){
            case 5:
                title = 订阅采集系统目录;
                receiveUrl = receiveAddr+/v1/subscribe/receiveXtml;
                ResultImageDeclare = -1;
                ResultFeatureDeclare = -1;
                break;
            case 3:
                title = 订阅采集设备目录;
                receiveUrl = receiveAddr+/v1/subscribe/receiveSbml;
                ResultImageDeclare = -1;
                ResultFeatureDeclare = -1;
                break;
            case 12:
                title = 订阅人脸识别消息;
                receiveUrl = receiveAddr+/v1/subscribe/receiveFace;
                ResultImageDeclare = -1;
                ResultFeatureDeclare = -1;
                break;
        }

        // 订阅统一标识码 = 公安机关机构代码 + 子类型编码（03-订阅）+ 时间编码（YYYYMMDDhhmmss） + 流水序号（00001）
        String time = DateTimeFormatter.ofPattern(yyyyMMddHHmmss).format(LocalDateTime.now());
        Random random = new Random();
        int xh = 10000+random.nextInt(1000);
		
        String subscribeID = 350700000050 + 03 + time + xh;

        // 订阅资源路径 赋值为 下级平台的国标编码
        String resourceURI = dahuaCode; // 订阅资源路径

        String beginTime = DateTimeFormatter.ofPattern(yyyy-MM-dd HH:mm:ss).format(LocalDateTime.now());

        String endTime = DateTimeFormatter.ofPattern(yyyy-MM-dd HH:mm:ss).format(LocalDateTime.now().plusDays(days));

        Integer operateType = 0;

        SubscribeRequestObject subscribeRequestObject = new SubscribeRequestObject();
        SubscribeRequestObject.SubscribeListObject subscribeListObject = new SubscribeRequestObject.SubscribeListObject();
        subscribeRequestObject.setSubscribeListObject(subscribeListObject);


        List<SubscribeRequestObject.Subscribe> subscribeList = new ArrayList<>();

        SubscribeRequestObject.Subscribe subscribe = new SubscribeRequestObject.Subscribe();
        subscribe.setSubscribeID(subscribeID);
        subscribe.setTitle(title);
        subscribe.setSubscribeDetail(subscribeDetail);
        subscribe.setResourceURI(dahuaCode);
        subscribe.setApplicantName(applicantName);
        subscribe.setApplicantOrg(applicantOrg);
        subscribe.setBeginTime(beginTime);
        subscribe.setEndTime(endTime);

        subscribe.setReceiveAddr(receiveUrl);
        subscribe.setOperateType(operateType);

        subscribe.setResultFeatureDeclare(ResultFeatureDeclare);
        subscribe.setResultImageDeclare(ResultImageDeclare);
        subscribe.setReportInterval(reportInterval);

        subscribeList.add(subscribe);
        subscribeListObject.setSubscribeObject(subscribeList);

        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.parseMediaType(application/json;charset=utf-8));
        headers.set(User-Identify, dahuaCode);


        String bodyStr = JSONUtil.toJsonStr(subscribeRequestObject);
        HttpEntity<String> httpEntity = new HttpEntity<>(bodyStr, headers);
        // 请求执行
        try{
            ResponseEntity<String> responseEntity = restTemplate.exchange(subscribeUrl, HttpMethod.POST, httpEntity, String.class);
            int code = responseEntity.getStatusCode().value();
            
            if (org.apache.http.HttpStatus.SC_OK == code) {
                String body = responseEntity.getBody();
                return Result.success();
            }
        }catch(Exception e){
            log.error(有异常：{},e.getMessage());
        }finally {
        }

        return Result.failed(订阅失败);
    }
	
	
	@PostMapping(/receiveFace)
    public Result receiveFace(@RequestBody String json) {
		log.warn(receiveFace...);
		//初始json
		JSONObject obj1 =  JSONObject.parseObject(json);
		//第一层JSONObject
		JSONObject obj2 = obj1.getJSONObject(SubscribeNotificationListObject);
		//第一层JSONObject中的JSONArray
		JSONArray arr1 = obj2.getJSONArray(SubscribeNotificationObject);
		for (int i = 0; i < arr1.size(); i++) {
			JSONObject obj3 = arr1.getJSONObject(i);
			JSONObject obj4 = obj3.getJSONObject(FaceObjectList);
			JSONArray arr2 = obj4.getJSONArray(FaceObject);
			
			int len = arr2.size();
			for (int j = 0; j < len; j++) {
				//obj5，就是对应的人脸数据结构
				JSONObject obj5 = arr2.getJSONObject(i);
				
				String DeviceID = obj5.getString(DeviceID);
				String FaceID = obj5.getString(FaceID);
				String SourceID = obj5.getString(SourceID);
				String ShotTime = obj5.getString(ShotTime);
				
				//图片
				JSONObject obj6 = obj5.getJSONObject(SubImageList);
				//arr3就是图片的结构
				JSONArray arr3 = obj6.getJSONArray(SubImageInfoObject);
				//...
			}
		}
		return Result.success();
	}
	
	@PostMapping(/receiveXtml)
    public Result receiveXtml(@RequestBody String json) {
		log.warn(receiveXtml...);
		return Result.success();
	}
	
	@PostMapping(/receiveSbml)
    public Result receiveSbml(@RequestBody String json) {
		log.warn(receiveSbml...);
		return Result.success();
	}
	
	@PostMapping
    @ApiOperation(value = 取消订阅, httpMethod = POST)
    @RequestMapping(/cancelSubV2)
    public Result cancelSubV2(@RequestBody String json){

        JSONObject obj = JSONObject.parseObject(json);
        String id = obj.getString(id);

        SubscribeRequestObject.Subscribe rec = new SubscribeRequestObject.Subscribe();
        rec.setSubscribeID(id);
        rec.setOperateType(1);
        rec.setSubscribeCancelOrg(applicantOrg);
        rec.setSubscribeCancelPerson(applicantName);
        rec.setCancelTime(DateTimeFormatter.ofPattern(yyyy-MM-dd HH:mm:ss).format(LocalDateTime.now()));
        rec.setCancelReason(取消订阅);

        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.parseMediaType(application/json;charset=utf-8));
        headers.set(User-Identify, dahuaCode);

        Map<String,Object> map = new HashMap<>();
        map.put(SubscribeObject,rec);

        String bodyStr = JSON.toJSONString(map);
        HttpEntity<String> httpEntity = new HttpEntity<>(bodyStr, headers);
        // 请求执行
        String url = subscribeUrl+/+id;
        ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.PUT, httpEntity, String.class);
        int code = responseEntity.getStatusCode().value();
        if (org.apache.http.HttpStatus.SC_OK == code) {
            String body = responseEntity.getBody();
//            log.warn(取消订阅OK);
            return Result.success();
        }
        return Result.failed(取消订阅失败);
    }
	
	
}
举报

相关推荐

网页游戏与平台登陆对接流程

服务器时间戳页面跳转Linux系统/运维

pulsar 2.9.2对接prometheus和grafana

配置文件大数据yyds干货盘点

国标GB28181对接维护手册

国标 维护手册敏捷开发软件研发

thinkphp6阿里云短信新版sdk对接(tp5对接新版阿里云短信sdk)

php

视图库对接系列(GA-T 1400)十四、视图库对接系列(本级)新增、修改订阅

excelpython

国标篇 GB/T28181对接华为NVR800

国标华为 NVR800敏捷开发软件研发

工业智能物联网网关BL110对接亚马逊AWS

数据客户端文件上传智能硬件嵌入式

Python 与 PHP 项目对接

APIjsonPHP后端开发

浅谈-国标GB28181协议上下级对接国标编码要求（四）

wiresharktcpdump网络协议

对接银行的方法与流程

java
0 条评论
加载失败