增加嫌疑人为空的积案数据检测

src/main/java/org/springblade/founder/asj/controller/AjxxzljcController.java

@@ -100,7 +100,25 @@ public class AjxxzljcController {
 	@LogOper(czxxLbdm = "03",yymcJyqk = "检查补采后数据是否合格")
 	public R insertXcc(@RequestBody TbStAsj  tbStAsj){
 		try {
-			ajxxzljcService.insertXcc(tbStAsj);
+			String ajType = tbStAsj.getAjType();
+			if ("xa".equals(ajType)) {
+				ajxxzljcService.insertXcc(tbStAsj);
+			}else if ("ja".equals(ajType)){
+				ajxxzljcService.updateJajcxx(tbStAsj);
+			}
+			return R.ok();
+		}catch (Exception e){
+			e.printStackTrace();
+			return R.error().message(e.getMessage());
+		}
+	}
+
+	//修改积案被害人为空的数据为不合格
+	@RequestMapping("/updateJaxxSfhg")
+	@ResponseBody
+	public R updateJaxxSfhg(){
+		try {
+			ajxxzljcService.updateJaxxSfhg();
 			return R.ok();
 		}catch (Exception e){
 			e.printStackTrace();

src/main/java/org/springblade/founder/asj/mapper/AjxxzljcMapper.java

 package org.springblade.founder.asj.mapper;
 
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 import org.springblade.founder.asj.entity.TbStAsj;
 import org.springframework.stereotype.Component;
 
@@ -16,9 +17,15 @@ import java.util.List;
 public interface AjxxzljcMapper {
 //	获取全部的案件信息
 	List<TbStAsj> getQbajxx();
+
+	//	获取无受害人的积案信息
+	List<TbStAsj> getJabccj();
+
 //	根据asjbh  更新  tbstasj表
 	void updateTbSta(TbStAsj tbStAsj);
 
+	void updateJasfhg(@Param("list") List<String> list);
+
 //	根据asjbh 获取  案件信息
 	TbStAsj  getAjxxByAsjbh(String asjbh);
 }

src/main/java/org/springblade/founder/asj/mapper/AjxxzljcMapper.xml

@@ -75,4 +75,28 @@
         WHERE ASJBH = #{asjbh,jdbcType=VARCHAR}
     </update>
 
+    <select id="getJabccj" resultType="org.springblade.founder.asj.entity.TbStAsj">
+        select
+		asj.asjbh as asjbh
+        from
+        tb_st_asj asj inner join tb_xw_asjcz cz on asj.asjbh=cz.asjbh
+        where asj.xxsc_pdbz='0'
+        and cz.laywsjzt ='02'
+        and asj.sfma_pdbz = '1'
+        and (cz.zczjywsjzt != '02' or cz.zczjywsjzt is null or cz.zczjywsjzt = '')
+        and DATE_FORMAT(asj.larq,'%Y-%m-%d') <![CDATA[<]]> '2021-01-01'
+        and asj.asjbh not in(select asjbh from tb_xw_rybh where asjbh is not null)
+    </select>
+
+    <update id="updateJasfhg" parameterType="java.util.List">
+        update tb_st_asj set
+        flwssfhgpdbz = '2'
+        where asjbh in
+        <foreach collection="list" item="item" open="(" separator="," close=")">
+            #{item }
+        </foreach>
+    </update>
+
+
+
 </mapper>

src/main/java/org/springblade/founder/asj/service/IAjxxzljcService.java

@@ -23,6 +23,12 @@ public interface IAjxxzljcService {
 	//历史数据补采时，检查补采后数据是否合格
 	void insertXcc(TbStAsj jbasj)throws Exception;
 
+	//修改积案被害人为空的数据为不合格
+	void updateJaxxSfhg()throws Exception;
+
+	//积案历史数据补采时，检查补采后数据是否合格
+	void updateJajcxx(TbStAsj  jbasj)throws Exception;
+
 //	根据asjbh获取对应案件的不合格  的字段
 	Map<String, Object> getSfhgXxx(String asjbh)throws Exception;
 

src/main/java/org/springblade/founder/asj/service/StAsjXxtqService.java

@@ -240,6 +240,7 @@ public class StAsjXxtqService {
 		}
 		if(data!=null && !data.isEmpty()){
 			StAsj queryAsj = new StAsj();
+
 			queryAsj.setAsjbh(query.getAsjbh());
 			queryAsj.setXxscPdbz("0");
 			StAsj stAsj = stAsjService.getOne(Condition.getQueryWrapper(queryAsj));

src/main/java/org/springblade/founder/asj/service/impl/AjxxzljcServiceImpl.java

@@ -140,6 +140,31 @@ public class AjxxzljcServiceImpl implements IAjxxzljcService {
 	}
 
 
+	//修改积案被害人为空的数据为不合格
+	@Override
+	public void updateJaxxSfhg()throws Exception{
+		List<String> ajbhList =new ArrayList<>();
+		List<TbStAsj> list = ajxxzljcMapper.getJabccj();
+		for (TbStAsj tbStAsj:list) {
+			ajbhList.add(tbStAsj.getAsjbh());
+		}
+		ajxxzljcMapper.updateJasfhg(ajbhList);
+	}
+	@Override
+	public void updateJajcxx(TbStAsj  jbasj){
+		TbStAsj tbStAsj = new TbStAsj();
+		Boolean result = getJcjaxx(jbasj);
+		tbStAsj.setAsjbh(jbasj.getAsjbh());
+		//检查案件信息和被害人信息
+		if(result) {
+			tbStAsj.setFlwssfhgpdbz("3"); //合格
+		}else {
+			tbStAsj.setFlwssfhgpdbz("2"); //不合格
+		}
+		ajxxzljcMapper.updateTbSta(tbStAsj);
+	}
+
+
 	private Boolean getJtxx(TbStAsj  jbasj){
 //		遍历出来的jbasj是  每一条数据，现在对每一个数据进行质量检测
 
@@ -152,47 +177,54 @@ public class AjxxzljcServiceImpl implements IAjxxzljcService {
 
 		Map<String, Object> jbxxlamap = ajspService.checkAsjjbxxAll(asjbh);//检查案件基本信息
 		ajFlag = (boolean)jbxxlamap.get("result");
-
 		if (ajFlag) {
 			Map<String, Object> bhrmap = ajspService.checkBhr(asjbh);//检查被害人信息
 			bhrFlag = (boolean) bhrmap.get("result");
 		}
-
 		if (ajFlag&&bhrFlag) {
 			Map<String, Object> fzxyrmap = ajspService.checkFzxry(asjbh);//检查嫌疑人信息
 			xyrFlag = (boolean) fzxyrmap.get("result");
 		}
-
 		result=ajFlag&&xyrFlag&&bhrFlag;
 		return result;
 	}
 
 	private Boolean getFlwsjc(TbStAsj  jbasj){
 //		遍历出来的jbasj是  每一条数据，现在对每一个数据进行质量检测
-
 		String asjbh = jbasj.getAsjbh();//获取每一个案件的asjbh
 		boolean result= true;
 		boolean ajWsFlag= true; //法律文书   是否合格判断标志
 
 		boolean xyrWsFlag = true;
 
-
 		//检查法律文书
 		Map<String, Object> ajlaWsmap = ajspService.checkAsjflwsAll(asjbh);//检查法律文书信息
 		ajWsFlag = (boolean)ajlaWsmap.get("result");
-
 		if (ajWsFlag) {
 			//检查嫌疑人法律文书
 			Map<String, Object> xyrflwsmap = ajspService.checkFzxryFlws(asjbh);//检查嫌疑人法律文书信息
 			xyrWsFlag = (boolean) xyrflwsmap.get("result");
 		}
-
-
 		result=ajWsFlag&&xyrWsFlag;
 		return result;
 	}
 
+	private Boolean getJcjaxx(TbStAsj  jbasj){
+//		遍历出来的jbasj是  每一条数据，现在对每一个数据进行质量检测
 
+		String asjbh = jbasj.getAsjbh();//获取每一个案件的asjbh
+		boolean result= true;
+		boolean ajFlag= true; //案件基本信息  是否合格判断标志
+		boolean bhrFlag = true;
+		Map<String, Object> jbxxlamap = ajspService.checkAsjjbxxAll(asjbh);//检查案件基本信息
+		ajFlag = (boolean)jbxxlamap.get("result");
+		if (ajFlag) {
+			Map<String, Object> bhrmap = ajspService.checkBhr(asjbh);//检查被害人信息
+			bhrFlag = (boolean) bhrmap.get("result");
+		}
+		result=ajFlag&&bhrFlag;
+		return result;
+	}
 
 
 //	返回的数据