package com.yeshi.location.app.service.impl.sos;
|
|
import java.lang.Exception;
|
import javax.annotation.Resource;
|
|
import com.sun.org.apache.regexp.internal.RECompiler;
|
import com.yeshi.location.app.dao.sos.SOSTargetInfoDao;
|
import com.yeshi.location.app.entity.sos.SOSRecordList;
|
import com.yeshi.location.app.entity.sos.SOSTargetInfo;
|
import com.yeshi.location.app.service.inter.sos.SOSRecordListService;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
|
import org.yeshi.utils.TimeUtil;
|
import org.yeshi.utils.bean.BeanUtil;
|
|
import com.yeshi.location.app.dao.sos.SOSRecordDao;
|
import com.yeshi.location.app.entity.sos.SOSRecord;
|
import com.yeshi.location.app.service.inter.sos.SOSRecordService;
|
import com.yeshi.location.app.service.query.sos.SOSRecordQuery;
|
import com.yeshi.location.app.dao.sos.SOSRecordDao.DaoQuery;
|
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
|
@Service
|
public class SOSRecordServiceImpl implements SOSRecordService {
|
|
@Resource
|
private SOSRecordDao sOSRecordDao;
|
|
@Resource
|
private SOSTargetInfoDao sosTargetInfoDao;
|
|
@Resource
|
private SOSRecordListService sosRecordListService;
|
|
@Override
|
public List<SOSRecord> list(SOSRecordQuery sOSRecordQuery, int page, int pageSize) {
|
DaoQuery daoQuery = new DaoQuery();
|
try {
|
BeanUtil.copyProperties(sOSRecordQuery, daoQuery);
|
} catch (IllegalAccessException e) {
|
e.printStackTrace();
|
}
|
daoQuery.start = (page - 1) * pageSize;
|
daoQuery.count = pageSize;
|
daoQuery.sortList = Arrays.asList(new Sort.Order[]{Sort.Order.desc("createTime")});
|
return sOSRecordDao.list(daoQuery);
|
}
|
|
@Override
|
public long count(SOSRecordQuery sOSRecordQuery) {
|
DaoQuery daoQuery = new DaoQuery();
|
try {
|
BeanUtil.copyProperties(sOSRecordQuery, daoQuery);
|
} catch (IllegalAccessException e) {
|
e.printStackTrace();
|
}
|
return sOSRecordDao.count(daoQuery);
|
}
|
|
@Override
|
public SOSRecord get(String id) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("_id").is(id));
|
return sOSRecordDao.findOne(query);
|
}
|
|
@Override
|
public void add(SOSRecord sOSRecord) throws Exception {
|
|
if (sOSRecord.getId() == null) {
|
sOSRecord.setId(sOSRecord.getUid() + "-" + TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyyMMddHHmmssSSS"));
|
}
|
|
//查询主键ID是否存在
|
if (sOSRecordDao.get(sOSRecord.getId()) != null) {
|
throw new Exception("已存在");
|
}
|
|
if (sOSRecord.getCreateTime() == null) {
|
sOSRecord.setCreateTime(new Date());
|
}
|
|
|
//保存
|
sOSRecordDao.save(sOSRecord);
|
|
//添加到列表记录
|
SOSRecordList recordList = new SOSRecordList();
|
recordList.setSourceId(sOSRecord.getId());
|
recordList.setType(SOSRecordList.SOSRecordType.initiative);
|
recordList.setUid(sOSRecord.getUid());
|
sosRecordListService.add(recordList);
|
}
|
|
@Override
|
public void update(SOSRecord sOSRecord) {
|
if (sOSRecord.getUpdateTime() == null) {
|
sOSRecord.setUpdateTime(new Date());
|
}
|
//更新
|
sOSRecordDao.updateSelective(sOSRecord);
|
}
|
|
@Override
|
public void delete(List<String> idList) {
|
for (String id : idList) {
|
sOSRecordDao.delete(id);
|
}
|
}
|
|
@Override
|
public void deleteAll(Long uid) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("uid").is(uid));
|
sOSRecordDao.delete(query);
|
}
|
|
@Override
|
public List<SOSRecord> listByIds(List<String> ids) {
|
|
if (ids == null || ids.size() == 0) {
|
return new ArrayList<>();
|
}
|
List<Criteria> orList = new ArrayList<>();
|
for (String id : ids) {
|
orList.add(Criteria.where("_id").is(id));
|
}
|
Criteria[] ors = new Criteria[orList.size()];
|
orList.toArray(ors);
|
|
Query query = new Query();
|
query.addCriteria(new Criteria().orOperator(ors));
|
List<SOSRecord> list = sOSRecordDao.findList(query);
|
Comparator<SOSRecord> cm = (SOSRecord o1, SOSRecord o2) -> {
|
return ids.indexOf(o1.getId()) - ids.indexOf(o2.getId());
|
};
|
Collections.sort(list, cm);
|
return list;
|
}
|
|
@Override
|
public List<SOSRecord> listDetail(List<String> ids) {
|
List<SOSRecord> list = listByIds(ids);
|
List<SOSTargetInfo> targetList = sosTargetInfoDao.listBySOSIds(ids);
|
Map<String, List<SOSTargetInfo>> map = new HashMap<>();
|
for (SOSTargetInfo targetInfo : targetList) {
|
if (map.get(targetInfo.getSosId()) == null) {
|
map.put(targetInfo.getSosId(), new ArrayList<>());
|
}
|
map.get(targetInfo.getSosId()).add(targetInfo);
|
}
|
|
for (SOSRecord record : list) {
|
record.setTargetList(map.get(record.getId()));
|
}
|
|
return list;
|
}
|
|
|
}
|
