Commit b3a4c979 by liulianglang

初始化

parent 6235c767
......@@ -4,8 +4,8 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>xzxt.tjfx.report</groupId>
<artifactId>tjfx</artifactId>
<groupId>xzxt.qyxzpt.report</groupId>
<artifactId>qyxzpt</artifactId>
<packaging>jar</packaging>
<version>1.0</version>
......@@ -210,7 +210,7 @@
</dependencies>
<build>
<finalName>xzxt-tjfx-report</finalName>
<finalName>xzxt-qyxzpt-report</finalName>
<resources>
<!-- 打包包含xml文件-->
......
package org.springblade.founder.ztrxyj.controller;
import io.swagger.annotations.ApiOperation;
import org.springblade.founder.tjfx.entity.AjtjParam;
import org.springblade.founder.tjfx.entity.LianTj;
import org.springblade.founder.utils.EasyUIPage;
import org.springblade.founder.utils.R;
import org.springblade.founder.ztrxyj.entity.ZtryBksj;
import org.springblade.founder.ztrxyj.entity.Ztryyjxx;
import org.springblade.founder.ztrxyj.service.ztgjService;
import org.springblade.modules.system.entity.SysNewUser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("/ztgj")
public class gjcxController {
@Autowired
private ztgjService ztService;
@PostMapping("/getYjList")
public R getYjList(Ztryyjxx ztryyjxx){
try {
return R.ok().data(ztService.getYjList(ztryyjxx));
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/getListYjXqgj")
public R getListYjXqgj(Ztryyjxx ztryyjxx){
try {
return R.ok().data(ztService.getListYjXqgj(ztryyjxx));
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/getBkzpList")
public R getBkzpList(ZtryBksj ztryBksj){
try {
return R.ok().data(ztService.getBkzpList(ztryBksj));
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/deleteBkzp")
public R deleteBkzp(String certNo){
try {
return R.ok().data(ztService.deleteBkzp(certNo));
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/deleteYjjl")
public R deleteYjjl(String xxzjbh){
try {
return R.ok().data(ztService.deleteYjjl(xxzjbh));
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/selectUserNewList")
public R selectUserNewList(SysNewUser sysNewUser){
try {
EasyUIPage easyUIPage = new EasyUIPage();
easyUIPage.setPage(sysNewUser.getPage());
easyUIPage.setPagePara(sysNewUser.getLimit());
int begin = easyUIPage.getBegin();
int end = easyUIPage.getEnd();
sysNewUser.setBegin(begin);
sysNewUser.setEnd(end);
Map<String,Object> map = new HashMap<>();
List<SysNewUser> list = ztService.getUserNewList(sysNewUser);
if(list == null){
return R.error("无权限查看");
}else{
int count = ztService.getUserNewCount(sysNewUser);
map.put("rows",list);
map.put("total",count);
return R.ok().data(map);
}
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/insertUserQh")
@ResponseBody
@ApiOperation(value = "给用户分配区划", notes = "给用户分配区划")
public R insertUserQh(String userIds,String qdIds){
try {
ztService.insertUserQh(userIds,qdIds);
return R.ok();
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
}
package org.springblade.founder.ztrxyj.entity;
import lombok.Data;
import org.springblade.founder.utils.BaseModel;
@Data
public class SysUserLlyqh extends BaseModel {
private String id; //照片
private String userId;
private String qhId;
}
package org.springblade.founder.ztrxyj.entity;
import lombok.Data;
@Data
public class ZtryBksj {
private String imgFace; //照片
private String faceDBId; //700046010603000104
private String name; //姓名
private String certNo; //证件号码
private String operate;
private int page;
private int limit;
}
package org.springblade.founder.ztrxyj.entity;
import lombok.Data;
import java.util.Date;
@Data
public class ZtryYjYhcz {
/**
* 信息主键
*/
private String xxzjbh;
/**
* 信息主键
*/
private String glxxzjbh;
/**
* 信息登记人员_姓名
*/
private String xxdjryXm;
/**
* 信息登记人员_联系电话
*/
private String xxdjryLxdh;
/**
* 信息登记单位_公安机关名称
*/
private String xxdjdwGajgmc;
/**
* 信息登记人员_公民身份号码
*/
private String xxdjryGmsfhm;
/**
* 信息登记单位_公安机关机构代码
*/
private String xxdjdwGajgjgdm;
/**
* 登记时间
*/
private Date djsj;
/**
* 操作类型:1删除
*/
private String czlx;
}
package org.springblade.founder.ztrxyj.entity;
public class Ztryyjxx {
/**
* faceName : 周千雷
* faceUrl : http://74.10.30.180:10005/125,136dc5d5b1545f0
* score : 0.9903
* captureTime : 2022-03-30 15:57:16
* faceDbId : 700046010603000037
* faceCertNo : 460026200003123010
* alarmTime : 2022-03-30 15:57:21
* faceDbName : 省-前科人员库
* panoramaUrl : http://74.10.30.180:10005/14892,ffffb852c48c8330781a7825
* deviceId : 800046010603004299
* deviceName : 华盛夜都大厅
* captureUrl : http://74.10.30.180:10005/14856,ffffb852c48c83360ca07721
*/
private String faceName;
private String faceUrl;
private String score;
private String captureTime;
private String captureTimeKssj;
private String scrxm;
public String getScrxm() {
return scrxm;
}
public void setScrxm(String scrxm) {
this.scrxm = scrxm;
}
public String getScrdwmc() {
return scrdwmc;
}
public void setScrdwmc(String scrdwmc) {
this.scrdwmc = scrdwmc;
}
private String scrdwmc;
public String getCaptureTimeKssj() {
return captureTimeKssj;
}
public void setCaptureTimeKssj(String captureTimeKssj) {
this.captureTimeKssj = captureTimeKssj;
}
public String getCaptureTimeJssj() {
return captureTimeJssj;
}
public void setCaptureTimeJssj(String captureTimeJssj) {
this.captureTimeJssj = captureTimeJssj;
}
private String captureTimeJssj;
private String faceDbId;
private String faceCertNo;
private String alarmTime;
private String faceDbName;
private String panoramaUrl;
private String deviceId;
private String deviceName;
private String captureUrl;
public String getQhmc() {
return qhmc;
}
public void setQhmc(String qhmc) {
this.qhmc = qhmc;
}
private String qhmc;
public String getQhdm() {
return qhdm;
}
public void setQhdm(String qhdm) {
this.qhdm = qhdm;
}
private String qhdm;
public String getScbz() {
return scbz;
}
public void setScbz(String scbz) {
this.scbz = scbz;
}
private String scbz;
private int page;
public int getPage() {
return page;
}
public void setPage(int page) {
this.page = page;
}
public int getLimit() {
return limit;
}
public void setLimit(int limit) {
this.limit = limit;
}
private int limit;
public String getXxzjbh() {
return xxzjbh;
}
public void setXxzjbh(String xxzjbh) {
this.xxzjbh = xxzjbh;
}
private String xxzjbh;
public void setFaceName(String faceName) {
this.faceName = faceName;
}
public void setFaceUrl(String faceUrl) {
this.faceUrl = faceUrl;
}
public void setScore(String score) {
this.score = score;
}
public void setCaptureTime(String captureTime) {
this.captureTime = captureTime;
}
public void setFaceDbId(String faceDbId) {
this.faceDbId = faceDbId;
}
public void setFaceCertNo(String faceCertNo) {
this.faceCertNo = faceCertNo;
}
public void setAlarmTime(String alarmTime) {
this.alarmTime = alarmTime;
}
public void setFaceDbName(String faceDbName) {
this.faceDbName = faceDbName;
}
public void setPanoramaUrl(String panoramaUrl) {
this.panoramaUrl = panoramaUrl;
}
public void setDeviceId(String deviceId) {
this.deviceId = deviceId;
}
public void setDeviceName(String deviceName) {
this.deviceName = deviceName;
}
public void setCaptureUrl(String captureUrl) {
this.captureUrl = captureUrl;
}
public String getFaceName() {
return faceName;
}
public String getFaceUrl() {
return faceUrl;
}
public String getScore() {
return score;
}
public String getCaptureTime() {
return captureTime;
}
public String getFaceDbId() {
return faceDbId;
}
public String getFaceCertNo() {
return faceCertNo;
}
public String getAlarmTime() {
return alarmTime;
}
public String getFaceDbName() {
return faceDbName;
}
public String getPanoramaUrl() {
return panoramaUrl;
}
public String getDeviceId() {
return deviceId;
}
public String getDeviceName() {
return deviceName;
}
public String getCaptureUrl() {
return captureUrl;
}
}
package org.springblade.founder.ztrxyj.mapper;
import org.apache.ibatis.annotations.Mapper;
import org.springblade.founder.ztrxyj.entity.SysUserLlyqh;
import org.springblade.founder.ztrxyj.entity.ZtryBksj;
import org.springblade.founder.ztrxyj.entity.ZtryYjYhcz;
import org.springblade.founder.ztrxyj.entity.Ztryyjxx;
import org.springblade.modules.system.entity.SysNewUser;
import org.springblade.modules.system.entity.SysUserRolesNew;
import org.springframework.stereotype.Component;
import java.util.List;
@Mapper
@Component
public interface ztgjMapper {
List<Ztryyjxx> getListYjgj(Ztryyjxx ztryyjxx);
int getListYjgjCount(Ztryyjxx ztryyjxx);
List<Ztryyjxx> getListYjXqgj(Ztryyjxx ztryyjxx);
int getListYjXqgjCount(Ztryyjxx ztryyjxx);
List<ZtryBksj> getBkzpList(ZtryBksj ztryBksj);
int getBkzpListCount(ZtryBksj ztryBksj);
ZtryBksj getMaztryZp(String certNo);
int updatesftsZtzp(String certNo);
int insertYjYhcz(ZtryYjYhcz ztryYjYhcz);
int updateYjsc(String xxzjbh);
// 获取用户 个数
int getUserNewCount(SysNewUser sysNewUser)throws Exception;
// 获取用户 列表
List<SysNewUser> getUserNewList(SysNewUser sysNewUser)throws Exception;
List<String> getUserqh(String id);
void deleteUserqh(SysUserLlyqh sysUserLlyqh)throws Exception;
//给用户分配角色
int insertUserqh(SysUserLlyqh SysUserLlyqh )throws Exception;
}
package org.springblade.founder.ztrxyj.service;
import org.springblade.founder.ztrxyj.entity.ZtryBksj;
import org.springblade.founder.ztrxyj.entity.Ztryyjxx;
import org.springblade.modules.system.entity.SysNewUser;
import java.util.List;
import java.util.Map;
public interface ztgjService {
Map<String, Object> getYjList(Ztryyjxx ztryyjxx);
Map<String, Object> getListYjXqgj(Ztryyjxx ztryyjxx);
Map<String, Object> getBkzpList(ZtryBksj ztryBksj);
Map<String, Object> deleteBkzp(String certNo);
Map<String, Object> deleteYjjl(String xxzjbh);
// 获取用户 列表
List<SysNewUser> getUserNewList(SysNewUser sysNewUser)throws Exception;
// 获取用户 个数
int getUserNewCount(SysNewUser sysNewUser)throws Exception;
//给用户分配角色
void insertUserQh(String userIds,String qdIds)throws Exception;
}
package org.springblade.founder.ztrxyj.utils;
import cn.hutool.core.exceptions.ExceptionUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.*;
import java.util.Properties;
@Slf4j
public class PropertieUtil {
/**
* 读取配置文件某属性绝对路径下的token
*/
public String readTokenValue(String key, String url) {
String value = "";
try {
Properties prop = new Properties();
// FileInputStream fileInputStream = new FileInputStream(url);
InputStream fileInputStream = this.getClass().getResourceAsStream("/token.properties");
prop.load(fileInputStream);
value = prop.getProperty(key);
fileInputStream.close();
} catch (Exception e) {
e.printStackTrace();
log.error(ExceptionUtil.getMessage(e));
}
return value;
}
/**
* 将值写入配置文件绝对路径下的token
*/
public void writeTokenProperties(String token_url, String parameterName, String parameterValue) throws Exception {
String filePath = token_url;
// 获取配置文件
Properties pps = new Properties();
// FileInputStream fileInputStream = new FileInputStream(filePath);
InputStream fileInputStream = this.getClass().getResourceAsStream("/token.properties");
InputStream in = new BufferedInputStream(fileInputStream);
InputStreamReader inputStreamReader = new InputStreamReader(in, "UTF-8");
pps.load(inputStreamReader);
inputStreamReader.close();
in.close();
fileInputStream.close();
//true表示追加打开,false表示每次都是清空重写
OutputStream out = new FileOutputStream(filePath);
// 设置配置名称和值
pps.setProperty(parameterName, parameterValue);
// comments 等于配置文件的注释
OutputStreamWriter outputStreamWriter = new OutputStreamWriter(out, "UTF-8");
pps.store(outputStreamWriter, "Update " + parameterName + " name");
out.flush();
outputStreamWriter.close();
out.close();
}
}
package org.springblade.founder.ztrxyj.utils;
import org.apache.commons.codec.binary.Base64;
import java.security.*;
import java.security.spec.PKCS8EncodedKeySpec;
import java.security.spec.X509EncodedKeySpec;
/**
* SHA1WithRSA-数字签名工具类
* Created by yangyang on 2022/04/27.
*/
public class RsaUtil {
//加密算法
public static final String SIGN_ALGORITHMS = "SHA1WithRSA";
//私钥
private static final String privateKey = "MIICdwIBADANBgkqhkiG9w0BAQEFAASCAmEwggJdAgEAAoGBANF/IIsbi9+v5V0VlXeDWp3LlWNXf1gQ3EYjbdj4qMJJoVaLUv2T6fsQq4MTGO6h0HaPQPb80g2VXXgtwOBAGhTN5ifi8VLkHp8h+sU3/hmR2q3eyUeUEaX8t53leWQiI462O23bysectI5lmqzkL/68LTzSpu8z308XSWOFdXKVAgMBAAECgYA7qjIxjCndDjKLvT7xZ8aiFD46qcvJ4BtsGmEJn2Ao3WGGzW1YbQ0BhTDjxseeBxXg/lGpRj3ownZ5aMZ616bVa8xFdI9agmElnM78RhUgJNtOelY4yB3vMQmdpYxhA6Zp+Z10DCvKyxiostqrLw/zdSr8ZkmRof1DUMml5FZzYQJBAPe8zQsHqXeGSjvAEpPpBX87Wzc7/T6tObuOokxOrWfPmZFO7qy2rsdOkmn8LghIhzvOognoT6DiBhO4UIgJAMkCQQDYe9Kfju7JhbhE0SRh+1hSRRV8+6vRmpTIxJpy+AN3Oc6oeiQ6UE7/ZxyeZ0pDgmBZGJDBHoX1rIYrsuMmgrVtAkEA0YwHO88tTwZuAABFNoshtS71xtCdMsi/TqAlM7pQ/sAgu0IyrDCRwc/6FF/UZ/lBOhtcAFlaEVFdpox+wbIr0QJBAM9BJHF7ruKiMbs4m2Nu9ay11Q+2BlYCb0US7Gb7SJ4hatdjMEHf1vGvrvd8Hd4p+MHzwcoRxeBhToaRmeSpqLUCQFFTCNRlE/0Qo8hKLJlu8NpN00/VznTp+llGsSelmpOJ3QVWWoFR4egxfkvS5k+lU3Xwwu4ljXh7gLxPRfTprgk=";
//公钥
private static final String publicKey = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDRfyCLG4vfr+VdFZV3g1qdy5VjV39YENxGI23Y+KjCSaFWi1L9k+n7EKuDExjuodB2j0D2/NINlV14LcDgQBoUzeYn4vFS5B6fIfrFN/4Zkdqt3slHlBGl/Led5XlkIiOOtjtt28rHnLSOZZqs5C/+vC080qbvM99PF0ljhXVylQIDAQAB";
/**
* 使用私钥给入参签名
* @param param 签名的数据
* @return 返回入参签名16进制字符串
* */
public static String sign(String param) {
try {
//获取privatekey
byte[] privateKeyByte = new Base64().decode(privateKey);
KeyFactory keyfactory = KeyFactory.getInstance("RSA");
PKCS8EncodedKeySpec encoderule = new PKCS8EncodedKeySpec(privateKeyByte);
PrivateKey key = keyfactory.generatePrivate(encoderule);
//用私钥给入参加签
Signature sign = Signature.getInstance(SIGN_ALGORITHMS);
sign.initSign(key);
sign.update(param.getBytes());
byte[] signature = sign.sign();
//将签名的入参转换成16进制字符串
return Base64.encodeBase64String(signature);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 用公钥验证签名
* @param param 入参
* @param signature 使用私钥签名的入参字符串
* @param publicKey 公钥
* @return 返回验证结果
* */
// public static boolean verifyRes(String param,String signature,String publicKey){
// try {
// //获取公钥
// KeyFactory keyFactory=KeyFactory.getInstance("RSA");
// byte[] publicKeyByte= new Base64().decode(publicKey);
// X509EncodedKeySpec encodeRule=new X509EncodedKeySpec(publicKeyByte);
// PublicKey key= keyFactory.generatePublic(encodeRule);
//
// //用获取到的公钥对 入参中未加签参数param入参中的加签之后的参数signature进行验签
// Signature sign=Signature.getInstance(SIGN_ALGORITHMS);
// sign.initVerify(key);
// sign.update(param.getBytes());
//
// //将16进制码转成字符数组
// byte[] hexByte = Base64.decodeBase64(signature);
// //验证签名
// return sign.verify(hexByte);
//
// } catch (Exception e) {
// e.printStackTrace();
// }
// return false;
// }
/**
* byte数组转换成十六进制字符串
* @param bytes byte数组
* @return 返回十六进制字符串
*/
private static String bytesToHexStr(byte[] bytes) {
StringBuffer stringBuffer = new StringBuffer("");
for (int i = 0; i < bytes.length; ++i) {
stringBuffer.append(Integer.toHexString(0x0100 + (bytes[i] & 0x00FF)).substring(1).toUpperCase());
}
return stringBuffer.toString();
}
/**
* 十六进制字符串转成byte数组
* @param hexStr 十六进制字符串
* @return 返回byte数组
* */
private static byte[] hexStrToBytes(String hexStr) {
byte[] bytes = new byte[hexStr.length() / 2];
for (int i = 0; i < bytes.length; i++) {
bytes[i] = (byte) Integer.parseInt(hexStr.substring(2 * i, 2 * i + 2), 16);
}
return bytes;
}
public static void main(String[] args) {
String param = "eyJhbGciOiJIUzI1NiJ9.eyJzdWIiOiI3NC4xMC4zMC4xNzQiLCJpc3MiOiJ0b2tlbi5idWlsZGVyIiwiaWF0IjoxNjUxMjIyOTcwfQ.WIbBf23zZ-KKpCbOX9z6qX0Tqzyanl_WBnvE8YWyle4.xingjdj";
String sign = sign(param);
System.out.println("签名后的参数>>>"+sign);
// System.out.println("验证结果>>>"+verifyRes(param,sign,publicKey));
}
}
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