package com.qxueyou.scc.portal.information.service.impl;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
//import com.qxueyou.appraisal.console.article.dto.ArticleDTO;
|
//import com.qxueyou.appraisal.console.article.dto.ArticleInfoDTO;
|
//import com.qxueyou.appraisal.console.article.service.IArticleService;
|
//import com.qxueyou.appraisal.console.article.vo.ListArticleVO;
|
//import com.qxueyou.appraisal.console.article.vo.SaveArticleVO;
|
//import com.qxueyou.appraisal.console.article.vo.UpdateArticleVO;
|
//import com.qxueyou.entity.article.ArticleDO;
|
//import com.qxueyou.model.Result;
|
import com.qxueyou.scc.base.model.Pager;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.impl.CommonAppService;
|
//import com.qxueyou.service.CommonMongoService;
|
//import com.qxueyou.util.TraceMongoUtils;
|
import com.qxueyou.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.portal.information.dto.ArticleInfoDTO;
|
import com.qxueyou.scc.portal.information.model.Information;
|
import com.qxueyou.scc.portal.information.service.IInformationService;
|
import com.qxueyou.scc.portal.information.vo.ListArticleVO;
|
import com.qxueyou.scc.portal.information.vo.SaveArticleVO;
|
import com.qxueyou.scc.portal.information.vo.UpdateArticleVO;
|
import com.qxueyou.scc.user.model.UserTeacher;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.data.domain.Sort;
|
//import org.springframework.data.mongodb.core.query.Criteria;
|
//import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.io.IOException;
|
import java.time.LocalDateTime;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author angy
|
* @created by 2021/3/1
|
*/
|
@Service
|
public class InformationService extends CommonAppService implements IInformationService {
|
|
private ObjectMapper objectMapper = new ObjectMapper();
|
|
/**
|
* 获取资讯总条数
|
*/
|
@Override
|
public int findInformationCount(String type,String title,String status) {
|
|
String hql = "from Information where type like :type and title like :title and status like :status and deleteFlag=0";
|
return findCountByComplexHql(hql, CollectionUtils.newObjectMap("type", type + "%","title", title + "%","status",status+"%"));
|
}
|
|
@Override
|
public Result listArticle(ListArticleVO vo) {
|
String type = StringUtils.isEmpty(vo.getType()) ? "" : vo.getType();
|
|
String title = StringUtils.isEmpty(vo.getKeyword()) ? "" : vo.getKeyword();
|
|
String hql = "from Information where deleteFlag=0 and type like ? and title like ? order by createTime desc";
|
List<Information> list = findList(hql, new Pager(vo.getSize(), vo.getPage()), CollectionUtils.newList(type.concat("%"), title.concat("%")), Information.class);
|
int count =findInformationCount(type,title,"");//资讯总条数
|
return new Result(true,"success", CollectionUtils.newObjectMap("list", list, "count", count));
|
}
|
|
@Override
|
public Result save(SaveArticleVO vo) {
|
Information articleDO = new Information();
|
BeanUtils.copyProperties(vo, articleDO);
|
articleDO.setBrowseCount(0);
|
articleDO.setDeleteFlag(0);
|
articleDO.setCreateTime(new Date());
|
articleDO.setUpdateTime(new Date());
|
articleDO.setStatus(Information.DRAFT_STATUS);
|
if (StringUtils.isNotBlank(vo.getAttachment())) {
|
// try {
|
//List<Map<String, String>> attachment = objectMapper.readValue(vo.getAttachment(), List.class);
|
articleDO.setAttachment(vo.getAttachment());
|
// } catch (IOException e) {
|
// log.error("文章附件json转换出错，json content : {}", vo.getAttachment());
|
// }
|
}
|
if (vo.getVideoUrl()!=null) {
|
// String videoUrl="";
|
// try {
|
// List<Map<String, String>> attachment = objectMapper.readValue(vo.getVideoUrl(), List.class);
|
// for (Map<String, String> map : attachment) {
|
// videoUrl=map.get("videoUrl");
|
// }
|
articleDO.setVideoUrl(vo.getVideoUrl());
|
// } catch (IOException e) {
|
// log.error("文章附件json转换出错，json content : {}", vo.getVideoUrl());
|
// }
|
}
|
// TraceMongoUtils.setCreateTrace(articleDO);
|
save(articleDO);
|
return Result.SUCCESS;
|
}
|
|
@Override
|
public Result delete(String id) {
|
Result result = new Result(true);
|
String[] arrStr = id.split(",");
|
if (arrStr != null && arrStr.length > 0) {
|
String hql = "update Information set deleteFlag = 1 where Id=?";
|
result = bulkUpdateInLoop(hql, arrStr);
|
}
|
// andIn(condition, "id", idLst);
|
//
|
// Update update = Update.update("deleteFlag", true);
|
// update.set("updateTime", LocalDateTime.now());
|
// template.updateMulti(Query.query(condition), update, ArticleDO.class);
|
//
|
return result;
|
//
|
}
|
|
@Override
|
public Result update(UpdateArticleVO vo) {
|
//
|
Information articleDO = read(Information.class, vo.getId());
|
//
|
if (StringUtils.equals(articleDO.getStatus(), Information.UP_STATUS)) {
|
return new Result(true, "不能对发布状态的文章进行修改！");
|
}
|
//
|
BeanUtils.copyProperties(vo, articleDO);
|
//
|
if (StringUtils.isNotBlank(vo.getAttachment())) {
|
// try {
|
// List<Map<String, String>> attachment = objectMapper.readValue(vo.getAttachment(), List.class);
|
articleDO.setAttachment(vo.getAttachment());
|
// } catch (IOException e) {
|
// log.error("文章附件json转换出错，json content : {}", vo.getAttachment());
|
// }
|
}
|
|
if (StringUtils.isNotBlank(vo.getVideoUrl())) {
|
String videoUrl="";
|
// try {
|
// List<Map<String, String>> attachment = objectMapper.readValue(vo.getVideoUrl(), List.class);
|
// for (Map<String, String> map : attachment) {
|
// videoUrl=map.get("videoUrl");
|
// }
|
articleDO.setVideoUrl(vo.getVideoUrl());
|
// } catch (IOException e) {
|
// log.error("文章附件json转换出错，json content : {}", vo.getVideoUrl());
|
// }
|
}
|
//
|
// TraceMongoUtils.setUpdateTrace(articleDO);
|
save(articleDO);
|
return Result.SUCCESS;
|
}
|
//
|
@Override
|
public Result getArticleById(String id) {
|
|
Information articleDO = read(Information.class, id);
|
ArticleInfoDTO articleInfoDTO = new ArticleInfoDTO();
|
BeanUtils.copyProperties(articleDO, articleInfoDTO);
|
return new Result(true, "articleInfoDTO",articleInfoDTO);
|
//
|
}
|
|
@Override
|
public Result upById(String id) {
|
Information articleDO = read(Information.class, id);
|
|
if (StringUtils.isNotBlank(articleDO.getTitle())) {
|
int count = findInformationCount("", articleDO.getTitle(),Information.UP_STATUS);
|
if (count > 0) {
|
return new Result(true, "该标题文章已发布，请勿发布相同的标题文章！");
|
}
|
}
|
articleDO.setStatus(Information.UP_STATUS);
|
// TraceMongoUtils.setUpdateTrace(articleDO);
|
save(articleDO);
|
return Result.SUCCESS;
|
}
|
//
|
@Override
|
public Result downById(String id) {
|
Result result = new Result(true);
|
// Criteria condition = condition();
|
String[] arrStr = id.split(",");
|
// List<String> idLst = Arrays.asList(arrStr);
|
// andIn(condition, "id", idLst);
|
// Update update = Update.update("status", Information.DOWN_STATUS);
|
// update.set("updateTime", LocalDateTime.now());
|
// template.updateMulti(Query.query(condition), update, ArticleDO.class);
|
String hql = "update Information set updateTime=now() ,status = 'down' where Id=?";
|
result = bulkUpdateInLoop(hql, arrStr);
|
return result;
|
}
|
}
|
