Commit e017f7d2 authored by suhuiguang's avatar suhuiguang

refactor(大编辑):代码重构

1.15个业务编辑实现
parent 868875c8
......@@ -56,4 +56,9 @@ public class BizRelationDataDto {
* 单位Code
*/
private String unitCode;
/**
* 单位是否已经完成
*/
private Boolean bizIsFinished;
}
......@@ -35,9 +35,13 @@ public enum BusinessTypeEnum {
JG_RENOVATION_REGISTRATION("111", "改造变更登记"),
JG_EQUIPMENT_START_STOP("112", "设备启用停用"),
JG_EQUIPMENT_START("112-1", "设备启用"),
JG_EQUIPMENT_STOP("112-2", "设备停用"),
JG_EQUIPMENT_MOVE_CANCEL("113", "注销报废"),
JG_EQUIPMENT_MOVE("113-1", "注销"),
JG_EQUIPMENT_CANCEL("113-2", "报废"),
......
......@@ -46,10 +46,6 @@ public abstract class DefaultBizDataChangeHandler<U extends BaseBizDataChangeEve
List<FieldChangeMeta> allChangeColumns = dataProcessor.handle(changeData, bizId);
List<FieldChangeMeta> bizEditColumns = updBizData(bizId, applyNo, model, changeData);
allChangeColumns.addAll(bizEditColumns);
if (bizIsFinished(applyNo, model, changeData)) {
List<FieldChangeMeta> equipColumns = updCertDataIfBizFin(bizId, applyNo, model, changeData);
allChangeColumns.addAll(equipColumns);
}
// 发送数据变更消息
publish2OtherBiz(allChangeColumns, applyNo, oData, selectedOrgInfo);
}
......@@ -67,6 +63,7 @@ public abstract class DefaultBizDataChangeHandler<U extends BaseBizDataChangeEve
bizRelationDataDto.setRecUserName(selectedOrgInfo.getUserModel().getUserName());
bizRelationDataDto.setUnitCode(selectedOrgInfo.getCompany().getCompanyCode());
bizRelationDataDto.setUnitName(selectedOrgInfo.getCompany().getCompanyName());
bizRelationDataDto.setBizIsFinished(bizIsFinished(applyNo));
eventPublisher.publish(new BaseBizDataChangeEvent(this, bizRelationDataDto, allChangeColumns, RequestContext.cloneRequestContext()));
}
}
......
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeRegistrationReform;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationReform;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.*;
/**
* 改造变更登记编辑处理器
*/
@Component
public class ChangeRegistrationReformDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final ChangeRegistrationReformEditUpdateService changeRegistrationReformEditUpdateService;
protected ChangeRegistrationReformDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, ChangeRegistrationReformEditUpdateService changeRegistrationReformEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.changeRegistrationReformEditUpdateService = changeRegistrationReformEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_RENOVATION_REGISTRATION.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return changeRegistrationReformEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgChangeRegistrationReform jgChangeRegistrationReform = changeRegistrationReformEditUpdateService.getMainService().getOne(new LambdaQueryWrapper<JgChangeRegistrationReform>().eq(JgChangeRegistrationReform::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgChangeRegistrationReform::getAuditStatus));
return jgChangeRegistrationReform.getAuditStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
Set<String> projectContraptionIds = new HashSet<>();
JgChangeRegistrationReform registrationReform = changeRegistrationReformEditUpdateService.getOneByApplyNo(applyNo);
projectContraptionIds.add(registrationReform.getProjectContraptionId());
projectContraptionIds.remove(null);
projectContraptionIds.remove("");
return projectContraptionIds;
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeRegistrationReform;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationReform;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationReformEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationReformEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationReformServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationReformEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationReformServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class ChangeRegistrationReformEditUpdateService {
private final JgChangeRegistrationReformServiceImpl mainService;
private final JgChangeRegistrationReformEqServiceImpl eqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgChangeRegistrationReform jgChangeRegistrationReform = mainService.getOne(new LambdaQueryWrapper<JgChangeRegistrationReform>().eq(JgChangeRegistrationReform::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgChangeRegistrationReformEq> eqs = eqService.list(new LambdaQueryWrapper<JgChangeRegistrationReformEq>().eq(JgChangeRegistrationReformEq::getEquipTransferId, jgChangeRegistrationReform.getSequenceNbr()).select(JgChangeRegistrationReformEq::getEquId));
return eqs.stream().map(JgChangeRegistrationReformEq::getEquId).collect(Collectors.toSet());
}
public JgChangeRegistrationReform getOneByApplyNo(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgChangeRegistrationReform>().eq(JgChangeRegistrationReform::getApplyNo, applyNo));
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeRegistrationTransfer;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationTransfer;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 移装变更登记编辑处理器
*/
@Component
public class ChangeRegistrationTransferDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final ChangeRegistrationTransferEditUpdateService changeRegistrationTransferEditUpdateService;
protected ChangeRegistrationTransferDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, ChangeRegistrationTransferEditUpdateService changeRegistrationTransferEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.changeRegistrationTransferEditUpdateService = changeRegistrationTransferEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_CHANGE_REGISTRATION.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return changeRegistrationTransferEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgChangeRegistrationTransfer jgChangeRegistrationTransfer = changeRegistrationTransferEditUpdateService.getMainService().getOne(new LambdaQueryWrapper<JgChangeRegistrationTransfer>().eq(JgChangeRegistrationTransfer::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgChangeRegistrationTransfer::getAuditStatus));
return jgChangeRegistrationTransfer.getAuditStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeRegistrationTransfer;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationTransfer;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationTransferEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationTransferEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationTransferServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationTransferEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationTransferServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class ChangeRegistrationTransferEditUpdateService {
private final JgChangeRegistrationTransferServiceImpl mainService;
private final JgChangeRegistrationTransferEqServiceImpl eqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgChangeRegistrationTransfer changeRegistrationTransfer = mainService.getOne(new LambdaQueryWrapper<JgChangeRegistrationTransfer>().eq(JgChangeRegistrationTransfer::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgChangeRegistrationTransferEq> eqs = eqService.list(new LambdaQueryWrapper<JgChangeRegistrationTransferEq>().eq(JgChangeRegistrationTransferEq::getEquipTransferId, changeRegistrationTransfer.getSequenceNbr()).select(JgChangeRegistrationTransferEq::getEquId));
return eqs.stream().map(JgChangeRegistrationTransferEq::getEquId).collect(Collectors.toSet());
}
public JgChangeRegistrationTransfer getOneByApplyNo(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgChangeRegistrationTransfer>().eq(JgChangeRegistrationTransfer::getApplyNo, applyNo));
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeRegistrationUnit;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationUnit;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 单位变更登记编辑处理器
*/
@Component
public class ChangeRegistrationUnitDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final ChangeRegistrationUnitEditUpdateService changeRegistrationUnitEditUpdateService;
protected ChangeRegistrationUnitDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, ChangeRegistrationUnitEditUpdateService changeRegistrationUnitEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.changeRegistrationUnitEditUpdateService = changeRegistrationUnitEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_COMPANY_CHANGE_REGISTRATION.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return changeRegistrationUnitEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgChangeRegistrationUnit jgChangeRegistrationUnit = changeRegistrationUnitEditUpdateService.getMainService().getOne(new LambdaQueryWrapper<JgChangeRegistrationUnit>().eq(JgChangeRegistrationUnit::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgChangeRegistrationUnit::getStatus));
return jgChangeRegistrationUnit.getStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
Set<String> pIds = changeRegistrationUnitEditUpdateService.getProIdsByApplyNo(applyNo);
pIds.remove(null);
pIds.remove("");
return pIds;
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeRegistrationUnit;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationUnit;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationUnitEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationUnitEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeRegistrationUnitServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class ChangeRegistrationUnitEditUpdateService {
private final JgChangeRegistrationUnitServiceImpl mainService;
private final JgChangeRegistrationUnitEqServiceImpl eqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgChangeRegistrationUnit jgChangeRegistrationUnit = getOneByApplyNoSingle(applyNo);
List<JgChangeRegistrationUnitEq> eqs = eqService.list(new LambdaQueryWrapper<JgChangeRegistrationUnitEq>().eq(JgChangeRegistrationUnitEq::getUnitChangeRegistrationId, jgChangeRegistrationUnit.getSequenceNbr()).select(JgChangeRegistrationUnitEq::getEquId));
return eqs.stream().map(JgChangeRegistrationUnitEq::getEquId).collect(Collectors.toSet());
}
public JgChangeRegistrationUnit getOneByApplyNo(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgChangeRegistrationUnit>().eq(JgChangeRegistrationUnit::getApplyNo, applyNo));
}
private JgChangeRegistrationUnit getOneByApplyNoSingle(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgChangeRegistrationUnit>().eq(JgChangeRegistrationUnit::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
}
public Set<String> getProIdsByApplyNo(String applyNo) {
JgChangeRegistrationUnit jgChangeRegistrationUnit = getOneByApplyNoSingle(applyNo);
List<JgChangeRegistrationUnitEq> proIds = eqService.list(new LambdaQueryWrapper<JgChangeRegistrationUnitEq>().eq(JgChangeRegistrationUnitEq::getUnitChangeRegistrationId, jgChangeRegistrationUnit.getSequenceNbr()).select(JgChangeRegistrationUnitEq::getProjectContraptionId));
return proIds.stream().map(JgChangeRegistrationUnitEq::getProjectContraptionId).collect(Collectors.toSet());
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeVehicleRegistrationUnit;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeVehicleRegistrationUnit;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import org.typroject.tyboot.core.rdbms.orm.entity.BaseEntity;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 车用气瓶变更(过户)登记编辑处理器
*/
@Component
public class VehicleInformationDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final VehicleInformationEditUpdateService vehicleInformationEditUpdateService;
protected VehicleInformationDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, VehicleInformationEditUpdateService vehicleInformationEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.vehicleInformationEditUpdateService = vehicleInformationEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_VEHICLE_GAS_CYLINDER_CHANGE.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return vehicleInformationEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgChangeVehicleRegistrationUnit jgChangeVehicleRegistrationUnit = vehicleInformationEditUpdateService.getMainService().getOne(new LambdaQueryWrapper<JgChangeVehicleRegistrationUnit>().eq(JgChangeVehicleRegistrationUnit::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgChangeVehicleRegistrationUnit::getStatus));
return jgChangeVehicleRegistrationUnit.getStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.changeVehicleRegistrationUnit;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeVehicleRegistrationUnit;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeVehicleRegistrationUnitEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeVehicleRegistrationUnitEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgChangeVehicleRegistrationUnitServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.typroject.tyboot.core.rdbms.orm.entity.BaseEntity;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class VehicleInformationEditUpdateService {
private final JgChangeVehicleRegistrationUnitServiceImpl mainService;
private final JgChangeVehicleRegistrationUnitEqServiceImpl eqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgChangeVehicleRegistrationUnit JgChangeVehicleRegistrationUnit = getOneByApplyNoSingle(applyNo);
List<JgChangeVehicleRegistrationUnitEq> eqs = eqService.list(new LambdaQueryWrapper<JgChangeVehicleRegistrationUnitEq>().eq(JgChangeVehicleRegistrationUnitEq::getUnitChangeId, JgChangeVehicleRegistrationUnit.getSequenceNbr()).select(JgChangeVehicleRegistrationUnitEq::getEquId));
return eqs.stream().map(JgChangeVehicleRegistrationUnitEq::getEquId).collect(Collectors.toSet());
}
public JgChangeVehicleRegistrationUnit getOneByApplyNo(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgChangeVehicleRegistrationUnit>().eq(JgChangeVehicleRegistrationUnit::getApplyNo, applyNo));
}
private JgChangeVehicleRegistrationUnit getOneByApplyNoSingle(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgChangeVehicleRegistrationUnit>().eq(JgChangeVehicleRegistrationUnit::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.enableDisable;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgEnableDisable;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 设备停用启用编辑处理器
*/
@Component
public class EnableDisableDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final EnableDisableEditUpdateService enableDisableEditUpdateService;
protected EnableDisableDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, EnableDisableEditUpdateService enableDisableEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.enableDisableEditUpdateService = enableDisableEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_EQUIPMENT_START_STOP.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return enableDisableEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgEnableDisable jgEnableDisable = enableDisableEditUpdateService.getEnableDisableService().getOne(new LambdaQueryWrapper<JgEnableDisable>().eq(JgEnableDisable::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgEnableDisable::getAuditStatus));
return jgEnableDisable.getAuditStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.enableDisable;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgEnableDisable;
import com.yeejoin.amos.boot.module.jg.api.entity.JgEnableDisableEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgEnableDisableEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgEnableDisableServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class EnableDisableEditUpdateService {
private final JgEnableDisableServiceImpl enableDisableService;
private final JgEnableDisableEqServiceImpl enableDisableEqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgEnableDisable enableDisableServiceOne = enableDisableService.getOne(new LambdaQueryWrapper<JgEnableDisable>().eq(JgEnableDisable::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgEnableDisableEq> eqs = enableDisableEqService.list(new LambdaQueryWrapper<JgEnableDisableEq>().eq(JgEnableDisableEq::getEnableDisableApplyId, enableDisableServiceOne.getSequenceNbr()).select(JgEnableDisableEq::getEquId));
return eqs.stream().map(JgEnableDisableEq::getEquId).collect(Collectors.toSet());
}
public JgEnableDisable getOneByApplyNo(String applyNo) {
return enableDisableService.getOne(new LambdaQueryWrapper<JgEnableDisable>().eq(JgEnableDisable::getApplyNo, applyNo));
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.equipTransfer;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgEquipTransfer;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 设备移交编辑处理器
*/
@Component
public class EquipTransferDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final EquipTransferEditUpdateService equipTransferEditUpdateService;
protected EquipTransferDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, EquipTransferEditUpdateService equipTransferEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.equipTransferEditUpdateService = equipTransferEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_EQUIPMENT_HANDOVER.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return equipTransferEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgEquipTransfer jgEquipTransfer = equipTransferEditUpdateService.getMainService().getOne(new LambdaQueryWrapper<JgEquipTransfer>().eq(JgEquipTransfer::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgEquipTransfer::getApplyStatus));
return jgEquipTransfer.getApplyStatus().equals(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
Set<String> pIds = equipTransferEditUpdateService.getProIdsByApplyNo(applyNo);
pIds.remove(null);
pIds.remove("");
return pIds;
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.equipTransfer;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgEquipTransfer;
import com.yeejoin.amos.boot.module.jg.api.entity.JgEquipTransferEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgEquipTransferEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgEquipTransferServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class EquipTransferEditUpdateService {
private final JgEquipTransferServiceImpl mainService;
private final JgEquipTransferEqServiceImpl eqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgEquipTransfer JgEquipTransfer = getOneByApplyNoSingle(applyNo);
List<JgEquipTransferEq> eqs = eqService.list(new LambdaQueryWrapper<JgEquipTransferEq>().eq(JgEquipTransferEq::getEquipTransferId, JgEquipTransfer.getSequenceNbr()).select(JgEquipTransferEq::getEquId));
return eqs.stream().map(JgEquipTransferEq::getEquId).collect(Collectors.toSet());
}
public JgEquipTransfer getOneByApplyNo(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgEquipTransfer>().eq(JgEquipTransfer::getApplyNo, applyNo));
}
private JgEquipTransfer getOneByApplyNoSingle(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgEquipTransfer>().eq(JgEquipTransfer::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgEquipTransfer::getProjectContraptionSeq));
}
public Set<String> getProIdsByApplyNo(String applyNo) {
JgEquipTransfer jgEquipTransfer = getOneByApplyNoSingle(applyNo);
String projectContraptionSeq = jgEquipTransfer.getProjectContraptionSeq();
Set<String> proIds = new HashSet<>();
proIds.add(projectContraptionSeq);
return proIds;
}
}
\ No newline at end of file
......@@ -14,6 +14,9 @@ import org.springframework.stereotype.Component;
import java.util.*;
/**
* 安装告知编辑处理器
*/
@Component
public class InstallNoticeDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
......@@ -45,12 +48,7 @@ public class InstallNoticeDataChangeHandler extends DefaultBizDataChangeHandler<
}
@Override
public List<FieldChangeMeta> updCertDataIfBizFin(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean bizIsFinished(String applyNo, ModelType model, Map<String, Object> changeData) {
public Boolean bizIsFinished(String applyNo) {
JgInstallationNotice installationNotice = installNoticeEditUpdateService.getInstallationNoticeService().getOne(new LambdaQueryWrapper<JgInstallationNotice>().eq(JgInstallationNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgInstallationNotice::getNoticeStatus));
return installationNotice.getNoticeStatus().equals(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
}
......
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.maintainNotice;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgMaintainNotice;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 维修告知编辑处理器
*/
@Component
public class MaintainNoticeDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final MaintainNoticeEditUpdateService maintainNoticeEditUpdateService;
protected MaintainNoticeDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, MaintainNoticeEditUpdateService maintainNoticeEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.maintainNoticeEditUpdateService = maintainNoticeEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_MAINTENANCE_NOTIFICATION.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return maintainNoticeEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgMaintainNotice jgMaintainNotice = maintainNoticeEditUpdateService.getMaintainNoticeService().getOne(new LambdaQueryWrapper<JgMaintainNotice>().eq(JgMaintainNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgMaintainNotice::getNoticeStatus));
return jgMaintainNotice.getNoticeStatus().equals(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.maintainNotice;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgInstallationNotice;
import com.yeejoin.amos.boot.module.jg.api.entity.JgInstallationNoticeEq;
import com.yeejoin.amos.boot.module.jg.api.entity.JgMaintainNotice;
import com.yeejoin.amos.boot.module.jg.api.entity.JgMaintainNoticeEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgInstallationNoticeServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgMaintainNoticeEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgMaintainNoticeServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class MaintainNoticeEditUpdateService {
private final JgMaintainNoticeServiceImpl maintainNoticeService;
private final JgMaintainNoticeEqServiceImpl maintainNoticeEqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgMaintainNotice jgInstallationNotice = maintainNoticeService.getOne(new LambdaQueryWrapper<JgMaintainNotice>().eq(JgMaintainNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgMaintainNoticeEq> eqs = maintainNoticeEqService.list(new LambdaQueryWrapper<JgMaintainNoticeEq>().eq(JgMaintainNoticeEq::getEquipTransferId, jgInstallationNotice.getSequenceNbr()).select(JgMaintainNoticeEq::getEquId));
return eqs.stream().map(JgMaintainNoticeEq::getEquId).collect(Collectors.toSet());
}
public JgMaintainNotice getOneByApplyNo(String applyNo) {
return maintainNoticeService.getOne(new LambdaQueryWrapper<JgMaintainNotice>().eq(JgMaintainNotice::getApplyNo, applyNo));
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.maintenanceContract;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgMaintenanceContract;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 维保备案编辑处理器
*/
@Component
public class MaintenanceContractDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final MaintenanceContractEditUpdateService maintenanceContractEditUpdateService;
protected MaintenanceContractDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, MaintenanceContractEditUpdateService maintenanceContractEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.maintenanceContractEditUpdateService = maintenanceContractEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_MAINTENANCE_RECORD.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return maintenanceContractEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgMaintenanceContract maintenanceContract = maintenanceContractEditUpdateService.getMaintenanceContractService().getOne(new LambdaQueryWrapper<JgMaintenanceContract>().eq(JgMaintenanceContract::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgMaintenanceContract::getStatus));
return maintenanceContract.getStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.maintenanceContract;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgMaintenanceContract;
import com.yeejoin.amos.boot.module.jg.api.entity.JgMaintenanceContractEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgMaintenanceContractEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgMaintenanceContractServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class MaintenanceContractEditUpdateService {
private final JgMaintenanceContractServiceImpl maintenanceContractService;
private final JgMaintenanceContractEqServiceImpl maintenanceContractEqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgMaintenanceContract maintenanceContract = maintenanceContractService.getOne(new LambdaQueryWrapper<JgMaintenanceContract>().eq(JgMaintenanceContract::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgMaintenanceContractEq> eqs = maintenanceContractEqService.list(new LambdaQueryWrapper<JgMaintenanceContractEq>().eq(JgMaintenanceContractEq::getEquipTransferId, maintenanceContract.getSequenceNbr()).select(JgMaintenanceContractEq::getEquId));
return eqs.stream().map(JgMaintenanceContractEq::getEquId).collect(Collectors.toSet());
}
public JgMaintenanceContract getOneByApplyNo(String applyNo) {
return maintenanceContractService.getOne(new LambdaQueryWrapper<JgMaintenanceContract>().eq(JgMaintenanceContract::getApplyNo, applyNo));
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.reformNotice;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgReformNotice;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 改造告知处理器
*/
@Component
public class ReformNoticeDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final ReformNoticeEditUpdateService reformNoticeEditUpdateService;
protected ReformNoticeDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, ReformNoticeEditUpdateService reformNoticeEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.reformNoticeEditUpdateService = reformNoticeEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_MODIFICATION_NOTIFICATION.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return reformNoticeEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgReformNotice jgReformNotice = reformNoticeEditUpdateService.getJgReformNoticeService().getOne(new LambdaQueryWrapper<JgReformNotice>().eq(JgReformNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgReformNotice::getNoticeStatus));
return jgReformNotice.getNoticeStatus().equals(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.reformNotice;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgReformNotice;
import com.yeejoin.amos.boot.module.jg.api.entity.JgReformNoticeEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgReformNoticeEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgReformNoticeServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class ReformNoticeEditUpdateService {
private final JgReformNoticeServiceImpl jgReformNoticeService;
private final JgReformNoticeEqServiceImpl jgReformNoticeEqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgReformNotice jgInstallationNotice = jgReformNoticeService.getOne(new LambdaQueryWrapper<JgReformNotice>().eq(JgReformNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgReformNoticeEq> eqs = jgReformNoticeEqService.list(new LambdaQueryWrapper<JgReformNoticeEq>().eq(JgReformNoticeEq::getEquipTransferId, jgInstallationNotice.getSequenceNbr()).select(JgReformNoticeEq::getEquId));
return eqs.stream().map(JgReformNoticeEq::getEquId).collect(Collectors.toSet());
}
public JgReformNotice getOneByApplyNo(String applyNo) {
return jgReformNoticeService.getOne(new LambdaQueryWrapper<JgReformNotice>().eq(JgReformNotice::getApplyNo, applyNo));
}
}
\ No newline at end of file
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.scrapCancel;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgScrapCancel;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 设备注销报废编辑处理器
*/
@Component
public class ScrapCancelDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final ScrapCancelEditUpdateService scrapCancelEditUpdateService;
protected ScrapCancelDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, ScrapCancelEditUpdateService scrapCancelEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.scrapCancelEditUpdateService = scrapCancelEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_EQUIPMENT_MOVE_CANCEL.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return scrapCancelEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgScrapCancel jgScrapCancel = scrapCancelEditUpdateService.getMainService().getOne(new LambdaQueryWrapper<JgScrapCancel>().eq(JgScrapCancel::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgScrapCancel::getAuditStatus));
return jgScrapCancel.getAuditStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.scrapCancel;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgScrapCancel;
import com.yeejoin.amos.boot.module.jg.api.entity.JgScrapCancelEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgScrapCancelEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgScrapCancelServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class ScrapCancelEditUpdateService {
private final JgScrapCancelServiceImpl mainService;
private final JgScrapCancelEqServiceImpl eqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgScrapCancel jgScrapCancel = mainService.getOne(new LambdaQueryWrapper<JgScrapCancel>().eq(JgScrapCancel::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgScrapCancelEq> eqs = eqService.list(new LambdaQueryWrapper<JgScrapCancelEq>().eq(JgScrapCancelEq::getEquipTransferId, jgScrapCancel.getSequenceNbr()).select(JgScrapCancelEq::getEquId));
return eqs.stream().map(JgScrapCancelEq::getEquId).collect(Collectors.toSet());
}
public JgScrapCancel getOneByApplyNo(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgScrapCancel>().eq(JgScrapCancel::getApplyNo, applyNo));
}
}
\ No newline at end of file
......@@ -77,24 +77,12 @@ public interface IBizDataChangeHandleStrategy {
Set<String> getEqs(String applyNo);
/**
* 在业务单位状态为已完成时进行证表的更新
* @param bizId 设备record或者装置id
* @param applyNo 单据编号
* @param model 类型
* @param changeData 数据
* @return 更新的字段
*/
List<FieldChangeMeta> updCertDataIfBizFin(String bizId, String applyNo, ModelType model, Map<String, Object> changeData);
/**
* 单据是否已经审核完成
*
* @param applyNo 单据编号
* @param model 类型
* @param changeData 数据
* @return true-完成;false-未完成
*/
Boolean bizIsFinished(String applyNo, ModelType model, Map<String, Object> changeData);
Boolean bizIsFinished(String applyNo);
/**
......
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.transferNotice;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgTransferNotice;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 移转告知编辑处理器
*/
@Component
public class TransferNoticeDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final TransferNoticeEditUpdateService transferNoticeEditUpdateService;
protected TransferNoticeDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, TransferNoticeEditUpdateService transferNoticeEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.transferNoticeEditUpdateService = transferNoticeEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_ADVICE_REMOVAL.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return transferNoticeEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgTransferNotice jgTransferNotice = transferNoticeEditUpdateService.getTransferNoticeService().getOne(new LambdaQueryWrapper<JgTransferNotice>().eq(JgTransferNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgTransferNotice::getNoticeStatus));
return jgTransferNotice.getNoticeStatus().equals(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.transferNotice;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgTransferNotice;
import com.yeejoin.amos.boot.module.jg.api.entity.JgTransferNoticeEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgTransferNoticeEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgTransferNoticeServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class TransferNoticeEditUpdateService {
private final JgTransferNoticeServiceImpl transferNoticeService;
private final JgTransferNoticeEqServiceImpl maintainNoticeEqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgTransferNotice jgInstallationNotice = transferNoticeService.getOne(new LambdaQueryWrapper<JgTransferNotice>().eq(JgTransferNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
List<JgTransferNoticeEq> eqs = maintainNoticeEqService.list(new LambdaQueryWrapper<JgTransferNoticeEq>().eq(JgTransferNoticeEq::getEquipTransferId, jgInstallationNotice.getSequenceNbr()).select(JgTransferNoticeEq::getEquId));
return eqs.stream().map(JgTransferNoticeEq::getEquId).collect(Collectors.toSet());
}
public JgTransferNotice getOneByApplyNo(String applyNo) {
return transferNoticeService.getOne(new LambdaQueryWrapper<JgTransferNotice>().eq(JgTransferNotice::getApplyNo, applyNo));
}
}
\ No newline at end of file
......@@ -18,6 +18,9 @@ import org.springframework.stereotype.Service;
import java.util.*;
import java.util.stream.Collectors;
/**
* 使用登记编辑处理器
*/
@Service
public class UseRegisterDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
......@@ -67,14 +70,9 @@ public class UseRegisterDataChangeHandler extends DefaultBizDataChangeHandler<Ba
return eqs.stream().map(JgUseRegistrationEq::getEquId).collect(Collectors.toSet());
}
@Override
public List<FieldChangeMeta> updCertDataIfBizFin(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
// 更新设备/装置的使用信息
return useRegisterUpdateService.updCertDataIfBizFin(applyNo, new JSONObject(changeData));
}
@Override
public Boolean bizIsFinished(String applyNo, ModelType model, Map<String, Object> changeData) {
public Boolean bizIsFinished(String applyNo) {
JgUseRegistration useRegistration = useRegisterUpdateService.getJgUseRegistrationService().getOne(new LambdaQueryWrapper<JgUseRegistration>().eq(JgUseRegistration::getApplyNo, applyNo));
return useRegistration.getStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
......
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.vehicleInformation;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.entity.JgVehicleInformation;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.edit.core.RouterEventPublisher;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.DefaultBizDataChangeHandler;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 车用气瓶登记编辑处理器
*/
@Component
public class VehicleInformationDataChangeHandler extends DefaultBizDataChangeHandler<BaseBizDataChangeEvent> {
private final VehicleInformationEditUpdateService vehicleInformationEditUpdateService;
protected VehicleInformationDataChangeHandler(RouterEventPublisher routerEventPublisher, ApplicationContext applicationContext, VehicleInformationEditUpdateService vehicleInformationEditUpdateService) {
super(routerEventPublisher, applicationContext);
this.vehicleInformationEditUpdateService = vehicleInformationEditUpdateService;
}
@Override
public String canHandleBizType() {
return BusinessTypeEnum.JG_VEHICLE_GAS_APPLICATION.name();
}
@Override
public List<FieldChangeMeta> updBizData(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Collections.emptyList();
}
@Override
public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
return Boolean.TRUE;
}
@Override
public Set<String> getEqs(String applyNo) {
return vehicleInformationEditUpdateService.getEqsByApplyNo(applyNo);
}
@Override
public Boolean bizIsFinished(String applyNo) {
JgVehicleInformation jgVehicleInformation = vehicleInformationEditUpdateService.getMainService().getOne(new LambdaQueryWrapper<JgVehicleInformation>().eq(JgVehicleInformation::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgVehicleInformation::getStatus));
return jgVehicleInformation.getStatus().equals(FlowStatusEnum.TO_BE_FINISHED.getName());
}
@Override
public Set<String> getProjectContraptionIds(String applyNo) {
return Collections.emptySet();
}
}
package com.yeejoin.amos.boot.module.jg.biz.edit.process.biz.vehicleInformation;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.entity.JgVehicleInformation;
import com.yeejoin.amos.boot.module.jg.api.entity.JgVehicleInformationEq;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgVehicleInformationEqServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgVehicleInformationServiceImpl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Getter
public class VehicleInformationEditUpdateService {
private final JgVehicleInformationServiceImpl mainService;
private final JgVehicleInformationEqServiceImpl eqService;
public Set<String> getEqsByApplyNo(String applyNo) {
JgVehicleInformation JgVehicleInformation = getOneByApplyNoSingle(applyNo);
List<JgVehicleInformationEq> eqs = eqService.list(new LambdaQueryWrapper<JgVehicleInformationEq>().eq(JgVehicleInformationEq::getVehicleId, JgVehicleInformation.getSequenceNbr()).select(JgVehicleInformationEq::getEquId));
return eqs.stream().map(JgVehicleInformationEq::getEquId).collect(Collectors.toSet());
}
public JgVehicleInformation getOneByApplyNo(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgVehicleInformation>().eq(JgVehicleInformation::getApplyNo, applyNo));
}
private JgVehicleInformation getOneByApplyNoSingle(String applyNo) {
return mainService.getOne(new LambdaQueryWrapper<JgVehicleInformation>().eq(JgVehicleInformation::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr));
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment