优化代码

1098226878

2021-09-09 42e2348b62b2c109a5c68dec95bb7fc3619ff035

优化代码

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

@@ -53,6 +53,13 @@
    //修改业主
    public static final String EDIT_OWNER_ACTION = "EDIT_OWNER";

    //添加员工
    public static final String ADD_STAFF_ACTION = "ADD_STAFF";
    //修改员工
    public static final String EDIT_STAFF_ACTION = "EDIT_STAFF";
    //添加商户company
    public static final String ADD_COMPANY_ACTION = "ADD_COMPANY";

    //添加位置
    public static final String ADD_LOCATION_ACTION = "ADD_LOCATION";
    //修改位置
@@ -67,4 +74,10 @@
        header.put("sign",newSign);
    }

    //商户属性编码
    public static final String STORE_ATTR_ARTIFICIALPERSON = "100201903001"; //企业法人
    public static final String STORE_ATTR_REGISTERTIME = "100201903003"; //成立日期
    public static final String STORE_ATTR_IDCARD = "100201903004"; //营业执照


}

 service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/BaseHcGovSendAsyn.java

@@ -1,5 +1,6 @@
package com.java110.job.adapt.hcGov.asyn;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;

public interface BaseHcGovSendAsyn {

 service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java

@@ -1,5 +1,6 @@
package com.java110.job.adapt.hcGov.asyn.impl;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.reportData.ReportDataHeaderDto;

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

New file
@@ -0,0 +1,204 @@
/*
 * Copyright 2017-2020 吴学文 and java110 team.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.java110.job.adapt.hcGov.staff;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.dto.CommunityMemberDto;
import com.java110.dto.community.CommunityAttrDto;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.org.OrgDto;
import com.java110.dto.org.OrgStaffRelDto;
import com.java110.dto.store.StoreAttrDto;
import com.java110.dto.store.StoreUserDto;
import com.java110.entity.order.Business;
import com.java110.intf.community.ICommunityInnerServiceSMO;
import com.java110.intf.store.IStoreAttrInnerServiceSMO;
import com.java110.intf.store.IStoreInnerServiceSMO;
import com.java110.intf.user.IOrgInnerServiceSMO;
import com.java110.intf.user.IOrgStaffRelInnerServiceSMO;
import com.java110.job.adapt.DatabusAdaptImpl;
import com.java110.job.adapt.hcGov.HcGovConstant;
import com.java110.job.adapt.hcGov.asyn.BaseHcGovSendAsyn;
import com.java110.po.user.UserPo;
import com.java110.utils.util.BeanConvertUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * 新增业主信息同步HC政务接口
 * <p>
 * 接口协议地址： https://gitee.com/java110/microCommunityInformation/tree/master/info-doc#1%E6%A5%BC%E6%A0%8B%E4%B8%8A%E4%BC%A0
 *
 * @desc add by 吴学文 16:20
 */
@Component(value = "addStaffToHcGovAdapt")
public class AddStaffToHcGovAdapt extends DatabusAdaptImpl {

    @Autowired
    private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
    @Autowired
    private BaseHcGovSendAsyn baseHcGovSendAsynImpl;
    @Autowired
    private IStoreInnerServiceSMO storeInnerServiceSMOImpl;
    @Autowired
    private IStoreAttrInnerServiceSMO storeAttrInnerServiceSMOImpl;
    @Autowired
    private IOrgStaffRelInnerServiceSMO orgStaffRelInnerServiceSMOImpl;
    @Autowired
    private IOrgInnerServiceSMO orgInnerServiceSMOImpl;

    /**
     * @param business   当前处理业务
     * @param businesses 所有业务信息
     */
    @Override
    public void execute(Business business, List<Business> businesses) {
        JSONObject data = business.getData();
        if (data.containsKey(UserPo.class.getSimpleName())) {
            Object bObj = data.get(UserPo.class.getSimpleName());
            JSONArray businessUserPo = null;
            if (bObj instanceof JSONObject) {
                businessUserPo = new JSONArray();
                businessUserPo.add(bObj);
            } else if (bObj instanceof List) {
                businessUserPo = JSONArray.parseArray(JSONObject.toJSONString(bObj));
            } else {
                businessUserPo = (JSONArray) bObj;
            }
            //JSONObject businessOwnerCar = data.getJSONObject("businessOwnerCar");
            for (int bUserIndex = 0; bUserIndex < businessUserPo.size(); bUserIndex++) {
                JSONObject businessUserCar = businessUserPo.getJSONObject(bUserIndex);
                doAddUser(business, businessUserCar);

            }
        }
    }

    private void doAddUser(Business business, JSONObject businessUserCar) {

        UserPo userPo = BeanConvertUtil.covertBean(businessUserCar, UserPo.class);
        StoreUserDto storeUserDto = new StoreUserDto();
        storeUserDto.setUserId(userPo.getUserId());
        List<StoreUserDto> storeUserDtos = storeInnerServiceSMOImpl.getStoreUserInfo(storeUserDto);
        if (storeUserDtos == null || storeUserDtos.size() < 1) {
            return;
        }
        storeUserDto = storeUserDtos.get(0);
        String artificialPerson = "";
        String registerTime = "";
        String idCard = "";
        String SoreId = storeUserDto.getStoreId();
        JSONObject companyInfo = new JSONObject();
        JSONObject staffInfo = new JSONObject();
        //查询商户属性 企业法人
        StoreAttrDto storeAttrDto = new StoreAttrDto();
        storeAttrDto.setStoreId(SoreId);
        storeAttrDto.setSpecCd(HcGovConstant.STORE_ATTR_ARTIFICIALPERSON);
        List<StoreAttrDto> storeAttrDtos = storeAttrInnerServiceSMOImpl.queryStoreAttrs(storeAttrDto);
        if (storeAttrDtos != null && storeAttrDtos.size() > 0) {
            artificialPerson = storeAttrDtos.get(0).getValue();
        }
        //查询商户属性 成立日期
        storeAttrDto.setStoreId(SoreId);
        storeAttrDto.setSpecCd(HcGovConstant.STORE_ATTR_REGISTERTIME);
        storeAttrDtos = storeAttrInnerServiceSMOImpl.queryStoreAttrs(storeAttrDto);
        if (storeAttrDtos != null && storeAttrDtos.size() > 0) {
            registerTime = storeAttrDtos.get(0).getValue();
        }
        //查询商户属性 营业执照
        storeAttrDto.setStoreId(SoreId);
        storeAttrDto.setSpecCd(HcGovConstant.STORE_ATTR_IDCARD);
        storeAttrDtos = storeAttrInnerServiceSMOImpl.queryStoreAttrs(storeAttrDto);
        if (storeAttrDtos != null && storeAttrDtos.size() > 0) {
            idCard = storeAttrDtos.get(0).getValue();
        }
        companyInfo.put("companyName", storeUserDto.getName());
        companyInfo.put("companyType", "2002");
        companyInfo.put("idCard", idCard);
        companyInfo.put("artificialPerson", artificialPerson);
        companyInfo.put("companyAddress", storeUserDto.getAddress());
        companyInfo.put("registerTime", registerTime);
        companyInfo.put("personName", artificialPerson);
        companyInfo.put("personTel", storeUserDto.getTel());
        companyInfo.put("personIdCard", idCard);

        CommunityMemberDto communityMemberDto = new CommunityMemberDto();
        communityMemberDto.setMemberId(SoreId);
        List<CommunityMemberDto> communityMemberDtos = communityInnerServiceSMOImpl.getCommunityMembers(communityMemberDto);
        JSONArray extCommunityId = new JSONArray();
        //
        getCommunityExtId(communityMemberDtos, extCommunityId);

        if (extCommunityId == null || extCommunityId.size() < 1) {
            return;
        }
        String orgName = "";
        String relCd = "";
        JSONObject body = new JSONObject();
        staffInfo.put("PersonName", userPo.getName());
        staffInfo.put("PersonTel", userPo.getTel());
        staffInfo.put("PersonSex", userPo.getSex());
        staffInfo.put("prePersonName", userPo.getName());

        OrgStaffRelDto orgStaffRelDto = new OrgStaffRelDto();
        orgStaffRelDto.setStaffId(userPo.getUserId());
        List<OrgStaffRelDto> orgStaffRelDtos = orgStaffRelInnerServiceSMOImpl.queryOrgStaffRels(orgStaffRelDto);
        if (orgStaffRelDtos != null || orgStaffRelDtos.size() > 0) {
            OrgDto orgDto = new OrgDto();
            orgDto.setOrgId(orgStaffRelDtos.get(0).getOrgId());
            List<OrgDto> orgDtos = orgInnerServiceSMOImpl.queryOrgs(orgDto);
            if (orgDtos != null || orgDtos.size() > 0) {
                orgName = orgDtos.get(0).getOrgName();
            }
            relCd = orgStaffRelDtos.get(0).getRelCd();
        }
        staffInfo.put("govOrgName", orgName);
        staffInfo.put("relCd", relCd);
        body.put("companyInfo",companyInfo);
        body.put("staffInfo",staffInfo);
        JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId.getString(0), HcGovConstant.ADD_OWNER_ACTION, HcGovConstant.COMMUNITY_SECURE);
        baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, extCommunityId.getString(0), SoreId, HcGovConstant.COMMUNITY_SECURE);
    }

    public void getCommunityExtId(List<CommunityMemberDto> communityMemberDtos, JSONArray extCommunityId) {
        if (communityMemberDtos == null || communityMemberDtos.size() == 0) {
            return;
        }
        for (CommunityMemberDto communityMember : communityMemberDtos) {
            CommunityDto communityDto = new CommunityDto();
            communityDto.setCommunityId(communityMember.getCommunityId());
            List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
            if (communityDtos == null || communityDtos.size() == 0) {
                continue;
            }
            extracted(extCommunityId, communityDtos);
        }
    }

    private void extracted(JSONArray extCommunityId, List<CommunityDto> communityDtos) {
        for (CommunityDto community : communityDtos) {
            for (CommunityAttrDto communityAttrDto : community.getCommunityAttrDtos()) {
                if (HcGovConstant.EXT_COMMUNITY_ID.equals(communityAttrDto.getSpecCd())) {
                    extCommunityId.add(communityAttrDto.getValue());
                }
            }
        }
    }

}