|
|
@@ -17,20 +17,16 @@ import com.xunmei.common.core.domain.R;
|
|
|
import com.xunmei.common.core.domain.drill.domain.*;
|
|
|
import com.xunmei.common.core.domain.drill.dto.*;
|
|
|
import com.xunmei.common.core.domain.drill.vo.*;
|
|
|
-import com.xunmei.common.core.domain.edu.vo.CoreEduTrainingTaskPageVo;
|
|
|
import com.xunmei.common.core.domain.panel.dto.PanelListDto;
|
|
|
import com.xunmei.common.core.domain.panel.enums.PanelTypeEnums;
|
|
|
import com.xunmei.common.core.domain.panel.vo.PanelListVo;
|
|
|
import com.xunmei.common.core.domain.worktime.domain.SysWorkTime;
|
|
|
import com.xunmei.common.core.domain.worktime.dto.WorkTimeDto;
|
|
|
import com.xunmei.common.core.enums.CycleCommonEnum;
|
|
|
-import com.xunmei.common.core.enums.edu.EduTrainingPlanCycleEnum;
|
|
|
import com.xunmei.common.core.enums.ExportPdfType;
|
|
|
import com.xunmei.common.core.enums.OrgTypeEnum;
|
|
|
-import com.xunmei.common.core.enums.drill.DrillDoStatus;
|
|
|
-import com.xunmei.common.core.enums.drill.DrillPlanStatus;
|
|
|
-import com.xunmei.common.core.enums.drill.DrillRecStatus;
|
|
|
-import com.xunmei.common.core.enums.drill.DrillType;
|
|
|
+import com.xunmei.common.core.enums.drill.*;
|
|
|
+import com.xunmei.common.core.enums.edu.EduTrainingPlanCycleEnum;
|
|
|
import com.xunmei.common.core.exception.SystemException;
|
|
|
import com.xunmei.common.core.utils.DateUtils;
|
|
|
import com.xunmei.common.core.web.domain.AjaxResult;
|
|
|
@@ -46,7 +42,10 @@ import com.xunmei.core.drill.service.ICoreDrillTaskToRoleService;
|
|
|
import com.xunmei.core.drill.service.ICoreDrillTaskToUserService;
|
|
|
import com.xunmei.core.thread.ThreadPoolConfig;
|
|
|
import com.xunmei.system.api.*;
|
|
|
-import com.xunmei.system.api.domain.*;
|
|
|
+import com.xunmei.system.api.domain.SysConfig;
|
|
|
+import com.xunmei.system.api.domain.SysDictData;
|
|
|
+import com.xunmei.system.api.domain.SysOrg;
|
|
|
+import com.xunmei.system.api.domain.SysUser;
|
|
|
import com.xunmei.system.api.function.RemoteCallHandlerExecutor;
|
|
|
import io.netty.util.internal.StringUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@@ -272,28 +271,48 @@ public class CoreDrillTaskServiceImpl extends ServiceImpl<CoreDrillTaskMapper, C
|
|
|
@Override
|
|
|
public int updateCoreDrillTask(CoreDrillTaskEditDto request) {
|
|
|
CoreDrillTask coreDrillTask = coreDrillTaskMapper.selectById(request.getId());
|
|
|
+ boolean isAdd = false;
|
|
|
+ if (ObjectUtil.isNull(coreDrillTask)) {
|
|
|
+ isAdd = true;
|
|
|
+ SysOrg sysOrg = RemoteCallHandlerExecutor.executeRemoteCall(() ->
|
|
|
+ orgService.selectOrgById(SecurityUtils.getLoginUser().getSysUser().getOrgId(), SecurityConstants.INNER),
|
|
|
+ ErrorMsgConstants.QUERY_ORG_DATA_ERROR);
|
|
|
+ coreDrillTask = new CoreDrillTask();
|
|
|
+ coreDrillTask.setId(IdWorker.getId());
|
|
|
+ coreDrillTask.setOrgId(sysOrg.getId());
|
|
|
+ coreDrillTask.setOrgName(sysOrg.getShortName());
|
|
|
+ coreDrillTask.setOrgPath(sysOrg.getPath());
|
|
|
+ coreDrillTask.setTitle(request.getTitle());
|
|
|
+ coreDrillTask.setPlanCycle(DrillPlanCycleEnum.NONE.getCode());
|
|
|
+ coreDrillTask.setCreateBy(SecurityUtils.getUserId().toString());
|
|
|
+ coreDrillTask.setCreateTime(new Date());
|
|
|
+
|
|
|
+ }
|
|
|
taskToUserMapper.deleteByMap(MapUtil.of("drill_task_id", request.getId()));
|
|
|
coreDrillTask.setType(request.getType());
|
|
|
- coreDrillTask.setDrillTime(request.getDrillTime());
|
|
|
+ coreDrillTask.setDrillStartTime(request.getDrillStartTime());
|
|
|
+ coreDrillTask.setDrillEndTime(request.getDrillEndTime());
|
|
|
coreDrillTask.setDrillSite(request.getDrillSite());
|
|
|
coreDrillTask.setPresetCase(request.getPresetCase());
|
|
|
coreDrillTask.setDrillSituation(request.getDrillSituation());
|
|
|
coreDrillTask.setRecorderId(SecurityUtils.getUserId());
|
|
|
coreDrillTask.setImageList(request.getImageList());
|
|
|
+ if (ObjectUtil.isNotEmpty(request.getFileList())) {
|
|
|
+ coreDrillTask.setFileList(JSON.toJSONString(request.getFileList()));
|
|
|
+ } else {
|
|
|
+ coreDrillTask.setFileList(null);
|
|
|
+ }
|
|
|
+ CoreDrillTask finalCoreDrillTask = coreDrillTask;
|
|
|
List<SysUser> userList = RemoteCallHandlerExecutor.executeRemoteCall(() ->
|
|
|
- roleService.selectUserByRoleNameAndOrgId("网点负责人", coreDrillTask.getOrgId(), SecurityConstants.INNER), ErrorMsgConstants.QUERY_USER_DATA_ERROR);
|
|
|
+ roleService.selectUserByRoleNameAndOrgId("网点负责人", finalCoreDrillTask.getOrgId(), SecurityConstants.INNER), ErrorMsgConstants.QUERY_USER_DATA_ERROR);
|
|
|
if (ObjectUtil.isNotEmpty(userList)) {
|
|
|
coreDrillTask.setHostId(userList.get(0).getId());
|
|
|
} else {
|
|
|
coreDrillTask.setHostId(SecurityUtils.getUserId());
|
|
|
}
|
|
|
List<CoreDrillTaskToUser> taskUserList = request.getTaskUserList();
|
|
|
- /*if (ObjectUtil.isNotEmpty(request.getTaskUserList())) {
|
|
|
- taskUserList = request.getTaskUserList();
|
|
|
- } else {
|
|
|
- taskUserList = Stream.of(request.getAbsenceList(), request.getAbsentList()).flatMap(Collection::stream).collect(Collectors.toList());
|
|
|
- }*/
|
|
|
if (ObjectUtil.isNotEmpty(taskUserList)) {
|
|
|
+ coreDrillTaskToUserService.removeByMap(MapUtil.of("drill_task_id", request.getId()));
|
|
|
checkTheSameUser(taskUserList);
|
|
|
for (CoreDrillTaskToUser taskToUser : taskUserList) {
|
|
|
taskToUser.setDrillTaskId(request.getId());
|
|
|
@@ -310,6 +329,9 @@ public class CoreDrillTaskServiceImpl extends ServiceImpl<CoreDrillTaskMapper, C
|
|
|
coreDrillTask.setUpdateBy(SecurityUtils.getLoginUser().getSysUser().getId().toString());
|
|
|
coreDrillTask.setUpdateTime(DateUtils.getNowDate());
|
|
|
|
|
|
+ if (isAdd) {
|
|
|
+ return coreDrillTaskMapper.insert(coreDrillTask);
|
|
|
+ }
|
|
|
return coreDrillTaskMapper.updateById(coreDrillTask);
|
|
|
}
|
|
|
|
|
|
@@ -421,7 +443,8 @@ public class CoreDrillTaskServiceImpl extends ServiceImpl<CoreDrillTaskMapper, C
|
|
|
trainingTask.setPresetCase(null);
|
|
|
trainingTask.setDrillSituation(null);
|
|
|
|
|
|
- trainingTask.setDrillTime(null);
|
|
|
+ trainingTask.setDrillStartTime(null);
|
|
|
+ trainingTask.setDrillEndTime(null);
|
|
|
trainingTask.setDrillSite(null);
|
|
|
trainingTask.setFileList(ObjectUtil.isEmpty(plan.getFileList()) ? null : JSON.toJSONString(plan.getFileList()));
|
|
|
trainingTask.setImageList(null);
|
|
|
@@ -596,7 +619,9 @@ public class CoreDrillTaskServiceImpl extends ServiceImpl<CoreDrillTaskMapper, C
|
|
|
String orgName = task.getOrgName();
|
|
|
String drillSite = task.getDrillSite();
|
|
|
String imageData = task.getImageList();
|
|
|
- String drillTime = DateUtil.format(task.getDrillTime(), "yyyy-MM-dd HH:mm:ss");
|
|
|
+ String startTime = DateUtil.format(task.getDrillStartTime(), "yyyy-MM-dd HH:mm");
|
|
|
+ String endTime = DateUtil.format(task.getDrillEndTime(), "yyyy-MM-dd HH:mm");
|
|
|
+ String drillTime = startTime + " - " + endTime;
|
|
|
String hostName = task.getHostName() == null ? StringUtil.EMPTY_STRING : task.getHostName();
|
|
|
String typeText = task.getTypeText() == null ? StringUtil.EMPTY_STRING : task.getTypeText();
|
|
|
String presetCase = task.getPresetCase() == null ? StringUtil.EMPTY_STRING : task.getPresetCase();
|