package com.panzhihua.service_equipment.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.panzhihua.common.model.dtos.equipment.UnionUserDto;
|
import com.panzhihua.common.model.vos.LoginUserInfoVO;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.redis.TokenManager;
|
import com.panzhihua.service_equipment.until.AccessUtil;
|
import com.panzhihua.service_equipment.dao.UnionAccessMapper;
|
import com.panzhihua.service_equipment.dao.UnionUserMapper;
|
import com.panzhihua.service_equipment.dao.UsersMapper;
|
import com.panzhihua.service_equipment.model.dos.UnionAccess;
|
import com.panzhihua.service_equipment.model.dos.UnionUser;
|
import com.panzhihua.service_equipment.model.dos.Users;
|
import com.panzhihua.service_equipment.service.UnionUserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
@Slf4j
|
public class UnionUserServiceImpl extends ServiceImpl<UnionUserMapper, UnionUser> implements UnionUserService {
|
|
@Resource
|
private AccessUtil accessUtil;
|
|
@Resource
|
private UnionAccessMapper unionAccessMapper;
|
|
@Resource
|
private UsersMapper usersMapper;
|
|
@Resource
|
private TokenManager tokenManager;
|
|
/**
|
* 总工会户外劳登录
|
*
|
* @param loginUserInfoVO
|
* @return 总工会户外劳共用户
|
*/
|
@Override
|
public R<UnionUser> login(LoginUserInfoVO loginUserInfoVO) {
|
UnionUser unionUser = baseMapper.selectOne(new QueryWrapper<UnionUser>().eq("user_id", loginUserInfoVO.getUserId()));
|
if (unionUser != null) {
|
return R.ok(unionUser);
|
} else {
|
unionUser = new UnionUser();
|
unionUser.setSex(loginUserInfoVO.getSex().toString());
|
unionUser.setPhone(loginUserInfoVO.getPhone());
|
unionUser.setDeleteFlag(false);
|
unionUser.setCreateAt(LocalDateTime.now());
|
unionUser.setUpdateAt(LocalDateTime.now());
|
unionUser.setStatus(1);
|
unionUser.setNickName(loginUserInfoVO.getNickName());
|
unionUser.setUserId(loginUserInfoVO.getUserId());
|
if (loginUserInfoVO.getImageUrl() != null)
|
unionUser.setImageUrl(loginUserInfoVO.getImageUrl());
|
int insert = baseMapper.insert(unionUser);
|
if (insert > 0) {
|
return R.ok(unionUser);
|
} else {
|
return R.fail();
|
}
|
}
|
|
}
|
|
/**
|
* 总工会户外劳登录(h5)
|
*
|
* @param phone
|
* @return 总工会户外劳共用户
|
*/
|
@Override
|
public R<Map<String, Object>> loginByUnion(String phone){
|
Map<String, Object> mapUser = new HashMap<>();
|
Users users = usersMapper.selectOne(new QueryWrapper<Users>()
|
.eq("phone", phone)
|
.eq("deleted", 0)
|
.eq("freezeFlag", 0)
|
.orderByDesc("updateTime")
|
.last("limit 1"));
|
if (users!=null){
|
UnionUser unionUser = baseMapper.selectOne(new QueryWrapper<UnionUser>().eq("union_h5_user_id", users.getUsersID()));
|
if (unionUser!=null){
|
String token = tokenManager.getTokenByUserId(unionUser.getId().toString());
|
// String token=null;
|
if (token == null) {
|
//生成一个token，保存用户登录状态
|
token = tokenManager.createToken(unionUser.getId().toString(), unionUser.getId().toString());
|
}
|
mapUser.put("token", token);
|
mapUser.put("unionUser",unionUser);
|
log.info("mapUser{}",mapUser);
|
return R.ok(mapUser);
|
}
|
else {
|
unionUser=new UnionUser();
|
unionUser.setPhone(users.getPhone());
|
unionUser.setDeleteFlag(false);
|
unionUser.setCreateAt(LocalDateTime.now());
|
unionUser.setUpdateAt(LocalDateTime.now());
|
unionUser.setStatus(1);
|
unionUser.setNickName(users.getUname());
|
unionUser.setUnionH5UserId(users.getUsersID());
|
int insert = baseMapper.insert(unionUser);
|
if (insert >0){
|
unionUser = baseMapper.selectOne(new QueryWrapper<UnionUser>().eq("union_h5_user_id", users.getUsersID()));
|
if (unionUser!=null){
|
String token = tokenManager.getTokenByUserId(unionUser.getId().toString());
|
if (token == null) {
|
//生成一个token，保存用户登录状态
|
token = tokenManager.createToken(unionUser.getId().toString(), unionUser.getId().toString());
|
}
|
mapUser.put("token", token);
|
mapUser.put("unionUser",unionUser);
|
log.info("mapUser{}",mapUser);
|
return R.ok(mapUser);
|
}
|
|
}
|
|
}
|
return R.fail("新增用户失败请查看是否在川共之家登录");
|
}else {
|
log.info("总工会数据库没有人物");
|
return R.fail("数据错误,请先在川共之家登录");
|
}
|
|
}
|
|
/**
|
* 使用id查找用户
|
*
|
* @param id
|
* @return 总工会户外劳共用户
|
*/
|
@Override
|
public UnionUserDto selectById(Long id){
|
UnionUserDto unionUserDto=new UnionUserDto();
|
UnionUser unionUser = baseMapper.selectById(id);
|
BeanUtils.copyProperties(unionUser, unionUserDto);
|
return unionUserDto;
|
}
|
|
|
/**
|
* 总工会户外劳工站用户认证
|
*
|
* @param unionUserDto
|
* @return 总工会户外劳共用户
|
*/
|
|
@Override
|
public R authentication(UnionUserDto unionUserDto){
|
UnionUser unionUser=null;
|
if (unionUserDto.getIsApplets().equals(1))
|
unionUser = baseMapper.selectOne(new QueryWrapper<UnionUser>().eq("user_id", unionUserDto.getUserId()));
|
else
|
unionUser = baseMapper.selectOne(new QueryWrapper<UnionUser>().eq("id", unionUserDto.getId()));
|
if (unionUser != null){
|
log.info("查询到用户开始认证操作{}",unionUser);
|
//设备下发照片代码
|
LambdaQueryWrapper<UnionAccess> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.inSql(UnionAccess::getSiteId, "SELECT id FROM union_outdoor_site WHERE area_code='" + unionUserDto.getAreaCode() + "'");
|
List<UnionAccess> unionAccesses = unionAccessMapper.selectList(queryWrapper);
|
for (UnionAccess unionAccess : unionAccesses) {
|
try {
|
log.info("人脸注册");
|
accessUtil.faceEnroll(unionUser.getPhone(), unionUserDto.getName(), unionUserDto.getAuthenticatedUrlBase(), unionAccess.getCommunityExternalId(), unionAccess.getUnitId());
|
} catch (Exception e) {
|
// 处理异常
|
e.printStackTrace();
|
return R.fail("认证失败,请验证照片是否符合规范或者联系工作人员"); // 或者抛出自定义异常，根据实际情况进行处理
|
}
|
}
|
//更改数据库
|
unionUser.setName(unionUserDto.getName());
|
unionUser.setIdCard(unionUserDto.getIdCard());
|
unionUser.setAreaCode(unionUserDto.getAreaCode());
|
unionUser.setAuthenticatedUrl(unionUserDto.getAuthenticatedUrl());
|
unionUser.setAuthenticatedUrlBase(unionUserDto.getAuthenticatedUrlBase());
|
unionUser.setIsAuthenticated(1);
|
int i = baseMapper.updateById(unionUser);
|
if (i>0){
|
return R.ok("认证成功");
|
}
|
else {
|
return R.fail("认证失败");
|
}
|
}
|
else {
|
log.info("未查询到用户");
|
return R.fail("认证失败");
|
}
|
|
}
|
}
|
