package com.java110.api.listener.applicationKey; import com.alibaba.fastjson.JSONObject; import com.java110.api.bmo.applicationKey.IApplicationKeyBMO; import com.java110.api.listener.AbstractServiceApiPlusListener; import com.java110.core.annotation.Java110Listener; import com.java110.core.context.DataFlowContext; import com.java110.core.factory.GenerateCodeFactory; import com.java110.intf.common.IFileInnerServiceSMO; import com.java110.dto.file.FileDto; import com.java110.core.event.service.api.ServiceDataFlowEvent; import com.java110.utils.constant.ServiceCodeApplicationKeyConstant; import com.java110.utils.util.Assert; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpMethod; /** * 保存小区侦听 * add by wuxw 2019-06-30 */ @Java110Listener("saveApplicationKeyListener") public class SaveApplicationKeyListener extends AbstractServiceApiPlusListener { @Autowired private IApplicationKeyBMO applicationKeyBMOImpl; @Autowired private IFileInnerServiceSMO fileInnerServiceSMOImpl; @Override protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) { //Assert.hasKeyAndValue(reqJson, "xxx", "xxx"); Assert.hasKeyAndValue(reqJson, "name", "必填,请填写姓名"); Assert.hasKeyAndValue(reqJson, "communityId", "必填,请填写小区"); Assert.hasKeyAndValue(reqJson, "tel", "必填,请填写手机号"); Assert.hasKeyAndValue(reqJson, "typeCd", "必填,请选择用户类型"); Assert.hasKeyAndValue(reqJson, "sex", "必填,请选择性别"); Assert.hasKeyAndValue(reqJson, "age", "必填,请填写年龄"); Assert.hasKeyAndValue(reqJson, "idCard", "必填,请填写身份证号"); Assert.hasKeyAndValue(reqJson, "startTime", "必填,请选择开始时间"); Assert.hasKeyAndValue(reqJson, "endTime", "必填,请选择结束时间"); Assert.hasKeyAndValue(reqJson, "locationTypeCd", "必填,位置不能为空"); Assert.hasKeyAndValue(reqJson, "locationObjId", "必填,未选择位置对象"); Assert.hasKeyAndValue(reqJson, "storeId", "必填,请填写商户ID"); Assert.hasKeyAndValue(reqJson, "typeFlag", "必填,请选择钥匙类型"); } @Override protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) { //添加单元信息 applicationKeyBMOImpl.addApplicationKey(reqJson, context); applicationKeyBMOImpl.addMsg(reqJson, context); if (reqJson.containsKey("photo") && !StringUtils.isEmpty(reqJson.getString("photo"))) { FileDto fileDto = new FileDto(); fileDto.setFileId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_file_id)); fileDto.setFileName(fileDto.getFileId()); fileDto.setContext(reqJson.getString("photo")); fileDto.setSuffix("jpeg"); fileDto.setCommunityId(reqJson.getString("communityId")); String fileName = fileInnerServiceSMOImpl.saveFile(fileDto); reqJson.put("applicationKeyPhotoId", fileDto.getFileId()); reqJson.put("fileSaveName", fileName); applicationKeyBMOImpl.addOwnerPhoto(reqJson, context); } } @Override public String getServiceCode() { return ServiceCodeApplicationKeyConstant.ADD_APPLICATIONKEY; } @Override public HttpMethod getHttpMethod() { return HttpMethod.POST; } @Override public int getOrder() { return DEFAULT_ORDER; } public IFileInnerServiceSMO getFileInnerServiceSMOImpl() { return fileInnerServiceSMOImpl; } public void setFileInnerServiceSMOImpl(IFileInnerServiceSMO fileInnerServiceSMOImpl) { this.fileInnerServiceSMOImpl = fileInnerServiceSMOImpl; } }