李林
2023-10-07 658d4927d468c47208fd012d9128b09249c07eff
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
package com.chinaztt.mes.production.controller;
 
import cn.hutool.core.thread.ThreadUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.chinaztt.mes.production.entity.Computation;
import com.chinaztt.mes.production.service.ComputationService;
import com.chinaztt.ztt.common.core.util.R;
import com.chinaztt.ztt.common.log.annotation.SysLog;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.*;
 
import java.util.List;
 
 
/**
 * 工时计算
 *
 * @author cxf
 * @date 2021-03-10 15:00:08
 */
@RestController
@AllArgsConstructor
@RequestMapping("/computation")
@Api(value = "computation", tags = "工时计算管理")
public class ComputationController {
 
    private final ComputationService computationService;
 
    /**
     * 根据班次记录计算对应的人工工资
     *
     * @param dutyRecordId
     * @return
     */
    @PostMapping("/computeByDutyRecordId/{dutyRecordId}")
    public R computeByDutyRecordId(@PathVariable("dutyRecordId") Long dutyRecordId) {
        computationService.computeByDutyRecordId(dutyRecordId);
        ThreadUtil.execute(() -> computationService.computeComingByDutyRecordId(dutyRecordId));
        return R.ok();
    }
 
 
    /**
     * 根据班次记录List计算对应的人工工资
     *
     * @param dutyRecordIdList
     * @return
     */
    @PostMapping("/computeByDutyRecordIdList")
    public R computeByDutyRecordIdList(@RequestBody List<Long> dutyRecordIdList) {
        computationService.checkDutyRecordSubmit(dutyRecordIdList);
        dutyRecordIdList.forEach(dutyRecordId->{
            computationService.computeByDutyRecordId(dutyRecordId);
            ThreadUtil.execute(() -> computationService.computeComingByDutyRecordId(dutyRecordId));
        });
        return R.ok();
    }
 
 
    /**
     * 分页查询
     *
     * @param page        分页对象
     * @param computation 工时计算
     * @return
     */
    @ApiOperation(value = "分页查询", notes = "分页查询")
    @GetMapping("/page")
    public R getProductionComputationPage(Page page, Computation computation) {
        return R.ok(computationService.page(page, Wrappers.query(computation)));
    }
 
 
    /**
     * 通过id查询工时计算
     *
     * @param id id
     * @return R
     */
    @ApiOperation(value = "通过id查询", notes = "通过id查询")
    @GetMapping("/{id}")
    public R getById(@PathVariable("id") Long id) {
        return R.ok(computationService.getById(id));
    }
 
    /**
     * 新增工时计算
     *
     * @param computation 工时计算
     * @return R
     */
    @ApiOperation(value = "新增工时计算", notes = "新增工时计算")
    @SysLog("新增工时计算")
    @PostMapping
    public R save(@RequestBody Computation computation) {
        return R.ok(computationService.save(computation));
    }
 
    /**
     * 修改工时计算
     *
     * @param computation 工时计算
     * @return R
     */
    @ApiOperation(value = "修改工时计算", notes = "修改工时计算")
    @SysLog("修改工时计算")
    @PutMapping
    public R updateById(@RequestBody Computation computation) {
        return R.ok(computationService.updateById(computation));
    }
 
    /**
     * 通过id删除工时计算
     *
     * @param id id
     * @return R
     */
    @ApiOperation(value = "通过id删除工时计算", notes = "通过id删除工时计算")
    @SysLog("通过id删除工时计算")
    @DeleteMapping("/{id}")
    public R removeById(@PathVariable Long id) {
        return R.ok(computationService.removeById(id));
    }
 
}