并行流

src/main/java/org/springblade/founder/tjfx/service/impl/DwTjfxServiceImpl.java

@@ -12,10 +12,8 @@ import org.springblade.modules.system.entity.XzxtUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
+import java.util.stream.Collectors;
 
 @Service
 @DS("xzxt")
@@ -28,6 +26,7 @@ public class DwTjfxServiceImpl implements DwTjfxService {
 		Map<String, Object> rtMap = new HashMap<>();
 		Map<String, Object> paramMap=new HashMap<>();
 		List<DwXnpgTj> dataList = new ArrayList<>();
+		List<DwXnpgTj> res = new ArrayList<>();
 		if (StringUtils.isEmpty(unitcode)) {
 			XzxtUser xzxtUser = SecureUtil.getUserXzxt();
 			unitcode = xzxtUser.getUnitcode();//获取对应用户的单位
@@ -47,6 +46,9 @@ public class DwTjfxServiceImpl implements DwTjfxService {
 
 		dwLevMap.put("includeBdw","true");
 		List<DictitemXz> unitList = dwTjfxMapper.getXqdwList(dwLevMap);
+
+		List<DictitemXz> unit1=new ArrayList<>();
+		List<DictitemXz> unit2=new ArrayList<>();
 		int ajts=0;//案件总量
 		int cjsswpajs=0;//采集损失物品案件量
 		int wcjsswpajs=0;//未采集损失物品案件量
@@ -57,40 +59,102 @@ public class DwTjfxServiceImpl implements DwTjfxService {
 		int cjshrajl=0;//采集受害人案件量
 		int wcjshrajl=0;//未采集受害人案件量
 		int cjshrsl=0;//采集受害人数量
-		for (int i = 0; i < unitList.size(); i++) {
-			DictitemXz item = unitList.get(i);
-			String dwdm = item.getCode();
-			String dwmc = item.getName();
-			String dwtype="";
-			paramMap.put("unitcode", dwdm);
-			if (i == 0) {
-				paramMap.put("qryType", "bdw");
-				dwtype= "bdw";
-			} else {
-				paramMap.put("qryType", "bxq");
-				dwtype= "bxq";
+		if(unitList!=null && unitList.size()>0){
+			if(unitList.size()<2){
+				unit1=unitList.subList(0,1);
+				unit1.stream().parallel().forEach(item -> {
+
+					String dwdm = item.getCode();
+					String dwmc = item.getName();
+					String dwtype="";
+					paramMap.put("unitcode", dwdm);
+					paramMap.put("qryType", "bdw");
+					dwtype= "bdw";
+
+					DwXnpgTj dwXnpgTj = dwTjfxMapper.getDwTjFx(paramMap);
+
+					dwXnpgTj.setDwdm(dwdm);
+					dwXnpgTj.setDwmc(dwmc);
+					dwXnpgTj.setQryType(dwtype);
+
+					dataList.add(dwXnpgTj);
+				});
+			}else {
+				unit1=unitList.subList(0,1);
+				unit2=unitList.subList(1,unitList.size());
+				unit1.stream().parallel().forEach(item -> {
+
+					String dwdm = item.getCode();
+					String dwmc = item.getName();
+					String dwtype="";
+					paramMap.put("unitcode", dwdm);
+						paramMap.put("qryType", "bdw");
+						dwtype= "bdw";
+
+					DwXnpgTj dwXnpgTj = dwTjfxMapper.getDwTjFx(paramMap);
+
+					dwXnpgTj.setDwdm(dwdm);
+					dwXnpgTj.setDwmc(dwmc);
+					dwXnpgTj.setQryType(dwtype);
+
+					dataList.add(dwXnpgTj);
+				});
+				unit2.stream().parallel().forEach(item -> {
+
+					String dwdm = item.getCode();
+					String dwmc = item.getName();
+					String dwtype="";
+					paramMap.put("unitcode", dwdm);
+					paramMap.put("qryType", "bxq");
+					dwtype= "bxq";
+
+					DwXnpgTj dwXnpgTj = dwTjfxMapper.getDwTjFx(paramMap);
+
+					dwXnpgTj.setDwdm(dwdm);
+					dwXnpgTj.setDwmc(dwmc);
+					dwXnpgTj.setQryType(dwtype);
+
+					dataList.add(dwXnpgTj);
+				});
+
+
 			}
 
-			DwXnpgTj dwXnpgTj = dwTjfxMapper.getDwTjFx(paramMap);
-//			if (dwXnpgTj.getAjts() == 0) {
-//				continue;
-//			}
-			System.out.println("unitcode"+dwdm+":===="+ JSON.toJSONString(dwXnpgTj));
-			dwXnpgTj.setDwdm(dwdm);
-			dwXnpgTj.setDwmc(dwmc);
-			dwXnpgTj.setQryType(dwtype);
-			ajts += dwXnpgTj.getAjts();
-			cjsswpajs += dwXnpgTj.getCjsswpajs();
-			wcjsswpajs += dwXnpgTj.getWcjsswpajs();
-			cssswpsl += dwXnpgTj.getCssswpsl();
-			cjxyrajl += dwXnpgTj.getCjxyrajl();
-			wcjxyrajl += dwXnpgTj.getWcjxyrajl();
-			cjxyrsl += dwXnpgTj.getCjxyrsl();
-			cjshrajl += dwXnpgTj.getCjshrajl();
-			wcjshrajl+= dwXnpgTj.getWcjshrajl();
-			cjshrsl += dwXnpgTj.getCjshrsl();
-			dataList.add(dwXnpgTj);
 		}
+//		for (int i = 0; i < unitList.size(); i++) {
+//			DictitemXz item = unitList.get(i);
+//			String dwdm = item.getCode();
+//			String dwmc = item.getName();
+//			String dwtype="";
+//			paramMap.put("unitcode", dwdm);
+//			if (i == 0) {
+//				paramMap.put("qryType", "bdw");
+//				dwtype= "bdw";
+//			} else {
+//				paramMap.put("qryType", "bxq");
+//				dwtype= "bxq";
+//			}
+//
+//			DwXnpgTj dwXnpgTj = dwTjfxMapper.getDwTjFx(paramMap);
+////			if (dwXnpgTj.getAjts() == 0) {
+////				continue;
+////			}
+//			System.out.println("unitcode"+dwdm+":===="+ JSON.toJSONString(dwXnpgTj));
+//			dwXnpgTj.setDwdm(dwdm);
+//			dwXnpgTj.setDwmc(dwmc);
+//			dwXnpgTj.setQryType(dwtype);
+//			ajts += dwXnpgTj.getAjts();
+//			cjsswpajs += dwXnpgTj.getCjsswpajs();
+//			wcjsswpajs += dwXnpgTj.getWcjsswpajs();
+//			cssswpsl += dwXnpgTj.getCssswpsl();
+//			cjxyrajl += dwXnpgTj.getCjxyrajl();
+//			wcjxyrajl += dwXnpgTj.getWcjxyrajl();
+//			cjxyrsl += dwXnpgTj.getCjxyrsl();
+//			cjshrajl += dwXnpgTj.getCjshrajl();
+//			wcjshrajl+= dwXnpgTj.getWcjshrajl();
+//			cjshrsl += dwXnpgTj.getCjshrsl();
+//			dataList.add(dwXnpgTj);
+//		}
 //		DwXnpgTj dwXnpgTj = new DwXnpgTj();
 //		dwXnpgTj.setDwdm("");
 //		dwXnpgTj.setDwmc("合计");
@@ -105,8 +169,9 @@ public class DwTjfxServiceImpl implements DwTjfxService {
 //		dwXnpgTj.setWcjshrajl(wcjshrajl);
 //		dwXnpgTj.setCjshrsl(cjshrsl);
 //		dataList.add(dwXnpgTj);
-
-		rtMap.put("rows",dataList);
+		res = dataList.stream().sorted(Comparator.comparing(DwXnpgTj::getDwdm))
+			.collect(Collectors.toList());
+		rtMap.put("rows",res);
 		return rtMap;
 	}