Commit 292f9c6e authored by zhangyingbin's avatar zhangyingbin

修改许可信息同步数据集成消息接口

parent 193c4f32
......@@ -69,7 +69,8 @@ public class PrivilegeCompanyUpdateAddListener extends EmqxListener {
TzBaseEnterpriseInfo tzBaseEnterpriseInfo = new TzBaseEnterpriseInfo();
tzBaseEnterpriseInfo.setSequenceNbr(object.getLong("sequence_nbr"));
tzBaseEnterpriseInfo.setUseUnitCertificate(object.getString("cert_type"));
tzBaseEnterpriseInfo.setAddress(object.getString("reg_address"));
tzBaseEnterpriseInfo.setUnitType(object.getString("cert_type"));
tzBaseEnterpriseInfo.setUseCode(object.getString("unit_code"));
tzBaseEnterpriseInfo.setUseUnit(object.getString("unit_name"));
tzBaseEnterpriseInfo.setProvince(object.getString("province"));
......@@ -83,33 +84,40 @@ public class PrivilegeCompanyUpdateAddListener extends EmqxListener {
//包含
if(orgName.contains("高新")){
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get("西安市工商局高新分局").getOrgCode());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get("西安市工商局高新分局").getCompanyName());
companyModel.setParentId(companyMap.get("西安市工商局高新分局").getSequenceNbr());
}else if(orgName.contains("曲江")){
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get("西安市工商局曲江分局").getOrgCode());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get("西安市工商局曲江分局").getCompanyName());
companyModel.setParentId(companyMap.get("西安市工商局曲江分局").getSequenceNbr());
}else if(orgName.contains("经开")){
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get("西安市工商局经开分局").getOrgCode());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get("西安市工商局经开分局").getCompanyName());
companyModel.setParentId(companyMap.get("西安市工商局经开分局").getSequenceNbr());
}else if(orgName.contains("航天")){
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get("西安市工商局航空分局").getOrgCode());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get("西安市工商局航空分局").getCompanyName());
companyModel.setParentId(companyMap.get("西安市工商局航空分局").getSequenceNbr());
}else if(orgName.contains("浐灞")){
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get("西安市工商局浐灞分局").getOrgCode());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get("西安市工商局浐灞分局").getCompanyName());
companyModel.setParentId(companyMap.get("西安市工商局浐灞分局").getSequenceNbr());
}else if(orgName.contains("港务")){
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get("西安市工商局港务分局").getOrgCode());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get("西安市工商局港务分局").getCompanyName());
companyModel.setParentId(companyMap.get("西安市工商局港务分局").getSequenceNbr());
}else if(object.getString("district").contains("泾河")){
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get("泾河新城分局").getOrgCode());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get("泾河新城分局").getCompanyName());
companyModel.setParentId(companyMap.get("泾河新城分局").getSequenceNbr());
} else{
tzBaseEnterpriseInfo.setSuperviseOrgCode("0");
companyModel.setParentId(0L);
return;
}
}else {
//不包含
tzBaseEnterpriseInfo.setSuperviseOrgCode(companyMap.get(orgName).getOrgCode());
companyModel.setParentId(companyMap.get(orgName).getSequenceNbr());
tzBaseEnterpriseInfo.setSuperviseOrgName(companyMap.get(orgName).getCompanyName());
}
......@@ -127,7 +135,7 @@ public class PrivilegeCompanyUpdateAddListener extends EmqxListener {
companyModel.setCompanyCode(object.getString("unit_code"));
companyModel.setLevel("company");
companyModel.setAgencyCode("tzs");
companyModel.setCompanyType("生产单位");
companyModel.setCompanyType(object.getString("cert_type"));
companyModel.setAddress(object.getString("reg_address"));
......
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