guoshilong
2023-05-29 08c7fcce9fa2a876412fa81a19550b77996214e2
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
package cn.gistack.sm.sjztmd.controller;
 
import cn.gistack.sm.sjztmd.entity.AttResManagePerson;
import cn.gistack.sm.sjztmd.service.IAttResManagePersonService;
import cn.gistack.system.user.entity.User;
import cn.gistack.system.user.feign.IUserClient;
import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import jodd.util.StringUtil;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.boot.ctrl.BladeController;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.*;
 
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
/**
 * @ClassName AttResManagePersonController
 * @Description TODO
 * @Author aix
 * @Date 2023/4/22 14:34
 * @Version 1.0
 */
@Slf4j
@Api(tags = "中台责任人水库列表")
@RestController
@RequestMapping("/sjztmd/attResManagePerson")
@AllArgsConstructor
public class AttResManagePersonController extends BladeController {
    private final IAttResManagePersonService attResManagePersonService;
 
    private final IUserClient userClient;
 
    @ApiOperation(value = "中台责任人水库列表-分页列表查询", notes = "中台责任人水库列表-分页列表查询")
    @GetMapping(value = "/list")
    public R queryPageList(AttResManagePerson attResManagePerson, Query query) {
        IPage<AttResManagePerson> pageList = attResManagePersonService.page(Condition.getPage(query), Condition.getQueryWrapper(attResManagePerson));
        return R.data(pageList);
    }
 
    @ApiOperation(value = "根据水库id获取中台责任人列表", notes = "根据水库id获取中台责任人列表")
    @GetMapping(value = "/findResManagePersonByResId")
    public R findResManagePersonByResId(AttResManagePerson attResManagePerson) {
 
        if (StringUtil.isEmpty(attResManagePerson.getResGuid()))
            return R.fail("resGuid不能为空");
 
        List<AttResManagePerson> list = attResManagePersonService.list(Condition.getQueryWrapper(attResManagePerson));
        return R.data(list);
 
    }
 
    @ApiOperation(value = "根据水库id获取中台责任人数据返回系统存在的用户列表", notes = "根据水库id获取中台责任人列表")
    @GetMapping(value = "/findResManagePersonByResIdReturnSys")
    public R findResManagePersonByResIdReturnSys(AttResManagePerson attResManagePerson) {
 
        if (StringUtil.isEmpty(attResManagePerson.getResGuid()))
            return R.fail("resGuid不能为空");
 
        List<AttResManagePerson> list = attResManagePersonService.list(Condition.getQueryWrapper(attResManagePerson));
        List<Object> resList = new ArrayList<>();
        for (AttResManagePerson person : list) {
            List<User> userList = userClient.userInfoByPhone("000000", person.getUserPhone()).getData();
            if (userList.size() > 0) {
                Map<Object, Object> map = new HashMap<>();
                map.put("value", userList.get(0).getId().toString());
                map.put("name", userList.get(0).getName());
                resList.add(map);
            }
        }
        return R.data(resList);
 
    }
 
    @ApiOperation(value = "根据水库id获取中台责任人列表", notes = "根据水库id获取中台责任人列表")
    @GetMapping(value = "/findResManagePersonByResIds")
    public R findResManagePersonByResId(String resIds) {
 
        if (StringUtil.isEmpty(resIds))
            return R.fail("resGuid不能为空");
 
        List<AttResManagePerson> list = attResManagePersonService.attResManagePersonListByResIds(resIds);
        return R.data(list);
 
    }
 
    @ApiOperation(value = "根据手机号码获取中台责任人水库id组合字符串", notes = "根据手机号码获取中台责任人水库id组合字符串")
    @GetMapping(value = "/queryListByPhone")
    public R queryListByPhone(AttResManagePerson attResManagePerson) {
        final List<AttResManagePerson> list = attResManagePersonService.list(Condition.getQueryWrapper(attResManagePerson));
        List<String> reslist = new ArrayList<>();
        list.forEach(item -> {
            reslist.add(item.getResGuid());
        });
        return R.data(StringUtil.join(reslist, ","));
    }
 
    @ApiOperation(value="责任人-添加/修改", notes="责任人-添加/修改")
    @PostMapping(value = "/editZrr")
    public R editZrr(@RequestBody AttResManagePerson attResManagePerson) {
        if (StringUtil.isEmpty(attResManagePerson.getResGuid()))
            return R.fail("resGuid不能为空");
        if (StringUtil.isEmpty(attResManagePerson.getType()))
            return R.fail("type不能为空");
        if (StringUtil.isEmpty(attResManagePerson.getSysResource()))
            return R.fail("sysResource不能为空");
        if (StringUtil.isEmpty(attResManagePerson.getUserPhone()))
            return R.fail("userPhone不能为空");
        if (StringUtil.isEmpty(attResManagePerson.getUserName()))
            return R.fail("userName不能为空");
        return R.data(attResManagePersonService.saveOrUpdateResManagePerson(attResManagePerson));
    }
 
    @ApiOperation(value="多个责任人-添加/修改", notes="多个责任人-添加/修改")
    @PostMapping(value = "/editListZrr")
    public R editListZrr(@RequestBody List<AttResManagePerson> attResManagePersons) {
        return attResManagePersonService.saveOrUpdateResManagePerson(attResManagePersons);
    }
 
}