| service-job/src/main/java/com/java110/job/adapt/hcGov/HcGovConstant.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-job/src/main/java/com/java110/job/adapt/hcGov/location/AddLocationToHcGovAdapt.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-job/src/main/java/com/java110/job/adapt/hcGov/location/AddLocationToHcGovReturnAdapt.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-job/src/main/java/com/java110/job/adapt/hcGov/location/EditLocationToHcGovAdapt.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-job/src/main/java/com/java110/job/adapt/hcGov/location/EditLocationToHcGovReturnAdapt.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
service-job/src/main/java/com/java110/job/adapt/hcGov/HcGovConstant.java
@@ -49,6 +49,12 @@ //修改房屋 public static final String EDIT_ROOM_ACTION = "EDIT_ROOM"; //添加位置 public static final String ADD_LOCATION_ACTION = "ADD_LOCATION"; //修改位置 public static final String EDIT_LOCATION_ACTION = "EDIT_LOCATION"; public static void generatorProducerSign(JSONObject header, JSONObject body, String code) { String newSign = AuthenticationFactory.md5(header.getString("tranId") + header.getString("reqTime") + body.toJSONString() + code).toLowerCase(); service-job/src/main/java/com/java110/job/adapt/hcGov/location/AddLocationToHcGovAdapt.java
New file @@ -0,0 +1,106 @@ /* * 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.location; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.dto.community.CommunityAttrDto; import com.java110.dto.community.CommunityDto; import com.java110.entity.order.Business; import com.java110.intf.community.ICommunityInnerServiceSMO; import com.java110.intf.community.IUnitInnerServiceSMO; 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.community.CommunityLocationPo; import com.java110.utils.util.Assert; 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 = "addLocationToHcGovAdapt") public class AddLocationToHcGovAdapt extends DatabusAdaptImpl { @Autowired private ICommunityInnerServiceSMO communityInnerServiceSMOImpl; @Autowired private BaseHcGovSendAsyn baseHcGovSendAsynImpl; /** * @param business 当前处理业务 * @param businesses 所有业务信息 */ @Override public void execute(Business business, List<Business> businesses) { JSONObject data = business.getData(); if (data.containsKey(CommunityLocationPo.class.getSimpleName())) { Object bObj = data.get(CommunityLocationPo.class.getSimpleName()); JSONArray businessCommunityLocations = null; if (bObj instanceof JSONObject) { businessCommunityLocations = new JSONArray(); businessCommunityLocations.add(bObj); } else if (bObj instanceof List) { businessCommunityLocations = JSONArray.parseArray(JSONObject.toJSONString(bObj)); } else { businessCommunityLocations = (JSONArray) bObj; } //JSONObject businessCommunityLocation = data.getJSONObject("businessCommunityLocation"); for (int bCommunityLocationIndex = 0; bCommunityLocationIndex < businessCommunityLocations.size(); bCommunityLocationIndex++) { JSONObject businessCommunityLocation = businessCommunityLocations.getJSONObject(bCommunityLocationIndex); doAddCommunityLocation(business, businessCommunityLocation); } } } private void doAddCommunityLocation(Business business, JSONObject businessCommunityLocation) { CommunityLocationPo communityLocationPo = BeanConvertUtil.covertBean(businessCommunityLocation, CommunityLocationPo.class); CommunityDto communityDto = new CommunityDto(); communityDto.setCommunityId(communityLocationPo.getCommunityId()); List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto); Assert.listNotNull(communityDtos, "未包含小区信息"); CommunityDto tmpCommunityDto = communityDtos.get(0); String extCommunityId = ""; String communityId = tmpCommunityDto.getCommunityId(); String communityLocationId = communityLocationPo.getLocationId(); for (CommunityAttrDto communityAttrDto : tmpCommunityDto.getCommunityAttrDtos()) { if (HcGovConstant.EXT_COMMUNITY_ID.equals(communityAttrDto.getSpecCd())) { extCommunityId = communityAttrDto.getValue(); } } JSONObject body = new JSONObject(); body.put("name", communityLocationPo.getLocationName()); JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId, HcGovConstant.ADD_LOCATION_ACTION, HcGovConstant.COMMUNITY_SECURE); baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, communityId, communityLocationId, HcGovConstant.COMMUNITY_SECURE); } } service-job/src/main/java/com/java110/job/adapt/hcGov/location/AddLocationToHcGovReturnAdapt.java
New file @@ -0,0 +1,79 @@ /* * 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.location; import com.java110.core.factory.GenerateCodeFactory; import com.java110.dto.communityLocationAttr.CommunityLocationAttrDto; import com.java110.dto.hcGovTranslate.HcGovTranslateDto; import com.java110.dto.reportData.ReportDataDto; import com.java110.intf.common.IHcGovTranslateInnerServiceSMO; import com.java110.intf.community.ICommunityLocationAttrInnerServiceSMO; import com.java110.job.adapt.hcGov.HcGovConstant; import com.java110.job.adapt.hcGov.IReportReturnDataAdapt; import com.java110.po.communityLocationAttr.CommunityLocationAttrPo; 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 = "ADD_LOCATION_RETURN") public class AddLocationToHcGovReturnAdapt implements IReportReturnDataAdapt { @Autowired private ICommunityLocationAttrInnerServiceSMO communityLocationAttrInnerServiceSMOImpl; @Autowired private IHcGovTranslateInnerServiceSMO hcGovTranslateInnerServiceSMOImpl; @Override public void reportReturn(ReportDataDto reportDataDto, String extCommunityId) { HcGovTranslateDto hcGovTranslateDto = new HcGovTranslateDto(); hcGovTranslateDto.setTranId(reportDataDto.getReportDataHeaderDto().getTranId()); hcGovTranslateDto.setServiceCode(reportDataDto.getReportDataHeaderDto().getServiceCode()); List<HcGovTranslateDto> hcGovTranslateDtos = hcGovTranslateInnerServiceSMOImpl.queryHcGovTranslates(hcGovTranslateDto); if (hcGovTranslateDtos == null || hcGovTranslateDtos.size() < 1) { throw new IllegalArgumentException("查询推送报文失败。不是同一订单信息"); } CommunityLocationAttrDto communityLocationAttrDto = new CommunityLocationAttrDto(); communityLocationAttrDto.setLocationId(hcGovTranslateDtos.get(0).getObjId()); communityLocationAttrDto.setCommunityId(hcGovTranslateDtos.get(0).getCommunityId()); communityLocationAttrDto.setSpecCd( HcGovConstant.EXT_COMMUNITY_ID); List<CommunityLocationAttrDto> communityLocationAttrDtos = communityLocationAttrInnerServiceSMOImpl.queryCommunityLocationAttrs(communityLocationAttrDto); CommunityLocationAttrPo communityLocationAttrPo = new CommunityLocationAttrPo(); communityLocationAttrPo.setAttrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_locationId)); communityLocationAttrPo.setLocationId(communityLocationAttrDto.getLocationId()); communityLocationAttrPo.setCommunityId(communityLocationAttrDto.getCommunityId()); communityLocationAttrPo.setSpecCd(communityLocationAttrDto.getSpecCd()); communityLocationAttrPo.setValue(reportDataDto.getReportDataBodyDto().getString("extLocationId")); if (communityLocationAttrDtos == null || communityLocationAttrDtos.size() < 1) { int flag = communityLocationAttrInnerServiceSMOImpl.saveCommunityLocationAttr(communityLocationAttrPo); if (flag < 1) { throw new IllegalArgumentException("保存楼栋属性失败"); } } } } service-job/src/main/java/com/java110/job/adapt/hcGov/location/EditLocationToHcGovAdapt.java
New file @@ -0,0 +1,136 @@ /* * 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.location; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.dto.community.CommunityAttrDto; import com.java110.dto.community.CommunityDto; import com.java110.dto.community.CommunityLocationDto; import com.java110.dto.communityLocationAttr.CommunityLocationAttrDto; import com.java110.entity.order.Business; import com.java110.intf.community.ICommunityInnerServiceSMO; import com.java110.intf.community.ICommunityLocationAttrInnerServiceSMO; import com.java110.intf.community.ICommunityLocationInnerServiceSMO; 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.community.CommunityLocationPo; import com.java110.utils.util.Assert; 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 = "editLocationToHcGovAdapt") public class EditLocationToHcGovAdapt extends DatabusAdaptImpl { @Autowired private ICommunityInnerServiceSMO communityInnerServiceSMOImpl; @Autowired private ICommunityLocationInnerServiceSMO communityLocationInnerServiceSMOImpl; @Autowired private ICommunityLocationAttrInnerServiceSMO communityLocationAttrInnerServiceSMOImpl; @Autowired private BaseHcGovSendAsyn baseHcGovSendAsynImpl; /** * @param business 当前处理业务 * @param businesses 所有业务信息 */ @Override public void execute(Business business, List<Business> businesses) { JSONObject data = business.getData(); if (data.containsKey(CommunityLocationPo.class.getSimpleName())) { Object bObj = data.get(CommunityLocationPo.class.getSimpleName()); JSONArray businessCommunityLocations = null; if (bObj instanceof JSONObject) { businessCommunityLocations = new JSONArray(); businessCommunityLocations.add(bObj); } else if (bObj instanceof List) { businessCommunityLocations = JSONArray.parseArray(JSONObject.toJSONString(bObj)); } else { businessCommunityLocations = (JSONArray) bObj; } //JSONObject businessCommunityLocation = data.getJSONObject("businessCommunityLocation"); for (int bCommunityLocationIndex = 0; bCommunityLocationIndex < businessCommunityLocations.size(); bCommunityLocationIndex++) { JSONObject businessCommunityLocation = businessCommunityLocations.getJSONObject(bCommunityLocationIndex); doAddCommunityLocation(business, businessCommunityLocation); } } } private void doAddCommunityLocation(Business business, JSONObject businessCommunityLocation) { CommunityLocationPo communityLocationPo = BeanConvertUtil.covertBean(businessCommunityLocation, CommunityLocationPo.class); CommunityLocationDto communityLocationDto = new CommunityLocationDto(); communityLocationDto.setLocationId(communityLocationPo.getLocationId()); communityLocationDto.setCommunityId(communityLocationPo.getCommunityId()); List<CommunityLocationDto> communityLocationDtos = communityLocationInnerServiceSMOImpl.queryCommunityLocations(communityLocationDto); Assert.listOnlyOne(communityLocationDtos, "位置不存在"); CommunityDto communityDto = new CommunityDto(); communityDto.setCommunityId(communityLocationPo.getCommunityId()); List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto); Assert.listNotNull(communityDtos, "未包含小区信息"); CommunityDto tmpCommunityDto = communityDtos.get(0); String extCommunityId = ""; String communityId = tmpCommunityDto.getCommunityId(); String communityLocationId = communityLocationPo.getLocationId(); for (CommunityAttrDto communityAttrDto : tmpCommunityDto.getCommunityAttrDtos()) { if (HcGovConstant.EXT_COMMUNITY_ID.equals(communityAttrDto.getSpecCd())) { extCommunityId = communityAttrDto.getValue(); } } CommunityLocationAttrDto communityLocationAttrDto = new CommunityLocationAttrDto(); communityLocationAttrDto.setLocationId(communityLocationDtos.get(0).getLocationId()); communityLocationAttrDto.setSpecCd(HcGovConstant.EXT_COMMUNITY_ID); communityLocationAttrDto.setCommunityId(communityId); List<CommunityLocationAttrDto> communityLocationAttrDtos = communityLocationAttrInnerServiceSMOImpl.queryCommunityLocationAttrs(communityLocationAttrDto); JSONObject kafkaData = null; if (communityLocationAttrDtos != null && communityLocationAttrDtos.size() > 0) { JSONObject body = new JSONObject(); body.put("name", communityLocationDtos.get(0).getLocationName()); body.put("extLocationId", communityLocationDtos.get(0).getLocationName()); kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId, HcGovConstant.EDIT_LOCATION_ACTION, HcGovConstant.COMMUNITY_SECURE); } else { JSONObject body = new JSONObject(); body.put("name", communityLocationDtos.get(0).getLocationName()); kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId, HcGovConstant.ADD_LOCATION_ACTION, HcGovConstant.COMMUNITY_SECURE); } baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, communityId, communityLocationId, HcGovConstant.COMMUNITY_SECURE); } } service-job/src/main/java/com/java110/job/adapt/hcGov/location/EditLocationToHcGovReturnAdapt.java
New file @@ -0,0 +1,82 @@ /* * 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.location; import com.java110.core.factory.GenerateCodeFactory; import com.java110.dto.communityLocationAttr.CommunityLocationAttrDto; import com.java110.dto.floorAttr.FloorAttrDto; import com.java110.dto.hcGovTranslate.HcGovTranslateDto; import com.java110.dto.reportData.ReportDataDto; import com.java110.intf.common.IHcGovTranslateInnerServiceSMO; import com.java110.intf.community.ICommunityLocationAttrInnerServiceSMO; import com.java110.intf.community.IFloorAttrInnerServiceSMO; import com.java110.job.adapt.hcGov.HcGovConstant; import com.java110.job.adapt.hcGov.IReportReturnDataAdapt; import com.java110.po.communityLocationAttr.CommunityLocationAttrPo; import com.java110.po.floorAttr.FloorAttrPo; 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 = "EDIT_LOCATION_RETURN") public class EditLocationToHcGovReturnAdapt implements IReportReturnDataAdapt { @Autowired private ICommunityLocationAttrInnerServiceSMO communityLocationAttrInnerServiceSMOImpl; @Autowired private IHcGovTranslateInnerServiceSMO hcGovTranslateInnerServiceSMOImpl; @Override public void reportReturn(ReportDataDto reportDataDto, String extCommunityId) { HcGovTranslateDto hcGovTranslateDto = new HcGovTranslateDto(); hcGovTranslateDto.setTranId(reportDataDto.getReportDataHeaderDto().getTranId()); hcGovTranslateDto.setServiceCode(reportDataDto.getReportDataHeaderDto().getServiceCode()); List<HcGovTranslateDto> hcGovTranslateDtos = hcGovTranslateInnerServiceSMOImpl.queryHcGovTranslates(hcGovTranslateDto); if (hcGovTranslateDtos == null || hcGovTranslateDtos.size() < 1) { throw new IllegalArgumentException("查询推送报文失败。不是同一订单信息"); } CommunityLocationAttrDto communityLocationAttrDto = new CommunityLocationAttrDto(); communityLocationAttrDto.setLocationId(hcGovTranslateDtos.get(0).getObjId()); communityLocationAttrDto.setCommunityId(hcGovTranslateDtos.get(0).getCommunityId()); communityLocationAttrDto.setSpecCd( HcGovConstant.EXT_COMMUNITY_ID); List<CommunityLocationAttrDto> communityLocationAttrDtos = communityLocationAttrInnerServiceSMOImpl.queryCommunityLocationAttrs(communityLocationAttrDto); CommunityLocationAttrPo communityLocationAttrPo = new CommunityLocationAttrPo(); communityLocationAttrPo.setAttrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_locationId)); communityLocationAttrPo.setLocationId(communityLocationAttrDto.getLocationId()); communityLocationAttrPo.setCommunityId(communityLocationAttrDto.getCommunityId()); communityLocationAttrPo.setSpecCd(communityLocationAttrDto.getSpecCd()); communityLocationAttrPo.setValue(reportDataDto.getReportDataBodyDto().getString("extLocationId")); if (communityLocationAttrDtos == null || communityLocationAttrDtos.size() < 1) { int flag = communityLocationAttrInnerServiceSMOImpl.saveCommunityLocationAttr(communityLocationAttrPo); if (flag < 1) { throw new IllegalArgumentException("保存楼栋属性失败"); } } } }
