package com.java110.api.listener.owner; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.api.listener.AbstractServiceApiDataFlowListener; import com.java110.api.listener.AbstractServiceApiListener; import com.java110.core.annotation.Java110Listener; import com.java110.core.context.DataFlowContext; import com.java110.core.factory.GenerateCodeFactory; import com.java110.core.smo.community.ICommunityInnerServiceSMO; import com.java110.core.smo.file.IFileInnerServiceSMO; import com.java110.dto.community.CommunityDto; import com.java110.dto.file.FileDto; import com.java110.entity.center.AppService; import com.java110.event.service.api.ServiceDataFlowEvent; import com.java110.utils.constant.*; import com.java110.utils.exception.ListenerExecuteException; import com.java110.utils.util.Assert; import com.java110.utils.util.DateUtil; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpMethod; import org.springframework.http.ResponseEntity; /** * @ClassName AppUserBindingOwnerListener * @Description app用户绑定业主接口 * @Author wuxw * @Date 2019/4/26 14:51 * @Version 1.0 * add by wuxw 2019/4/26 **/ @Java110Listener("appUserBindingOwnerListener") public class AppUserBindingOwnerListener extends AbstractServiceApiListener { private static final int DEFAULT_SEQ_COMMUNITY_MEMBER = 2; @Autowired private IFileInnerServiceSMO fileInnerServiceSMOImpl; @Autowired private ICommunityInnerServiceSMO communityInnerServiceSMOImpl; private static Logger logger = LoggerFactory.getLogger(AppUserBindingOwnerListener.class); @Override public String getServiceCode() { return ServiceCodeConstant.SERVICE_CODE_APP_USER_BINDING_OWNER; } @Override public HttpMethod getHttpMethod() { return HttpMethod.POST; } @Override protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) { Assert.hasKeyAndValue(reqJson, "communityName", "未包含小区名称"); Assert.hasKeyAndValue(reqJson, "areaCode", "未包含小区地区"); Assert.hasKeyAndValue(reqJson, "appUserName", "未包含用户名称"); Assert.hasKeyAndValue(reqJson, "idCard", "未包含身份证号"); Assert.hasKeyAndValue(reqJson, "link", "未包含联系电话"); } @Override protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) { logger.debug("ServiceDataFlowEvent : {}", event); //查询小区是否存在 CommunityDto communityDto = new CommunityDto(); //communityInnerServiceSMOImpl.queryCommunitys(); // } @Override public int getOrder() { return 0; } public IFileInnerServiceSMO getFileInnerServiceSMOImpl() { return fileInnerServiceSMOImpl; } public void setFileInnerServiceSMOImpl(IFileInnerServiceSMO fileInnerServiceSMOImpl) { this.fileInnerServiceSMOImpl = fileInnerServiceSMOImpl; } public ICommunityInnerServiceSMO getCommunityInnerServiceSMOImpl() { return communityInnerServiceSMOImpl; } public void setCommunityInnerServiceSMOImpl(ICommunityInnerServiceSMO communityInnerServiceSMOImpl) { this.communityInnerServiceSMOImpl = communityInnerServiceSMOImpl; } }