Skip to content

X
xzxt-api-report
Commit 1a4c0b7e by wang_jiaxing
Options

西藏法律文书入库

parent 069340a2
Showing with 172 additions and 0 deletions
src/main/java/com/founder/file/controller/XzFlwsController.java
......@@ -48,4 +48,52 @@ public class XzFlwsController {
getJzzjkFlwsnrToXjxz(null, null);
}
}
@RequestMapping("/getRyzbnrToXzxz")
public String getRyzbnrToXzxz(@DateTimeFormat(pattern = "yyyyMMdd") Date date, @RequestParam(required = false) String xxzjbh){
try {
if (date == null){
Calendar calendar=Calendar.getInstance();
calendar.setTime(new Date());
calendar.add(Calendar.DATE, -1);
date = calendar.getTime();
}
return xzFlwsService.getRyzbnrToXzxz(date, xxzjbh);
} catch (Exception e) {
e.printStackTrace();
log.error("错误信息", e);
return e.getMessage();
}
}
@Scheduled(cron = "${zpCron}")
public void autoGetRyzbnrToXzxz(){
if ("true".equals(isStart)){
getRyzbnrToXzxz(null, null);
}
}
@RequestMapping("/getCqbgwsnrToXzxz")
public String getCqbgwsnrToXzxz(@DateTimeFormat(pattern = "yyyyMMdd") Date date, @RequestParam(required = false) String xxzjbh){
try {
if (date == null){
Calendar calendar=Calendar.getInstance();
calendar.setTime(new Date());
calendar.add(Calendar.DATE, -1);
date = calendar.getTime();
}
return xzFlwsService.getCqbgwsnrToXzxz(date, xxzjbh);
} catch (Exception e) {
e.printStackTrace();
log.error("错误信息", e);
return e.getMessage();
}
}
@Scheduled(cron = "${cqbgCron}")
public void autoGetCqbgwsnrToXzxz(){
if ("true".equals(isStart)){
getCqbgwsnrToXzxz(null, null);
}
}
}
src/main/java/com/founder/file/dao/xjxz/XzxzFlwsMapper.java
......@@ -19,4 +19,12 @@ public interface XzxzFlwsMapper {
Integer getFlwsCountWzByDate(@Param("date") Date date, @Param("xxzjbh") String xxzjbh);
List<String> getJzzjkFlwsList(@Param("date") Date date, @Param("xxzjbh") String xxzjbh);
List<String> getRyzpList(@Param("date") Date date, @Param("xxzjbh") String xxzjbh);
int updateZp(@Param("xxzjbh") String xxzjbh, @Param("bytes") byte[] bytes);
List<String> getCqbgList(@Param("date") Date date, @Param("xxzjbh") String xxzjbh);
int updateCqbg(@Param("xxzjbh") String xxzjbh, @Param("bytes") byte[] bytes);
}
src/main/java/com/founder/file/service/XzFlwsService.java
......@@ -5,4 +5,8 @@ import java.util.Date;
public interface XzFlwsService {
String getJzzjkFlwsnrToXjxz(Date date, String xxzjbh) throws IOException;
String getRyzbnrToXzxz(Date date, String xxzjbh) throws IOException;
String getCqbgwsnrToXzxz(Date date, String xxzjbh);
}
src/main/java/com/founder/file/service/impl/XzFlwsServiceImpl.java
......@@ -9,6 +9,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
......@@ -62,4 +63,86 @@ public class XzFlwsServiceImpl implements XzFlwsService {
return "共" + wssl + "个文书准备更新，" + "成功更新" + cg + "个，失败" + cw + "个，文书位置为空"
+ wswzwk + "个，未关联文书" + wgl + "个，文书内容为空" + wnr + "个";
}
@Override
public String getRyzbnrToXzxz(Date date, String xxzjbh) {
List<String> list = xzxzFlwsMapper.getRyzpList(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(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 update = xzxzFlwsMapper.updateZp(id, bytes);
if (update > 0) {
cgsl.incrementAndGet();
} else {
wglsl.incrementAndGet();
}
}
}
} catch (Exception e) {
e.printStackTrace();
cwsl.incrementAndGet();
}
} else {
System.out.println("文件位置为空");
wswzwksl.incrementAndGet();
}
});
int cg = cgsl.get();
int cw = cwsl.get();
int wswzwk = wswzwksl.get();
int wgl = wglsl.get();
int wnr = wssl - (cg + cw + wswzwk + wgl);
return "共" + wssl + "个文书准备更新，" + "成功更新" + cg + "个，失败" + cw + "个，文书位置为空"
+ wswzwk + "个，未关联文书" + wgl + "个，文书内容为空" + wnr + "个";
}
@Override
public String getCqbgwsnrToXzxz(Date date, String xxzjbh) {
List<String> list = xzxzFlwsMapper.getCqbgList(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(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 update = xzxzFlwsMapper.updateCqbg(id, bytes);
if (update > 0) {
cgsl.incrementAndGet();
} else {
wglsl.incrementAndGet();
}
}
}
} catch (Exception e) {
e.printStackTrace();
cwsl.incrementAndGet();
}
} else {
System.out.println("文件位置为空");
wswzwksl.incrementAndGet();
}
});
int cg = cgsl.get();
int cw = cwsl.get();
int wswzwk = wswzwksl.get();
int wgl = wglsl.get();
int wnr = wssl - (cg + cw + wswzwk + wgl);
return "共" + wssl + "个文书准备更新，" + "成功更新" + cg + "个，失败" + cw + "个，文书位置为空"
+ wswzwk + "个，未关联文书" + wgl + "个，文书内容为空" + wnr + "个";
}
}
\ No newline at end of file
src/main/resources/application-dev.yml
......@@ -48,6 +48,8 @@ wjwz: http://localhost:8080/
isStart: false
#定时 0秒 0分开始每3分钟 每时 每日 每月 任意周
cron: 0 0/3 * * * ?
zpCron: 0 0/3 * * * ?
cqbgCron: 0 0/3 * * * ?
ftpserverip: 47.92.129.99
nginxport: 9053
......
src/main/resources/mybatis/xjFlwsMpaaer/XzxzFlwsMapper.xml
......@@ -6,6 +6,16 @@
set flws_dzwjnr = #{bytes,jdbcType=BLOB}
where dxcc_id = #{xxzjbh,jdbcType=VARCHAR}
</update>
<update id="updateZp">
update tb_st_ry_zp
set ryzp_dzwjnr = #{bytes,jdbcType=BLOB}
where dxcc_id = #{xxzjbh,jdbcType=VARCHAR}
</update>
<update id="updateCqbg">
update tb_st_asj_cqbg
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
<foreach collection="flwsList" item="flws" open="(" separator="," close=")">
......@@ -56,4 +66,19 @@
and dxcc_id = #{xxzjbh}
</if>
</select>
<select id="getRyzpList" resultType="java.lang.String">
select DISTINCT dxcc_id from tb_st_ry_zp
where (ryzp_dzwjnr is null or OCTET_LENGTH(ryzp_dzwjnr) = 0)
<if test="xxzjbh != null and xxzjbh != ''">
and dxcc_id = #{xxzjbh}
</if>
</select>
<select id="getCqbgList" resultType="java.lang.String">
select DISTINCT dxcc_id from tb_st_asj_cqbg
where (flws_dzwjnr is null or OCTET_LENGTH(flws_dzwjnr) = 0)
and dcxx_id is not null
<if test="xxzjbh != null and 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