linzhijie
2021-03-11 93af1c6ffb9ae0e894689ad3a37b548e57d54cff
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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
package com.ots.project.exam.controller;
 
import com.ots.common.constant.UserConstants;
import com.ots.common.enums.SenderType;
import com.ots.common.enums.TestPackageStatusEnum;
import com.ots.common.enums.UserTypeEnum;
import com.ots.common.utils.MessageUtils;
import com.ots.common.utils.StringUtils;
import com.ots.common.utils.poi.ExcelUtil;
import com.ots.common.utils.security.ShiroUtils;
import com.ots.framework.aspectj.lang.annotation.Log;
import com.ots.framework.aspectj.lang.enums.BusinessType;
import com.ots.framework.config.VueConfig;
import com.ots.framework.web.controller.BaseController;
import com.ots.framework.web.domain.AjaxResult;
import com.ots.framework.web.page.TableDataInfo;
import com.ots.project.exam.domain.*;
import com.ots.project.exam.dto.SendTask;
import com.ots.project.exam.service.*;
import com.ots.project.system.user.domain.User;
import lombok.extern.slf4j.Slf4j;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.i18n.LocaleContextHolder;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
 
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
 
import static com.ots.common.enums.UserTypeEnum.SYS_USER;
 
/**
 * 批量导入测试人员名单Controller
 *
 * @author Shawn
 * @date 2019-11-22
 */
@Controller
@RequestMapping("/exam/testMember")
@Slf4j
public class EntTestMemberController extends BaseController {
    private String prefix = "exam/testMember";
 
    @Autowired
    private IEntTestMemberService entTestMemberService;
 
    @Autowired
    private IEntTestPackageService entTestPackageService;
 
    @Autowired
    private IEntTestSendtaskService iEntTestSendtaskService;
 
    @Autowired
    private ISysUserExtendService sysUserExtendService;
 
    @Autowired
    private ITExamPaperService itExamPaperService;
    @Autowired
    private VueConfig vueConfig;
 
    @RequiresPermissions("exam:testMember:view")
    @GetMapping()
    public String testMember(ModelMap mmap) {
        memberParam(null, mmap);
        return prefix + "/testMember";
    }
 
    @GetMapping("/memberQuery")
    public String testMemberQuery(String queryType, String queryValue, ModelMap mmap) {
        memberParam(null, mmap);
        if (Objects.nonNull(queryType)) {
            if (Objects.nonNull(queryValue)) {
                if (Objects.equals("2", queryType)) {//按姓名搜索测试用户
                    mmap.put("memberNameSend", queryValue);
                } else if (Objects.equals("3", queryType)) {//按邮箱搜索测试用户
                    mmap.put("memberEmailSend", queryValue);
                } else if (Objects.equals("4", queryType)) {//按手机号码搜索测试用户
                    mmap.put("memberPhoneSend", queryValue);
                } else if (Objects.equals("5", queryType)) {//按密码搜索测试用户
                    mmap.put("tokenSend", queryValue);
                }
            }
        }
        return prefix + "/testMemberQuery";
    }
 
 
    @GetMapping("/memberDetailVerify/{testId}")
    @ResponseBody
    public AjaxResult memberDetailVerify(@PathVariable Long testId) {
        EntTestPackage entTestPackage = entTestPackageService.selectEntTestPackageById(testId);
        TExamPaper tExamPaper = itExamPaperService.selectTExamPaperById(entTestPackage.getProdId());
        if (Objects.isNull(tExamPaper)) {
            // 无效的产品包,请重新选择测试包的产品包
            return AjaxResult.error(MessageUtils.message("jsp.exam.member.invalidProductPackage"));
        }
        return AjaxResult.success();
    }
 
    /**
     * 查询评测人员详情
     */
    @GetMapping("/memberDetail/{testId}")
    public String testMemberDetail(@PathVariable Long testId, ModelMap mmap) {
        memberParam(testId, mmap);
        return prefix + "/testMember";
    }
 
    public void memberParam(Long testId, ModelMap mmap) {
        User sysUser = ShiroUtils.getSysUser();
        Long userId = sysUser.getUserId();
        if (Objects.equals(sysUser.getUserType(), UserConstants.SYS_USER)) {
            userId = null;
        }
        EntTestPackage value = new EntTestPackage();
        if (Objects.nonNull(testId)) {
            value = entTestPackageService.selectEntTestPackageById(testId);
        }
        mmap.put("testpkg", value);
        mmap.put("packageTestId", testId);
        mmap.put("packageTestName", value.getTestName());
        String[] status = {TestPackageStatusEnum.enable.getCode(), TestPackageStatusEnum.pause.getCode(), TestPackageStatusEnum.ending.getCode(), TestPackageStatusEnum.invalid.getCode()};
        mmap.put("testPackages", entTestPackageService.selectEntTestPackageListByIdAndStatusIn(userId, Arrays.asList(status)));
    }
 
    /**
     * 查询批量导入测试人员名单列表
     */
    @RequiresPermissions("exam:testMember:list")
    @PostMapping("/list")
    @ResponseBody
    public TableDataInfo list(EntTestMember entTestMember) {
        startPage();
        String queryValue = entTestMember.getQueryValue();
        if (StringUtils.isNotBlank(queryValue)) {
            String queryType = entTestMember.getQueryType();
            if (Objects.equals("2", queryType)) {
                entTestMember.setMemberName(queryValue);
            } else if (Objects.equals("3", queryType)) {
                entTestMember.setMemberEmail(queryValue);
            } else if (Objects.equals("4", queryType)) {
                entTestMember.setMemberPhone(queryValue);
            } else if (Objects.equals("5", queryType)) {
                entTestMember.setToken(queryValue);
            }
        }
        List<EntTestMember> list = entTestMemberService.selectEntTestMemberList(entTestMember);
        return getDataTable(list);
    }
 
    @PostMapping("/listTopAnswering")
    @ResponseBody
    public TableDataInfo listTopAnswering(EntTestMember entTestMember) {
        startPage();
        User sysUser = ShiroUtils.getSysUser();
        if (!SYS_USER.getUserType().equals(sysUser.getUserType())) {
            entTestMember.setUserId(sysUser.getUserId());
        }
        return getDataTable(entTestMemberService.selectEntTestMemberTopList(entTestMember));
    }
 
    @PostMapping("/queryList")
    @ResponseBody
    public TableDataInfo queryList(EntTestMember entTestMember) {
        startPage();
 
        User sysUser = ShiroUtils.getSysUser();
        String userType = sysUser.getUserType();
 
        List<Long> userIds = new ArrayList<>();
        userIds.add(sysUser.getUserId());
        //分销商可以看到分销商下的企业信息
        if (UserTypeEnum.DIS_USER.getUserType().equals(userType)) {
            SysUserExtend sysUserExtend = new SysUserExtend();
            sysUserExtend.setParentUserId(sysUser.getUserId());
            List<SysUserExtend> sysUserExtends = sysUserExtendService.selectSysUserExtendList(sysUserExtend);
            for (int i = 0; i < sysUserExtends.size(); i++) {
                SysUserExtend extend = sysUserExtends.get(i);
                userIds.add(extend.getUserId());
            }
        }
 
        List<EntTestMember> list;
        if (!SYS_USER.getUserType().equals(userType)) {
            entTestMember.setUserList(userIds);
        }
        list = entTestMemberService.selectEntTestMemberQueryList(entTestMember);
        return getDataTable(list);
    }
 
    /**
     * 导出批量导入测试人员名单列表
     */
    @RequiresPermissions("exam:testMember:export")
    @PostMapping("/export")
    @ResponseBody
    public AjaxResult export(EntTestMember entTestMember) {
        List<EntTestMember> list = entTestMemberService.selectEntTestMemberList(entTestMember);
        ExcelUtil<EntTestMember> util = new ExcelUtil<EntTestMember>(EntTestMember.class);
        return util.exportExcel(list, "测试用户链接(Test Taker URLs)");
    }
 
    /**
     * 一键导出测试包里所有成员的测试连接
     */
    @RequiresPermissions("exam:testMember:export")
    @PostMapping("/exportLinkTest")
    @ResponseBody
    public AjaxResult exportLinkTest(EntTestMember entTestMember) {
        List<EntTestMember> list = entTestMemberService.selectEntTestMemberList(entTestMember);
        String url = vueConfig.getUrl();
        List<EntTestMemberOther> collect = list.stream().map(item -> {
            String token = item.getToken();
            String urlNew = MessageFormat.format(url, token);
            EntTestMemberOther entTestMemberOther = new EntTestMemberOther();
            entTestMemberOther.setMemberName(item.getMemberName());
            entTestMemberOther.setTestUrl(urlNew);
            return entTestMemberOther;
        }).collect(Collectors.toList());
        ExcelUtil<EntTestMemberOther> util = new ExcelUtil<>(EntTestMemberOther.class);
        return util.exportExcel(collect, "测试用户链接(Test Taker URLs)");
    }
 
    /**
     * 新增批量导入测试人员名单
     */
    @RequiresPermissions("exam:testMember:batchimport")
    @GetMapping("/add/{testId}")
    public String add(@PathVariable Long testId, ModelMap mmap) {
        EntTestPackage value = new EntTestPackage();
        if (Objects.nonNull(testId)) {
            value = entTestPackageService.selectEntTestPackageById(testId);
        }
        mmap.put("testpkg", value);
        return prefix + "/add";
    }
 
    /**
     * 新增保存批量导入测试人员名单
     */
    @RequiresPermissions("exam:testMember:add")
    @Log(title = "批量导入测试人员名单", businessType = BusinessType.INSERT)
    @PostMapping("/add")
    @ResponseBody
    public AjaxResult addSave(EntTestMember entTestMember) {
        return toAjax(entTestMemberService.insertEntTestMember(entTestMember));
    }
 
    /**
     * 新增邀请用户邮件发送列表
     */
    @RequiresPermissions("exam:testMember:add")
    @Log(title = "记录邀请用户发送列表", businessType = BusinessType.INSERT)
    @PostMapping("/addSendTask")
    @ResponseBody
    public AjaxResult addSaveEmail(SendTask sendTask) {
        return toAjax(iEntTestSendtaskService.insertEntTestSendtaskFromMemberIds(sendTask));
    }
 
    /**
     * 修改批量导入测试人员名单
     */
    @GetMapping("/edit/{memberId}")
    public String edit(@PathVariable("memberId") Long memberId, ModelMap mmap) {
        EntTestMember entTestMember = entTestMemberService.selectEntTestMemberById(memberId);
        mmap.put("entTestMember", entTestMember);
        return prefix + "/edit";
    }
 
    @GetMapping("/send/sendSms/{memberIds}/{testId}")
    public String sendSms(@PathVariable("memberIds") String memberIds, @PathVariable("testId") Long testId, ModelMap mmap) {
        StringBuilder builder = new StringBuilder();
        builder.append("亲爱的{FullName},").append("\n");
        builder.append("\n");
        builder.append("{Company} 邀请您完成一份测试,大概需要20-25分钟时间。您可以直接点击下面的链接开始该测试。如果不能直接访问,请复制地址到浏览器中直接打开。").append("\n");
        builder.append("\n");
        builder.append("链接地址是:{url}");
        builder.append("\n");
        builder.append("如有疑问,请与客服联系,邮箱是:support@tai-online.com。");
        builder.append("\n");
        builder.append("谢谢!").append("\n");
        builder.append("{Company}");
        String type = SenderType.sms.getType();
        processParams(memberIds, testId, mmap, builder.toString(), type);
        return prefix + "/sendSms";
    }
 
    @GetMapping("/send/sendEmail/{memberIds}/{testId}")
    public String sendEmail(@PathVariable("memberIds") String memberIds, @PathVariable("testId") Long testId, ModelMap mmap) {
//        String defaultTemplate = "欢迎您参加“工作行为问卷!”链接地址: <a href='{url}' target='_blank'>{url}</a>\n如果不能直接访问,请复制地址到浏览器中直接打开。如有疑问,请和XX联系。";
        String langType = LocaleContextHolder.getLocale().toString();
        StringBuilder builder = new StringBuilder();
 
        builder.append("亲爱的{FullName},").append("\n<br>");
        builder.append("Dear {FullName},").append("\n<br>");
        builder.append("เรียน {FullName},").append("\n<br>");
        builder.append("\n<br>");
 
        builder.append("{Company} 邀请您完成一份测试,大概需要20-25分钟时间。您可以直接点击下面的链接开始该测试。如果不能直接访问,请复制地址到浏览器中直接打开。").append("\n<br>");
        builder.append("You've been invited to take an assessment by {Company}, which shall take about 20-25 minutes to complete. Please click the link below, or copy the link to your browser, to begin the assessment.").append("\n<br>");
        builder.append("คุณได้รับเชิญให้ทำแบบประเมินจาก {Company} กรุณาใช้ลิงค์ด้านล่างเพื่อเริ่มดำเนินการ โดยคุณสามารถคลิกที่ลิงค์ด้านล่างโดยตรง หรือจะคัดลอกแล้วนำลิงค์ไปวางบนเบราว์เซอร์ของคุณก็ได้").append("\n<br>");
 
 
        builder.append("链接地址是:").append("\n<br>");
        builder.append("The link is:").append("\n<br>");
        builder.append("ตามลิงค์นี้:").append("\n<br>");
        builder.append("<a href='{url}' target='_blank'>{url}</a>").append("\n<br>");
        builder.append("\n<br>");
 
        builder.append("如有疑问,请与客服联系,邮箱是:support@tai-online.com。").append("\n<br>");
        builder.append("Should you have problem assessing the above link, please contact our customer service at support@tai-online.com.").append("\n<br>");
        builder.append("หากคุณมีปัญหาในการเข้าสู่ลิงค์ข้างต้น โปรดติดต่อฝ่ายบริการลูกค้าของเราที่ support@tai-online.com").append("\n<br>");
        builder.append("\n<br>");
        builder.append("\n<br>");
 
        builder.append("谢谢!").append("\n<br>");
        builder.append("All the best,").append("\n<br>");
        builder.append("ด้วยความเคารพ").append("\n<br>");
        builder.append("\n<br>");
 
        builder.append("{Company}").append("\n<br>");
 
        String type = SenderType.email.getType();
        processParams(memberIds, testId, mmap, builder.toString(), type);
        return prefix + "/sendEmail";
    }
 
    private void processParams(@PathVariable("memberIds") String memberIds, @PathVariable("testId") Long testId, ModelMap mmap, String defaultTemplate, String type) {
        mmap.put("memberIds", memberIds);
        mmap.put("size", memberIds.split(",").length);
        mmap.put("type", type);
        EntTestPackage entTestPackage = entTestPackageService.selectEntTestPackageById(testId);
        String template = entTestPackage.getTemplate();
        if (Objects.equals(SenderType.sms.getType(), type)) {
            mmap.put("template", defaultTemplate);
        } else {
            mmap.put("template", Objects.isNull(template) ? defaultTemplate : template);
        }
        mmap.put("testName", entTestPackage.getTestName() + "邀请邮件");
    }
 
 
    /**
     * 修改保存批量导入测试人员名单
     */
    @RequiresPermissions("exam:testMember:edit")
    @Log(title = "批量导入测试人员名单", businessType = BusinessType.UPDATE)
    @PostMapping("/edit")
    @ResponseBody
    public AjaxResult editSave(EntTestMember entTestMember) {
        return toAjax(entTestMemberService.updateEntTestMember(entTestMember));
    }
 
    /**
     * 删除批量导入测试人员名单
     */
    @RequiresPermissions("exam:testMember:remove")
    @Log(title = "批量导入测试人员名单", businessType = BusinessType.DELETE)
    @PostMapping("/remove")
    @ResponseBody
    public AjaxResult remove(String ids) {
        return toAjax(entTestMemberService.deleteEntTestMemberByIds(ids));
    }
 
    /**
     * 批量导入测试人员名单
     */
//    @RequiresPermissions("enterprise:testMember:import")
    @PostMapping("/importData/{testId}")
    @ResponseBody
    public AjaxResult importData(MultipartFile file, boolean updateSupport, @PathVariable Long testId) throws Exception {
        ExcelUtil<EntTestMember> util = new ExcelUtil<>(EntTestMember.class);
        List<EntTestMember> entTestMemberList = util.importExcel(file.getInputStream());
        for (EntTestMember member : entTestMemberList) {
            member.setTestId(testId);
        }
        String message = entTestMemberService.importEntTestMember(entTestMemberList, updateSupport);
        return AjaxResult.success(message);
    }
 
 
    /**
     * 批量导入测试人员名单模板下载
     */
    @GetMapping("/importTemplate")
    @ResponseBody
    public AjaxResult importTemplate() {
        ExcelUtil<EntTestMember> util = new ExcelUtil<EntTestMember>(EntTestMember.class);
        return util.importTemplateExcel("测试用户(Test-Takers)");
    }
 
}