布控新增车牌号

src/main/java/com/founder/interservice/bkxx/service/impl/BkScheduleService.java

@@ -5,6 +5,8 @@ import com.founder.interservice.bkxx.model.Bkxx;
 import com.founder.interservice.bkxx.repository.BkTaskResultRepository;
 import com.founder.interservice.bkxx.repository.BkxxRepository;
 import com.founder.interservice.mapper.xzxt.BkxxMapper;
+import com.founder.interservice.model.Track;
+import com.founder.interservice.util.DateUtil;
 import com.founder.interservice.util.KeyUtil;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -229,7 +231,44 @@ public class BkScheduleService {
                     task.setXgsj(new Date());
                     bkxxRepository.save(task);
                 }
+            }else if ("005".equals(bshlx)){
+               /* System.out.println("============进入了005的任务==========");*/
+                    List<String> oldCphms = new ArrayList<>();
+                    String kssj = DateUtil.getDate().getTime()+"";
+                    String jssj = DateUtil.convertStringToDate(DateUtil.beforeDate(-1).substring(0,10)).getTime()+"";
+                    //每次保存之前进行重复判断
+                    List<BkTaskResult> bkTaskResults = bkTaskResultRepository.findBkResultsByBkXxzjbh(task.getXxzjbh());
+              /*  System.out.println("============005的任务==========当前的xxzjbh========"+task.getXxzjbh());*/
+                    if(bkTaskResults!=null&&bkTaskResults.size()>0){
+                        /*System.out.println("============进入了005的任务==========有重复=====================");*/
+                        for (BkTaskResult oldResult:bkTaskResults) {
+                            oldCphms.add(oldResult.getBkbsh());
                         }
+                        if(!oldCphms.contains(task.getBkdxhm())){
+                            //出现新的车牌号码
+                            //直接获取轨迹信息
+                            Track newLocation = bkServiceCommon.getNewLocation(task.getBkdxhm(),kssj,jssj);
+                            BkTaskResult bkTaskResult = bkServiceCommon.setBkResult( newLocation, task, "","");
+                            bkTaskResult.setFlag("01");
+                            bkTaskResult.setType(taskType);
+                            bkTaskResult.setXxly(task.getSqr_xm());
+                            bkTaskResult.setXxlytype("02");
+                            bkTaskResultRepository.save(bkTaskResult);
+                        }
+                    }else{
+                        //此数据库中没有
+                        //出现新的车牌号
+                        Track newLocation = bkServiceCommon.getNewLocation(task.getBkdxhm(),kssj,jssj);
+                        BkTaskResult bkTaskResult = bkServiceCommon.setBkResult( newLocation, task, "","");
+                        bkTaskResult.setType(taskType);
+                        bkTaskResult.setFlag("01");
+                        bkTaskResultRepository.save(bkTaskResult);
+                    }
+                    }
+                    //保存结果之后，更新任务状态，表示有结果返回
+                    task.setBkzt("02");
+                    task.setXgsj(new Date());
+                    bkxxRepository.save(task);
                 }
     }
 

src/main/java/com/founder/interservice/bkxx/service/impl/BkServiceImpl.java

@@ -11,6 +11,8 @@ import com.founder.interservice.bkxx.service.BkService;
 import com.founder.interservice.enums.ResultEnum;
 import com.founder.interservice.exception.InterServiceException;
 import com.founder.interservice.mapper.xzxt.BkxxMapper;
+import com.founder.interservice.model.Track;
+import com.founder.interservice.util.DateUtil;
 import com.founder.interservice.util.KeyUtil;
 import com.founder.interservice.util.ResultVOUtil;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -111,6 +113,35 @@ public class BkServiceImpl implements BkService{
                         }
                     }
                 }
+            }else if("005".equals(bkxx.getBkdxlx())){
+                //005:车牌号
+                List<String> oldCphm = new ArrayList<>();
+                String kssj = DateUtil.getDate().getTime()+"";
+                String jssj = DateUtil.convertStringToDate(DateUtil.beforeDate(-1).substring(0,10)).getTime()+"";
+              /*  System.out.println("=============================进来了=========================");
+                System.out.println("=============================进来了=============信息主键============"+bkxx.getXxzjbh());*/
+                List<BkTaskResult> bkTaskResults = bkTaskResultRepository.findBkResultsByBkXxzjbh(bkxx.getXxzjbh());
+              /*  System.out.println("=============================进来了=============判重成功了============"+bkTaskResults.size());*/
+                if(bkTaskResults!=null&&bkTaskResults.size()>0){
+                    for (BkTaskResult oldResult:bkTaskResults){
+                        oldCphm.add(oldResult.getBkbsh());
+                    }
+                    if (!oldCphm.contains(bkxx.getBkdxhm())){
+                        //在库中不存在
+                        //直接获取轨迹信息
+                        Track newLocation = bkServiceCommon.getNewLocation(bkxx.getBkdxhm(),kssj,jssj);
+                       /* System.out.print("获取的轨迹信息:"+newLocation.getAddress()+";==经纬度="+newLocation.getJ()+"===纬度"+newLocation.getW());*/
+                        BkTaskResult bkTaskResult = bkServiceCommon.setBkResult( newLocation, bkxx, "", "");
+                        bkTaskResultRepository.save(bkTaskResult);
+                    }
+                }else {
+                    //关于此数据，库中没有结果
+                    //直接获取轨迹信息
+                    Track newLocation = bkServiceCommon.getNewLocation(bkxx.getBkdxhm(),kssj,jssj);
+             /*       System.out.println("=============================进来了==查询了轨迹============"+newLocation.getAddress());*/
+                    BkTaskResult bkTaskResult = bkServiceCommon.setBkResult( newLocation, bkxx, "", "");
+                    bkTaskResultRepository.save(bkTaskResult);
+                }
             }
 
         } else {