jiangjiazhi / regional-platform

Commit f3aab027e5d1b0ea6c8e9d9849a5df16e8b47153

Authored by shiyang about 3 years ago

Exists in master and in 6 other branches

隆化-儿童档案，儿童居住地同步到儿童户籍地(隆化地区跑数据)

Showing 3 changed files with 55 additions and 2 deletions

platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/CdGwController.java
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BabySieveFacede.java

...	...	@@ -146,10 +146,10 @@
146	146	if ("saveChFs".equals(typeStr)) {
147	147	return cdGwInterface.saveChFs(startTime, endTime);
148	148	}
149		- if ("saveEtDa".equals(typeStr)) {//需要排查
	149	+ if ("saveEtDa".equals(typeStr)) {
150	150	return cdGwInterface.saveEtDa(startTime, endTime);
151	151	}
152		- if ("saveXsrFs".equals(typeStr)) {
	152	+ if ("saveXsrFs".equals(typeStr)) {//需要排查
153	153	return cdGwInterface.saveXsrFs(startTime, endTime);
154	154	}
155	155	if ("saveEb".equals(typeStr)) {

...	...	@@ -5133,5 +5133,16 @@
5133	5133
5134	5134	}
5135	5135
	5136	+ /**
	5137	+ * 隆化-儿童档案，儿童居住地同步到儿童户籍地
	5138	+ * @param hospitalId 地区id 必填
	5139	+ * @return
	5140	+ */
	5141	+ @RequestMapping(value = "/syncBabyArchivesAddress", method = RequestMethod.GET)
	5142	+ @ResponseBody
	5143	+ @TokenRequired
	5144	+ public BaseObjectResponse syncBabyArchivesAddress(@RequestParam(required = false) String hospitalId) {
	5145	+ return babySieveFacede.syncBabyArchivesAddress(hospitalId);
	5146	+ }
5136	5147	}

...	...	@@ -43,6 +43,7 @@
43	43	import java.util.*;
44	44	import java.util.concurrent.Callable;
45	45	import java.util.concurrent.Future;
	46	+import java.util.concurrent.TimeUnit;
46	47
47	48	/**
48	49	* 新生儿筛查
...	...	@@ -1718,5 +1719,46 @@
1718	1719	//System.out.print("我是定时任务！！！");
1719	1720	}
1720	1721
	1722	+ public BaseObjectResponse syncBabyArchivesAddress(String hospitalId) {
	1723	+ BaseObjectResponse objectResponse = new BaseObjectResponse();
	1724	+ if(StringUtils.isEmpty(hospitalId)){
	1725	+ objectResponse.setErrorcode(ErrorCodeConstants.PARAMETER_ERROR);
	1726	+ objectResponse.setErrormsg("失败");
	1727	+ return objectResponse;
	1728	+ }
	1729	+ BabyModelQuery babyQuery=new BabyModelQuery();
	1730	+ babyQuery.setYn(YnEnums.YES.getId());
	1731	+ babyQuery.setHospitalId(hospitalId);
	1732	+ List<BabyModel> list=babyBookbuildingService.queryBabyBuildByCond(babyQuery);
	1733	+ int batchSize = 20;
	1734	+ int end = 0;
	1735	+ List <Future> listFuture = new ArrayList <>();
	1736	+ for (int i = 0; i < list.size(); i += batchSize) {
	1737	+ end = (end + batchSize);
	1738	+ if (end > list.size()) {
	1739	+ end = list.size();
	1740	+ }
	1741	+ final List<BabyModel> babyModelList = list.subList(i, end);
	1742	+ listFuture.add(commonThreadPool.submit(new Callable() {
	1743	+ @Override
	1744	+ public Object call() throws Exception {
	1745	+ if (CollectionUtils.isNotEmpty(babyModelList)) {
	1746	+ for (BabyModel babyModel : babyModelList){
	1747	+ babyModel.setBabyProvinceId(babyModel.getProvinceId());
	1748	+ babyModel.setBabyCityId(babyModel.getCityId());
	1749	+ babyModel.setBabyAreaId(babyModel.getAreaId());
	1750	+ babyModel.setBabyStreetId(babyModel.getStreetId());
	1751	+ babyModel.setBabyAddress(babyModel.getAddress());
	1752	+ babyBookbuildingService.updateBabyBuild(babyModel,babyModel.getId());
	1753	+ }
	1754	+ }
	1755	+ return null;
	1756	+ }
	1757	+ }));
	1758	+ }
	1759	+ objectResponse.setErrorcode(ErrorCodeConstants.SUCCESS);
	1760	+ objectResponse.setErrormsg("成功");
	1761	+ return objectResponse;
	1762	+ }
1721	1763	}