From f7e9d18d1065a065bf06b859dc42e4ac40acda3f Mon Sep 17 00:00:00 2001 From: YYC <1833023622@qq.com> Date: 星期一, 25 十二月 2023 14:47:54 +0800 Subject: [PATCH] 熏蒸备案调整 --- src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1023.java | 111 ++++++++++++++++++++++++++++++++----------------------- 1 files changed, 64 insertions(+), 47 deletions(-) diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1023.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1023.java index 187a941..09a50f5 100644 --- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1023.java +++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1023.java @@ -22,7 +22,6 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import java.text.DateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; @@ -64,82 +63,100 @@ apiLog.setType(ApiLog.TYPE_SYNC); apiLog.setKqdm(deptId); apiLog.setUploadTime(new Date()); - apiLog.setInteId(Constant.API_CODE_1107); + apiLog.setInteId(ApiCodeConstant.API_1023); apiLog.setStatus(99); apiLog.setId(ContextUtil.getUUID()); try { - List<Fz4DrugLogApply> list = fzzy40Sync1023Rep.listDrugLogApply(deptId); + List<Fz40DrugLogApply> list = fzzy40Sync1023Rep.listDrugLogApply(deptId); if (null == list || list.isEmpty()) { log.info("-------------娌℃湁鑾峰彇鍒扮啅钂稿妗堜俊鎭�------------------"); return; } + List<GdApi1023Dtl> dtlList; + List<GdApi1023Way> wayList; + List<GdApi1023People> peopleList; - List<GdApi1023Dtl> dtlList = new ArrayList<>(); - List<GdApi1023Way> wayList = new ArrayList<>(); - List<GdApi1023People> peopleList = new ArrayList<>(); - for (Fz4DrugLogApply data : list) { - //鍌ㄧ伯绮儏鏄庣粏琛� - String tbrq = ""; - if (null != data.getTbrq()) { - tbrq = DateFormatUtils.format(data.getTbrq(), "yyyyMMdd"); - } - List<Fz40DrugLogDtl> dtls = drugLogDtlRep.listDrugLogDtl(data.getXzbm() + data.getDeptId() + tbrq); - for (Fz40DrugLogDtl dtl : dtls) { - GdApi1023Dtl gdApi1023Dtl = new GdApi1023Dtl(); - BeanUtils.copyProperties(dtl, gdApi1023Dtl); - gdApi1023Dtl.setCfdm(dtl.getDepotId()); - gdApi1023Dtl.setLspzdm(dtl.getFoodVariety()); - gdApi1023Dtl.setLsxzdm(dtl.getFoodType()); - gdApi1023Dtl.setLsdjdm(dtl.getFoodLevel()); - gdApi1023Dtl.setLssl(dtl.getNumber()); - gdApi1023Dtl.setSf(dtl.getPerWet()); - gdApi1023Dtl.setZz(dtl.getPerImpurity()); - dtlList.add(gdApi1023Dtl); - } - List<Fz40DrugLogWay> ways = drugLogWayRep.listDrugLogWay(data.getXzbm() + data.getDeptId() + tbrq); - for (Fz40DrugLogWay way : ways) { - GdApi1023Way gdApi1023Way = new GdApi1023Way(); - BeanUtils.copyProperties(way, gdApi1023Way); - wayList.add(gdApi1023Way); - } - List<Fz40DrugLogPeople> peoples = drugLogPeopleRep.listDrugLogPeople(data.getXzbm() + kqdm + tbrq); - for (Fz40DrugLogPeople people : peoples) { - GdApi1023People gdApi1023People = new GdApi1023People(); - BeanUtils.copyProperties(people, gdApi1023People); - peopleList.add(gdApi1023People); - } + GdApi1023 gdApi1023; + GdApi1023Dtl gdApi1023Dtl; + GdApi1023Way gdApi1023Way; + GdApi1023People gdApi1023People; - GdApi1023 gdApi1023 = new GdApi1023(); + List<ApiInfoData> apiInfoList; + ApiInfoData infoData; + for (Fz40DrugLogApply data : list) { + + gdApi1023 = new GdApi1023(); BeanUtils.copyProperties(data, gdApi1023); - gdApi1023.setXzbm(data.getXzbm()); + gdApi1023.setXzbm(data.getXzbm().substring(8)); gdApi1023.setKqdm(kqdm); + gdApi1023.setDwdm(kqdm.substring(0, 18)); gdApi1023.setYjmc(data.getDrugName()); gdApi1023.setYjlx(data.getDrugType()); + gdApi1023.setLqrq(data.getLqsj()); gdApi1023.setZhgxsj(data.getUpdateTime()); - gdApi1023.setDtls(dtlList); - gdApi1023.setWays(wayList); - gdApi1023.setPeoples(peopleList); + //鍌ㄧ伯绮儏鏄庣粏琛� + List<Fz40DrugLogDtl> dtls = drugLogDtlRep.listDrugLogDtl(data.getXzbm()); + if (null != dtls && dtls.size() > 0) { + dtlList = new ArrayList<>(); + for (Fz40DrugLogDtl dtl : dtls) { + gdApi1023Dtl = new GdApi1023Dtl(); + BeanUtils.copyProperties(dtl, gdApi1023Dtl); + gdApi1023Dtl.setCfdm(dtl.getDepotId()); + gdApi1023Dtl.setLspzdm(dtl.getFoodVariety()); + gdApi1023Dtl.setLsxzdm(dtl.getFoodType()); + gdApi1023Dtl.setLsdjdm(dtl.getFoodLevel()); + gdApi1023Dtl.setLssl(dtl.getNumber()); + gdApi1023Dtl.setSf(dtl.getPerWet()); + gdApi1023Dtl.setZz(dtl.getPerImpurity()); + dtlList.add(gdApi1023Dtl); + } + gdApi1023.setDtls(dtlList); + } + List<Fz40DrugLogWay> ways = drugLogWayRep.listDrugLogWay(data.getXzbm()); + if (null != ways && ways.size() > 0) { + wayList = new ArrayList<>(); + for (Fz40DrugLogWay way : ways) { + gdApi1023Way = new GdApi1023Way(); + BeanUtils.copyProperties(way, gdApi1023Way); + wayList.add(gdApi1023Way); + } + gdApi1023.setWays(wayList); + } + + List<Fz40DrugLogPeople> peoples = drugLogPeopleRep.listDrugLogPeople(data.getXzbm()); + if (null != peoples && peoples.size() > 0) { + peopleList = new ArrayList<>(); + for (Fz40DrugLogPeople people : peoples) { + gdApi1023People = new GdApi1023People(); + BeanUtils.copyProperties(people, gdApi1023People); + gdApi1023People.setXm(people.getMx()); + peopleList.add(gdApi1023People); + } + gdApi1023.setPeoples(peopleList); + } //鎸佷箙鍖栦繚瀛橈紝鍗曠嫭瀛樺叆闈炲浗鏍囨帴鍙h〃 - ApiInfoData infoData = new ApiInfoData(); - infoData.setId(ContextUtil.getUUID()); + infoData = new ApiInfoData(); + infoData.setKqdm(kqdm); infoData.setInteType(Constant.API_CATEGORY_13); infoData.setInteId(ApiCodeConstant.API_1023); infoData.setBizType(PushProtocol.SB_GD_2022.getCode()); - infoData.setUpdateTime(data.getUpdateTime()); - infoData.setDataId(kqdm + DateFormatUtils.format(data.getTbrq(), "yyMMdd") + data.getXzbm()); + infoData.setUpdateTime(new Date()); + infoData.setDataId(data.getXzbm()); + apiInfoList = apiInfoDataRep.getDataByInteAndData(ApiCodeConstant.API_1023, data.getXzbm(), kqdm); - List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByDataId(DateFormatUtils.format(data.getTbrq(), "yyMMdd") + kqdm + data.getXzbm()); if (null == apiInfoList || apiInfoList.isEmpty()) { gdApi1023.setCzbz(Constant.CZBZ_I); infoData.setCzbz(Constant.CZBZ_I); + infoData.setId(ContextUtil.getUUID()); } else { gdApi1023.setCzbz(apiInfoList.get(0).getCzbz()); infoData.setCzbz(apiInfoList.get(0).getCzbz()); + infoData.setId(apiInfoList.get(0).getId()); } infoData.setData(JSON.toJSONString(gdApi1023)); -- Gitblit v1.9.3