package com.java110.api.listener.applicationKey; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.api.bmo.applicationKey.IApplicationKeyBMO; import com.java110.api.listener.AbstractServiceApiListener; import com.java110.core.factory.GenerateCodeFactory; import com.java110.core.smo.file.IFileInnerServiceSMO; import com.java110.core.smo.hardwareAdapation.IMachineInnerServiceSMO; import com.java110.dto.file.FileDto; import com.java110.dto.hardwareAdapation.MachineDto; import com.java110.utils.constant.*; import com.java110.utils.exception.ListenerExecuteException; import com.java110.utils.util.Assert; import com.java110.core.context.DataFlowContext; import com.java110.entity.center.AppService; import com.java110.event.service.api.ServiceDataFlowEvent; import com.java110.core.annotation.Java110Listener; import com.java110.utils.util.DateUtil; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpMethod; import org.springframework.http.ResponseEntity; import java.util.Calendar; import java.util.Date; import java.util.List; import java.util.Random; /** * 保存小区侦听 * add by wuxw 2019-06-30 */ @Java110Listener("saveApplicationKeyListener") public class SaveApplicationKeyListener extends AbstractServiceApiListener { @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) { HttpHeaders header = new HttpHeaders(); context.getRequestCurrentHeaders().put(CommonConstant.HTTP_ORDER_TYPE_CD, "D"); JSONArray businesses = new JSONArray(); AppService service = event.getAppService(); //添加单元信息 businesses.add(applicationKeyBMOImpl.addApplicationKey(reqJson, context)); businesses.add(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); businesses.add(applicationKeyBMOImpl.addOwnerPhoto(reqJson, context)); } ResponseEntity responseEntity = applicationKeyBMOImpl.callService(context, service.getServiceCode(), businesses); context.setResponseEntity(responseEntity); } @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; } }