调整上海接口数据实时性

CZT

2024-01-15 a1d6638c3dad0a2c42aa3f35b0c080738f69bd9b

调整上海接口数据实时性

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1307.java

@@ -125,7 +125,7 @@
                if(null != apiConfs && PushProtocol.SB_SH_2023.getCode().equals(apiConfs.get(0).getPushProtocol())){
                    api1109 = new Api1109();
                    //主键id
                    api1109.setId(UUID.randomUUID().toString());
                    api1109.setId(apiData.getId());
                    //文件路径
                    api1109.setWjdz(apiData.getWjdz());
                    //文件名称
@@ -141,9 +141,9 @@
                    api1109.setSyncTime(new Date());
                    api1109List = api1109Rep.getDataByBizId(api1109.getBizId());
                    if (null == api1109List || api1109List.isEmpty()) {
                        apiData.setCzbz(Constant.CZBZ_I);
                        api1109.setCzbz(Constant.CZBZ_I);
                    } else {
                        apiData.setCzbz(api1109List.get(0).getCzbz());
                        api1109.setCzbz(api1109List.get(0).getCzbz());
                    }
                    //保存数据
                    api1109Rep.save(api1109);

 src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java

@@ -239,6 +239,12 @@
        } else {
            List<Object> list = new ArrayList<>();
            Object object = getJsonApiData(inteId, data, code);

            //除库存接口外，其他接口上传前更新最后更新时间
            if(!SH2023Constant.SH_2023_API_CODE_1208.equals(inteId)){
                setZhgxsjValue(object);
            }

            list.add(object);
            return JSON.toJSONString(list);
        }
@@ -979,6 +985,23 @@
    }

    /**
     * 赋值最后更新时间
     * @param object
     * @return
     */
    private Object setZhgxsjValue(Object object) {
        // 使用反射获取属性列表 vo为实体对象名
        try {
            Field zhgxsj = object.getClass().getDeclaredField("zhgxsj");
            zhgxsj.setAccessible(true);
            zhgxsj.set(object, new Date());
        } catch (Exception e) {
            e.printStackTrace();
        }
        return object;
    }

    /**
     * 根据上海数据格式进行封装
     * 层均温：
     * 层高温：
@@ -1123,7 +1146,7 @@
        shFinanceDto.setBbsj(DateFormatUtils.format(api1503.getBbsj(), "yyyyMMdd"));
        shFinanceDto.setBbm("03");
        shFinanceDto.setCzbz(api1503.getCzbz());
        shFinanceDto.setZhgxsj(DateFormatUtils.format(api1503.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));
        shFinanceDto.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));

        paddingData(shFinanceDto, list, "项目//t", "本期金额//t", "本年累计//t");
        paddingData(shFinanceDto, list, "一、营业收入", api1503.getYyzsrbqye() + "", api1503.getYyzsrbnlj() + "");
@@ -1173,7 +1196,7 @@
        shFinanceDto.setBbsj(DateFormatUtils.format(api1502.getBbsj(), "yyyyMMdd"));
        shFinanceDto.setBbm("02");
        shFinanceDto.setCzbz(api1502.getCzbz());
        shFinanceDto.setZhgxsj(DateFormatUtils.format(api1502.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));
        shFinanceDto.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));

        paddingData(shFinanceDto, list, "项目//t", "本月数//t", "本年累计数//t");
        paddingData(shFinanceDto, list, "一、经营活动产生的现金流量：", api1502.getJyhdxjllbys() + "", api1502.getJyhdxjllbnljs() + "");
@@ -1225,7 +1248,7 @@
        shFinanceDto.setBbsj(DateFormatUtils.format(api1501.getBbsj(), "yyyyMMdd"));
        shFinanceDto.setBbm("01");
        shFinanceDto.setCzbz(api1501.getCzbz());
        shFinanceDto.setZhgxsj(DateFormatUtils.format(api1501.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));
        shFinanceDto.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));

        paddingData(shFinanceDto, list, "资产//t", "期末余额//t", "年初余额//t");
        paddingData(shFinanceDto, list, "流动资产：", api1501.getLdzchjqmye() + "", api1501.getLdzchjncye() + "");

 src/main/resources/application-linux.yml

@@ -52,5 +52,5 @@
igds:
  default:
    companyId: 5327
  file-path: /usr/local/igds-api/file/
  img-path: /usr/local/igds/file/
  file-path: /home/igds-api/file/
  img-path: /home/igds/file/