package com.java110.api.listener.parkingSpace; import com.alibaba.fastjson.JSONObject; import com.java110.api.bmo.parkingSpace.IParkingSpaceBMO; 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.core.smo.fee.IFeeConfigInnerServiceSMO; import com.java110.core.smo.community.IParkingSpaceInnerServiceSMO; import com.java110.core.event.service.api.ServiceDataFlowEvent; import com.java110.utils.constant.ResponseConstant; import com.java110.utils.constant.ServiceCodeConstant; import com.java110.utils.exception.ListenerExecuteException; import com.java110.utils.util.Assert; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpMethod; /** * @ClassName SaveParkingSpaceListener * @Description 保存小区楼信息 * @Author wuxw * @Date 2019/4/26 14:51 * @Version 1.0 * add by wuxw 2019/4/26 **/ @Java110Listener("sellParkingSpaceListener") public class SellParkingSpaceListener extends AbstractServiceApiPlusListener { private static Logger logger = LoggerFactory.getLogger(SellParkingSpaceListener.class); @Autowired private IParkingSpaceBMO parkingSpaceBMOImpl; @Autowired private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl; @Autowired private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl; @Override public String getServiceCode() { return ServiceCodeConstant.SERVICE_CODE_SELL_PARKING_SPACE; } @Override public HttpMethod getHttpMethod() { return HttpMethod.POST; } @Override protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) { Assert.jsonObjectHaveKey(reqJson, "communityId", "未包含小区ID"); Assert.jsonObjectHaveKey(reqJson, "ownerId", "请求报文中未包含ownerId"); Assert.jsonObjectHaveKey(reqJson, "carNum", "请求报文中未包含carNum"); Assert.jsonObjectHaveKey(reqJson, "carBrand", "请求报文中未包含carBrand"); Assert.jsonObjectHaveKey(reqJson, "carType", "请求报文中未包含carType"); Assert.jsonObjectHaveKey(reqJson, "carColor", "未包含carColor"); Assert.jsonObjectHaveKey(reqJson, "psId", "未包含psId"); Assert.jsonObjectHaveKey(reqJson, "storeId", "未包含storeId"); Assert.jsonObjectHaveKey(reqJson, "receivedAmount", "未包含receivedAmount"); Assert.jsonObjectHaveKey(reqJson, "sellOrHire", "未包含sellOrHire"); Assert.hasLength(reqJson.getString("communityId"), "小区ID不能为空"); Assert.hasLength(reqJson.getString("ownerId"), "ownerId不能为空"); Assert.hasLength(reqJson.getString("psId"), "psId不能为空"); Assert.isMoney(reqJson.getString("receivedAmount"), "不是有效的实收金额"); if (!"H".equals(reqJson.getString("sellOrHire")) && !"S".equals(reqJson.getString("sellOrHire"))) { throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR, "请求报文中sellOrFire值错误 ,出售为S 出租为H"); } } @Override protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) { String feeId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId); reqJson.put("feeId", feeId); //添加小区楼 parkingSpaceBMOImpl.sellParkingSpace(reqJson, context); parkingSpaceBMOImpl.modifySellParkingSpaceState(reqJson, context); //计算 费用信息 parkingSpaceBMOImpl.computeFeeInfo(reqJson, context); //添加物业费用信息 parkingSpaceBMOImpl.addParkingSpaceFee(reqJson, context); parkingSpaceBMOImpl.addFeeDetail(reqJson, context); } @Override public int getOrder() { return 0; } public IFeeConfigInnerServiceSMO getFeeConfigInnerServiceSMOImpl() { return feeConfigInnerServiceSMOImpl; } public void setFeeConfigInnerServiceSMOImpl(IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl) { this.feeConfigInnerServiceSMOImpl = feeConfigInnerServiceSMOImpl; } public IParkingSpaceInnerServiceSMO getParkingSpaceInnerServiceSMOImpl() { return parkingSpaceInnerServiceSMOImpl; } public void setParkingSpaceInnerServiceSMOImpl(IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl) { this.parkingSpaceInnerServiceSMOImpl = parkingSpaceInnerServiceSMOImpl; } }