增城配置

YYC

2024-07-12 ab8b3af2bc6460dba2a807d27004e128d772ab24

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1023.java

@@ -5,6 +5,7 @@
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy40.entity.*;
@@ -54,6 +55,8 @@
    private ApiCommonService commonService;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;
    @Autowired
    private ApiTriggerService apiTriggerService;


    /**
@@ -64,7 +67,7 @@
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1023接口设备信息开始同步------------------");
        log.info("-------------1023接口熏蒸备案信息开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
@@ -113,6 +116,9 @@
                GD2022Api1023.setYjlx(data.getDrugType());
                GD2022Api1023.setLqrq(data.getLqsj());
                GD2022Api1023.setZhgxsj(data.getUpdateTime());
                if(data.getLqr().contains("、")){
                    GD2022Api1023.setLqr(data.getLqr().replace('、', '|'));
                }

                //储粮粮情明细表
                List<Fz40DrugLogDtl> dtls = drugLogDtlRep.listDrugLogDtl(data.getXzbm());
@@ -121,10 +127,12 @@
                BeanUtils.copyProperties(data, gd2022Api1023Dtl);
                if (null != api1105) {
                    gd2022Api1023Dtl.setCfmc(api1105.getHwmc());
                    gd2022Api1023Dtl.setCfdm(api1105.getHwdm().substring(0,25));
                    gd2022Api1023Dtl.setCfdm(api1105.getHwdm().substring(0, 25));
                }

                gd2022Api1023Dtl.setLspzdm(data.getFoodVariety());
                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, data.getFoodVariety());
                gd2022Api1023Dtl.setLspzdm(mappingCode);
                gd2022Api1023Dtl.setLsxzdm(data.getFoodType());
                gd2022Api1023Dtl.setLsdjdm(data.getFoodLevel());
                gd2022Api1023Dtl.setLssl(data.getNumber());
@@ -209,8 +217,8 @@
            }

        } catch (Exception e) {
            log.error("---设备信息同步执行失败----{}", e.toString());
            apiLog.setResult("设备信息同步执行失败：" + e.getMessage());
            log.error("---熏蒸备案同步执行失败----{}", e.toString());
            apiLog.setResult("熏蒸备案信息同步执行失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }