Skip to content

M
map-parent
Commit a42d14ad by YANGYANG
Options

标注更新ES提交

parent c70344d7
Showing with 175 additions and 4 deletions
service/bzpt/src/main/java/com/founder/bzpt/controller/DetailController.java
......@@ -393,12 +393,17 @@ public class DetailController {
}
// es更新 TbStAsj实例
public Map<String, Object> updateTbStAsjEsData(String asjbh){
//es更新 TbStAsj实例
public Map<String, Object> updateTbStAsjEsData(String asjbh){
String message="";
try {
TbStAsjEsEntity tbStAsjEsEntity = detailervice.getTbStAsjEsEntity(asjbh);
List<TbStAsjEsEntity> tbStAsjEsEntityXyr = detailervice.selectTbStAsjXyrList(asjbh);
List<TbStAsjEsEntity> tbStAsjEsEntityShr = detailervice.selectTbStAsjShrList(asjbh);
List<TbStAsjEsEntity> tbStAsjEsEntityXyrShr = detailervice.selectTbStAsjXyrShrList(asjbh);
final UpdateRequest request = new UpdateRequest();
request.index("qgasj");// 索引名
request.index("asjnm");// 索引名
request.type("pointdata");// 库
request.id(tbStAsjEsEntity.getAsjbh());
request.doc(XContentFactory.jsonBuilder().startObject()
......@@ -425,6 +430,105 @@ public class DetailController {
System.out.println("ID：" + updateResponse.getId());
System.out.println("版本：" + updateResponse.getVersion());
System.out.println("是否创建成功：" + "success");
if(null != tbStAsjEsEntityXyr){
for(int i=0;i<tbStAsjEsEntityXyr.size();i++){
final UpdateRequest requestXyr = new UpdateRequest();
requestXyr.index("asjnm_xyr");// 索引名
requestXyr.type("pointdata");// 库
requestXyr.id(tbStAsjEsEntityXyr.get(i).getXxzjbh());
requestXyr.doc(XContentFactory.jsonBuilder().startObject()
.field("asjbh", tbStAsjEsEntityXyr.get(i).getAsjbh())
.field("asjbzAjfl",tbStAsjEsEntityXyr.get(i).getAsjbz_ajfl())// 案件分类
.field("ajzlb",tbStAsjEsEntityXyr.get(i).getAjzlb())
.field("ajzlbMc",tbStAsjEsEntityXyr.get(i).getAjzlbmc())// 主案类别名称
.field("ajxzlb",tbStAsjEsEntityXyr.get(i).getAjxzlb())
.field("ajxzlbMc",tbStAsjEsEntityXyr.get(i).getAjxzlbmc())// 类案类别名称
.field("xalbdmbcms",tbStAsjEsEntityXyr.get(i).getXalbdmbcms())
.field("xalbdmbcmsMc",tbStAsjEsEntityXyr.get(i).getXalbdmbcmsmc())// 次类案类别名称
.field("bzzt",tbStAsjEsEntityXyr.get(i).getBzzt())// 标注状态
.field("bzztMs",tbStAsjEsEntityXyr.get(i).getBzztMs())// 标注状态描述
.field("ssjzrmby",tbStAsjEsEntity.getSsjzrmby())// 涉案价值
.endObject());
final UpdateResponse updateResponseXyr = client.update(requestXyr).get();
System.out.println("索引名称：" + updateResponseXyr.getIndex());
System.out.println("文档类型：" + updateResponseXyr.getType());
System.out.println("ID：" + updateResponseXyr.getId());
System.out.println("版本：" + updateResponseXyr.getVersion());
System.out.println("是否创建成功：" + "success");
}
}
if(null != tbStAsjEsEntityShr){
for(int i=0;i<tbStAsjEsEntityShr.size();i++){
final UpdateRequest requestShr = new UpdateRequest();
requestShr.index("asjnm_shr");// 索引名
requestShr.type("pointdata");// 库
requestShr.id(tbStAsjEsEntityShr.get(i).getXxzjbh());
requestShr.doc(XContentFactory.jsonBuilder().startObject()
.field("asjbh", tbStAsjEsEntityShr.get(i).getAsjbh())
.field("asjbzAjfl",tbStAsjEsEntityShr.get(i).getAsjbz_ajfl())// 案件分类
.field("ajzlb",tbStAsjEsEntityShr.get(i).getAjzlb())
.field("ajzlbMc",tbStAsjEsEntityShr.get(i).getAjzlbmc())// 主案类别名称
.field("ajxzlb",tbStAsjEsEntityShr.get(i).getAjxzlb())
.field("ajxzlbMc",tbStAsjEsEntityShr.get(i).getAjxzlbmc())// 类案类别名称
.field("xalbdmbcms",tbStAsjEsEntityShr.get(i).getXalbdmbcms())
.field("xalbdmbcmsMc",tbStAsjEsEntityShr.get(i).getXalbdmbcmsmc())// 次类案类别名称
.field("bzzt",tbStAsjEsEntityShr.get(i).getBzzt())// 标注状态
.field("bzztMs",tbStAsjEsEntityShr.get(i).getBzztMs())// 标注状态描述
.field("ssjzrmby",tbStAsjEsEntity.getSsjzrmby())// 涉案价值
.endObject());
final UpdateResponse updateResponseShr = client.update(requestShr).get();
System.out.println("索引名称：" + updateResponseShr.getIndex());
System.out.println("文档类型：" + updateResponseShr.getType());
System.out.println("ID：" + updateResponseShr.getId());
System.out.println("版本：" + updateResponseShr.getVersion());
System.out.println("是否创建成功：" + "success");
}
}
if(null != tbStAsjEsEntityXyrShr){
for(int i=0;i<tbStAsjEsEntityXyrShr.size();i++){
final UpdateRequest requestXyrShr = new UpdateRequest();
requestXyrShr.index("asjnm_xyr_shr");// 索引名
requestXyrShr.type("pointdata");// 库
requestXyrShr.id(tbStAsjEsEntityXyrShr.get(i).getXxzjbh());
requestXyrShr.doc(XContentFactory.jsonBuilder().startObject()
.field("asjbh", tbStAsjEsEntityXyrShr.get(i).getAsjbh())
.field("asjbzAjfl",tbStAsjEsEntityXyrShr.get(i).getAsjbz_ajfl())// 案件分类
.field("ajzlb",tbStAsjEsEntityXyrShr.get(i).getAjzlb())
.field("ajzlbMc",tbStAsjEsEntityXyrShr.get(i).getAjzlbmc())// 主案类别名称
.field("ajxzlb",tbStAsjEsEntityXyrShr.get(i).getAjxzlb())
.field("ajxzlbMc",tbStAsjEsEntityXyrShr.get(i).getAjxzlbmc())// 类案类别名称
.field("xalbdmbcms",tbStAsjEsEntityXyrShr.get(i).getXalbdmbcms())
.field("xalbdmbcmsMc",tbStAsjEsEntityXyrShr.get(i).getXalbdmbcmsmc())// 次类案类别名称
.field("bzzt",tbStAsjEsEntityXyrShr.get(i).getBzzt())// 标注状态
.field("bzztMs",tbStAsjEsEntityXyrShr.get(i).getBzztMs())// 标注状态描述
.field("ssjzrmby",tbStAsjEsEntity.getSsjzrmby())// 涉案价值
.endObject());
final UpdateResponse updateResponseXyrShr = client.update(requestXyrShr).get();
System.out.println("索引名称：" + updateResponseXyrShr.getIndex());
System.out.println("文档类型：" + updateResponseXyrShr.getType());
System.out.println("ID：" + updateResponseXyrShr.getId());
System.out.println("版本：" + updateResponseXyrShr.getVersion());
System.out.println("是否创建成功：" + "success");
}
}
/*client.close();*/
message="同步成功";
}catch (Exception e){
......
service/bzpt/src/main/java/com/founder/bzpt/controller/EsQueryController.java
......@@ -46,7 +46,7 @@ public class EsQueryController {
List<Map<String, Object>> listMapsBack = new ArrayList<>();
Map<String, Object> resultMapHtml = new HashMap<String, Object>();
listMaps = EsAsjQueryServiceImpl.searchQuery("qgasj",asj,null,page,rows);
listMaps = EsAsjQueryServiceImpl.searchQuery("asjnm",asj,null,page,rows);
// 取出总数
int total = 0;
......@@ -80,7 +80,7 @@ public class EsQueryController {
List<Map<String, Object>> listMaps = new ArrayList<>();
List<Map<String, Object>> listMapsBack = new ArrayList<>();
listMaps = EsAsjQueryServiceImpl.searchQuery("qgasj",asj,"export",page,rows);
listMaps = EsAsjQueryServiceImpl.searchQuery("asjnm",asj,"export",page,rows);
for (Map<String, Object> map : listMaps) {
if(!map.containsKey("Count")){
......
service/bzpt/src/main/java/com/founder/bzpt/mapper/xml/DetailMapper.xml
......@@ -352,6 +352,73 @@
T.SSJZRMBY AS ssjzrmby
FROM tb_st_asj T LEFT JOIN tb_st_asjbz ASJBZ ON T.ASJBH = ASJBZ.ASJBH where T.xxsc_pdbz='0' AND T.ASJBH=#{asjbh}
</select>
<!-- asjxyr-->
<select id="selectTbStAsjXyrList" parameterType="String" resultType="com.founder.commonutils.bzptEntity.TbStAsjEsEntity">
SELECT
XYR.xxzjbh as xxzjbh,
T.asjbh AS asjbh,
ASJBZ.asjbz_ajfl AS asjbzAjfl,
ASJBZ.ajzlb AS ajzlb,
(select name from SYS_DICTITEM where groupid='CODE_GABAJZLB' AND code = ASJBZ.ajzlb) AS ajzlbMc,
ASJBZ.ajxzlb AS ajxzlb,
(select name from SYS_DICTITEM where groupid='CODE_GABAJXZLB' AND code = ASJBZ.ajxzlb) AS ajxzlbMc,
ASJBZ.xalbdmbcms AS xalbdmbcms,
(select name from SYS_DICTITEM where groupid='CODE_GABXALBDMBCMS' AND code = ASJBZ.xalbdmbcms) AS xalbdmbcmsMc,
ASJBZ.bzzt AS bzzt,
T.SSJZRMBY AS ssjzrmby,
case when ASJBZ.bzzt='1' then '已标注' else case when ASJBZ.bzzt='2' then '待标注' else '未标注' end end AS bzztMs
FROM TB_ST_ASJ T, TB_ST_ASJBZ ASJBZ,TB_XW_ZBFZXYR XYR where
T.ASJBH = ASJBZ.ASJBH(+)
AND T.ASJBH = XYR.ASJBH
AND T.XXSC_PDBZ = 0
AND XYR.XXSC_PDBZ = 0
AND T.ASJBH = #{asjbh}
</select>
<!-- asjshr-->
<select id="selectTbStAsjShrList" parameterType="String" resultType="com.founder.commonutils.bzptEntity.TbStAsjEsEntity">
SELECT
RYBH.xxzjbh AS xxzjbh,
T.asjbh AS asjbh,
ASJBZ.ajzlb AS ajzlb,
(select name from SYS_DICTITEM where groupid='CODE_GABAJZLB' AND code = ASJBZ.ajzlb) AS ajzlbMc,
ASJBZ.ajxzlb AS ajxzlb,
(select name from SYS_DICTITEM where groupid='CODE_GABAJXZLB' AND code = ASJBZ.ajxzlb) AS ajxzlbMc,
ASJBZ.xalbdmbcms AS xalbdmbcms,
(select name from SYS_DICTITEM where groupid='CODE_GABXALBDMBCMS' AND code = ASJBZ.xalbdmbcms) AS xalbdmbcmsMc,
ASJBZ.bzzt as bzzt,
T.SSJZRMBY AS ssjzrmby,
case when ASJBZ.bzzt='1' then '已标注' else case when ASJBZ.bzzt='2' then '待标注' else '未标注' end end AS bzztMs
FROM TB_ST_ASJ T, TB_ST_ASJBZ ASJBZ,TB_XW_RYBH RYBH where
T.ASJBH = ASJBZ.ASJBH(+)
AND T.ASJBH = RYBH.ASJBH
AND T.XXSC_PDBZ = 0
AND RYBH.XXSC_PDBZ = 0
AND T.ASJBH = #{asjbh}
</select>
<!-- asjxyrshr全量-->
<select id="selectTbStAsjXyrShrList" parameterType="String" resultType="com.founder.commonutils.bzptEntity.TbStAsjEsEntity">
SELECT
XYR.xxzjbh || RYBH.xxzjbh as xxzjbh,
T.asjbh AS asjbh,
ASJBZ.asjbz_ajfl AS asjbzAjfl,
ASJBZ.ajzlb AS ajzlb,
(select name from SYS_DICTITEM where groupid='CODE_GABAJZLB' AND code = ASJBZ.ajzlb) AS ajzlbMc,
ASJBZ.ajxzlb AS ajxzlb,
(select name from SYS_DICTITEM where groupid='CODE_GABAJXZLB' AND code = ASJBZ.ajxzlb) AS ajxzlbMc,
ASJBZ.xalbdmbcms AS xalbdmbcms,
(select name from SYS_DICTITEM where groupid='CODE_GABXALBDMBCMS' AND code = ASJBZ.xalbdmbcms) AS xalbdmbcmsMc,
ASJBZ.bzzt AS bzzt,
T.SSJZRMBY AS ssjzrmby,
case when ASJBZ.bzzt='1' then '已标注' else case when ASJBZ.bzzt='2' then '待标注' else '未标注' end end AS bzztMs
FROM TB_ST_ASJ T, TB_ST_ASJBZ ASJBZ,TB_XW_ZBFZXYR XYR, TB_XW_RYBH RYBH where
T.ASJBH = ASJBZ.ASJBH(+)
AND T.ASJBH = XYR.ASJBH
AND T.ASJBH = RYBH.ASJBH
AND T.XXSC_PDBZ = 0
AND XYR.XXSC_PDBZ = 0
AND RYBH.XXSC_PDBZ = 0
AND T.ASJBH = #{asjbh}
</select>
<!--修改服务标识号-->
<update id="updateBsh" parameterType="com.founder.commonutils.bzptEntity.TbTzxxjqTzxxlxdy">
update tb_tzxxjq_tzxxlxdy
......
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