package cn.chnmuseum.party.web.controller;
import cn.chnmuseum.party.auth.SHA256PasswordEncryptionService;
import cn.chnmuseum.party.auth.SecureRandomSaltService;
import cn.chnmuseum.party.auth.util.AESUtils;
import cn.chnmuseum.party.common.enums.AuditOperationEnum;
import cn.chnmuseum.party.common.log.MethodLog;
import cn.chnmuseum.party.common.log.OperModule;
import cn.chnmuseum.party.common.log.OperType;
import cn.chnmuseum.party.common.util.DateUtil80;
import cn.chnmuseum.party.model.Role;
import cn.chnmuseum.party.model.TUser;
import cn.chnmuseum.party.service.RoleService;
import cn.chnmuseum.party.service.impl.TUserServiceImpl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import cn.chnmuseum.party.web.controller.base.BaseController;
import cn.chnmuseum.party.model.TInteraction;
import cn.chnmuseum.party.service.TInteractionService;
import cn.chnmuseum.party.common.enums.AuditStatusEnum;
import cn.chnmuseum.party.common.validator.groups.Add;
import cn.chnmuseum.party.common.validator.groups.Update;
import cn.chnmuseum.party.common.vo.GenericPageParam;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.authz.annotation.RequiresAuthentication;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.stereotype.Controller;
import javax.annotation.Resource;
import javax.validation.constraints.NotNull;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* <pre>
* 看板互动 前端控制器
* </pre>
*
* @author Danny Lee
* @since 2021-03-23
*/
@Slf4j
@RestController
@RequestMapping("/interaction")
@Api(tags = {"看板互动操作接口"})
public class TInteractionController extends BaseController {
@Resource
private TInteractionService tInteractionService;
@Resource
private TUserServiceImpl userService;
@Resource
private RoleService roleService;
@PostMapping("/add")
@RequiresAuthentication //@RequiresPermissions("/interaction/add")
@ApiOperation(value = "添加看板互动", notes = "添加看板互动")
@MethodLog(operModule = OperModule.INTERACTIVE, operType = OperType.ADD)
public Map<String, Object> saveTInteraction(TInteraction tInteraction) {
TUser user = getcurUser();
// 保存业务节点信息
boolean result = false;
try {
Map<String, Object> resultMap = new LinkedHashMap<String, Object>();
// 验证互动审核员账号
if (StringUtils.isBlank(tInteraction.getName()) || StringUtils.isBlank(tInteraction.getPassword())) {
resultMap.put("resultCode", "400");
resultMap.put("message", "互动管理员账号或密码不能为空");
return resultMap;
}
// 只能填写当前操作的互动审核员账号
if (!tInteraction.getName().equals(user.getUserName())) {
resultMap.put("resultCode", "400");
resultMap.put("message", "请填写当前登录用户的账号和密码");
return resultMap;
}
TUser tUser = userService.selectByUsername(tInteraction.getName());
if (tUser == null) {
resultMap.put("resultCode", "400");
resultMap.put("message", "用户名不正确！");
return resultMap;
}
if (AuditOperationEnum.DISABLE.name().equals(tUser.getStatus())) {
resultMap.put("resultCode", "400");
resultMap.put("message", "此帐号已禁用，请联系管理员！");
return resultMap;
}
if (tUser.getPermanent() != null && !tUser.getPermanent()) {
if (user.getEffectiveDate() != null && user.getEffectiveDate().isAfter(LocalDate.now()) || user.getExiredDate() != null && user.getExiredDate().isBefore(LocalDate.now())) {
resultMap.put("resultCode", "400");
resultMap.put("message", "此帐号已失效，请联系管理员！");
return resultMap;
}
}
//密码解密
String s = AESUtils.aesDecrypt(tInteraction.getPassword());
byte[] salt = tUser.getPasswordSalt();
String s1 = new String(SHA256PasswordEncryptionService.createPasswordHash(s, salt));
if (!s1.equals(new String(tUser.getPasswordHash()))) {
resultMap.put("resultCode", "400");
resultMap.put("message", "密码不正确！");
return resultMap;
}
List<Role> roles = roleService.selectRoleByUserId(tUser.getId());
List<String> roleIds = roles.stream().map(Role::getId).collect(Collectors.toList());
if (!roleIds.contains("17")) {
resultMap.put("resultCode", "400");
resultMap.put("message", "所填写账号非互动审核员！");
return resultMap;
}
tInteraction.setUserId(user.getId());
tInteraction.setCreateTime(LocalDateTime.now());
result = tInteractionService.save(tInteraction);
// 返回操作结果
if (result) {
return getSuccessResult();
} else {
// 保存失败
return getFailResult();
}
} catch (Exception e) {
e.printStackTrace();
}
return getFailResult();
}
@PutMapping("/update")
@RequiresAuthentication //@RequiresPermissions("/interaction/update")
@ApiOperation(value = "修改看板互动信息", notes = "修改看板互动信息")
@MethodLog(operModule = OperModule.INTERACTIVE, operType = OperType.UPDATE)
public Map<String, Object> updateTInteraction(TInteraction tInteraction) {
boolean flag = false;
try {
flag = tInteractionService.updateById(tInteraction);
if (!flag) {
return getFailResult();
}
return getSuccessResult();
} catch (Exception e) {
e.printStackTrace();
}
return getFailResult();
}
@DeleteMapping("/delete")
@RequiresAuthentication //@RequiresPermissions("/interaction/delete")
@ApiOperation(value = "根据ID删除看板互动", notes = "根据ID删除看板互动")
@ApiImplicitParams(value = {
@ApiImplicitParam(name = "id", value = "标识ID", paramType = "query", dataType = "String")
})
@MethodLog(operModule = OperModule.INTERACTIVE, operType = OperType.DELETE)
public Map<String, Object> deleteTInteraction(String id) {
boolean result = tInteractionService.removeById(id);
if (result) {
return getSuccessResult();
}
return getFailResult();
}
@PostMapping("/getList")
@RequiresAuthentication //@RequiresPermissions("/interaction/getList")
@ApiImplicitParams(value = {
@ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
@ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer"),
@ApiImplicitParam(name = "orgId", value = "机构id", paramType = "query", dataType = "String")
})
@ApiOperation(value = "获取看板互动列表", notes = "获取看板互动列表")
@MethodLog(operModule = OperModule.INTERACTIVE, operType = OperType.SELECT)
public Map<String, Object> getTInteractionPageList(String orgId) {
Page<TInteraction> list = null;
try {
list = tInteractionService.selectPageList(getPage(), orgId);
return getResult(list);
} catch (Exception e) {
e.printStackTrace();
}
return getFailResult();
}
@ApiOperation(value = "获取看板互动详情", notes = "获取看板互动详情")
@GetMapping("/getById")
@RequiresAuthentication //@RequiresPermissions("/interaction/getById")
@MethodLog(operModule = OperModule.INTERACTIVE, operType = OperType.SELECT)
public Map<String, Object> getById(String id) {
TInteraction tInteraction = null;
try {
tInteraction = tInteractionService.getById(id);
return getResult(tInteraction);
} catch (Exception e) {
e.printStackTrace();
}
return getFailResult();
}
// @ApiImplicitParams(value = {
// @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
// @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer"),
// @ApiImplicitParam(name = "nameOrCode", value = "名称或编码", paramType = "query", dataType = "String"),
// @ApiImplicitParam(name = "startDate", value = "创建时间-开始", paramType = "query", dataType = "String"),
// @ApiImplicitParam(name = "endDate", value = "创建时间-结束", paramType = "query", dataType = "String")
// })
// @PostMapping("/getPageList")
// @RequiresAuthentication //@RequiresPermissions("/interaction/getPageList")
// @ApiOperation(value = "获取看板互动分页列表", notes = "获取看板互动分页列表")
// public Map<String, Object> getTInteractionPageList(GenericPageParam genericPageParam) {
// LambdaQueryWrapper<TInteraction> queryWrapper = new LambdaQueryWrapper<>();
// // 对名称或编码模糊查询
// if (StringUtils.isNotBlank(genericPageParam.getNameOrCode())) {
// queryWrapper.like(TInteraction::getUsername, genericPageParam.getNameOrCode());
// }
// // 根据创建时间区间检索
// if (genericPageParam.getStartDate() != null && genericPageParam.getEndDate() != null) {
// queryWrapper.ge(TInteraction::getCreateTime, genericPageParam.getStartDate().atTime(0, 0, 0))
// .le(TInteraction::getCreateTime, genericPageParam.getEndDate().atTime(23, 59, 59));
// }
// // 设置排序规则
// queryWrapper.orderByDesc(TInteraction::getCreateTime);
// Page<TInteraction> page = this.tInteractionService.page(getPage(), queryWrapper);
// for (TInteraction tInteraction : page.getRecords()) {
//
// }
// return getResult(page);
// }
}