linwe
2023-11-11 4cc3da53fca83e9212511c980acb6799ec346565
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.springblade.modules.task.service.impl;
 
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import org.apache.xmlbeans.impl.xb.xsdschema.Public;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.modules.task.entity.TaskEntity;
import org.springblade.modules.task.mapper.TaskMapper;
import org.springblade.modules.task.service.ITaskService;
import org.springblade.modules.task.vo.TaskVO;
import org.springframework.stereotype.Service;
 
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
 
/**
 * 任务表 服务实现类
 *
 * @author BladeX
 * @since 2023-11-06
 */
@Service
public class TaskServiceImpl extends BaseServiceImpl<TaskMapper, TaskEntity> implements ITaskService {
 
 
    @Override
    public IPage<TaskVO> selectTaskPage(IPage<TaskVO> page, TaskVO task) {
        task.setUserId(AuthUtil.getUserId());
        return page.setRecords(baseMapper.selectTaskPage(page, task));
    }
 
    /**
     * 新增任务
     *
     * @param type
     * @param name
     * @param frequency
     * @param remark
     * @param createUser
     * @return
     */
    @Override
    public Long saveTask(Integer type, String name, Integer frequency, String remark, Long createUser, String houseCode) {
        TaskEntity taskEntity = new TaskEntity();
        taskEntity.setType(type);
        taskEntity.setName(name);
        taskEntity.setFrequency(frequency);
        taskEntity.setRemark(remark);
        taskEntity.setCreateTime(new Date());
        taskEntity.setCreateUser(createUser);
        taskEntity.setHouseCode(houseCode);
        return baseMapper.insert(taskEntity) > 0 ? taskEntity.getId() : 0;
    }
 
    @Override
    public Long updateTask(Integer type, String name, Integer frequency, String remark, Long updateUser, Long id, Integer status) {
        TaskEntity taskEntity = new TaskEntity();
        taskEntity.setId(id);
        taskEntity.setType(type);
        taskEntity.setName(name);
        taskEntity.setFrequency(frequency);
        taskEntity.setRemark(remark);
        taskEntity.setUpdateTime(new Date());
        taskEntity.setUpdateUser(updateUser);
        taskEntity.setStatus(status);
        return baseMapper.updateById(taskEntity) > 0 ? 1L : 0;
    }
 
 
    @Override
    public Object countNumber(String houseCode, Integer status) {
        Map<String, Object> objectObjectHashMap = new HashMap<>();
        // 总数
        Long all = baseMapper.selectCount(Wrappers.<TaskEntity>lambdaQuery().eq(TaskEntity::getCreateUser, AuthUtil.getUserId() ));
        // 已处理
        Long processed = baseMapper.selectCount(Wrappers.<TaskEntity>lambdaQuery().eq(TaskEntity::getCreateUser, AuthUtil.getUserId())
            .eq(TaskEntity::getStatus, 2));
        objectObjectHashMap.put("all", all);
        objectObjectHashMap.put("processed", processed);
        return objectObjectHashMap;
    }
 
    @Override
    public Object countTypeNumber() {
        TaskVO taskVO = new TaskVO();
        Map<String, Object> objectObjectHashMap = new HashMap<>();
        taskVO.setUserId(AuthUtil.getUserId());
        taskVO.setType(1);
        taskVO.setStatus(1);
        Integer comprehensiveTask = baseMapper.selectTaskCount(taskVO);
        taskVO.setType(2);
        Integer residentialTask =  baseMapper.selectTaskCount(taskVO);
        taskVO.setType(3);
        Integer publicTask =  baseMapper.selectTaskCount(taskVO);
        objectObjectHashMap.put("comprehensiveTask", comprehensiveTask);
        objectObjectHashMap.put("residentialTask", residentialTask);
        objectObjectHashMap.put("publicTask", publicTask);
        return objectObjectHashMap;
    }
 
    @Override
    public Object countFrequencyNumber() {
        Map<String, Object> objectObjectHashMap = new HashMap<>();
        TaskVO taskVO = new TaskVO();
        taskVO.setUserId(AuthUtil.getUserId());
        taskVO.setFrequency(1);
        taskVO.setStatus(1);
        Integer disposable = baseMapper.selectTaskCount(taskVO);
        taskVO.setFrequency(2);
        Integer periodicity =  baseMapper.selectTaskCount(taskVO);
        objectObjectHashMap.put("disposable", disposable);
        objectObjectHashMap.put("periodicity", periodicity);
        return objectObjectHashMap;
    }
}