package com.qxueyou.scc.school.service.impl;
|
|
import java.text.DateFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Locale;
|
import java.util.Map;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.springframework.stereotype.Service;
|
|
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.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
import com.qxueyou.scc.school.model.SchHandoutPage;
|
import com.qxueyou.scc.school.model.SchNote;
|
import com.qxueyou.scc.school.model.viewvo.SchNoteViewVO;
|
import com.qxueyou.scc.school.service.INoteService;
|
|
/**
|
* 笔记服务
|
* @author ody.yuan
|
*
|
*/
|
@Service
|
public class NoteService extends CommonAppService implements INoteService {
|
|
private final Logger log = LogManager.getLogger(NoteService.class);
|
|
/**
|
* 添加笔记
|
* @param note
|
* @return
|
*/
|
public Result insertOrUpdateNote(SchNote note) {
|
|
if(StringUtils.isNotBlank(note.getNoteId())){
|
SchNote note0 = read(SchNote.class, note.getNoteId());
|
TraceUtils.setUpdateTrace(note0);
|
note0.setContent(note.getContent());
|
note0.setNoteObjectId(note.getNoteObjectId());
|
note0.setShareFlag(note.getShareFlag());
|
if(note.getShareFlag()){
|
note0.setShareScope(SchNote.NOTE_SCOPE_CLASS);
|
}else{
|
note0.setShareScope(0);
|
}
|
save(note0);
|
}else{
|
TraceUtils.setCreateTrace(note);
|
note.setNoteTime(new Date(System.currentTimeMillis()));
|
note.setUserId(ClientUtils.getUserId());
|
note.setNoteObjectType(SchNote.NOTE_OBJECT_TYPE_HANDOUT_PAGE);
|
if(note.getShareFlag()){
|
note.setShareScope(SchNote.NOTE_SCOPE_CLASS);
|
}else{
|
note.setShareScope(0);
|
}
|
this.save(note);
|
}
|
|
return new Result(true);
|
}
|
|
/**
|
* 删除某页讲一下的一条或 多条 笔记
|
* @param noteIds
|
* @return
|
*/
|
public Result deleteNotes(String noteIds) {
|
|
if(StringUtils.isBlank(noteIds)){
|
return new Result(false,"参数不正确：noteIds为空");
|
}
|
|
Result result = bulkUpdateInLoop("update SchNote set deleteFlag = true where noteId = ?",noteIds.split(","));
|
|
return result;
|
}
|
|
/**
|
* 删除某页讲义下的所有笔记
|
* @param handoutPageId 讲义pageID
|
* @param strObjectType 笔记对象类型
|
* @return
|
*/
|
public Result deleteAllNotes(String handoutPageId,int iObjectType) {
|
|
if(StringUtils.isBlank(handoutPageId)){
|
return new Result(false,"参数不正确：handoutPageId为空");
|
}
|
|
Result result = bulkUpdateInLoop("update SchNote set deleteFlag = true where " +
|
" noteObjectType = " + iObjectType + " and noteObjectId = ?",new String[]{handoutPageId});
|
|
return result;
|
}
|
|
/**
|
* 笔记列表
|
* @param handoutPageId 讲义pageID
|
* @return
|
*/
|
public List<SchNoteViewVO> queryNoteList(String handoutPageId,Pager pager) {
|
|
String sql = "select n.note_id,n.content,n.share_flag ,n.share_scope,n.note_time,n.note_object_id, " +
|
" n.user_id,u.name as user_name ,u.IMG_PATH as user_img " +
|
" from sch_note n ,sch_handout_page p,user u " +
|
" where n.note_object_id = p.HANDOUT_PAGE_ID " +
|
" and u.USER_ID = n.user_id " +
|
" and n.delete_flag is false and p.delete_flag is FALSE and u.DELETE_FLAG is FALSE " +
|
" and ( n.share_flag is true or n.user_id = ? ) " +
|
" and n.note_object_id = ? " +
|
" order by note_time desc " ;
|
|
return this.queryNoteList(sql, CollectionUtils.newList(ClientUtils.getUserId() , handoutPageId), pager);
|
}
|
|
/**
|
* 讲义笔记列表
|
* @param handoutPageId
|
* @param type （我的讲义笔记：0,同学笔记 ：1,全部笔记：2）
|
* @return
|
*/
|
public List<SchNoteViewVO> queryHandoutNoteList(String handoutPageId,Integer type,Pager pager) {
|
List<Object> args = new ArrayList<Object>();
|
String sql = " from sch_note n ,sch_handout_page p,user u " +
|
" where n.note_object_id = p.HANDOUT_PAGE_ID " +
|
" and u.USER_ID = n.user_id " +
|
" and n.delete_flag is false and p.delete_flag is FALSE and u.DELETE_FLAG is FALSE ";
|
if(0==type){
|
sql = sql.concat(" and n.user_id = ? ");
|
args.add(ClientUtils.getUserId());
|
}
|
if(1==type){
|
sql = sql.concat(" and n.share_flag is true and n.user_id !=?");
|
args.add(ClientUtils.getUserId());
|
}
|
sql = sql.concat(" and n.note_object_id = ? order by note_time desc ");
|
args.add(handoutPageId);
|
|
return this.queryPageNoteList(sql, args, pager);
|
}
|
|
/**
|
* 查询笔记列表
|
* @param sql
|
* @param args
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
private List<SchNoteViewVO> queryPageNoteList(String sql , List<Object> args, Pager pager){
|
|
DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm",Locale.CHINA);
|
|
int allCount = this.findCountBySql(sql, args);
|
|
if(allCount < 1){
|
return new ArrayList<SchNoteViewVO>();
|
}
|
|
List<Object[]> lst = this.findByPageSql("select n.note_id,n.content,n.share_flag ,n.share_scope,n.note_time,n.note_object_id, " +
|
" n.user_id,u.name as user_name ,u.IMG_PATH as user_img " +sql, args, pager);
|
List<SchNoteViewVO> resultLst = new ArrayList<SchNoteViewVO>(lst.size());
|
SchNoteViewVO vo ;
|
|
for (Object[] obj : lst) {
|
vo = new SchNoteViewVO();
|
|
vo.setAllCount(allCount);
|
vo.setNoteId(String.valueOf(obj[0]));
|
vo.setContent(String.valueOf(obj[1]));
|
vo.setShareFlag(Boolean.parseBoolean(String.valueOf(obj[2])));
|
vo.setShareScope(null != obj[3] ? Integer.parseInt(String.valueOf(obj[3])) : 0);
|
|
try {
|
vo.setNoteTime(null != obj[4] ? format.parse(String.valueOf(obj[4])) : null);
|
} catch (ParseException e) {
|
log.error("获取笔记列表转换日期报错" , e);
|
}
|
vo.setNoteObjectId(String.valueOf(obj[5]));
|
vo.setUserId(String.valueOf(obj[6]));
|
vo.setUserName(String.valueOf(obj[7]));
|
vo.setUserImg(String.valueOf(obj[8]));
|
|
resultLst.add(vo);
|
}
|
|
return resultLst ;
|
}
|
|
/**
|
* 单个讲义全部笔记列表
|
* @param type （我的讲义笔记：0,同学笔记 ：1,全部笔记：2）
|
* @return
|
*/
|
public List<Map<String,Object>> queryAllHandoutNoteList(Integer type,String handoutId,Pager pager) {
|
|
Map<String,Object> args = new HashMap<String, Object>();
|
|
String hql = " from SchHandoutPage where handoutId = ? and deleteFlag is false";
|
List<SchHandoutPage> pages = find(hql, CollectionUtils.newList(handoutId), SchHandoutPage.class);
|
Map<String,Integer> pageOrderMap = new HashMap<String,Integer>();
|
List<String> pageIds = new ArrayList<String>();
|
for (SchHandoutPage schHandoutPage : pages) {
|
pageOrderMap.put(schHandoutPage.getHandoutPageId(), schHandoutPage.getPageOrder());
|
pageIds.add(schHandoutPage.getHandoutPageId());
|
}
|
|
if(pageIds.isEmpty()){
|
return new ArrayList<Map<String,Object>>();
|
}
|
|
//组装sql
|
String sql = generateSql(type, args, pageIds);
|
|
int allCount = findCountByComplexSql("select count(1) "+sql, args);
|
|
if(allCount < 1){
|
return new ArrayList<Map<String,Object>>();
|
}
|
List<Object[]> lst = findByComplexSql("select n.note_id,n.content,n.share_flag ,n.share_scope,n.note_time,n.note_object_id, " +
|
" n.user_id,u.name as user_name ,u.IMG_PATH as user_img " + sql, pager, args,Object[].class);
|
|
List<Map<String,Object>> resultLst = new ArrayList<Map<String,Object>>(lst.size());
|
Map<String,Object> map;
|
DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm",Locale.CHINA);
|
for (Object[] obj : lst) {
|
map = new HashMap<String, Object>();
|
map.put("allCount", allCount);
|
map.put("noteId", String.valueOf(obj[0]));
|
map.put("content", String.valueOf(obj[1]));
|
map.put("shareFlag", Boolean.parseBoolean(String.valueOf(obj[2])));
|
map.put("shareScope", null != obj[3] ? Integer.parseInt(String.valueOf(obj[3])) : 0);
|
try {
|
map.put("noteTime", null != obj[4] ? format.parse(String.valueOf(obj[4])) : null);
|
|
} catch (ParseException e) {
|
log.error("获取笔记列表转换日期报错" , e);
|
}
|
map.put("noteObjectId", String.valueOf(obj[5]));
|
map.put("userId", String.valueOf(obj[6]));
|
map.put("userName", String.valueOf(obj[7]));
|
map.put("userImg", String.valueOf(obj[8]));
|
map.put("pageOrder", pageOrderMap.get(String.valueOf(obj[5])));
|
resultLst.add(map);
|
}
|
|
|
return resultLst;
|
}
|
|
/**
|
* 组装sql
|
* @param type
|
* @param args
|
* @param pageIds
|
* @return
|
*/
|
private String generateSql(Integer type,Map<String,Object> args,List<String> pageIds){
|
|
String sql = " from sch_note n ,sch_handout_page p,user u " +
|
" where n.note_object_id = p.HANDOUT_PAGE_ID " +
|
" and u.USER_ID = n.user_id " +
|
" and n.delete_flag is false and p.delete_flag is FALSE and u.DELETE_FLAG is FALSE ";
|
if(0==type){
|
sql = sql.concat(" and n.user_id = :userId ");
|
args.put("userId", ClientUtils.getUserId());
|
}else if(1==type){
|
sql = sql.concat(" and n.share_flag is true ");
|
}
|
sql = sql.concat(" and n.note_object_id in (:handoutPageIds) order by p.page_order asc,n.note_time desc ");
|
args.put("handoutPageIds", pageIds.toArray());
|
return sql;
|
}
|
|
/**
|
* 查询笔记列表
|
* @param sql
|
* @param args
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
private List<SchNoteViewVO> queryNoteList(String sql , List<Object> args, Pager pager){
|
|
DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm",Locale.CHINA);
|
List<Object[]> lst = this.findByPageSql(sql, args, pager);
|
List<SchNoteViewVO> resultLst = new ArrayList<SchNoteViewVO>(lst.size());
|
SchNoteViewVO vo ;
|
|
for (Object[] obj : lst) {
|
vo = new SchNoteViewVO();
|
|
vo.setNoteId(String.valueOf(obj[0]));
|
vo.setContent(String.valueOf(obj[1]));
|
vo.setShareFlag(Boolean.parseBoolean(String.valueOf(obj[2])));
|
vo.setShareScope(null != obj[3] ? Integer.parseInt(String.valueOf(obj[3])) : 0);
|
|
try {
|
vo.setNoteTime(null != obj[4] ? format.parse(String.valueOf(obj[4])) : null);
|
} catch (ParseException e) {
|
log.error("获取笔记列表转换日期报错" , e);
|
}
|
vo.setNoteObjectId(String.valueOf(obj[5]));
|
vo.setUserId(String.valueOf(obj[6]));
|
vo.setUserName(String.valueOf(obj[7]));
|
vo.setUserImg(String.valueOf(obj[8]));
|
|
resultLst.add(vo);
|
}
|
|
return resultLst ;
|
}
|
|
}
|
