调整上海接口数据实时性

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);
        }
@@ -441,6 +447,7 @@
            //设置粮食轮换年度,根据计划明细号查询计划明细，再根据计划明细查询轮换计划
            List<Api1404> api1404List = api1404Rep.getDataByJhmxdh(apiData.getJhmxh());
            if (null != api1404List && api1404List.size() > 0) {
                api1202.setShnd(api1404List.get(0).getShnd());
                List<Api1403> api1403List = api1403Rep.getDataByLhjhdh(api1404List.get(0).getLhjhdh());
                if(null != api1403List && api1403List.size() > 0){
                    if(StringUtils.isNotEmpty(api1403List.get(0).getJhnd())){
@@ -558,8 +565,6 @@
                api1205.setPch(apiData.getHwdm() + api1208List.get(0).getShnd());
            }

            //粮食性质
            api1205.setLsxzdm("200");
            //设置空属性为默认值
            changeObject(api1205);
            return api1205;
@@ -613,6 +618,13 @@
            if (StringUtils.isEmpty(api1208.getCd())) {
                api1208.setCd(api1208.getHwdm().substring(2, 8));
            }
            //包装储粮是，核查包存粮包数
            if(null == apiData.getBclbs()){
                apiData.setBclbs(0);
            }
            if("2".equals(apiData.getClfs()) && apiData.getBclbs() == 0){
                apiData.setBclbs((int)(apiData.getSjsl()/25));
            }
            //设置空属性为默认值
            changeObject(api1208);
            return api1208;
@@ -649,6 +661,24 @@
            List<Api1208> api1208List = api1208Rep.findDataByHwdm(api1210.getHwdm());
            if (null != api1208List && api1208List.size() > 0) {
                api1210.setPch(apiData.getHwdm() + api1208List.get(0).getShnd());
            }

            //若计划明细号为空，设置计划明细号，根据划转性质查询出入库信息获取计划号
            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());
                    }
                }
            }

            //设置空属性为默认值
@@ -835,6 +865,9 @@
            if (StringUtils.isEmpty(api1310.getShrxm())) {
                api1310.setShrxm("审核人");
            }
            if (StringUtils.isEmpty(api1310.getBglx())) {
                api1310.setBglx("1");
            }

            //设置空属性为默认值
            changeObject(api1310);
@@ -890,8 +923,8 @@
                    }
                }
            }
            api1403.setLrsl(lrsl/1000 + "");
            api1403.setLcsl(lcsl/1000 + "");
            api1403.setLrsl(lrsl + "");
            api1403.setLcsl(lcsl + "");

            //设置空属性为默认值
            changeObject(api1403);
@@ -949,6 +982,23 @@
        //设置空属性为默认值
        changeObject(data);
        return data;
    }

    /**
     * 赋值最后更新时间
     * @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;
    }

    /**
@@ -1096,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() + "");
@@ -1146,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() + "");
@@ -1198,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() + "");