| | |
|---|
| | | package com.fzzy.async.whhpjl.impl; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.fzzy.api.Constant; |
|---|
| | | import com.fzzy.api.entity.ApiInfoData; |
|---|
| | | import com.fzzy.api.entity.ApiLog; |
|---|
| | | import com.fzzy.api.utils.ContextUtil; |
|---|
| | | import com.fzzy.api.view.repository.ApiInfoDataRep; |
|---|
| | | import com.fzzy.api.view.repository.ApiLogRep; |
|---|
| | | import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultBuilding; |
|---|
| | | import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultGranary; |
|---|
| | | import com.fzzy.async.whhpjl.repository.Fz40ToWhjlSync1105Rep; |
|---|
| | | import com.fzzy.async.whhpjl.repository.Fz40ToWhjlSync1106Rep; |
|---|
| | | import com.fzzy.whjl.dto.WhjlApi1105; |
|---|
| | | import com.fzzy.whjl.dto.WhjlApi1106; |
|---|
| | | import com.fzzy.otherview.whhpjl.WhjlConstant; |
|---|
| | | import com.fzzy.otherview.whhpjl.dto.WhjlApi1106; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | |
|---|
| | | private Fz40ToWhjlSync1106Rep fz40ToWhjlSync1106Rep; |
|---|
| | | @Autowired |
|---|
| | | private ApiLogRep apiLogRep; |
|---|
| | | @Autowired |
|---|
| | | private ApiInfoDataRep apiInfoDataRep; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 廒间信息 |
|---|
| | |
|---|
| | | log.info("-------------没有获取到单位信息------------------"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | List<ApiInfoData> apiInfoDataList; |
|---|
| | | WhjlApi1106 apiData; |
|---|
| | | for (Fz40WhjlDefaultGranary sysData : list) { |
|---|
| | | apiData = new WhjlApi1106(); |
|---|
| | |
|---|
| | | apiData.setAjsyzt(""); //廒间使用状态 |
|---|
| | | apiData.setSfyx(""); //是否有效 |
|---|
| | | |
|---|
| | | |
|---|
| | | apiData.setBizId(sysData.getAjdh()); |
|---|
| | | apiData.setUpdateTime(new Date()); |
|---|
| | | |
|---|
| | | //TODO 持久化保存待实现 |
|---|
| | | //持久化保存，单独存入非国标接口表 |
|---|
| | | ApiInfoData infoData = new ApiInfoData(); |
|---|
| | | infoData.setId(sysData.getAjdh()); |
|---|
| | | infoData.setKqdm(kqdm); |
|---|
| | | infoData.setInteType(WhjlConstant.API_CATEGORY_11); |
|---|
| | | infoData.setInteId(WhjlConstant.API_CODE_1106); |
|---|
| | | infoData.setUpdateTime(new Date()); |
|---|
| | | infoData.setDataId(sysData.getAjdh()); |
|---|
| | | infoData.setRemarks("备注信息"); |
|---|
| | | |
|---|
| | | //设置操作标志 |
|---|
| | | apiInfoDataList = apiInfoDataRep.getDataByDataId(infoData.getDataId()); |
|---|
| | | if (null == apiInfoDataList || apiInfoDataList.isEmpty()) { |
|---|
| | | apiData.setCzbz(Constant.CZBZ_I); |
|---|
| | | infoData.setCzbz(Constant.CZBZ_I); |
|---|
| | | } else { |
|---|
| | | apiData.setCzbz(apiInfoDataList.get(0).getCzbz()); |
|---|
| | | infoData.setCzbz(apiInfoDataList.get(0).getCzbz()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | infoData.setData(JSON.toJSONString(apiData)); |
|---|
| | | apiInfoDataRep.save(infoData); |
|---|
| | | |
|---|
| | | |
|---|
| | | log.info("1106---廒间-同步数据：{}", apiData.toString()); |
|---|
