package com.product.saas.service;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.product.admin.service.LoginAuthService;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.transfer.Transactional;
|
import com.product.file.service.FileManagerService;
|
import com.product.saas.config.SaasConst;
|
import com.product.saas.service.idel.ITenantApplyService;
|
import com.product.tool.flow.service.FlowService;
|
import com.product.util.BaseUtil;
|
|
@Component
|
public class TenantApplyService extends AbstractBaseService implements ITenantApplyService{
|
|
@Autowired
|
BaseDao baseDao;
|
|
@Autowired
|
FlowService flowService;
|
|
@Autowired
|
LoginAuthService loginAuthService;
|
|
@Autowired
|
FileManagerService fileManagerService;
|
|
/**
|
* 租户信息读取和验证
|
* @param fse
|
* @return
|
*/
|
public boolean validTenantInfo(FieldSetEntity fse) {
|
// 获取手机号和验证码
|
String phone = fse.getString("phone");
|
String code = fse.getString("code");
|
// 验证验证码是否正确
|
loginAuthService.verifyPhoneCaptcha(phone, code);
|
String unitName = fse.getString("unitName");
|
// 验证信息是否匹配
|
FieldSetEntity fseTenantByPhone = baseDao.getFieldSetEntityByFilter(SaasConst.PRODUCT_SYS_TENANT_APPLY, "applicant_phone = ?", new Object[] {phone}, false);
|
FieldSetEntity fseTenantByName = baseDao.getFieldSetEntityByFilter(SaasConst.PRODUCT_SYS_TENANT_APPLY, "unit_name = ?", new Object[] {unitName}, false);
|
if (fseTenantByPhone == null) {
|
if(fseTenantByName == null) {
|
// 都不存在，验证通过
|
return true;
|
} else {
|
throw new BaseException("单位已经被使用", "单位已经被使用");
|
}
|
} else {
|
if(fseTenantByName == null) {
|
throw new BaseException("手机号已经被使用", "手机号已经被使用");
|
} else {
|
if (fseTenantByName.getUUID().equals(fseTenantByPhone.getUUID())) {
|
// 都存在于同一条数据，验证通过
|
return true;
|
} else {
|
throw new BaseException("手机号和单位已经被使用", "手机号和单位已经被使用");
|
}
|
}
|
}
|
}
|
|
/**
|
* 获取指定租户申请，根据申请人手机号
|
* @param applicantPhone 申请人手机号
|
* @return
|
*/
|
public FieldSetEntity getTenantApplyByPhone(String applicantPhone) {
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT A.*, B.file_name AS business_license_name, B.attachment_size AS business_license_size, C.dict_label AS apply_status_label \n");
|
sql.append("FROM product_sys_tenant_apply A \n");
|
sql.append("LEFT JOIN product_sys_attachments B ON B.uuid = A.business_license \n");
|
sql.append("LEFT JOIN product_sys_dict C ON C.dict_value = A.apply_status AND C.dict_name = 'SYSTEM_TENANT_APPLY_STATUS' \n");
|
sql.append("WHERE A.applicant_phone = ?");
|
return baseDao.getFieldSetEntityBySQL(sql.toString(), new Object[] {applicantPhone}, false);
|
}
|
|
/**
|
* 保存租户申请
|
* @param fse
|
* @return
|
*/
|
@Override
|
@Transactional
|
public boolean saveTenantApply(FieldSetEntity fse) {
|
// 获取送审标志
|
String flowSign = fse.getString("approval_sign");
|
if (!BaseUtil.strIsNull(flowSign) || "1".equals(flowSign)) {
|
fse.setValue("apply_status", 2);
|
baseDao.saveFieldSetEntity(fse);
|
// 获取送审开始的后一个节点信息
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT * FROM product_sys_flow_node \n");
|
sql.append("WHERE uuid IN ( \n");
|
sql.append(" SELECT target_uuid FROM product_sys_flow_link \n");
|
sql.append(" WHERE source_uuid IN ( \n");
|
sql.append(" SELECT uuid FROM product_sys_flow_node \n");
|
sql.append(" WHERE module_type = 1 AND flow_uuid IN ( \n");
|
sql.append(" SELECT uuid FROM product_sys_flow_model \n");
|
sql.append(" WHERE type_code = ? \n");
|
sql.append(" ) \n");
|
sql.append(" ) \n");
|
sql.append(") \n");
|
FieldSetEntity fseFlowNode = baseDao.getFieldSetEntityBySQL(sql.toString(), new Object[] {SaasConst.FLOW_TENANT_APPLY}, false);
|
if (fseFlowNode == null || BaseUtil.strIsNull(fseFlowNode.getString("default_users"))) {
|
throw new BaseException("租户申请流程有误", "租户申请流程有误");
|
}
|
// 封装送审参数
|
FieldSetEntity fseFlowTask = new FieldSetEntity(SaasConst.PRODUCT_SYS_TENANT_APPLY);
|
fseFlowTask.setValue("uuid", fse.getUUID());
|
fseFlowTask.setValue("type_code", SaasConst.FLOW_TENANT_APPLY);
|
fseFlowTask.setValue("accepters", fseFlowNode.getString("default_users"));
|
fseFlowTask.setValue("flow_title", "租户申请-" + fse.getString("unit_name"));
|
// 执行送审
|
flowService.autoSendFlow(fseFlowTask);
|
return true;
|
} else {
|
fse.setValue("apply_status", 1);
|
// 保存记录
|
return baseDao.saveFieldSetEntity(fse);
|
}
|
}
|
|
public boolean cancelTenantApply(FieldSetEntity fse){
|
return true;
|
}
|
}
|
