Commit ca1fab8e authored by tangwei's avatar tangwei

电站全过程状态修改

parent 84868875
...@@ -16,7 +16,29 @@ public enum ArrivalStateeEnum { ...@@ -16,7 +16,29 @@ public enum ArrivalStateeEnum {
已收货("已收货", "已收货"), 已收货("已收货", "已收货"),
已作废("已作废", "已作废"); 已作废("已作废", "已作废"),
待勘察("待勘察", "待勘察"),
勘察中("勘察中", "勘察中"),
勘察完成 ("勘察完成", "勘察完成"),
备货中("备货中", "备货中"),
备货完成("备货完成", "备货完成"),
施工中("施工中", "施工中"),
施工完成 ("施工完成", "施工完成"),
并网中("并网中", "并网中"),
并网完成("并网完成", "并网完成"),
线上验收("线上验收", "线上验收"),
线下验收("线下验收", "线下验收"),
验收完成("验收完成", "验收完成");
/** /**
* 名称,描述 * 名称,描述
......
...@@ -27,7 +27,7 @@ VALUES ...@@ -27,7 +27,7 @@ VALUES
#{userId}, #{userId},
#{userId}, #{userId},
#{com}, #{com},
NULL, null,
'JXIOP', 'JXIOP',
#{role} ); #{role} );
......
package com.yeejoin.amos.boot.module.hygf.biz.service.impl; package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.yeejoin.amos.boot.module.hygf.api.Enum.AcceptanceStatusEnum; import com.yeejoin.amos.boot.module.hygf.api.Enum.AcceptanceStatusEnum;
import com.yeejoin.amos.boot.module.hygf.api.Enum.ArrivalStateeEnum;
import com.yeejoin.amos.boot.module.hygf.api.dto.AcceptanceDto; import com.yeejoin.amos.boot.module.hygf.api.dto.AcceptanceDto;
import com.yeejoin.amos.boot.module.hygf.api.dto.StandardDto; import com.yeejoin.amos.boot.module.hygf.api.dto.StandardDto;
import com.yeejoin.amos.boot.module.hygf.api.entity.AcceptanceCheckItem; import com.yeejoin.amos.boot.module.hygf.api.entity.AcceptanceCheckItem;
...@@ -117,6 +119,14 @@ public class AcceptanceServiceImpl implements IAcceptanceService { ...@@ -117,6 +119,14 @@ public class AcceptanceServiceImpl implements IAcceptanceService {
standardDto.setTaskId(basicGridAcceptanc.getNextTaskId()); standardDto.setTaskId(basicGridAcceptanc.getNextTaskId());
workflow.standard(basicGridAcceptanc,standardDto,userId); workflow.standard(basicGridAcceptanc,standardDto,userId);
basicGridAcceptanceMapper.updateById(basicGridAcceptanc); basicGridAcceptanceMapper.updateById(basicGridAcceptanc);
//线上验收
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState, ArrivalStateeEnum.线上验收.getCode());
long idsk= basicGridAcceptanc.getPeasantHouseholdId();
up.eq(PeasantHousehold::getSequenceNbr,idsk);
peasantHouseholdMapper.update(null,up);
} }
......
...@@ -43,6 +43,10 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta ...@@ -43,6 +43,10 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta
@Autowired @Autowired
WorkOrderMapper workOrderMapper; WorkOrderMapper workOrderMapper;
@Autowired
PeasantHouseholdMapper peasantHouseholdMapper;
private final String OK ="0"; private final String OK ="0";
private final String PASS ="5"; private final String PASS ="5";
...@@ -104,6 +108,15 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta ...@@ -104,6 +108,15 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta
startProcessDto.setProcess(process); startProcessDto.setProcess(process);
workflow.startProcess(basicGridAcceptance, startProcessDto,userId); workflow.startProcess(basicGridAcceptance, startProcessDto,userId);
//线上验收
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState, ArrivalStateeEnum.并网中.getCode());
long idsk= basicGridAcceptance.getPeasantHouseholdId();
up.eq(PeasantHousehold::getSequenceNbr,idsk);
peasantHouseholdMapper.update(null,up);
} }
if(grid.getSequenceNbr()!=null){ if(grid.getSequenceNbr()!=null){
onGridMapper.updateById(grid); onGridMapper.updateById(grid);
...@@ -154,11 +167,19 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta ...@@ -154,11 +167,19 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta
upq.eq(HygfOnGrid::getSequenceNbr, dto.getFonGridId()); upq.eq(HygfOnGrid::getSequenceNbr, dto.getFonGridId());
upq.set(HygfOnGrid::getGridConnectionTime, new Date()); upq.set(HygfOnGrid::getGridConnectionTime, new Date());
onGridMapper.update(null, upq); onGridMapper.update(null, upq);
//并网完成
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState,ArrivalStateeEnum.并网完成.getCode());
long idsk= basicGridAcceptanc.getPeasantHouseholdId();
up.eq(PeasantHousehold::getSequenceNbr,idsk);
peasantHouseholdMapper.update(null,up);
} else { } else {
basicGridAcceptanc.setAcceptanceStatus(AcceptanceStatusEnum.getNodeByKey(nextNodeKey, dto.getApprovalStatus())); basicGridAcceptanc.setAcceptanceStatus(AcceptanceStatusEnum.getNodeByKey(nextNodeKey, dto.getApprovalStatus()));
} }
} else { } else {
if (BasicGridAcceptancEnum.并网管理端工程审核.getCode().equals(nextNodeKey)) { if (BasicGridAcceptancEnum.并网管理端工程审核.getCode().equals(nextNodeKey)) {
basicGridAcceptanc.setGridStatus(GridStatusEnum.WTG.getCode()); basicGridAcceptanc.setGridStatus(GridStatusEnum.WTG.getCode());
...@@ -210,7 +231,26 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta ...@@ -210,7 +231,26 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta
standardDto.setVariable(variable); standardDto.setVariable(variable);
BasicGridAcceptance workBasicGridAcceptance = workflow.standard(basicGridAcceptanc, standardDto, userId); BasicGridAcceptance workBasicGridAcceptance = workflow.standard(basicGridAcceptanc, standardDto, userId);
if (workBasicGridAcceptance.getNextNodeKey().equals(BasicGridAcceptancEnum.管理端工程线下验.getCode())) {
//线下验收
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState,ArrivalStateeEnum.线下验收.getCode());
long idsk= basicGridAcceptanc.getPeasantHouseholdId();
up.eq(PeasantHousehold::getSequenceNbr,idsk);
peasantHouseholdMapper.update(null,up);
}
//验收完成
if(workBasicGridAcceptance.getNextTaskId()==null){
//更新状态
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState,ArrivalStateeEnum.验收完成.getCode());
long idsk= basicGridAcceptanc.getPeasantHouseholdId();
up.eq(PeasantHousehold::getSequenceNbr,idsk);
peasantHouseholdMapper.update(null,up);
}
basicGridAcceptanceMapper.updateById(workBasicGridAcceptance); basicGridAcceptanceMapper.updateById(workBasicGridAcceptance);
} }
......
...@@ -390,12 +390,12 @@ public class PersonnelBusinessServiceImpl extends BaseService<PersonnelBusinessD ...@@ -390,12 +390,12 @@ public class PersonnelBusinessServiceImpl extends BaseService<PersonnelBusinessD
Privilege.groupUserClient.deleteGroupUser(userGroupId,publicAgencyUsex.getAmosUserId()); Privilege.groupUserClient.deleteGroupUser(userGroupId,publicAgencyUsex.getAmosUserId());
userEmpowerMapper.upuserrole( // userEmpowerMapper.upuserrole(
publicAgencyUse.getSequenceNbr(), // publicAgencyUse.getSequenceNbr(),
publicAgencyUse.getAmosUserId(), // publicAgencyUse.getAmosUserId(),
userGroupId, // userGroupId,
personnelBusines.getAmosUnitId() // personnelBusines.getAmosUnitId()
); // );
//修改权限 //修改权限
......
...@@ -326,6 +326,7 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS ...@@ -326,6 +326,7 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
String peasantHouseholdId = powerStation.getPeasantHouseholdId(); String peasantHouseholdId = powerStation.getPeasantHouseholdId();
PeasantHousehold peasantHousehold = peasantHouseholdService.getBaseMapper().selectById(Long.valueOf(peasantHouseholdId)); PeasantHousehold peasantHousehold = peasantHouseholdService.getBaseMapper().selectById(Long.valueOf(peasantHouseholdId));
peasantHousehold.setSurveyOrNot(3); peasantHousehold.setSurveyOrNot(3);
peasantHousehold.setConstructionState(ArrivalStateeEnum.勘察完成.getCode());
peasantHouseholdService.saveOrUpdate(peasantHousehold); peasantHouseholdService.saveOrUpdate(peasantHousehold);
} }
//} //}
......
...@@ -310,7 +310,7 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto ...@@ -310,7 +310,7 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
//更新电站施工状态 //更新电站施工状态
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState,DeliveryStateeEnum.已发货.getCode()); up.set(PeasantHousehold::getConstructionState,ArrivalStateeEnum.备货中.getCode());
List<DocumentStation> idsk= model.getPeasantHouseholdId(); List<DocumentStation> idsk= model.getPeasantHouseholdId();
List<Long> idsH=new ArrayList<>(); List<Long> idsH=new ArrayList<>();
...@@ -391,7 +391,7 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto ...@@ -391,7 +391,7 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
//更新电站施工状态 //更新电站施工状态
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState,ArrivalStateeEnum.已收货.getCode()); up.set(PeasantHousehold::getConstructionState,ArrivalStateeEnum.备货完成.getCode());
List<DocumentStation> idsk= model.getPeasantHouseholdId(); List<DocumentStation> idsk= model.getPeasantHouseholdId();
List<Long> idsH=new ArrayList<>(); List<Long> idsH=new ArrayList<>();
...@@ -410,7 +410,7 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto ...@@ -410,7 +410,7 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
//更新电站施工状态 //更新电站施工状态
LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<PeasantHousehold> up =new LambdaUpdateWrapper<>();
up.set(PeasantHousehold::getConstructionState,DeliveryStateeEnum.已发货.getCode()); up.set(PeasantHousehold::getConstructionState,ArrivalStateeEnum.备货中.getCode());
List<DocumentStation> idsk= model.getPeasantHouseholdId(); List<DocumentStation> idsk= model.getPeasantHouseholdId();
List<Long> idsH=new ArrayList<>(); List<Long> idsH=new ArrayList<>();
for (DocumentStation documentStation : idsk) { for (DocumentStation documentStation : idsk) {
......
...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; ...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.yeejoin.amos.boot.module.hygf.api.Enum.ArrivalStateeEnum;
import com.yeejoin.amos.boot.module.hygf.api.Enum.CodeEnum; import com.yeejoin.amos.boot.module.hygf.api.Enum.CodeEnum;
import com.yeejoin.amos.boot.module.hygf.api.Enum.WorkOrderEnum; import com.yeejoin.amos.boot.module.hygf.api.Enum.WorkOrderEnum;
import com.yeejoin.amos.boot.module.hygf.api.dto.*; import com.yeejoin.amos.boot.module.hygf.api.dto.*;
...@@ -92,6 +93,8 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor ...@@ -92,6 +93,8 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor
WorkflowFeignClient workflowFeignClient; WorkflowFeignClient workflowFeignClient;
@Autowired
PeasantHouseholdMapper peasantHouseholdMapper;
/** /**
* 分页查询 * 分页查询
...@@ -282,6 +285,15 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor ...@@ -282,6 +285,15 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor
up.set(WorkOrderPowerStation::getPowerStationConstructionStatus,WorkOrderEnum.施工中.getCode()); up.set(WorkOrderPowerStation::getPowerStationConstructionStatus,WorkOrderEnum.施工中.getCode());
}else{ }else{
up.set(WorkOrderPowerStation::getPowerStationConstructionStatus,WorkOrderEnum.待登记.getCode()); up.set(WorkOrderPowerStation::getPowerStationConstructionStatus,WorkOrderEnum.待登记.getCode());
WorkOrderPowerStation basicGridAcceptanc= workOrderPowerStationMapper.selectById(powerStationConstructionData.getWorkOrderPowerStationId());
//施工完成
LambdaUpdateWrapper<PeasantHousehold> up1 =new LambdaUpdateWrapper<>();
up1.set(PeasantHousehold::getConstructionState, ArrivalStateeEnum.并网完成.getCode());
long idsk= basicGridAcceptanc.getPeasantHouseholdId();
up1.eq(PeasantHousehold::getSequenceNbr,idsk);
peasantHouseholdMapper.update(null,up1);
} }
workOrderPowerStationMapper.update(null,up); workOrderPowerStationMapper.update(null,up);
//修改派工单状态 //修改派工单状态
......
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