12 changed files with 1296 additions and 971 deletions
File diff suppressed because it is too large
@ -0,0 +1,407 @@ |
|||
import { computed, nextTick, watch } from 'vue'; |
|||
import { useStore } from 'vuex'; |
|||
import { flatten } from 'lodash'; |
|||
import dayjs from 'dayjs'; |
|||
|
|||
export default function useGetTasks() { |
|||
const store = useStore(); |
|||
const tasks = computed(() => store.state.task.tasks); |
|||
const timeLineType = computed(() => store.state.task.timeLineType); // 时间轴模式
|
|||
const realTasks = computed(() => store.state.task.realTasks); // 真实任务
|
|||
const downNextPage = computed(() => store.state.task.downNextPage); // 下一页
|
|||
const upNextPage = computed(() => store.state.task.upNextPage); // 下一页
|
|||
const currUpTimeNode = computed(() => store.state.task.currUpTimeNode); // 当前查询的时间
|
|||
const currDownTimeNode = computed(() => store.state.task.currDownTimeNode); // 当前查询的时间
|
|||
const roleId = computed(() => store.state.role.roleId); |
|||
const timeNode = computed(() => store.state.task.timeNode); |
|||
const timeUnit = computed(() => store.state.task.timeUnit); |
|||
const visibleRoles = computed(() => store.state.role.visibleRoles); |
|||
const allTasks = computed(() => store.state.task.allTasks); |
|||
const roleIndex = computed(() => store.state.role.roleIndex); |
|||
|
|||
const projectId = computed(() => store.getters['project/projectId']); |
|||
const timeGranularity = computed(() => store.getters['task/timeGranularity']); |
|||
|
|||
const remindData = computed(() => store.state.socket.remindData); // 小红点
|
|||
|
|||
const currRoleRealTasks = computed(() => store.state.task.currRoleRealTasks); // 当前角色的真实任务数据
|
|||
const currRoleShowTasks = computed(() => store.state.task.currRoleShowTasks); // 当前角色的展示任务数据
|
|||
const currLocationTaskId = computed(() => store.state.socket.currLocationTaskId); |
|||
|
|||
const businessCode = computed(() => store.state.task.businessCode); |
|||
|
|||
// 初始化 定期任务
|
|||
async function initPlanTasks() { |
|||
uni.$ui.showLoading(); |
|||
await getTasks({}); // 获取初始数据
|
|||
} |
|||
|
|||
/** |
|||
* 生成getTasks所用的参数 |
|||
* @param {object} query getTasks传递的参数 |
|||
*/ |
|||
function generateGetTaskParam(query) { |
|||
return { |
|||
roleId: roleId.value, |
|||
timeNode: query.timeNode || timeNode.value, |
|||
timeUnit: query.timeUnit || timeUnit.value, |
|||
queryType: query.queryType === 0 ? 0 : 1, |
|||
pageNum: query.pageNum || 1, |
|||
pageSize: query.pageSize || uni.$taskConfig.pageCount, |
|||
taskId: query.taskId || currLocationTaskId.value, |
|||
businessCode: query.businessCode || businessCode.value, |
|||
triggerType: query.triggerType || 1 |
|||
}; |
|||
} |
|||
|
|||
/** |
|||
* 根据时间基准点和角色查找定期任务 |
|||
* @param {object} query |
|||
* @param {string} query.roleId 角色id |
|||
* @param {string} query.timeNode 时间基准点 默认当前 |
|||
* @param {string} query.timeUnit 时间颗粒度 默认天 |
|||
* @param {string} query.queryNum 查找颗粒度数量 默认3个 |
|||
* @param {number} query.queryType 0向上查找 1向下查找(默认) 下查包含自己，上查不包含 |
|||
*/ |
|||
function getTasks(query) { |
|||
uni.$ui.showLoading(); |
|||
store.commit('task/setShowSkeleton', false); |
|||
|
|||
if (businessCode.value === 'ZERO' && currRoleRealTasks.value.length > 0) { |
|||
let needTask = query.queryType === 0 ? currRoleRealTasks.value[0] : currRoleRealTasks.value[currRoleRealTasks.value.length - 1]; |
|||
query.taskId = needTask.id; |
|||
query.timeNode = needTask.planStart; |
|||
query.businessCode = needTask.businessCode; |
|||
} |
|||
|
|||
const params = generateGetTaskParam(query); |
|||
uni.$catchReq.getTaskByNum(params, (err, data) => { |
|||
store.commit('task/setShowSkeleton', false); |
|||
if (err) { |
|||
// TODO: 提示错误
|
|||
console.error('err: ', err); |
|||
} else { |
|||
store.commit('task/setShowScrollTo', true); |
|||
params.queryType === 0 ? store.commit('task/setUpRealTasks', data.list) : store.commit('task/setDownRealTasks', data.list); |
|||
|
|||
const index = visibleRoles.value.findIndex(role => role.id === roleId.value); |
|||
const arr = [...allTasks.value]; |
|||
arr[index].realTasks = [...realTasks.value]; |
|||
arr[index].upNextPage = params.queryType === 0 ? data.nextPage : 1; |
|||
arr[index].downNextPage = params.queryType === 1 ? data.nextPage : 1; |
|||
store.commit('task/setAllTasks', arr); |
|||
store.commit('task/setCurrRoleRealTasks', arr[index].realTasks); // 设置当前角色的真实任务数据
|
|||
|
|||
if (businessCode.value === 'ZERO' && data.list.length < params.pageSize) { |
|||
params.queryType === 0 ? store.commit('task/setUpNextPage', 0) : store.commit('task/setDownNextPage', 0); // 下一页
|
|||
} else if (businessCode.value !== 'ZERO') { |
|||
params.queryType === 0 ? store.commit('task/setUpNextPage', arr[index].upNextPage) : store.commit('task/setDownNextPage', arr[index].downNextPage); // 下一页
|
|||
} |
|||
|
|||
// 数据处理
|
|||
dataRender(params); |
|||
} |
|||
}); |
|||
} |
|||
|
|||
function dataRender(params) { |
|||
timeLineType.value === 1 ? renderScaleTask(params) : renderConTask(params); |
|||
} |
|||
|
|||
// 刻度模式数据处理
|
|||
async function renderScaleTask(query) { |
|||
const params = generateGetTaskParam(query); |
|||
let centerData = await showTaskTime(params, currRoleShowTasks.value, currRoleRealTasks.value) || []; |
|||
await handleTasksData(params, centerData, currRoleRealTasks.value); |
|||
} |
|||
|
|||
// 已显示的任务第一个时间和最后一个时间
|
|||
async function showTaskTime(params, showTasks, realTasks) { |
|||
/** |
|||
* 1、判断显示任务中是否有真实任务 |
|||
* 1-1、有。根据id查找任务 |
|||
* 1-2、无。根据时间查找任务 |
|||
* 2、查找15个任务 |
|||
*/ |
|||
|
|||
// 初始值
|
|||
// 显示任务中没有真实任务数据
|
|||
let centerData = []; |
|||
if (realTasks.length > params.pageSize && params.queryType === 0) { |
|||
centerData = realTasks.slice(realTasks.length - params.pageSize); |
|||
} else { |
|||
centerData = realTasks.slice(0, params.pageSize); |
|||
} |
|||
|
|||
const firstDetailIndex = showTasks.findIndex(task => task.detailId); |
|||
if (firstDetailIndex > -1) { |
|||
// 显示任务中有真实任务数据
|
|||
const firstId = showTasks[firstDetailIndex].id; |
|||
let lastDetailIndex = -1; |
|||
showTasks.forEach((item, index) => { |
|||
if (item.detailId) { |
|||
lastDetailIndex = index; |
|||
} |
|||
}) |
|||
const lastId = showTasks[lastDetailIndex].id; |
|||
|
|||
realTasks.forEach((item, index) => { |
|||
if (params.queryType === 1 && item.id === lastId) { |
|||
centerData = realTasks.slice(index + 1, index + 1 + params.pageSize); |
|||
} else if (params.queryType === 0 && item.id === firstId) { |
|||
centerData = index >= params.pageSize ? realTasks.slice(index - params.pageSize, index) : realTasks.slice(0, index); |
|||
} |
|||
}) |
|||
} |
|||
|
|||
return centerData; |
|||
} |
|||
|
|||
async function handleTasksData(params, centerData, realTasks) { |
|||
let showTasks = currRoleShowTasks.value; // 显示的数据
|
|||
let firstTime = showTasks.length > 0 ? showTasks[0].planStart : new Date().getTime(); // 显示的数据第一个数据的时间
|
|||
let lastTime = showTasks.length > 0 ? dayjs(+showTasks[showTasks.length - 1].planStart).add(1, timeGranularity.value) : new Date().getTime(); // 显示的数据最后一个数据的时间
|
|||
let upTargetTime = dayjs(+firstTime).subtract(params.pageSize, timeGranularity.value); |
|||
let downTargetTime = dayjs(+lastTime).add(params.pageSize - 1, timeGranularity.value); |
|||
const nextPage = params.queryType === 0 ? upNextPage.value : downNextPage.value; // 下一页的值
|
|||
|
|||
// 双击小红点
|
|||
if (currLocationTaskId.value) { |
|||
lastTime = centerData.length ? centerData[0].planStart : new Date().getTime(); |
|||
} |
|||
|
|||
if (centerData.length) { |
|||
let arr = []; |
|||
|
|||
centerData.forEach(v => { |
|||
let centerTime = '', // 中间数据+/-15后的数据
|
|||
isExceed = false; // 时间跨度是否大于15
|
|||
|
|||
if (params.queryType) { |
|||
isExceed = dayjs(+downTargetTime).isAfter(+v.planStart, timeGranularity.value) |
|||
} else { |
|||
isExceed = dayjs(+upTargetTime).isBefore(+v.planStart, timeGranularity.value) |
|||
} |
|||
|
|||
if (isExceed) { |
|||
arr.push(v); |
|||
} |
|||
}) |
|||
|
|||
if (!arr.length) { |
|||
params.queryType === 0 ? setPrevPlaceholderTasks(params) : setNextPlaceholderTasks(params); |
|||
} else { |
|||
if (arr.length === centerData.length && centerData.length < params.pageSize && nextPage > 0) { |
|||
getTasks({pageNum: nextPage, queryType: params.queryType}); |
|||
} else { |
|||
let cycleIndex = params.pageSize; |
|||
let newArr = []; |
|||
let breakTime = ''; // 循环结束时间
|
|||
let continueTime = ''; // 第一个数据的时间
|
|||
// 循环开始时间
|
|||
let currTime = params.queryType === 0 ? upTargetTime : lastTime; |
|||
|
|||
// 符合条件的数据 < centerData的数据
|
|||
// 或者
|
|||
// centerData的数据全部符合条件，但是 < 15，而且没有下一页，不能向下查
|
|||
// 数据需要补齐15天的刻度
|
|||
// 所以循环长度为params.pageSize
|
|||
|
|||
// centerData的数据全部显示，且数量 = 15
|
|||
// 需要补齐数据中间的空刻度
|
|||
// 循环长度为 结束时间到开始时间的差
|
|||
// 当循环到的时间 = 数据最后一条的时间，则跳出循环
|
|||
if (arr.length === centerData.length && centerData.length === params.pageSize) { |
|||
if (params.queryType === 0) { |
|||
continueTime = arr[0].planStart; |
|||
} else { |
|||
breakTime = arr[arr.length - 1].planStart; |
|||
} |
|||
} |
|||
|
|||
// if (arr.length < centerData.length || (arr.length === centerData.length && centerData.length < params.pageSize && nextPage === 0)) {
|
|||
const startTime = params.queryType === 0 ? firstTime : dayjs(+lastTime).subtract(1, timeGranularity.value); |
|||
let firstArr = arr.filter(item => dayjs(+item.planStart).isSame(+startTime, timeGranularity.value)); |
|||
|
|||
if (firstArr.length && params.queryType === 1) { |
|||
newArr = [...newArr, ...firstArr]; |
|||
} |
|||
|
|||
// }
|
|||
|
|||
for (let i = 0; i < params.pageSize; i++) { |
|||
if (continueTime && dayjs(+currTime).isBefore(+continueTime, timeGranularity.value)) { |
|||
currTime = dayjs(+currTime).add(1, timeGranularity.value); |
|||
continue; |
|||
} else { |
|||
let termArr = arr.filter(item => dayjs(+item.planStart).isSame(+currTime, timeGranularity.value)); |
|||
if (termArr.length === 0) { |
|||
const newTasks = uni.$task.setPlaceholderTasks(+currTime, false, timeGranularity.value, 1); |
|||
newArr = [...newArr, ...newTasks]; |
|||
} else { |
|||
newArr = [...newArr, ...termArr]; |
|||
} |
|||
|
|||
if (breakTime && dayjs(+currTime).isSame(+breakTime, timeGranularity.value)) { |
|||
break; |
|||
} else { |
|||
currTime = dayjs(+currTime).add(1, timeGranularity.value); |
|||
} |
|||
} |
|||
} |
|||
|
|||
if (firstArr.length && params.queryType === 0) { |
|||
newArr = [...newArr, ...firstArr]; |
|||
} |
|||
|
|||
const repeatTime = params.queryType === 0 ? newArr[newArr.length - 1].planStart : newArr[0].planStart; |
|||
const repeatTimeArr = showTasks.filter(item => dayjs(+item.planStart).isSame(+repeatTime, timeGranularity.value)); |
|||
|
|||
if (repeatTimeArr.length) { |
|||
const index = repeatTimeArr.findIndex(item => item.detailId); |
|||
|
|||
if (index > -1) { |
|||
showTasks = params.queryType === 0 ? [...newArr, ...showTasks] : [...showTasks, ...newArr]; |
|||
} else { |
|||
showTasks = params.queryType === 0 ? showTasks.slice(1) : showTasks.slice(0, showTasks.length - 2); |
|||
showTasks = params.queryType === 0 ? [...newArr, ...showTasks] : [...showTasks, ...newArr]; |
|||
} |
|||
} else { |
|||
showTasks = params.queryType === 0 ? [...newArr, ...showTasks] : [...showTasks, ...newArr]; |
|||
} |
|||
} |
|||
|
|||
showTasks = flatten(showTasks); // 1维拍平
|
|||
|
|||
store.commit('task/clearTasks'); |
|||
params.queryType === 0 ? store.commit('task/setUpTasks', showTasks) : store.commit('task/setDownTasks', showTasks); |
|||
} |
|||
} else { |
|||
if (nextPage > 0) { |
|||
getTasks({pageNum: nextPage, queryType: params.queryType}); |
|||
} else { |
|||
params.queryType === 0 ? setPrevPlaceholderTasks(params) : setNextPlaceholderTasks(params); |
|||
} |
|||
} |
|||
|
|||
uni.$ui.hideLoading(); |
|||
// if (showTasks.length > 30) {
|
|||
// showTasks = params.queryType === 0 ? showTasks.slice(0, 80) : showTasks.slice(showTasks.length - 80);
|
|||
// }
|
|||
} |
|||
|
|||
// 任务模式
|
|||
async function renderConTask(params) { |
|||
let nextPage = params.queryType === 0 ? upNextPage.value : downNextPage.value; // 下一页的值
|
|||
let showTasks = currRoleShowTasks.value; |
|||
let centerData = await showTaskTime(params, showTasks, currRoleRealTasks.value) || []; |
|||
|
|||
if (centerData.length < 15 && nextPage > 0) { |
|||
getTasks({pageNum: nextPage, queryType: params.queryType}); |
|||
} else { |
|||
if (params.queryType === 0) { |
|||
showTasks = [...centerData, ...showTasks]; |
|||
} else { |
|||
showTasks = [...showTasks, ...centerData]; |
|||
} |
|||
} |
|||
|
|||
if (showTasks.length < 15 && nextPage === 0 && params.queryType === 1) { |
|||
getTasks({pageNum: 1, queryType: 0}); |
|||
} |
|||
|
|||
// if (showTasks.length > 80) {
|
|||
// showTasks = params.queryType === 0 ? showTasks.slice(0, 80) : showTasks.slice(showTasks.length - 80);
|
|||
// }
|
|||
|
|||
store.commit('task/clearTasks'); |
|||
params.queryType === 0 ? store.commit('task/setUpTasks', showTasks) : store.commit('task/setDownTasks', showTasks); |
|||
} |
|||
|
|||
// 设置时间轴向上的空数据
|
|||
function setPrevPlaceholderTasks() { |
|||
store.commit('task/setTopEnd', true); |
|||
let startTime = ''; |
|||
if (!currRoleShowTasks.value || !currRoleShowTasks.value.length) { |
|||
startTime = Date.now(); // 没有任务就应该是时间基准点
|
|||
} else { |
|||
startTime = currRoleShowTasks.value[0].planStart - 0; // 有任务就是第一个任务的计划开始时间
|
|||
} |
|||
const placeholderTasks = uni.$task.setPlaceholderTasks(startTime, true, timeGranularity.value); |
|||
store.commit('task/setCurrUpTimeNode', startTime); |
|||
store.commit('task/setUpTasks', placeholderTasks); |
|||
} |
|||
|
|||
// 设置时间轴向下的空数据
|
|||
function setNextPlaceholderTasks(params) { |
|||
// store.commit('task/setBottomEnd', true);
|
|||
let startTime = ''; |
|||
if (!currRoleShowTasks.value || !currRoleShowTasks.value.length) { |
|||
startTime = Date.now(); |
|||
} else { |
|||
startTime = dayjs(+currRoleShowTasks.value[currRoleShowTasks.value.length - 1].planStart).add(1, timeGranularity.value).valueOf(); |
|||
} |
|||
|
|||
// if (params.taskId) {
|
|||
// currRoleRealTasks.value.forEach(item => {
|
|||
// if (item.id === params.taskId) {
|
|||
// startTime = Number(item.planStart);
|
|||
// }
|
|||
// })
|
|||
// }
|
|||
|
|||
const initData = uni.$task.setPlaceholderTasks(startTime, false, timeGranularity.value); |
|||
store.commit('task/setCurrDownTimeNode', startTime); |
|||
store.commit('task/setDownTasks', initData); |
|||
} |
|||
|
|||
/** |
|||
* 当日常任务发生变化时 |
|||
* 将新获取到的日常任务放在allTasks里 |
|||
*/ |
|||
watch(tasks, () => { |
|||
// 添加到allTasks里
|
|||
const index = visibleRoles.value.findIndex(role => role.id === roleId.value); |
|||
const arr = [...allTasks.value]; |
|||
if (arr.length && index > -1) { |
|||
if (remindData.value) { |
|||
tasks.value.forEach(task => { |
|||
task.remindNum = 0; |
|||
task.msgId = ''; |
|||
|
|||
if (task.plugins && task.plugins.length) { |
|||
task.plugins.forEach(pluginArr => { |
|||
pluginArr.forEach(plugin => { |
|||
plugin.remindNum = 0; |
|||
remindData.value.forEach(remind => { |
|||
const remind_data = JSON.parse(remind.data); |
|||
|
|||
if (projectId.value === remind_data.data.projectId && roleId.value === remind_data.data.roleId) { |
|||
if (remind_data.data.taskId === task.id) { |
|||
task.remindNum++; |
|||
task.msgId = remind.id; |
|||
} |
|||
|
|||
if (remind_data.data.taskId === task.id && remind_data.data.pluginId === plugin.pluginTaskId) { |
|||
plugin.remindNum++; |
|||
} |
|||
} |
|||
}); |
|||
}); |
|||
}); |
|||
} |
|||
}) |
|||
} |
|||
|
|||
arr[index].task = [...tasks.value]; |
|||
store.commit('task/setCurrRoleShowTasks', arr[index].task); // 设置当前角色的展示任务数据
|
|||
} |
|||
store.commit('task/setAllTasks', arr); |
|||
}); |
|||
|
|||
return { |
|||
initPlanTasks, |
|||
getTasks, |
|||
dataRender |
|||
} |
|||
} |
|||
Loading…
Reference in new issue