package cn.iocoder.yudao.module.ums.service.application;
|
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import cn.iocoder.yudao.module.system.service.auth.WxcpMembershipRegistration;
|
import cn.iocoder.yudao.module.ums.dal.dataobject.application.UmsApplicationDO;
|
import cn.iocoder.yudao.module.ums.dal.mysql.application.UmsApplicationMapper;
|
import cn.iocoder.yudao.module.ums.dal.redis.UmsNoRedisDAO;
|
import cn.iocoder.yudao.module.ums.enums.UmsApplicationStatusEnum;
|
import cn.iocoder.yudao.module.bpm.api.task.BpmProcessInstanceApi;
|
import cn.iocoder.yudao.module.bpm.api.task.dto.BpmProcessInstanceCreateReqDTO;
|
import cn.iocoder.yudao.module.system.service.user.AdminUserService;
|
import cn.iocoder.yudao.module.system.dal.dataobject.user.AdminUserDO;
|
import cn.iocoder.yudao.module.system.controller.admin.user.vo.user.UserSaveReqVO;
|
import cn.iocoder.yudao.module.system.service.permission.PermissionService;
|
import cn.iocoder.yudao.framework.datapermission.core.annotation.DataPermission;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.util.Collections;
|
import java.util.UUID;
|
|
@Service
|
public class WxcpMembershipRegistrationImpl implements WxcpMembershipRegistration {
|
@Resource private UmsApplicationMapper mapper;
|
@Resource private UmsNoRedisDAO noRedisDAO;
|
@Resource private BpmProcessInstanceApi processInstanceApi;
|
@Resource private AdminUserService userService;
|
@Resource private PermissionService permissionService;
|
|
@Override
|
public boolean hasPendingApplication(String openid) {
|
UmsApplicationDO application = mapper.selectOne(new LambdaQueryWrapperX<UmsApplicationDO>()
|
.eq(UmsApplicationDO::getWxcpOpenid, openid));
|
return application != null && !UmsApplicationStatusEnum.APPROVED.getStatus().equals(application.getStatus());
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@DataPermission(enable = false)
|
public void startIfAbsent(String openid, String nickname, String mobile) {
|
if (StrUtil.isBlank(openid)) throw new IllegalArgumentException("企业微信身份为空");
|
UmsApplicationDO existing = mapper.selectOne(new LambdaQueryWrapperX<UmsApplicationDO>()
|
.eq(UmsApplicationDO::getWxcpOpenid, openid));
|
if (existing != null) {
|
// 兼容旧版本首次扫码产生的草稿；已在审批或已结束的申请不重复发起。
|
if (UmsApplicationStatusEnum.DRAFT.getStatus().equals(existing.getStatus())
|
&& StrUtil.isBlank(existing.getProcessInstanceId())) {
|
existing.setStatus(UmsApplicationStatusEnum.APPROVING.getStatus());
|
if (StrUtil.isBlank(existing.getMemberGrade())) existing.setMemberGrade("1");
|
if (StrUtil.isBlank(existing.getContactPhone()) && StrUtil.isNotBlank(mobile)
|
&& mobile.trim().matches("^1[3-9]\\d{9}$")) existing.setContactPhone(mobile.trim());
|
int claimed = mapper.update(null, new LambdaUpdateWrapper<UmsApplicationDO>()
|
.eq(UmsApplicationDO::getId, existing.getId())
|
.eq(UmsApplicationDO::getStatus, UmsApplicationStatusEnum.DRAFT.getStatus())
|
.set(UmsApplicationDO::getStatus, UmsApplicationStatusEnum.APPROVING.getStatus())
|
.set(UmsApplicationDO::getMemberGrade, existing.getMemberGrade())
|
.set(UmsApplicationDO::getContactPhone, existing.getContactPhone()));
|
if (claimed == 1) startProcess(existing);
|
}
|
return;
|
}
|
UmsApplicationDO application = new UmsApplicationDO();
|
application.setNo(noRedisDAO.generate(UmsNoRedisDAO.APPLICATION_NO_PREFIX));
|
application.setWxcpOpenid(openid);
|
application.setApplicantName(StrUtil.maxLength(StrUtil.blankToDefault(nickname, "待完善"), 64));
|
application.setMemberType(1);
|
application.setMemberGrade("1");
|
if (StrUtil.isNotBlank(mobile) && mobile.trim().matches("^1[3-9]\\d{9}$")) {
|
application.setContactPhone(mobile.trim());
|
}
|
application.setStatus(UmsApplicationStatusEnum.APPROVING.getStatus());
|
mapper.insert(application);
|
startProcess(application);
|
}
|
|
private void startProcess(UmsApplicationDO application) {
|
Long initiatorId = getServiceUserId();
|
String processId = processInstanceApi.createProcessInstance(initiatorId,
|
new BpmProcessInstanceCreateReqDTO().setProcessDefinitionKey("ums_membership_approve")
|
.setBusinessKey(String.valueOf(application.getId())));
|
mapper.updateById(new UmsApplicationDO().setId(application.getId()).setProcessInstanceId(processId));
|
}
|
|
private Long getServiceUserId() {
|
String username = "wxcpservice";
|
AdminUserDO existing = userService.getUserByUsername(username);
|
if (existing != null) {
|
if (cn.iocoder.yudao.framework.common.enums.CommonStatusEnum.isDisable(existing.getStatus()))
|
throw new IllegalStateException("入会审批服务账号已停用");
|
if (!"仅用于系统自动发起入会审批".equals(existing.getRemark())
|
|| !permissionService.getUserRoleIdListByUserId(existing.getId()).isEmpty())
|
throw new IllegalStateException("入会审批服务账号配置不符合要求，请联系管理员核查");
|
return existing.getId();
|
}
|
UserSaveReqVO req = new UserSaveReqVO();
|
req.setUsername(username);
|
req.setNickname("入会审批服务");
|
req.setPassword(UUID.randomUUID().toString().replace("-", "").substring(0, 16));
|
req.setPostIds(Collections.emptySet());
|
req.setRoleIds(Collections.emptySet());
|
req.setRemark("仅用于系统自动发起入会审批");
|
return userService.createUser(req);
|
}
|
}
|
