czt
2025-03-21 e61f0d87d0a2ce75ead83afcecc74a1432d13798
优化上海对农数据解析
已修改3个文件
21 ■■■■ 文件已修改
src/main/java/com/fzzy/api/view/Api9109.view.xml 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/inte/sh2023/controller/ControllerSh2023.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/inte/sh2023/service/SHDNService.java 14 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/api/view/Api9109.view.xml
@@ -410,8 +410,8 @@
                <Editor/>
              </AutoFormElement>
              <AutoFormElement>
                <Property name="name">ygs</Property>
                <Property name="property">ygs</Property>
                <Property name="name">ajs</Property>
                <Property name="property">ajs</Property>
                <Editor/>
              </AutoFormElement>
              <AutoFormElement>
src/main/java/com/fzzy/inte/sh2023/controller/ControllerSh2023.java
@@ -35,6 +35,7 @@
    public @ResponseBody
    ApiResp dnjgsj(HttpServletRequest request, @PathVariable("interfaceId") String interfaceId, @RequestBody String dataStr) {
        log.info("-----接收对农系统数据={}-----", dataStr);
        if(StringUtils.isEmpty(interfaceId)){
            return new ApiResp(ApiRespCode.R_500.getCode(),ApiRespCode.R_500.getMsg());
        }
@@ -52,7 +53,7 @@
        if(StringUtils.isEmpty(data)){
            return new ApiResp(ApiRespCode.R_500.getCode(),ApiRespCode.R_500.getMsg());
        }
        log.info("-----对农系统,接口编码={},数据解密={}-----",interfaceId, data);
        //异步保存
        shdnService.syncData(interfaceId, data, shdn2023ReqDto.getDeptId());
src/main/java/com/fzzy/inte/sh2023/service/SHDNService.java
@@ -4,6 +4,8 @@
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.view.repository.*;
import com.fzzy.inte.sh2023.constant.ApiRespCode;
import com.fzzy.inte.sh2023.dto.ApiResp;
import com.fzzy.push.sh2023.SH2023Constant;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -56,18 +58,20 @@
                apiData.setZhgxsj(new Date());
                api9109Rep.save(apiData);
            }
            log.info("-----单位信息解析完成={}-----", list);
        }
        //收纳库信息
        if(SH2023Constant.SH_2023_API_CODE_3102.equals(interfaceId)){
            List<Api9110> list = JSONObject.parseArray(dataStr, Api9110.class);
            if(null == list || list.isEmpty()){
                return;
                log.error("-----未获取到库区信息,不解析---------");
            }
            for (Api9110 apiData : list) {
                apiData.setZhgxsj(new Date());
                api9110Rep.save(apiData);
            }
            log.info("-----库区信息解析完成={}-----", list);
        }
        //仓房信息
@@ -80,6 +84,7 @@
                apiData.setZhgxsj(new Date());
                api9111Rep.save(apiData);
            }
            log.info("-----仓房信息解析完成={}-----", list);
        }
        //廒间信息
@@ -93,6 +98,7 @@
                apiData.setZhgxsj(new Date());
                api9112Rep.save(apiData);
            }
            log.info("-----廒间信息解析完成={}-----", list);
        }
        //货位信息
@@ -106,6 +112,7 @@
                apiData.setZhgxsj(new Date());
                api9113Rep.save(apiData);
            }
            log.info("-----货位信息解析完成={}-----", list);
        }
        //粮食入库信息
@@ -119,6 +126,7 @@
                apiData.setZhgxsj(new Date());
                api9114Rep.save(apiData);
            }
            log.info("-----粮食入库信息解析完成={}-----", list);
        }
        //来粮检验信息
@@ -132,6 +140,7 @@
                apiData.setZhgxsj(new Date());
                api9115Rep.save(apiData);
            }
            log.info("-----来粮检验信息解析完成={}-----", list);
        }
        //粮食收购基础信息
@@ -145,8 +154,7 @@
                apiData.setZhgxsj(new Date());
                api9116Rep.save(apiData);
            }
            log.info("-----粮食收购基础信息解析完成={}-----", list);
        }
    }
}