From fca93a39f72035502670f655a478df991a163e6d Mon Sep 17 00:00:00 2001 From: WS <1143478319@qq.com> Date: 星期日, 14 五月 2023 19:33:10 +0800 Subject: [PATCH] 上海嘉定纪委监管平台-上传数据服务类 --- src/main/java/com/fzzy/api/service/ApiTriggerService.java | 6 src/main/java/com/fzzy/api/view/repository/Api1103Rep.java | 10 + src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService14.java | 4 src/main/java/com/fzzy/api/view/repository/Api1208Rep.java | 3 src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1404.java | 35 +++ src/main/java/com/fzzy/api/view/repository/Api1104Rep.java | 11 + src/main/java/com/fzzy/api/view/repository/ApiTriggerRep.java | 3 src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1310.java | 89 +++++++++ src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1403.java | 73 ++++++++ src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1209.java | 3 src/main/java/com/fzzy/push/impl/ComPushService14.java | 2 src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1202.java | 3 src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService13.java | 2 src/main/java/com/fzzy/push/shjdjw2023/ShjdjwApiRemoteService2023.java | 292 +++++++++++++++++++++++++------ src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1203.java | 3 15 files changed, 471 insertions(+), 68 deletions(-) diff --git a/src/main/java/com/fzzy/api/service/ApiTriggerService.java b/src/main/java/com/fzzy/api/service/ApiTriggerService.java index 3a0a609..e4d43a1 100644 --- a/src/main/java/com/fzzy/api/service/ApiTriggerService.java +++ b/src/main/java/com/fzzy/api/service/ApiTriggerService.java @@ -61,6 +61,12 @@ } } + public ApiTrigger findNameByCode(String code, String parentCode) { + + List<ApiTrigger> listParent = apiTriggerRep.findNameByCode(code, parentCode); + if (null == listParent || listParent.isEmpty()) return null; + return listParent.get(0); + } private void add2Cache(ApiTrigger trigger) { diff --git a/src/main/java/com/fzzy/api/view/repository/Api1103Rep.java b/src/main/java/com/fzzy/api/view/repository/Api1103Rep.java index d483643..2772379 100644 --- a/src/main/java/com/fzzy/api/view/repository/Api1103Rep.java +++ b/src/main/java/com/fzzy/api/view/repository/Api1103Rep.java @@ -16,10 +16,18 @@ int updateStatus(@Param("id") String id, @Param("czbz") String czbz); /** - * 鏌ヨ鎵�鏈夌殑鐩戞帶鐐逛綅淇℃伅 + * * @param kqdm * @return */ @Query("from Api1103 where kqdm=:kqdm ") List<Api1103> findPushData(@Param("kqdm") String kqdm); + + /** + * 鏍规嵁浠撴埧浠g爜鏌ヨ + * @param cfdm + * @return + */ + @Query("from Api1103 where cfdm=:cfdm ") + List<Api1103> findPushDataByCfdm(@Param("cfdm") String cfdm); } diff --git a/src/main/java/com/fzzy/api/view/repository/Api1104Rep.java b/src/main/java/com/fzzy/api/view/repository/Api1104Rep.java index 12d100e..b9c8140 100644 --- a/src/main/java/com/fzzy/api/view/repository/Api1104Rep.java +++ b/src/main/java/com/fzzy/api/view/repository/Api1104Rep.java @@ -1,11 +1,14 @@ package com.fzzy.api.view.repository; +import com.fzzy.api.entity.Api1102; import com.fzzy.api.entity.Api1104; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.Modifying; import org.springframework.data.jpa.repository.Query; import org.springframework.data.repository.query.Param; import org.springframework.transaction.annotation.Transactional; + +import java.util.List; public interface Api1104Rep extends JpaRepository<Api1104, String> { @@ -22,4 +25,12 @@ @Query("update Api1104 set czbz=:czbz where ajdh=:id ") int updateStatus(@Param("id") String id, @Param("czbz") String czbz); + + /** + * + * @param + * @return + */ + @Query("from Api1104 where ajdh=:ajdh ") + List<Api1104> findDataByAjdh(@Param("ajdh") String ajdh); } diff --git a/src/main/java/com/fzzy/api/view/repository/Api1208Rep.java b/src/main/java/com/fzzy/api/view/repository/Api1208Rep.java index 972c0b1..d3e47e2 100644 --- a/src/main/java/com/fzzy/api/view/repository/Api1208Rep.java +++ b/src/main/java/com/fzzy/api/view/repository/Api1208Rep.java @@ -24,4 +24,7 @@ @Query("from Api1208 where id=:id ") List<Api1208> getDataById(@Param("id") String id); + + @Query("from Api1208 where hwdm=:hwdm ") + List<Api1208> getDataByHwdm(@Param("hwdm") String hwdm); } diff --git a/src/main/java/com/fzzy/api/view/repository/ApiTriggerRep.java b/src/main/java/com/fzzy/api/view/repository/ApiTriggerRep.java index 1904dff..90364db 100644 --- a/src/main/java/com/fzzy/api/view/repository/ApiTriggerRep.java +++ b/src/main/java/com/fzzy/api/view/repository/ApiTriggerRep.java @@ -17,6 +17,9 @@ @Query("from ApiTrigger where parentCode =:parentCode order by code ") List<ApiTrigger> findByParent(@Param("parentCode") String parentCode); + @Query("from ApiTrigger where parentCode =:parentCode and code=:code") + List<ApiTrigger> findNameByCode(@Param("code") String code, @Param("parentCode") String parentCode ); + @Query("from ApiTrigger where parentCode =:parentCode and val=:val order by code ") List<ApiTrigger> findByParent(@Param("parentCode") String parentCode, @Param("val") String val); } diff --git a/src/main/java/com/fzzy/push/impl/ComPushService14.java b/src/main/java/com/fzzy/push/impl/ComPushService14.java index 894b4e0..8195e5a 100644 --- a/src/main/java/com/fzzy/push/impl/ComPushService14.java +++ b/src/main/java/com/fzzy/push/impl/ComPushService14.java @@ -58,7 +58,7 @@ } } - public void pushData1404(GDApiRemoteService apiRemoteService, ApiParam param) { + public void pushData1404(ApiRemoteService apiRemoteService, ApiParam param) { //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁 List<Api1404> items = api1404Rep.findPushData(param.getKqdm()); diff --git a/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService13.java b/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService13.java index 0628cd2..3ca03ab 100644 --- a/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService13.java +++ b/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService13.java @@ -34,7 +34,7 @@ log.info("------->>>>绮绠$悊 鎺ュ彛妯″潡涓婃姤寮�濮�"); //TODO 璐ㄦ淇℃伅 - + pushService.pushData1310(apiRemoteService, param); log.info("------->>>>绮绠$悊 鎺ュ彛妯″潡涓婃姤缁撴潫"); } diff --git a/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService14.java b/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService14.java index c9f3529..12e5628 100644 --- a/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService14.java +++ b/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService14.java @@ -33,9 +33,9 @@ log.info("------->>>>琛屾斂绠$悊 鎺ュ彛妯″潡涓婃姤寮�濮�"); //TODO 杞崲璁″垝淇℃伅 - + pushService.pushData1403(apiRemoteService, param); //TODO 杞崲璁″垝瀹屾垚淇℃伅 - + pushService.pushData1404(apiRemoteService, param); log.info("------->>>>琛屾斂绠$悊 鎺ュ彛妯″潡涓婃姤缁撴潫"); } } \ No newline at end of file diff --git a/src/main/java/com/fzzy/push/shjdjw2023/ShjdjwApiRemoteService2023.java b/src/main/java/com/fzzy/push/shjdjw2023/ShjdjwApiRemoteService2023.java index 29c578d..ff6a39d 100644 --- a/src/main/java/com/fzzy/push/shjdjw2023/ShjdjwApiRemoteService2023.java +++ b/src/main/java/com/fzzy/push/shjdjw2023/ShjdjwApiRemoteService2023.java @@ -8,6 +8,7 @@ import com.fzzy.api.entity.*; import com.fzzy.api.service.ApiCommonService; import com.fzzy.api.service.ApiRemoteService; +import com.fzzy.api.service.ApiTriggerService; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.utils.RedisUtil; import com.fzzy.api.view.repository.*; @@ -37,6 +38,8 @@ @Autowired private ApiCommonService apiCommonService; @Autowired + private ApiTriggerService apiTriggerService; + @Autowired private ApiLogRep apiLogRep; @Autowired private Api1101Rep api1101Rep; @@ -46,6 +49,10 @@ private Api1103Rep api1103Rep; @Autowired private Api1202Rep api1202Rep; + @Autowired + private Api1104Rep api1104Rep; + @Autowired + private Api1208Rep api1208Rep; @Override public String getProtocol() { @@ -133,20 +140,20 @@ //鏌ヨ鍗曚綅淇℃伅 List<Api1101> listApi1101 = api1101Rep.findPushData(shjdjwApi1101.getKqdm()); Api1101 api1101 = null; - if(null != listApi1101 && listApi1101.size() > 0){ + if (null != listApi1101 && listApi1101.size() > 0) { api1101 = listApi1101.get(0); } - if(null != api1101){ + if (null != api1101) { shjdjwApi1101.setDwmc(api1101.getDwmc()); shjdjwApi1101.setKqs(api1101.getKqs()); } //鏌ヨ浠撴埧淇℃伅 List<Api1103> listApi1103 = api1103Rep.findPushData(shjdjwApi1101.getKqdm()); - if(null != listApi1103 && listApi1103.size() > 0){ - for(int i = 0; i < listApi1103.size(); i++){ - if(i == 0){ + if (null != listApi1103 && listApi1103.size() > 0) { + for (int i = 0; i < listApi1103.size(); i++) { + if (i == 0) { shjdjwApi1101.setCfmc(listApi1103.get(i).getCfmc()); - }else { + } else { shjdjwApi1101.setCfmc(shjdjwApi1101.getCfmc() + "#" + listApi1103.get(i).getCfmc()); } } @@ -161,69 +168,44 @@ list.add(shjdjwApi1202); } else if (Constant.API_CODE_1203.equals(inteId)) { //绮鍏ュ簱妫�楠屾暟鎹皝瑁� - ShjdjwApi1203 shjdjwApi1203 = new ShjdjwApi1203(); - Api1203 api1203 = (Api1203) data; - BeanUtils.copyProperties(api1203, shjdjwApi1203); - - shjdjwApi1203.setQydbh(api1203.getRkjydh()); - shjdjwApi1203.setHwbm(api1203.getHwdm()); - shjdjwApi1203.setYpbm(api1203.getRkywdh()); - shjdjwApi1203.setJyjg(api1203.getJyz()); - shjdjwApi1203.setJyjl(api1203.getJyjg()); - shjdjwApi1203.setPzbm(api1203.getLspzdm()); - //TODO 鏍囪浣� - shjdjwApi1203.setPch("0"); + ShjdjwApi1203 shjdjwApi1203 = copyApi1203((Api1203) data); list.add(shjdjwApi1203); } else if (Constant.API_CODE_1205.equals(inteId)) { //绮鍑哄簱鏁版嵁灏佽 - ShjdjwApi1205 shjdjwApi1205 = new ShjdjwApi1205(); - Api1205 api1205 = (Api1205) data; - - BeanUtils.copyProperties(api1205, shjdjwApi1205); - - shjdjwApi1205.setYwdh(api1205.getCkywdh()); - shjdjwApi1205.setHtbm(api1205.getHth()); - shjdjwApi1205.setPzbm(api1205.getLspzdm()); - shjdjwApi1205.setDjbm(api1205.getLsdjdm()); - shjdjwApi1205.setLqxzbm(api1205.getLsxzdm()); - shjdjwApi1205.setCzbz(api1205.getCzbz()); - shjdjwApi1205.setLrfs("0"); - shjdjwApi1205.setPzbm("0"); - //TODO 鍗曚綅鍚嶇О 浠撴埧鍚嶇О 鍗曟嵁绫诲瀷 鍝佺鍚嶇О 鍦板潃 鍒板簱鏃堕棿 绂诲簱鏃堕棿 杞崲骞村害 - shjdjwApi1205.setPch("0"); + ShjdjwApi1205 shjdjwApi1205 = copyApi1205((Api1205) data); list.add(shjdjwApi1205); } else if (Constant.API_CODE_1208.equals(inteId)) { //绮搴撳瓨鏁版嵁灏佽 - ShjdjwApi1208 shjdjwApi1208 = new ShjdjwApi1208(); - Api1208 api1208 = (Api1208) data; - - BeanUtils.copyProperties(api1208, shjdjwApi1208); - - shjdjwApi1208.setLspzbm(api1208.getLspzdm()); - shjdjwApi1208.setLsxzbm(api1208.getLsxzdm()); - shjdjwApi1208.setDjbm(api1208.getLsdjdm()); - shjdjwApi1208.setLqgsdwbm(api1208.getLqgsdwdm()); - shjdjwApi1208.setPch("0"); - //TODO 鍗曚綅鍚嶇О 浠撴埧鍚嶇О 寤掗棿鍚嶇О 搴撳瓨鐩戞祴鏃堕棿 + ShjdjwApi1208 shjdjwApi1208 = copyApi1208((Api1208) data); list.add(shjdjwApi1208); } else if (Constant.API_CODE_1209.equals(inteId)) { //鎹熺泭鍗曟暟鎹皝瑁� - ShjdjwApi1209 shjdjwApi1209 = new ShjdjwApi1209(); - Api1209 api1209 = (Api1209) data; - - BeanUtils.copyProperties(api1209, shjdjwApi1209); - - shjdjwApi1209.setSydbh(api1209.getSydh()); - shjdjwApi1209.setHwbm(api1209.getHwdm()); - shjdjwApi1209.setRksl(api1209.getRkjz()); - shjdjwApi1209.setCksl(api1209.getCkjz()); - shjdjwApi1209.setSysl(api1209.getJzsysl()); - //TODO 鍗曚綅鍚嶇О 搴撶偣鍚嶇О 骞撮檺 杈呮崯婧㈡暟閲� 鎹熺泭绫诲瀷 + ShjdjwApi1209 shjdjwApi1209 = copyApi1209((Api1209) data); list.add(shjdjwApi1209); + } else if (Constant.API_CODE_1310.equals(inteId)) { + //璐ㄦ鏁版嵁灏佽 + ShjdjwApi1310 shjdjwApi1310 = copyApi1310((Api1310) data); + + list.add(shjdjwApi1310); + } else if (Constant.API_CODE_1403.equals(inteId)) { + //杞崲璁″垝鏁版嵁灏佽 + ShjdjwApi1403 shjdjwApi1403 = new ShjdjwApi1403(); + Api1403 api1403 = (Api1403) data; + BeanUtils.copyProperties(api1403, shjdjwApi1403); + + shjdjwApi1403.setJhbm(api1403.getLhjhdh()); + shjdjwApi1403.setPch("0"); + + list.add(shjdjwApi1403); + } else if (Constant.API_CODE_1404.equals(inteId)) { + //杞崲璁″垝瀹屾垚鎯呭喌鏁版嵁灏佽 + ShjdjwApi1404 shjdjwApi1404 = copyApi1404((Api1404) data); + + list.add(shjdjwApi1404); } else { list.add(data); @@ -232,6 +214,189 @@ return JSON.toJSONString(dto); } + private ShjdjwApi1404 copyApi1404(Api1404 data) { + ShjdjwApi1404 shjdjwApi1404 = new ShjdjwApi1404(); + Api1404 api1404 = data; + BeanUtils.copyProperties(api1404, shjdjwApi1404); + + //鏌ヨ鍗曚綅淇℃伅 + List<Api1101> listApi1101 = api1101Rep.findPushData(api1404.getKqdm()); + if (null != listApi1101 || listApi1101.size() > 0) { + shjdjwApi1404.setDwmc(listApi1101.get(0).getDwmc()); + } + + shjdjwApi1404.setJhnd("0"); + shjdjwApi1404.setJhsl("0"); + shjdjwApi1404.setYzxsl("0"); + shjdjwApi1404.setZxbl("0"); + shjdjwApi1404.setZbjjbl("0"); + //TODO 璁″垝骞村害 璁″垝鏁伴噺 宸叉墽琛屾暟閲� 鎵ц姣斾緥 鎷涙爣/绔炰环姣斾緥 + return shjdjwApi1404; + } + + private ShjdjwApi1203 copyApi1203(Api1203 data) { + ShjdjwApi1203 shjdjwApi1203 = new ShjdjwApi1203(); + Api1203 api1203 = data; + BeanUtils.copyProperties(api1203, shjdjwApi1203); + + shjdjwApi1203.setQydbh(api1203.getRkjydh()); + shjdjwApi1203.setHwbm(api1203.getHwdm()); + shjdjwApi1203.setYpbm(api1203.getRkywdh()); + shjdjwApi1203.setJyjg(api1203.getJyz()); + shjdjwApi1203.setJyjl(api1203.getJyjg()); + shjdjwApi1203.setPzbm(api1203.getLspzdm()); + shjdjwApi1203.setBjw("jiading"); + shjdjwApi1203.setPch("0"); + return shjdjwApi1203; + } + + private ShjdjwApi1310 copyApi1310(Api1310 data) { + ShjdjwApi1310 shjdjwApi1310 = new ShjdjwApi1310(); + Api1310 api1310 = data; + BeanUtils.copyProperties(api1310, shjdjwApi1310); + + shjdjwApi1310.setZjbgdbh(api1310.getZjbgdh()); + shjdjwApi1310.setPznm(api1310.getLspzdm()); + shjdjwApi1310.setSkdjbm(api1310.getLsdjdm()); + shjdjwApi1310.setJylbbm(api1310.getJylb()); + shjdjwApi1310.setJyjl(api1310.getJyxmz()); + shjdjwApi1310.setZlzbjgpd(api1310.getZbjgpd()); + //鏌ヨ鍗曚綅淇℃伅 + List<Api1101> listApi1101 = api1101Rep.findPushData(api1310.getKqdm()); + if (null != listApi1101 || listApi1101.size() > 0) { + shjdjwApi1310.setDwmc(listApi1101.get(0).getDwmc()); + } + + //鏌ヨ浠撴埧淇℃伅 + List<Api1103> listApi1103 = api1103Rep.findPushDataByCfdm(api1310.getHwdm().substring(0, 25)); + if (null != listApi1103 || listApi1103.size() > 0) { + shjdjwApi1310.setCfmc(listApi1103.get(0).getCfmc()); + } + + //鏌ヨ寤掗棿淇℃伅 + List<Api1104> listApi1104 = api1104Rep.findDataByAjdh(api1310.getHwdm().substring(0, 28)); + if (null != listApi1104 || listApi1104.size() > 0) { + shjdjwApi1310.setAjmc(listApi1104.get(0).getAjmc()); + } + + //鏌ヨ搴撳尯淇℃伅 + List<Api1102> listApi1102 = api1102Rep.findPushData(api1310.getKqdm()); + if (null != listApi1102 || listApi1102.size() > 0) { + shjdjwApi1310.setKdmc(listApi1102.get(0).getKqmc()); + } + //鏌ヨ绮搴撳瓨 + List<Api1208> listApi1208 = api1208Rep.getDataByHwdm(api1310.getHwdm()); + if (null != listApi1208 || listApi1208.size() > 0) { + shjdjwApi1310.setKdmc(listApi1208.get(0).getLsxzdm()); + } + shjdjwApi1310.setPch("0"); + return shjdjwApi1310; + } + + private ShjdjwApi1209 copyApi1209(Api1209 data) { + ShjdjwApi1209 shjdjwApi1209 = new ShjdjwApi1209(); + Api1209 api1209 = data; + + BeanUtils.copyProperties(api1209, shjdjwApi1209); + + shjdjwApi1209.setSydbh(api1209.getSydh()); + shjdjwApi1209.setHwbm(api1209.getHwdm()); + shjdjwApi1209.setRksl(api1209.getRkjz()); + shjdjwApi1209.setCksl(api1209.getCkjz()); + shjdjwApi1209.setSysl(api1209.getJzsysl()); + //鏌ヨ鍗曚綅淇℃伅 + List<Api1101> listApi1101 = api1101Rep.findPushData(api1209.getKqdm()); + if (null != listApi1101 || listApi1101.size() > 0) { + shjdjwApi1209.setDwmc(listApi1101.get(0).getDwmc()); + } + //鏌ヨ搴撳尯淇℃伅 + List<Api1102> listApi1102 = api1102Rep.findPushData(api1209.getKqdm()); + if (null != listApi1102 || listApi1102.size() > 0) { + shjdjwApi1209.setKdmc(listApi1102.get(0).getKqmc()); + } + + shjdjwApi1209.setNx(api1209.getYwrq()); + //杈呮崯鐩婃暟閲� + shjdjwApi1209.setFsysl(Math.abs(api1209.getJzsysl())); + //鎹熺泭绫诲瀷 + shjdjwApi1209.setSylx(api1209.getJzsysl() > 0 ? "0" : "1"); + return shjdjwApi1209; + } + + private ShjdjwApi1208 copyApi1208(Api1208 data) { + ShjdjwApi1208 shjdjwApi1208 = new ShjdjwApi1208(); + Api1208 api1208 = data; + + BeanUtils.copyProperties(api1208, shjdjwApi1208); + + shjdjwApi1208.setLspzbm(api1208.getLspzdm()); + shjdjwApi1208.setLsxzbm(api1208.getLsxzdm()); + shjdjwApi1208.setDjbm(api1208.getLsdjdm()); + shjdjwApi1208.setLqgsdwbm(api1208.getLqgsdwdm()); + + //鏌ヨ鍗曚綅淇℃伅 + List<Api1101> listApi1101 = api1101Rep.findPushData(api1208.getKqdm()); + if (null != listApi1101 || listApi1101.size() > 0) { + shjdjwApi1208.setDwmc(listApi1101.get(0).getDwmc()); + } + + //鏌ヨ浠撴埧淇℃伅 + List<Api1103> listApi1103 = api1103Rep.findPushDataByCfdm(api1208.getHwdm().substring(0, 25)); + if (null != listApi1103 || listApi1103.size() > 0) { + shjdjwApi1208.setCfmc(listApi1103.get(0).getCfmc()); + } + + //鏌ヨ寤掗棿淇℃伅 + List<Api1104> listApi1104 = api1104Rep.findDataByAjdh(api1208.getHwdm().substring(0, 28)); + if (null != listApi1104 || listApi1104.size() > 0) { + shjdjwApi1208.setAjmc(listApi1104.get(0).getAjmc()); + } + + shjdjwApi1208.setKcjcsj(api1208.getZhgxsj()); + + shjdjwApi1208.setPch("0"); + return shjdjwApi1208; + } + + private ShjdjwApi1205 copyApi1205(Api1205 data) { + ShjdjwApi1205 shjdjwApi1205 = new ShjdjwApi1205(); + Api1205 api1205 = data; + + BeanUtils.copyProperties(api1205, shjdjwApi1205); + + shjdjwApi1205.setYwdh(api1205.getCkywdh()); + shjdjwApi1205.setHtbm(api1205.getHth()); + shjdjwApi1205.setPzbm(api1205.getLspzdm()); + shjdjwApi1205.setDjbm(api1205.getLsdjdm()); + shjdjwApi1205.setLqxzbm(api1205.getLsxzdm()); + shjdjwApi1205.setCzbz(api1205.getCzbz()); + shjdjwApi1205.setLrfs("0"); + shjdjwApi1205.setPzbm(api1205.getLspzdm()); + + //鏌ヨ鍗曚綅淇℃伅 + List<Api1101> listApi1101 = api1101Rep.findPushData(api1205.getKqdm()); + if (null != listApi1101 || listApi1101.size() > 0) { + shjdjwApi1205.setDwmc(listApi1101.get(0).getDwmc()); + } + + //鏌ヨ浠撴埧淇℃伅 + List<Api1103> listApi1103 = api1103Rep.findPushDataByCfdm(api1205.getHwdm().substring(0, 25)); + if (null != listApi1103 || listApi1103.size() > 0) { + shjdjwApi1205.setCfmc(listApi1103.get(0).getCfmc()); + } + + shjdjwApi1205.setDjlx("0"); + + //鏌ヨ瀛楀吀鏁版嵁 + ApiTrigger apiTrigger = apiTriggerService.findNameByCode(api1205.getLspzdm(), Constant.TRIGGER_P_LSPZ); + shjdjwApi1205.setWlmc(null == apiTrigger ? api1205.getLspzdm() : apiTrigger.getName()); + shjdjwApi1205.setDz(StringUtils.isNotEmpty(api1205.getXldd()) ? api1205.getXldd() : "搴撳唴"); + + shjdjwApi1205.setDksj(api1205.getDjsj()); + shjdjwApi1205.setLksj(api1205.getCmsj()); + shjdjwApi1205.setPch("0"); + return shjdjwApi1205; + } /** @@ -260,6 +425,15 @@ case "1209": //鎹熺泭鍗曟帴鍙g紪鐮� return ShjdjwApiCodeConstant.API_CODE_LS1311; + case "1310": + //璐ㄦ鎺ュ彛缂栫爜 + return ShjdjwApiCodeConstant.API_CODE_LS1201; + case "1403": + //杞崲璁″垝鎺ュ彛缂栫爜 + return ShjdjwApiCodeConstant.API_CODE_LS1501; + case "1404": + //杞崲璁″垝瀹屾垚鎯呭喌鎺ュ彛缂栫爜 + return ShjdjwApiCodeConstant.API_CODE_LS1502; default: return inteId; } @@ -268,7 +442,7 @@ //瑁呮崲灏佽 private void copyApi1202(Api1202 api1202, ShjdjwApi1202 shjdjwApi1202) { - BeanUtils.copyProperties(api1202,shjdjwApi1202); + BeanUtils.copyProperties(api1202, shjdjwApi1202); String ywdh = api1202.getRkywdh(); shjdjwApi1202.setYwdh(ywdh); shjdjwApi1202.setHwbm(api1202.getHwdm()); @@ -276,14 +450,14 @@ shjdjwApi1202.setLqxzbm(api1202.getLsxzdm()); shjdjwApi1202.setZjkl(api1202.getZjklxj()); //杞崲璁″垝鍗曞彿 - shjdjwApi1202.setJhbh(null); + shjdjwApi1202.setJhbh(api1202.getJhmxh()); //椤哄簭鍙� shjdjwApi1202.setSxh(ywdh.substring(ywdh.length() - 4)); shjdjwApi1202.setDjzt("2"); //涓氬姟鍗曞彿 - shjdjwApi1202.setJydbh(null); + shjdjwApi1202.setJydbh(api1202.getRkywdh()); //杞崲骞村害 - shjdjwApi1202.setLhnd(null); + shjdjwApi1202.setLhnd(api1202.getShnd()); //鎵规鍙� shjdjwApi1202.setPch("0"); } diff --git a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1202.java b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1202.java index d9dd3db..a8bff62 100644 --- a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1202.java +++ b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1202.java @@ -276,8 +276,7 @@ private String jydbh; @PropertyDef(label = "杞崲骞村害") - @JSONField(format = "yyyy") - private Date lhnd; + private String lhnd; @PropertyDef(label = "鎵规鍙�") private String Pch; diff --git a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1203.java b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1203.java index 13b2501..e7a1e1e 100644 --- a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1203.java +++ b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1203.java @@ -16,7 +16,8 @@ @EqualsAndHashCode(callSuper = false) public class ShjdjwApi1203 implements Serializable { - @Id + private static final long serialVersionUID = 1L; + @PropertyDef(label = "鍏ュ簱妫�楠屽崟鍙�") private String qydbh; diff --git a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1209.java b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1209.java index d2e35d3..979e516 100644 --- a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1209.java +++ b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1209.java @@ -67,7 +67,8 @@ private Double ckzz; @PropertyDef(label = "骞撮檺") - private String nx; + @JSONField(format = "yyyy") + private Date nx; @PropertyDef(label = "杈呮崯婧㈡暟閲�") private Double fsysl; diff --git a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1310.java b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1310.java new file mode 100644 index 0000000..78b3b81 --- /dev/null +++ b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1310.java @@ -0,0 +1,89 @@ +package com.fzzy.push.shjdjw2023.dto; + +import com.alibaba.fastjson.annotation.JSONField; +import com.bstek.dorado.annotation.PropertyDef; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.io.Serializable; +import java.util.Date; + +@Data +@EqualsAndHashCode(callSuper = false) +public class ShjdjwApi1310 implements Serializable { + + @PropertyDef(label = "璐ㄦ鎶ュ憡鍗曞彿") + private String zjbgdbh; + + @PropertyDef(label = "鍗曚綅鍚嶇О") + private String dwmc; + + @PropertyDef(label = "搴撶偣鍚嶇О") + private String kdmc; + + @PropertyDef(label = "浠撴埧鍚嶇О") + private String cfmc; + + @PropertyDef(label = "寤掗棿鍚嶇О") + private String ajmc; + + @PropertyDef(label = "绮鍝佺浠g爜") + private String pznm; + + @PropertyDef(label = "绮绛夌骇浠g爜") + private String skdjbm; + + @PropertyDef(label = "鍏ュ簱鏃ユ湡") + @JSONField(format = "yyyy-MM-dd") + private Date rkrq; + + @PropertyDef(label = "妫�楠岀被鍒�") + private String jylbbm; + + @PropertyDef(label = "妫�楠屽崟浣�") + private String jydw; + + @PropertyDef(label = "妫�楠屼緷鎹�") + private String jyyj; + + @PropertyDef(label = "鎸囨爣绫诲埆") + private String zblb; + + @PropertyDef(label = "妫�楠岄」鐩�") + private String jyxm; + + @PropertyDef(label = "妫�楠岀粨璁�") + private String jyjl; + + @PropertyDef(label = "鎸囨爣缁撴灉鍒ゅ畾") + private String zlzbjgpd; + + @PropertyDef(label = "鎵︽牱鏃堕棿") + @JSONField(format = "yyyy-MM-dd HH:mm:ss") + private Date qysj; + + @PropertyDef(label = "鏄惁姝e父瀛樺偍骞撮檺") + private String sfzcccnx; + + @PropertyDef(label = "鎿嶄綔鏍囧織") + private String czbz; + + @PropertyDef(label = "鍏ュ簱骞撮檺") + private Integer rknx; + + @PropertyDef(label = "妫�楠屾椂闂�") + private Date jysj; + + @PropertyDef(label = "鍝佺鍚嶇О") + private String wlzhmc; + + @PropertyDef(label = "绮鎬ц川") + private String lsxz; + + @PropertyDef(label = "椋熷搧瀹夊叏鎸囨爣璐ㄦ缁撴灉") + private String spaqzjjg; + + @PropertyDef(label = "鎵规鍙�") + private String pch; + +} diff --git a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1403.java b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1403.java new file mode 100644 index 0000000..e8e1e13 --- /dev/null +++ b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1403.java @@ -0,0 +1,73 @@ +package com.fzzy.push.shjdjw2023.dto; + +import com.alibaba.fastjson.annotation.JSONField; +import com.bstek.dorado.annotation.PropertyDef; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.io.Serializable; +import java.util.Date; + +@Data +@EqualsAndHashCode(callSuper = false) +public class ShjdjwApi1403 implements Serializable { + + + @PropertyDef(label = "杞崲璁″垝鍗曞彿") + private String jhbm; + + @PropertyDef(label = "璁″垝骞村害") + private String jhnd; + + @PropertyDef(label = "寮�濮嬫墽琛屾棩鏈�") + @JSONField(format = "yyyy-MM-dd") + private Date kszxrq; + + @PropertyDef(label = "鎴鎵ц鏃ユ湡") + @JSONField(format = "yyyy-MM-dd") + private Date jzzxrq; + + @PropertyDef(label = "璁″垝涓嬭揪鍗曚綅") + private String jhxddw; + + @PropertyDef(label = "璁″垝涓嬭揪鏃堕棿") + @JSONField(format = "yyyy-MM-dd") + private Date jhxdsj; + + @PropertyDef(label = "鎿嶄綔鏍囧織") + private String czbz; + + @PropertyDef(label = "璁″垝鍚嶇О") + private String jhmc; + + @PropertyDef(label = "鍝佺") + private String wlzhmc; + + @PropertyDef(label = "鏀惰幏骞村害") + private String shnd; + + @PropertyDef(label = "瀹為檯瀹屾垚鏃ユ湡") + private String sjwcrq; + + @PropertyDef(label = "璁″垝鐘舵��") + private String jhbz; + + @PropertyDef(label = "杞叆杞嚭绫诲瀷") + private String lrlclx; + + @PropertyDef(label = "杞叆鏁伴噺") + private Double lrsl; + + @PropertyDef(label = "杞嚭鏁伴噺") + private Double lcsl; + + @PropertyDef(label = "鏀惰喘鏁伴噺") + private Double sgsl; + + @PropertyDef(label = "閿�鍞暟閲�") + private Double xssl; + + @PropertyDef(label = "鎵规鍙�") + private String pch; + +} diff --git a/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1404.java b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1404.java new file mode 100644 index 0000000..bbca162 --- /dev/null +++ b/src/main/java/com/fzzy/push/shjdjw2023/dto/ShjdjwApi1404.java @@ -0,0 +1,35 @@ +package com.fzzy.push.shjdjw2023.dto; + +import com.bstek.dorado.annotation.PropertyDef; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.io.Serializable; + +@Data +@EqualsAndHashCode(callSuper = false) +public class ShjdjwApi1404 implements Serializable { + + @PropertyDef(label = "鍗曚綅鍚嶇О") + private String dwmc; + + @PropertyDef(label = "璁″垝骞村害") + private String jhnd; + + @PropertyDef(label = "璁″垝鏁伴噺") + private String jhsl; + + @PropertyDef(label = "宸叉墽琛屾暟閲�") + private String yzxsl; + + @PropertyDef(label = "鎵ц姣斾緥") + private String zxbl; + + @PropertyDef(label = "鎷涙爣/绔炰环姣斾緥") + private String zbjjbl; + + @PropertyDef(label = "鎿嶄綔鏍囧織") + private String czbz; + + +} -- Gitblit v1.9.3