package com.zbooksoft.gdmis.service.impl;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.node.ArrayNode;
|
import com.fasterxml.jackson.databind.node.ObjectNode;
|
import com.ruili.wcp.common.CustomConfigUtil;
|
import com.ruili.wcp.common.IdGenerater;
|
import com.ruili.wcp.data.entity.management.User;
|
import com.ruili.wcp.engine.form.IFormData;
|
import com.zbooksoft.gdmis.data.entity.*;
|
import com.zbooksoft.gdmis.service.*;
|
import org.apache.shiro.SecurityUtils;
|
import org.apache.shiro.session.Session;
|
import org.apache.shiro.subject.Subject;
|
import org.dom4j.Document;
|
import org.dom4j.Node;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.text.SimpleDateFormat;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import static com.zbooksoft.gdmis.common.XmlUtil.*;
|
|
/**
|
* @Description:
|
* @Author: zhai
|
* @Date: 2024/8/7
|
**/
|
@Service
|
public class XmlServiceImpl implements XmlService {
|
|
@Autowired
|
CatXzqService catXzqService;
|
@Autowired
|
CatDlwzxxService catDlwzxxService;
|
@Autowired
|
CatKcService catKcService;
|
@Autowired
|
CatSmxxService catSmxxService;
|
@Autowired
|
CatZkxxService catZkxxService;
|
@Autowired
|
CatTfxxService catTfxxService;
|
@Autowired
|
CatYswjxxService catYswjxxService;
|
|
@Autowired
|
CatCgwjxxService catCgwjxxService;
|
|
@Autowired
|
CatAjjxxService catAjjxxService;
|
@Autowired
|
CatCheckService catCheckService;
|
@Autowired
|
CustomConfigUtil customConfigUtil;
|
@Autowired
|
JdbcTemplate jdbcTemplate;
|
@Autowired
|
IFormData iform;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void readXml(Document document, String startData, String endData) throws Exception {
|
|
Subject currentUser = SecurityUtils.getSubject();
|
Session session = currentUser.getSession();
|
User user = (User) session.getAttribute("user");
|
|
//案卷级信息
|
Node ajjxxNode = getNode(document, "AJJXX");
|
Node zlxxNode = getNode(document, "ZLXX");
|
// Node bsdNode = getNode(document, "DZZLBSD");
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
String xmbh = getNodeText(ajjxxNode, "XMBH");
|
String xmmc = getNodeText(ajjxxNode, "XMMC");
|
|
|
Long ajjxxId = 0L;
|
QueryWrapper<CatAjjxx> catAjjxxQueryWrapper = new QueryWrapper<>();
|
catAjjxxQueryWrapper.eq("XMKYQBH", xmbh);
|
catAjjxxQueryWrapper.eq("XMKYQMC", xmmc);
|
List<CatAjjxx> list = catAjjxxService.list(catAjjxxQueryWrapper);
|
if (list.size() > 0) {
|
CatAjjxx catAjjxx = list.get(0);
|
ajjxxId = catAjjxx.getId();
|
} else {
|
CatAjjxx catAjjxx = new CatAjjxx();
|
ajjxxId = IdGenerater.getId();
|
String sql = "select NVL(max(DH), 0) DH FROM CAT_FILE_AJJXX";
|
Map<String, Object> stringObjectMap = jdbcTemplate.queryForMap(sql);
|
String dh = stringObjectMap.get("DH").toString();
|
if (dh.length() > 4) {
|
//取后4位
|
dh = dh.substring(dh.length() - 4);
|
}
|
int maxDH = Integer.parseInt(dh);
|
int newDH = maxDH + 1;
|
String newDhString = String.format("%04d", newDH);
|
catAjjxx.setDh(newDhString);
|
catAjjxx.setId(ajjxxId);
|
catAjjxx.setDeleteState(0);
|
catAjjxx.setSlsj(startData);
|
catAjjxx.setYsjzsj(stringToDate(endData));
|
catAjjxx.setZlzt(0);
|
if (user != null) {
|
catAjjxx.setSlr(user.getTrueName());
|
catAjjxx.setYsr(user.getTrueName());
|
}
|
//项目信息XMKYQBH
|
catAjjxx.setXmkyqbh(getNodeText(ajjxxNode, "XMBH"));
|
catAjjxx.setRwsbh(getNodeText(ajjxxNode, "XMRWSBH"));
|
catAjjxx.setXmkyqlx(getNodeText(ajjxxNode, "XMLX"));
|
catAjjxx.setXmkyqxz(getNodeText(ajjxxNode, "XMXZ"));
|
catAjjxx.setZjly(getNodeText(ajjxxNode, "XMZJLY"));
|
catAjjxx.setXmsfzm(getNodeText(ajjxxNode, "XMSFM"));
|
//矿业权人
|
catAjjxx.setXmkyqmc(getNodeText(ajjxxNode, "XMMC"));
|
catAjjxx.setNd(getNodeText(ajjxxNode, "ND"));
|
catAjjxx.setNdjf(getNodeText(ajjxxNode, "NDJF"));
|
catAjjxx.setQssj(getNodeText(ajjxxNode, "QSSJ"));
|
catAjjxx.setZzsj(getNodeText(ajjxxNode, "ZZSJ"));
|
catAjjxx.setXmzq(getNodeText(ajjxxNode, "XMZQ"));
|
catAjjxx.setXmsx(getNodeText(ajjxxNode, "XMSX"));
|
catAjjxx.setSxdw(getNodeText(ajjxxNode, "SXDW"));
|
catAjjxx.setSxdw(getNodeText(ajjxxNode, "SXDW"));
|
catAjjxx.setXmzt(getNodeText(ajjxxNode, "XMZT"));
|
catAjjxx.setXmfzr(getNodeText(ajjxxNode, "XMFZR"));
|
catAjjxx.setXmzgjgmc(getNodeText(ajjxxNode, "XMZGJGMC"));
|
catAjjxx.setXmfzrjs(getNodeText(ajjxxNode, "XMFZRJS"));
|
catAjjxx.setXmfzrhq(getNodeText(ajjxxNode, "XMFFZR"));
|
catAjjxx.setXmxxsm(getNodeText(ajjxxNode, "XMXXSM"));
|
catAjjxxService.saveOrUpdate(catAjjxx);
|
}
|
|
String yjdw = getNodeText(ajjxxNode, "YJDW");
|
String yjsj = getNodeText(ajjxxNode, "YJSJ");
|
String yjr = getNodeText(ajjxxNode, "YJR");
|
String yjrlxfs = getNodeText(ajjxxNode, "YJRLXFS");
|
String yjbh = getNodeText(ajjxxNode, "YJBH");
|
String cjsj = getNodeText(ajjxxNode, "CJSJ");
|
HashMap<String, Object> transferMap = new HashMap<>();
|
transferMap.put("TRANSFER_DEPT", yjdw);
|
transferMap.put("TRANSFER_TIEM", yjsj);
|
transferMap.put("TRANSFER_USER", yjr);
|
transferMap.put("USER_NUMBER", yjrlxfs);
|
transferMap.put("TRANSFER_NUM", yjbh);
|
transferMap.put("CREATE_TIME", cjsj);
|
transferMap.put("CREATE_USER_ID", user.getUserId());
|
transferMap.put("AJ_ID", ajjxxId);
|
Long insertId = iform.insert(1977224563949338625l, transferMap);
|
|
// 原始文件级信息
|
List<Node> yswjxxNodeList = getNodeList(zlxxNode, "WJJXX");
|
for (Node yswjxxNode : yswjxxNodeList) {
|
String wjtm = getNodeText(yswjxxNode, "WJTM");
|
HashMap<String, Object> map = new HashMap<>();
|
//判断是否存在，存在进行更新，不存在添加
|
|
Long catYswjxxId = IdGenerater.getId();
|
String selectSql = " select * from CAT_ITEM_YSWJXX where AJ_ID =" + ajjxxId + " and WJTM = '" + wjtm + "'";
|
List<Map<String, Object>> mapList = jdbcTemplate.queryForList(selectSql);
|
if (mapList.size() > 0) {
|
Map<String, Object> stringObjectMap = mapList.get(0);
|
String yszt = stringObjectMap.get("yszt") == null ? "0" : stringObjectMap.get("yszt").toString();
|
if (("3").equals(yszt)) {
|
throw new Exception(wjtm + "资料已被接收，请勿重复导入");
|
}
|
catYswjxxId = Long.parseLong(stringObjectMap.get("ID").toString());
|
Object transferNumber = stringObjectMap.get("TRANSFER_NUMBER");
|
int transfer = 1;
|
if (transferNumber != null) {
|
transfer = Integer.parseInt(transferNumber.toString());
|
}
|
map.put("TRANSFER_NUMBER", transfer);
|
}
|
String cgwjmc = getNodeText(yswjxxNode, "WJLB");
|
String jh = getNodeText(yswjxxNode, "JH");
|
String jhLast = jh.substring(jh.length() - 1);
|
String xcdw = getNodeText(yswjxxNode, "XCDW");
|
String xcr = getNodeText(yswjxxNode, "XCR");
|
String xcsj = getNodeText(yswjxxNode, "XCSJ");
|
String sl = getNodeText(yswjxxNode, "SL");
|
String ym = getNodeText(yswjxxNode, "YM");
|
String psdw = getNodeText(yswjxxNode, "PSDW");
|
String pswh = getNodeText(yswjxxNode, "PSWH");
|
String pssj = getNodeText(yswjxxNode, "PSSJ");
|
String bxdw = getNodeText(yswjxxNode, "BXDW");
|
String bxz = getNodeText(yswjxxNode, "BXZ");
|
String zzys = getNodeText(yswjxxNode, "ZZYS");
|
String wjdx = getNodeText(yswjxxNode, "WJDX");
|
String wjlb = getNodeText(yswjxxNode, "WJLB");
|
String wjlj = getNodeText(yswjxxNode, "WJLJ");
|
String ztxs = getNodeText(yswjxxNode, "ZTXS");
|
String qzy = getNodeText(yswjxxNode, "QZY");
|
String hxblc = getNodeText(yswjxxNode, "HXBLC");
|
String zxblc = getNodeText(yswjxxNode, "ZXBLC");
|
String wjgs = getNodeText(yswjxxNode, "WJGSXX/WJGS");
|
String wjgssm = getNodeText(yswjxxNode, "WJGSXX/WJGSSM");
|
|
|
map.put("ID", catYswjxxId);
|
map.put("AJ_ID", ajjxxId);
|
map.put("CGWJMC", cgwjmc);
|
map.put("JNXH", jh);
|
map.put("WJTM", wjtm);
|
//E:\项目\广海\测试数据导入\海南陆XX成果年度总结报告光盘（GHD20255082；含成果报告、普查报告、附图、评审意见）.pdf
|
//截取文件名不带后缀 从最后一个\开始
|
String wjm = "";
|
if (wjgs != null && !"".equals(wjgs)) {
|
wjm = wjlj.substring(wjlj.lastIndexOf("\\") + 1, wjlj.lastIndexOf("."));
|
} else {
|
wjm = wjlj.substring(wjlj.lastIndexOf("\\") + 1);
|
}
|
|
|
map.put("WJM", wjm);
|
map.put("XCDWMC", xcdw);
|
map.put("BXZ", xcr);
|
map.put("XCSJ", xcsj);
|
map.put("SL", sl);
|
map.put("YM", ym);
|
map.put("PSDW", psdw);
|
map.put("PSWH", pswh);
|
map.put("PSSJ", pssj);
|
map.put("BXDW", bxdw);
|
// map.put("BXZ", bxz);
|
map.put("ZZYS", zzys);
|
map.put("WJDX", wjdx);
|
map.put("WJLX", wjlb);
|
map.put("WJLJ", wjlj);
|
map.put("GDZTXS", ztxs);
|
map.put("QZY", qzy);
|
map.put("FTHXBLC", hxblc);
|
map.put("FTZXBLC", zxblc);
|
map.put("WJGS", wjgs);
|
map.put("WJGSSM", wjgssm);
|
map.put("JUANH", 1);
|
map.put("XH", jhLast);
|
map.put("YJ_ID", insertId);
|
|
|
//涉密信息
|
List<Node> smxxNodeList = getNodeList(yswjxxNode, "SMXX/Item");
|
ObjectMapper mapper = new ObjectMapper();
|
ObjectNode root = mapper.createObjectNode();
|
ArrayNode addresses = mapper.createArrayNode();
|
if (smxxNodeList.size() > 0) {
|
map.put("SFSM", "是");
|
} else {
|
map.put("SFSM", "否");
|
}
|
for (int j = 0; j < smxxNodeList.size(); j++) {
|
Node smxxNode = smxxNodeList.get(j);
|
if (j == 0) {
|
map.put("SMYM", getNodeText(smxxNode, "SMNR"));
|
map.put("SMZL", getNodeText(smxxNode, "SMZL"));
|
map.put("SMSX", getNodeText(smxxNode, "SMSX"));
|
map.put("WJMJ", getNodeText(smxxNode, "WJMJ"));
|
Integer securityCode = getSecurityCode(getNodeText(smxxNode, "WJMJ"));
|
map.put("SECURITY_CODE", securityCode);
|
map.put("BMQX", getNodeText(smxxNode, "BMQX"));
|
map.put("ZXFW", getNodeText(smxxNode, "ZXFW"));
|
} else {
|
|
String smnr = getNodeText(smxxNode, "SMNR");
|
String smzl = getNodeText(smxxNode, "SMZL");
|
String smsx = getNodeText(smxxNode, "SMSX");
|
String wjmj = getNodeText(smxxNode, "WJMJ");
|
String bmqx = getNodeText(smxxNode, "BMQX");
|
String zxfw = getNodeText(smxxNode, "ZXFW");
|
|
CatSmxx catSmxx = new CatSmxx();
|
catSmxx.setAjId(ajjxxId);
|
catSmxx.setWjId(catYswjxxId);
|
catSmxx.setSmnr(smnr);
|
catSmxx.setSmzl(smzl);
|
catSmxx.setSmsx(smsx);
|
catSmxx.setWjmj(wjmj);
|
catSmxx.setBmqx(bmqx);
|
// catSmxx.setZxfw(zxfw);
|
catSmxxService.saveOrUpdate(catSmxx);
|
|
//{"classified":[{"mj":"内部","smym":"11","smsx":"22","bmqx":"33","zxfw":"34","smzl":""}]}
|
ObjectNode address = mapper.createObjectNode();
|
address.put("mj", wjmj);
|
address.put("smym", smnr);
|
address.put("smsx", smsx);
|
address.put("bmqx", bmqx);
|
address.put("zxfw", zxfw);
|
address.put("smzl", smzl);
|
addresses.add(address);
|
}
|
}
|
root.put("classified", addresses);
|
String jsonString = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(root);
|
map.put("smxx", jsonString);
|
|
if (mapList.size() > 0) {
|
//TRANSFER_NUMBER
|
iform.update(1823021414679085057L, map, catYswjxxId);
|
} else {
|
iform.insert(1823021414679085057L, map);
|
}
|
}
|
}
|
|
public static void main(String[] args) {
|
//E:\项目\广海\测试数据导入\海南陆XX成果年度总结报告光盘（GHD20255082；含成果报告、普查报告、附图、评审意见）.pdf
|
//截取文件名不带后缀 从最后一个\开始
|
String wjtm = "E:\\项目\\广海\\测试数据导入\\海南陆XX成果年度总结报告光盘（GHD20255082；含成果报告、普查报告、附图、评审意见）.pdf";
|
String wjm = wjtm.substring(wjtm.lastIndexOf("\\") + 1, wjtm.lastIndexOf("."));
|
System.out.println(wjm);
|
}
|
}
|
