ganzi-api/inventory-ent/src/main/java/com/rzyc/controller/PersonalController.java

package com.rzyc.controller;

import com.common.utils.model.Code;
import com.common.utils.model.Message;
import com.alibaba.fastjson.JSONArray;
import com.common.utils.StringUtils;
import com.common.utils.encryption.PasswdFactory;
import com.common.utils.jwt.JwtUtil;
import com.common.utils.model.SingleResult;
import com.rzyc.bean.user.dto.LoginDto;
import com.rzyc.config.MethodAnnotation;
import com.rzyc.model.dto.EntUserCredentialUpdateDto;
import com.rzyc.model.ent.EntUser;
import com.rzyc.service.PcBusinessService;
import com.rzyc.service.UserLoginService;
import com.rzyc.bean.user.dto.WeChartLoginDto;
import com.rzyc.model.ent.SysEnterprise;
import com.rzyc.model.user.SysUser;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import java.util.Objects;


/**
 * 个人中心系统
 * @author dong
 * @date 2022-09-16 14:19
 * @Version V1.0
 */
@Api(tags = "个人中心系统")
@CrossOrigin("*")
@RequestMapping("personal")
@RestController
@Validated
public class PersonalController extends BaseController{

    @Autowired
    UserLoginService userLoginService;

    @Autowired
    PcBusinessService pcBusinessService;

    /**
     * 用户登录
     * @version v1.0
     * @author dong
     * @date 2022/9/16 14:21
     */
    @ApiOperation(value = "用户登录", notes = "用户登录")
    @PostMapping(value = "/login")
    public SingleResult<String> login(@Valid LoginDto loginDto)throws Exception{
        SingleResult<String> result = new SingleResult<>();

        String generateCode = request.getSession().getAttribute(constantsConfigure.getGenerateCodeKey())+"";
        //验证码只能使用一次
        request.getSession().removeAttribute(constantsConfigure.getGenerateCodeKey());

        if(loginDto.getGenerateCode().equals(generateCode)) {
            String loginResult = userLoginService.login(loginDto.sysusername, loginDto.getSyspassword());
            if (Objects.isNull(loginResult)) {
                result.setCode(Code.PASSWORD_OR_ACCOUNT_ERROR.getCode());
                result.setMessage(Message.PASSWORD_OR_ACCOUNT_ERROR);
            } else {
                System.out.println("登陆成功");
                result.setData(loginResult);
            }
        }else {
            result.setCode(Code.CODE_ERROT.getCode());
            result.setMessage(Message.CODE_ERROT);
        }
        return result;
    }

    /**
     * 企业登录
     * @param loginDto
     * @return
     * @throws Exception
     */
    @ApiOperation(value = "企业登录", notes = "企业登录")
    @PostMapping(value = "/entlogin")
    @ResponseBody
    public SingleResult<SysUser> applogin(@Valid WeChartLoginDto loginDto)throws Exception{
        SingleResult<SysUser> result = new SingleResult<>();
        System.out.println("loginDto -> "+JSONArray.toJSONString(loginDto));
        String sysusername = loginDto.getSysusername();
        String syspassword = loginDto.getSyspassword();
        System.out.println("sessionid -> "+request.getSession().getId());
        SysUser sysUser = sysUserMapper.findBySysUserName(sysusername);
        if(null != sysUser && StringUtils.isNotBlank(sysUser.getUsertype())){
            if("企业用户".equals(sysUser)){
                //如果企业被禁用 直接返回登录失败
                SysEnterprise sysEnterprise = sysEnterpriseMapper.selectByPrimaryKey(sysUser.getSysunitorentid());
                if(null == sysEnterprise){
                    result.setCode(Code.TOKEN_EXPIRE.getCode());
                    result.setMessage(Message.TOKEN_EXPIRE);
                    return result;
                }
            }
            String ps = PasswdFactory.encryptPasswd(sysUser.getSysuserid(), sysusername, syspassword);
            if(sysUser.getSyspassword().equals(ps) || "guest".equals(sysUser.getUsertype())){
                sysUser.setSyspassword("");


                sysUser.setSyspassword("");

                //获取职务
                sysUser = getUserDuty(sysUser);

//                if(StringUtils.isNotBlank())

                //通过角色判断是否为安办 或者 部门管理员
                if(StringUtils.isNotBlank(sysUser.getUserroles())){
                    Integer userRole = this.getUserRole(sysUser.getUserroles());
                    sysUser.setUserRole(userRole);
                }

                //用户权限
                userAuth(sysUser);

                this.addLogAuth(sysUser.getSysuserid(),"登录","成功","");
                String userToken = JwtUtil.createToken(sysUser.getSysuserid());
                sysUser.setUserToken(userToken);
                result.setData(sysUser);

            }else{
                this.addLogAuth(sysUser.getSysuserid(),"登录","失败","");
                result.setCode(Code.PASSWORD_ERROR.getCode());
                result.setMessage(Message.PASSWORD_ERROR);
            }
        }else{
            result.setCode(Code.PASSWORD_ERROR.getCode());
            result.setMessage(Message.PASSWORD_ERROR);
        }
        return result;
    }


    /**
     * 企业用户组织树
     * @param enterpriseId 企业id
     * @param postId 企业用户id
     * @return 企业用户树
     * @throws Exception
     */
    @ApiOperation(value = "企业用户组织树", notes = "企业用户组织树")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "enterpriseId", value = "公司id", required = true, dataType = "string"),
            @ApiImplicitParam(name = "postId", value = "企业用户岗位id",required = false, dataType = "string"),
    })
    @GetMapping(value = "/entUserTree")
    @PreAuthorize("hasAnyAuthority('entUserTree','entUserTree:update')")
    @MethodAnnotation(authorizations = {"entUserTree","entUserTree:update"},name = "企业用户组织树")
    @ResponseBody
    public SingleResult<List<EntUser>> entUserTree(String enterpriseId, String postId)throws Exception{
        return  pcBusinessService.entUserTree(enterpriseId,postId);
    }


    /**
     * 企业用户工作要务
     * @param enterpriseId 企业id
     * @param entUserId 企业用户id
     * @param postId 企业用户岗位id
     * @return 企业用户工作要务
     * @throws Exception
     */
    @ApiOperation(value = "企业用户工作要务", notes = "企业用户工作要务")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "enterpriseId", value = "公司id", required = true, dataType = "string"),
            @ApiImplicitParam(name = "entUserId", value = "企业用户id", required = true, dataType = "string"),
            @ApiImplicitParam(name = "postId", value = "企业用户岗位id",required = false, dataType = "string"),
    })
    @GetMapping(value = "/entUserPostList")
    @PreAuthorize("hasAnyAuthority('entUserPostList','entUserPostList:update')")
    @MethodAnnotation(authorizations = {"entUserPostList","entUserPostList:update"},name = "企业用户工作要务")
    @ResponseBody
    public SingleResult entUserPostList(String enterpriseId, String entUserId,String postId,Integer page,Integer pageSize)throws Exception{
        return  pcBusinessService.entUserPostList(enterpriseId,entUserId,postId,page,pageSize);
    }


    /**
     * 企业用户工作清单
     * @param enterpriseId 企业id
     * @param postId 岗位id
     * @param listId 清单id
     * @param entUserId 企业用户id
     * @return 企业用户工作清单
     * @throws Exception
     */
    @ApiOperation(value = "企业用户工作清单", notes = "企业用户工作清单")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "enterpriseId", value = "公司id", required = true, dataType = "string"),
            @ApiImplicitParam(name = "entUserId", value = "企业用户id", required = true, dataType = "string"),
            @ApiImplicitParam(name = "postId", value = "企业用户岗位id",required = false, dataType = "string"),
            @ApiImplicitParam(name = "listId", value = "清单类型Id", required = false, dataType = "string"),
            @ApiImplicitParam(name = "content", value = "内容模糊搜索", required = false, dataType = "string"),
            @ApiImplicitParam(name = "taskState", value = "任务状态  1、进行中 2、已完成 3、已超期", required = false, dataType = "int"),
    })

    @GetMapping(value = "/entUserPostTask")
    @PreAuthorize("hasAnyAuthority('entUserPostTask','entUserPostTask:update')")
    @MethodAnnotation(authorizations = {"entUserPostTask","entUserPostTask:update"},name = "企业用户工作清单")
    @ResponseBody
    public SingleResult entUserPostTask(String enterpriseId, String entUserId,String postId,String listId,String content,Integer taskState,Integer page,Integer pageSize)throws Exception{
        return  pcBusinessService.entUserPostTask(enterpriseId,entUserId,postId,listId,content,taskState,page,pageSize);
    }


    /**
     * 企业用户岗位职责
     * @param enterpriseId 企业id
     * @param postId 岗位id
     * @return 企业用户岗位职责
     * @throws Exception
     */
    @ApiOperation(value = "企业用户岗位职责", notes = "企业用户岗位职责")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "enterpriseId", value = "公司id", required = true, dataType = "string"),
            @ApiImplicitParam(name = "postId", value = "企业用户岗位id",required = true, dataType = "string"),
    })

    @GetMapping(value = "/entUserPostDuty")
    @PreAuthorize("hasAnyAuthority('entUserPostDuty','entUserPostDuty:update')")
    @MethodAnnotation(authorizations = {"entUserPostDuty","entUserPostDuty:update"},name = "企业用户岗位职责")
    @ResponseBody
    public SingleResult entUserPostDuty(String enterpriseId, String postId,Integer page,Integer pageSize)throws Exception{
        return  pcBusinessService.entUserPostDuty(enterpriseId,postId,page,pageSize);
    }

    /**
     * 企业用户证照表
     * @param entUserId 企业用户id
     * @return 企业用户证照表
     * @throws Exception
     */
    @ApiOperation(value = "企业用户证照表", notes = "企业用户证照表")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "entUserId", value = "企业用户id",required = true, dataType = "string"),
    })
    @GetMapping(value = "/entUserCredential")
    @PreAuthorize("hasAnyAuthority('entUserCredential','entUserCredential:update')")
    @MethodAnnotation(authorizations = {"entUserCredential","entUserCredential:update"},name = "企业用户证照表")
    @ResponseBody
    public SingleResult entUserCredential(String entUserId,Integer page,Integer pageSize)throws Exception{
        return  pcBusinessService.entUserCredential(null,entUserId,page,pageSize);
    }

    /**
     * 企业用户证照表-新增,修改
     * @param entUserCredentialUpdateDto 企业用户证件对象
     * @return 成功或失败
     * @throws Exception
     */
    @ApiOperation(value = "企业用户证照表-新增,修改", notes = "企业用户证照表-新增,修改")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "entUserId", value = "企业用户id",required = true, dataType = "string"),
    })
    @PostMapping(value = "/entUserCredentialUpdate")
    @PreAuthorize("hasAnyAuthority('entUserCredentialUpdate:update')")
    @MethodAnnotation(authorizations = {"entUserCredentialUpdate:update"},name = "企业用户证照表-新增,修改")
    @ResponseBody
    public SingleResult entUserCredentialUpdate(@RequestBody EntUserCredentialUpdateDto entUserCredentialUpdateDto)throws Exception{
        return  pcBusinessService.entUserCredentialUpdate(entUserCredentialUpdateDto);
    }


    /**
     * 企业用户证照表-删除
     * @param credentialId 企业用户证件表删除
     * @return 成功或失败
     * @throws Exception
     */
    @ApiOperation(value = "企业用户证照表-删除", notes = "企业用户证照表-删除")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "credentialId", value = "证件照id",required = true, dataType = "string"),
    })
    @PostMapping(value = "/entUserCredentialDelete")
    @PreAuthorize("hasAnyAuthority('entUserCredentialDelete')")
    @MethodAnnotation(authorizations = {"entUserCredentialDelete"},name = "企业用户证照表-删除")
    @ResponseBody
    public SingleResult entUserCredentialDelete(String credentialId)throws Exception{
        return  pcBusinessService.entUserCredentialDelete(credentialId);
    }


    /**
     * 企业岗位总体信息列表
     * @param keyContent
     * @return list
     * @throws Exception
     */
    @ApiOperation(value = "企业岗位总体信息列表", notes = "企业岗位总体信息列表")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "keyContent", value = "搜索关键字",required = false, dataType = "string"),
    })
    @GetMapping(value = "/entUserList")
    @PreAuthorize("hasAnyAuthority('entUserList','entUserList:update')")
    @MethodAnnotation(authorizations = {"entUserList","entUserList:update"},name = "企业岗位总体信息列表")
    @ResponseBody
    public SingleResult entUserList(String keyContent,Integer page,Integer pageSize)throws Exception{
        return  pcBusinessService.entUserList(keyContent,page,pageSize);
    }







}