Skip to content

A
amos-boot-biz
Commit 07232074 authored by zhangyingbin's avatar zhangyingbin
Browse files
Options

修改使用单位同步企业一次性接口

parent 6ff7e386
Hide whitespace changes
Inline Side-by-side
Showing with 101 additions and 83 deletions
amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/TzBaseEnterpriseInfoServiceImpl.java
View file @ 07232074
...@@ -22,6 +22,7 @@ import com.yeejoin.amos.boot.module.tzs.api.service.ITzBaseEnterpriseInfoService ...@@ -22,6 +22,7 @@ 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.biz.utils.RedisUtil;
import com.yeejoin.amos.boot.module.tzs.flc.api.dto.RegUnitIcDto; 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.api.entity.RegUnitIc;
import com.yeejoin.amos.boot.module.tzs.flc.api.feign.AccessFeignService;
import com.yeejoin.amos.boot.module.tzs.flc.biz.service.impl.RegUnitIcServiceImpl; import com.yeejoin.amos.boot.module.tzs.flc.biz.service.impl.RegUnitIcServiceImpl;
import com.yeejoin.amos.component.feign.model.FeignClientResult; import com.yeejoin.amos.component.feign.model.FeignClientResult;
import com.yeejoin.amos.feign.privilege.Privilege; import com.yeejoin.amos.feign.privilege.Privilege;
...@@ -73,6 +74,9 @@ public class TzBaseEnterpriseInfoServiceImpl ...@@ -73,6 +74,9 @@ public class TzBaseEnterpriseInfoServiceImpl
@Autowired @Autowired
private ISpeUseUnitService speUseUnitService; private ISpeUseUnitService speUseUnitService;
@Autowired
private AccessFeignService accessFeignService;
@Override @Override
public List<EquEnterDto> getInfo(String sequenceNbr) { public List<EquEnterDto> getInfo(String sequenceNbr) {
return tzBaseEnterpriseInfoMapper.getInfo(sequenceNbr); return tzBaseEnterpriseInfoMapper.getInfo(sequenceNbr);
...@@ -173,106 +177,120 @@ public class TzBaseEnterpriseInfoServiceImpl ...@@ -173,106 +177,120 @@ public class TzBaseEnterpriseInfoServiceImpl
int current = total/size; int current = total/size;
current = current + 1; current = current + 1;
for(int i = 1; i<=current; i++){ for(int i = 1; i<=current; i++){
System.out.println("-----------------------------------------------------------------------");
System.out.println(i);
System.out.println("-----------------------------------------------------------------------");
IPage<SpeUseUnit> page = new Page<>(); IPage<SpeUseUnit> page = new Page<>();
page.setCurrent(i); page.setCurrent(i);
page.setSize(size); page.setSize(size);
List<SpeUseUnit> speUseUnitList = speUseUnitService.page(page).getRecords(); List<SpeUseUnit> speUseUnitList = speUseUnitService.page(page).getRecords();
for (SpeUseUnit speUseUnit : speUseUnitList) { for (SpeUseUnit speUseUnit : speUseUnitList) {
if(speUseUnit.getAuditOrgName()==null)
{
System.out.println();
}
if(!"西安市工商局经开分局".equals(speUseUnit.getAuditOrgName()) && !"碑林区市场监督管理局".equals(speUseUnit.getAuditOrgName())){
continue;
}
if(ValidationUtil.isEmpty(companyMap.get(speUseUnit.getAuditOrgName()))){
continue;
}
CompanyModel companyPrivilegeModel = Privilege.companyClient.queryByCompanyName(speUseUnit.getName()).getResult(); CompanyModel companyPrivilegeModel = Privilege.companyClient.queryByCompanyName(speUseUnit.getName()).getResult();
QueryWrapper<TzBaseEnterpriseInfo> queryWrapper = new QueryWrapper<TzBaseEnterpriseInfo>(); QueryWrapper<TzBaseEnterpriseInfo> queryWrapper = new QueryWrapper<TzBaseEnterpriseInfo>();
queryWrapper.eq("use_unit",speUseUnit.getName()); queryWrapper.eq("use_unit",speUseUnit.getName());
TzBaseEnterpriseInfo tzBaseEnterprisePrivilegeInfo = this.getOne(queryWrapper); TzBaseEnterpriseInfo tzBaseEnterprisePrivilegeInfo = this.getOne(queryWrapper);
TzBaseEnterpriseInfo baseEnterpriseInfo = new TzBaseEnterpriseInfo(); Map<String, Object> resultMap = accessFeignService.getData(speUseUnit.getCerCode()).getResult();
baseEnterpriseInfo.setUseUnit(speUseUnit.getName());
baseEnterpriseInfo.setUseCode(speUseUnit.getCerCode()); if (ValidationUtil.isEmpty(resultMap)){
baseEnterpriseInfo.setUnitType(speUseUnit.getUnitNature()); if(!ValidationUtil.isEmpty(companyPrivilegeModel)){
baseEnterpriseInfo.setRegistrationAuthority(speUseUnit.getCerRegiOrg()); Privilege.companyClient.deleteCompany(String.valueOf(companyPrivilegeModel.getSequenceNbr()));
baseEnterpriseInfo.setProvince(speUseUnit.getOffiAddrProvince()); }
baseEnterpriseInfo.setCity(speUseUnit.getOffiAddrCity()); if (!ValidationUtil.isEmpty(tzBaseEnterprisePrivilegeInfo)) {
baseEnterpriseInfo.setDistrict(speUseUnit.getOffiAddrArea()); this.deleteBySeq(tzBaseEnterprisePrivilegeInfo.getSequenceNbr());
baseEnterpriseInfo.setStreet(speUseUnit.getOffiAddrStreet()); }
baseEnterpriseInfo.setCommunity(speUseUnit.getOffiAddrVillage()); }else {
baseEnterpriseInfo.setAddress(speUseUnit.getOffiAddrDetail()); CompanyModel privilegeCompanyModel = Privilege.companyClient.queryByCompanyName(String.valueOf(resultMap.get("registration_authority"))).getResult();
baseEnterpriseInfo.setLegalPerson(speUseUnit.getLegalPerson()); CompanyModel companyModel = new CompanyModel();
baseEnterpriseInfo.setLegalPhone(speUseUnit.getLegalPersonPhone()); companyModel.setCompanyName(speUseUnit.getName());
baseEnterpriseInfo.setUseContact(speUseUnit.getResponPerson()); companyModel.setCompanyCode(speUseUnit.getCerCode());
baseEnterpriseInfo.setContactPhone(speUseUnit.getResponPersonPhone()); companyModel.setLevel("company");
baseEnterpriseInfo.setIndustry(speUseUnit.getIndustry()); companyModel.setAgencyCode("tzs");
baseEnterpriseInfo.setSuperviseOrgName(speUseUnit.getAuditOrgName()); companyModel.setCompanyType("使用单位");
baseEnterpriseInfo.setSuperviseOrgCode(speUseUnit.getAuditOrgCode()); companyModel.setAddress(String.valueOf(resultMap.get("address")));
baseEnterpriseInfo.setOperatingStatus(String.valueOf(speUseUnit.getStatus())); companyModel.setParentId(privilegeCompanyModel.getSequenceNbr());
baseEnterpriseInfo.setUnitType("使用单位");
baseEnterpriseInfo.setSuperviseOrgCode(companyMap.get(speUseUnit.getAuditOrgName()).getOrgCode());
baseEnterpriseInfoList.add(baseEnterpriseInfo);
String area = String.valueOf(resultMap.get("area"));
CompanyModel companyModel = new CompanyModel(); String province = "";
String address = speUseUnit.getOffiAddrProvince()+speUseUnit.getOffiAddrCity()+speUseUnit.getOffiAddrArea()+speUseUnit.getOffiAddrStreet()+speUseUnit.getOffiAddrVillage()+speUseUnit.getOffiAddrDetail(); if(area.contains("省")){
companyModel.setCompanyName(speUseUnit.getName()); province = area.substring(0,area.indexOf("省")+1);
companyModel.setCompanyCode(speUseUnit.getCerCode());
companyModel.setLevel("company");
companyModel.setAgencyCode("tzs");
companyModel.setCompanyType("使用单位");
companyModel.setAddress(address);
companyModel.setParentId(companyMap.get(speUseUnit.getAuditOrgName()).getParentId());
//保存平台和业务的企业信息
try {
if (tzBaseEnterprisePrivilegeInfo == null && companyPrivilegeModel == null) {
//当企业表、平台表 中没有时
this.save(baseEnterpriseInfo);
Privilege.companyClient.create(companyModel);
} else if(tzBaseEnterprisePrivilegeInfo == null){
//企业表没有，平台表有
if(!companyPrivilegeModel.getCompanyType().contains(companyModel.getCompanyType())){
companyPrivilegeModel.setCompanyType(companyPrivilegeModel.getCompanyType()+","+companyModel.getCompanyType());
Privilege.companyClient.update(companyPrivilegeModel,companyPrivilegeModel.getSequenceNbr());
}
this.save(baseEnterpriseInfo);
} else if(companyPrivilegeModel == null){
//平台表没有，企业表有
if(!tzBaseEnterprisePrivilegeInfo.getUnitType().contains(baseEnterpriseInfo.getUnitType())){
tzBaseEnterprisePrivilegeInfo.setUnitType(tzBaseEnterprisePrivilegeInfo.getUnitType()+","+baseEnterpriseInfo.getUnitType());
this.updateById(tzBaseEnterprisePrivilegeInfo);
}
Privilege.companyClient.create(companyModel);
} }
else { String city = "";
//企业表有 平台表有 if(area.contains("市")){
if(!companyPrivilegeModel.getCompanyType().contains(companyModel.getCompanyType())){ city = area.substring(province.length(),area.indexOf("市")+1);
companyPrivilegeModel.setCompanyType(companyPrivilegeModel.getCompanyType()+","+companyModel.getCompanyType()); }
Privilege.companyClient.update(companyPrivilegeModel,companyPrivilegeModel.getSequenceNbr()); String district = area.substring(city.length()+province.length());
TzBaseEnterpriseInfo baseEnterpriseInfo = new TzBaseEnterpriseInfo();
baseEnterpriseInfo.setUseUnit(speUseUnit.getName());
baseEnterpriseInfo.setUseCode(speUseUnit.getCerCode());
baseEnterpriseInfo.setUnitType("使用单位");
baseEnterpriseInfo.setRegistrationAuthority(String.valueOf(resultMap.get("registration_authority")));
baseEnterpriseInfo.setProvince(province);
baseEnterpriseInfo.setCity(city);
baseEnterpriseInfo.setDistrict(district);
baseEnterpriseInfo.setStreet(String.valueOf(resultMap.get("district")));
baseEnterpriseInfo.setCommunity(String.valueOf(resultMap.get("community")));
baseEnterpriseInfo.setAddress(String.valueOf(resultMap.get("address")));
baseEnterpriseInfo.setLegalPerson(String.valueOf(resultMap.get("legalPeople")));
baseEnterpriseInfo.setIndustry(String.valueOf(resultMap.get("industry")));
baseEnterpriseInfo.setSuperviseOrgName(String.valueOf(resultMap.get("registration_authority")));
baseEnterpriseInfo.setSuperviseOrgCode(privilegeCompanyModel.getOrgCode());
baseEnterpriseInfo.setOperatingStatus(String.valueOf(resultMap.get("operating_status")));
baseEnterpriseInfo.setUnitType("使用单位");
baseEnterpriseInfoList.add(baseEnterpriseInfo);
//保存平台和业务的企业信息
try {
if (tzBaseEnterprisePrivilegeInfo == null && companyPrivilegeModel == null) {
//当企业表、平台表 中没有时
this.save(baseEnterpriseInfo);
Privilege.companyClient.create(companyModel);
} else if(tzBaseEnterprisePrivilegeInfo == null){
//企业表没有，平台表有
if(!companyPrivilegeModel.getCompanyType().contains(companyModel.getCompanyType())){
companyModel.setCompanyType(companyPrivilegeModel.getCompanyType()+","+companyModel.getCompanyType());
Privilege.companyClient.update(companyModel,companyPrivilegeModel.getSequenceNbr());
}
this.save(baseEnterpriseInfo);
} else if(companyPrivilegeModel == null){
//平台表没有，企业表有
if(!tzBaseEnterprisePrivilegeInfo.getUnitType().contains(baseEnterpriseInfo.getUnitType())){
baseEnterpriseInfo.setUnitType(tzBaseEnterprisePrivilegeInfo.getUnitType()+","+baseEnterpriseInfo.getUnitType());
this.updateById(baseEnterpriseInfo);
}
Privilege.companyClient.create(companyModel);
} }
if(!tzBaseEnterprisePrivilegeInfo.getUnitType().contains(baseEnterpriseInfo.getUnitType())){ else {
tzBaseEnterprisePrivilegeInfo.setUnitType(tzBaseEnterprisePrivilegeInfo.getUnitType()+","+baseEnterpriseInfo.getUnitType()); //企业表有 平台表有
this.updateById(tzBaseEnterprisePrivilegeInfo); if(!companyPrivilegeModel.getCompanyType().contains(companyModel.getCompanyType())){
companyModel.setCompanyType(companyPrivilegeModel.getCompanyType()+","+companyModel.getCompanyType());
Privilege.companyClient.update(companyModel,companyPrivilegeModel.getSequenceNbr());
}
if(!tzBaseEnterprisePrivilegeInfo.getUnitType().contains(baseEnterpriseInfo.getUnitType())){
baseEnterpriseInfo.setUnitType(tzBaseEnterprisePrivilegeInfo.getUnitType()+","+baseEnterpriseInfo.getUnitType());
this.updateById(baseEnterpriseInfo);
}
} }
} } catch (Exception e) {
} catch (Exception e) {
if(!e.getMessage().equals("重复的公司名称."))
{
System.out.println(e.getMessage());
}else
{
System.out.println(e.getMessage()); System.out.println(e.getMessage());
} }
} }
// if(ValidationUtil.isEmpty(companyMap.get(speUseUnit.getAuditOrgName()))){
// continue;
// }
} }
} }
return "ok"; return "ok";
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment