package com.zbooksoft.gdmis.operate;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.ruili.wcp.common.CustomConfigUtil;
|
import com.ruili.wcp.common.SpringContextUtil;
|
import com.ruili.wcp.configsettting.SystemConfig;
|
import com.ruili.wcp.data.entity.config.Module;
|
import com.ruili.wcp.data.entity.config.View;
|
import com.ruili.wcp.data.entity.management.User;
|
import com.ruili.wcp.engine.form.IFormData;
|
import com.ruili.wcp.service.config.ModuleService;
|
import com.ruili.wcp.service.config.ViewService;
|
import com.ruili.wcp.web.model.AjaxResponse;
|
import com.ruili.wcp.web.model.ErrorInfo;
|
import com.zbooksoft.gdmis.config.ArchivesCustomConfig;
|
import com.zbooksoft.gdmis.data.entity.BorrowDetail;
|
import com.zbooksoft.gdmis.data.entity.CatAjjxx;
|
import com.zbooksoft.gdmis.data.entity.CatYswjxx;
|
import com.zbooksoft.gdmis.data.entity.PhysicalDetail;
|
import com.zbooksoft.gdmis.service.*;
|
import org.apache.shiro.SecurityUtils;
|
import org.apache.shiro.session.Session;
|
import org.apache.shiro.subject.Subject;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.jdbc.core.BatchPreparedStatementSetter;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import java.io.File;
|
import java.io.IOException;
|
import java.sql.PreparedStatement;
|
import java.sql.SQLException;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.*;
|
|
|
/**
|
* @Description:地质资料基本信息操作方法
|
* @Author: zhai
|
* @Date: 2024/8/15
|
**/
|
public class CatAjjxxOperate {
|
private static final Logger logger = LoggerFactory.getLogger(CatAjjxxOperate.class);
|
ViewService viewService = (ViewService) SpringContextUtil.getBean("viewServiceImpl");
|
BorrowDetailService borrowDetailService = (BorrowDetailService) SpringContextUtil.getBean("borrowDetailServiceImpl");
|
CatAjjxxService catAjjxxService = (CatAjjxxService) SpringContextUtil.getBean("catAjjxxServiceImpl");
|
PhysicalDetailService physicalDetailService = (PhysicalDetailService) SpringContextUtil.getBean("physicalDetailServiceImpl");
|
ModuleService moduleService = (ModuleService) SpringContextUtil.getBean("moduleServiceImpl");
|
JdbcTemplate jdbcTemplate = (JdbcTemplate) SpringContextUtil.getBean("jdbcTemplate");
|
IFormData iform = (IFormData) SpringContextUtil.getBean("iFormData");
|
CatYswjxxService catYswjxxService = (CatYswjxxService) SpringContextUtil.getBean("catYswjxxServiceImpl");
|
CustomConfigUtil customConfigUtil = (CustomConfigUtil) SpringContextUtil.getBean("customConfigUtil");
|
|
|
/**
|
* 发布
|
*
|
* @param viewId
|
* @param idList
|
* @return
|
*/
|
public AjaxResponse release(Long viewId, ArrayList<Long> idList) {
|
try {
|
LocalDateTime now = LocalDateTime.now();
|
|
// 创建 DateTimeFormatter 对象，指定日期格式 blankTape
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
// 格式化日期
|
String formattedDate = now.format(formatter);
|
View view = viewService.getViewById(viewId);
|
String strSql = "update " + view.getMainTableName() + " set fbzt = 1 ";
|
jdbcTemplate.batchUpdate(strSql + " where " + view.getIdField() + "=?", new BatchPreparedStatementSetter() {
|
@Override
|
public void setValues(PreparedStatement ps, int i) throws SQLException {
|
ps.setLong(1, idList.get(i));// 下标从1开始
|
}
|
|
@Override
|
public int getBatchSize() {
|
return idList.size();
|
}
|
});
|
QueryWrapper<CatYswjxx> queryWrapper=new QueryWrapper<>();
|
queryWrapper.in("aj_id",idList).eq("yszt",3);
|
// queryWrapper.in("aj_id",idList);
|
List<CatYswjxx> catYswjxxList=catYswjxxService.list(queryWrapper);
|
ArchivesCustomConfig archivesCustomConfig = customConfigUtil.getConfigObj(ArchivesCustomConfig.class);
|
for (CatYswjxx catYswjxx : catYswjxxList) {
|
String destDir = archivesCustomConfig.getOriginalPath() + "已入库" + File.separator + catYswjxx.getWjlj().substring(archivesCustomConfig.getOriginalPath().length());
|
// 源文件路径
|
File sourceFile = new File(catYswjxx.getWjlj());
|
// 目标文件路径
|
File destFile = new File(destDir);
|
|
// 确保目标目录存在
|
File destParentDir = destFile.getParentFile();
|
if (destParentDir != null && !destParentDir.exists()) {
|
destParentDir.mkdirs();
|
}
|
|
// 判断源文件是文件还是文件夹
|
if (sourceFile.isDirectory()) {
|
// 如果是文件夹，复制整个文件夹及其内容
|
copyDirectory(sourceFile, destFile);
|
} else {
|
// 如果是文件，直接复制
|
java.nio.file.Files.copy(sourceFile.toPath(), destFile.toPath(),
|
java.nio.file.StandardCopyOption.REPLACE_EXISTING);
|
}
|
|
// 删除源文件或源文件夹
|
deleteDirectory(sourceFile);
|
|
catYswjxx.setWjlj(destDir);
|
catYswjxxService.saveOrUpdate(catYswjxx);
|
}
|
return new AjaxResponse(true);
|
} catch (Exception e) {
|
logger.error(e.getMessage(), e);
|
return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
|
}
|
}
|
|
/**
|
* 复制目录及其子目录和文件
|
* @param source 源目录
|
* @param target 目标目录
|
* @throws IOException
|
*/
|
private void copyDirectory(File source, File target) throws IOException {
|
if (source.isDirectory()) {
|
// 如果目标目录不存在，则创建
|
if (!target.exists()) {
|
target.mkdirs();
|
}
|
|
// 获取源目录下的所有文件和子目录
|
String[] files = source.list();
|
if (files != null) {
|
for (String file : files) {
|
File srcFile = new File(source, file);
|
File destFile = new File(target, file);
|
// 递归复制
|
copyDirectory(srcFile, destFile);
|
}
|
}
|
} else {
|
// 如果是文件，直接复制
|
java.nio.file.Files.copy(source.toPath(), target.toPath(),
|
java.nio.file.StandardCopyOption.REPLACE_EXISTING);
|
}
|
}
|
|
/**
|
* 删除目录及其子目录和文件
|
* @param directory 要删除的目录
|
*/
|
private void deleteDirectory(File directory) {
|
if (directory.isDirectory()) {
|
File[] files = directory.listFiles();
|
if (files != null) {
|
for (File file : files) {
|
deleteDirectory(file);
|
}
|
}
|
}
|
directory.delete();
|
}
|
|
/**
|
* 取消发布
|
*
|
* @param viewId
|
* @param idList
|
* @return
|
*/
|
public AjaxResponse cancelRelease(Long viewId, ArrayList<Long> idList) {
|
try {
|
int state = 0;
|
String columnName = "fbzt";
|
// updateState(viewId, idList, state, columnName);
|
QueryWrapper<CatAjjxx> fileQueryWrapper = new QueryWrapper<>();
|
fileQueryWrapper.in("id",idList);
|
List<CatAjjxx> catAjjxxList=catAjjxxService.list(fileQueryWrapper);
|
return new AjaxResponse(true);
|
} catch (Exception e) {
|
logger.error(e.getMessage(), e);
|
return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
|
}
|
}
|
|
|
/**
|
* 取消发布
|
*
|
* @param viewId
|
* @param idList
|
* @return
|
*/
|
public AjaxResponse warehousing(Long viewId, ArrayList<Long> idList) {
|
try {
|
int state = 1;
|
String columnName = "zlzt";
|
updateState(viewId, idList, state, columnName);
|
return new AjaxResponse(true);
|
} catch (Exception e) {
|
logger.error(e.getMessage(), e);
|
return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
|
}
|
}
|
|
public void updateState(Long viewId, ArrayList<Long> idList, Integer state, String columnName) {
|
View view = viewService.getViewById(viewId);
|
String strSql = "update " + view.getMainTableName() + " set " + columnName + " = " + state;
|
// jdbcTemplate.batchUpdate(strSql + " where " + view.getIdField() + "=?", new BatchPreparedStatementSetter() {
|
// @Override
|
// public void setValues(PreparedStatement ps, int i) throws SQLException {
|
// ps.setLong(1, idList.get(i));// 下标从1开始
|
// }
|
//
|
// @Override
|
// public int getBatchSize() {
|
// return idList.size();
|
// }
|
// });
|
|
}
|
|
|
/**
|
* 添加档案利用
|
*
|
* @param viewId
|
* @param idList
|
* @return
|
*/
|
public AjaxResponse addUtilization(Long viewId, ArrayList<Long> idList) {
|
try {
|
View view = viewService.getViewById(viewId);
|
AjaxResponse ajaxResponse = addUtilizationByModuleId(view.getModuleId(), idList);
|
return ajaxResponse;
|
} catch (Exception e) {
|
logger.error(e.getMessage(), e);
|
return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
|
}
|
}
|
|
/**
|
* 添加档案利用
|
*
|
* @param viewId
|
* @param idList
|
* @return
|
*/
|
public AjaxResponse addUtilizationAll(Long viewId, ArrayList<Long> idList) {
|
try {
|
|
AjaxResponse ajaxResponse = addUtilizationByAll(idList);
|
return ajaxResponse;
|
} catch (Exception e) {
|
logger.error(e.getMessage(), e);
|
return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
|
}
|
}
|
|
/**
|
* 通过moduleid添加档案利用
|
*/
|
public AjaxResponse addUtilizationByModuleId(Long moduleId, List<Long> idList) {
|
try {
|
|
Module module = moduleService.getByIdModule(moduleId);
|
QueryWrapper<Module> moduleQueryWrapper = new QueryWrapper<>();
|
moduleQueryWrapper.eq("module_id", module.getParentId());
|
moduleQueryWrapper.ne("parent_id", 0);
|
List<Module> moduleList = moduleService.list(moduleQueryWrapper);
|
|
AjaxResponse ajaxResponse = new AjaxResponse(true);
|
|
Map<String, Object> resultMap = new HashMap<String, Object>();
|
if (moduleList.size() == 0) {
|
// 案卷级利用
|
resultMap = addUtilizationForFile(idList);
|
} else if (moduleList.size() > 0) {
|
// 文件级利用，需要反查案卷级信息
|
resultMap = addUtilizationForItem(module, idList);
|
}
|
|
// String unit = resultMap.get("unit").toString().equals("卷") ? "0" : "1";
|
String unit = "0";
|
if (resultMap != null) {
|
StringBuilder sb = new StringBuilder();
|
sb.append("top.layer.open({");
|
sb.append(" title : '提示',");
|
sb.append(" type : 2,");
|
sb.append(" area : [ '700px', '220px' ],");
|
sb.append(" fixed : true, ");
|
sb.append(" content : 'common/commonTips?addNum=" + resultMap.get("addNum") + "&type=借阅&repeatNum=" + resultMap.get("repeatNum") + "&existFileNum=" + resultMap.get("existFileNum") + "&existItemNum=" + resultMap.get("existItemNum") + "&urlPath=borrow'");
|
sb.append("});");
|
|
Map<String, String> result = new HashMap<String, String>();
|
result.put("jsExpression", sb.toString());
|
result.put("totalNum", resultMap.get("existFileNum").toString());
|
ajaxResponse.setResult(result);
|
}
|
return ajaxResponse;
|
} catch (Exception ex) {
|
logger.error(ex.getMessage(), ex);
|
return new AjaxResponse(new ErrorInfo(ex.getMessage()), false);
|
}
|
}
|
|
/**
|
* 通过moduleid添加档案利用
|
*/
|
public AjaxResponse addUtilizationByAll(List<Long> idList) {
|
try {
|
|
String strSql = "select * from view_all_utlization where id = " + idList.get(0);
|
Map<String, Object> map = jdbcTemplate.queryForMap(strSql);
|
Long moduleId = Long.parseLong(map.get("module_id").toString());
|
Module module = moduleService.getByIdModule(moduleId);
|
QueryWrapper<Module> moduleQueryWrapper = new QueryWrapper<>();
|
moduleQueryWrapper.eq("module_id", module.getParentId());
|
moduleQueryWrapper.ne("parent_id", 0);
|
List<Module> moduleList = moduleService.list(moduleQueryWrapper);
|
|
AjaxResponse ajaxResponse = new AjaxResponse(true);
|
|
Map<String, Object> resultMap = new HashMap<String, Object>();
|
if (moduleList.size() == 0) {
|
// 案卷级利用
|
resultMap = addUtilizationForFile(idList);
|
} else if (moduleList.size() > 0) {
|
// 文件级利用，需要反查案卷级信息
|
resultMap = addUtilizationForItem(module, idList);
|
}
|
|
// String unit = resultMap.get("unit").toString().equals("卷") ? "0" : "1";
|
String unit = "0";
|
if (resultMap != null) {
|
StringBuilder sb = new StringBuilder();
|
sb.append("top.layer.open({");
|
sb.append(" title : '提示',");
|
sb.append(" type : 2,");
|
sb.append(" area : [ '700px', '220px' ],");
|
sb.append(" fixed : true, ");
|
sb.append(" content : 'common/commonTips?addNum=" + resultMap.get("addNum") + "&type=借阅&repeatNum=" + resultMap.get("repeatNum") + "&existFileNum=" + resultMap.get("existFileNum") + "&existItemNum=" + resultMap.get("existItemNum") + "&urlPath=borrow'");
|
sb.append("});");
|
|
Map<String, String> result = new HashMap<String, String>();
|
result.put("jsExpression", sb.toString());
|
result.put("totalNum", resultMap.get("existFileNum").toString());
|
ajaxResponse.setResult(result);
|
}
|
return ajaxResponse;
|
} catch (Exception ex) {
|
logger.error(ex.getMessage(), ex);
|
return new AjaxResponse(new ErrorInfo(ex.getMessage()), false);
|
}
|
}
|
|
public Map<String, Object> addUtilizationForFile(List<Long> idList) {
|
Subject currentUser = SecurityUtils.getSubject();
|
Session session = currentUser.getSession();
|
User user = (User) session.getAttribute("user");
|
|
Map<String, Object> resultMap = new HashMap<>();
|
int addNum = 0;
|
int repeatNum = 0;
|
int existItemNum = 0;
|
|
for (int i = 0; i < idList.size(); i++) {
|
Long keyId = idList.get(i);
|
QueryWrapper<BorrowDetail> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("form_id", 0);
|
queryWrapper.eq("create_user_id", user.getUserId());
|
int itemCount = borrowDetailService.count(queryWrapper);
|
existItemNum += itemCount;
|
queryWrapper.eq("file_id", keyId);
|
List<BorrowDetail> borrowDetailList = borrowDetailService.list(queryWrapper);
|
if (borrowDetailList.size() == 0) {
|
CatAjjxx catAjjxx = catAjjxxService.getById(keyId);
|
Integer cgwjxxCount = borrowDetailService.setCgwjxx(catAjjxx);
|
Integer yswjxxCount = borrowDetailService.setYswjxx(catAjjxx);
|
addNum++;
|
existItemNum += cgwjxxCount + yswjxxCount;
|
} else {
|
repeatNum++;
|
}
|
}
|
String strSql = "select distinct file_id from UTL_BORROW_DETAIL where form_id=0 and create_user_id=" + user.getUserId();
|
List<Map<String, Object>> parentMapList = jdbcTemplate.queryForList(strSql);
|
resultMap.put("existFileNum", parentMapList.size());
|
resultMap.put("existItemNum", existItemNum);
|
resultMap.put("addNum", addNum);
|
resultMap.put("repeatNum", repeatNum);
|
|
return resultMap;
|
}
|
|
public Map<String, Object> addUtilizationForItem(Module module, List<Long> idList) {
|
Subject currentUser = SecurityUtils.getSubject();
|
Session session = currentUser.getSession();
|
User user = (User) session.getAttribute("user");
|
|
int addNum = 0;
|
int repeatNum = 0;
|
int existItemNum = 0;
|
|
Map<String, Object> resultMap = new HashMap<>();
|
for (int i = 0; i < idList.size(); i++) {
|
Long keyId = idList.get(i);
|
QueryWrapper<BorrowDetail> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("form_id", 0);
|
queryWrapper.eq("create_user_id", user.getUserId());
|
int itemCount = borrowDetailService.count(queryWrapper);
|
existItemNum += itemCount;
|
queryWrapper.eq("item_id", keyId);
|
List<BorrowDetail> borrowDetailList = borrowDetailService.list(queryWrapper);
|
if (borrowDetailList.size() == 0) {
|
String mainTableName = module.getMainTableName();
|
if (mainTableName.equals("CAT_ITEM_CGWJXX")) {
|
Integer cgwjxxCount = borrowDetailService.setCgwjxxByIds(idList);
|
existItemNum += cgwjxxCount;
|
} else if (mainTableName.equals("CAT_ITEM_YSWJXX")) {
|
Integer cgwjxxCount = borrowDetailService.setYswjxxByIds(idList);
|
existItemNum += cgwjxxCount;
|
}
|
}
|
}
|
|
resultMap.put("addNum", 1);
|
resultMap.put("repeatNum", 0);
|
resultMap.put("existItemNum", existItemNum);
|
String strSql = "select distinct file_id from UTL_BORROW_DETAIL where form_id=0 and create_user_id=" + user.getUserId();
|
List<Map<String, Object>> parentMapList = jdbcTemplate.queryForList(strSql);
|
resultMap.put("existFileNum", parentMapList.size());
|
return resultMap;
|
}
|
|
|
|
//添加实物样品
|
public Map<String, Object> addPhysicalForItem( Long viewId, ArrayList<Long> idList) {
|
Subject currentUser = SecurityUtils.getSubject();
|
Session session = currentUser.getSession();
|
User user = (User) session.getAttribute("user");
|
|
int addNum = 0;
|
int repeatNum = 0;
|
int existItemNum = 0;
|
|
Map<String, Object> resultMap = new HashMap<>();
|
for (int i = 0; i < idList.size(); i++) {
|
Long keyId = idList.get(i);
|
QueryWrapper<PhysicalDetail> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("form_id", 0);
|
queryWrapper.eq("create_user_id", user.getUserId());
|
int itemCount = physicalDetailService.count(queryWrapper);
|
existItemNum += itemCount;
|
queryWrapper.eq("item_id", keyId);
|
List<PhysicalDetail> physicalDetailList = physicalDetailService.list(queryWrapper);
|
if (physicalDetailList.size() == 0) {
|
Integer cgwjxxCount = physicalDetailService.setCgwjxxByIds(idList);
|
existItemNum += cgwjxxCount;
|
}
|
}
|
|
resultMap.put("addNum", 1);
|
resultMap.put("repeatNum", 0);
|
resultMap.put("existItemNum", existItemNum);
|
String strSql = "select distinct file_id from UTL_PHYSICAL_DETAIL where form_id=0 and create_user_id=" + user.getUserId();
|
List<Map<String, Object>> parentMapList = jdbcTemplate.queryForList(strSql);
|
resultMap.put("existFileNum", parentMapList.size());
|
return resultMap;
|
}
|
|
/**
|
* 添加成果
|
*
|
* @param viewId
|
* @param idList
|
* @return
|
*/
|
public AjaxResponse addCg(Long viewId, ArrayList<Long> idList) {
|
try {
|
String cgSql = "select NVL(max(BGBH), 0) BGBH FROM CAT_ITEM_CGWJXX";
|
Map<String, Object> stringMap = jdbcTemplate.queryForMap(cgSql);
|
int maxDH = Integer.parseInt(stringMap.get("BGBH").toString());
|
for (int i = 0; i < idList.size(); i++) {
|
int newDH = maxDH + 1 + i;
|
String newDhString = String.format("%04d", newDH);
|
String sql = "select * from CAT_ITEM_YSWJXX where id = " + idList.get(i);
|
Map<String, Object> stringObjectMap = jdbcTemplate.queryForMap(sql);
|
|
stringObjectMap.put("BGBH", newDhString);
|
LocalDateTime currentDate = LocalDateTime.now();
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
String formattedDate = currentDate.format(formatter);
|
stringObjectMap.put("CREATE_TIME", formattedDate);
|
stringObjectMap.put("MODIFY_TIME", formattedDate);
|
stringObjectMap.put("CDDZWJLJ", stringObjectMap.get("WJLJ"));
|
stringObjectMap.put("CDDZWJLJ", stringObjectMap.get("WJLJ"));
|
iform.insert(1823017354756390913L, stringObjectMap);
|
}
|
|
return null;
|
} catch (Exception e) {
|
logger.error(e.getMessage(), e);
|
return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
|
}
|
}
|
|
/**
|
* 取消发布
|
*
|
* @param viewId
|
* @param idList
|
* @return
|
*/
|
public AjaxResponse createArchiveCode(Long viewId, ArrayList<Long> idList) {
|
try {
|
String sql = "select NVL(max(DH), 0) DH FROM CAT_FILE_AJJXX";
|
Map<String, Object> stringObjectMap = jdbcTemplate.queryForMap(sql);
|
int maxDH = Integer.parseInt(stringObjectMap.get("DH").toString());
|
for (int i = 0; i < idList.size(); i++) {
|
int newDH = maxDH + 1 + i;
|
String newDhString = String.format("%04d", newDH);
|
String updateSql = "update CAT_FILE_AJJXX set DH = '" + newDhString + "' where ID = " + idList.get(i);
|
jdbcTemplate.update(updateSql);
|
}
|
return new AjaxResponse(true);
|
} catch (Exception e) {
|
logger.error(e.getMessage(), e);
|
return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
|
}
|
}
|
|
}
|
