武汉黄陂军粮-质检报告共享接口同步及推送

czt

2 天以前 9f6dacf7b39e5aeba37d8faf575c9e56d8cbe51a

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2009PR.java

@@ -7,6 +7,7 @@
import com.bstek.dorado.annotation.Expose;
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.entity.ApiInfoData;
@@ -15,7 +16,7 @@
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.view.repository.ApiInfoDataRep;
import com.fzzy.otherview.whhpjl.WhjlConstant;
import com.fzzy.otherview.whhpjl.dto.WhjlShareApi2002;
import com.fzzy.otherview.whhpjl.dto.WhjlShareApi2009;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -39,20 +40,20 @@

    /**
     * 获取列表信息
     * whjlShareApi2002PR#listData
     * whjlShareApi2009PR#listData
     *
     * @return
     */
    @DataProvider
    public List<WhjlShareApi2002> listData() {
        List<ApiInfoData> result = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_2002);
    public List<WhjlShareApi2009> listData() {
        List<ApiInfoData> result = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_2009);
        if (null == result || result.isEmpty()) {
            return null;
        }
        List<WhjlShareApi2002> list = new ArrayList<>();
        WhjlShareApi2002 whjlShareApiData;
        List<WhjlShareApi2009> list = new ArrayList<>();
        WhjlShareApi2009 whjlShareApiData;
        for (ApiInfoData infoData : result) {
            whjlShareApiData = JSONObject.parseObject(infoData.getData(), WhjlShareApi2002.class);
            whjlShareApiData = JSONObject.parseObject(infoData.getData(), WhjlShareApi2009.class);
            whjlShareApiData.setKqdm(infoData.getKqdm());
            whjlShareApiData.setCzbz(infoData.getCzbz());
            whjlShareApiData.setUpdateTime(infoData.getUpdateTime());
@@ -64,20 +65,20 @@

    /**
     * 更新或修改
     * whjlShareApi2002PR#saveData
     * whjlShareApi2009PR#saveData
     *
     * @param data
     * @return
     */
    @DataResolver
    public void saveData(WhjlShareApi2002 data) {
    public void saveData(WhjlShareApi2009 data) {
        ApiInfoData infoData = new ApiInfoData();
        infoData.setId(data.getCpflbm());
        infoData.setId(data.getMbhb());
        infoData.setKqdm(data.getKqdm());
        infoData.setInteType(WhjlConstant.API_CATEGORY_20);
        infoData.setInteId(WhjlConstant.API_CODE_2002);
        infoData.setInteId(WhjlConstant.API_CODE_2009);
        infoData.setUpdateTime(new Date());
        infoData.setDataId(data.getCpflbm());
        infoData.setDataId(data.getMbhb());
        infoData.setData(JSON.toJSONString(data));
        infoData.setCzbz(data.getCzbz());
        infoData.setRemarks("备注信息");
@@ -88,26 +89,26 @@

    /**
     * 删除
     * whjlShareApi2002PR#delData
     * whjlShareApi2009PR#delData
     *
     * @param data
     * @return
     */
    @Expose
    public String delData(WhjlShareApi2002 data) {
        apiInfoDataRep.deleteById(data.getCpflbm());
    public String delData(WhjlShareApi2009 data) {
        apiInfoDataRep.deleteById(data.getMbhb());
        return null;
    }

    /**
     * 更新数据
     * whjlShareApi2002PR#pullData
     * whjlShareApi2009PR#pullData
     *
     * @param items
     * @return
     */
    @Expose
    public String pullData(List<WhjlShareApi2002> items) {
    public String pullData(List<WhjlShareApi2009> items) {


        //获取配置信息
@@ -121,28 +122,31 @@
        ResponseDto responseDto;
        ApiInfoData infoData;
        String result = "";
        List<WhjlShareApi2002> list;
        List<WhjlShareApi2009> list;
        for (ApiConfs apiConf : apiConfs) {
            if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){
                continue;
            }
            apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol());
            if (null == apiService) {
                continue;
            }
            //封装参数
            param = new ApiParam(apiConf, WhjlConstant.API_CATEGORY_20, WhjlConstant.API_CODE_2002);
            param = new ApiParam(apiConf, WhjlConstant.API_CATEGORY_20, WhjlConstant.API_CODE_2009);
            responseDto = apiService.pullData(param, apiConf);

            if (responseDto.getSuccess() == 0) {
                list = JSONObject.parseArray(responseDto.getData(), WhjlShareApi2002.class);
                list = JSONObject.parseArray(responseDto.getData(), WhjlShareApi2009.class);
                if(null != list && list.size() > 0){
                    for (WhjlShareApi2002 shareData : list) {
                    for (WhjlShareApi2009 shareData : list) {
                        shareData.setCzbz(Constant.CZBZ_U);
                        infoData = new ApiInfoData();
                        infoData.setId(shareData.getCpflbm());
                        infoData.setId(shareData.getMbhb());
                        infoData.setKqdm(apiConf.getKqdm());
                        infoData.setInteType(WhjlConstant.API_CATEGORY_20);
                        infoData.setInteId(WhjlConstant.API_CODE_2002);
                        infoData.setInteId(WhjlConstant.API_CODE_2009);
                        infoData.setUpdateTime(new Date());
                        infoData.setDataId(shareData.getCpflbm());
                        infoData.setDataId(shareData.getMbhb());
                        infoData.setData(JSON.toJSONString(shareData));
                        infoData.setCzbz(Constant.CZBZ_U);
                        apiInfoDataRep.save(infoData);