package com.cloud.control.service.impl;
|
|
import com.cloud.common.model.FileInfos;
|
import com.cloud.common.utils.PageUtil;
|
import com.cloud.control.dao.TaskUserMapper;
|
import com.cloud.control.dao.TaskUserPendMapper;
|
import com.cloud.control.model.TaskUserPend;
|
import com.cloud.control.service.TaskUserPendingService;
|
import com.cloud.control.utils.Base64Utils;
|
import com.cloud.model.common.Page;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
|
@Service
|
public class TaskUserPendingServiceImpl implements TaskUserPendingService {
|
|
@Autowired
|
private TaskUserPendMapper taskUserPendDao;
|
@Autowired
|
private TaskUserMapper taskUserDao;
|
|
@Override
|
public List<Map> select(Map<String, Object> params) {
|
return null;
|
}
|
|
@Override
|
public void deleteTaskUser(List<String> list) {
|
list.forEach(id-> {
|
taskUserPendDao.deleteById(id);
|
});
|
}
|
|
@Override
|
public TaskUserPend selectById(String id) {
|
TaskUserPend taskUserPend = taskUserPendDao.selectByPrimaryKey(id);
|
return taskUserPend;
|
}
|
|
/**
|
* 查找待布控人员
|
* @return
|
*/
|
@Override
|
public Page<TaskUserPend> findTaskPendingUsers(Map<String, Object> params) {
|
Page<TaskUserPend> page = new Page<>();
|
int total = taskUserPendDao.countTaskPendingUsers(params);
|
page.setTotal(total);
|
if(params.containsKey("start") && params.get("start")!=null && params.containsKey("length") && params.get("length")!=null)
|
PageUtil.pageParamConver(params, true);
|
if(params.containsKey("orderBy") && params.get("orderBy") !=null && params.containsKey("sortType") && params.get("sortType") !=null){
|
Object orderBy = params.get("orderBy");
|
Object sortType = params.get("sortType");
|
if(!orderBy.equals("createTime") && !orderBy.equals("dbInfos") && !orderBy.equals("updateBy")){//处理排序非法
|
params.remove("orderBy");
|
}else{
|
if(!sortType.equals("asc") && !sortType.equals("desc")){//处理排序非法
|
params.put("sortType","desc");
|
}
|
}
|
|
}
|
List<TaskUserPend> taskPendingUsers = taskUserPendDao.findTaskPendingUsers(params);
|
page.setData(taskPendingUsers);
|
return page;
|
}
|
|
@Override
|
public void save(TaskUserPend taskUserPend) {
|
taskUserPendDao.updateByPrimaryKeySelective(taskUserPend);
|
}
|
|
@Override
|
public void upload(List<FileInfos> fileInfos) {
|
|
for (FileInfos file : fileInfos){
|
TaskUserPend record = new TaskUserPend();
|
record.setId(UUID.randomUUID().toString());
|
record.setImgUrl(file.getPath());
|
record.setCreateTime(new Date());
|
record.setUpdateTime(new Date());
|
record.setDelFlag("0");
|
taskUserPendDao.insertSelective(record);
|
}
|
}
|
|
@Override
|
public void addFromRetrieve(Map jsonMap) {
|
TaskUserPend taskUserPend = new TaskUserPend();
|
taskUserPend.setImgUrl(jsonMap.get("imgUrl").toString());
|
if(jsonMap.get("idCard").toString()!="" && jsonMap.get("idCard").toString()!=null){
|
taskUserPend.setIdCard(jsonMap.get("idCard").toString());
|
}
|
if(jsonMap.get("dbInfos").toString()!=null && jsonMap.get("dbInfos").toString()!=""){
|
taskUserPend.setDbInfos(jsonMap.get("dbInfos").toString());
|
}
|
taskUserPend.setId(UUID.randomUUID().toString());
|
taskUserPend.setDelFlag("0");
|
taskUserPend.setCreateTime(new Date());
|
taskUserPend.setUpdateTime(new Date());
|
byte[] feature = Base64Utils.Base64Tobyte(taskUserPend.getFeatureBase64());
|
taskUserPend.setFeature(feature);
|
taskUserPendDao.insertSelective(taskUserPend);
|
}
|
|
@Override
|
public void joinControl(TaskUserPend taskUserPend) {
|
//先删除原有的用户布控任务关联
|
taskUserPendDao.deleteByUser(taskUserPend.getUserId());
|
List<String> taskIds = taskUserPend.getTaskIds();
|
//再进行新的关联
|
TaskUserPend taskUserPend1 = taskUserPendDao.selectByPrimaryKey(taskUserPend.getId());
|
taskIds.forEach(taskId->{
|
taskUserPend1.setId(UUID.randomUUID().toString());
|
taskUserPend1.setTaskId(taskId);
|
taskUserPend1.setCreateTime(new Date());
|
taskUserPend1.setIsControl("1");
|
taskUserPend1.setSource(0);
|
taskUserDao.insertFromPend(taskUserPend1);
|
});
|
}
|
}
|
