package com.java110.api.bmo.inspection.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.api.bmo.ApiBaseBMO;
|
import com.java110.api.bmo.inspection.IInspectionBMO;
|
import com.java110.core.context.DataFlowContext;
|
import com.java110.dto.inspectionPlan.InspectionTaskDto;
|
import com.java110.intf.community.IInspectionPlanInnerServiceSMO;
|
import com.java110.intf.community.IInspectionRoutePointRelInnerServiceSMO;
|
import com.java110.dto.inspectionPlan.InspectionPlanDto;
|
import com.java110.dto.inspectionPlan.InspectionRoutePointRelDto;
|
import com.java110.intf.community.IInspectionTaskInnerServiceSMO;
|
import com.java110.po.inspection.InspectionPlanPo;
|
import com.java110.po.inspection.InspectionPointPo;
|
import com.java110.po.inspection.InspectionRoutePo;
|
import com.java110.po.inspection.InspectionRoutePointRelPo;
|
import com.java110.utils.constant.BusinessTypeConstant;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.BeanConvertUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* @ClassName InspectionBMOImpl
|
* @Description TODO
|
* @Author wuxw
|
* @Date 2020/3/9 22:39
|
* @Version 1.0
|
* add by wuxw 2020/3/9
|
**/
|
@Service("inspectionBMOImpl")
|
public class InspectionBMOImpl extends ApiBaseBMO implements IInspectionBMO {
|
|
@Autowired
|
private IInspectionPlanInnerServiceSMO inspectionPlanInnerServiceSMOImpl;
|
|
@Autowired
|
private IInspectionRoutePointRelInnerServiceSMO inspectionRoutePointRelInnerServiceSMOImpl;
|
|
@Autowired
|
private IInspectionTaskInnerServiceSMO inspectionTaskInnerServiceSMOImpl;
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void deleteInspectionPlan(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
InspectionPlanPo inspectionPlanPo = BeanConvertUtil.covertBean(paramInJson, InspectionPlanPo.class);
|
InspectionTaskDto inspectionTaskDto = new InspectionTaskDto();
|
inspectionTaskDto.setInspectionPlanId(inspectionPlanPo.getInspectionPlanId());
|
//根据巡检计划id查询巡检任务
|
List<InspectionTaskDto> inspectionTaskDtos = inspectionTaskInnerServiceSMOImpl.queryInspectionTasks(inspectionTaskDto);
|
Assert.listIsNull(inspectionTaskDtos, "该巡检计划正在使用，不能删除！");
|
super.delete(dataFlowContext, inspectionPlanPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_INSPECTION_PLAN);
|
|
}
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void addInspectionPlan(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
|
JSONObject businessInspectionPlan = new JSONObject();
|
businessInspectionPlan.putAll(paramInJson);
|
businessInspectionPlan.put("inspectionPlanId", "-1");
|
InspectionPlanPo inspectionPlanPo = BeanConvertUtil.covertBean(businessInspectionPlan, InspectionPlanPo.class);
|
|
super.insert(dataFlowContext, inspectionPlanPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_INSPECTION_PLAN);
|
}
|
|
/**
|
* 添加巡检计划信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void updateInspectionPlan(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
InspectionPlanPo inspectionPlanPo = BeanConvertUtil.covertBean(paramInJson, InspectionPlanPo.class);
|
super.update(dataFlowContext, inspectionPlanPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_INSPECTION_PLAN);
|
}
|
|
/**
|
* 添加设备信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void updateInspectionPlanState(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
|
InspectionPlanDto inspectionPlanDto = new InspectionPlanDto();
|
inspectionPlanDto.setCommunityId(paramInJson.getString("communityId"));
|
inspectionPlanDto.setInspectionPlanId(paramInJson.getString("inspectionPlanId"));
|
List<InspectionPlanDto> inspectionPlanDtos = inspectionPlanInnerServiceSMOImpl.queryInspectionPlans(inspectionPlanDto);
|
|
Assert.listOnlyOne(inspectionPlanDtos, "根据计划ID查询到多条记录，请检查数据");
|
JSONObject businessInspectionPlan = new JSONObject();
|
businessInspectionPlan.putAll(BeanConvertUtil.beanCovertMap(inspectionPlanDtos.get(0)));
|
businessInspectionPlan.put("state", paramInJson.getString("state"));
|
InspectionPlanPo inspectionPlanPo = BeanConvertUtil.covertBean(businessInspectionPlan, InspectionPlanPo.class);
|
super.update(dataFlowContext, inspectionPlanPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_INSPECTION_PLAN);
|
}
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void deleteInspectionPoint(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
InspectionPointPo inspectionPointPo = BeanConvertUtil.covertBean(paramInJson, InspectionPointPo.class);
|
InspectionRoutePointRelDto inspectionRoutePointRelDto = new InspectionRoutePointRelDto();
|
inspectionRoutePointRelDto.setInspectionId(inspectionPointPo.getInspectionId());
|
//查询巡检点巡检路线关系表
|
List<InspectionRoutePointRelDto> inspectionRoutePointRelDtos = inspectionRoutePointRelInnerServiceSMOImpl.queryInspectionRoutePointRels(inspectionRoutePointRelDto);
|
Assert.listIsNull(inspectionRoutePointRelDtos, "该巡检点正在使用，不能删除！");
|
super.delete(dataFlowContext, inspectionPointPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_INSPECTION);
|
}
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void addInspectionPoint(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
|
paramInJson.put("inspectionId", "-1");
|
InspectionPointPo inspectionPointPo = BeanConvertUtil.covertBean(paramInJson, InspectionPointPo.class);
|
|
super.insert(dataFlowContext, inspectionPointPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_INSPECTION);
|
}
|
|
/**
|
* 添加巡检点信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void updateInspectionPoint(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
|
InspectionPointPo inspectionPointPo = BeanConvertUtil.covertBean(paramInJson, InspectionPointPo.class);
|
super.update(dataFlowContext, inspectionPointPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_INSPECTION);
|
}
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void deleteInspectionRoute(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
InspectionRoutePo inspectionRoutePo = BeanConvertUtil.covertBean(paramInJson, InspectionRoutePo.class);
|
InspectionPlanDto inspectionPlanDto = new InspectionPlanDto();
|
inspectionPlanDto.setInspectionRouteId(inspectionRoutePo.getInspectionRouteId());
|
//根据巡检路线id查询巡检计划
|
List<InspectionPlanDto> inspectionPlanDtos = inspectionPlanInnerServiceSMOImpl.queryInspectionPlans(inspectionPlanDto);
|
Assert.listIsNull(inspectionPlanDtos, "该巡检路线正在使用，不能删除！");
|
super.delete(dataFlowContext, inspectionRoutePo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_INSPECTION_ROUTE);
|
}
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void deleteInspectionRoutePoint(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
InspectionRoutePointRelDto inspectionRoutePointRelDto = new InspectionRoutePointRelDto();
|
inspectionRoutePointRelDto.setCommunityId(paramInJson.getString("communityId"));
|
inspectionRoutePointRelDto.setInspectionId(paramInJson.getString("inspectionId"));
|
inspectionRoutePointRelDto.setInspectionRouteId(paramInJson.getString("inspectionRouteId"));
|
List<InspectionRoutePointRelDto> inspectionRoutePointRelDtos = inspectionRoutePointRelInnerServiceSMOImpl.queryInspectionRoutePointRels(inspectionRoutePointRelDto);
|
|
Assert.listOnlyOne(inspectionRoutePointRelDtos, "未查询到（或多条）要删除的 巡检路线下的巡检点");
|
JSONObject businessInspectionRoute = new JSONObject();
|
businessInspectionRoute.putAll(BeanConvertUtil.beanCovertMap(inspectionRoutePointRelDtos.get(0)));
|
|
InspectionRoutePointRelPo inspectionRoutePointRelPo = BeanConvertUtil.covertBean(businessInspectionRoute, InspectionRoutePointRelPo.class);
|
super.delete(dataFlowContext, inspectionRoutePointRelPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_INSPECTION_ROUTE_POINT_REL);
|
}
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void addInspectionRoute(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
|
|
paramInJson.put("inspectionRouteId", "-1");
|
InspectionRoutePo inspectionRoutePo = BeanConvertUtil.covertBean(paramInJson, InspectionRoutePo.class);
|
super.insert(dataFlowContext, inspectionRoutePo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_INSPECTION_ROUTE);
|
|
}
|
|
/**
|
* 添加小区信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void addInspectionRoute(JSONObject paramInJson, DataFlowContext dataFlowContext, int index) {
|
|
paramInJson.put("irpRelId", "-" + index);
|
InspectionRoutePointRelPo inspectionRoutePointRelPo = BeanConvertUtil.covertBean(paramInJson, InspectionRoutePointRelPo.class);
|
super.insert(dataFlowContext, inspectionRoutePointRelPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_INSPECTION_ROUTE_POINT_REL);
|
}
|
|
/**
|
* 添加巡检路线信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void updateInspectionRoute(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
InspectionRoutePo inspectionRoutePo = BeanConvertUtil.covertBean(paramInJson, InspectionRoutePo.class);
|
super.insert(dataFlowContext, inspectionRoutePo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_INSPECTION_ROUTE);
|
}
|
|
/**
|
* 添加巡检路线信息
|
*
|
* @param paramInJson 接口调用放传入入参
|
* @param dataFlowContext 数据上下文
|
* @return 订单服务能够接受的报文
|
*/
|
public void updateInspectionRoutePointRel(JSONObject paramInJson, DataFlowContext dataFlowContext) {
|
InspectionRoutePointRelPo inspectionRoutePointRelPo = BeanConvertUtil.covertBean(paramInJson, InspectionRoutePointRelPo.class);
|
super.update(dataFlowContext, inspectionRoutePointRelPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_INSPECTION_ROUTE_POINT_REL);
|
}
|
|
}
|
