|
@@ -7,8 +7,7 @@ import com.ozs.common.utils.DateUtils;
|
|
|
import com.ozs.common.utils.StringUtils;
|
|
|
import com.ozs.common.utils.bean.BeanUtils;
|
|
|
import com.ozs.pm.doman.*;
|
|
|
-import com.ozs.pm.doman.vo.requestVo.PmBookBuildingReqVo;
|
|
|
-import com.ozs.pm.doman.vo.requestVo.PmReqVo;
|
|
|
+import com.ozs.pm.doman.vo.requestVo.*;
|
|
|
import com.ozs.pm.doman.vo.responseVo.*;
|
|
|
import com.ozs.pm.mapper.PmDemandMapper;
|
|
|
import com.ozs.pm.service.*;
|
|
@@ -35,12 +34,14 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
{
|
|
|
@Autowired
|
|
|
private PmDemandMapper pmDemandMapper;
|
|
|
+
|
|
|
@Autowired
|
|
|
- private IPmDemandServeService iPmDemandServeService;
|
|
|
+ private IPmDemandEquipService iPmDemandEquipService;
|
|
|
@Autowired
|
|
|
private IPmDemandMaterialsService iPmDemandMaterialsService;
|
|
|
+
|
|
|
@Autowired
|
|
|
- private IPmDemandEquipService iPmDemandEquipService;
|
|
|
+ private IPmDemandServeService iPmDemandServeService;
|
|
|
@Autowired
|
|
|
private IPmDemandEngineeringService iPmDemandEngineeringService;
|
|
|
@Autowired
|
|
@@ -151,7 +152,7 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
responseVo.setFileMap(fileMap1);
|
|
|
}
|
|
|
|
|
|
- vo.setPmDemandEquipResponseVo(responseVo);
|
|
|
+ vo.setPmDemandEquipResVo(responseVo);
|
|
|
}
|
|
|
} else if(ProjectTypes.MATERIALTYPE.getCode().equals(vo.getProjectType())){ //物资类
|
|
|
PmDemandMaterials obj = new PmDemandMaterials();
|
|
@@ -171,7 +172,7 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
if(fileMap2 != null){
|
|
|
responseVo.setFileMap(fileMap2);
|
|
|
}
|
|
|
- vo.setPmDemandMaterialsResponseVo(responseVo);
|
|
|
+ vo.setPmDemandMaterialsResVo(responseVo);
|
|
|
}
|
|
|
} else if(ProjectTypes.SERVICESTYPE.getCode().equals(vo.getProjectType())){//服务类
|
|
|
PmDemandServe obj = new PmDemandServe();
|
|
@@ -191,7 +192,7 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
if(fileMap3 != null){
|
|
|
responseVo.setFileMap(fileMap3);
|
|
|
}
|
|
|
- vo.setPmDemandServeResponseVo(responseVo);
|
|
|
+ vo.setPmDemandServeResVo(responseVo);
|
|
|
}
|
|
|
} else if(ProjectTypes.PLANTOEXAMINETYPE.getCode().equals(vo.getProjectType())){//工程类
|
|
|
PmDemandEngineering obj = new PmDemandEngineering();
|
|
@@ -232,7 +233,7 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
if(fileMap4 != null){
|
|
|
responseVo.setFileMap(fileMap4);
|
|
|
}
|
|
|
- vo.setPmDemandEngineeringResponseVo(responseVo);
|
|
|
+ vo.setPmDemandEngineeringResVo(responseVo);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -245,19 +246,19 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
/**
|
|
|
* 查询采购需求列表
|
|
|
*
|
|
|
- * @param pmReqVo
|
|
|
+ * @param pmDemandReqVo
|
|
|
* @return 采购需求
|
|
|
*/
|
|
|
@Override
|
|
|
- public List<PmDemandResVo> selectPmDemandList(PmReqVo pmReqVo) {
|
|
|
+ public List<PmDemandResVo> selectPmDemandList(PmDemandReqVo pmDemandReqVo) {
|
|
|
PmDemand pmDemand = new PmDemand();
|
|
|
- pmDemand.setProjectName(pmReqVo.getProjectName());
|
|
|
- pmDemand.setPurchaseServices(pmReqVo.getPurchaseServiceStation());
|
|
|
- pmDemand.setProjectStatus(pmReqVo.getProjectStatus());
|
|
|
- pmDemand.setIsExcess(pmReqVo.getIsExcess());
|
|
|
+ pmDemand.setProjectName(pmDemandReqVo.getProjectName());
|
|
|
+ pmDemand.setPurchaseServices(pmDemandReqVo.getPurchaseServiceStation());
|
|
|
+ pmDemand.setProjectStatus(pmDemandReqVo.getProjectStatus());
|
|
|
+ pmDemand.setIsExcess(pmDemandReqVo.getIsExcess());
|
|
|
Map<String,Object> params = new HashMap<>();
|
|
|
- params.put("beginDate",pmReqVo.getBeginDate());
|
|
|
- params.put("endDate",pmReqVo.getEndDate());
|
|
|
+ params.put("beginDate", pmDemandReqVo.getBeginDate());
|
|
|
+ params.put("endDate", pmDemandReqVo.getEndDate());
|
|
|
pmDemand.setParams(params);
|
|
|
List<PmDemand> pmDemandList = pmDemandMapper.selectPmDemandList(pmDemand);
|
|
|
List<PmDemandResVo> pmDemandResponseVoList = new ArrayList<>();
|
|
@@ -352,13 +353,126 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
/**
|
|
|
* 需求建档
|
|
|
*
|
|
|
- * @param pmBookBuildingReqVo 采购需求
|
|
|
+ * @param vo 采购需求
|
|
|
* @return 结果
|
|
|
*/
|
|
|
@Override
|
|
|
- public int bookBuilding(PmBookBuildingReqVo pmBookBuildingReqVo) {
|
|
|
- PmDemand pmDemand = new PmDemand();
|
|
|
- pmDemand.setDemandId(pmBookBuildingReqVo.getDemandId());
|
|
|
+ public int bookBuilding(PmBookBuildingReqVo vo) {
|
|
|
+ PmDemand pmDemand = pmDemandMapper.selectPmDemandByDemandId(vo.getDemandId());
|
|
|
+ String projectType = pmDemand.getProjectType();
|
|
|
+ if(ProjectTypes.EQUIPMENTTYPE.getCode().equals(projectType)){ //装备类
|
|
|
+ PmDemandEquipReqVo pmDemandEquipReqVo = vo.getPmDemandEquipReqVo();
|
|
|
+ PmDemandEquip pmDemandEquipReq = new PmDemandEquip();
|
|
|
+ pmDemandEquipReq.setDemandId(vo.getDemandId());
|
|
|
+ PmDemandEquip pmDemandEquip = null;
|
|
|
+ List<PmDemandEquip> pmDemandEquipList = iPmDemandEquipService.selectPmDemandEquipList(pmDemandEquipReq);
|
|
|
+ if(pmDemandEquipList != null && pmDemandEquipList.size() > 0){
|
|
|
+ pmDemandEquip = pmDemandEquipList.get(0);
|
|
|
+ BeanUtils.copyProperties(pmDemandEquipReqVo,pmDemandEquip);
|
|
|
+ iPmDemandEquipService.updatePmDemandEquip(pmDemandEquip);
|
|
|
+ } else {
|
|
|
+ pmDemandEquip = new PmDemandEquip();
|
|
|
+ BeanUtils.copyProperties(pmDemandEquipReqVo,pmDemandEquip);
|
|
|
+ iPmDemandEquipService.insertPmDemandEquip(pmDemandEquip);
|
|
|
+ }
|
|
|
+
|
|
|
+ List<SysFileRef> sysFileRefs = pmDemandEquipReqVo.getSysFileRefs();
|
|
|
+ if (!ObjectUtils.isEmpty(sysFileRefs)) {
|
|
|
+ for (SysFileRef ref : sysFileRefs) {
|
|
|
+ ref.setRedId(pmDemandEquip.getDemandEquipId());
|
|
|
+ ref.setType(SysFileRefEnum.PM_DEMAND_EQUIP.getType());
|
|
|
+ ref.setCreated(vo.getUpdateBy());
|
|
|
+ ref.setCreateTime(new Date());
|
|
|
+ ref.setUpdated(vo.getUpdateBy());
|
|
|
+ ref.setUpdateTime(new Date());
|
|
|
+ sysFileRefService.save(ref);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else if(ProjectTypes.MATERIALTYPE.getCode().equals(projectType)) { //物资类
|
|
|
+ PmDemandMaterialsReqVo pmDemandMaterialsReqVo = vo.getPmDemandMaterialsReqVo();
|
|
|
+ PmDemandMaterials pmDemandMaterialsReq = new PmDemandMaterials();
|
|
|
+ pmDemandMaterialsReq.setDemandId(vo.getDemandId());
|
|
|
+ PmDemandMaterials pmDemandMaterials = null;
|
|
|
+ List<PmDemandMaterials> pmDemandMaterialsList = iPmDemandMaterialsService.selectPmDemandMaterialsList(pmDemandMaterialsReq);
|
|
|
+ if(pmDemandMaterialsList != null && pmDemandMaterialsList.size() > 0){
|
|
|
+ pmDemandMaterials = pmDemandMaterialsList.get(0);
|
|
|
+ BeanUtils.copyProperties(pmDemandMaterialsReqVo,pmDemandMaterials);
|
|
|
+ iPmDemandMaterialsService.updatePmDemandMaterials(pmDemandMaterials);
|
|
|
+ } else {
|
|
|
+ pmDemandMaterials = new PmDemandMaterials();
|
|
|
+ BeanUtils.copyProperties(pmDemandMaterialsReqVo,pmDemandMaterials);
|
|
|
+ iPmDemandMaterialsService.insertPmDemandMaterials(pmDemandMaterials);
|
|
|
+ }
|
|
|
+
|
|
|
+ List<SysFileRef> sysFileRefs = pmDemandMaterialsReqVo.getSysFileRefs();
|
|
|
+ if (!ObjectUtils.isEmpty(sysFileRefs)) {
|
|
|
+ for (SysFileRef ref : sysFileRefs) {
|
|
|
+ ref.setRedId(pmDemandMaterials.getDemandMaterialsId());
|
|
|
+ ref.setType(SysFileRefEnum.PM_DEMAND_MATERIALS.getType());
|
|
|
+ ref.setCreated(vo.getUpdateBy());
|
|
|
+ ref.setCreateTime(new Date());
|
|
|
+ ref.setUpdated(vo.getUpdateBy());
|
|
|
+ ref.setUpdateTime(new Date());
|
|
|
+ sysFileRefService.save(ref);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else if(ProjectTypes.SERVICESTYPE.getCode().equals(projectType)) { //服务类
|
|
|
+ PmDemandServeReqVo pmDemandServeReqVo = vo.getPmDemandServeReqVo();
|
|
|
+ PmDemandServe pmDemandServeReq = new PmDemandServe();
|
|
|
+ pmDemandServeReq.setDemandId(vo.getDemandId());
|
|
|
+ PmDemandServe pmDemandServe = null;
|
|
|
+ List<PmDemandServe> pmDemandServeList = iPmDemandServeService.selectPmDemandServeList(pmDemandServeReq);
|
|
|
+ if(pmDemandServeList != null && pmDemandServeList.size() > 0){
|
|
|
+ pmDemandServe = pmDemandServeList.get(0);
|
|
|
+ BeanUtils.copyProperties(pmDemandServeReqVo,pmDemandServe);
|
|
|
+ iPmDemandServeService.updatePmDemandServe(pmDemandServe);
|
|
|
+ } else {
|
|
|
+ pmDemandServe = new PmDemandServe();
|
|
|
+ BeanUtils.copyProperties(pmDemandServeReqVo,pmDemandServe);
|
|
|
+ iPmDemandServeService.insertPmDemandServe(pmDemandServe);
|
|
|
+ }
|
|
|
+ List<SysFileRef> sysFileRefs = pmDemandServeReqVo.getSysFileRefs();
|
|
|
+ if (!ObjectUtils.isEmpty(sysFileRefs)) {
|
|
|
+ for (SysFileRef ref : sysFileRefs) {
|
|
|
+ ref.setRedId(pmDemandServe.getDemandServeId());
|
|
|
+ ref.setType(SysFileRefEnum.PM_DEMAND_SERVE.getType());
|
|
|
+ ref.setCreated(vo.getUpdateBy());
|
|
|
+ ref.setCreateTime(new Date());
|
|
|
+ ref.setUpdated(vo.getUpdateBy());
|
|
|
+ ref.setUpdateTime(new Date());
|
|
|
+ sysFileRefService.save(ref);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else if(ProjectTypes.PLANTOEXAMINETYPE.getCode().equals(projectType)) { //工程类
|
|
|
+ PmDemandEngineeringReqVo pmDemandEngineeringReqVo = vo.getPmDemandEngineeringReqVo();
|
|
|
+ PmDemandEngineering pmDemandEngineeringReq = new PmDemandEngineering();
|
|
|
+ pmDemandEngineeringReq.setDemandId(vo.getDemandId());
|
|
|
+ PmDemandEngineering pmDemandEngineering = null;
|
|
|
+ List<PmDemandEngineering> pmDemandEngineeringList = iPmDemandEngineeringService.selectPmDemandEngineeringList(pmDemandEngineeringReq);
|
|
|
+ if(pmDemandEngineeringList != null && pmDemandEngineeringList.size() > 0){
|
|
|
+ pmDemandEngineering = pmDemandEngineeringList.get(0);
|
|
|
+ BeanUtils.copyProperties(pmDemandEngineeringReqVo,pmDemandEngineering);
|
|
|
+ iPmDemandEngineeringService.updatePmDemandEngineering(pmDemandEngineering);
|
|
|
+ } else {
|
|
|
+ pmDemandEngineering = new PmDemandEngineering();
|
|
|
+ BeanUtils.copyProperties(pmDemandEngineeringReqVo,pmDemandEngineering);
|
|
|
+ iPmDemandEngineeringService.insertPmDemandEngineering(pmDemandEngineering);
|
|
|
+ }
|
|
|
+ List<SysFileRef> sysFileRefs = pmDemandEngineeringReqVo.getSysFileRefs();
|
|
|
+ if (!ObjectUtils.isEmpty(sysFileRefs)) {
|
|
|
+ for (SysFileRef ref : sysFileRefs) {
|
|
|
+ ref.setRedId(pmDemandEngineering.getDemandEngineeringId());
|
|
|
+ ref.setType(SysFileRefEnum.PM_DEMAND_ENGINEERING.getType());
|
|
|
+ ref.setCreated(vo.getUpdateBy());
|
|
|
+ ref.setCreateTime(new Date());
|
|
|
+ ref.setUpdated(vo.getUpdateBy());
|
|
|
+ ref.setUpdateTime(new Date());
|
|
|
+ sysFileRefService.save(ref);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ pmDemand.setUpdateBy(vo.getUpdateBy());
|
|
|
pmDemand.setUpdateTime(DateUtils.getNowDate());
|
|
|
return pmDemandMapper.updatePmDemand(pmDemand);
|
|
|
}
|
|
@@ -397,14 +511,15 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
/**
|
|
|
* 提交采购需求
|
|
|
*
|
|
|
- * @param pmReqVo
|
|
|
+ * @param pmDemandReqVo
|
|
|
* @return 结果
|
|
|
*/
|
|
|
@Override
|
|
|
- public int commit(PmReqVo pmReqVo) {
|
|
|
+ public int commit(PmDemandReqVo pmDemandReqVo) {
|
|
|
PmDemand pmDemand = new PmDemand();
|
|
|
- pmDemand.setDemandId(pmReqVo.getDemandId());
|
|
|
+ pmDemand.setDemandId(pmDemandReqVo.getDemandId());
|
|
|
pmDemand.setProjectStatus(Long.parseLong(PmProjectStatus.DEMAND_WAIT_AUDIT.getCode()));
|
|
|
+ pmDemand.setUpdateBy(pmDemandReqVo.getUpdateBy());
|
|
|
pmDemand.setUpdateTime(DateUtils.getNowDate());
|
|
|
return pmDemandMapper.updatePmDemand(pmDemand);
|
|
|
}
|
|
@@ -412,26 +527,27 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
/**
|
|
|
* 审核采购需求通过
|
|
|
*
|
|
|
- * @param pmReqVo
|
|
|
+ * @param pmDemandReqVo
|
|
|
* @return 结果
|
|
|
*/
|
|
|
@Override
|
|
|
- public int reviewTo(PmReqVo pmReqVo) {
|
|
|
+ public int reviewTo(PmDemandReqVo pmDemandReqVo) {
|
|
|
PmDemand pmDemand = new PmDemand();
|
|
|
- pmDemand.setDemandId(pmReqVo.getDemandId());
|
|
|
+ pmDemand.setDemandId(pmDemandReqVo.getDemandId());
|
|
|
pmDemand.setProjectStatus(Long.parseLong(PmProjectStatus.TASK_WAIT_RELEASE.getCode()));
|
|
|
- List<SysFileRef> sysFileRefs = pmReqVo.getSysFileRefs();
|
|
|
+ List<SysFileRef> sysFileRefs = pmDemandReqVo.getSysFileRefs();
|
|
|
if (!ObjectUtils.isEmpty(sysFileRefs)) {
|
|
|
for (SysFileRef ref : sysFileRefs) {
|
|
|
- ref.setRedId(pmReqVo.getDemandId());
|
|
|
+ ref.setRedId(pmDemandReqVo.getDemandId());
|
|
|
ref.setType(SysFileRefEnum.PM_DEMAND_EXAMINE.getType());
|
|
|
- ref.setCreated(pmReqVo.getUpdateBy());
|
|
|
+ ref.setCreated(pmDemandReqVo.getUpdateBy());
|
|
|
ref.setCreateTime(new Date());
|
|
|
- ref.setUpdated(pmReqVo.getUpdateBy());
|
|
|
+ ref.setUpdated(pmDemandReqVo.getUpdateBy());
|
|
|
ref.setUpdateTime(new Date());
|
|
|
sysFileRefService.save(ref);
|
|
|
}
|
|
|
}
|
|
|
+ pmDemand.setUpdateBy(pmDemandReqVo.getUpdateBy());
|
|
|
pmDemand.setUpdateTime(DateUtils.getNowDate());
|
|
|
pmDemand.setAuditTime(DateUtils.getNowDate());
|
|
|
return pmDemandMapper.updatePmDemand(pmDemand);
|
|
@@ -440,15 +556,16 @@ public class PmDemandServiceImpl implements IPmDemandService
|
|
|
/**
|
|
|
* 审核采购需求退回
|
|
|
*
|
|
|
- * @param pmReqVo
|
|
|
+ * @param pmDemandReqVo
|
|
|
* @return 结果
|
|
|
*/
|
|
|
@Override
|
|
|
- public int reviewReturn(PmReqVo pmReqVo) {
|
|
|
+ public int reviewReturn(PmDemandReqVo pmDemandReqVo) {
|
|
|
PmDemand pmDemand = new PmDemand();
|
|
|
- pmDemand.setDemandId(pmReqVo.getDemandId());
|
|
|
+ pmDemand.setDemandId(pmDemandReqVo.getDemandId());
|
|
|
pmDemand.setProjectStatus(Long.parseLong(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()));
|
|
|
- pmDemand.setAdjustReason(pmReqVo.getRefuseReason());
|
|
|
+ pmDemand.setAdjustReason(pmDemandReqVo.getRefuseReason());
|
|
|
+ pmDemand.setUpdateBy(pmDemandReqVo.getUpdateBy());
|
|
|
pmDemand.setUpdateTime(DateUtils.getNowDate());
|
|
|
pmDemand.setAuditTime(DateUtils.getNowDate());
|
|
|
return pmDemandMapper.updatePmDemand(pmDemand);
|