Commit e8bd3b15 by yangyang

任务相关对接接口

parent 60250353
...@@ -83,5 +83,6 @@ public class TbStAsjParm implements Serializable { ...@@ -83,5 +83,6 @@ public class TbStAsjParm implements Serializable {
@ApiModelProperty(value = "破案标记") @ApiModelProperty(value = "破案标记")
private String pabj_pdbz; private String pabj_pdbz;
@ApiModelProperty(value = "立案单位公安机关代码")
private String ladwGajgjgdm;
} }
...@@ -29,7 +29,7 @@ import java.util.Map; ...@@ -29,7 +29,7 @@ import java.util.Map;
public class JwtUser { public class JwtUser {
// @Value("${jwt.secret}") // @Value("${jwt.secret}")
public String base64Security="bWFwLXBsYXRmb3JtLWRvbmdndWFuLTIwMTktMTEtNg=="; public String base64Security="bWFwLXBsYXRmb3JtLWRvbmdndWFuLTIwMTktMTEtNg==";
final static long ttlMillis = 1000 * 60 * 60;//过期时间,30分钟 final static long ttlMillis = 1000 * 60 * 60 * 24;//过期时间,24小时
private static final Logger logger = LoggerFactory.getLogger(JwtUser.class); private static final Logger logger = LoggerFactory.getLogger(JwtUser.class);
/** /**
* 创建jwt * 创建jwt
......
...@@ -123,7 +123,7 @@ public class PhoneUtil { ...@@ -123,7 +123,7 @@ public class PhoneUtil {
public static void main(String[] main){ public static void main(String[] main){
System.out.println(getCarrier("15754879533", "86")); System.out.println(getCarrier("13900733224", "86"));
System.out.println(getGeo("15754879533", "86")); System.out.println(getGeo("13900733224", "86"));
} }
} }
\ No newline at end of file
...@@ -49,15 +49,6 @@ ...@@ -49,15 +49,6 @@
<scope>provided </scope> <scope>provided </scope>
</dependency> </dependency>
<!-- &lt;!&ndash;swagger&ndash;&gt;
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
</dependency>-->
<dependency> <dependency>
<groupId>com.github.xiaoymin</groupId> <groupId>com.github.xiaoymin</groupId>
<artifactId>knife4j-spring-boot-starter</artifactId> <artifactId>knife4j-spring-boot-starter</artifactId>
......
...@@ -146,7 +146,7 @@ public class SkDictionaryController implements ExcelControllerInterface { ...@@ -146,7 +146,7 @@ public class SkDictionaryController implements ExcelControllerInterface {
@OperLog(message = "查找所有代码类型",operation = OperationType.QUERY) @OperLog(message = "查找所有代码类型",operation = OperationType.QUERY)
public MapRestResult queryAllDmlx(){ public MapRestResult queryAllDmlx(){
QueryWrapper queryWrapper=new QueryWrapper(); QueryWrapper queryWrapper=new QueryWrapper();
queryWrapper.groupBy("dmlx"); queryWrapper.groupBy("dmlx","dmms");
queryWrapper.eq("isDeleted","0"); queryWrapper.eq("isDeleted","0");
queryWrapper.select("dmlx","dmms"); queryWrapper.select("dmlx","dmms");
......
...@@ -111,15 +111,7 @@ ...@@ -111,15 +111,7 @@
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId> <artifactId>spring-boot-starter-aop</artifactId>
</dependency> </dependency>
<!--swagger--> <!--swagger升级版本-->
<!-- <dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
</dependency>-->
<dependency> <dependency>
<groupId>com.github.xiaoymin</groupId> <groupId>com.github.xiaoymin</groupId>
<artifactId>knife4j-spring-boot-starter</artifactId> <artifactId>knife4j-spring-boot-starter</artifactId>
......
...@@ -11,7 +11,7 @@ ...@@ -11,7 +11,7 @@
<artifactId>publicapi</artifactId> <artifactId>publicapi</artifactId>
<build> <build>
<finalName>publicapi</finalName> <finalName>publicapi1003</finalName>
<!--添加标签,防止编译时excel损坏--> <!--添加标签,防止编译时excel损坏-->
<resources> <resources>
......
...@@ -42,6 +42,8 @@ public class SkRegionalsPersonController extends ApiController implements ExcelC ...@@ -42,6 +42,8 @@ public class SkRegionalsPersonController extends ApiController implements ExcelC
*/ */
@Resource @Resource
private SkRegionalsPersonService skRegionalsPersonService; private SkRegionalsPersonService skRegionalsPersonService;
@Resource
private RyxxQgInterface ryxxQgInterface;
@Value("${environment}") @Value("${environment}")
private String environment; private String environment;
/** /**
...@@ -54,7 +56,7 @@ public class SkRegionalsPersonController extends ApiController implements ExcelC ...@@ -54,7 +56,7 @@ public class SkRegionalsPersonController extends ApiController implements ExcelC
SkRegionalsPerson skRegionalsPerson=new SkRegionalsPerson(); SkRegionalsPerson skRegionalsPerson=new SkRegionalsPerson();
BeanUtils.copyProperties(param,skRegionalsPerson); BeanUtils.copyProperties(param,skRegionalsPerson);
if (img!=null){ if (img!=null){
skRegionalsPerson.setImg(Base64Util.getBase64(img)); skRegionalsPerson.setImg("data:image/jpg;base64,"+Base64Util.getBase64(img));
} }
skRegionalsPerson.setXxzjbh(KeyUtil.getUUIDKey("RY")); skRegionalsPerson.setXxzjbh(KeyUtil.getUUIDKey("RY"));
boolean save = skRegionalsPersonService.save(skRegionalsPerson); boolean save = skRegionalsPersonService.save(skRegionalsPerson);
...@@ -141,7 +143,7 @@ public class SkRegionalsPersonController extends ApiController implements ExcelC ...@@ -141,7 +143,7 @@ public class SkRegionalsPersonController extends ApiController implements ExcelC
IPage page1 = skRegionalsPersonService.page(page, queryWrapper); IPage page1 = skRegionalsPersonService.page(page, queryWrapper);
return new MapRestResult(200, "OK", page1.getTotal(), page1.getRecords()); return new MapRestResult(200, "OK", page1.getTotal(), page1.getRecords());
} }
return RyxxQgInterface.getQgckAllxxXml(skRegionalsDetailParam.getSfzhm()); return ryxxQgInterface.getQgckAllxxXml(skRegionalsDetailParam.getSfzhm());
} }
@Override @Override
......
...@@ -451,7 +451,7 @@ public class SkRegionalsResultController extends ApiController implements ExcelC ...@@ -451,7 +451,7 @@ public class SkRegionalsResultController extends ApiController implements ExcelC
// 翻译表入库(根据结果中的车牌号或者手机号等拿到人员证件号码入库) // 翻译表入库(根据结果中的车牌号或者手机号等拿到人员证件号码入库)
skRegionalsDetail.setXxzjbh(KeyUtil.getUUIDKey("FY")); skRegionalsDetail.setXxzjbh(KeyUtil.getUUIDKey("FY"));
skRegionalsDetail.setResultid(xxzjbh);// 翻译表 skRegionalsDetail.setResultid(xxzjbh);// 翻译表
skRegionalsDetail.setSfzhm("460003198912096617");// 证件号码 skRegionalsDetail.setSfzhm("430123196510265891");// 证件号码
skRegionalsDetail.setObjecttype(p.getObjecttype());// 类型 skRegionalsDetail.setObjecttype(p.getObjecttype());// 类型
skRegionalsDetail.setObjecttypename(p.getObjecttypename());// 类型名称 skRegionalsDetail.setObjecttypename(p.getObjecttypename());// 类型名称
skRegionalsDetail.setObjectvalue(p.getObjectvalue());// 标识号值 skRegionalsDetail.setObjectvalue(p.getObjectvalue());// 标识号值
...@@ -465,7 +465,7 @@ public class SkRegionalsResultController extends ApiController implements ExcelC ...@@ -465,7 +465,7 @@ public class SkRegionalsResultController extends ApiController implements ExcelC
if(!"skhs_rx".equals(p.getObjecttype())&&!"qypz_rx".equals(p.getObjecttype())||!"skph_rx".equals(p.getObjecttype())){ if(!"skhs_rx".equals(p.getObjecttype())&&!"qypz_rx".equals(p.getObjecttype())||!"skph_rx".equals(p.getObjecttype())){
// 先查看身份证对应人信息是否已存在 // 先查看身份证对应人信息是否已存在
SkRegionalsPerson skRegionalsPerson=new SkRegionalsPerson(); SkRegionalsPerson skRegionalsPerson=new SkRegionalsPerson();
skRegionalsPerson.setSfzhm("460003198912096617");// 证件号码 skRegionalsPerson.setSfzhm("430123196510265891");// 证件号码
skRegionalsPerson.setSfcheck("1");// 是否翻译成功 skRegionalsPerson.setSfcheck("1");// 是否翻译成功
skRegionalsPerson.setSffzxyr(String.valueOf(tbStAsjMapper.getQkryBySfzh(skRegionalsPerson.getSfzhm())));// 是否犯罪嫌疑人 skRegionalsPerson.setSffzxyr(String.valueOf(tbStAsjMapper.getQkryBySfzh(skRegionalsPerson.getSfzhm())));// 是否犯罪嫌疑人
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper queryWrapper = new QueryWrapper();
......
...@@ -10,9 +10,10 @@ import org.dom4j.Document; ...@@ -10,9 +10,10 @@ import org.dom4j.Document;
import org.dom4j.DocumentHelper; import org.dom4j.DocumentHelper;
import org.dom4j.Element; import org.dom4j.Element;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
...@@ -20,16 +21,16 @@ import java.util.List; ...@@ -20,16 +21,16 @@ import java.util.List;
* 全国人员常口接口 * 全国人员常口接口
* *
*/ */
@Api(description = "全国人员常口接口") @Service
@RequestMapping(value="/ryxxqgIntegerface")
public class RyxxQgInterface { public class RyxxQgInterface {
@Autowired @Autowired
private static SysDictitemMapper sysDictitemMapper; private SysDictitemMapper sysDictitemMapper;
@ApiOperation(value = "获取全国常住人口信息") @ApiOperation(value = "获取全国常住人口信息")
@PostMapping("/ryxxQg") @PostMapping("/ryxxQg")
public static MapRestResult getQgckAllxxXml(String zjhm){ public MapRestResult getQgckAllxxXml(String zjhm){
List<SkRegionalsPerson> listSkRegionalsPerson = new ArrayList<>();
SkRegionalsPerson ryxx=new SkRegionalsPerson(); SkRegionalsPerson ryxx=new SkRegionalsPerson();
String esbServiceReturn=""; String esbServiceReturn="";
//String url="http://10.100.17.115:8080/NmgEsbQueryService/QueryLocalPersonForOther?conditions=sfzh="+"'"+zjhm+"'"; //String url="http://10.100.17.115:8080/NmgEsbQueryService/QueryLocalPersonForOther?conditions=sfzh="+"'"+zjhm+"'";
...@@ -41,11 +42,12 @@ public class RyxxQgInterface { ...@@ -41,11 +42,12 @@ public class RyxxQgInterface {
return MapRestResult.error("失败"+e); return MapRestResult.error("失败"+e);
} }
ryxx=getryJbxxxmls(esbServiceReturn); ryxx=getryJbxxxmls(esbServiceReturn);
return MapRestResult.build(200,"成功获取全国常口人员信息",ryxx); listSkRegionalsPerson.add(ryxx);
return MapRestResult.build(200, "OK",listSkRegionalsPerson.size(),listSkRegionalsPerson);
} }
public static SkRegionalsPerson getryJbxxxmls(String esb_result){ public SkRegionalsPerson getryJbxxxmls(String esb_result){
SkRegionalsPerson resulryxx=new SkRegionalsPerson(); SkRegionalsPerson resulryxx=new SkRegionalsPerson();
/* esb_result = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>"+ /* esb_result = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>"+
"<RBSPMessage>"+ "<RBSPMessage>"+
...@@ -150,7 +152,7 @@ public class RyxxQgInterface { ...@@ -150,7 +152,7 @@ public class RyxxQgInterface {
for(int i=0;i<element.size();i++){ for(int i=0;i<element.size();i++){
zp64bite=element.get(3).getTextTrim(); zp64bite=element.get(3).getTextTrim();
} }
resulryxx.setImg(zp64bite);// 人员照片 resulryxx.setImg("data:image/jpg;base64,"+zp64bite);// 人员照片
resulryxx.setXm(XM); // 姓名 resulryxx.setXm(XM); // 姓名
// 民族转为汉字 // 民族转为汉字
codeMap.put("groupid", "CODE_MZ"); codeMap.put("groupid", "CODE_MZ");
......
...@@ -2,10 +2,12 @@ package com.founder.publicapi.mapper.mysqlMapper; ...@@ -2,10 +2,12 @@ package com.founder.publicapi.mapper.mysqlMapper;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import java.util.Map; import java.util.Map;
@Mapper @Mapper
@Component
public interface SysDictitemMapper { public interface SysDictitemMapper {
String getNameByCode(Map<String, String> map); String getNameByCode(Map<String, String> map);
} }
...@@ -86,10 +86,13 @@ SELECT ...@@ -86,10 +86,13 @@ SELECT
a.fsrxm, a.fsrxm,
a.fssj, a.fssj,
a.isdeleted, a.isdeleted,
( SELECT count(*) FROM sk_regionals_result t WHERE t.taskId = a.taskId) AS resultCount CASE WHEN tasktype like CONCAT('skph_','%') then
(SELECT count(distinct(t.objectValue)) FROM sk_regionals_result t WHERE t.taskId = a.taskId)
ELSE
( SELECT count(*) FROM sk_regionals_result t WHERE t.taskId = a.taskId)end AS resultCount
FROM FROM
sk_regionals_task a sk_regionals_task a
WHERE isDeleted = '0' and taskCaseId != 'test' WHERE isDeleted = '0' and (taskCaseId != 'test'or taskCaseId IS NULL)
<if test="taskname != null and taskname != ''"> <if test="taskname != null and taskname != ''">
and a.taskName like concat('%', #{taskname , jdbcType=VARCHAR }, '%') and a.taskName like concat('%', #{taskname , jdbcType=VARCHAR }, '%')
</if> </if>
...@@ -112,7 +115,7 @@ ORDER BY ...@@ -112,7 +115,7 @@ ORDER BY
count(*) count(*)
FROM FROM
sk_regionals_task a sk_regionals_task a
WHERE isDeleted = '0' and taskCaseId != 'test' WHERE isDeleted = '0' and (taskCaseId != 'test'or taskCaseId IS NULL)
<if test="taskname != null and taskname != ''"> <if test="taskname != null and taskname != ''">
and a.taskName like concat('%', #{taskname , jdbcType=VARCHAR }, '%') and a.taskName like concat('%', #{taskname , jdbcType=VARCHAR }, '%')
</if> </if>
......
...@@ -105,6 +105,9 @@ ...@@ -105,6 +105,9 @@
<if test="pabj_pdbz != null and pabj_pdbz == '0'"> <if test="pabj_pdbz != null and pabj_pdbz == '0'">
and ZCJDDM not in ('0600','0700','0800') and ZCJDDM not in ('0600','0700','0800')
</if> </if>
<if test="ladwGajgjgdm!= null and ladwGajgjgdm!=''">
AND T.ladw_Gajgjgdm = #{ladwGajgjgdm , jdbcType=VARCHAR }
</if>
</sql> </sql>
<select id="getXszajbhByAsjbh" parameterType="java.lang.String" resultType="String"> <select id="getXszajbhByAsjbh" parameterType="java.lang.String" resultType="String">
select select
......
...@@ -460,9 +460,9 @@ public class SkRegionalsResultServiceImpl extends ServiceImpl<SkRegionalsResultM ...@@ -460,9 +460,9 @@ public class SkRegionalsResultServiceImpl extends ServiceImpl<SkRegionalsResultM
SkRegionalsResultSaveParam skRegionalsResultSaveParam = new SkRegionalsResultSaveParam(); SkRegionalsResultSaveParam skRegionalsResultSaveParam = new SkRegionalsResultSaveParam();
skRegionalsResultSaveParam.setObjectvalue(p.getDeviceId());// 标识号 skRegionalsResultSaveParam.setObjectvalue(p.getDeviceId());// 标识号
skRegionalsResultSaveParam.setTime(createRandomDate(LocalDateTime.parse(sf.format(p.getStartTime()), formatter),LocalDateTime.parse(sf.format(p.getEndTime()), formatter)));// 时间在开始时间和结束时间期间取一个 skRegionalsResultSaveParam.setTime(createRandomDate(LocalDateTime.parse(sf.format(p.getStartTime()), formatter),LocalDateTime.parse(sf.format(p.getEndTime()), formatter)));// 时间在开始时间和结束时间期间取一个
Random random=new Random(); skRegionalsResultSaveParam.setAddress("进入区域");
String lx=random.nextBoolean()?"离开区域":"进入区域"; skRegionalsResultSaveParam.setX(p.getX());
skRegionalsResultSaveParam.setAddress(lx); skRegionalsResultSaveParam.setY(p.getY());
listResult.add(skRegionalsResultSaveParam); listResult.add(skRegionalsResultSaveParam);
}); });
return listResult; return listResult;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment