企业认证加链属关系

tianhu-system/src/main/java/com/tianhu/system/companyAuth/controller/OwnAuthController.java

@@ -93,6 +93,10 @@ public class OwnAuthController extends BaseController {
     @Autowired
     private ISysUserRoleService sysUserRoleService;
     @Autowired
+    private ISysCompanySpareService sysCompanySpareService;
+    @Autowired
+    private ISysCompanyRelService sysCompanyRelService;
+    @Autowired
     private IOwnNoticeService ownNoticeService;
     @Autowired
     private ISysConfigService configService;
@@ -232,7 +236,7 @@ public class OwnAuthController extends BaseController {
         queryWrapper.eq(SysCompany::getScyName,scyName);
         //统一社会信用代码
         queryWrapper.eq(SysCompany::getScySocialCode,scySocialCode);
-        queryWrapper.ne(SysCompany::getScyStatus,"99");
+        queryWrapper.ne(SysCompany::getScyStatus,"99").ne(SysCompany::getScyStatus,"02");
         List<SysCompany> list = sysCompanyService.findSysCompanys(queryWrapper);
         if (list.size()>0){
             return R.fail("当前公司已存在,请重新选择公司");
@@ -757,6 +761,48 @@ public class OwnAuthController extends BaseController {
         redisService.setCacheObject(CacheConstants.LOGIN_TOKEN_KEY + token, userInfo, Constants.TOKEN_EXPIRE * 60, TimeUnit.SECONDS);
         //返回企业信息
         SysCompany company = sysCompanyService.getById(scyId);
+        //查询链属公司信息
+        LambdaQueryWrapper<SysCompanySpare> companySpare = new LambdaQueryWrapper<>();
+        companySpare.eq(SysCompanySpare::getScpSocialCode,company.getScySocialCode());
+        companySpare.eq(SysCompanySpare::getScpStatus,"00");
+        List<SysCompanySpare>  sysCompanySpare =  sysCompanySpareService.findSysCompanySpares(companySpare);
+        //新增链属关系
+        for(int i = 0;i<sysCompanySpare.size();i++){
+            SysCompanyRel companyRel =new SysCompanyRel();
+            String scrId  =  IdUtils.fastSimpleUUID();
+            companyRel.setScrId(scrId);
+            companyRel.setScrLaunchCompanyId(sysCompanySpare.get(i).getScpCompanyId());
+            companyRel.setScrReceiveCompanyId(scyId);
+           //供应商
+            if("00".equals(sysCompanySpare.get(i).getScpType())){
+                //00:待链属, 01:正常, 02:拒绝链属, 99:删除
+                companyRel.setScrStatus("01");
+                companyRel.setScrLaunchType("00");
+                companyRel.setScrReceiveType("01");
+            }else{
+                //00:待链属, 01:正常, 02:拒绝链属, 99:删除
+                companyRel.setScrStatus("00");
+                companyRel.setScrLaunchType("01");
+                companyRel.setScrReceiveType("00");
+            }
+            String contact =null;
+            if("1".equals(CommonUtil.objToString(map.get("legalHandles")))){
+                contact = handler;
+            }else{
+                contact= scyLegal;
+            }
+            companyRel.setScrContarct(contact);
+            companyRel.setScrContarctPhone(phoneNumber);
+            companyRel.setCreateBy(sysCompanySpare.get(i).getCreateBy());
+            companyRel.setCreateTime(sysCompanySpare.get(i).getCreateTime());
+            sysCompanyRelService.createSysCompanyRel(companyRel);
+            SysCompanySpare companySpare1 =new SysCompanySpare();
+            companySpare1.setScpId(sysCompanySpare.get(i).getScpId());
+            companySpare1.setScpRelId(scrId);
+            sysCompanySpareService.updateSysCompanySpare(companySpare1);
+        }
+
+
         if(company.getScyAuthStatus()=="02"){
             String tittle = "【企业认证】"+scyName+"CFCA工商四要素认证失败，请联系用户"+phoneNumber+"线下核实企业信息；";
             ownNoticeService.sendNotice(scyId,scyId,tittle,"00",null,"09","0","1",null, null, null);
@@ -1062,6 +1108,7 @@ public class OwnAuthController extends BaseController {
         //待实名认证
         sysCompany.setScyStatus("04");
         sysCompanyService.updateSysCompany(sysCompany);
+
         // 刷新登录用户菜单和权限
         SysUser sysUser = userInfo.getSysUser();
         sysUser.setCompanyId(scyId);
@@ -1253,7 +1300,18 @@ public class OwnAuthController extends BaseController {
                 sysUserRoleService.insertSysUserRole(sysUserRole);
             }
         }
-        //TODO 加消息通知
+        //查询链属公司信息
+        LambdaQueryWrapper<SysCompanySpare> companySpare = new LambdaQueryWrapper<>();
+        companySpare.eq(SysCompanySpare::getScpSocialCode,scySocialCode);
+        companySpare.eq(SysCompanySpare::getScpStatus,"00");
+        List<SysCompanySpare>  sysCompanySpare =  sysCompanySpareService.findSysCompanySpares(companySpare);
+        //新增链属关系
+        for(int i = 0;i<sysCompanySpare.size();i++){
+            SysCompanySpare companySpare1 =new SysCompanySpare();
+            companySpare1.setScpId(sysCompanySpare.get(i).getScpId());
+            companySpare1.setScpStatus("01");
+            sysCompanySpareService.updateSysCompanySpare(companySpare1);
+        }
         //获取经办人id
         LambdaQueryWrapper<SysUserCompanyRel> companyRelLambdaQueryWrapper = new LambdaQueryWrapper<>();
         companyRelLambdaQueryWrapper.eq(SysUserCompanyRel::getSucrCompanyId,scyId);

tianhu-system/src/main/java/com/tianhu/system/domain/SysCompanyRel.java

@@ -0,0 +1,107 @@
+package com.tianhu.system.domain;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.util.Date;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableField;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 企业链属关系表
+ * </p>
+ *
+ * @author cuixq
+ * @since 2021-09-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("sys_company_rel")
+public class SysCompanyRel implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    @TableId("scr_id")
+    private String scrId;
+
+    /**
+     * 发起方
+     */
+    @TableField("scr_launch_company_id")
+    private String scrLaunchCompanyId;
+
+    /**
+     * 接收方
+     */
+    @TableField("scr_receive_company_id")
+    private String scrReceiveCompanyId;
+
+    /**
+     * 00:待链属, 01:正常, 02:拒绝链属, 99:删除
+     */
+    @TableField("scr_status")
+    private String scrStatus;
+
+    /**
+     * 链属关系(发起方) 00:供应商 01:核心企业
+     */
+    @TableField("scr_launch_type")
+    private String scrLaunchType;
+
+    /**
+     * 链属关系(接收方) 00:供应商 01:核心企业
+     */
+    @TableField("scr_receive_type")
+    private String scrReceiveType;
+
+    /**
+     * 联系人
+     */
+    @TableField("scr_contarct")
+    private String scrContarct;
+
+    /**
+     * 联系电话
+     */
+    @TableField("scr_contarct_phone")
+    private String scrContarctPhone;
+
+    /**
+     * 邮箱
+     */
+    @TableField("scr_contarct_email")
+    private String scrContarctEmail;
+
+    /**
+     * 创建者
+     */
+    @TableField("create_by")
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField("create_time")
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    @TableField("update_by")
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    @TableField("update_time")
+    private Date updateTime;
+
+
+}

tianhu-system/src/main/java/com/tianhu/system/domain/SysCompanySpare.java

@@ -0,0 +1,125 @@
+package com.tianhu.system.domain;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.util.Date;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableField;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 链属公司信息表
+ * </p>
+ *
+ * @author cuixq
+ * @since 2021-09-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("sys_company_spare")
+public class SysCompanySpare implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    @TableId("scp_id")
+    private String scpId;
+
+    /**
+     * 链属关系表id(scr_id)
+     */
+    @TableField("scp_rel_id")
+    private String scpRelId;
+
+    /**
+     * 录入企业
+     */
+    @TableField("scp_company_id")
+    private String scpCompanyId;
+
+    /**
+     * 企业名称
+     */
+    @TableField("scp_name")
+    private String scpName;
+
+    /**
+     * 统一社会信用代码
+     */
+    @TableField("scp_social_code")
+    private String scpSocialCode;
+
+    /**
+     * 联系人
+     */
+    @TableField("scp_contarct")
+    private String scpContarct;
+
+    /**
+     * 联系电话
+     */
+    @TableField("scp_contarct_phone")
+    private String scpContarctPhone;
+
+    /**
+     * 邮箱
+     */
+    @TableField("scp_contarct_email")
+    private String scpContarctEmail;
+
+    /**
+     * 企业类型 00:供应商,01:核心企业
+     */
+    @TableField("scp_type")
+    private String scpType;
+
+    /**
+     * 备注
+     */
+    @TableField("scp_remarks")
+    private String scpRemarks;
+
+    /**
+     * 状态 00:正常 01:已认证 99:删除
+     */
+    @TableField("scp_status")
+    private String scpStatus;
+
+    /**
+     * 邀请次数
+     */
+    @TableField("scp_invite")
+    private String scpInvite;
+
+    /**
+     * 创建人
+     */
+    @TableField("create_by")
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField("create_time")
+    private Date createTime;
+
+    /**
+     * 修改人
+     */
+    @TableField("update_by")
+    private String updateBy;
+
+    /**
+     * 修改时间
+     */
+    @TableField("update_time")
+    private Date updateTime;
+
+
+}

tianhu-system/src/main/java/com/tianhu/system/mapper/SysCompanyRelMapper.java

@@ -0,0 +1,16 @@
+package com.tianhu.system.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.tianhu.system.domain.SysCompanyRel;
+
+/**
+ * <p>
+ * 企业链属关系表 Mapper 接口
+ * </p>
+ *
+ * @author cuixq
+ * @since 2021-09-28
+ */
+public interface SysCompanyRelMapper extends BaseMapper<SysCompanyRel> {
+
+}

tianhu-system/src/main/java/com/tianhu/system/mapper/SysCompanySpareMapper.java

@@ -0,0 +1,16 @@
+package com.tianhu.system.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.tianhu.system.domain.SysCompanySpare;
+
+/**
+ * <p>
+ * 链属公司信息表 Mapper 接口
+ * </p>
+ *
+ * @author cuixq
+ * @since 2021-09-28
+ */
+public interface SysCompanySpareMapper extends BaseMapper<SysCompanySpare> {
+
+}

tianhu-system/src/main/java/com/tianhu/system/service/ISysCompanyRelService.java

@@ -0,0 +1,58 @@
+package com.tianhu.system.service;
+
+
+import com.keao.tianhu.starter.mybatis.plus.entity.QueryRequest;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.tianhu.system.domain.SysCompanyRel;
+
+import java.util.List;
+
+/**
+ * ClassName: ISysCompanyRelService<br>
+ * Description: SysCompanyRelService接口 <br>
+ * Company: keao
+ *
+ * @author cuixq
+ * @version v1.0.0    2021-09-28  cuixq    由Generator自动创建
+ */
+public interface ISysCompanyRelService extends IService<SysCompanyRel> {
+    /**
+     * 查询（分页）
+     *
+     * @param request QueryRequest
+     * @param wrapper LambdaQueryWrapper<SysCompanyRel>
+     * @return IPage<SysCompanyRel>
+     */
+    IPage<SysCompanyRel> findSysCompanyRels(QueryRequest request, LambdaQueryWrapper<SysCompanyRel> wrapper);
+
+    /**
+     * 查询（所有）
+     *
+     * @param wrapper LambdaQueryWrapper<SysCompanyRel>
+     * @return List<SysCompanyRel>
+     */
+    List<SysCompanyRel> findSysCompanyRels(LambdaQueryWrapper<SysCompanyRel> wrapper);
+
+    /**
+     * 新增
+     *
+     * @param sysCompanyRel sysCompanyRel
+     */
+    void createSysCompanyRel(SysCompanyRel sysCompanyRel);
+
+    /**
+     * 修改
+     *
+     * @param sysCompanyRel sysCompanyRel
+     */
+    void updateSysCompanyRel(SysCompanyRel sysCompanyRel);
+
+    /**
+     * 删除
+     *
+     * @param wrapper LambdaQueryWrapper<SysCompanyRel>
+     */
+    void deleteSysCompanyRel(LambdaQueryWrapper<SysCompanyRel> wrapper);
+}

tianhu-system/src/main/java/com/tianhu/system/service/ISysCompanySpareService.java

@@ -0,0 +1,58 @@
+package com.tianhu.system.service;
+
+
+import com.keao.tianhu.starter.mybatis.plus.entity.QueryRequest;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.tianhu.system.domain.SysCompanySpare;
+
+import java.util.List;
+
+/**
+ * ClassName: ISysCompanySpareService<br>
+ * Description: SysCompanySpareService接口 <br>
+ * Company: keao
+ *
+ * @author cuixq
+ * @version v1.0.0    2021-09-28  cuixq    由Generator自动创建
+ */
+public interface ISysCompanySpareService extends IService<SysCompanySpare> {
+    /**
+     * 查询（分页）
+     *
+     * @param request QueryRequest
+     * @param wrapper LambdaQueryWrapper<SysCompanySpare>
+     * @return IPage<SysCompanySpare>
+     */
+    IPage<SysCompanySpare> findSysCompanySpares(QueryRequest request, LambdaQueryWrapper<SysCompanySpare> wrapper);
+
+    /**
+     * 查询（所有）
+     *
+     * @param wrapper LambdaQueryWrapper<SysCompanySpare>
+     * @return List<SysCompanySpare>
+     */
+    List<SysCompanySpare> findSysCompanySpares(LambdaQueryWrapper<SysCompanySpare> wrapper);
+
+    /**
+     * 新增
+     *
+     * @param sysCompanySpare sysCompanySpare
+     */
+    void createSysCompanySpare(SysCompanySpare sysCompanySpare);
+
+    /**
+     * 修改
+     *
+     * @param sysCompanySpare sysCompanySpare
+     */
+    void updateSysCompanySpare(SysCompanySpare sysCompanySpare);
+
+    /**
+     * 删除
+     *
+     * @param wrapper LambdaQueryWrapper<SysCompanySpare>
+     */
+    void deleteSysCompanySpare(LambdaQueryWrapper<SysCompanySpare> wrapper);
+}

tianhu-system/src/main/java/com/tianhu/system/service/impl/SysCompanyRelServiceImpl.java

@@ -0,0 +1,64 @@
+package com.tianhu.system.service.impl;
+
+import com.tianhu.system.domain.SysCompanyRel;
+import com.tianhu.system.mapper.SysCompanyRelMapper;
+import com.tianhu.system.service.ISysCompanyRelService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.beans.factory.annotation.Autowired;
+import com.keao.tianhu.starter.mybatis.plus.entity.QueryRequest;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+
+import java.util.List;
+
+/**
+ * ClassName: SysCompanyRelServiceImpl<br>
+ * Description: ISysCompanyRelService实现 <br>
+ * Company: keao
+ *
+ * @author cuixq
+ * @version v1.0.0    2021-09-28  cuixq    由Generator自动创建
+ */
+@Service
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
+public class SysCompanyRelServiceImpl extends ServiceImpl<SysCompanyRelMapper, SysCompanyRel> implements ISysCompanyRelService {
+
+    @Autowired
+    private SysCompanyRelMapper sysCompanyRelMapper;
+
+    @Override
+    public IPage<SysCompanyRel> findSysCompanyRels(QueryRequest request, LambdaQueryWrapper<SysCompanyRel> wrapper) {
+        Page<SysCompanyRel> page = new Page<>(request.getPageNum(), request.getPageSize());
+        return this.page(page, wrapper);
+    }
+
+    @Override
+    public List<SysCompanyRel> findSysCompanyRels(LambdaQueryWrapper<SysCompanyRel> wrapper) {
+		return this.list(wrapper);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void createSysCompanyRel(SysCompanyRel sysCompanyRel) {
+        this.save(sysCompanyRel);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateSysCompanyRel(SysCompanyRel sysCompanyRel) {
+        this.saveOrUpdate(sysCompanyRel);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteSysCompanyRel(LambdaQueryWrapper<SysCompanyRel> wrapper) {
+	    this.remove(wrapper);
+	}
+}

tianhu-system/src/main/java/com/tianhu/system/service/impl/SysCompanySpareServiceImpl.java

@@ -0,0 +1,64 @@
+package com.tianhu.system.service.impl;
+
+import com.tianhu.system.domain.SysCompanySpare;
+import com.tianhu.system.mapper.SysCompanySpareMapper;
+import com.tianhu.system.service.ISysCompanySpareService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.beans.factory.annotation.Autowired;
+import com.keao.tianhu.starter.mybatis.plus.entity.QueryRequest;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+
+import java.util.List;
+
+/**
+ * ClassName: SysCompanySpareServiceImpl<br>
+ * Description: ISysCompanySpareService实现 <br>
+ * Company: keao
+ *
+ * @author cuixq
+ * @version v1.0.0    2021-09-28  cuixq    由Generator自动创建
+ */
+@Service
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
+public class SysCompanySpareServiceImpl extends ServiceImpl<SysCompanySpareMapper, SysCompanySpare> implements ISysCompanySpareService {
+
+    @Autowired
+    private SysCompanySpareMapper sysCompanySpareMapper;
+
+    @Override
+    public IPage<SysCompanySpare> findSysCompanySpares(QueryRequest request, LambdaQueryWrapper<SysCompanySpare> wrapper) {
+        Page<SysCompanySpare> page = new Page<>(request.getPageNum(), request.getPageSize());
+        return this.page(page, wrapper);
+    }
+
+    @Override
+    public List<SysCompanySpare> findSysCompanySpares(LambdaQueryWrapper<SysCompanySpare> wrapper) {
+		return this.list(wrapper);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void createSysCompanySpare(SysCompanySpare sysCompanySpare) {
+        this.save(sysCompanySpare);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateSysCompanySpare(SysCompanySpare sysCompanySpare) {
+        this.saveOrUpdate(sysCompanySpare);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteSysCompanySpare(LambdaQueryWrapper<SysCompanySpare> wrapper) {
+	    this.remove(wrapper);
+	}
+}

tianhu-system/src/main/resources/mapper/system/SysCompanyRelMapper.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.tianhu.system.mapper.SysCompanyRelMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.tianhu.system.domain.SysCompanyRel">
+        <id column="scr_id" property="scrId" />
+        <result column="scr_launch_company_id" property="scrLaunchCompanyId" />
+        <result column="scr_receive_company_id" property="scrReceiveCompanyId" />
+        <result column="scr_status" property="scrStatus" />
+        <result column="scr_launch_type" property="scrLaunchType" />
+        <result column="scr_receive_type" property="scrReceiveType" />
+        <result column="scr_contarct" property="scrContarct" />
+        <result column="scr_contarct_phone" property="scrContarctPhone" />
+        <result column="scr_contarct_email" property="scrContarctEmail" />
+        <result column="create_by" property="createBy" />
+        <result column="create_time" property="createTime" />
+        <result column="update_by" property="updateBy" />
+        <result column="update_time" property="updateTime" />
+    </resultMap>
+
+</mapper>

tianhu-system/src/main/resources/mapper/system/SysCompanySpareMapper.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.tianhu.system.mapper.SysCompanySpareMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.tianhu.system.domain.SysCompanySpare">
+        <id column="scp_id" property="scpId" />
+        <result column="scp_rel_id" property="scpRelId" />
+        <result column="scp_company_id" property="scpCompanyId" />
+        <result column="scp_name" property="scpName" />
+        <result column="scp_social_code" property="scpSocialCode" />
+        <result column="scp_contarct" property="scpContarct" />
+        <result column="scp_contarct_phone" property="scpContarctPhone" />
+        <result column="scp_contarct_email" property="scpContarctEmail" />
+        <result column="scp_type" property="scpType" />
+        <result column="scp_remarks" property="scpRemarks" />
+        <result column="scp_status" property="scpStatus" />
+        <result column="scp_invite" property="scpInvite" />
+        <result column="create_by" property="createBy" />
+        <result column="create_time" property="createTime" />
+        <result column="update_by" property="updateBy" />
+        <result column="update_time" property="updateTime" />
+    </resultMap>
+
+</mapper>