Skip to content

X
xzxt-api-report
Commit 069340a2 by wang_jiaxing
Options

西藏法律文书入库

parent 608b13a2
Showing with 81 additions and 63 deletions
pom.xml
......@@ -165,30 +165,35 @@
<!-- log start -->
<!-- <dependency>-->
<!-- <groupId>org.apache.logging.log4j</groupId>-->
<!-- <artifactId>log4j-api</artifactId>-->
<!-- <version>${log4j2.version}</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>org.apache.logging.log4j</groupId>-->
<!-- <artifactId>log4j-core</artifactId>-->
<!-- <version>${log4j2.version}</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>org.apache.logging.log4j</groupId>-->
<!-- <artifactId>log4j-web</artifactId>-->
<!-- <version>${log4j2.version}</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>org.apache.logging.log4j</groupId>-->
<!-- <artifactId>log4j-slf4j-impl</artifactId>-->
<!-- <version>${log4j2.version}</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>org.apache.logging.log4j</groupId>-->
<!-- <artifactId>log4j-to-slf4j</artifactId>-->
<!-- <version>${log4j2.version}</version>-->
<!-- </dependency>-->
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>${log4j2.version}</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>${log4j2.version}</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-web</artifactId>
<version>${log4j2.version}</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
<version>${log4j2.version}</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-to-slf4j</artifactId>
<version>${log4j2.version}</version>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.18</version>
</dependency>
</dependencies>
......
src/main/java/com/founder/file/controller/XjFlwsController.java → src/main/java/com/founder/file/controller/XzFlwsController.java
package com.founder.file.controller;
import com.founder.file.service.XjFlwsService;
import com.founder.file.service.XzFlwsService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
......@@ -15,9 +15,15 @@ import java.util.Date;
@RestController
@Slf4j
public class XjFlwsController {
public class XzFlwsController {
@Autowired
private XjFlwsService xjFlwsService;
private XzFlwsService xzFlwsService;
@Value("${isStart}")
private String isStart;
@RequestMapping("/getJzzjkFlwsnrToXjxz")
public String getJzzjkFlwsnrToXjxz(@DateTimeFormat(pattern = "yyyyMMdd") Date date, @RequestParam(required = false) String xxzjbh){
......@@ -28,7 +34,7 @@ public class XjFlwsController {
calendar.add(Calendar.DATE, -1);
date = calendar.getTime();
}
return xjFlwsService.getJzzjkFlwsnrToXjxz(date, xxzjbh);
return xzFlwsService.getJzzjkFlwsnrToXjxz(date, xxzjbh);
} catch (Exception e) {
e.printStackTrace();
log.error("错误信息", e);
......@@ -36,8 +42,10 @@ public class XjFlwsController {
}
}
@Scheduled(cron = "0 0 3 * * ?")
@Scheduled(cron = "${cron}")
public void autoGetJzzjkFlwsnrToXjxz(){
if ("true".equals(isStart)){
getJzzjkFlwsnrToXjxz(null, null);
}
}
}
src/main/java/com/founder/file/dao/xjxz/XjxzFlwsMapper.java → src/main/java/com/founder/file/dao/xjxz/XzxzFlwsMapper.java
......@@ -10,13 +10,13 @@ import java.util.Map;
@Mapper
@Component
public interface XjxzFlwsMapper {
int update(@Param("xxzjbh") String xxzjbh, @Param("bytes") byte[] bytes, @Param("length") int length);
public interface XzxzFlwsMapper {
int update(@Param("xxzjbh") String xxzjbh, @Param("bytes") byte[] bytes);
List<String> getNoFileFlwsXxzjbh(@Param("flwsList") List<Map<String, String>> flwsList);
List<Map<String, String>> getFlwsWzByDate(@Param("date") Date date, @Param("xxzjbh") String xxzjbh, @Param("begin") Integer page, @Param("end") Integer rows);
Integer getFlwsCountWzByDate(@Param("date") Date date, @Param("xxzjbh") String xxzjbh);
List<Map<String, String>> getJzzjkFlwsList(@Param("date") Date date, @Param("xxzjbh") String xxzjbh);
List<String> getJzzjkFlwsList(@Param("date") Date date, @Param("xxzjbh") String xxzjbh);
}
src/main/java/com/founder/file/service/XjFlwsService.java → src/main/java/com/founder/file/service/XzFlwsService.java
......@@ -3,6 +3,6 @@ package com.founder.file.service;
import java.io.IOException;
import java.util.Date;
public interface XjFlwsService {
public interface XzFlwsService {
String getJzzjkFlwsnrToXjxz(Date date, String xxzjbh) throws IOException;
}
src/main/java/com/founder/file/service/impl/XjFlwsServiceImpl.java → src/main/java/com/founder/file/service/impl/XzFlwsServiceImpl.java
package com.founder.file.service.impl;
import com.founder.file.dao.xjxz.XjxzFlwsMapper;
import com.founder.file.service.XjFlwsService;
import com.founder.file.dao.xjxz.XzxzFlwsMapper;
import com.founder.file.service.XzFlwsService;
import com.founder.util.HttpUtil;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import java.io.InputStream;
......@@ -15,28 +16,27 @@ import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
@Service
public class XjFlwsServiceImpl implements XjFlwsService {
public class XzFlwsServiceImpl implements XzFlwsService {
@Autowired
private XjxzFlwsMapper xjxzFlwsMapper;
private XzxzFlwsMapper xzxzFlwsMapper;
@Value("${wjwz}")
private String wjwz;
@Override
public String getJzzjkFlwsnrToXjxz(Date date, String xxzjbh) {
List<Map<String, String>> list = xjxzFlwsMapper.getJzzjkFlwsList(date, xxzjbh);
List<String> list = xzxzFlwsMapper.getJzzjkFlwsList(date, xxzjbh);
int wssl = list.size();
AtomicInteger cgsl = new AtomicInteger(0);
AtomicInteger cwsl = new AtomicInteger(0);
AtomicInteger wswzwksl = new AtomicInteger(0);
AtomicInteger wglsl = new AtomicInteger(0);
list.stream().parallel().forEach(map -> {
String flwsxxzjbh = map.get("XXZJBH");
String wjwz = map.get("WJWZ");
if (StringUtils.isNotEmpty(flwsxxzjbh) && StringUtils.isNotEmpty(wjwz)) {
try (InputStream is = HttpUtil.getInputStreamByUrl(wjwz)){
list.stream().parallel().forEach(id -> {
if (StringUtils.isNotEmpty(id) && StringUtils.isNotEmpty(wjwz)) {
try (InputStream is = HttpUtil.getInputStreamByUrl(wjwz + id)){
if (is != null) {
byte[] bytes = IOUtils.toByteArray(is);
if (bytes != null && bytes.length > 0) {
int length = bytes.length;
int update = xjxzFlwsMapper.update(flwsxxzjbh, bytes, length);
int update = xzxzFlwsMapper.update(id, bytes);
if (update > 0) {
cgsl.incrementAndGet();
} else {
......
src/main/resources/application-dev.yml
......@@ -13,10 +13,13 @@ spring:
jdbc-url: jdbc:oracle:thin:@47.92.129.99:1600:orcl
type: com.alibaba.druid.pool.DruidDataSource
xjxz:
jdbc-url: jdbc:oracle:thin:@10.20.2.208:6521:XJXZXT
username: XZXT
password: XzxtPwd#65
driver-class-name: oracle.jdbc.driver.OracleDriver
# jdbc-url: jdbc:mysql://47.92.223.200:3365/xzxt?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&serverTimezone=GMT%2B8
# username: xzxt
# password: xzxt
jdbc-url: jdbc:mysql://155.200.1.23:1106/jzzjk?allowPublicKeyRetrieval=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&serverTimezone=GMT%2B8
username: root
password: XzxtPwd#54
driver-class-name: com.mysql.cj.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource
jzzjk:
jdbc-url: jdbc:oracle:thin:@10.20.2.208:6521:XJXZXT
......@@ -39,6 +42,13 @@ poorSize: 1000
clusterSize: 1
clusterId: 1
#最后以/结尾
wjwz: http://localhost:8080/
#开始定时使用true
isStart: false
#定时 0秒 0分开始每3分钟 每时 每日 每月 任意周
cron: 0 0/3 * * * ?
ftpserverip: 47.92.129.99
nginxport: 9053
ftpport: 4546
......
src/main/resources/mybatis/xjFlwsMpaaer/XjxzFlwsMapper.xml → src/main/resources/mybatis/xjFlwsMpaaer/XzxzFlwsMapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.founder.file.dao.xjxz.XjxzFlwsMapper">
<mapper namespace="com.founder.file.dao.xjxz.XzxzFlwsMapper">
<update id="update">
update TB_ST_ASJ_FLWS
set FLWS_DZWJNR = #{bytes,jdbcType=BLOB},
FLWS_DZWJDX = #{length,jdbcType=INTEGER},
GXSJ = sysdate
where xxzjbh = #{xxzjbh,jdbcType=VARCHAR}
update tb_st_asj_flwspdf_mx
set flws_dzwjnr = #{bytes,jdbcType=BLOB}
where dxcc_id = #{xxzjbh,jdbcType=VARCHAR}
</update>
<select id="getNoFileFlwsXxzjbh" resultType="java.lang.String">
select xxzjbh from TB_ST_ASJ_FLWS where FLWS_DZWJNR is null and xxzjbh in
......@@ -51,15 +49,11 @@
and dz.TZTXBH = #{xxzjbh}
</if>
</select>
<select id="getJzzjkFlwsList" resultType="java.util.Map">
select tld.XXZJBH as XXZJBH,
tld.FLWS_DZWJWZ as WJWZ
from JZZJK.ASJ_FLWS_TLD tld, TB_ST_ASJ_FLWS flws
where tld.XXSC_PDBZ = '0' and flws.XXSC_PDBZ = '0'
and tld.XXZJBH = flws.XXZJBH
and (flws.DJSJ <![CDATA[>=]]> #{date} or flws.XXRSKSJ <![CDATA[>=]]> #{date})
<select id="getJzzjkFlwsList" resultType="java.lang.String">
select DISTINCT dxcc_id from tb_st_asj_flwspdf_mx
where (flws_dzwjnr is null or OCTET_LENGTH(flws_dzwjnr) = 0)
<if test="xxzjbh != null and xxzjbh != ''">
and tld.xxzjbh = #{xxzjbh}
and dxcc_id = #{xxzjbh}
</if>
</select>
</mapper>
\ No newline at end of file
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