任务结果分类提交

common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/SkRegionalsDetail.java

@@ -56,8 +56,14 @@ public class SkRegionalsDetail extends Model<SkRegionalsDetail> {
      * 是否删除，0代表未删除，1代表删除
      */
     private String isdeleted;
-
-
+    /**
+     * 手机号码(运营商)
+     */
+    private String serviceProvider;
+    /**
+     * 手机号码(归属地)
+     */
+    private String attribution;
     /**
      * 获取主键值
      *

service/publicapi/src/main/java/com/founder/publicapi/controller/SkDataOperation/SkRegionalsResultController.java

@@ -11,6 +11,7 @@ import com.founder.commonutils.model.vo.param.SkRegionalsResultAllParam;
 import com.founder.commonutils.model.vo.param.SkRegionalsResultParam;
 import com.founder.commonutils.model.vo.param.SkRegionalsResultSaveParam;
 import com.founder.commonutils.util.*;
+import com.founder.publicapi.mapper.mysqlMapper.TbStAsjMapper;
 import com.founder.publicapi.service.SkRegionalsDetailService;
 import com.founder.publicapi.service.SkRegionalsPersonService;
 import com.founder.publicapi.service.SkRegionalsTaskService;
@@ -58,6 +59,8 @@ public class SkRegionalsResultController extends ApiController implements ExcelC
      */
     @Resource
     private SkRegionalsTaskService skRegionalsTaskService;
+    @Autowired
+    private TbStAsjMapper tbStAsjMapper;
     /**
      * 新增结果信息
      */
@@ -245,6 +248,31 @@ public class SkRegionalsResultController extends ApiController implements ExcelC
 
     }
 
+    @PostMapping("queryResultFl")
+    @ApiOperation(value = "查询结果列表信息分类")
+    //@OperLog(message = "查询结果列表信息分类", operation = OperationType.QUERY)
+    public MapRestResult queryResultFl(@RequestBody String taskId) {
+        QueryWrapper queryWrapper = new QueryWrapper();
+        queryWrapper.eq("taskid", taskId);
+        queryWrapper.eq("isDeleted", "0");
+        List<SkRegionalsTask>  taskList = skRegionalsTaskService.list(queryWrapper);
+        if(taskList.size()>0) {
+            String taskType = taskList.get(0).getTasktype();
+
+            // 1.2根据任务类型  走不同接口
+            switch (taskType) {
+                case "skhs_car":
+                    // 获取任务结果分类
+                    break;//车辆回溯
+                case "skhs_people":
+                    // 获取任务结果分类  运营商分类  归属地分类
+                    break;//基站回溯
+            }
+        }
+        return new MapRestResult(200, "OK", "1", "1");
+
+    }
+
     @Override
     public void setService(String bean) {
         if (skRegionalsResultService == null) {
@@ -298,13 +326,18 @@ public class SkRegionalsResultController extends ApiController implements ExcelC
                     skRegionalsDetail.setObjecttype(p.getObjecttype());// 类型
                     skRegionalsDetail.setObjecttypename(p.getObjecttypename());// 类型名称
                     skRegionalsDetail.setObjectvalue(p.getObjectvalue());// 标识号值
+                    // 如果是基站回溯 翻译手机号归属地和运营商
+                    if("skhs_people".equals(p.getObjecttype())){
+                        skRegionalsDetail.setServiceProvider("移动运营商");
+                        skRegionalsDetail.setAttribution("重庆市北碚区");
+                    }
                     boolean savesDetail = skRegionalsDetailService.save(skRegionalsDetail);
                     if(savesDetail){// 翻译成功通过身份证拿到人员基本信息
                         // 先查看身份证对应人信息是否已存在
                         SkRegionalsPerson skRegionalsPerson=new SkRegionalsPerson();
                         skRegionalsPerson.setSfzhm("460003198912096617");// 证件号码
                         skRegionalsPerson.setSfcheck("1");// 是否翻译成功
-                        skRegionalsPerson.setSffzxyr("0");// 是否犯罪嫌疑人
+                        skRegionalsPerson.setSffzxyr(String.valueOf(tbStAsjMapper.getQkryBySfzh(skRegionalsPerson.getSfzhm())));// 是否犯罪嫌疑人
                         QueryWrapper queryWrapper = new QueryWrapper();
                         queryWrapper.eq("sfzhm", skRegionalsPerson.getSfzhm());
                         if(skRegionalsPersonService.list(queryWrapper).size()==0){

service/publicapi/src/main/java/com/founder/publicapi/mapper/mysqlMapper/TbStAsjMapper.java

@@ -44,4 +44,7 @@ public interface TbStAsjMapper extends BaseMapper<TbStAsj> {
     List<ZdryResult> getZdry(ZdryParams params);
 
     List<ZdcsResult> getQkryByTime(SkPointlocationParams params);
+
+    Integer getQkryBySfzh(@Param(value = "zjhm")String zjhm);
+
 }

service/publicapi/src/main/java/com/founder/publicapi/mapper/mysqlMapper/xml/TbStAsjMapper.xml

@@ -254,4 +254,10 @@
             AND a.KSSJ <![CDATA[<=]]> DATE_FORMAT(#{jssj},'%Y-%m-%d %H:%i:%S')
         </if>
     </select>
+    <select id="getQkryBySfzh" parameterType="java.lang.String" resultType="Integer">
+        select
+        count(*)
+        from tb_xw_zbfzxyr a
+        where a.zhfzxyr_cyzj_zjhm = #{sfzh}
+    </select>
 </mapper>

service/publicapi/src/main/resources/data/getJzhs.json

@@ -13,6 +13,7 @@
     "y": "19.925187",
     "time": "2022-03-01 11:50:08",
     "deviceid": "54000001031321014658",
+    "deviceid": "54000001031321014658",
     "devicename": "HSQMB-ZN1412A交包头大街与达尔登路路口2D8340"
   }
 ]
\ No newline at end of file