优化diamante

java110

2021-10-19 b278a4b743d0cf45fd0b42bc78ff42f4e1124baf

 service-job/src/main/java/com/java110/job/adapt/hcGov/staff/AddStaffToHcGovAdapt.java

@@ -111,7 +111,7 @@
        communityMemberDto.setMemberId(SoreId);
        List<CommunityMemberDto> communityMemberDtos = communityInnerServiceSMOImpl.getCommunityMembers(communityMemberDto);
        JSONArray extCommunityId = new JSONArray();
        //
        //获取商户对应所有小区的外部编码
        getCommunityExtId(communityMemberDtos, extCommunityId);

        if (extCommunityId == null || extCommunityId.size() < 1) {
@@ -131,10 +131,10 @@
            ACTION_TYPE=HcGovConstant.ADD_COMPANY_ACTION;
        }

        body.put("staffInfo", getCarateStaffInfo(userPo));
        body.put("staffInfo", getCarateStaffInfo(userPo,extCompanyId));

        JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId.getString(0), ACTION_TYPE, HcGovConstant.COMMUNITY_SECURE);
        baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, extCommunityId.getString(0), SoreId, HcGovConstant.COMMUNITY_SECURE);
        JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, "622021090866160001", ACTION_TYPE, HcGovConstant.COMMUNITY_SECURE);
        baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, "622021090866160001", userPo.getUserId(), HcGovConstant.COMMUNITY_SECURE);
    }

    public void getCommunityExtId(List<CommunityMemberDto> communityMemberDtos, JSONArray extCommunityId) {
@@ -162,15 +162,15 @@
        }
    }

    private JSONObject getCarateStaffInfo(UserPo userPo) {
    private JSONObject getCarateStaffInfo(UserPo userPo,String extCompanyId) {

        String orgName = "";
        String relCd = "";
        JSONObject staffInfo = new JSONObject();

        staffInfo.put("PersonName", userPo.getName());
        staffInfo.put("PersonTel", userPo.getTel());
        staffInfo.put("PersonSex", userPo.getSex());
        staffInfo.put("personName", userPo.getName());
        staffInfo.put("personTel", userPo.getTel());
        staffInfo.put("personSex", userPo.getSex());
        staffInfo.put("prePersonName", userPo.getName());

        OrgStaffRelDto orgStaffRelDto = new OrgStaffRelDto();
@@ -187,6 +187,9 @@
        }
        staffInfo.put("govOrgName", orgName);
        staffInfo.put("relCd", relCd);
        if(!StringUtil.isEmpty(extCompanyId)){
            staffInfo.put("extCompanyId",extCompanyId);
        }

        return staffInfo;
    }