|
@@ -11,14 +11,21 @@ import com.fs.app.param.LoginMaWxParam;
|
|
|
import com.fs.app.utils.JwtUtils;
|
|
|
import com.fs.common.core.domain.R;
|
|
|
import com.fs.common.core.redis.RedisCache;
|
|
|
+import com.fs.common.utils.IpUtil;
|
|
|
import com.fs.common.utils.ServletUtils;
|
|
|
+import com.fs.company.domain.Company;
|
|
|
import com.fs.company.domain.CompanyUser;
|
|
|
import com.fs.company.service.ICompanyDeptService;
|
|
|
+import com.fs.company.service.ICompanyService;
|
|
|
import com.fs.company.service.ICompanyUserService;
|
|
|
import com.fs.core.config.WxMaConfiguration;
|
|
|
import com.fs.course.config.CourseMaConfig;
|
|
|
+import com.fs.course.domain.FsUserCompanyUser;
|
|
|
+import com.fs.course.service.IFsUserCompanyUserService;
|
|
|
import com.fs.his.domain.FsUser;
|
|
|
+import com.fs.his.domain.FsUserWx;
|
|
|
import com.fs.his.service.IFsUserService;
|
|
|
+import com.fs.his.service.IFsUserWxService;
|
|
|
import com.fs.system.domain.SysConfig;
|
|
|
import com.fs.system.mapper.SysConfigMapper;
|
|
|
import com.fs.wx.miniapp.config.WxMaProperties;
|
|
@@ -35,6 +42,9 @@ import org.springframework.web.bind.annotation.*;
|
|
|
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
+import java.util.Objects;
|
|
|
+
|
|
|
+import static com.fs.his.utils.PhoneUtil.encryptPhone;
|
|
|
|
|
|
@Api("微信小程序相关接口(暂废弃,后面再删除)")
|
|
|
@RestController
|
|
@@ -43,164 +53,183 @@ import java.util.List;
|
|
|
public class WxCompanyUserController extends AppBaseController {
|
|
|
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
|
|
|
|
- @Autowired
|
|
|
- private WxMaProperties maProperties;
|
|
|
-
|
|
|
@Autowired
|
|
|
JwtUtils jwtUtils;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- RedisCache redisCache;
|
|
|
-
|
|
|
@Autowired
|
|
|
private ICompanyUserService companyUserService;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private ICompanyDeptService companyDeptService;
|
|
|
-
|
|
|
@Autowired
|
|
|
private IFsUserService userService;
|
|
|
-
|
|
|
@Autowired
|
|
|
- private SysConfigMapper sysConfigMapper;
|
|
|
+ private ICompanyService companyService;
|
|
|
+ @Autowired
|
|
|
+ private IFsUserCompanyUserService userCompanyUserService;
|
|
|
+ @Autowired
|
|
|
+ private IFsUserWxService fsUserWxService;
|
|
|
|
|
|
@ApiOperation("小程序-授权登录")
|
|
|
@PostMapping("/loginByMa")
|
|
|
public R login(@RequestBody LoginMaWxParam param) {
|
|
|
+ log.info("=====================进入小程序授权登录, 入参: {}", param);
|
|
|
if (StringUtils.isBlank(param.getCode())) {
|
|
|
return R.error("code不存在");
|
|
|
}
|
|
|
- SysConfig sysConfig3 = sysConfigMapper.selectConfigByConfigKey("courseMa.config");
|
|
|
- List<CourseMaConfig> courseMaConfigs = JSON.parseArray(sysConfig3.getConfigValue(), CourseMaConfig.class);
|
|
|
- if (courseMaConfigs.isEmpty()){
|
|
|
- return R.error("小程序配置为空");
|
|
|
+
|
|
|
+ // 特殊(需求设计:需要根据公司是否开启黑名单来设置会员初始化的状态)
|
|
|
+ Company company = companyService.selectCompanyById(param.getCompanyId());
|
|
|
+ if (company==null || company.getStatus()==0){
|
|
|
+ return R.error("注册失败团队已停用,或不存在!");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 根据销售后台设置的 是否需要单独注册会员 来判断是否需要设置销售的值
|
|
|
+ CompanyUser companyUser = companyUserService.selectCompanyUserById(param.getCompanyUserId());;
|
|
|
+ if(companyUser == null || companyUser.getStatus().equals("1")){
|
|
|
+ return R.error("注册失败客服已停用,或不存在!");
|
|
|
}
|
|
|
- CourseMaConfig courseMaConfig = courseMaConfigs.get(0);
|
|
|
- //获取第二个小程序配置,序号从0开始
|
|
|
- final WxMaService wxService = WxMaConfiguration.getMaService(courseMaConfig.getAppid());
|
|
|
+// if (company.getCourseMiniAppId() == null) {
|
|
|
+// return R.error("小程序参数错误!");
|
|
|
+// }
|
|
|
+// if (!param.getAppId().equals(company.getCourseMiniAppId())){
|
|
|
+// return R.error("无权限,");
|
|
|
+// }
|
|
|
+
|
|
|
+ final WxMaService wxService = WxMaConfiguration.getMaService(param.getAppId());
|
|
|
try {
|
|
|
WxMaJscode2SessionResult session = wxService.getUserService().getSessionInfo(param.getCode());
|
|
|
this.logger.info(session.getSessionKey());
|
|
|
this.logger.info(session.getOpenid());
|
|
|
- // 解密
|
|
|
- WxMaPhoneNumberInfo phoneNoInfo = wxService.getUserService().getPhoneNoInfo(session.getSessionKey(), param.getEncryptedData(), param.getIv());
|
|
|
- WxMaUserInfo userInfo = wxService.getUserService().getUserInfo(session.getSessionKey(), param.getEncryptedData(), param.getIv());
|
|
|
-
|
|
|
- //以下暂时注释,不需要往销售表添加数据
|
|
|
-// CompanyUser companyUser = companyUserService.getCompanyUserByOpenId(session.getOpenid());
|
|
|
-// String ip = IpUtil.getRequestIp();
|
|
|
-//
|
|
|
-//// // 如果公司id为空(表示可能是该公司的第一位销售管理员),则需要根据电话号码判断是否存在销售,如果不存在则提示
|
|
|
-//// if (param.getCompanyId() == null) {
|
|
|
-//// if (checkPhone == null) {
|
|
|
-//// throw new CustomException("由于不是管理员,不能直接登录", 401);
|
|
|
-//// }
|
|
|
-//// }
|
|
|
-// if (companyUser == null) {
|
|
|
-// CompanyUser checkPhone = companyUserService.getCompanyUserByPhone(phoneNoInfo.getPhoneNumber());
|
|
|
-// if (checkPhone != null) {
|
|
|
-// if (checkPhone.getMaOpenId() == null) {
|
|
|
-// companyUser = checkPhone;
|
|
|
-// companyUser.setMaOpenId(session.getOpenid());
|
|
|
-// companyUser.setUserId(companyUser.getUserId());
|
|
|
-// companyUser.setUpdateTime(new DateTime());
|
|
|
-// companyUser.setLoginIp(ip);
|
|
|
-// companyUserService.updateUserProfile(companyUser);
|
|
|
-// } else {
|
|
|
-// throw new CustomException("此手机号用户已存在");
|
|
|
-// }
|
|
|
-// } else {
|
|
|
-// //新增
|
|
|
-// companyUser = new CompanyUser();
|
|
|
-// companyUser.setUserName(phoneNoInfo.getPhoneNumber());
|
|
|
-// companyUser.setNickName(userInfo.getNickName() == null ? "微信用户" : userInfo.getNickName());
|
|
|
-// companyUser.setPhonenumber(phoneNoInfo.getPhoneNumber());
|
|
|
-// companyUser.setSex(userInfo.getGender());
|
|
|
-// //密码初始化为123456
|
|
|
-// String pw = "123456";
|
|
|
-// companyUser.setPassword(SecurityUtils.encryptPassword(param.getPassword() == null ? pw : param.getPassword()));
|
|
|
-// companyUser.setCreateTime(new Date());
|
|
|
-// companyUser.setCompanyId(param.getCompanyId());
|
|
|
-// companyUser.setParentId(param.getParentCompanyUseId());
|
|
|
-// companyUser.setMaOpenId(session.getOpenid());
|
|
|
-//
|
|
|
-// //部门信息
|
|
|
-// CompanyDept dept = companyDeptService.getDefaultCompanyDeptByCompanyId(param.getCompanyId());
|
|
|
-// if (Objects.nonNull(dept)) {
|
|
|
-// companyUser.setDeptId(dept.getDeptId());
|
|
|
-// }
|
|
|
-// companyUserService.insertUser(companyUser);
|
|
|
-// }
|
|
|
-// } else {
|
|
|
-// CompanyUser companyUserMp = new CompanyUser();
|
|
|
-// companyUserMp.setPhonenumber(phoneNoInfo.getPhoneNumber());
|
|
|
-// companyUserMp.setUserId(companyUser.getUserId());
|
|
|
-// companyUserMp.setUpdateTime(new DateTime());
|
|
|
-// companyUserMp.setLoginIp(ip);
|
|
|
-// companyUserService.updateUserProfile(companyUser);
|
|
|
-// }
|
|
|
-
|
|
|
- // 添加会员表数据
|
|
|
- FsUser user = userService.selectFsUserByMpOpenId(session.getOpenid());
|
|
|
- if (user != null) {
|
|
|
- //修改
|
|
|
- FsUser userMap = new FsUser();
|
|
|
- userMap.setUserId(user.getUserId());
|
|
|
- userMap.setMpOpenId(session.getOpenid());
|
|
|
- userMap.setUnionId(session.getUnionid());
|
|
|
- userMap.setUpdateTime(new DateTime());
|
|
|
- userMap.setNickName(userInfo.getNickName() != null ? userInfo.getNickName() : "微信用户");
|
|
|
- userMap.setAvatar(userInfo.getAvatarUrl() != null ? userInfo.getAvatarUrl() : null);
|
|
|
- userMap.setPhone(phoneNoInfo.getPhoneNumber());
|
|
|
- userService.updateFsUser(userMap);
|
|
|
- } else {
|
|
|
- //新增
|
|
|
- user = new FsUser();
|
|
|
- user.setNickName(userInfo.getNickName() != null ? userInfo.getNickName() : "微信用户");
|
|
|
- user.setAvatar(userInfo.getAvatarUrl() != null ? userInfo.getAvatarUrl() : null);
|
|
|
- user.setStatus(1);
|
|
|
- user.setMpOpenId(session.getOpenid());
|
|
|
- user.setUnionId(session.getUnionid());
|
|
|
- user.setCreateTime(new Date());
|
|
|
- user.setPhone(phoneNoInfo.getPhoneNumber());
|
|
|
- userService.insertFsUser(user);
|
|
|
+ this.logger.info(session.getUnionid());
|
|
|
+ if (StringUtils.isEmpty(session.getOpenid())){
|
|
|
+ return R.error("登陆失败,openid未授权,请稍后再试!");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (param.getAuthType() == 2 && StringUtils.isEmpty(session.getUnionid())){
|
|
|
+ return R.error("未绑定开发平台,请联系管理员!");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 手机号信息
|
|
|
+ WxMaPhoneNumberInfo phoneNoInfo = new WxMaPhoneNumberInfo();;
|
|
|
+ if (param.getAuthType()==1){
|
|
|
+ phoneNoInfo = wxService.getUserService().getPhoneNoInfo(session.getSessionKey(), param.getEncryptedData(), param.getIv());
|
|
|
+ if (StringUtils.isEmpty(phoneNoInfo.getPhoneNumber())){
|
|
|
+ return R.error("授权失败,请联系客服!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ FsUser user = getUserByAuthType(param, wxService, session, phoneNoInfo);
|
|
|
+
|
|
|
+ // 3. 处理用户注册或更新
|
|
|
+ String ip = IpUtil.getRequestIp();
|
|
|
+ user = handleUserRegisterOrUpdate(user, param, session, phoneNoInfo, company, companyUser, ip);
|
|
|
+
|
|
|
+ FsUserCompanyUser userCompanyUser = userCompanyUserService.selectByUserIdAndProjectId(user.getUserId(), param.getProjectId());
|
|
|
+ if (Objects.nonNull(userCompanyUser) && !param.getCompanyUserId().equals(userCompanyUser.getCompanyUserId())){
|
|
|
+ return R.error(500, "该用户("+user.getUserId() + ")已成为其他销售会员");
|
|
|
}
|
|
|
- log.info("保存成功的用户信息user: {}, 用户id: {}", user, user.getUserId());
|
|
|
+
|
|
|
+ // 4. 处理用户与小程序的绑定
|
|
|
+ handleFsUserWx(user, param, session);
|
|
|
+
|
|
|
+ log.info("保存成功的用户信息user: {}, 用户id: {},小程序AppId:{}", user, user.getUserId(), param.getAppId());
|
|
|
String token = jwtUtils.generateToken(user.getUserId());
|
|
|
- // 返回一个写死的数据到前端
|
|
|
- return R.ok("登录成功").put("token", token).put("phoneNumber", phoneNoInfo.getPhoneNumber()).put("nickName", "微信用户").put("user", user);
|
|
|
+ // 返回TOKEN和user
|
|
|
+ return R.ok("登录成功").put("token", token).put("user", user);
|
|
|
} catch (WxErrorException e) {
|
|
|
this.logger.error(e.getMessage(), e);
|
|
|
return R.error("授权失败," + e.getMessage());
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- @Login(isMiniLogin = true)
|
|
|
- @ApiOperation("获取销售通过小程序登录后的用户信息")
|
|
|
- @GetMapping("/getMaUser")
|
|
|
- public R getUserInfo() {
|
|
|
- try {
|
|
|
- CompanyUser companyUser = companyUserService.selectCompanyUserById(Long.parseLong(getUserId()));
|
|
|
- if (companyUser == null) {
|
|
|
- return R.error(401, "用户信息不存在");
|
|
|
+ /**
|
|
|
+ * 根据authType获取用户信息
|
|
|
+ */
|
|
|
+ private FsUser getUserByAuthType(LoginMaWxParam param, WxMaService wxService, WxMaJscode2SessionResult session, WxMaPhoneNumberInfo phoneNoInfo) throws WxErrorException {
|
|
|
+ FsUser user = null;
|
|
|
+ if (param.getAuthType() == 1) {
|
|
|
+ user = userService.selectFsUserByPhone(encryptPhone(phoneNoInfo.getPhoneNumber()));
|
|
|
+ } else {
|
|
|
+ // unionid判定唯一
|
|
|
+ if (StringUtils.isNotEmpty(session.getUnionid())) {
|
|
|
+ user = userService.selectFsUserByUnionId(session.getUnionid());
|
|
|
}
|
|
|
- return R.ok().put("user", companyUser);
|
|
|
- } catch (Exception e) {
|
|
|
- return R.error("操作异常");
|
|
|
}
|
|
|
+ return user;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 特殊要求:销售小程序临时登录,登录后页面中还有一个之前常用的登录,所以为了区分,token名称不能跟之前的一样
|
|
|
- *
|
|
|
- * @return 用户id
|
|
|
+ * 处理用户注册或更新
|
|
|
*/
|
|
|
- public String getUserId() {
|
|
|
- String headValue = ServletUtils.getRequest().getHeader("UserToken");
|
|
|
- Claims claims = jwtUtils.getClaimByToken(headValue);
|
|
|
- String userId = claims.getSubject().toString();
|
|
|
- return userId;
|
|
|
+ private FsUser handleUserRegisterOrUpdate(FsUser user, LoginMaWxParam param, WxMaJscode2SessionResult session, WxMaPhoneNumberInfo phoneNoInfo, Company company, CompanyUser companyUser, String ip) {
|
|
|
+ if (user == null) {
|
|
|
+ return createUser(param, session, phoneNoInfo, company, companyUser);
|
|
|
+ } else {
|
|
|
+ return updateUser(user, param, session, phoneNoInfo, company, companyUser);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 新增用户
|
|
|
+ */
|
|
|
+ private FsUser createUser(LoginMaWxParam param, WxMaJscode2SessionResult session, WxMaPhoneNumberInfo phoneNoInfo, Company company, CompanyUser companyUser) {
|
|
|
+ FsUser user = new FsUser();
|
|
|
+ user.setStatus((company != null ? company.getFsUserIsDefaultBlack() : 0) == 1 ? 0 : 1);
|
|
|
+ user.setUnionId(session.getUnionid() == null ? "" : session.getUnionid());
|
|
|
+ user.setCreateTime(new Date());
|
|
|
+ if (param.getAuthType() == 1 && phoneNoInfo != null) {
|
|
|
+ user.setPhone(phoneNoInfo.getPhoneNumber());
|
|
|
+ }
|
|
|
+ userService.insertFsUser(user);
|
|
|
+
|
|
|
+ if((companyUser.getIsAllowedAllRegister() == null || companyUser.getIsAllowedAllRegister() == 1)
|
|
|
+ && companyUser.getIsNeedRegisterMember() != null && companyUser.getIsNeedRegisterMember() != 1){
|
|
|
+ int defaultStatus = (company != null ? company.getFsUserIsDefaultBlack() : 0) == 1 ? 0 : 1;
|
|
|
+ userCompanyUserService.bindRelationship(user.getUserId(), param.getProjectId(), companyUser.getCompanyId(), companyUser.getUserId(), defaultStatus);
|
|
|
+ }
|
|
|
+ return user;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 修改用户
|
|
|
+ */
|
|
|
+ private FsUser updateUser(FsUser user, LoginMaWxParam param, WxMaJscode2SessionResult session, WxMaPhoneNumberInfo phoneNoInfo, Company company, CompanyUser companyUser) {
|
|
|
+ FsUser userMap = new FsUser();
|
|
|
+ userMap.setUserId(user.getUserId());
|
|
|
+ userMap.setUnionId(session.getUnionid() == null ? "" : session.getUnionid());
|
|
|
+ userMap.setUpdateTime(new DateTime());
|
|
|
+ if (param.getAuthType() == 1 && phoneNoInfo != null) {
|
|
|
+ userMap.setPhone(phoneNoInfo.getPhoneNumber());
|
|
|
+ }
|
|
|
|
|
|
+ userService.updateFsUser(userMap);
|
|
|
+ return userMap;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 处理用户与小程序的绑定
|
|
|
+ */
|
|
|
+ private void handleFsUserWx(FsUser user, LoginMaWxParam param, WxMaJscode2SessionResult session) {
|
|
|
+ if (user == null) return;
|
|
|
+ // 尝试更新
|
|
|
+ boolean updated = fsUserWxService.lambdaUpdate()
|
|
|
+ .eq(FsUserWx::getFsUserId, user.getUserId())
|
|
|
+ .eq(FsUserWx::getAppId, param.getAppId())
|
|
|
+ .eq(FsUserWx::getOpenId, session.getOpenid())
|
|
|
+ .set(FsUserWx::getCompanyId, param.getCompanyId())
|
|
|
+ .set(FsUserWx::getUnionId, session.getUnionid() == null ? "" : session.getUnionid())
|
|
|
+ .set(FsUserWx::getUpdateTime, new Date())
|
|
|
+ .update();
|
|
|
+
|
|
|
+ // 如果更新失败(记录不存在),则插入
|
|
|
+ if (!updated) {
|
|
|
+ FsUserWx fsUserWx = new FsUserWx();
|
|
|
+ fsUserWx.setType(1);
|
|
|
+ fsUserWx.setFsUserId(user.getUserId());
|
|
|
+ fsUserWx.setCompanyId(param.getCompanyId());
|
|
|
+ fsUserWx.setAppId(param.getAppId());
|
|
|
+ fsUserWx.setOpenId(session.getOpenid());
|
|
|
+ fsUserWx.setUnionId(session.getUnionid() == null ? "" : session.getUnionid());
|
|
|
+ fsUserWx.setCreateTime(new Date());
|
|
|
+ fsUserWx.setUpdateTime(new Date());
|
|
|
+ fsUserWxService.save(fsUserWx);
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|