提交 218cc475 作者: 925993793@qq.com

自定义专题-部分逻辑调整以及研究中心补充接口

上级 9488bd24
package com.zzsn.event.config; package com.zzsn.event.config;
import com.zzsn.event.util.user.AuthUtil; import com.zzsn.event.util.user.AuthUtil;
import com.zzsn.event.util.user.UserVo;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.ibatis.binding.MapperMethod.ParamMap; import org.apache.ibatis.binding.MapperMethod.ParamMap;
import org.apache.ibatis.executor.Executor; import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.mapping.MappedStatement;
...@@ -35,41 +35,33 @@ public class MybatisInterceptor implements Interceptor { ...@@ -35,41 +35,33 @@ public class MybatisInterceptor implements Interceptor {
if (parameter == null) { if (parameter == null) {
return invocation.proceed(); return invocation.proceed();
} }
String loginUsername = this.getLoginUsername();
Date date = new Date();
if (SqlCommandType.INSERT == sqlCommandType) { if (SqlCommandType.INSERT == sqlCommandType) {
UserVo sysUser = this.getLoginUser();
Field[] fields = getAllFields(parameter); Field[] fields = getAllFields(parameter);
for (Field field : fields) { for (Field field : fields) {
log.debug("------field.name------" + field.getName()); String fieldName = field.getName();
try { log.debug("------field.name------" + fieldName);
if ("createBy".equals(field.getName())) { if ("createBy".equals(fieldName)) {
field.setAccessible(true); field.setAccessible(true);
Object localCreateBy = field.get(parameter); Object localCreateBy = field.get(parameter);
field.setAccessible(false); field.setAccessible(false);
if (localCreateBy == null || localCreateBy.equals("") && (sysUser != null)) { if ((localCreateBy == null || localCreateBy.equals("")) && StringUtils.isNotBlank(loginUsername)) {
// 登录人账号 changeData(field, parameter, loginUsername);
field.setAccessible(true);
field.set(parameter, sysUser.getUsername());
field.setAccessible(false);
} }
} }
// 注入创建时间 // 注入创建时间
if ("createTime".equals(field.getName())) { if ("createTime".equals(fieldName)) {
field.setAccessible(true); field.setAccessible(true);
Object localCreateDate = field.get(parameter); Object localCreateDate = field.get(parameter);
field.setAccessible(false); field.setAccessible(false);
if (localCreateDate == null || localCreateDate.equals("")) { if (localCreateDate == null || localCreateDate.equals("")) {
field.setAccessible(true); changeData(field, parameter, date);
field.set(parameter, new Date());
field.setAccessible(false);
} }
} }
} catch (Exception e) {
e.printStackTrace();
}
} }
} }
if (SqlCommandType.UPDATE == sqlCommandType) { if (SqlCommandType.UPDATE == sqlCommandType) {
UserVo sysUser = this.getLoginUser();
Field[] fields; Field[] fields;
if (parameter instanceof ParamMap) { if (parameter instanceof ParamMap) {
ParamMap<?> p = (ParamMap<?>) parameter; ParamMap<?> p = (ParamMap<?>) parameter;
...@@ -86,20 +78,13 @@ public class MybatisInterceptor implements Interceptor { ...@@ -86,20 +78,13 @@ public class MybatisInterceptor implements Interceptor {
fields = getAllFields(parameter); fields = getAllFields(parameter);
} }
for (Field field : fields) { for (Field field : fields) {
log.debug("------field.name------" + field.getName()); String fieldName = field.getName();
try { log.debug("------field.name------" + fieldName);
if ("updateBy".equals(field.getName()) && (sysUser != null)) { if ("updateBy".equals(fieldName) && StringUtils.isNotBlank(loginUsername)) {
field.setAccessible(true); changeData(field, parameter, loginUsername);
field.set(parameter, sysUser.getUsername());
field.setAccessible(false);
} }
if ("updateTime".equals(field.getName())) { if ("updateTime".equals(fieldName)) {
field.setAccessible(true); changeData(field, parameter, date);
field.set(parameter, new Date());
field.setAccessible(false);
}
} catch (Exception e) {
e.printStackTrace();
} }
} }
} }
...@@ -115,8 +100,19 @@ public class MybatisInterceptor implements Interceptor { ...@@ -115,8 +100,19 @@ public class MybatisInterceptor implements Interceptor {
public void setProperties(Properties properties) { public void setProperties(Properties properties) {
} }
private UserVo getLoginUser() { private String getLoginUsername() {
return AuthUtil.getLoginUser(); return AuthUtil.getLoginUser().getUsername();
}
//修改对应字段的值
private void changeData(Field field, Object parameter,Object data){
try {
field.setAccessible(true);
field.set(parameter,data);
field.setAccessible(false);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
} }
private Field[] getAllFields(Object object) { private Field[] getAllFields(Object object) {
......
...@@ -522,7 +522,7 @@ public class FileController { ...@@ -522,7 +522,7 @@ public class FileController {
* @date 2024/4/11 * @date 2024/4/11
*/ */
private Map<String, Object> formatDocData(List<SpecialInformation> exportDataList, String searchWord, Integer type) { private Map<String, Object> formatDocData(List<SpecialInformation> exportDataList, String searchWord, Integer type) {
String docTitle = "事件资讯"; String docTitle = "专题资讯";
//遍历取到的文章 //遍历取到的文章
List<Map<String, Object>> contents = new ArrayList<>(); List<Map<String, Object>> contents = new ArrayList<>();
//文档结构图 //文档结构图
......
...@@ -81,7 +81,6 @@ public class PlatEventManageController { ...@@ -81,7 +81,6 @@ public class PlatEventManageController {
KeywordsVO keywordsVO = eventParam.getKeywordsVO(); KeywordsVO keywordsVO = eventParam.getKeywordsVO();
if (keywordsVO != null) { if (keywordsVO != null) {
UserVo currentUser = UserUtil.getLoginUser(); UserVo currentUser = UserUtil.getLoginUser();
eventParam.setCreateTime(new Date());
eventParam.setCreateBy(currentUser.getUsername()); eventParam.setCreateBy(currentUser.getUsername());
Event event = eventService.saveMain(eventParam); Event event = eventService.saveMain(eventParam);
//新增关键词 //新增关键词
......
...@@ -81,6 +81,8 @@ public class SubjectManageController { ...@@ -81,6 +81,8 @@ public class SubjectManageController {
private SubjectSampleFileService subjectSampleFileService; private SubjectSampleFileService subjectSampleFileService;
@Autowired @Autowired
private SubjectInfoSourceMiddleMapService subjectInfoSourceMiddleMapService; private SubjectInfoSourceMiddleMapService subjectInfoSourceMiddleMapService;
@Autowired
private SysDictItemService sysDictItemService;
@Value("${hotWords.extractUrl}") @Value("${hotWords.extractUrl}")
...@@ -98,24 +100,48 @@ public class SubjectManageController { ...@@ -98,24 +100,48 @@ public class SubjectManageController {
return Result.OK(list); return Result.OK(list);
} }
/**
* 数据字典下字典值信息列表
*
* @param dictCode 字典编码
* @author lkg
* @date 2025/1/7
*/
@GetMapping("/dictItemList")
public Result<?> dictItemList(@RequestParam(defaultValue = "Thematic_Library")String dictCode){
List<SysDictItem> dictItemList = sysDictItemService.listByDictCode(dictCode);
return Result.OK(dictItemList);
}
/**
* 分页列表查询-研究中心
*
* @param subjectCondition 搜索条件
* @param pageNo 当前页
* @param pageSize 每页返回条数
* @author lkg
* @date 2025/1/7
*/
@GetMapping(("/pageList"))
public Result<?> researchCenterPageList(SubjectCondition subjectCondition,
@RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
Page<SubjectPage> pageList = subjectService.researchCenterPageList(subjectCondition, pageNo, pageSize);
return Result.OK(pageList);
}
/** /**
* 分页列表查询 * 分页列表查询
* *
* @param subjectCondition * @param subjectCondition 搜索条件
* @param pageNo * @param pageNo 当前页
* @param pageSize * @param pageSize 每页返回条数
* @return * @return
*/ */
@GetMapping(value = "/listByTypeId") @GetMapping(value = "/listByTypeId")
public Result<?> queryPageListByTypeId(SubjectCondition subjectCondition, public Result<?> queryPageListByTypeId(SubjectCondition subjectCondition,
@RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
Integer facePublic = subjectCondition.getFacePublic();
if (facePublic == null) {
UserVo loginUser = AuthUtil.getLoginUser();
subjectCondition.setUsername(loginUser.getUsername());
}
IPage<SubjectPage> pageList = subjectService.pageList(subjectCondition, pageNo, pageSize); IPage<SubjectPage> pageList = subjectService.pageList(subjectCondition, pageNo, pageSize);
return Result.OK(pageList); return Result.OK(pageList);
} }
...@@ -599,29 +625,32 @@ public class SubjectManageController { ...@@ -599,29 +625,32 @@ public class SubjectManageController {
if (StringUtils.isNotEmpty(subjectId)) { if (StringUtils.isNotEmpty(subjectId)) {
return Result.FAIL("专题id不能为空"); return Result.FAIL("专题id不能为空");
} }
List<String> labelCodes = subjectSourceTagVO.getLabelCodes(); List<InfoSourceLabelVO> labelList = subjectSourceTagVO.getLabelList();
List<String> labelItemCodes = subjectSourceTagVO.getLabelItemCodes(); if (CollectionUtils.isEmpty(labelList)) {
if (CollectionUtils.isEmpty(labelCodes) && CollectionUtils.isEmpty(labelItemCodes)) { return Result.FAIL("信息源标签数据不能为空");
return Result.FAIL("参数不全");
} }
List<SubjectInfoSourceMap> dataList = new ArrayList<>(); List<SubjectInfoSourceMap> dataList = new ArrayList<>();
if (CollectionUtils.isNotEmpty(labelCodes)) { for (InfoSourceLabelVO infoSourceLabelVO : labelList) {
for (String labelCode : labelCodes) { List<InfoSourceLabelItemVO> infoSourceLabelItemList = infoSourceLabelVO.getInfoSourceLabelItemList();
if (CollectionUtils.isEmpty(infoSourceLabelItemList)) {
continue;
}
String labelCode = infoSourceLabelVO.getLabelCode();
for (InfoSourceLabelItemVO infoSourceLabelItemVO : infoSourceLabelItemList) {
String labelItemCode = infoSourceLabelItemVO.getLabelItemCode();
SubjectInfoSourceMap subjectInfoSourceMap = new SubjectInfoSourceMap(); SubjectInfoSourceMap subjectInfoSourceMap = new SubjectInfoSourceMap();
subjectInfoSourceMap.setSubjectId(subjectId); subjectInfoSourceMap.setSubjectId(subjectId);
subjectInfoSourceMap.setSourceId(labelCode); subjectInfoSourceMap.setSourceId(labelCode);
subjectInfoSourceMap.setType(6); subjectInfoSourceMap.setSourceItemId(labelItemCode);
subjectInfoSourceMap.setType(12);
dataList.add(subjectInfoSourceMap); dataList.add(subjectInfoSourceMap);
} }
} }
if (CollectionUtils.isNotEmpty(labelItemCodes)) { LambdaQueryWrapper<SubjectInfoSourceMap> queryWrapper = Wrappers.lambdaQuery();
for (String labelItemCode : labelItemCodes) { queryWrapper.eq(SubjectInfoSourceMap::getSubjectId, subjectId).eq(SubjectInfoSourceMap::getType, 12);
SubjectInfoSourceMap subjectInfoSourceMap = new SubjectInfoSourceMap(); int count = subjectInfoSourceMapService.count(queryWrapper);
subjectInfoSourceMap.setSubjectId(subjectId); if (count > 0) {
subjectInfoSourceMap.setSourceId(labelItemCode); subjectInfoSourceMapService.remove(queryWrapper);
subjectInfoSourceMap.setType(7);
dataList.add(subjectInfoSourceMap);
}
} }
subjectInfoSourceMapService.saveBatch(dataList); subjectInfoSourceMapService.saveBatch(dataList);
return Result.OK(); return Result.OK();
......
...@@ -241,7 +241,7 @@ public class StatisticalAnalysisController { ...@@ -241,7 +241,7 @@ public class StatisticalAnalysisController {
*/ */
private void changeKey(List<CountVO> dataList, String dictCode) { private void changeKey(List<CountVO> dataList, String dictCode) {
if (CollectionUtils.isNotEmpty(dataList)) { if (CollectionUtils.isNotEmpty(dataList)) {
List<SysDictItem> dictItemList = sysDictItemService.listByDictCode(""); List<SysDictItem> dictItemList = sysDictItemService.listByDictCode(dictCode);
Map<String, List<SysDictItem>> map = dictItemList.stream().collect(Collectors.groupingBy(SysDictItem::getItemValue)); Map<String, List<SysDictItem>> map = dictItemList.stream().collect(Collectors.groupingBy(SysDictItem::getItemValue));
for (CountVO countVO : dataList) { for (CountVO countVO : dataList) {
List<SysDictItem> sysDictItemList = map.get(countVO.getName()); List<SysDictItem> sysDictItemList = map.get(countVO.getName());
......
...@@ -39,7 +39,6 @@ public class SubjectTypeController { ...@@ -39,7 +39,6 @@ public class SubjectTypeController {
*/ */
@GetMapping("/treeList") @GetMapping("/treeList")
public Result<?> typeList(@RequestParam Integer category) { public Result<?> typeList(@RequestParam Integer category) {
//获取当前登录用户
List<Node> nodes = subjectTypeService.enableList(category); List<Node> nodes = subjectTypeService.enableList(category);
List<Node> tree = TreeUtil.tree(nodes, "0"); List<Node> tree = TreeUtil.tree(nodes, "0");
return Result.OK(tree); return Result.OK(tree);
...@@ -97,15 +96,21 @@ public class SubjectTypeController { ...@@ -97,15 +96,21 @@ public class SubjectTypeController {
} }
/** /**
* 专题和分类树型结构 * 专题和分类树型结构-研究中心专题页左侧树
* *
* @param facePublic 是否公开(1-是;0-否)
* @author lkg * @author lkg
* @date 2024/4/29 * @date 2025/1/7
*/ */
@GetMapping("/subjectAndTypeTree") @GetMapping("/subjectAndTypeTree")
public Result<?> subjectAndTypeTree(@RequestParam(required = false) Integer facePublic) { public Result<?> subjectAndTypeTree(@RequestParam(required = false) Integer facePublic) {
List<SubjectTreeVO> tree = subjectTypeService.subjectAndTypeTree(facePublic); List<SubjectTreeVO> dataList = null;
return Result.OK(tree); if (facePublic == null) {
dataList = subjectTypeService.subjectAndTypeTree();
} else if (facePublic == 1) {
dataList = subjectTypeService.subjectsByFacePublic(facePublic);
}
return Result.OK(dataList);
} }
/** /**
......
...@@ -191,7 +191,6 @@ public class EventApi { ...@@ -191,7 +191,6 @@ public class EventApi {
event.setUnit("2"); event.setUnit("2");
event.setSpace(1); event.setSpace(1);
event.setCron(CronUtil.generateCron("2",1)); event.setCron(CronUtil.generateCron("2",1));
event.setCreateTime(new Date());
event.setCreateBy(addEventVO.getUsername()); event.setCreateBy(addEventVO.getUsername());
eventService.save(event); eventService.save(event);
String eventId = event.getId(); String eventId = event.getId();
...@@ -212,7 +211,6 @@ public class EventApi { ...@@ -212,7 +211,6 @@ public class EventApi {
//专题和分类关系 //专题和分类关系
SubjectTypeMap subjectTypeMap = new SubjectTypeMap(); SubjectTypeMap subjectTypeMap = new SubjectTypeMap();
subjectTypeMap.setSubjectId(eventId); subjectTypeMap.setSubjectId(eventId);
subjectTypeMap.setCreateTime(new Date());
//分类默认 研究中心 //分类默认 研究中心
subjectTypeMap.setTypeId("1802619433932296193"); subjectTypeMap.setTypeId("1802619433932296193");
subjectTypeMapService.save(subjectTypeMap); subjectTypeMapService.save(subjectTypeMap);
...@@ -235,7 +233,6 @@ public class EventApi { ...@@ -235,7 +233,6 @@ public class EventApi {
eventRegionMap.setRegionId(regionVO.getId()); eventRegionMap.setRegionId(regionVO.getId());
eventRegionMap.setTopRegionId(regionVO.getTopId()); eventRegionMap.setTopRegionId(regionVO.getTopId());
eventRegionMap.setType(regionVO.getType()); eventRegionMap.setType(regionVO.getType());
eventRegionMap.setCreateTime(new Date());
dataList.add(eventRegionMap); dataList.add(eventRegionMap);
} }
eventRegionMapService.saveBatch(dataList); eventRegionMapService.saveBatch(dataList);
......
...@@ -137,7 +137,6 @@ public class EventManageController { ...@@ -137,7 +137,6 @@ public class EventManageController {
KeywordsVO keywordsVO = eventParam.getKeywordsVO(); KeywordsVO keywordsVO = eventParam.getKeywordsVO();
if (keywordsVO != null) { if (keywordsVO != null) {
UserVo currentUser = UserUtil.getLoginUser(); UserVo currentUser = UserUtil.getLoginUser();
eventParam.setCreateTime(new Date());
eventParam.setCreateBy(currentUser.getUsername()); eventParam.setCreateBy(currentUser.getUsername());
Event event = eventService.saveMain(eventParam); Event event = eventService.saveMain(eventParam);
//新增关键词 //新增关键词
......
...@@ -29,8 +29,10 @@ public class SubjectInfoSourceMap implements Serializable { ...@@ -29,8 +29,10 @@ public class SubjectInfoSourceMap implements Serializable {
private String id; private String id;
/**专题id*/ /**专题id*/
private String subjectId; private String subjectId;
/**信息源id或信息源组id*/ /**关联id*/
private String sourceId; private String sourceId;
/**标签值编码(专题绑定信息源标签时特有的字段)*/
private String sourceItemId;
/**种类(1:信息源id 2:信息源组id)*/ /**种类(1:信息源id 2:信息源组id)*/
private Integer type; private Integer type;
/**信息源组权重*/ /**信息源组权重*/
......
...@@ -28,6 +28,16 @@ public interface SubjectMapper extends BaseMapper<Subject> { ...@@ -28,6 +28,16 @@ public interface SubjectMapper extends BaseMapper<Subject> {
Page<SubjectPage> pageList(@Param("subjectCondition") SubjectCondition subjectCondition, Page<SubjectPage> page); Page<SubjectPage> pageList(@Param("subjectCondition") SubjectCondition subjectCondition, Page<SubjectPage> page);
/** /**
* 专题分页列表-研究中心
*
* @param subjectCondition 查询条件
* @param page 分页参数
* @author lkg
* @date 2024/12/18
*/
Page<SubjectPage> researchCenterPageList(@Param("subjectCondition") SubjectCondition subjectCondition, Page<SubjectPage> page);
/**
* 专题详情 * 专题详情
* *
* @param subjectId 专题id * @param subjectId 专题id
......
...@@ -23,10 +23,11 @@ public interface SubjectTypeMapper extends BaseMapper<SubjectType> { ...@@ -23,10 +23,11 @@ public interface SubjectTypeMapper extends BaseMapper<SubjectType> {
* 可用的专题分类列表 * 可用的专题分类列表
* *
* @param category 类别(1-专题;2-事件) * @param category 类别(1-专题;2-事件)
* @param createBy 创建人
* @author lkg * @author lkg
* @date 2024/4/29 * @date 2024/4/29
*/ */
List<Node> enableList(@Param("category") Integer category); List<Node> enableList(@Param("category") Integer category,@Param("username") String createBy);
/** /**
* 更新分类是否有子节点状态 * 更新分类是否有子节点状态
...@@ -39,12 +40,21 @@ public interface SubjectTypeMapper extends BaseMapper<SubjectType> { ...@@ -39,12 +40,21 @@ public interface SubjectTypeMapper extends BaseMapper<SubjectType> {
void updateTreeNodeStatus(@Param("id") String id, @Param("hasChild") String hasChild); void updateTreeNodeStatus(@Param("id") String id, @Param("hasChild") String hasChild);
/** /**
* 根据是否公开获取专题列表
*
* @param facePublic 是否公开(1-是;0-否)
* @author lkg
* @date 2025/1/7
*/
List<SubjectTreeVO> subjectsByFacePublic(@Param("facePublic") Integer facePublic);
/**
* 可用的事件和分类列表 * 可用的事件和分类列表
* *
* @author lkg * @author lkg
* @date 2024/4/29 * @date 2024/4/29
*/ */
List<SubjectTreeVO> subjectAndTypeTree(@Param("facePublic") Integer facePublic,@Param("username") String createBy); List<SubjectTreeVO> subjectAndTypeTree(@Param("username") String createBy);
/** /**
* 可用的事件和分类列表 * 可用的事件和分类列表
* *
......
...@@ -73,4 +73,38 @@ ...@@ -73,4 +73,38 @@
and n.subject_id = #{subjectId} and n.subject_id = #{subjectId}
and m.source_id = #{sourceId} and m.source_id = #{sourceId}
</select> </select>
<select id="researchCenterPageList" resultType="com.zzsn.event.vo.SubjectPage">
SELECT d.id,
d.subject_name,
d.remark,
d.create_time,
d.status c.type_name as subjectTypeName,
from subject d
LEFT JOIN subject_type_map b ON b.subject_id = d.id
LEFT JOIN subject_type c ON b.type_id = c.id
where 1 = 1
<if test="subjectCondition.typeIds!=null and subjectCondition.typeIds.size()>0">
and b.type_id in
<foreach collection="subjectCondition.typeIds" item="item" open="(" close=")" separator=",">
#{item}
</foreach>
</if>
<if test="subjectCondition.id !=null and subjectCondition.id !=''">
and d.id =#{subjectCondition.id}
</if>
<if test="subjectCondition.subjectName!=null and subjectCondition.subjectName != ''">
and d.subject_name like CONCAT('%',#{subjectCondition.subjectName},'%')
</if>
<if test="subjectCondition.startTime != null and subjectCondition.startTime != ''">
and d.create_time >= #{subjectCondition.startTime}
</if>
<if test="subjectCondition.endTime != null and subjectCondition.endTime != ''">
and d.create_time <![CDATA[ <= ]]> #{subjectCondition.endTime}
</if>
<if test="subjectCondition.status!=null">
and d.status = #{subjectCondition.status}
</if>
order by d.create_time desc
</select>
</mapper> </mapper>
...@@ -7,6 +7,9 @@ ...@@ -7,6 +7,9 @@
from subject_type s from subject_type s
where s.category = #{category} where s.category = #{category}
and s.status = 1 and s.status = 1
<if test="username!=null and username != ''">
and s.create_by = #{username}
</if>
</select> </select>
<update id="updateTreeNodeStatus" parameterType="java.lang.String"> <update id="updateTreeNodeStatus" parameterType="java.lang.String">
...@@ -15,6 +18,18 @@ ...@@ -15,6 +18,18 @@
where id = #{id} where id = #{id}
</update> </update>
<select id="subjectsByFacePublic" resultType="com.zzsn.event.vo.SubjectTreeVO">
select s.id,
s.subject_name as name,
'true' as ynSubject,
s.time_enable as start_time,
s.time_disable as end_time
from subject s
where s.face_public = #{facePublic}
order by create_time
</select>
<select id="subjectAndTypeTree" resultType="com.zzsn.event.vo.SubjectTreeVO"> <select id="subjectAndTypeTree" resultType="com.zzsn.event.vo.SubjectTreeVO">
select x.* select x.*
from ( from (
...@@ -52,9 +67,6 @@ ...@@ -52,9 +67,6 @@
s.create_time s.create_time
from subject s from subject s
where 1 = 1 where 1 = 1
<if test="facePublic!=null">
and s.face_public = #{facePublic}
</if>
<if test="username!=null and username != ''"> <if test="username!=null and username != ''">
and s.create_by = #{username} and s.create_by = #{username}
</if> </if>
......
...@@ -73,7 +73,6 @@ public class EventSimpleService { ...@@ -73,7 +73,6 @@ public class EventSimpleService {
event.setUnit("2"); event.setUnit("2");
event.setSpace(1); event.setSpace(1);
event.setCron(CronUtil.generateCron("2",1)); event.setCron(CronUtil.generateCron("2",1));
event.setCreateTime(new Date());
UserVo currentUser = UserUtil.getLoginUser(); UserVo currentUser = UserUtil.getLoginUser();
event.setCreateBy(currentUser.getUsername()); event.setCreateBy(currentUser.getUsername());
eventService.save(event); eventService.save(event);
...@@ -107,7 +106,6 @@ public class EventSimpleService { ...@@ -107,7 +106,6 @@ public class EventSimpleService {
//专题和分类关系 //专题和分类关系
SubjectTypeMap subjectTypeMap = new SubjectTypeMap(); SubjectTypeMap subjectTypeMap = new SubjectTypeMap();
subjectTypeMap.setSubjectId(eventId); subjectTypeMap.setSubjectId(eventId);
subjectTypeMap.setCreateTime(new Date());
//分类默认 研究中心 //分类默认 研究中心
subjectTypeMap.setTypeId("1802619433932296193"); subjectTypeMap.setTypeId("1802619433932296193");
subjectTypeMapService.save(subjectTypeMap); subjectTypeMapService.save(subjectTypeMap);
...@@ -130,7 +128,6 @@ public class EventSimpleService { ...@@ -130,7 +128,6 @@ public class EventSimpleService {
eventRegionMap.setRegionId(regionVO.getId()); eventRegionMap.setRegionId(regionVO.getId());
eventRegionMap.setTopRegionId(regionVO.getTopId()); eventRegionMap.setTopRegionId(regionVO.getTopId());
eventRegionMap.setType(regionVO.getType()); eventRegionMap.setType(regionVO.getType());
eventRegionMap.setCreateTime(new Date());
dataList.add(eventRegionMap); dataList.add(eventRegionMap);
} }
eventRegionMapService.saveBatch(dataList); eventRegionMapService.saveBatch(dataList);
......
...@@ -63,13 +63,31 @@ public interface ISubjectTypeService extends IService<SubjectType> { ...@@ -63,13 +63,31 @@ public interface ISubjectTypeService extends IService<SubjectType> {
void delete(String typeId); void delete(String typeId);
/** /**
* 专题和分类列表 * 根据是否公开获取专题列表-研究中心
*
* @param facePublic 是否公开(1-是;0-否)
* @author lkg
* @date 2025/1/7
*/
List<SubjectTreeVO> subjectsByFacePublic(Integer facePublic);
/**
* 专题和分类列表-研究中心
* *
* @param facePublic 是否公开(0-未公开;1-已公开)
* @author lkg * @author lkg
* @date 2024/12/26 * @date 2024/12/26
*/ */
List<SubjectTreeVO> subjectAndTypeTree(Integer facePublic); List<SubjectTreeVO> subjectAndTypeTree();
/**
* 获取分类下的所有节点id集合-研究中心
*
* @param typeId 分类id
* @param category 类别(1-专题;2-事件)
* @author lkg
* @date 2024/4/29
*/
List<String> researchCenterBelowIdList(String typeId,Integer category);
List<SubjectTypeVo> subjectListByType(String parentId); List<SubjectTypeVo> subjectListByType(String parentId);
......
...@@ -28,6 +28,17 @@ public interface SubjectService extends IService<Subject> { ...@@ -28,6 +28,17 @@ public interface SubjectService extends IService<Subject> {
Page<SubjectPage> pageList(SubjectCondition subjectCondition, Integer pageNo, Integer pageSize); Page<SubjectPage> pageList(SubjectCondition subjectCondition, Integer pageNo, Integer pageSize);
/** /**
* 分页列表-研究中心
*
* @param subjectCondition 查询条件
* @param pageNo 当前页
* @param pageSize 每页返回条数
* @author lkg
* @date 2024/12/18
*/
Page<SubjectPage> researchCenterPageList(SubjectCondition subjectCondition, Integer pageNo, Integer pageSize);
/**
* 新增专题 * 新增专题
* *
* @param subjectPage 参数 * @param subjectPage 参数
......
...@@ -40,7 +40,6 @@ public class EventAnalysisReportServiceImpl extends ServiceImpl<EventAnalysisRep ...@@ -40,7 +40,6 @@ public class EventAnalysisReportServiceImpl extends ServiceImpl<EventAnalysisRep
EventAnalysisReport report = new EventAnalysisReport(); EventAnalysisReport report = new EventAnalysisReport();
report.setEventId(eventId); report.setEventId(eventId);
report.setFilePath(filePath); report.setFilePath(filePath);
report.setCreateTime(new Date());
InputStream inputStream = obsUtil.getObjectStream(filePath); InputStream inputStream = obsUtil.getObjectStream(filePath);
String content = DocUtil.convertDocStream2Html(inputStream); String content = DocUtil.convertDocStream2Html(inputStream);
report.setContent(content); report.setContent(content);
......
...@@ -420,7 +420,6 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements ...@@ -420,7 +420,6 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements
eventRegionMap.setRegionId(regionVO.getId()); eventRegionMap.setRegionId(regionVO.getId());
eventRegionMap.setTopRegionId(regionVO.getTopId()); eventRegionMap.setTopRegionId(regionVO.getTopId());
eventRegionMap.setType(regionVO.getType()); eventRegionMap.setType(regionVO.getType());
eventRegionMap.setCreateTime(new Date());
dataList.add(eventRegionMap); dataList.add(eventRegionMap);
} }
eventRegionMapService.saveBatch(dataList); eventRegionMapService.saveBatch(dataList);
...@@ -431,8 +430,6 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements ...@@ -431,8 +430,6 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements
if (StringUtils.isNotEmpty(addEventParam.getSubjectTypeId())) { if (StringUtils.isNotEmpty(addEventParam.getSubjectTypeId())) {
SubjectTypeMap subjectTypeMap = new SubjectTypeMap(); SubjectTypeMap subjectTypeMap = new SubjectTypeMap();
subjectTypeMap.setSubjectId(subject.getId()); subjectTypeMap.setSubjectId(subject.getId());
subjectTypeMap.setCreateBy(subject.getCreateBy());
subjectTypeMap.setCreateTime(subject.getCreateTime());
subjectTypeMap.setUpdateBy(subject.getUpdateBy()); subjectTypeMap.setUpdateBy(subject.getUpdateBy());
subjectTypeMap.setUpdateTime(subject.getUpdateTime()); subjectTypeMap.setUpdateTime(subject.getUpdateTime());
subjectTypeMap.setTypeId(addEventParam.getSubjectTypeId()); subjectTypeMap.setTypeId(addEventParam.getSubjectTypeId());
......
...@@ -336,8 +336,6 @@ public class InformationServiceImpl implements InformationService { ...@@ -336,8 +336,6 @@ public class InformationServiceImpl implements InformationService {
attachmentInfo.setItemId(specialInformation.getId()); attachmentInfo.setItemId(specialInformation.getId());
attachmentInfo.setStatus(1); attachmentInfo.setStatus(1);
attachmentInfo.setOrderBy(0); attachmentInfo.setOrderBy(0);
attachmentInfo.setCreateBy(operateUser);
attachmentInfo.setCreateTime(new Date());
attachmentInfo.setSource(""); attachmentInfo.setSource("");
attachmentInfo.setYear(cn.hutool.core.date.DateUtil.thisYear()); attachmentInfo.setYear(cn.hutool.core.date.DateUtil.thisYear());
clbSysAttachmentService.save(attachmentInfo); clbSysAttachmentService.save(attachmentInfo);
...@@ -563,7 +561,6 @@ public class InformationServiceImpl implements InformationService { ...@@ -563,7 +561,6 @@ public class InformationServiceImpl implements InformationService {
String type = collectionInfo.getType(); String type = collectionInfo.getType();
if ("1".equals(type)) { if ("1".equals(type)) {
collectionMap.setEsIndex(collectionInfo.getIndex()); collectionMap.setEsIndex(collectionInfo.getIndex());
collectionMap.setCreateTime(new Date());
collectionMapService.save(collectionMap); collectionMapService.save(collectionMap);
} else { } else {
QueryWrapper<CollectionMap> query = Wrappers.query(); QueryWrapper<CollectionMap> query = Wrappers.query();
......
...@@ -217,7 +217,6 @@ public class KeyWordsServiceImpl extends ServiceImpl<KeyWordsMapper, KeyWords> i ...@@ -217,7 +217,6 @@ public class KeyWordsServiceImpl extends ServiceImpl<KeyWordsMapper, KeyWords> i
keyWords.setKeyWord(keyword); keyWords.setKeyWord(keyword);
keyWords.setExclusionWord(exclusionWord); keyWords.setExclusionWord(exclusionWord);
keyWords.setStatus("1"); keyWords.setStatus("1");
keyWords.setCreateTime(new Date());
this.save(keyWords); this.save(keyWords);
String keyWordsId = keyWords.getId(); String keyWordsId = keyWords.getId();
//关键词和分类关系 //关键词和分类关系
...@@ -225,7 +224,6 @@ public class KeyWordsServiceImpl extends ServiceImpl<KeyWordsMapper, KeyWords> i ...@@ -225,7 +224,6 @@ public class KeyWordsServiceImpl extends ServiceImpl<KeyWordsMapper, KeyWords> i
keywordsTypeMap.setKeywordsId(keyWordsId); keywordsTypeMap.setKeywordsId(keyWordsId);
//分类默认 事件专题 //分类默认 事件专题
keywordsTypeMap.setTypeId("1802634369064525826"); keywordsTypeMap.setTypeId("1802634369064525826");
keywordsTypeMap.setCreateTime(new Date());
keywordsTypeMapService.save(keywordsTypeMap); keywordsTypeMapService.save(keywordsTypeMap);
//专题和关键词关系 //专题和关键词关系
SubjectKeywordsMap subjectKeywordsMap = new SubjectKeywordsMap(); SubjectKeywordsMap subjectKeywordsMap = new SubjectKeywordsMap();
...@@ -267,8 +265,6 @@ public class KeyWordsServiceImpl extends ServiceImpl<KeyWordsMapper, KeyWords> i ...@@ -267,8 +265,6 @@ public class KeyWordsServiceImpl extends ServiceImpl<KeyWordsMapper, KeyWords> i
KeywordsTypeMap keywordsTypeMap = new KeywordsTypeMap(); KeywordsTypeMap keywordsTypeMap = new KeywordsTypeMap();
keywordsTypeMap.setKeywordsId(keyWords.getId()); keywordsTypeMap.setKeywordsId(keyWords.getId());
keywordsTypeMap.setTypeId(keyWordsTypeId); keywordsTypeMap.setTypeId(keyWordsTypeId);
keywordsTypeMap.setCreateBy(keyWords.getCreateBy());
keywordsTypeMap.setCreateTime(keyWords.getCreateTime());
keywordsTypeMap.setUpdateBy(keyWords.getUpdateBy()); keywordsTypeMap.setUpdateBy(keyWords.getUpdateBy());
keywordsTypeMap.setUpdateTime(keyWords.getUpdateTime()); keywordsTypeMap.setUpdateTime(keyWords.getUpdateTime());
keywordsTypeMap.setSysOrgCode(keyWords.getSysOrgCode()); keywordsTypeMap.setSysOrgCode(keyWords.getSysOrgCode());
......
...@@ -140,6 +140,19 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl ...@@ -140,6 +140,19 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
} }
@Override @Override
public Page<SubjectPage> researchCenterPageList(SubjectCondition subjectCondition, Integer pageNo, Integer pageSize) {
//查询类别id的所有明细id
List<String> typeIds = new ArrayList<>();
String subjectTypeId = subjectCondition.getSubjectTypeId();
if (StringUtils.isNotEmpty(subjectTypeId) && !"0".equals(subjectTypeId)) {
typeIds = subjectTypeService.researchCenterBelowIdList(subjectTypeId, 1);
}
subjectCondition.setTypeIds(typeIds);
Page<SubjectPage> page = new Page<>(pageNo, pageSize);
return baseMapper.researchCenterPageList(subjectCondition, page);
}
@Override
@Transactional @Transactional
public Subject saveMain(SubjectPage subjectPage) { public Subject saveMain(SubjectPage subjectPage) {
Subject subject = new Subject(); Subject subject = new Subject();
...@@ -157,7 +170,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl ...@@ -157,7 +170,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
baseMapper.insert(subject); baseMapper.insert(subject);
//插入专题-类别、项目的绑定关系 //插入专题-类别、项目的绑定关系
saveMapMain(subject, subjectPage); saveMapMain(subject, subjectPage);
return null; return subject;
} }
@Override @Override
...@@ -604,10 +617,6 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl ...@@ -604,10 +617,6 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
if (StringUtils.isNotEmpty(subjectPage.getSubjectTypeId())) { if (StringUtils.isNotEmpty(subjectPage.getSubjectTypeId())) {
SubjectTypeMap subjectTypeMap = new SubjectTypeMap(); SubjectTypeMap subjectTypeMap = new SubjectTypeMap();
subjectTypeMap.setSubjectId(subject.getId()); subjectTypeMap.setSubjectId(subject.getId());
subjectTypeMap.setCreateBy(subject.getCreateBy());
subjectTypeMap.setCreateTime(subject.getCreateTime());
subjectTypeMap.setUpdateBy(subject.getUpdateBy());
subjectTypeMap.setUpdateTime(subject.getUpdateTime());
subjectTypeMap.setSysOrgCode(subject.getSysOrgCode()); subjectTypeMap.setSysOrgCode(subject.getSysOrgCode());
subjectTypeMap.setTypeId(subjectPage.getSubjectTypeId()); subjectTypeMap.setTypeId(subjectPage.getSubjectTypeId());
subjectTypeMapService.save(subjectTypeMap); subjectTypeMapService.save(subjectTypeMap);
......
...@@ -34,7 +34,7 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje ...@@ -34,7 +34,7 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje
@Override @Override
public List<Node> enableList(Integer category) { public List<Node> enableList(Integer category) {
return baseMapper.enableList(category); return baseMapper.enableList(category,null);
} }
@Override @Override
...@@ -55,7 +55,6 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje ...@@ -55,7 +55,6 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje
baseMapper.updateById(parent); baseMapper.updateById(parent);
} }
} }
subjectType.setCreateTime(new Date());
baseMapper.insert(subjectType); baseMapper.insert(subjectType);
} }
...@@ -91,28 +90,34 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje ...@@ -91,28 +90,34 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje
} }
@Override @Override
public List<SubjectTreeVO> subjectAndTypeTree(Integer facePublic) { public List<SubjectTreeVO> subjectsByFacePublic(Integer facePublic) {
String username = null; return baseMapper.subjectsByFacePublic(facePublic);
if (facePublic == null) {
username = AuthUtil.getLoginUser().getUsername();
} }
@Override
public List<SubjectTreeVO> subjectAndTypeTree() {
String username = AuthUtil.getLoginUser().getUsername();
List<SubjectTreeVO> tree = new ArrayList<>(); List<SubjectTreeVO> tree = new ArrayList<>();
List<SubjectTreeVO> subjectTreeVOS = baseMapper.subjectAndTypeTree(facePublic,username); List<SubjectTreeVO> subjectTreeVOS = baseMapper.subjectAndTypeTree(username);
if (CollectionUtils.isNotEmpty(subjectTreeVOS)) { if (CollectionUtils.isNotEmpty(subjectTreeVOS)) {
tree = TreeUtil.tree(subjectTreeVOS, "0"); tree = TreeUtil.tree(subjectTreeVOS, "0");
tree.forEach(this::subjectNumCount);
tree.sort(Comparator.comparing(SubjectTreeVO::getCreateTime));
} }
return tree; return tree;
} }
@Override
public List<String> researchCenterBelowIdList(String typeId, Integer category) {
String username = AuthUtil.getLoginUser().getUsername();
List<Node> nodes = baseMapper.enableList(category,username);
return TreeUtil.belowList(nodes, typeId, true);
}
@Override @Override
public List<SubjectTreeVO> eventAndTypeTree() { public List<SubjectTreeVO> eventAndTypeTree() {
List<SubjectTreeVO> tree = new ArrayList<>(); List<SubjectTreeVO> tree = new ArrayList<>();
List<SubjectTreeVO> subjectTreeVOS = baseMapper.eventAndTypeTree(); List<SubjectTreeVO> subjectTreeVOS = baseMapper.eventAndTypeTree();
if (CollectionUtils.isNotEmpty(subjectTreeVOS)) { if (CollectionUtils.isNotEmpty(subjectTreeVOS)) {
tree = TreeUtil.tree(subjectTreeVOS, "0"); tree = TreeUtil.tree(subjectTreeVOS, "0");
tree.forEach(this::subjectNumCount);
tree.sort(Comparator.comparing(SubjectTreeVO::getCreateTime));
} }
return tree; return tree;
} }
...@@ -265,22 +270,6 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje ...@@ -265,22 +270,6 @@ public class SubjectTypeServiceImpl extends ServiceImpl<SubjectTypeMapper, Subje
getFinalIdListInMap(nextGradeNotFinalList, pidMap, finalAllList); getFinalIdListInMap(nextGradeNotFinalList, pidMap, finalAllList);
} }
private void subjectNumCount(SubjectTreeVO subjectTreeVO) {
Boolean ynSubject = subjectTreeVO.getYnSubject();
if (!ynSubject) {
int num = 0;
List<? extends Node> children = subjectTreeVO.getChildren();
if (CollectionUtils.isNotEmpty(children)) {
for (Node node : children) {
SubjectTreeVO subjectTreeNode = (SubjectTreeVO)node;
subjectNumCount(subjectTreeNode);
num = num + 1;
}
subjectTreeVO.setSubjectCount(num);
}
}
}
private void updateOldParentNode(String pid) { private void updateOldParentNode(String pid) {
if (!"0".equals(pid)) { if (!"0".equals(pid)) {
Integer count = baseMapper.selectCount(new QueryWrapper<SubjectType>().eq("pid", pid)); Integer count = baseMapper.selectCount(new QueryWrapper<SubjectType>().eq("pid", pid));
......
package com.zzsn.event.util.user; package com.zzsn.event.util.user;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSON;
import lombok.Data; import lombok.Data;
import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.RequestContextHolder;
...@@ -17,14 +18,14 @@ import javax.servlet.http.HttpServletRequest; ...@@ -17,14 +18,14 @@ import javax.servlet.http.HttpServletRequest;
public class AuthUtil { public class AuthUtil {
public static UserVo getLoginUser() { public static UserVo getLoginUser() {
UserVo userVo = new UserVo();
try { try {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
String userInfo = request.getHeader("loginUser"); String userInfo = request.getHeader("loginUser");
return JSON.parseObject(userInfo, UserVo.class); userVo = JSON.parseObject(userInfo, UserVo.class);
}catch (Exception e){ }catch (Exception e){
return null; return userVo;
} }
return userVo;
} }
} }
...@@ -15,8 +15,6 @@ public class SubjectSourceTagVO { ...@@ -15,8 +15,6 @@ public class SubjectSourceTagVO {
/**专题id*/ /**专题id*/
private String subjectId; private String subjectId;
/**标签编码集合*/ /**标签集合*/
private List<String> labelCodes; private List<InfoSourceLabelVO> labelList;
/**标签值编码集合*/
private List<String> labelItemCodes;
} }
...@@ -17,8 +17,6 @@ public class SubjectTreeVO extends Node { ...@@ -17,8 +17,6 @@ public class SubjectTreeVO extends Node {
private Boolean ynSubject; private Boolean ynSubject;
private Integer subjectCount=0;
private String startTime; private String startTime;
private String endTime; private String endTime;
private String createTime; private String createTime;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论