package com.unis.crk.common.service;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.IService;
import com.unis.crk.common.entity.DataCenterUpload;

public interface IDataCRKtoYJCRKUploadService {

    /**
     * 根据单位Id查询上下发政务外网出入库至应急出入库
     * @param unitId
     * @return
     */
    JSONObject uploadCRKtoYJData(String unitId,String topic);
    /**
     * 根据应急出入库至政务外网出入库
     * @param unitId
     * @return
     */
    JSONObject uploadYJtoCRKData(String unitId,String topic);
    /**
     * 根据单位Id,topic查询删除数据
     * @param unitId
     * @return
     */
    JSONObject uploadCRKtoYJDDelete(String unitId,String topic);

    /**
     * 出入库应急端，下载政务外网出入库数据
     * @param object
     * @param routingKey
     * @return
     */
    JSONObject downloadCRKtoYJData(String object,String routingKey);

    /**
     * 政务外网出入库接收应急端数据
     * @param object
     * @param routingKey
     * @return
     */
    JSONObject downloadYJtoCRKData(String object,String routingKey);

}
