zhangjinli 3 years ago
parent 9f3c946233
commit 9fe18b5067

@ -26,11 +26,13 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.time.DayOfWeek;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.LocalTime; import java.time.LocalTime;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
import java.time.temporal.ChronoUnit; import java.time.temporal.ChronoUnit;
import java.time.temporal.TemporalAdjusters;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.stream.Stream; import java.util.stream.Stream;
@ -75,20 +77,20 @@ public class StatisticsController {
DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd"); DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd");
DateTimeFormatter df2 = DateTimeFormatter.ofPattern("yyyy-MM"); DateTimeFormatter df2 = DateTimeFormatter.ofPattern("yyyy-MM");
LocalDate now = LocalDateTime.now().toLocalDate(); LocalDate now = LocalDateTime.now().toLocalDate();
LocalDate before = now.minusMonths(1); LocalDate before =now.with(TemporalAdjusters.firstDayOfMonth());
if (null != param.getDateCondition()) { if (null != param.getDateCondition()) {
switch (param.getDateCondition()) { switch (param.getDateCondition()) {
case 1: case 1:
before = now; before = now;
break; break;
case 2: case 2:
before = now.minusWeeks(1); before = now.with(DayOfWeek.MONDAY);
break; break;
case 3: case 3:
before = now.minusMonths(1); before = now.with(TemporalAdjusters.firstDayOfMonth());
break; break;
case 4: case 4:
before = now.minusYears(1); before = now.with(TemporalAdjusters.firstDayOfYear());
break; break;
default: default:
} }
@ -158,20 +160,20 @@ public class StatisticsController {
QueryWrapper<UserEffectRecords> qw = new QueryWrapper<>(); QueryWrapper<UserEffectRecords> qw = new QueryWrapper<>();
DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd"); DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd");
LocalDateTime now = LocalDateTime.of(LocalDateTime.now().toLocalDate(), LocalTime.MIN); LocalDateTime now = LocalDateTime.of(LocalDateTime.now().toLocalDate(), LocalTime.MIN);
LocalDateTime before = now.minusMonths(1); LocalDateTime before = now.with(TemporalAdjusters.firstDayOfMonth());
if (param.getDateCondition() != null) { if (param.getDateCondition() != null) {
switch (param.getDateCondition()) { switch (param.getDateCondition()) {
case 1: case 1:
before = now; before = now;
break; break;
case 2: case 2:
before = now.minusWeeks(1); before = now.with(DayOfWeek.MONDAY);
break; break;
case 3: case 3:
before = now.minusMonths(1); before = now.with(TemporalAdjusters.firstDayOfMonth());
break; break;
case 4: case 4:
before = now.minusYears(1); before = now.with(TemporalAdjusters.firstDayOfYear());
break; break;
default: default:
} }

@ -348,7 +348,7 @@ public class TaskController {
taskBrandService.remove(new QueryWrapper<TaskBrand>().eq("taskId", id)); taskBrandService.remove(new QueryWrapper<TaskBrand>().eq("taskId", id));
} else { } else {
List<Map> brandListOri = taskBrandService.selByTaskId(id); List<Map> brandListOri = taskBrandService.selByTaskId(id);
taskBrandService.remove(new QueryWrapper<TaskBrand>().eq("taskId", id).notIn((brandIdList!=null&&brandIdList.size()!=0),"brandId", brandIdList)); taskBrandService.remove(new QueryWrapper<TaskBrand>().eq("taskId", id).notIn("brandId", brandIdList));
List brandIdListOri = new ArrayList(); List brandIdListOri = new ArrayList();
for (Map map : brandListOri) { for (Map map : brandListOri) {
brandIdListOri.add(map.get("id")); brandIdListOri.add(map.get("id"));
@ -361,28 +361,28 @@ public class TaskController {
} }
// 添加任务部门 // 添加任务部门
List dpIdList = new ArrayList();
List<Integer> departmentIdList = task.getDepartmentList(); List<Integer> departmentIdList = task.getDepartmentList();
List departmentGroupList = task.getDepartmentGroupList();
if (departmentIdList != null && departmentGroupList != null) {
List dpIdList = new ArrayList();
if (departmentIdList != null && departmentIdList.size() > 0) { if (departmentIdList != null && departmentIdList.size() > 0) {
for (Integer e : departmentIdList) { for (Integer e : departmentIdList) {
dpIdList.add(e); dpIdList.add(e);
} }
} }
List departmentGroupList = task.getDepartmentGroupList();
if (departmentGroupList != null && departmentGroupList.size() > 0) {
List<Integer> departmentIdList1 = qywxDepartmentGroupLinkService.departmentIdList(null, departmentGroupList); List<Integer> departmentIdList1 = qywxDepartmentGroupLinkService.departmentIdList(null, departmentGroupList);
if (departmentGroupList != null && departmentGroupList.size() > 0) {
if (departmentIdList != null && departmentIdList.size() > 0) { if (departmentIdList != null && departmentIdList.size() > 0) {
for (Integer e : departmentIdList1) { for (Integer e : departmentIdList1) {
dpIdList.add(e); dpIdList.add(e);
} }
} }
} }
if(dpIdList !=null){
if (dpIdList.size() == 0) { if (dpIdList.size() == 0) {
taskDepartmentService.remove(new QueryWrapper<TaskDepartment>().eq("taskId", id)); taskDepartmentService.remove(new QueryWrapper<TaskDepartment>().eq("taskId", id));
} else { } else {
List<TaskDepartment> departmentListOri = taskDepartmentService.list(new QueryWrapper<TaskDepartment>().eq("taskId", task.getId())); List<TaskDepartment> departmentListOri = taskDepartmentService.list(new QueryWrapper<TaskDepartment>().eq("taskId", task.getId()));
taskDepartmentService.remove(new QueryWrapper<TaskDepartment>().eq("taskId", id).notIn((dpIdList!=null&&dpIdList.size()!=0),"departmentId", departmentIdList)); taskDepartmentService.remove(new QueryWrapper<TaskDepartment>().eq("taskId", id).notIn("departmentId", departmentIdList));
List departmentIdListOri = new ArrayList(); List departmentIdListOri = new ArrayList();
for (TaskDepartment taskDepartment : departmentListOri) { for (TaskDepartment taskDepartment : departmentListOri) {
departmentIdListOri.add(taskDepartment.getDepartmentId()); departmentIdListOri.add(taskDepartment.getDepartmentId());
@ -393,8 +393,8 @@ public class TaskController {
} }
} }
} }
taskService.upReferenceInTask(task,task.getReferenceList(),task.getReferenceUrlList()); taskService.upReferenceInTask(task, task.getReferenceList(), task.getReferenceUrlList(), true);
taskService.upTeachRefeInTask(task,task.getTeachRefeList(),task.getTeachRefeUrlList()); taskService.upTeachRefeInTask(task, task.getTeachRefeList(), task.getTeachRefeUrlList(), true);
task.setUpdateAt(LocalDateTime.now()); task.setUpdateAt(LocalDateTime.now());
taskService.updateById(task); taskService.updateById(task);
return Result.success(null, "修改完成"); return Result.success(null, "修改完成");

@ -31,7 +31,7 @@ public interface ITaskService extends IService<Task> {
List<Map> taskDepartment(int taskId); List<Map> taskDepartment(int taskId);
// 上传任务时同时上传素材 // 上传任务时同时上传素材
Boolean upReferenceInTask(Task task, List<Integer> referenceList, List<FileUploadParamVo> referenceUrlList) ; Boolean upReferenceInTask(Task task, List<Integer> referenceList, List<FileUploadParamVo> referenceUrlList,Boolean isUpd) ;
// 上传任务的通用教程 // 上传任务的通用教程
Boolean upTeachRefeInTask(Task task,List<Integer> teachRefeList, List<FileUploadParamVo> teachRefeUrlList); Boolean upTeachRefeInTask(Task task,List<Integer> teachRefeList, List<FileUploadParamVo> teachRefeUrlList,Boolean isUpd) ;
} }

@ -2,13 +2,11 @@ package com.zh.project0512.serviceImpl;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.zh.project0512.mapper.ReferenceMapper; import com.zh.project0512.mapper.ReferenceMapper;
import com.zh.project0512.model.Reference; import com.zh.project0512.model.*;
import com.zh.project0512.model.Task;
import com.zh.project0512.mapper.TaskMapper; import com.zh.project0512.mapper.TaskMapper;
import com.zh.project0512.model.TaskTeachRefe;
import com.zh.project0512.model.TeachingRefe;
import com.zh.project0512.model.vo.FileUploadParamVo; import com.zh.project0512.model.vo.FileUploadParamVo;
import com.zh.project0512.service.*; import com.zh.project0512.service.*;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@ -18,10 +16,12 @@ import org.apache.poi.ss.formula.functions.T;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.sql.Ref;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors;
/** /**
* <p> * <p>
@ -73,7 +73,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements IT
} }
// 上传任务时同时上传素材 // 上传任务时同时上传素材
public Boolean upReferenceInTask(Task task, List<Integer> referenceList, List<FileUploadParamVo> referenceUrlList) { public Boolean upReferenceInTask(Task task, List<Integer> referenceList, List<FileUploadParamVo> referenceUrlList,Boolean isUpd) {
List<Integer> reference = new ArrayList<>(); List<Integer> reference = new ArrayList<>();
if (referenceList != null && referenceList.size() > 0) { if (referenceList != null && referenceList.size() > 0) {
for (Integer e : referenceList) { for (Integer e : referenceList) {
@ -102,13 +102,26 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements IT
} }
} }
if (reference.size() > 0) { if (reference.size() > 0) {
if(isUpd){
List<TaskReference> trListOri = taskReferenceService.list(new QueryWrapper<TaskReference>().eq("taskId", task.getId()));
taskReferenceService.remove(new QueryWrapper<TaskReference>().eq("taskId", task.getId()).notIn((reference != null && reference.size() != 0), "referenceId", reference));
List trIdListOri = new ArrayList();
for (TaskReference tr : trListOri) {
trIdListOri.add(tr.getReferenceId());
}
List collect = (List) reference.stream().filter(item -> !trIdListOri.contains(item)).collect(Collectors.toList());
if (collect != null && collect.size() != 0) {
taskReferenceService.addGroup(collect, task.getId());
}
}else{
taskReferenceService.addGroup(reference, task.getId()); taskReferenceService.addGroup(reference, task.getId());
} }
}
return true; return true;
} }
// 上传任务的通用教程 // 上传任务的通用教程
public Boolean upTeachRefeInTask(Task task,List<Integer> teachRefeList, List<FileUploadParamVo> teachRefeUrlList) { public Boolean upTeachRefeInTask(Task task, List<Integer> teachRefeList, List<FileUploadParamVo> teachRefeUrlList,Boolean isUpd) {
List<TaskTeachRefe> l2 = new ArrayList<>(); List<TaskTeachRefe> l2 = new ArrayList<>();
if (teachRefeList != null && teachRefeList.size() > 0) { if (teachRefeList != null && teachRefeList.size() > 0) {
List<TeachingRefe> teachingRefes = (List<TeachingRefe>) teachingRefeService.listByIds(teachRefeList); List<TeachingRefe> teachingRefes = (List<TeachingRefe>) teachingRefeService.listByIds(teachRefeList);
@ -117,15 +130,17 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements IT
.setFileUrl(e.getFileUrl()).setType(FileTypeUtil.getcontentTypeNum(e.getFileUrl().substring(e.getFileUrl().lastIndexOf(".")))))); .setFileUrl(e.getFileUrl()).setType(FileTypeUtil.getcontentTypeNum(e.getFileUrl().substring(e.getFileUrl().lastIndexOf("."))))));
} }
} }
for ( if (teachRefeUrlList != null && teachRefeUrlList.size() > 0) {
FileUploadParamVo e : teachRefeUrlList) { for (FileUploadParamVo e : teachRefeUrlList) {
String url = e.getUrl(); String url = e.getUrl();
if (url != null && url.lastIndexOf(".") != -1) { if (url != null && url.lastIndexOf(".") != -1) {
l2.add(new TaskTeachRefe().setTaskId(task.getId()).setCreatAt(LocalDateTime.now()).setDuration(e.getDuration()) l2.add(new TaskTeachRefe().setTaskId(task.getId()).setCreatAt(LocalDateTime.now()).setDuration(e.getDuration())
.setFileUrl(url).setType(FileTypeUtil.getcontentTypeNum(url.substring(url.lastIndexOf("."))))); .setFileUrl(url).setType(FileTypeUtil.getcontentTypeNum(url.substring(url.lastIndexOf(".")))));
} }
} }
}
if (l2.size() > 0) { if (l2.size() > 0) {
taskTeachRefeService.remove(new QueryWrapper<TaskTeachRefe>().eq("taskId", task.getId()));
taskTeachRefeService.saveBatch(l2); taskTeachRefeService.saveBatch(l2);
} }
return true; return true;

Loading…
Cancel
Save