许可信息表及监管系统用户全量表导入平台和业务的企业表

amos-boot-system-tzs/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/SpeUseUnitDto.java

+package com.yeejoin.amos.boot.module.tzs.api.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 使用单位
+ *
+ * @author duanwei
+ * @date 2022-09-08
+ */
+@Data
+@Accessors(chain = true)
+@ApiModel(value="SpeUseUnit对象", description="使用单位")
+public class SpeUseUnitDto implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+
+    @ApiModelProperty(value = "单位名称")
+    private String name;
+
+    @ApiModelProperty(value = "统一社会信用代码")
+    private String cerCode;
+
+    @ApiModelProperty(value = "单位性质")
+    private String unitNature;
+
+    @ApiModelProperty(value = "营业执照图片")
+    private String cerImgUrl;
+
+    @ApiModelProperty(value = "营业执照登记机关")
+    private String cerRegiOrg;
+
+    @ApiModelProperty(value = "注册地址_省")
+    private String cerAddrProvince;
+
+    @ApiModelProperty(value = "注册地址_市")
+    private String cerAddrCity;
+
+    @ApiModelProperty(value = "注册地址")
+    private String cerAddrArea;
+
+    @ApiModelProperty(value = "注册大厦（小区）")
+    private String cerAddrVillage;
+
+    @ApiModelProperty(value = "注册地址_街道")
+    private String cerAddrStreet;
+
+    @ApiModelProperty(value = "注册地址_详细地址")
+    private String cerAddrDetail;
+
+    @ApiModelProperty(value = "法定代表人")
+    private String legalPerson;
+
+    @ApiModelProperty(value = "法人手机")
+    private String legalPersonPhone;
+
+    @ApiModelProperty(value = "负责人")
+    private String responPerson;
+
+    @ApiModelProperty(value = "负责人手机")
+    private String responPersonPhone;
+
+    @ApiModelProperty(value = "所在地邮政编码")
+    private String zipCode;
+
+    @ApiModelProperty(value = "办公地址_省")
+    private String offiAddrProvince;
+
+    @ApiModelProperty(value = "办公地址_市")
+    private String offiAddrCity;
+
+    @ApiModelProperty(value = "办公地址")
+    private String offiAddrArea;
+
+    @ApiModelProperty(value = "办公地址_街道")
+    private String offiAddrStreet;
+
+    @ApiModelProperty(value = "办公大厦（小区）")
+    private String offiAddrVillage;
+
+    @ApiModelProperty(value = "办公地址_详细地址")
+    private String offiAddrDetail;
+
+    @ApiModelProperty(value = "冻结原因")
+    private String frozenReason;
+
+    @ApiModelProperty(value = "单位所属行业")
+    private String industry;
+
+    @ApiModelProperty(value = "值班电话")
+    private String onDutyPhone;
+
+    @ApiModelProperty(value = "管辖分局ID")
+    private String auditOrgId;
+
+    @ApiModelProperty(value = "管辖分局")
+    private String auditOrgName;
+
+    @ApiModelProperty(value = "管辖分局编码")
+    private String auditOrgCode;
+
+    @ApiModelProperty(value = "单位状态")
+    private Integer status;
+
+    @ApiModelProperty(value = "备注")
+    private String remark;
+
+    @ApiModelProperty(value = "删除状态")
+    private Integer delFlag;
+
+    @ApiModelProperty(value = "创建人")
+    private String createBy;
+
+    @ApiModelProperty(value = "创建时间")
+    private Date createTime;
+
+    @ApiModelProperty(value = "更新人")
+    private String updateBy;
+
+    @ApiModelProperty(value = "更新时间")
+    private Date updateTime;
+
+    @ApiModelProperty(value = "组织机构ID")
+    private String sysOrgId;
+
+    @ApiModelProperty(value = "所属组织机构编码")
+    private String sysOrgCode;
+
+    @ApiModelProperty(value = "96333救援电话")
+    private String rescueCall;
+
+    @ApiModelProperty(value = "同步id")
+    private String syncId;
+
+
+}

amos-boot-system-tzs/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/entity/SpeUseUnit.java

+package com.yeejoin.amos.boot.module.tzs.api.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
+import org.typroject.tyboot.core.rdbms.orm.entity.BaseEntity;
+
+/**
+ * 使用单位
+ *
+ * @author duanwei
+ * @date 2022-09-08
+ */
+@Data
+@Accessors(chain = true)
+@ApiModel(value="SpeUseUnit对象", description="使用单位")
+public class SpeUseUnit implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+
+    @ApiModelProperty(value = "单位名称")
+    private String name;
+
+    @ApiModelProperty(value = "统一社会信用代码")
+    private String cerCode;
+
+    @ApiModelProperty(value = "单位性质")
+    private String unitNature;
+
+    @ApiModelProperty(value = "营业执照图片")
+    private String cerImgUrl;
+
+    @ApiModelProperty(value = "营业执照登记机关")
+    private String cerRegiOrg;
+
+    @ApiModelProperty(value = "注册地址_省")
+    private String cerAddrProvince;
+
+    @ApiModelProperty(value = "注册地址_市")
+    private String cerAddrCity;
+
+    @ApiModelProperty(value = "注册地址")
+    private String cerAddrArea;
+
+    @ApiModelProperty(value = "注册大厦（小区）")
+    private String cerAddrVillage;
+
+    @ApiModelProperty(value = "注册地址_街道")
+    private String cerAddrStreet;
+
+    @ApiModelProperty(value = "注册地址_详细地址")
+    private String cerAddrDetail;
+
+    @ApiModelProperty(value = "法定代表人")
+    private String legalPerson;
+
+    @ApiModelProperty(value = "法人手机")
+    private String legalPersonPhone;
+
+    @ApiModelProperty(value = "负责人")
+    private String responPerson;
+
+    @ApiModelProperty(value = "负责人手机")
+    private String responPersonPhone;
+
+    @ApiModelProperty(value = "所在地邮政编码")
+    private String zipCode;
+
+    @ApiModelProperty(value = "办公地址_省")
+    private String offiAddrProvince;
+
+    @ApiModelProperty(value = "办公地址_市")
+    private String offiAddrCity;
+
+    @ApiModelProperty(value = "办公地址")
+    private String offiAddrArea;
+
+    @ApiModelProperty(value = "办公地址_街道")
+    private String offiAddrStreet;
+
+    @ApiModelProperty(value = "办公大厦（小区）")
+    private String offiAddrVillage;
+
+    @ApiModelProperty(value = "办公地址_详细地址")
+    private String offiAddrDetail;
+
+    @ApiModelProperty(value = "冻结原因")
+    private String frozenReason;
+
+    @ApiModelProperty(value = "单位所属行业")
+    private String industry;
+
+    @ApiModelProperty(value = "值班电话")
+    private String onDutyPhone;
+
+    @ApiModelProperty(value = "管辖分局ID")
+    private String auditOrgId;
+
+    @ApiModelProperty(value = "管辖分局")
+    private String auditOrgName;
+
+    @ApiModelProperty(value = "管辖分局编码")
+    private String auditOrgCode;
+
+    @ApiModelProperty(value = "单位状态")
+    private Integer status;
+
+    @ApiModelProperty(value = "备注")
+    private String remark;
+
+    @ApiModelProperty(value = "删除状态")
+    private Integer delFlag;
+
+    @ApiModelProperty(value = "创建人")
+    private String createBy;
+
+    @ApiModelProperty(value = "创建时间")
+    private Date createTime;
+
+    @ApiModelProperty(value = "更新人")
+    private String updateBy;
+
+    @ApiModelProperty(value = "更新时间")
+    private Date updateTime;
+
+    @ApiModelProperty(value = "组织机构ID")
+    private String sysOrgId;
+
+    @ApiModelProperty(value = "所属组织机构编码")
+    private String sysOrgCode;
+
+    @ApiModelProperty(value = "96333救援电话")
+    private String rescueCall;
+
+    @ApiModelProperty(value = "同步id")
+    private String syncId;
+
+
+}

amos-boot-system-tzs/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/mapper/SpeUseUnitMapper.java

+package com.yeejoin.amos.boot.module.tzs.api.mapper;
+
+import com.yeejoin.amos.boot.module.tzs.api.entity.SpeUseUnit;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * 使用单位 Mapper 接口
+ *
+ * @author duanwei
+ * @date 2022-09-08
+ */
+public interface SpeUseUnitMapper extends BaseMapper<SpeUseUnit> {
+
+}

amos-boot-system-tzs/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/service/ISpeUseUnitService.java

+package com.yeejoin.amos.boot.module.tzs.api.service;
+
+import com.yeejoin.amos.boot.module.tzs.api.entity.SpeUseUnit;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * 使用单位 服务类
+ *
+ * @author duanwei
+ * @date 2022-09-08
+ */
+public interface ISpeUseUnitService extends IService<SpeUseUnit> {
+
+}

amos-boot-system-tzs/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/service/ITzBaseEnterpriseInfoService.java

@@ -32,4 +32,6 @@ public interface ITzBaseEnterpriseInfoService extends IService<TzBaseEnterpriseI
 	List<EquEnterDto> getInfoByUseUnit(String useUnit);
 
 	TzBaseEnterpriseInfoDto selectByUseUnit(String useUnit);
+
+	String syncEnterpriseInfo();
 }

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/AmosTzsApplication.java

@@ -3,6 +3,8 @@ package com.yeejoin.amos;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 
+import com.yeejoin.amos.boot.module.tzs.biz.listener.PrivilegeCompanyDeleteListener;
+import com.yeejoin.amos.boot.module.tzs.biz.listener.PrivilegeCompanyUpdateAddListener;
 import org.eclipse.paho.client.mqttv3.MqttException;
 import org.mybatis.spring.annotation.MapperScan;
 import org.slf4j.Logger;
@@ -63,6 +65,12 @@ public class AmosTzsApplication {
 	@Autowired
 	private StartPlatformTokenService startPlatformTokenService;
 
+	@Autowired
+	private PrivilegeCompanyUpdateAddListener privilegeCompanyUpdateAddListener;
+
+	@Autowired
+	private PrivilegeCompanyDeleteListener privilegeCompanyDeleteListener;
+
 	public static void main(String[] args) throws UnknownHostException {
 		ConfigurableApplicationContext context = SpringApplication.run(AmosTzsApplication.class, args);
 		Environment env = context.getEnvironment();
@@ -84,6 +92,8 @@ public class AmosTzsApplication {
 	public void initMqtt() throws MqttException {
 		emqKeeper.getMqttClient().subscribe("/idx/idx_biz_carcyl_unit_inspect", 1, carcylUnitInspectMqTtlListener);
 		emqKeeper.getMqttClient().subscribe("/tm/tz_base_enterprise_info", 1, baseEnterpriseMqTtlListener);
+		emqKeeper.getMqttClient().subscribe("/tz/privilege_company_add_update",1, privilegeCompanyUpdateAddListener);
+		emqKeeper.getMqttClient().subscribe("/tz/privilege_company_delete",1, privilegeCompanyDeleteListener);
 //		emqKeeper.getMqttClient().subscribe("topic_mqtt_exam", 1, examMqTtlListener);
 //		emqKeeper.getMqttClient().subscribe("topic_mqtt_exam_record", 1, examMqTtRecordListener);
 	}

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/TzBaseEnterpriseInfoController.java

@@ -9,6 +9,8 @@ import com.yeejoin.amos.boot.module.tzs.api.dto.TzBaseEnterpriseInfoDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.PageParam;
 import com.yeejoin.amos.boot.module.tzs.api.entity.TzBaseEnterpriseInfo;
 import com.yeejoin.amos.boot.module.tzs.api.service.ITzBaseEnterpriseInfoService;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.apache.commons.lang3.StringUtils;
@@ -172,4 +174,14 @@ public class TzBaseEnterpriseInfoController {
 		return ResponseHelper.buildResponse(iTzBaseEnterpriseInfoService.selectByUseUnit(useUnit));
 	}
 
+	/**
+	 * 将监管系统全量用户导入 业务企业表 和 平台企业表
+	 * @return OK
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@RequestMapping(value = "/syncUnitData", method = RequestMethod.GET)
+	@ApiOperation(httpMethod = "GET", value = "同步企业信息", notes = "同步企业信息")
+	public ResponseModel<String> syncUnitData(){
+		return ResponseHelper.buildResponse(iTzBaseEnterpriseInfoService.syncEnterpriseInfo());
+	}
 }

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/listener/PrivilegeCompanyDeleteListener.java

+package com.yeejoin.amos.boot.module.tzs.biz.listener;
+
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.tzs.biz.utils.RedisUtil;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+import org.typroject.tyboot.component.emq.EmqxListener;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
+
+@Component
+@Slf4j
+public class PrivilegeCompanyDeleteListener extends EmqxListener {
+
+    @Autowired
+    RedisUtil redisUtil;
+
+    @Value("${admin.product}")
+    String product;
+
+    @Value("${admin.appkey}")
+    String appkey;
+
+
+    @Override
+    public void processMessage(String s, MqttMessage message) throws Exception {
+        System.out.println(message);
+        JSONObject object = null;
+        try {
+            object = JSONObject.parseObject(message.toString());
+        } catch (Exception e) {
+            throw new Exception("公司同步消息解析失败");
+        }
+        RequestContext.setAppKey(appkey);
+        RequestContext.setProduct(product);
+        RequestContext.setToken(String.valueOf(redisUtil.get("platform_token")));
+
+        //通过sequence_nbr删除企业
+        Privilege.companyClient.deleteCompany(object.getString("sequence_nbr"));
+    }
+}

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/listener/PrivilegeCompanyUpdateAddListener.java

+package com.yeejoin.amos.boot.module.tzs.biz.listener;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.tzs.biz.utils.DesUtil;
+import com.yeejoin.amos.boot.module.tzs.biz.utils.RedisUtil;
+import com.yeejoin.amos.component.feign.model.FeignClientResult;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.ApplicationModel;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
+import com.yeejoin.amos.feign.privilege.model.RoleModel;
+import lombok.extern.slf4j.Slf4j;
+import org.bouncycastle.pqc.math.linearalgebra.PolynomialRingGF2;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+import org.typroject.tyboot.component.emq.EmqxListener;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Component
+@Slf4j
+public class PrivilegeCompanyUpdateAddListener extends EmqxListener {
+
+    @Autowired
+    RedisUtil redisUtil;
+
+    @Value("${admin.product}")
+    String product;
+
+    @Value("${admin.appkey}")
+    String appkey;
+
+    @Override
+    public void processMessage(String s, MqttMessage message) throws Exception {
+        System.out.println(message);
+        JSONObject object = null;
+        try {
+            object = JSONObject.parseObject(message.toString());
+        } catch (Exception e) {
+            throw new Exception("公司同步消息解析失败");
+        }
+        RequestContext.setAppKey(appkey);
+        RequestContext.setProduct(product);
+        RequestContext.setToken(String.valueOf(redisUtil.get("platform_token")));
+
+        //获取parent_id
+        Long parent_id = 0L;
+        Collection<CompanyModel> companyModels = Privilege.companyClient.companyTreeWithoutAuth().getResult();
+        List<CompanyModel> companyList = new ArrayList<>();
+        recursion(companyModels,companyList);
+
+        //判断库中company是否重复
+        CompanyModel companyModel = Privilege.companyClient.seleteOne(Long.valueOf(object.getString("sequence_nbr"))).getResult();
+
+        if (companyModel == null ) {
+            companyModel = new CompanyModel();
+            companyModel.setSequenceNbr(object.getLong("sequence_nbr"));
+            companyModel.setCompanyName(object.getString("unit_name"));
+            companyModel.setCompanyCode(object.getString("unit_code"));
+            companyModel.setParentId(parent_id);
+            companyModel.setLevel("company");
+            companyModel.setAgencyCode("tzs");
+            companyModel.setCompanyType("生产单位");
+            companyModel.setAddress(object.getString("reg_address"));
+            Privilege.companyClient.create(companyModel);
+        }else{
+        //为空或者是更新
+        companyModel.setSequenceNbr(object.getLong("sequence_nbr"));
+        companyModel.setCompanyName(object.getString("unit_name"));
+        companyModel.setCompanyCode(object.getString("unit_code"));
+        companyModel.setParentId(parent_id);
+        companyModel.setLevel("company");
+        companyModel.setAgencyCode("tzs");
+        companyModel.setCompanyType("生产单位");
+        companyModel.setAddress(object.getString("reg_address"));
+        Privilege.companyClient.update(companyModel,object.getLong("sequence_nbr"));
+        }
+    }
+
+    public List recursion(Collection feign,List ids){
+        if(feign == null){
+            return ids;
+        }
+        Iterator iter = feign.iterator();
+        while(iter.hasNext()){
+            String json = JSON.toJSONString(iter.next());
+            CompanyModel companyModel =  JSON.parseObject(json,CompanyModel.class);
+            if(!companyModel.getLevel().equals("company")){
+                ids.add(String.valueOf(companyModel.getSequenceNbr()));
+            }
+            recursion(companyModel.getChildren(),ids);
+        }
+        return ids;
+    }
+}

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/SpeUseUnitServiceImpl.java

+package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yeejoin.amos.boot.module.tzs.api.dto.SpeUseUnitDto;
+import com.yeejoin.amos.boot.module.tzs.api.entity.SpeUseUnit;
+import com.yeejoin.amos.boot.module.tzs.api.mapper.SpeUseUnitMapper;
+import com.yeejoin.amos.boot.module.tzs.api.service.ISpeUseUnitService;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+/**
+ * 使用单位 服务实现类
+ *
+ * @author duanwei
+ * @date 2022-09-08
+ */
+@Service
+public class SpeUseUnitServiceImpl extends BaseService<SpeUseUnitDto, SpeUseUnit, SpeUseUnitMapper> implements ISpeUseUnitService {
+
+}

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/TzBaseEnterpriseInfoServiceImpl.java

 package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
 
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -9,10 +10,13 @@ import com.yeejoin.amos.boot.module.tzs.api.dto.EquEnterDto;
 import com.yeejoin.amos.boot.module.tzs.api.dto.TzBaseEnterpriseInfoDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.BaseUnitLicence;
 import com.yeejoin.amos.boot.module.tzs.api.entity.PageParam;
+import com.yeejoin.amos.boot.module.tzs.api.entity.SpeUseUnit;
 import com.yeejoin.amos.boot.module.tzs.api.entity.TzBaseEnterpriseInfo;
 import com.yeejoin.amos.boot.module.tzs.api.mapper.TzBaseEnterpriseInfoMapper;
 import com.yeejoin.amos.boot.module.tzs.api.service.IBaseUnitLicenceService;
+import com.yeejoin.amos.boot.module.tzs.api.service.ISpeUseUnitService;
 import com.yeejoin.amos.boot.module.tzs.api.service.ITzBaseEnterpriseInfoService;
+import com.yeejoin.amos.boot.module.tzs.biz.utils.RedisUtil;
 import com.yeejoin.amos.boot.module.tzs.flc.api.dto.RegUnitIcDto;
 import com.yeejoin.amos.boot.module.tzs.flc.api.entity.RegUnitIc;
 import com.yeejoin.amos.boot.module.tzs.flc.biz.service.impl.RegUnitIcServiceImpl;
@@ -20,13 +24,15 @@ import com.yeejoin.amos.component.feign.model.FeignClientResult;
 import com.yeejoin.amos.feign.privilege.Privilege;
 import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 
-import java.util.ArrayList;
-import java.util.List;
+import java.util.*;
 
 
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
+import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 
 /**
@@ -41,6 +47,15 @@ public class TzBaseEnterpriseInfoServiceImpl
 		implements ITzBaseEnterpriseInfoService {
 
 	@Autowired
+	RedisUtil redisUtil;
+
+	@Value("${admin.product}")
+	String product;
+
+	@Value("${admin.appkey}")
+	String appkey;
+
+	@Autowired
 	private TzBaseEnterpriseInfoMapper tzBaseEnterpriseInfoMapper;
 
 	@Autowired
@@ -52,6 +67,9 @@ public class TzBaseEnterpriseInfoServiceImpl
 	@Autowired
 	private IBaseUnitLicenceService iBaseUnitLicenceService;
 
+	@Autowired
+	private ISpeUseUnitService speUseUnitService;
+
 	@Override
 	public List<EquEnterDto> getInfo(String sequenceNbr) {
 		return tzBaseEnterpriseInfoMapper.getInfo(sequenceNbr);
@@ -133,4 +151,92 @@ public class TzBaseEnterpriseInfoServiceImpl
 
 	}
 
+	@Override
+	public String syncEnterpriseInfo() {
+		RequestContext.setAppKey(appkey);
+		RequestContext.setProduct(product);
+		RequestContext.setToken(String.valueOf(redisUtil.get("platform_token")));
+
+		List<TzBaseEnterpriseInfo> baseEnterpriseInfoList = new ArrayList<>();
+
+		//获取平台企业表企业名称及sequence_code，并装入map中
+		Collection<CompanyModel> companyModels = Privilege.companyClient.queryAgencyTree(null).getResult();
+		Map<String,Long> companyMap = new HashMap<>();
+
+		getCompanyInfoMap(companyModels,companyMap);
+
+		int size = 500;
+		int total = speUseUnitService.count();
+		int current = total/size+1;
+		for(int i = 0; i<current; i++){
+			IPage<SpeUseUnit> page = new Page<>();
+			page.setCurrent(i);
+			page.setSize(size);
+			List<SpeUseUnit> speUseUnitList = speUseUnitService.page(page).getRecords();
+			for (SpeUseUnit speUseUnit : speUseUnitList) {
+
+				if(!speUseUnit.getAuditOrgName().equals("西安市工商局经开分局") && !speUseUnit.getAuditOrgName().equals("碑林区市场监督管理局")){
+					continue;
+				}
+				if(ValidationUtil.isEmpty(companyMap.get(speUseUnit.getAuditOrgName()))){
+					continue;
+				}
+
+				TzBaseEnterpriseInfo baseEnterpriseInfo = new TzBaseEnterpriseInfo();
+				baseEnterpriseInfo.setUseUnit(speUseUnit.getName());
+				baseEnterpriseInfo.setUseCode(speUseUnit.getCerCode());
+				baseEnterpriseInfo.setUnitType(speUseUnit.getUnitNature());
+				baseEnterpriseInfo.setRegistrationAuthority(speUseUnit.getCerRegiOrg());
+				baseEnterpriseInfo.setProvince(speUseUnit.getOffiAddrProvince());
+				baseEnterpriseInfo.setCity(speUseUnit.getOffiAddrCity());
+				baseEnterpriseInfo.setDistrict(speUseUnit.getOffiAddrArea());
+				baseEnterpriseInfo.setStreet(speUseUnit.getOffiAddrStreet());
+				baseEnterpriseInfo.setCommunity(speUseUnit.getOffiAddrVillage());
+				baseEnterpriseInfo.setAddress(speUseUnit.getOffiAddrDetail());
+				baseEnterpriseInfo.setLegalPerson(speUseUnit.getLegalPerson());
+				baseEnterpriseInfo.setLegalPhone(speUseUnit.getLegalPersonPhone());
+				baseEnterpriseInfo.setUseContact(speUseUnit.getResponPerson());
+				baseEnterpriseInfo.setContactPhone(speUseUnit.getResponPersonPhone());
+				baseEnterpriseInfo.setIndustry(speUseUnit.getIndustry());
+				baseEnterpriseInfo.setSuperviseOrgName(speUseUnit.getAuditOrgName());
+				baseEnterpriseInfo.setSuperviseOrgCode(speUseUnit.getAuditOrgCode());
+				baseEnterpriseInfo.setOperatingStatus(String.valueOf(speUseUnit.getStatus()));
+				baseEnterpriseInfo.setUnitType("使用单位");
+				baseEnterpriseInfoList.add(baseEnterpriseInfo);
+
+				CompanyModel companyModel = new CompanyModel();
+				companyModel.setCompanyName(speUseUnit.getName());
+				companyModel.setCompanyCode(speUseUnit.getCerCode());
+				companyModel.setLevel("company");
+				companyModel.setAgencyCode("tzs");
+				companyModel.setCompanyType("使用单位");
+				companyModel.setAddress(speUseUnit.getOffiAddrDetail());
+				companyModel.setParentId(companyMap.get(speUseUnit.getAuditOrgName()));
+
+				//保存平台和业务的企业信息
+				try {
+					Privilege.companyClient.create(companyModel);
+					this.save(baseEnterpriseInfo);
+				} catch (Exception e) {
+					System.out.println(e.getMessage());
+				}
+			}
+		}
+		return "ok";
+	}
+
+	public Map<String, Long> getCompanyInfoMap(Collection companyModels,Map<String, Long> map){
+		if(companyModels == null){
+			return map;
+		}
+		Iterator iter = companyModels.iterator();
+		while(iter.hasNext()){
+			String json = JSON.toJSONString(iter.next());
+			CompanyModel companyModel =  JSON.parseObject(json,CompanyModel.class);
+			map.put(companyModel.getCompanyName(),companyModel.getSequenceNbr());
+			getCompanyInfoMap(companyModel.getChildren(),map);
+		}
+		return map;
+	}
+
 }