武汉军粮省平台-提交推送

CZT

2023-08-04 4fbbb9c7c3ab7ec36f5e0778482da8dea7268dc2

武汉军粮省平台-提交推送

 src/main/java/com/fzzy/api/data/PushProtocol.java

@@ -15,6 +15,7 @@
    SB_GD_2022("SB_GD_2022", "广东省平台2022版"),
    SB_GD_2020("SB_GD_2020", "广东省平台2020版"),
    SB_HN_2022("SB_HN_2022", "河南省平台2022版"),
    SB_WHJL_2023("SB_WHJL_2023", "武汉军粮平台2023版"),
    HB_FZZY_JG_2022("HB_FZZY_JG_2022", "风正致远监管2022版本"),
    SB_SHJdJW_2023("SB_SHJdJW_2023", "上海嘉定纪委监管平台2023版");


 src/main/java/com/fzzy/async/whhpjl/Fzzy40ToWhjlSyncService11.java

ÎļþÃû´Ó src/main/java/com/fzzy/async/whhpjl/Fzzy40ToWhSyncService11.java ÐÞ¸Ä
@@ -18,7 +18,7 @@
 */
@Slf4j
@Component
public class Fzzy40ToWhSyncService11 implements SyncService11 {
public class Fzzy40ToWhjlSyncService11 implements SyncService11 {


    @Autowired
@@ -31,7 +31,7 @@

    @Override
    public void syncData(ApiParam param) {
        log.info("--------------基础数据手动配置推送--------");
        log.info("--------------基础数据同步--------");
        String kqdm = param.getKqdm();
        String deptId = param.getDeptId();
        Date start = param.getStart();
@@ -39,6 +39,20 @@

        //同步军工单位信息
        fz40ToWhjlSync1101.syncData(kqdm, deptId, start, end);


        //TODO åŒæ­¥å†›å·¥ç«™ç‚¹ä¿¡æ¯

        //TODO åŒæ­¥å†›ç²®äººå‘˜ä¿¡æ¯

        //TODO åŒæ­¥ä»“房信息

        //TODO åŒæ­¥å»’间信息

        //TODO åŒæ­¥è´§ä½ä¿¡æ¯

        //TODO åŒæ­¥ä»“储设备信息

    }

}

 src/main/java/com/fzzy/async/whhpjl/Fzzy40ToWhjlSyncService12.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,49 @@
package com.fzzy.async.whhpjl;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.util.Date;

/**
 * @Desc: ç²®é£Ÿè´­é”€åŒæ­¥
 *
 * @author: czt
 * @update-time: 2023/08/04
 *
 */
@Slf4j
@Component
public class Fzzy40ToWhjlSyncService12 implements SyncService11 {


    @Override
    public String getProtocol() {
        return SyncProtocol.FZZY_V40_WHJL.getCode();
    }

    @Override
    public void syncData(ApiParam param) {
        log.info("--------------粮食购销数据同步--------");
        String kqdm = param.getKqdm();
        String deptId = param.getDeptId();
        Date start = param.getStart();
        Date end = param.getEnd();

        //TODO åŒæ­¥å®¢æˆ·ä¿¡æ¯

        //TODO åŒæ­¥åˆåŒä¿¡æ¯

        //TODO åŒæ­¥åº“存台账信息

        //TODO åŒæ­¥åº“存台账产品批次信息

        //TODO åŒæ­¥åº“存台账出入信息

        //TODO åŒæ­¥å‡ºå…¥åº“记录

    }

}

 src/main/java/com/fzzy/async/whhpjl/Fzzy40ToWhjlSyncService13.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,44 @@
package com.fzzy.async.whhpjl;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.Date;

/**
 * @Desc: ç²®é£Ÿç®¡ç†åŒæ­¥
 *
 * @author: czt
 * @update-time: 2023/08/04
 *
 */
@Slf4j
@Component
public class Fzzy40ToWhjlSyncService13 implements SyncService11 {


    @Override
    public String getProtocol() {
        return SyncProtocol.FZZY_V40_WHJL.getCode();
    }

    @Override
    public void syncData(ApiParam param) {
        log.info("--------------粮食管理数据同步--------");
        String kqdm = param.getKqdm();
        String deptId = param.getDeptId();
        Date start = param.getStart();
        Date end = param.getEnd();

        //TODO åŒæ­¥è´¨æ£€æŠ¥å‘Š

        //TODO åŒæ­¥ç²®æƒ…检测记录

        //TODO åŒæ­¥èƒ½è€—记录

    }

}

 src/main/java/com/fzzy/push/whhpjl/Whjl2023HttpClientUtil.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,174 @@
package com.fzzy.push.whhpjl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.utils.AESUtils;
import com.fzzy.api.utils.MyMD5Util;
import com.fzzy.api.utils.SnowflakeIdWorker;
import com.fzzy.push.gd2022.dto.GD2022AuthToken;
import com.fzzy.push.whhpjl.dto.WhjlRespDto;
import lombok.extern.slf4j.Slf4j;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.lang.reflect.Type;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Map;

/**
 * æ­¦æ±‰å†›ç²®çœå¹³å°-上传数据服务类
 * @author czt
 * @date 2023/08/04
 */
@Slf4j
public class Whjl2023HttpClientUtil {

    /**
     * post formData
     * @param url
     * @param map
     * @return
     * @throws Exception
     */
    @SuppressWarnings("resource")
    public static WhjlRespDto postGetToken(String url, Map<String, Object> map) throws Exception {
        log.info("---------接口请求地址：" +url+ "----------参数：" + JSON.toJSONString(map) +"---------");
        BufferedReader in = null;
        URL urls = new URL(url);
        HttpURLConnection connection = null;
        OutputStream outputStream = null;
        String rs = "";
        WhjlRespDto responseDto;
        try {
            connection = (HttpURLConnection) urls.openConnection();
            connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
            connection.setDoOutput(true);
            connection.setDoInput(true);
            connection.setRequestProperty("Accept-Language", "zh-CN,zh;q=0.8");
            connection.setRequestProperty("Accept", "*/*");
            connection.setRequestProperty("Range", "bytes=" + "");
            connection.setConnectTimeout(20000);
            connection.setReadTimeout(30000);
            connection.setRequestMethod("POST");

            StringBuffer buffer = new StringBuffer();
            outputStream = connection.getOutputStream();
            buffer.append(JSON.toJSONString(map));
            outputStream.write(buffer.toString().getBytes());
            try {
                connection.connect();
                if (connection.getResponseCode() == 200) {
                    in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
                    String line = "";
                    while ((line = in.readLine()) != null) {
                        rs += line;
                    }
                }else{
                    log.error("http状态：" + connection.getResponseCode());
                    log.error("http消息：" + connection.getResponseMessage());
                }

            } catch (Exception e) {
                System.out.println("发生异常");
                log.error(e.getMessage(),e);
                rs = null;
                return new WhjlRespDto(99,e.getMessage());
            }
            log.info("---------接口返回：" + rs +"---------");

            Type type = new TypeReference<WhjlRespDto<GD2022AuthToken>>() {}.getType();
            responseDto = JSON.parseObject(rs,type);
            if(responseDto == null )   return new WhjlRespDto(99,"接口请求发生未知错误");
            return responseDto;
        } finally {
            try {
                outputStream.close();
                if (in != null){
                    in.close();
                }
            } catch (Exception e) {
            }
            outputStream = null;
            if (connection != null)
                connection.disconnect();
            connection = null;
        }
    }


    /**
     * post formData
     * @param url
     * @return
     * @throws Exception
     */
    @SuppressWarnings("resource")
    public static WhjlRespDto postPushData(String url, String data , ApiConfs apiConfs, GD2022AuthToken authToken) throws Exception {
        log.info("---------接口请求地址：" +url+ "----------参数：" + data +"---------");
        BufferedReader in = null;
        URL urls = new URL(url);
        HttpURLConnection connection = null;
        OutputStream outputStream = null;
        String rs = "";
        WhjlRespDto responseDto;
        try {
            String md = AESUtils.encrypt(data,apiConfs.getPublicKey());
            log.info("---------接口请求地址：" +url+ "----------密文参数：" + md +"---------");
            connection = (HttpURLConnection) urls.openConnection();
            connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
            connection.setDoOutput(true);
            connection.setDoInput(true);
            connection.setRequestProperty("Accept-Language", "zh-CN,zh;q=0.8");
            connection.setRequestProperty("Accept", "*/*");
            connection.setRequestProperty("Range", "bytes=" + "");
            connection.setRequestProperty("Authorization", "Bearer " + authToken.getAccess_token() );
            connection.setRequestProperty("nonce", AESUtils.encrypt(authToken.getAccess_token() + System.currentTimeMillis(),apiConfs.getPublicKey()));
            connection.setRequestProperty("requestId", AESUtils.encrypt(authToken.getAccess_token() + SnowflakeIdWorker.nextId(),apiConfs.getPublicKey()));
            connection.setRequestProperty("digest", MyMD5Util.encrypt(data));
            connection.setConnectTimeout(20000);
            connection.setReadTimeout(30000);
            connection.setRequestMethod("POST");
            StringBuffer buffer = new StringBuffer();
            buffer.append(md);
            outputStream = connection.getOutputStream();
            outputStream.write(buffer.toString().getBytes("UTF-8"));
            try {
                connection.connect();
                if (connection.getResponseCode() == 200) {
                    in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
                    String line = "";
                    while ((line = in.readLine()) != null) {
                        rs += line;
                    }
                }else{
                    log.error("http状态：" + connection.getResponseCode());
                    log.error("http消息：" + connection.getResponseMessage());
                }

            } catch (Exception e) {
                System.out.println("发生异常");
                log.error(e.getMessage(),e);
                rs = null;
                return new WhjlRespDto(99,e.getMessage());
            }
            log.info("---------接口返回：" + rs +"---------");
            responseDto = JSON.parseObject(rs,WhjlRespDto.class);
            if(responseDto == null )   return new WhjlRespDto(99,"接口请求发生未知错误");
            return responseDto;
        } finally {
            try {
                outputStream.close();
                if (in != null){
                    in.close();
                }
            } catch (Exception e) {
            }
            outputStream = null;
            if (connection != null)
                connection.disconnect();
            connection = null;
        }
    }
}

 src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,202 @@
package com.fzzy.push.whhpjl;

import com.alibaba.fastjson.JSON;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.RedisUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.push.whhpjl.dto.WhjlRespDto;
import com.fzzy.whjl.WhjlConstant;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * æ­¦æ±‰å†›ç²®çœå¹³å°-上传数据服务类
 *
 * @author czt
 * @date 2023/08/04
 */
@Slf4j
@Data
@Service
public class WhjlApiRemoteService implements ApiRemoteService {

    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private ApiCommonService apiCommonService;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private ApiLogRep apiLogRep;

    @Override
    public String getProtocol() {
        return PushProtocol.SB_WHJL_2023.getCode();
    }

    @Override
    public ResponseDto pushData(ApiParam param, Object data) {
        return pushData(param, null, data);
    }

    @Override
    public ResponseDto pushData(ApiParam param, ApiConfs conf, Object data) {
        String inteId = param.getInteId();
        String kqdm = param.getKqdm();
        String bizId = param.getBizId();

        try {
            if (null == conf) {
                conf = apiCommonService.getConf(kqdm);
            }

            //添加LOGO
            ApiLog apiLog = new ApiLog();
            apiLog.setId(ContextUtil.getUUID());
            apiLog.setInteId(inteId);
            String jsonData = getJsonData(inteId, data, conf.getApiUrl());
            log.info("报文信息=" + jsonData);
            inteId = getInteId(inteId);
            if (StringUtils.isEmpty(inteId)) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到接口", bizId);
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到接口");
                apiLogRep.save(apiLog);
                return responseDto;
            }
            apiLog.setData(jsonData);
            apiLog.setKqdm(kqdm);
            apiLog.setUploadTime(new Date());

            if (conf == null) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到上传配置", bizId);
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到上传配置");
                apiLogRep.save(apiLog);
                return responseDto;
            }

            Map<String, Object> map = new HashMap<>();
            WhjlRespDto responseDto = Whjl2023HttpClientUtil.postPushData(conf.getApiUrl() + inteId, jsonData, conf, null);
            apiLog.setStatus(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
            apiLog.setResult(responseDto.getResult());
            apiLogRep.save(apiLog);
            ResponseDto resd = new ResponseDto();
            resd.setSuccess(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
            resd.setMsg(responseDto.getResult());
            //updateGD2022AuthToken(responseDto,conf, token);
            return resd;
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            return new ResponseDto(99, e.getMessage());
        }
    }

    /**
     * è°ƒæ•´æ•°æ®å°è£…，获取json数据
     *
     * @param inteId
     * @param data
     * @return
     * @throws Exception
     */
    private String getJsonData(String inteId, Object data, String url) {
        return JSON.toJSONString(data);
    }

    private String getInteId(String inteId) {
        switch (inteId) {
            case "1101":
                return WhjlConstant.API_CODE_JLQYXX;
            case "1102":
                return WhjlConstant.API_CODE_JLZDXX;
            case "1103":
                return WhjlConstant.API_CODE_JLRYXX;
            case "1104":
                return WhjlConstant.API_CODE_FXLYD;
            case "1105":
                return WhjlConstant.API_CODE_CFXX;
            case "1106":
                return WhjlConstant.API_CODE_AJXX;
            case "1107":
                return WhjlConstant.API_CODE_HWXX;
            case "1108":
                return WhjlConstant.API_CODE_CCSSDZDA;
            case "1109":
                return WhjlConstant.API_CODE_CCSSWHJL;
            case "1110":
                return WhjlConstant.API_CODE_CCSSBFJL;
            case "1111":
                return WhjlConstant.API_CODE_CCSBXX;
            case "1112":
                return WhjlConstant.API_CODE_CCSBWHJL;
            case "1113":
                return WhjlConstant.API_CODE_CCSBWXJL;
            case "1114":
                return WhjlConstant.API_CODE_CCSBBFJL;
            case "1201":
                return WhjlConstant.API_CODE_FSGYSXX;
            case "1202":
                return WhjlConstant.API_CODE_FSPPXX;
            case "1203":
                return WhjlConstant.API_CODE_FSCPXX;
            case "1204":
                return WhjlConstant.API_CODE_KHXX;
            case "1205":
                return WhjlConstant.API_CODE_CCJL;
            case "1206":
                return WhjlConstant.API_CODE_DDXX;
            case "1207":
                return WhjlConstant.API_CODE_HTXX;
            case "1208":
                return WhjlConstant.API_CODE_KCTZ;
            case "1209":
                return WhjlConstant.API_CODE_KCTZPCXX;
            case "1210":
                return WhjlConstant.API_CODE_KCTZCRJL;
            case "1211":
                return WhjlConstant.API_CODE_KCPDJL;
            case "1212":
                return WhjlConstant.API_CODE_KNZCJL;
            case "1213":
                return WhjlConstant.API_CODE_CRKJL;
            case "1301":
                return WhjlConstant.API_CODE_ZJJG;
            case "1302":
                return WhjlConstant.API_CODE_ZJBG;
            case "1303":
                return WhjlConstant.API_CODE_LQJCJL;
            case "1304":
                return WhjlConstant.API_CODE_NHJL;
            case "1401":
                return WhjlConstant.API_CODE_DYQY;
            case "1402":
                return WhjlConstant.API_CODE_DYXY;
            case "1403":
                return WhjlConstant.API_CODE_DYNL;
            case "1404":
                return WhjlConstant.API_CODE_DYYJ;
            case "1405":
                return WhjlConstant.API_CODE_SCJGDD;
            case "1406":
                return WhjlConstant.API_CODE_YSLX;
            case "1407":
                return WhjlConstant.API_CODE_YJDD;
            default:
                return inteId;
        }
    }
}

 src/main/java/com/fzzy/push/whhpjl/WhjlPushService11.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,86 @@
package com.fzzy.push.whhpjl;

import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.whjl.WhjlConstant;
import com.fzzy.whjl.dto.WhjlApi1101;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.List;

/**
 * æ­¦æ±‰å†›ç²®çœå¹³å°-基础数据推送
 *
 * @author czt
 * @date 2023/08/04
 */
@Slf4j
@Component
public class WhjlPushService11 implements PushService11 {

    @Autowired
    private WhjlApiRemoteService apiRemoteService;

    @Override
    public String getProtocol() {
        return PushProtocol.SB_WHJL_2023.getCode();
    }

    @Override
    public void pushData(ApiParam param) {
        log.info("武汉军粮省平台--->>>基础信息 ä¸ŠæŠ¥å¼€å§‹");

        //推送军工企业信息
        this.pushData1101(apiRemoteService, param);

        //TODO æŽ¨é€å†›å·¥ç«™ç‚¹ä¿¡æ¯

        //TODO æŽ¨é€å†›ç²®äººå‘˜ä¿¡æ¯

        //TODO æŽ¨é€ä»“房信息

        //TODO æŽ¨é€å»’间信息

        //TODO æŽ¨é€è´§ä½ä¿¡æ¯

        //TODO æŽ¨é€ä»“储设备信息


        log.info("武汉军粮省平台--->>>基础信息 ä¸ŠæŠ¥ç»“束");
    }

    /**
     * 1101 å†›å·¥ä¼ä¸šä¿¡æ¯
     */
    private void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) {

        //TODO èŽ·å–军工企业信息
        List<WhjlApi1101> items = new ArrayList<>();
        if (null == items || items.isEmpty()) {
            return;
        }

        param.setInteCategory(WhjlConstant.API_CATEGORY_11);
        param.setInteId(WhjlConstant.API_CODE_1101);

        ResponseDto responseDto;
        for (WhjlApi1101 data : items) {
            param.setBizId(data.getBizId());
            responseDto = apiRemoteService.pushData(param, data);

            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    //TODO æ›´æ–°æ“ä½œæ ‡å¿—状态

                }
            }
        }
    }
}

 src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,49 @@
package com.fzzy.push.whhpjl;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.service.PushService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * æ­¦æ±‰å†›ç²®çœå¹³å°-粮食购销数据推送
 *
 * @author czt
 * @date 2023/08/04
 */
@Slf4j
@Component
public class WhjlPushService12 implements PushService11 {

    @Autowired
    private WhjlApiRemoteService apiRemoteService;

    @Override
    public String getProtocol() {
        return PushProtocol.SB_WHJL_2023.getCode();
    }

    @Override
    public void pushData(ApiParam param) {
        log.info("武汉军粮省平台--->>>粮食购销 ä¸ŠæŠ¥å¼€å§‹");

        //TODO æŽ¨é€å®¢æˆ·ä¿¡æ¯

        //TODO æŽ¨é€åˆåŒä¿¡æ¯

        //TODO æŽ¨é€åº“存台账信息

        //TODO æŽ¨é€åº“存台账产品批次信息

        //TODO æŽ¨é€åº“存台账出入信息

        //TODO æŽ¨é€å‡ºå…¥åº“记录


        log.info("武汉军粮省平台--->>>粮食购销 ä¸ŠæŠ¥ç»“束");
    }


}

 src/main/java/com/fzzy/push/whhpjl/WhjlPushService13.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,43 @@
package com.fzzy.push.whhpjl;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.service.PushService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * æ­¦æ±‰å†›ç²®çœå¹³å°-粮食管理数据推送
 *
 * @author czt
 * @date 2023/08/04
 */
@Slf4j
@Component
public class WhjlPushService13 implements PushService11 {

    @Autowired
    private WhjlApiRemoteService apiRemoteService;

    @Override
    public String getProtocol() {
        return PushProtocol.SB_WHJL_2023.getCode();
    }

    @Override
    public void pushData(ApiParam param) {
        log.info("武汉军粮省平台--->>>粮食管理 ä¸ŠæŠ¥å¼€å§‹");

        //TODO æŽ¨é€è´¨æ£€æŠ¥å‘Š

        //TODO æŽ¨é€ç²®æƒ…检测记录

        //TODO æŽ¨é€èƒ½è€—记录


        log.info("武汉军粮省平台--->>>粮食管理 ä¸ŠæŠ¥ç»“束");
    }


}

 src/main/java/com/fzzy/push/whhpjl/dto/WhjlRespDto.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package com.fzzy.push.whhpjl.dto;

import lombok.Data;
import java.io.Serializable;

/**
 * æŽ¥å£è¿”回
 * @author czt
 * @date 2023/08/04
 */
@Data
public class WhjlRespDto<T> implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = -6714158228489303453L;

    private int code ;

    private String result;


    public WhjlRespDto() {
    }

    public WhjlRespDto(int code, String result) {
        this.code = code;
        this.result = result;
    }
}

 src/main/java/com/fzzy/whjl/WhjlConstant.java

@@ -36,172 +36,204 @@
    public static String API_CATEGORY_14 = "14";

    /**
     * æŽ¥å£ç¼–码-1101 å•ä½ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1101 å†›ç²®ä¼ä¸šä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1101 = "1101";
    /**
     * æŽ¥å£ç¼–码-1102 åº“区信息数据接口
     * æŽ¥å£ç¼–码-1102 å†›ä¾›ç«™ç‚¹ä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1102 = "1102";
    /**
     * æŽ¥å£ç¼–码-1103 ä»“房信息数据接口
     * æŽ¥å£ç¼–码-1103 å†›ç²®äººå‘˜ä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1103 = "1103";
    /**
     * æŽ¥å£ç¼–码-1104 å»’间信息数据接口
     * æŽ¥å£ç¼–码-1104 æ”¾å¿ƒç²®æ²¹åº—数据接口
     */
    public static String API_CODE_1104 = "1104";
    /**
     * æŽ¥å£ç¼–码-1105 è´§ä½ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1105 ä»“房信息数据接口
     */
    public static String API_CODE_1105 = "1105";
    /**
     * æŽ¥å£ç¼–码-1106 æ²¹ç½ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1106 å»’间信息数据接口
     */
    public static String API_CODE_1106 = "1106";
    /**
     * æŽ¥å£ç¼–码-1107 è®¾å¤‡ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1107 è´§ä½ä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1107 = "1107";
    /**
     * æŽ¥å£ç¼–码-1108 è¯å‰‚信息数据接口
     * æŽ¥å£ç¼–码-1108 ä»“储设施电子档案数据接口
     */
    public static String API_CODE_1108 = "1108";
    /**
     * æŽ¥å£ç¼–码-1109 æ–‡ä»¶ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1109 ä»“储设施维护记录数据接口
     */
    public static String API_CODE_1109 = "1109";
    /**
     * æŽ¥å£ç¼–码-1110 åº“区图仓房点位标注数据接口
     * æŽ¥å£ç¼–码-1110 ä»“储设备报废记录数据接口
     */
    public static String API_CODE_1110 = "1110";
    /**
     * æŽ¥å£ç¼–码-1111 åº“区图视频监控设备点位标注数据接口
     * æŽ¥å£ç¼–码-1111 ä»“储设备信息数据接口
     */
    public static String API_CODE_1111 = "1111";
    /**
     * æŽ¥å£ç¼–码-1112 äººå‘˜ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1112 ä»“储设备维护记录数据接口
     */
    public static String API_CODE_1112 = "1112";
    /**
     * æŽ¥å£ç¼–码-1113 ä¼ä¸šä¿¡ç”¨ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1113 ä»“储设备维修记录数据接口
     */
    public static String API_CODE_1113 = "1113";
    /**
     * æŽ¥å£ç¼–码-1114 ä»“储设备报废记录数据接口
     */
    public static String API_CODE_1114 = "1114";

    /**
     * æŽ¥å£ç¼–码-1201 åˆåŒä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1201 å‰¯é£Ÿä¾›åº”商信息数据接口
     */
    public static String API_CODE_1201 = "1201";
    /**
     * æŽ¥å£ç¼–码-1202 ç²®é£Ÿå…¥åº“信息数据接口
     * æŽ¥å£ç¼–码-1202 å‰¯é£Ÿå“ç‰Œä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1202 = "1202";
    /**
     * æŽ¥å£ç¼–码-1203 ç²®é£Ÿå…¥åº“检验信息数据接口
     * æŽ¥å£ç¼–码-1203 å‰¯é£Ÿäº§å“ä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1203 = "1203";
    /**
     * æŽ¥å£ç¼–码-1204 ç²®é£Ÿå…¥åº“结算信息数据口
     * æŽ¥å£ç¼–码-1204 å®¢æˆ·ä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1204 = "1204";
    /**
     * æŽ¥å£ç¼–码-1205 ç²®é£Ÿå‡ºåº“信息数据接口
     * æŽ¥å£ç¼–码-1205 ç­¹æŽªè®¡åˆ’数据接口
     */
    public static String API_CODE_1205 = "1205";
    /**
     * æŽ¥å£ç¼–码-1206 ç²®é£Ÿå‡ºåº“结算信息数据接口
     * æŽ¥å£ç¼–码-1206 è®¢å•ä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1206 = "1206";
    /**
     * æŽ¥å£ç¼–码-1207 å€’仓信息数据接口
     * æŽ¥å£ç¼–码-1207 åˆåŒä¿¡æ¯æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1207 = "1207";
    /**
     * æŽ¥å£ç¼–码-1208 ç²®é£Ÿåº“存数据接口
     * æŽ¥å£ç¼–码-1208 åº“存台账数据接口
     */
    public static String API_CODE_1208 = "1208";
    /**
     * æŽ¥å£ç¼–码-1209 æŸæº¢å•æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1209 åº“存台账产品批次数据接口
     */
    public static String API_CODE_1209 = "1209";
    /**
     * æŽ¥å£ç¼–码-1210 ç²®é£Ÿæ€§è´¨è½¬å˜å•æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1210 åº“存台账出入记录数据接口
     */
    public static String API_CODE_1210 = "1210";
    /**
     * æŽ¥å£ç¼–码-1211 è´¦é¢åº“存数据接口
     * æŽ¥å£ç¼–码-1211 åº“存盘点记录数据接口
     */
    public static String API_CODE_1211 = "1211";
    /**
     * æŽ¥å£ç¼–码-1212 å®¢æˆ·ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1212 åº“内转仓记录数据接口
     */
    public static String API_CODE_1212 = "1212";
    /**
     * æŽ¥å£ç¼–码-1213 å‡ºå…¥åº“记录数据接口
     */
    public static String API_CODE_1213 = "1213";

    /**
     * æŽ¥å£ç¼–码-1301 å®‰å…¨ç®¡ç†æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1301 è´¨æ£€æœºæž„数据接口
     */
    public static String API_CODE_1301 = "1301";
    /**
     * æŽ¥å£ç¼–码-1302 æ¸©æ¹¿åº¦æ£€æµ‹æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1302 è´¨æ£€æŠ¥å‘Šæ•°æ®æŽ¥å£
     */
    public static String API_CODE_1302 = "1302";
    /**
     * æŽ¥å£ç¼–码-1303 å®³è™«æ£€æµ‹æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1303 ç²®æƒ…检测记录数据接口
     */
    public static String API_CODE_1303 = "1303";
    /**
     * æŽ¥å£ç¼–码-1304 æ°”体检测数据接口
     * æŽ¥å£ç¼–码-1304 èƒ½è€—记录数据接口
     */
    public static String API_CODE_1304 = "1304";
    /**
     * æŽ¥å£ç¼–码-1305 é€šé£Žä½œä¸šæ•°æ®æŽ¥å£
     */
    public static String API_CODE_1305 = "1305";
    /**
     * æŽ¥å£ç¼–码-1306 ç†è’¸ä½œä¸šæ•°æ®æŽ¥å£
     */
    public static String API_CODE_1306 = "1306";
    /**
     * æŽ¥å£ç¼–码-1307 ä»“内视频图像数据接口
     */
    public static String API_CODE_1307 = "1307";
    /**
     * æŽ¥å£ç¼–码-1308 è§†é¢‘监控异常事件告警基本信息数据接口
     */
    public static String API_CODE_1308 = "1308";
    /**
     * æŽ¥å£ç¼–码-1309 è¿è§„预警信息数据接口
     */
    public static String API_CODE_1309 = "1309";
    /**
     * æŽ¥å£ç¼–码-1310 è´¨æ£€æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1310 = "1310";

    /**
     * æŽ¥å£ç¼–码-1401 å‚¨å¤‡è§„模数据接口
     * æŽ¥å£ç¼–码-1401 åŠ¨å‘˜ä¼ä¸šæ•°æ®æŽ¥å£
     */
    public static String API_CODE_1401 = "1401";
    /**
     * æŽ¥å£ç¼–码-1402 å‚¨å¤‡è®¡åˆ’信息数据接口
     * æŽ¥å£ç¼–码-1402 åŠ¨å‘˜åè®®æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1402 = "1402";
    /**
     * æŽ¥å£ç¼–码-1403 è½®æ¢è®¡åˆ’信息数据接口
     * æŽ¥å£ç¼–码-1403 åŠ¨å‘˜èƒ½åŠ›æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1403 = "1403";
    /**
     * æŽ¥å£ç¼–码-1404 è½®æ¢è®¡åˆ’明细信息数据接口
     * æŽ¥å£ç¼–码-1404 åŠ¨å‘˜é¢„警数据接口
     */
    public static String API_CODE_1404 = "1404";
    /**
     * æŽ¥å£ç¼–码-1405 é¡¹ç›®ä¿¡æ¯æ•°æ®æŽ¥å£
     * æŽ¥å£ç¼–码-1405 ç”Ÿäº§åŠ å·¥è®¢å•æ•°æ®æŽ¥å£
     */
    public static String API_CODE_1405 = "1405";
    /**
     * æŽ¥å£ç¼–码-1406 è¿è¾“路线数据接口
     */
    public static String API_CODE_1406 = "1406";
    /**
     * æŽ¥å£ç¼–码-1407 åº”急调度数据接口
     */
    public static String API_CODE_1407 = "1407";

    public static String API_CODE_1501 = "1501";
    public static String API_CODE_1502 = "1502";
    public static String API_CODE_1503 = "1503";
    /*----------接口路径----------*/
    /**
     * æŽ¥å£ç¼–码-1001 å†›ç²®ä¼ä¸šä¿¡æ¯æŽ¥å£
     */
    public static String API_CODE_JLQYXX = "JLQYXX";   //接口编码-1101 å†›ç²®ä¼ä¸šä¿¡æ¯     --路径(JLQYXX)
    public static String API_CODE_JLZDXX = "JLZDXX";   //接口编码-1102 å†›ä¾›ç«™ç‚¹ä¿¡æ¯     --路径(JLZDXX)
    public static String API_CODE_JLRYXX = "JLRYXX";   //接口编码-1103 å†›ç²®äººå‘˜ä¿¡æ¯     --路径(JLRYXX)
    public static String API_CODE_FXLYD = "FXLYD";   //接口编码-1104 æ”¾å¿ƒç²®æ²¹åº—       --路径(FXLYD)
    public static String API_CODE_CFXX = "CFXX";   //接口编码-1105 ä»“房信息         --路径(CFXX)
    public static String API_CODE_AJXX = "AJXX";   //接口编码-1106 å»’间信息         --路径(AJXX)
    public static String API_CODE_HWXX = "HWXX";   //接口编码-1107 è´§ä½ä¿¡æ¯         --路径(HWXX)
    public static String API_CODE_CCSSDZDA = "CCSSDZDA";   //接口编码-1108 ä»“储设施电子档案 --路径(CCSSDZDA)
    public static String API_CODE_CCSSWHJL = "CCSSWHJL";   //接口编码-1109 ä»“储设施维护记录 --路径(CCSSWHJL)
    public static String API_CODE_CCSSBFJL = "CCSSBFJL";   //接口编码-1110 ä»“储设备报废记录 --路径(CCSBBFJL)
    public static String API_CODE_CCSBXX = "CCSBXX";   //接口编码-1111 ä»“储设备信息     --路径(CCSBXX)
    public static String API_CODE_CCSBWHJL = "CCSBWHJL";   //接口编码-1112 ä»“储设备维护记录 --路径(CCSBWHJL)
    public static String API_CODE_CCSBWXJL = "CCSBWXJL";   //接口编码-1113 ä»“储设备维修记录 --路径(CCSBWXJL)
    public static String API_CODE_CCSBBFJL = "CCSBBFJL";   //接口编码-1114 ä»“储设备报废记录 --路径(CCSBBFJL)
    public static String API_CODE_FSGYSXX = "FSGYSXX";   //接口编码-1201 å‰¯é£Ÿä¾›åº”商信息   --路径(FSGYSXX)
    public static String API_CODE_FSPPXX = "FSPPXX";   //接口编码-1202 å‰¯é£Ÿå“ç‰Œä¿¡æ¯     --路径(FSPPXX)
    public static String API_CODE_FSCPXX = "FSCPXX";   //接口编码-1203 å‰¯é£Ÿäº§å“ä¿¡æ¯     --路径(FSCPXX)
    public static String API_CODE_KHXX = "KHXX";   //接口编码-1204 å®¢æˆ·ä¿¡æ¯         --路径(KHXX)
    public static String API_CODE_CCJL = "CCJL";   //接口编码-1205 ç­¹æŽªè®¡åˆ’         --路径(CCJL)
    public static String API_CODE_DDXX = "DDXX";   //接口编码-1206 è®¢å•ä¿¡æ¯         --路径(DDXX)
    public static String API_CODE_HTXX = "HTXX";   //接口编码-1207 åˆåŒä¿¡æ¯         --路径(HTXX)
    public static String API_CODE_KCTZ = "KCTZ";   //接口编码-1208 åº“存台账         --路径(KCTZ)
    public static String API_CODE_KCTZPCXX = "KCTZPCXX";   //接口编码-1209 åº“存台账产品批次 --路径(KCTZPCXX)
    public static String API_CODE_KCTZCRJL = "KCTZCRJL";   //接口编码-1210 åº“存台账出入记录 --路径(KCTZCRJL)
    public static String API_CODE_KCPDJL = "KCPDJL";   //接口编码-1211 åº“存盘点记录     --路径(KCPDJL)
    public static String API_CODE_KNZCJL = "KNZCJL";   //接口编码-1212 åº“内转仓记录     --路径(KNZCJL)
    public static String API_CODE_CRKJL = "CRKJL";   //接口编码-1213 å‡ºå…¥åº“记录       --路径(CRKJL)
    public static String API_CODE_ZJJG = "ZJJG";   //接口编码-1301 è´¨æ£€æœºæž„         --路径(ZJJG)
    public static String API_CODE_ZJBG = "ZJBG";   //接口编码-1302 è´¨æ£€æŠ¥å‘Š         --路径(ZJBG)
    public static String API_CODE_LQJCJL = "LQJCJL";   //接口编码-1303 ç²®æƒ…检测记录     --路径(LQJCJL)
    public static String API_CODE_NHJL = "NHJL";   //接口编码-1304 èƒ½è€—记录         --路径(NHJL)
    public static String API_CODE_DYQY = "DYQY";   //接口编码-1401 åŠ¨å‘˜ä¼ä¸š         --路径(DYQY)
    public static String API_CODE_DYXY = "DYXY";   //接口编码-1402 åŠ¨å‘˜åè®®         --路径(DYXY)
    public static String API_CODE_DYNL = "DYNL";   //接口编码-1403 åŠ¨å‘˜èƒ½åŠ›         --路径(DYNL)
    public static String API_CODE_DYYJ = "DYYJ";   //接口编码-1404 åŠ¨å‘˜é¢„è­¦         --路径(DYYJ)
    public static String API_CODE_SCJGDD = "SCJGDD";   //接口编码-1405 ç”Ÿäº§åŠ å·¥è®¢å•     --路径(SCJGDD)
    public static String API_CODE_YSLX = "YSLX";   //接口编码-1406 è¿è¾“路线         --路径(YSLX)
    public static String API_CODE_YJDD = "YJDD";   //接口编码-1407 åº”急调度         --路径(YJDD)

    /**
     * å›½æ ‡å‡ºå…¥åº“类型
     */

 src/main/java/com/fzzy/whjl/dto/WhjlApi1101.java

@@ -53,4 +53,5 @@

    private String bizId;  //业务ID
    private Date updateTime;  //最后更新时间
    private String czbz;  //操作标志
}