提交上海嘉定纪委-单位接口信息

陈战涛

2023-05-09 8f432dc748b977cbf7f0f80a8da4ff83569df363

提交上海嘉定纪委-单位接口信息

 src/main/java/com/fzzy/api/view/repository/Api1102Rep.java

@@ -7,6 +7,8 @@
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;


public interface Api1102Rep extends JpaRepository<Api1102, String> {

@@ -16,4 +18,12 @@
    @Query("update Api1102 set czbz=:czbz where kqdm=:id ")
    int updateStatus(@Param("id") String id, @Param("czbz") String czbz);


    /**
     * æŸ¥è¯¢æ‰€æœ‰çš„监控点位信息
     * @param kqdm
     * @return
     */
    @Query("from Api1102 where kqdm=:kqdm ")
    List<Api1102> findPushData(@Param("kqdm") String kqdm);
}

 src/main/java/com/fzzy/api/view/repository/Api1103Rep.java

@@ -6,6 +6,7 @@
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;


public interface Api1103Rep extends JpaRepository<Api1103, String> {
@@ -13,4 +14,12 @@
    @Modifying
    @Query("update Api1103 set czbz=:czbz where cfdm =:id ")
    int updateStatus(@Param("id") String id, @Param("czbz") String czbz);

    /**
     * æŸ¥è¯¢æ‰€æœ‰çš„监控点位信息
     * @param kqdm
     * @return
     */
    @Query("from Api1103 where kqdm=:kqdm ")
    List<Api1103> findPushData(@Param("kqdm") String kqdm);
}

 src/main/java/com/fzzy/async/fzzy35/entity/Building.java

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

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.io.Serializable;
import java.util.Date;

/**
 * å»ºç­‘物，包括仓房和其他房子
 * <p>
 * ä»“库的敖间使用的是：Depot类，一个仓房建筑可能包含多个敖间。
 * <p>
 * å½“前定义对象仅仅用于建筑物的数据配置
 */
@Data
@Entity
@Table(name = "D_BUILDING")
public class Building implements Serializable {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    @Id
    @Column(name = "ID_", length = 50)
    @PropertyDef(label = "仓房编码")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属库点")
    private String deptId;

    @Column(name = "NAME_", length = 50)
    @PropertyDef(label = "建筑名称")
    private String name;

    @Column(name = "STORAGE_")
    @PropertyDef(label = "设计储量", description = "单位：KG")
    private Double storage;

    @Column(name = "USER_DATE_")
    @PropertyDef(label = "使用日期")
    private Date userDate;

    @Column(name = "HEIGHT_", precision = 16, scale = 2)
    @PropertyDef(label = "仓房高度", description = "单位：米")
    private Double height;

    @Column(name = "LENGTH_", precision = 16, scale = 2)
    @PropertyDef(label = "仓房长度", description = "单位：米")
    private Double length;

    @Column(name = "WIDTH_", precision = 16, scale = 2)
    @PropertyDef(label = "仓房宽度", description = "单位：米")
    private Double width;

    @Column(name = "DIAMETER_", precision = 16, scale = 2)
    @PropertyDef(label = "筒仓直径", description = "单位：米")
    private Double diameter;

    @Column(name = "VOLUME_", precision = 16, scale = 2)
    @PropertyDef(label = "筒仓体积", description = "单位：立方米")
    private Double volume;

    @Column(name = "DOOR_NUM_")
    @PropertyDef(label = "仓门数")
    private Integer doorNum;

    @Column(name = "GROUND_", length = 20)
    @PropertyDef(label = "地面结构")
    private String ground;

    @Column(name = "WALL_", length = 20)
    @PropertyDef(label = "墙体结构")
    private String wall;

    @Column(name = "ROOF_", length = 20)
    @PropertyDef(label = "屋顶结构")
    private String roof;

    @Column(name = "ROOF_TRUSS_", length = 20)
    @PropertyDef(label = "屋架结构")
    private String roofTruss;

    @Column(name = "CREATE_DATE_")
    @PropertyDef(label = "建造日期")
    private Date createDate;
    
    @Column(name = "LON_", precision = 16, scale = 4)
    @PropertyDef(label = "经度")
    private Double lon;

    @Column(name = "LAT_", precision = 16, scale = 4)
    @PropertyDef(label = "纬度")
    private Double lat;
}

 src/main/java/com/fzzy/async/fzzy35/entity/DefaultDept.java

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

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

/**
 * @since 2013-1-22
 * @author Jacky.gao
 */
@Data
@Entity
@Table(name = "BDF2_DEPT")
public class DefaultDept implements Serializable {

    private static final long serialVersionUID = -7669420244144806105L;

    // ----------业务公共字段-------//
    @Id
    @Column(name = "ID_", length = 60)
    private String id;

    @Column(name = "COMPANY_ID_", length = 60)
    private String companyId;

    @Column(name = "PARENT_ID_", length = 60)
    private String parentId;

    @Column(name = "CREATE_DATE_")
    @PropertyDef(label = "建成时间")
    private Date createDate;

    @Column(name = "NAME_", length = 60)
    private String name;

    @Column(name = "DESC_", length = 1000)
    private String desc;

    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "类型", description = "组织,库点")
    private String type;

    @Column(name = "CODE_", length = 60)
    @PropertyDef(label = "编码", description = "用于上报的组织编码")
    private String code;

    @PropertyDef(label = "所在省")
    @Column(name = "PROVINCE_", length = 30)
    private String province;

    @PropertyDef(label = "所在城市")
    @Column(name = "CITY_", length = 30)
    private String city;

    @PropertyDef(label = "所在区县")
    @Column(name = "COUNTRY_", length = 30)
    private String country;

    @Column(name = "LON_")
    @PropertyDef(label = "经度")
    private Double lon;

    @Column(name = "LAT_")
    @PropertyDef(label = "纬度")
    private Double lat;

    @Column(name = "POST_CODE_", length = 10)
    @PropertyDef(label = "邮编")
    private String postCode;

    @Column(name = "BUILDING_NUM_")
    @PropertyDef(label = "仓房数")
    private Integer buildingNum;

    @Column(name = "OIL_NUM_")
    @PropertyDef(label = "油罐数")
    private Integer oilNum;

    @PropertyDef(label = "地址")
    @Column(name = "ADDRESS_", length = 200)
    private String address;

    @PropertyDef(label = "联系人")
    @Column(name = "CONTACT_", length = 50)
    private String contact;

    @PropertyDef(label = "联系电话")
    @Column(name = "PHONE_", length = 20)
    private String phone;

    @Column(name = "FAX_", length = 20)
    @PropertyDef(label = "传真")
    private String fax;

    // ----------单位字段-------//
    @Column(name = "COMPANY_TYPE_", length = 10)
    @PropertyDef(label = "单位类型", description = "1-粮食仓储企业;2-粮食购销企业;3-粮食加工企业;4-粮食设备制造企业;9-其他粮食企业")
    private String companyType;

    @Column(name = "NATURE_", length = 10)
    @PropertyDef(label = "企业性质", description = "1-固有企业;2-民营企业;3-事业单位;9-其他内资企业;10-港澳台商投资企业;11-外商投资企业;")
    private String nature;

    @Column(name = "LEGAL_PERSON_", length = 30)
    @PropertyDef(label = "法人")
    private String legalPerson;

    @Column(name = "DEPT_NUM_")
    @PropertyDef(label = "库区数")
    private Integer deptNum;

    @Column(name = "REGISTER_CODE_", length = 30)
    @PropertyDef(label = "工商登记注册号")
    private String registerCode;

    @Column(name = "CREDIT_CODE_", length = 20)
    @PropertyDef(label = "信用编码")
    private String creditCode;

    // ----------库区字段-------//
    @Column(name = "DEPOT_NUM_")
    @PropertyDef(label = "廒间数")
    private Integer depotNum;

    @Column(name = "STORAGE_")
    @PropertyDef(label = "库点设计储量", description = "单位：吨")
    private Double storage;

    @Column(name = "OIL_STORAGE_")
    @PropertyDef(label = "库点设计罐容", description = "单位：吨")
    private Double oilStorage;

    @Column(name = "AREA_")
    @PropertyDef(label = "库点设计面积", description = "单位：㎡")
    private Double area;

    @Column(name = "ACTING_RESERVE_", length = 1)
    @PropertyDef(label = "是否代储", description = "1-是; 0-否")
    private String actingReserve = "0";

    @Column(name = "PROPERTY_RIGHT_", length = 2)
    @PropertyDef(label = "库区产权", description = "1-自有; 2-租赁；9-其他")
    private String propertyRight = "1";

    @Column(name = "VAL_", length = 1)
    @PropertyDef(label = "是否启用")
    private String val;
}

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1101.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.DefaultDept;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1101Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;

/**
 * å•ä½ä¿¡æ¯
 */
@Slf4j
@Component
public class Fzzy35Sync1101 {

    @Autowired
    private Fzzy35Sync1101Rep fzzy35Sync1101Rep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å•ä½ä¿¡æ¯
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1111接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1111);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<DefaultDept> list = fzzy35Sync1101Rep.listDept(deptId.substring(0, 4));

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到单位信息------------------");
                return;
            }
            Api1101 apiData;
            for (DefaultDept sysData : list) {

                //TODO
//                apiData = new Api1101();
//
//                api1101Rep.save(apiData);
//                log.info("1111---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---文件同步执行失败----{}", e);
            apiLog.setResult("同步文件信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1102.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.DefaultDept;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1101Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;

/**
 * åº“区信息
 */
@Slf4j
@Component
public class Fzzy35Sync1102 {

    @Autowired
    private Fzzy35Sync1101Rep fzzy35Sync1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å•ä½ä¿¡æ¯
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1102接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1111);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<DefaultDept> list = fzzy35Sync1101Rep.listDept(deptId);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到库区信息------------------");
                return;
            }
            Api1102 apiData;
            for (DefaultDept sysData : list) {

                //TODO
//                apiData = new Api1101();
//
//                api1102Rep.save(apiData);
//                log.info("1111---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---库区同步执行失败----{}", e);
            apiLog.setResult("同步库区信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1103.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.Building;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1103Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;

/**
 * ä»“房信息
 */
@Slf4j
@Component
public class Fzzy35Sync1103 {

    @Autowired
    private Fzzy35Sync1103Rep fzzy35Sync1103Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å•ä½ä¿¡æ¯
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1103接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1111);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Building> list = fzzy35Sync1103Rep.listBuilding(deptId);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到单位信息------------------");
                return;
            }
            Api1101 apiData;
            for (Building sysData : list) {

                //TODO
//                apiData = new Api1101();
//
//                api1103Rep.save(apiData);
//                log.info("1111---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---仓房同步执行失败----{}", e);
            apiLog.setResult("同步仓房信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy35/repository/Fzzy35Sync1101Rep.java

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

import com.fzzy.async.fzzy35.entity.DefaultDept;
import com.fzzy.async.fzzy35.entity.MContract;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import java.util.List;

/**
 * åŸºç¡€ä¿¡æ¯-单位及库区信息
 */
public interface Fzzy35Sync1101Rep extends JpaRepository<MContract, String> {

    /**
     * èŽ·å–单位或库区信息
     *
     * @return
     */
    @Query("from DefaultDept where id=:id ")
    List<DefaultDept> listDept(@Param("id") String id);
}

 src/main/java/com/fzzy/async/fzzy35/repository/Fzzy35Sync1102Rep.java

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

import com.fzzy.async.fzzy35.entity.MContract;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.Date;
import java.util.List;

/**
 * ç²®é£Ÿè´­é”€-合同信息数据接口数据获取
 */
public interface Fzzy35Sync1102Rep extends JpaRepository<MContract, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–合同信息
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from MContract where deptId=:deptId and createTime >=:start and createTime <:end order by createTime ")
    List<MContract> listContract(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy35/repository/Fzzy35Sync1103Rep.java

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

import com.fzzy.async.fzzy35.entity.Building;
import com.fzzy.async.fzzy35.entity.MContract;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import java.util.List;

/**
 * åŸºç¡€ä¿¡æ¯-仓房信息
 */
public interface Fzzy35Sync1103Rep extends JpaRepository<MContract, String> {

    /**
     * èŽ·å–仓房信息
     *
     * @return
     */
    @Query("from Building where deptId=:deptId ")
    List<Building> listBuilding(@Param("deptId") String deptId);
}

 src/main/java/com/fzzy/push/gd2022/dto/Api1101.java

@@ -7,11 +7,7 @@
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springframework.format.annotation.DateTimeFormat;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.io.Serializable;
import java.util.Date;


 src/main/java/com/fzzy/push/impl/ComPushService11.java

@@ -4,9 +4,11 @@
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1111;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1111Rep;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -24,6 +26,8 @@
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1111Rep api1111Rep;

    /**
@@ -37,7 +41,7 @@
        }

        param.setInteCategory(Constant.API_CATEGORY_11);
        param.setInteId(Constant.API_CODE_1111);
        param.setInteId(Constant.API_CODE_1101);

        ResponseDto responseDto;
        for (Api1101 data : items) {
@@ -53,6 +57,32 @@
    }

    /**
     * 1101 åº“区信息
     */
    public void pushData1102(ApiRemoteService apiRemoteService, ApiParam param) {

        List<Api1102> items = api1102Rep.findPushData(param.getKqdm());
        if (null == items || items.isEmpty()) {
            return;
        }

        param.setInteCategory(Constant.API_CATEGORY_11);
        param.setInteId(Constant.API_CODE_1102);

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

            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1102Rep.updateStatus(data.getDwdm(), Constant.CZBZ_U);
                }
            }
        }
    }

    /**
     * 1111 åº“区图视频监控设备点位标注
     */
    public void pushData1111(ApiRemoteService apiRemoteService, ApiParam param) {

 src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023HttpClientUtil.java

@@ -1,21 +1,15 @@
package com.fzzy.push.shjdjw2023;

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.gd2022.dto.GD2022ResponseDto;
import com.fzzy.push.shjdjw2023.dto.ShjdjwRespDto;
import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang.StringUtils;
import java.io.*;
import java.lang.reflect.Type;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Map;
import java.util.UUID;

/**
 * ä¸Šæµ·å˜‰å®šçºªå§”监管平台-上传数据服务类
@@ -32,16 +26,16 @@
     * @throws Exception
     */
    @SuppressWarnings("resource")
    public static GD2022ResponseDto postPushData(String url, String data , ApiConfs apiConfs) throws Exception {
    public static ShjdjwRespDto postPushData(String url, String data , ApiConfs apiConfs) throws Exception {
        log.info("---------接口请求地址：" +url+ "----------参数：" + data +"---------");
        BufferedReader in = null;
        URL urls = new URL(url);
        HttpURLConnection connection = null;
        OutputStream outputStream = null;
        String rs = "";
        GD2022ResponseDto responseDto;
        ShjdjwRespDto responseDto = null;
        try {
            String md = AESUtils.encryptByEcb(data, apiConfs.getPublicKey());
            String md = AESUtils.encrypt(data, apiConfs.getPublicKey());
            log.info("---------接口请求地址：" +url+ "----------密文参数：" + md +"---------");
            connection = (HttpURLConnection) urls.openConnection();
            connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
@@ -75,11 +69,17 @@
                System.out.println("发生异常");
                log.error(e.getMessage(),e);
                rs = null;
                return new GD2022ResponseDto(99,e.getMessage());
                return new ShjdjwRespDto(99,e.getMessage());
            }
            log.info("---------接口返回：" + rs +"---------");
            responseDto = JSON.parseObject(rs,GD2022ResponseDto.class);
            if(responseDto == null )   return new GD2022ResponseDto(99,"接口请求发生未知错误");
            if(StringUtils.isNotEmpty(rs)){
                rs = rs.replaceAll("\"", "");
                log.info("---------接口返回，秘文：" + rs +"---------");
                rs = AESUtils.decrypt(rs, apiConfs.getPublicKey());
                log.info("---------接口返回，解析后：" + rs +"---------");
                responseDto = JSON.parseObject(rs, ShjdjwRespDto.class);
            }

            if(responseDto == null )   return new ShjdjwRespDto(99,"接口请求发生未知错误");
            return responseDto;
        } finally {
            try {

 src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService11.java

@@ -1,21 +1,12 @@
package com.fzzy.push.shjdjw2023;

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.entity.Api1101;
import com.fzzy.api.entity.Api1109;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * ä¸Šæµ·å˜‰å®šçºªå§”监管平台-基础数据上传
@@ -31,8 +22,6 @@

    @Autowired
    private ComPushService11 pushService;
    @Autowired
    private Api1101Rep api1101Rep;

    @Override
    public String getProtocol() {
@@ -43,34 +32,9 @@
    public void pushData(ApiParam param) {
        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报开始");

        //单位信息
        this.pushData(param);
        //获取库区信息，推送为单位信息
        pushService.pushData1102(apiRemoteService, param);

        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报结束");

    }

    /**
     * 1101 å•ä½ä¿¡æ¯
     */
    private void pushData1101(ApiParam param) {
        List<Api1101> items = api1101Rep.findPushData(param.getKqdm());
        if (null == items || items.isEmpty()) {
            return;
        }

        param.setInteCategory(Constant.API_CATEGORY_11);
        param.setInteId(Constant.API_CODE_1111);

        ResponseDto responseDto = apiRemoteService.pushData(param, items);
        if (responseDto.getSuccess() == 0) {
            for (Api1101 data : items) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1101Rep.updateStatus(data.getDwdm(), Constant.CZBZ_U);
                }

            }
        }
    }

}

 src/main/java/com/fzzy/push/shjdjw2023/ShjdjwApiRemoteService2023.java

@@ -5,18 +5,24 @@
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1103;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.RedisUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1103Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.push.gd2022.dto.*;
import com.fzzy.push.shjdjw2023.dto.ShjdjwApi1101;
import com.fzzy.push.shjdjw2023.dto.ShjdjwReqDto;
import com.fzzy.push.shjdjw2023.dto.ShjdjwRespDto;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@@ -35,12 +41,14 @@

    @Autowired
    private RedisUtil redisUtil;

    @Autowired
    private ApiCommonService apiCommonService;

    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1103Rep api1103Rep;


    @Override
@@ -94,14 +102,14 @@
            }

            Map<String, Object> map = new HashMap<>();
            GD2022ResponseDto responseDto = Shjdjw2023HttpClientUtil.postPushData(conf.getApiUrl() + inteId, jsonData, conf);
            ShjdjwRespDto responseDto = Shjdjw2023HttpClientUtil.postPushData(conf.getApiUrl(), jsonData, conf);
            responseDto.setBizId(bizId);
            apiLog.setStatus(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
            apiLog.setResult(responseDto.getMsg());
            apiLog.setStatus(responseDto.getCode() == 1 ? 0 : responseDto.getCode());
            apiLog.setResult(responseDto.getDescription());
            apiLogRep.save(apiLog);
            ResponseDto resd = new ResponseDto();
            resd.setSuccess(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
            resd.setMsg(responseDto.getMsg());
            resd.setSuccess(responseDto.getCode() == 1 ? 0 : responseDto.getCode());
            resd.setMsg(responseDto.getDescription());
            //updateGD2022AuthToken(responseDto,conf, token);
            return resd;
        } catch (Exception e) {
@@ -121,17 +129,40 @@
    private String getJsonData(String inteId, Object data, String interfaceId) {
        ShjdjwReqDto<Object> dto = new ShjdjwReqDto<>();
        dto.setId(getDataId(interfaceId));
        List<Object> list = new ArrayList<>();
        //转换封装
        if (Constant.API_CODE_1101.equals(inteId)) {
            dto.setData(data);
        if (Constant.API_CODE_1102.equals(inteId)) {
            ShjdjwApi1101 shjdjwApi1101 = new ShjdjwApi1101();
            BeanUtils.copyProperties(data, shjdjwApi1101);
            //查询单位信息
            List<Api1101> listApi1101 = api1101Rep.findPushData(shjdjwApi1101.getKqdm());
            Api1101 api1101 = null;
            if(null != listApi1101 && listApi1101.size() > 0){
                api1101 = listApi1101.get(0);
            }
            if(null != api1101){
                shjdjwApi1101.setDwmc(api1101.getDwmc());
                shjdjwApi1101.setKqs(api1101.getKqs());
            }
            //查询仓房信息
            List<Api1103> listApi1103 = api1103Rep.findPushData(shjdjwApi1101.getKqdm());
            if(null != listApi1103 && listApi1103.size() > 0){
                for(int i = 0; i < listApi1103.size(); i++){
                    if(i == 0){
                        shjdjwApi1101.setCfmc(listApi1103.get(i).getCfmc());
                    }else {
                        shjdjwApi1101.setCfmc(shjdjwApi1101.getCfmc() + "#" + listApi1103.get(i).getCfmc());
                    }
                }
            }
            //单位信息封装
            list.add(shjdjwApi1101);
        } else if (Constant.API_CODE_1202.equals(inteId)) {


            dto.setData(data);
            list.add(data);
        } else {
            dto.setData(data);
            list.add(data);
        }

        dto.setData(list);
        return JSON.toJSONString(dto);
    }

@@ -143,7 +174,8 @@
     */
    private String getDataId(String inteId) {
        switch (inteId) {
            case "1101":
            case "1102":
                //单位接口编码
                return ShjdjwApiCodeConstant.API_CODE_LS1101;
            case "1202":
                return ShjdjwApiCodeConstant.API_CODE_LS1302;

 src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1101.java

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

import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
import lombok.EqualsAndHashCode;
import com.bstek.dorado.annotation.PropertyDef;
import java.io.Serializable;

/**
 * @author czt
 * @date 2023/5/9  19:27
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class ShjdjwApi1101 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "单位名称")
    private String dwmc;

    @PropertyDef(label = "库区数")
    private Integer kqs;

    @JSONField(serialize = false)
    @PropertyDef(label = "库区代码" )
    private String kqdm;

    @PropertyDef(label = "库区名称" )
    private String kqmc;

    @PropertyDef(label = "仓房数" )
    private Integer cfs;

    @PropertyDef(label = "仓房名称", description = "多个用#隔开")
    private String cfmc;

    @PropertyDef(label = "操作标志" )
    private String czbz;

}

 src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwRespDto.java

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

import lombok.Data;

import java.io.Serializable;

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



    private int code ;

    private String description;

    private String bizId;

    private  T data;

    public ShjdjwRespDto() {
    }

    public ShjdjwRespDto(int code, String description) {
        this.code = code;
        this.description = description;
    }
    public ShjdjwRespDto(int code, String description, String bizId) {
        this.code = code;
        this.description = description;
        this.bizId = bizId;
    }
}