调整上海接口数据实时性

CZT

2024-01-15 a1d6638c3dad0a2c42aa3f35b0c080738f69bd9b

 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);
        }
@@ -559,8 +565,6 @@
                api1205.setPch(apiData.getHwdm() + api1208List.get(0).getShnd());
            }

            //粮食性质
            api1205.setLsxzdm("200");
            //设置空属性为默认值
            changeObject(api1205);
            return api1205;
@@ -659,19 +663,21 @@
                api1210.setPch(apiData.getHwdm() + api1208List.get(0).getShnd());
            }

            //设置计划明细号，根据划转性质查询出入库信息获取计划号
            if("200".equals(api1210.getHzqlsxzdm())){
                //若划转前性质为商品粮，则查询入库信息获取计划明细号
                List<Api1202> api1202List = api1202Rep.getDataByHwdmAndTime(api1210.getHwdm(), api1210.getHzrq());
                if (null != api1202List && api1202List.size() > 0) {
                    api1210.setJhmxdh(api1202List.get(0).getJhmxh());
            //若计划明细号为空，设置计划明细号，根据划转性质查询出入库信息获取计划号
            if(StringUtils.isEmpty(api1210.getJhmxdh())){
                if("200".equals(api1210.getHzqlsxzdm())){
                    //若划转前性质为商品粮，则查询入库信息获取计划明细号
                    List<Api1202> api1202List = api1202Rep.getDataByHwdmAndTime(api1210.getHwdm(), api1210.getHzrq());
                    if (null != api1202List && api1202List.size() > 0) {
                        api1210.setJhmxdh(api1202List.get(0).getJhmxh());
                    }
                }
            }
            if("200".equals(api1210.getHzhlsxzdm())){
                //若划转后性质为商品粮，则查询出库信息获取计划明细号
                List<Api1205> api1205List = api1205Rep.getDataByHwdmAndTime(api1210.getHwdm(), api1210.getHzrq());
                if (null != api1205List && api1205List.size() > 0) {
                    api1210.setJhmxdh(api1205List.get(0).getJhmxh());
                if("200".equals(api1210.getHzhlsxzdm())){
                    //若划转后性质为商品粮，则查询出库信息获取计划明细号
                    List<Api1205> api1205List = api1205Rep.getDataByHwdmAndTime(api1210.getHwdm(), api1210.getHzrq());
                    if (null != api1205List && api1205List.size() > 0) {
                        api1210.setJhmxdh(api1205List.get(0).getJhmxh());
                    }
                }
            }

@@ -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() + "");