Commit 5fdf1b34 authored by limei's avatar limei

Merge branch 'developer' of http://39.98.45.134:8090/moa/amos-boot-biz into developer

parents 892d85ad ca1acbf2
package com.yeejoin.amos.boot.module.ugp.api.Enum;
import lombok.AllArgsConstructor;
import lombok.Getter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @Author cpp
* @Description
* @Date 2022/11/10
*/
@Getter
@AllArgsConstructor
public enum AuditEnum {
符合("符合","1"),
不符合且不需要整改("不符合且不需要整改","0"),
不符合且需要重新提交资料("不符合且需要重新提交资料","2");
private String name;
private String status;
public static Map<String,String> getStatusByName = new HashMap<>();
public static Map<String,String> getNameByStatus = new HashMap<>();
static{
for(AuditEnum auditEnum:AuditEnum.values()){
getStatusByName.put(auditEnum.name,auditEnum.status);
getNameByStatus.put(auditEnum.status,auditEnum.name);
}
}
}
...@@ -21,7 +21,8 @@ public enum ProjectInitiationEnum { ...@@ -21,7 +21,8 @@ public enum ProjectInitiationEnum {
监检员分配("10","监检员分配","JJYFP"), 监检员分配("10","监检员分配","JJYFP"),
监检员审核("11","监检员审核","JJYSH"), 监检员审核("11","监检员审核","JJYSH"),
项目关闭("12","项目关闭","XMGB"), 项目关闭("12","项目关闭","XMGB"),
接受审查意见("13","接受审查意见","JSSCYJ"); 接受审查意见("13","接受审查意见","JSSCYJ"),
流程结束("14","流程结束!","LCJS");
private String status; private String status;
private String name; private String name;
......
...@@ -31,11 +31,20 @@ ...@@ -31,11 +31,20 @@
<artifactId>fastjson</artifactId> <artifactId>fastjson</artifactId>
<version>1.2.24</version> <version>1.2.24</version>
</dependency> </dependency>
<!--pqr 和wps-->
<dependency> <dependency>
<groupId>fakepath</groupId> <groupId>fakepath</groupId>
<artifactId>ugp-welding-evaluation-inspection-sdk</artifactId> <artifactId>ugp-welding-evaluation-inspection-sdk</artifactId>
<version>1.0.1</version> <version>1.0.1</version>
</dependency> </dependency>
<!--调用python的依赖-->
<dependency>
<groupId>org.python</groupId>
<artifactId>jython-standalone</artifactId>
<version>2.7.0</version>
</dependency>
</dependencies> </dependencies>
<build> <build>
......
...@@ -241,13 +241,13 @@ public class CompanyController extends BaseController { ...@@ -241,13 +241,13 @@ public class CompanyController extends BaseController {
} }
/*** /***
* 获取当前登录人所在单位下的所有部门 * 分页获取当前登录人所在单位下的所有部门
* @param * @param
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@GetMapping(value = "/deptList") @GetMapping(value = "/deptList")
@ApiOperation(httpMethod = "GET", value = "部門新增", notes = "部門新增") @ApiOperation(httpMethod = "GET", value = "分页获取当前登录人所在单位下的所有部门", notes = "分页获取当前登录人所在单位下的所有部门")
public ResponseModel<IPage> getDept(String size, String current) { public ResponseModel<IPage> getDept(String size, String current) {
Page<OrgUsr> page = new Page<>(); Page<OrgUsr> page = new Page<>();
page.setSize(Long.parseLong(size)); page.setSize(Long.parseLong(size));
...@@ -255,6 +255,19 @@ public class CompanyController extends BaseController { ...@@ -255,6 +255,19 @@ public class CompanyController extends BaseController {
return ResponseHelper.buildResponse(orgServiceImpl.getCompanyDept(page)); return ResponseHelper.buildResponse(orgServiceImpl.getCompanyDept(page));
} }
/***
* 获取当前登录人所在单位下的所有部门(全部)
* @param
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@GetMapping(value = "/dept")
@ApiOperation(httpMethod = "GET", value = "获取当前登录人所在单位下的所有部门(全部)", notes = "获取当前登录人所在单位下的所有部门(全部)")
public ResponseModel<List> getDept() {
Page<OrgUsr> page = new Page<>(0,Long.MAX_VALUE);
return ResponseHelper.buildResponse(orgServiceImpl.getCompanyDept(page).getRecords());
}
/** /**
* 企业注册:获取单位类型 * 企业注册:获取单位类型
......
...@@ -5,15 +5,18 @@ import com.alibaba.fastjson.JSONArray; ...@@ -5,15 +5,18 @@ import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yeejoin.amos.boot.module.common.biz.utils.CommonResponseUtil;
import com.yeejoin.amos.boot.module.ugp.api.dto.AttachmentDto; import com.yeejoin.amos.boot.module.ugp.api.dto.AttachmentDto;
import com.yeejoin.amos.boot.module.ugp.api.dto.CompanyDto; import com.yeejoin.amos.boot.module.ugp.api.dto.CompanyDto;
import com.yeejoin.amos.boot.module.ugp.api.dto.WelderDto; import com.yeejoin.amos.boot.module.ugp.api.dto.WelderDto;
import com.yeejoin.amos.boot.module.ugp.api.entity.Attachment; import com.yeejoin.amos.boot.module.ugp.api.entity.Attachment;
import com.yeejoin.amos.boot.module.ugp.api.entity.Company; import com.yeejoin.amos.boot.module.ugp.api.entity.Company;
import com.yeejoin.amos.boot.module.ugp.api.entity.Equipment; import com.yeejoin.amos.boot.module.ugp.api.entity.Equipment;
import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource;
import com.yeejoin.amos.boot.module.ugp.api.mapper.AttachmentMapper; import com.yeejoin.amos.boot.module.ugp.api.mapper.AttachmentMapper;
import com.yeejoin.amos.boot.module.ugp.api.mapper.EquipmentMapper; import com.yeejoin.amos.boot.module.ugp.api.mapper.EquipmentMapper;
import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper;
import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify; import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify;
import com.yeejoin.amos.boot.module.ugp.biz.service.impl.AttachmentServiceImpl; import com.yeejoin.amos.boot.module.ugp.biz.service.impl.AttachmentServiceImpl;
import com.yeejoin.amos.boot.module.ugp.biz.service.impl.OrgServiceImpl; import com.yeejoin.amos.boot.module.ugp.biz.service.impl.OrgServiceImpl;
...@@ -66,6 +69,8 @@ public class EquipmentController extends BaseController { ...@@ -66,6 +69,8 @@ public class EquipmentController extends BaseController {
@Autowired @Autowired
OrgServiceImpl orgService; OrgServiceImpl orgService;
@Autowired
ProjectResourceMapper projectResourceMapper;
/** /**
* 新增设备信息表 * 新增设备信息表
...@@ -108,8 +113,17 @@ public class EquipmentController extends BaseController { ...@@ -108,8 +113,17 @@ public class EquipmentController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@DeleteMapping(value = "/{sequenceNbr}") @DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除设备信息表", notes = "根据sequenceNbr删除设备信息表") @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除设备信息表", notes = "根据sequenceNbr删除设备信息表")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){ public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") List<Long> sequenceNbr) throws Exception {
return ResponseHelper.buildResponse(equipmentServiceImpl.removeById(sequenceNbr)); LambdaQueryWrapper<ProjectResource> wrapper = new LambdaQueryWrapper<>();
for (Long i:sequenceNbr){
wrapper.eq(ProjectResource::getResourceId,i);
if (!projectResourceMapper.selectList(wrapper).isEmpty()){
return CommonResponseUtil.failure("无法删除,设备:"+equipmentServiceImpl.getById(i).getName()+"已绑定项目");
}
}
return ResponseHelper.buildResponse(equipmentServiceImpl.removeByIds(sequenceNbr));
} }
/** /**
......
...@@ -136,7 +136,7 @@ public class InspectionController { ...@@ -136,7 +136,7 @@ public class InspectionController {
return page; return page;
} }
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "", notes = "") @ApiOperation(httpMethod = "GET", value = "", notes = "")
@GetMapping("/saveInfo") @GetMapping("/saveInfo")
public ResponseModel<String> saveInfo(@RequestBody JSONObject jsonObject) { public ResponseModel<String> saveInfo(@RequestBody JSONObject jsonObject) {
......
...@@ -2,18 +2,21 @@ package com.yeejoin.amos.boot.module.ugp.biz.controller; ...@@ -2,18 +2,21 @@ package com.yeejoin.amos.boot.module.ugp.biz.controller;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource;
import com.yeejoin.amos.boot.module.ugp.api.mapper.AttachmentMapper; import com.yeejoin.amos.boot.module.ugp.api.mapper.AttachmentMapper;
import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper;
import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify; import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify;
import com.yeejoin.amos.boot.module.ugp.biz.service.impl.AttachmentServiceImpl; import com.yeejoin.amos.boot.module.ugp.biz.service.impl.*;
import com.yeejoin.amos.boot.module.ugp.biz.service.impl.EquipmentServiceImpl;
import com.yeejoin.amos.boot.module.ugp.biz.service.impl.OrgServiceImpl;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.biz.common.controller.BaseController; import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import com.yeejoin.amos.boot.module.ugp.biz.service.impl.MaterialServiceImpl;
import org.typroject.tyboot.core.restful.utils.ResponseHelper; import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel; import org.typroject.tyboot.core.restful.utils.ResponseModel;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -43,6 +46,8 @@ public class MaterialController extends BaseController { ...@@ -43,6 +46,8 @@ public class MaterialController extends BaseController {
AttachmentMapper attachmentMapper; AttachmentMapper attachmentMapper;
@Autowired @Autowired
OrgServiceImpl orgService; OrgServiceImpl orgService;
@Autowired
ProjectResourceMapper projectResourceMapper;
/** /**
...@@ -81,9 +86,19 @@ public class MaterialController extends BaseController { ...@@ -81,9 +86,19 @@ public class MaterialController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@DeleteMapping(value = "/{sequenceNbr}") @DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除材料信息表", notes = "根据sequenceNbr删除材料信息表") @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除材料信息表", notes = "根据sequenceNbr删除材料信息表")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){ public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") List<Long> sequenceNbr) throws Exception {
return ResponseHelper.buildResponse(materialServiceImpl.removeById(sequenceNbr));
LambdaQueryWrapper<ProjectResource> wrapper = new LambdaQueryWrapper<>();
for (Long i:sequenceNbr){
wrapper.eq(ProjectResource::getResourceId,i);
if (!projectResourceMapper.selectList(wrapper).isEmpty()){
throw new Exception("无法删除,已绑定项目");
} }
}
return ResponseHelper.buildResponse(materialServiceImpl.removeByIds(sequenceNbr));
}
/** /**
* 根据sequenceNbr查询 * 根据sequenceNbr查询
......
...@@ -274,9 +274,18 @@ public class ProjectController extends BaseController { ...@@ -274,9 +274,18 @@ public class ProjectController extends BaseController {
public ResponseModel<String> processProject(@RequestParam("sequenceNbr") String sequenceNbr,String option,@RequestBody JSONObject json){ public ResponseModel<String> processProject(@RequestParam("sequenceNbr") String sequenceNbr,String option,@RequestBody JSONObject json){
Project project = projectServiceImpl.getById(sequenceNbr); Project project = projectServiceImpl.getById(sequenceNbr);
JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(project)); JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(project));
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核不通过");
if("1".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核通过"); jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核通过");
String insDep = json.getString(XJConstant.INS_DEP);
String insPerson = json.getString(XJConstant.INS_PRESON);
if(!ValidationUtil.isEmpty(insPerson)){
jsonObject.put(XJConstant.INS_PRESON,insPerson);
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"监检员待审核");
} else if (!ValidationUtil.isEmpty(insDep)) {
jsonObject.put(XJConstant.INS_DEP,insDep);
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"监检员待分配");
}
if("0".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核不通过");
} }
if(ValidationUtil.isEmpty(option)){ if(ValidationUtil.isEmpty(option)){
option = json.getString(XJConstant.PROCESS_PROJECT_STATE); option = json.getString(XJConstant.PROCESS_PROJECT_STATE);
...@@ -284,14 +293,16 @@ public class ProjectController extends BaseController { ...@@ -284,14 +293,16 @@ public class ProjectController extends BaseController {
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审批通过"); jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审批通过");
} else if ("0".equals(option)){ } else if ("0".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审批不通过"); jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审批不通过");
} else if ("2".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审核通过");
option = "1";
} else if ("3".equals(option)){ } else if ("3".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"监检科室待分配");
option = "1";
} else if ("4".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审核不通过"); jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审核不通过");
option = "0"; option = "0";
} }
}
if(ValidationUtil.isEmpty(option)){
option = "1";
} }
projectInitiationService.execute(project.getInstanceId(),jsonObject,option); projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
return ResponseHelper.buildResponse("ok"); return ResponseHelper.buildResponse("ok");
......
...@@ -5,7 +5,6 @@ import com.yeejoin.amos.boot.module.ugp.api.Enum.StageEnum; ...@@ -5,7 +5,6 @@ import com.yeejoin.amos.boot.module.ugp.api.Enum.StageEnum;
import com.yeejoin.amos.boot.module.ugp.api.dto.*; import com.yeejoin.amos.boot.module.ugp.api.dto.*;
import com.yeejoin.amos.boot.module.ugp.api.entity.Verify; import com.yeejoin.amos.boot.module.ugp.api.entity.Verify;
import com.yeejoin.amos.boot.module.ugp.api.service.IVerifyService; import com.yeejoin.amos.boot.module.ugp.api.service.IVerifyService;
import netscape.javascript.JSObject;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
...@@ -64,7 +63,7 @@ public class VerifyController extends BaseController { ...@@ -64,7 +63,7 @@ public class VerifyController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/{sequenceNbr}") @PutMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新智能监检管理表", notes = "根据sequenceNbr更新智能监检管理表") @ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新智能监检管理表", notes = "根据sequenceNbr更新智能监检管理表")
public ResponseModel<VerifyDto> updateBySequenceNbrVerify(@RequestBody VerifyDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) { public ResponseModel<VerifyDto> updateBySequenceNbrVerify(@RequestBody VerifyDto model, @PathVariable(value = "sequenceNbr") Long sequenceNbr) {
model.setSequenceNbr(sequenceNbr); model.setSequenceNbr(sequenceNbr);
return ResponseHelper.buildResponse(verifyServiceImpl.updateWithModel(model)); return ResponseHelper.buildResponse(verifyServiceImpl.updateWithModel(model));
} }
...@@ -78,7 +77,7 @@ public class VerifyController extends BaseController { ...@@ -78,7 +77,7 @@ public class VerifyController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}") @DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除智能监检管理表", notes = "根据sequenceNbr删除智能监检管理表") @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除智能监检管理表", notes = "根据sequenceNbr删除智能监检管理表")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){ public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr) {
return ResponseHelper.buildResponse(verifyServiceImpl.removeById(sequenceNbr)); return ResponseHelper.buildResponse(verifyServiceImpl.removeById(sequenceNbr));
} }
...@@ -90,7 +89,7 @@ public class VerifyController extends BaseController { ...@@ -90,7 +89,7 @@ public class VerifyController extends BaseController {
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/{sequenceNbr}") @GetMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个智能监检管理表", notes = "根据sequenceNbr查询单个智能监检管理表") @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个智能监检管理表", notes = "根据sequenceNbr查询单个智能监检管理表")
public ResponseModel<VerifyDto> selectOne(@PathVariable Long sequenceNbr) { public ResponseModel<VerifyDto> selectOne(@PathVariable Long sequenceNbr) {
return ResponseHelper.buildResponse(verifyServiceImpl.queryBySeq(sequenceNbr)); return ResponseHelper.buildResponse(verifyServiceImpl.queryBySeq(sequenceNbr));
} }
...@@ -104,10 +103,10 @@ public class VerifyController extends BaseController { ...@@ -104,10 +103,10 @@ public class VerifyController extends BaseController {
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/page") @GetMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "智能监检管理表分页查询", notes = "智能监检管理表分页查询") @ApiOperation(httpMethod = "GET", value = "智能监检管理表分页查询", notes = "智能监检管理表分页查询")
public ResponseModel<Page<VerifyDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam public ResponseModel<Page<VerifyDto>> queryForPage(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size) { (value = "size") int size) {
Page<VerifyDto> page = new Page<VerifyDto>(); Page<VerifyDto> page = new Page<VerifyDto>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(verifyServiceImpl.queryForVerifyPage(page)); return ResponseHelper.buildResponse(verifyServiceImpl.queryForVerifyPage(page));
...@@ -118,24 +117,17 @@ public class VerifyController extends BaseController { ...@@ -118,24 +117,17 @@ public class VerifyController extends BaseController {
* *
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "GET",value = "智能监检管理表列表全部数据查询", notes = "智能监检管理表列表全部数据查询") @ApiOperation(httpMethod = "GET", value = "智能监检管理表列表全部数据查询", notes = "智能监检管理表列表全部数据查询")
@GetMapping(value = "/list") @GetMapping(value = "/list")
public ResponseModel<List<VerifyDto>> selectForList() { public ResponseModel<List<VerifyDto>> selectForList() {
return ResponseHelper.buildResponse(verifyServiceImpl.queryForVerifyList()); return ResponseHelper.buildResponse(verifyServiceImpl.queryForVerifyList( ));
} }
/**
* cpp
* <p>
* 焊接管材检验信息列表
/** cpp
* *
*焊接管材检验信息列表
* @param current * @param current
* @param size * @param size
* @return * @return
...@@ -145,15 +137,18 @@ public class VerifyController extends BaseController { ...@@ -145,15 +137,18 @@ public class VerifyController extends BaseController {
@GetMapping(value = "/selectTubular") @GetMapping(value = "/selectTubular")
@ApiOperation(httpMethod = "GET", value = "焊接管材检验信息列表", notes = "焊接管材检验信息列表") @ApiOperation(httpMethod = "GET", value = "焊接管材检验信息列表", notes = "焊接管材检验信息列表")
public ResponseModel<Page<SmartListDto>> selectTubular(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<SmartListDto>> selectTubular(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,SmartListDto smartListDto) { (value = "size") int size, SmartListDto smartListDto) {
Page<SmartListDto> page = new Page<>(); Page<SmartListDto> page = new Page<>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前管材质量.getStage(),page,smartListDto)); return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前管材质量.getStage( ), page, smartListDto));
} }
/** cpp
/**
* cpp
* <p>
* 查询焊接人员检验信息列表
* *
*查询焊接人员检验信息列表
* @param current * @param current
* @param size * @param size
* @param * @param
...@@ -164,34 +159,38 @@ public class VerifyController extends BaseController { ...@@ -164,34 +159,38 @@ public class VerifyController extends BaseController {
@GetMapping(value = "/selectWorker") @GetMapping(value = "/selectWorker")
@ApiOperation(httpMethod = "GET", value = "查询焊接人员检验信息列表", notes = "查询焊接人员检验信息列表") @ApiOperation(httpMethod = "GET", value = "查询焊接人员检验信息列表", notes = "查询焊接人员检验信息列表")
public ResponseModel<Page<SmartListDto>> selectWorker(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<SmartListDto>> selectWorker(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,SmartListDto smartListDto) { (value = "size") int size, SmartListDto smartListDto) {
Page<SmartListDto> page = new Page<>(); Page<SmartListDto> page = new Page<>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前人员.getStage(),page,smartListDto)); return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前人员.getStage( ), page, smartListDto));
} }
/** cpp /**
* cpp
* <p>
* 查询焊接设备检验信息列表
* *
*查询焊接设备检验信息列表
* @param current * @param current
* @param size * @param size
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@GetMapping(value = "/selectFacility") @GetMapping(value = "/selectFacility")
@ApiOperation(httpMethod = "GET", value = "查询焊接设备检验信息列表", notes = "查询焊接设备检验信息列表") @ApiOperation(httpMethod = "GET", value = "查询焊接设备检验信息列表", notes = "查询焊接设备检验信息列表")
public ResponseModel<Page<SmartListDto>> selectFacility(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<SmartListDto>> selectFacility(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,SmartListDto smartListDto) { (value = "size") int size, SmartListDto smartListDto) {
Page<SmartListDto> page = new Page<>(); Page<SmartListDto> page = new Page<>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前设备.getStage(),page,smartListDto)); return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前设备.getStage( ), page, smartListDto));
} }
/** cpp
/**
* cpp
* <p>
* 查询焊接工艺检验信息列表
* *
*查询焊接工艺检验信息列表
* @param current * @param current
* @param size * @param size
* @return * @return
...@@ -201,34 +200,36 @@ public class VerifyController extends BaseController { ...@@ -201,34 +200,36 @@ public class VerifyController extends BaseController {
@GetMapping(value = "/selectCraft") @GetMapping(value = "/selectCraft")
@ApiOperation(httpMethod = "GET", value = "查询焊接工艺检验信息列表", notes = "查询焊接工艺检验信息列表") @ApiOperation(httpMethod = "GET", value = "查询焊接工艺检验信息列表", notes = "查询焊接工艺检验信息列表")
public ResponseModel<Page<SmartListDto>> selectCraft(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<SmartListDto>> selectCraft(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,SmartListDto smartListDto) { (value = "size") int size, SmartListDto smartListDto) {
Page<SmartListDto> page = new Page<>(); Page<SmartListDto> page = new Page<>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(service.commonality(StageEnum.焊接工艺.getStage(),page,smartListDto)); return ResponseHelper.buildResponse(service.commonality(StageEnum.焊接工艺.getStage( ), page, smartListDto));
} }
/** cpp
/**
* cpp
* <p>
* 查询管道耐压检验信息列表
* *
*查询管道耐压检验信息列表
* @param current * @param current
* @param size * @param size
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@GetMapping(value = "/selectVoltage") @GetMapping(value = "/selectVoltage")
@ApiOperation(httpMethod = "GET", value = "查询管道耐压检验信息列表", notes = "查询管道耐压检验信息列表") @ApiOperation(httpMethod = "GET", value = "查询管道耐压检验信息列表", notes = "查询管道耐压检验信息列表")
public ResponseModel<Page<SmartListDto>> selectVoltage(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<SmartListDto>> selectVoltage(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,SmartListDto smartListDto) { (value = "size") int size, SmartListDto smartListDto) {
Page<SmartListDto> page = new Page<>(); Page<SmartListDto> page = new Page<>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(service.commonality(StageEnum.管道耐压.getStage(),page,smartListDto)); return ResponseHelper.buildResponse(service.commonality(StageEnum.管道耐压.getStage( ), page, smartListDto));
} }
/** /**
* 敷设质量 * 敷设质量
*
* @param current * @param current
* @param size * @param size
* @param smartListDto * @param smartListDto
...@@ -238,35 +239,37 @@ public class VerifyController extends BaseController { ...@@ -238,35 +239,37 @@ public class VerifyController extends BaseController {
@GetMapping(value = "/depth") @GetMapping(value = "/depth")
@ApiOperation(httpMethod = "GET", value = "敷设质量", notes = "敷设质量") @ApiOperation(httpMethod = "GET", value = "敷设质量", notes = "敷设质量")
public ResponseModel<Page<SmartListDto>> depth(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<SmartListDto>> depth(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,SmartListDto smartListDto) { (value = "size") int size, SmartListDto smartListDto) {
Page<SmartListDto> page = new Page<>(); Page<SmartListDto> page = new Page<>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(service.commonality(StageEnum.敷设质量.getStage(),page, smartListDto)); return ResponseHelper.buildResponse(service.commonality(StageEnum.敷设质量.getStage( ), page, smartListDto));
} }
/** cpp /**
* cpp
* <p>
* 位置标定检验列表
* *
*位置标定检验列表
* @param current * @param current
* @param size * @param size
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY)
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@GetMapping(value = "/selectLocation") @GetMapping(value = "/selectLocation")
@ApiOperation(httpMethod = "GET", value = "敷设位置标定检验列表", notes = "敷设位置标定检验列表") @ApiOperation(httpMethod = "GET", value = "敷设位置标定检验列表", notes = "敷设位置标定检验列表")
public ResponseModel<Page<SmartListDto>> selectLocation(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<SmartListDto>> selectLocation(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,SmartListDto smartListDto) { (value = "size") int size, SmartListDto smartListDto) {
Page<SmartListDto> page = new Page<>(); Page<SmartListDto> page = new Page<>( );
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(service.commonality(StageEnum.定位.getStage(),page, smartListDto)); return ResponseHelper.buildResponse(service.commonality(StageEnum.定位.getStage( ), page, smartListDto));
} }
/** /**
* cpp * cpp
* 校验 * 校验
*
* @param jsonObject * @param jsonObject
* @return * @return
*/ */
...@@ -280,26 +283,28 @@ public class VerifyController extends BaseController { ...@@ -280,26 +283,28 @@ public class VerifyController extends BaseController {
/** /**
* cpp * cpp
* 主键id查询verity表 * 主键id查询verity表
*
* @param * @param
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@GetMapping(value = "/selectById") @GetMapping(value = "/selectById")
@ApiOperation(httpMethod = "GET", value = "主键id查询verity表", notes = "主键id查询verity表") @ApiOperation(httpMethod = "GET", value = "主键id查询verity表", notes = "主键id查询verity表")
public ResponseModel<OpenDto> selectById(@RequestParam Long sequenceNbr ) { public ResponseModel<OpenDto> selectById(@RequestParam Long sequenceNbr) {
return ResponseHelper.buildResponse(verifyServiceImpl.selectById(sequenceNbr)); return ResponseHelper.buildResponse(verifyServiceImpl.selectById(sequenceNbr));
} }
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@GetMapping(value = "/photo") @GetMapping(value = "/photo")
@ApiOperation(httpMethod = "GET", value = "获取图片", notes = "获取图片") @ApiOperation(httpMethod = "GET", value = "获取图片", notes = "获取图片")
public ResponseModel<Map> photo(@RequestParam Long sequenceNbr ) { public ResponseModel<Map> photo(@RequestParam Long sequenceNbr) {
Map map =new HashMap<>(); Map map = new HashMap<>( );
map.put("newPhoto","https://img2.baidu.com/it/u=806791452,2765805606&fm=253&fmt=auto&app=138&f=JPEG?w=350&h=500"); map.put("newPhoto", "https://img2.baidu.com/it/u=806791452,2765805606&fm=253&fmt=auto&app=138&f=JPEG?w=350&h=500");
return ResponseHelper.buildResponse(map); return ResponseHelper.buildResponse(map);
} }
}
...@@ -315,60 +320,5 @@ public class VerifyController extends BaseController { ...@@ -315,60 +320,5 @@ public class VerifyController extends BaseController {
/**
* 焊接工艺效验
*/
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "POST", value = "焊接工艺效验", notes = "焊接工艺效验")
@PostMapping(value = "/weldeEffect")
public ResponseModel<String> weldEffect(@RequestBody JSONObject jsonObject) {
return ResponseHelper.buildResponse(verifyServiceImpl.weldEffect(jsonObject));
}
/**
* 管材耐压效验
*/
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "POST", value = "管材耐压效验", notes = "管材耐压效验")
@PostMapping(value = "/materialEffect")
public ResponseModel<String> materialEffect(@RequestBody JSONObject jsonObject) {
return ResponseHelper.buildResponse(verifyServiceImpl.materialEffect(jsonObject));
}
/**
* 敷设质量检验
*/
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "POST", value = "敷设质量检验", notes = "敷设质量检验")
@PostMapping(value = "/layEffect")
public ResponseModel<String> layEffect(@RequestBody JSONObject jsonObject) {
return ResponseHelper.buildResponse(verifyServiceImpl.layEffect(jsonObject));
}
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "POST", value = "焊口敷设位置标定检验", notes = "焊口敷设位置标定检验")
@PostMapping(value = "/postadd")
public ResponseModel<String> postadd(@RequestBody JSONObject jsonObject) {
String code = jsonObject.getString("code");
Long projectId = jsonObject.getLong("projectId");
jsonObject.getString("userId");
Verify verify = new Verify( );
verify.setProjectId(projectId);
verify.setTargetInfo(code);
boolean save = verifyServiceImpl.save(verify);
if (!save) {
//
return ResponseHelper.buildResponse("新增失败");
}
return ResponseHelper.buildResponse("成功");
}
}
package com.yeejoin.amos.boot.module.ugp.biz.controller; package com.yeejoin.amos.boot.module.ugp.biz.controller;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource;
import com.yeejoin.amos.boot.module.ugp.api.entity.Weld; import com.yeejoin.amos.boot.module.ugp.api.entity.Weld;
import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
...@@ -37,6 +40,8 @@ public class WeldController extends BaseController { ...@@ -37,6 +40,8 @@ public class WeldController extends BaseController {
@Autowired @Autowired
WeldServiceImpl weldServiceImpl; WeldServiceImpl weldServiceImpl;
@Autowired
ProjectResourceMapper projectResourceMapper;
/** /**
* 新增焊口信息表 * 新增焊口信息表
...@@ -74,8 +79,16 @@ public class WeldController extends BaseController { ...@@ -74,8 +79,16 @@ public class WeldController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}") @DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除焊口信息表", notes = "根据sequenceNbr删除焊口信息表") @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除焊口信息表", notes = "根据sequenceNbr删除焊口信息表")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr) { public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") List<Long> sequenceNbr) throws Exception {
return ResponseHelper.buildResponse(weldServiceImpl.removeById(sequenceNbr)); LambdaQueryWrapper<ProjectResource> wrapper = new LambdaQueryWrapper<>();
for (Long i:sequenceNbr){
wrapper.eq(ProjectResource::getResourceId,i);
if (!projectResourceMapper.selectList(wrapper).isEmpty()){
throw new Exception("无法删除,已绑定项目");
}
}
return ResponseHelper.buildResponse(weldServiceImpl.removeByIds(sequenceNbr));
} }
/** /**
......
...@@ -196,7 +196,7 @@ public class WelderController extends BaseController { ...@@ -196,7 +196,7 @@ public class WelderController extends BaseController {
IPage page = new Page(); IPage page = new Page();
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
page = orgServiceImpl.getPersonInfo(String.valueOf(orgServiceImpl.getReginParams().getCompany().getSequenceNbr()),page); page = orgServiceImpl.getPersonInfo(String.valueOf(orgServiceImpl.getReginParams().getBusinessInfo().getCompanySequenceNbr()),page);
List<Map> mapList = page.getRecords(); List<Map> mapList = page.getRecords();
for(Map map : mapList){ for(Map map : mapList){
if(OrgEnum.焊工.getKey().equals((String)map.get("type"))){ if(OrgEnum.焊工.getKey().equals((String)map.get("type"))){
......
...@@ -280,7 +280,16 @@ public class OrgServiceImpl { ...@@ -280,7 +280,16 @@ public class OrgServiceImpl {
public IPage getCompanyDept(IPage page){ public IPage getCompanyDept(IPage page){
LambdaQueryWrapper<OrgUsr> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<OrgUsr> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(OrgUsr :: getAmosOrgId,String.valueOf(getReginParams().getCompany().getSequenceNbr())); wrapper.eq(OrgUsr :: getAmosOrgId,String.valueOf(getReginParams().getCompany().getSequenceNbr()));
return getInfo(String.valueOf(orgUsrServiceImpl.getOne(wrapper).getSequenceNbr()),page); LambdaQueryWrapper<OrgUsr> wrapper1 = new LambdaQueryWrapper<>();
wrapper1.eq(OrgUsr :: getParentId,orgUsrServiceImpl.getOne(wrapper).getSequenceNbr())
.eq(OrgUsr ::getBizOrgType, OrgEnum.部门.getKey());
IPage<OrgUsr> list = orgUsrServiceImpl.page(page,wrapper1);
List<Map> mapList = new ArrayList<>();
for(OrgUsr orgUsr: list.getRecords()){
mapList.add(getdetialInfo(String.valueOf(orgUsr.getSequenceNbr())));
}
page.setRecords(mapList);
return page;
} }
/** /**
......
...@@ -170,11 +170,11 @@ public class ProblemInitiationServiceImpl { ...@@ -170,11 +170,11 @@ public class ProblemInitiationServiceImpl {
smsParams.put("reviewInfo", object.getString("reviewInfo")); smsParams.put("reviewInfo", object.getString("reviewInfo"));
//给监察发短信 //给监察发短信
LambdaQueryWrapper<SuperviseRule> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SuperviseRule> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(SuperviseRule::getAdminRegionCode, projectServiceImpl.getById(object.getLong("projectId")).getInstallRegionCode()); wrapper.eq(SuperviseRule::getAdminRegionCode, projectServiceImpl.getById(object.getLong("sequenceNbr")).getInstallRegionCode());
String supervisionUnitId = orgUsrServiceImpl.getById(superviseRuleServiceImpl.getOne(wrapper).getSuperviseDeptId()).getAmosOrgId(); String supervisionUnitId = orgUsrServiceImpl.getById(superviseRuleServiceImpl.getOne(wrapper).getSuperviseDeptId()).getAmosOrgId();
sendMessage(sequenceNbr,supervisionUnitId,smsParams,smsCode,supervisionRoleId,object); sendMessage(sequenceNbr,supervisionUnitId,smsParams,smsCode,supervisionRoleId,object);
//给安装发短信 //给安装发短信
String installationUnitId = orgUsrServiceImpl.getById(projectServiceImpl.getById(object.getLong("projectId")).getInstallationUnitId()).getAmosOrgId(); String installationUnitId = orgUsrServiceImpl.getById(projectServiceImpl.getById(object.getLong("sequenceNbr")).getInstallationUnitId()).getAmosOrgId();
sendMessage(sequenceNbr,installationUnitId,smsParams,smsCode,installationRoleId,object); sendMessage(sequenceNbr,installationUnitId,smsParams,smsCode,installationRoleId,object);
} }
......
...@@ -8,10 +8,14 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; ...@@ -8,10 +8,14 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.mao.expertSystem.WeldingQualification;
import com.mao.expertSystem.material.MyPqr;
import com.mao.expertSystem.material.MyWps;
import com.yeejoin.amos.boot.biz.common.service.impl.WorkflowExcuteServiceImpl; import com.yeejoin.amos.boot.biz.common.service.impl.WorkflowExcuteServiceImpl;
import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr; import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl; import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
import com.yeejoin.amos.boot.module.common.biz.utils.CommonResponseUtil; import com.yeejoin.amos.boot.module.common.biz.utils.CommonResponseUtil;
import com.yeejoin.amos.boot.module.ugp.api.Enum.AuditEnum;
import com.yeejoin.amos.boot.module.ugp.api.Enum.ProjectInitiationEnum; import com.yeejoin.amos.boot.module.ugp.api.Enum.ProjectInitiationEnum;
import com.yeejoin.amos.boot.module.ugp.api.Enum.SMSEnum; import com.yeejoin.amos.boot.module.ugp.api.Enum.SMSEnum;
import com.yeejoin.amos.boot.module.ugp.api.Util.CommonResponse; import com.yeejoin.amos.boot.module.ugp.api.Util.CommonResponse;
...@@ -153,7 +157,6 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD ...@@ -153,7 +157,6 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD
} }
} }
try { try {
//组装信息 //组装信息
TaskResultDTO dto = new TaskResultDTO(); TaskResultDTO dto = new TaskResultDTO();
...@@ -176,6 +179,108 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD ...@@ -176,6 +179,108 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD
} }
} }
/*焊评审核(后期优化)
* @return
*/
public String evaluateMethod(String sequenceNbr,JSONObject json) {
//获取文档信息(2个文档 wps pqr)
JSONArray subForm = json.getJSONArray("subForm");
JSONObject jsonObject1 = subForm.getJSONObject(0);
JSONArray info = jsonObject1.getJSONArray("info");
//info里面上传两个文档
JSONObject js1 = info.getJSONObject(0);
JSONObject js2 = info.getJSONObject(1);
String name1 = js1.getString("name");
String url1 = js1.getString("url");
String name2 = js1.getString("name");
String url2 = js2.getString("url");
//文档下载,调用python 文字识别
//识别结果,将结果放到pqr wps
MyPqr pqr = new MyPqr( );
MyWps wps = new MyWps( );
pqr.setWelding_method(json.getString("pqr_welding_method"));
pqr.setMaterial_a_number(json.getString("pqr_material_a_number"));
pqr.setMaterial_a_class(json.getString("pqr_material_a_class"));
pqr.setMaterial_a_thickness(json.getDouble("pqr_material_a_thickness"));
pqr.setMaterial_a_group(json.getString("pqr_material_a_group"));
pqr.setMaterial_a_standard(json.getString("pqr_material_a_standard"));
pqr.setMaterial_b_number(json.getString("pqr_material_b_number"));
pqr.setMaterial_b_class(json.getString("pqr_material_b_class"));
pqr.setMaterial_b_thickness(json.getDouble("pqr_material_b_thickness"));
pqr.setMaterial_b_group(json.getString("pqr_material_b_group"));
pqr.setMaterial_b_standard(json.getString("pqr_material_b_standard"));
pqr.setIf_shock(json.getString("pqr_if_shock"));
pqr.setIf_bend(json.getString("pqr_if_bend"));
pqr.setGtaw_weld_material_class(json.getString("pqr_gtaw_weld_material_class"));
pqr.setSmaw_weld_material_class(json.getString("pqr_smaw_weld_material_class"));
pqr.setSaw_weld_material_class_1(json.getString("pqr_saw_weld_material_class_1"));
pqr.setSaw_weld_material_class_2(json.getString("pqr_saw_weld_material_class_2"));
pqr.setGmaw_weld_material_class(json.getString("pqr_gmaw_weld_material_class"));
pqr.setIf_heat_treatment(json.getString("pqr_if_heat_treatment"));
pqr.setTemperature(json.getDouble("pqr_temperature"));
pqr.setCombox_type(json.getString("pqr_combox_type"));
pqr.setTemperature_time(json.getDouble("pqr_temperature_time"));
pqr.setMaterial_minT_of_a_b_thickness(json.getDouble("pqr_material_minT_of_a_b_thickness"));
wps.setWelding_method(json.getString("wps_welding_method"));
wps.setMaterial_a_number(json.getString("wps_material_a_number"));
wps.setMaterial_a_class(json.getString("wps_material_a_class"));
wps.setMaterial_a_thickness(json.getDouble("wps_material_a_thickness"));
wps.setMaterial_a_group(json.getString("wps_material_a_group"));
wps.setMaterial_a_standard(json.getString("wps_material_a_standard"));
wps.setMaterial_b_number(json.getString("wps_material_b_number"));
wps.setMaterial_b_class(json.getString("wps_material_b_class"));
wps.setMaterial_b_thickness(json.getDouble("wps_material_b_thickness"));
wps.setMaterial_b_group(json.getString("wps_material_b_group"));
wps.setMaterial_b_standard(json.getString("wps_material_b_standard"));
wps.setIf_shock(json.getString("wps_if_shock"));
wps.setIf_bend(json.getString("wps_if_bend"));
wps.setGtaw_weld_material_class(json.getString("wps_gtaw_weld_material_class"));
wps.setSmaw_weld_material_class(json.getString("wps_smaw_weld_material_class"));
wps.setSaw_weld_material_class_1(json.getString("wps_saw_weld_material_class_1"));
wps.setSaw_weld_material_class_2(json.getString("wps_saw_weld_material_class_2"));
wps.setGmaw_weld_material_class(json.getString("wps_gmaw_weld_material_class"));
wps.setIf_heat_treatment(json.getString("wps_if_heat_treatment"));
wps.setTemperature(json.getDouble("wps_temperature"));
wps.setCombox_type(json.getString("wps_combox_type"));
wps.setTemperature_time(json.getDouble("wps_temperature_time"));
wps.setMaterial_minT_of_a_b_thickness(json.getDouble("wps_material_minT_of_a_b_thickness"));
HashMap<String, String> stringStringHashMap = new WeldingQualification( ).equipmentWeldingQualification(pqr, wps);
//结果(假设)
String reslut =AuditEnum.符合.getName();
String option =AuditEnum.getNameByStatus.get(reslut);
Project project = projectServiceImpl.getById(sequenceNbr);
JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(project));
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,AuditEnum.符合.getName());
if(AuditEnum.不符合且不需要整改.getStatus().equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,AuditEnum.不符合且不需要整改.getName());
projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
}else if(AuditEnum.不符合且需要重新提交资料.getStatus().equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,AuditEnum.不符合且需要重新提交资料.getName());
}
projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
return stringStringHashMap.toString();
}
/** /**
* 获取流程当前任务名称 * 获取流程当前任务名称
* @param instanceId * @param instanceId
......
...@@ -86,7 +86,7 @@ public class ProjectServiceImpl extends BaseService<ProjectDto, Project, Project ...@@ -86,7 +86,7 @@ public class ProjectServiceImpl extends BaseService<ProjectDto, Project, Project
if(!ValidationUtil.isEmpty(projectInitiationList)){ if(!ValidationUtil.isEmpty(projectInitiationList)){
ProjectInitiation projectInitiation = projectInitiationList.iterator().next(); ProjectInitiation projectInitiation = projectInitiationList.iterator().next();
JSONObject jsonObject = JSON.parseObject(projectInitiation.getContext()); JSONObject jsonObject = JSON.parseObject(projectInitiation.getContext());
if(ProjectInitiationEnum.平台审核.getName().equals(project.getStatus()) || ProjectInitiationEnum.审批人审批.getName().equals(project.getStatus()) || ProjectInitiationEnum.审核人审核.getName().equals(project.getStatus()) || ProjectInitiationEnum.监检科室分配.getName().equals(project.getStatus()) || ProjectInitiationEnum.监检员分配.getName().equals(project.getStatus()) || ProjectInitiationEnum.监检员审核.getName().equals(project.getStatus())){ if(ProjectInitiationEnum.平台审核.getName().equals(project.getStatus()) || ProjectInitiationEnum.审批人审批.getName().equals(project.getStatus()) || ProjectInitiationEnum.审核人审核.getName().equals(project.getStatus()) || ProjectInitiationEnum.监检科室分配.getName().equals(project.getStatus()) || ProjectInitiationEnum.监检员分配.getName().equals(project.getStatus()) || ProjectInitiationEnum.监检员审核.getName().equals(project.getStatus()) || ProjectInitiationEnum.流程结束.getName().equals(project.getStatus()) || ProjectInitiationEnum.项目关闭.getName().equals(project.getStatus())){
if(!ValidationUtil.isEmpty(jsonObject)){ if(!ValidationUtil.isEmpty(jsonObject)){
state = jsonObject.getString(XJConstant.PROCESS_PROJECT_STATE); state = jsonObject.getString(XJConstant.PROCESS_PROJECT_STATE);
insDep = jsonObject.getString(XJConstant.INS_DEP); insDep = jsonObject.getString(XJConstant.INS_DEP);
......
...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.ugp.biz.service.impl; ...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature; import com.alibaba.fastjson.serializer.SerializerFeature;
...@@ -20,8 +21,10 @@ import com.yeejoin.amos.boot.module.ugp.api.Enum.VerifyEnum; ...@@ -20,8 +21,10 @@ import com.yeejoin.amos.boot.module.ugp.api.Enum.VerifyEnum;
import com.yeejoin.amos.boot.module.ugp.api.Enum.VerifyTypeEnum; import com.yeejoin.amos.boot.module.ugp.api.Enum.VerifyTypeEnum;
import com.yeejoin.amos.boot.module.ugp.api.constants.XJConstant;
import com.yeejoin.amos.boot.module.ugp.api.dto.*; import com.yeejoin.amos.boot.module.ugp.api.dto.*;
import com.yeejoin.amos.boot.module.ugp.api.entity.Project;
import com.yeejoin.amos.boot.module.ugp.api.entity.QualityProblem; import com.yeejoin.amos.boot.module.ugp.api.entity.QualityProblem;
import com.yeejoin.amos.boot.module.ugp.api.entity.Verify; import com.yeejoin.amos.boot.module.ugp.api.entity.Verify;
...@@ -44,9 +47,12 @@ import org.typroject.tyboot.core.rdbms.service.BaseService; ...@@ -44,9 +47,12 @@ import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import java.awt.*;
import java.util.*; import java.util.*;
import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
...@@ -94,6 +100,8 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -94,6 +100,8 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
@Autowired @Autowired
QualityProblemServiceImpl qualityProblemService; QualityProblemServiceImpl qualityProblemService;
@Autowired
ProjectServiceImpl projectServiceImpl;
/** /**
...@@ -109,21 +117,14 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -109,21 +117,14 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
/** /**
* 列表查询 示例 * 列表查询 示例
*/ */
public List<VerifyDto> queryForVerifyList() { public List<VerifyDto> queryForVerifyList() {
return this.queryForList("" , false); return this.queryForList("" , false);
} }
/** cpp /** cpp
* 智能监检共用查询方法 * 智能监检共用查询方法
* stage 阶段 * stage 阶段
* page 分页 * page 分页
*/ */
private static final String HEGE ="合格期内"; private static final String HEGE ="合格期内";
private static final String NOTHEGE ="超期未检"; private static final String NOTHEGE ="超期未检";
...@@ -132,10 +133,7 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -132,10 +133,7 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
List<SmartListDto> dtoList =new ArrayList<>(); List<SmartListDto> dtoList =new ArrayList<>();
//进入焊前 //进入焊前
if (verifyList !=null && verifyList.size() !=0){ if (verifyList !=null && verifyList.size() !=0){
for (Verify verify : verifyList) { for (Verify verify : verifyList) {
SmartListDto dto = new SmartListDto( ); SmartListDto dto = new SmartListDto( );
dto.setSequenceNbr(verify.getSequenceNbr());//智能监检表id dto.setSequenceNbr(verify.getSequenceNbr());//智能监检表id
dto.setProjectId(verify.getProjectId()); //项目id dto.setProjectId(verify.getProjectId()); //项目id
...@@ -150,10 +148,9 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -150,10 +148,9 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
dto.setStatus(VerifyEnum.未通过.getName()); dto.setStatus(VerifyEnum.未通过.getName());
} }
dto.setType(verify.getType());//检验方式 dto.setType(verify.getType());//检验方式
dto.setSubmitTime(verify.getSubmitTime());//交检日期 dto.setSubmitTime(verify.getVerifyTime());//交检日期
dto.setVerifyTime(verify.getVerifyTime());//检验时间 dto.setVerifyTime(verify.getVerifyTime());//检验时间
String stage1 = verify.getStage( );//检验检测阶段 String stage1 = verify.getStage( );//检验检测阶段
Map<String, String> map = StageEnum.getStatusByVerifyNameMap; Map<String, String> map = StageEnum.getStatusByVerifyNameMap;
for (String key:map.keySet()){ for (String key:map.keySet()){
if (key.equals(stage1)) { if (key.equals(stage1)) {
...@@ -161,141 +158,104 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -161,141 +158,104 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
} }
} }
String targetInfo = verify.getTargetInfo();//app上传数据 String targetInfo = verify.getTargetInfo();//app上传数据
Map mapInfo = JSON.parseObject(targetInfo, Map.class); JSONObject jsonObject = JSONObject.parseObject(targetInfo);
for (Object o:mapInfo.keySet()){ String code = jsonObject.getString("code");//焊口编码
if (o.toString().equals("code")) { String manyCode = jsonObject.getString("manyCode");
//获取焊口编号 if (!StringUtils.isEmpty(code)) {
String code = (String)mapInfo.get(o.toString( ));
dto.setCode(code); dto.setCode(code);
} }
if (!StringUtils.isEmpty(manyCode)) {
if (o.toString().equals("peopleLocation")) { dto.setCode(manyCode);
//获取焊接定位信息 }
String peopleLocation = (String)mapInfo.get(o.toString( )); String location = jsonObject.getString("location");
dto.setPeopleLocation(peopleLocation); if (!StringUtils.isEmpty(location)) {
dto.setPeopleLocation(location);
} }
Long welderId = jsonObject.getLong("welderId");
//人员 if (welderId!=null) {
if (o.toString().equals("userId")) { OrgUsr orgUsr = orgService.getOrgUsrById(welderId.toString());
//获取焊工信息 if (orgUsr != null) {
String userId = mapInfo.get(o.toString( )).toString(); if (!StringUtils.isEmpty(orgUsr.getBizOrgName())) {
if (userId != null) {
OrgUsr orgUsr = orgService.getOrgUsrById(userId);
dto.setPeopleName(orgUsr.getBizOrgName());//焊工姓名 dto.setPeopleName(orgUsr.getBizOrgName());//焊工姓名
}
if (!StringUtils.isEmpty(orgUsr.getCode())) {
dto.setPersonWeld(orgUsr.getCode());//焊工编号 dto.setPersonWeld(orgUsr.getCode());//焊工编号
} }
} }
}
//持证判断 //持证判断(写死)
dto.setPeopleStatus("合格期内");
dto.setFacilityStatus("合格期内");
//设备 dto.setCompanyName("检测单位");
dto.setUsrName("检验负责人");
if (o.toString().equals("facilityId")) { dto.setInspector("cs");
//设备id dto.setFacilityNumber("XH007");
Long eId = Long.valueOf(mapInfo.get(o.toString( )).toString()); dto.setFacilityName("焊机xxx");
if (eId != null) { dto.setDuration("6");
//获取设备 dto.setPressureNumber("1xm001");
EquipmentDto equipmentDto = equipmentService.queryBySeq(eId); dto.setPressureName("耐压设备");
dto.setPressureCode("DF988x");
Long weldingId = jsonObject.getLong("weldingId");
if (weldingId !=null) {
EquipmentDto equipmentDto = equipmentService.queryBySeq(weldingId);
if (equipmentDto != null) { if (equipmentDto != null) {
//设备名 设备编号 //设备名 设备编号
dto.setFacilityName(equipmentDto.getName()); dto.setFacilityName(equipmentDto.getName());
dto.setFacilityNumber(equipmentDto.getCode()); dto.setFacilityNumber(equipmentDto.getCode());
} }
}
} }
//管材 Long materialId = jsonObject.getLong("materialId");
if (materialId!=null) {
if (o.toString().equals("materialId")) { MaterialDto materialDto = materialService.queryBySeq(materialId);
//管材id
Long mId = Long.valueOf(mapInfo.get(o.toString( )).toString());
if (mId != null) {
MaterialDto materialDto = materialService.queryBySeq(mId);
if (materialDto != null) { if (materialDto != null) {
//管材厂家 生产编号 //管材厂家 生产编号
dto.setManufacturer(materialDto.getManufacturer()); dto.setManufacturer(materialDto.getManufacturer());
dto.setBatchNumber(materialDto.getBatchNum()); dto.setBatchNumber(materialDto.getBatchNum());
//生产日期需要判断(加判断)是否在有效期内 //生产日期需要判断(加判断)是否在有效期内
Date manufactureDate = materialDto.getManufactureDate( ); Date manufactureDate = materialDto.getManufactureDate( );
//将判断结果 //将判断结果
dto.setPermission(HEGE); dto.setPermission(HEGE);
} }
}
} }
//工艺 String craft = jsonObject.getString("craft");
if (o.toString().equals("craft")) {
//获取焊接工艺
String craft = mapInfo.get(o.toString( )).toString();
if (!StringUtils.isEmpty(craft)) { if (!StringUtils.isEmpty(craft)) {
dto.setCraft(craft); dto.setCraft(craft);
} }
}
if (o.toString().equals("weldingId")) {
//设备id
Long eId = Long.valueOf(mapInfo.get(o.toString( )).toString());
if (eId != null) {
//获取设备
EquipmentDto equipmentDto = equipmentService.queryBySeq(eId);
if (!StringUtils.isEmpty(equipmentDto.getCode())) {
// 焊机编号
dto.setFacilityNumber(equipmentDto.getCode());
}
}
}
//耐压 //耐压
if (o.toString().equals("pressureId")) { Long pressureId = jsonObject.getLong("pressureId");
Long pressureId = Long.valueOf(mapInfo.get(o.toString( )).toString()); if (pressureId != null) {
if (pressureId !=null) {
EquipmentDto equipmentDto = equipmentService.queryBySeq(pressureId); EquipmentDto equipmentDto = equipmentService.queryBySeq(pressureId);
if (equipmentDto != null && !StringUtils.isEmpty(equipmentDto.getName()) &&!StringUtils.isEmpty(equipmentDto.getCode())) { if (equipmentDto != null && !StringUtils.isEmpty(equipmentDto.getName()) &&!StringUtils.isEmpty(equipmentDto.getCode())) {
dto.setPressureName(equipmentDto.getName()); dto.setPressureName(equipmentDto.getName());
dto.setPressureCode(equipmentDto.getCode()); dto.setPressureCode(equipmentDto.getCode());
} }
} }
String pressureTest = jsonObject.getString("pressureTest");
if (!StringUtils.isEmpty(pressureTest)) {
dto.setMpa(pressureTest);
} }
if (o.toString().equals("pressureTest")) { //埋深
String mpa = mapInfo.get(o.toString( )).toString(); String depthType = jsonObject.getString("depthType");
if (!StringUtils.isEmpty(mpa)) {
dto.setMpa(mpa);
}
}
//埋深 埋深检测方式
if (o.toString().equals("depthType")) {
String depthType = mapInfo.get(o.toString( )).toString();
if (!StringUtils.isEmpty(depthType)) { if (!StringUtils.isEmpty(depthType)) {
dto.setDetectionMethod(depthType); dto.setDetectionMethod(depthType);
} }
} String depth = jsonObject.getString("depth");
if (o.toString().equals("depth")) {
String depth = mapInfo.get(o.toString( )).toString();
if (!StringUtils.isEmpty(depth)) { if (!StringUtils.isEmpty(depth)) {
dto.setBurialDepth(depth); dto.setBurialDepth(depth);
} }
}
//位置标定 //位置标定
if (o.toString().equals("locationType")) { String locationType = jsonObject.getString("locationType");
String locationType = mapInfo.get(o.toString( )).toString();
if (!StringUtils.isEmpty(locationType)) { if (!StringUtils.isEmpty(locationType)) {
dto.setPreciseWeldingPosition(locationType); dto.setPreciseWeldingPosition(locationType);
} }
}
//判断标定检验结果 getResuts // //判断标定检验结果 (写死) getResuts
} dto.setResuts("合格");
dtoList.add(dto); dtoList.add(dto);
} }
...@@ -330,6 +290,7 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -330,6 +290,7 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
Date time = new Date();// //获取当前校验时间 Date time = new Date();// //获取当前校验时间
String photo = jsonObject.getString("photo");//图片 String photo = jsonObject.getString("photo");//图片
Verify verify = new Verify( ); Verify verify = new Verify( );
jsonObject.put("welderId",welderId);
//属性赋值 //属性赋值
String targetInfo = jsonObject.toString(); String targetInfo = jsonObject.toString();
verify.setTargetInfo(targetInfo);//json信息 verify.setTargetInfo(targetInfo);//json信息
...@@ -777,570 +738,11 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -777,570 +738,11 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
} }
private String 效验状态 = "已存在";
private final String 问题编码="-WT";
/**
* 公共效验接口
*/
public String effect(JSONObject jsonObject,Integer 效验数量,Boolean i) {
// String 效验状态 = "已存在";
Verify verify = new Verify();
//添加筛选条件
LambdaQueryWrapper<Verify> wrapper = new LambdaQueryWrapper<>();
//获取target_info
JSONObject targetInfo = jsonObject.getJSONObject("target_info");
String code = targetInfo.getString("code");
//筛选出本焊口监检数
wrapper.eq(Verify::getCode, code);
//改焊口焊前数据
Integer verifyCount = verifyMapper.selectCount(wrapper);
if (verifyCount == 效验数量) {
wrapper.eq(Verify::getStatus, VerifyEnum.已通过.getStatus());
//该焊口焊前效验通过数据
Integer integer = verifyMapper.selectCount(wrapper);
//判断入库数量
if (integer == 效验数量) {
verify.setProjectId(jsonObject.getLong("projectId"));
verify.setCode(jsonObject.getString("code"));
verify.setTargetInfo(jsonObject.getString("target_info"));
verify.setSubmitTime(new Date());
verify.setVerifyTime(new Date());
verify.setType(VerifyTypeEnum.智能检验.getStatus());
//获取操作阶段
String stage = targetInfo.getString("stage");
verify.setStage(stage);
//获取效验接口
if (i) {
verify.setStatus(VerifyEnum.已通过.getStatus());
//添加筛选条件
LambdaQueryWrapper<Weld> wrapperWeld = new LambdaQueryWrapper<>();
wrapperWeld.eq(Weld::getCode, jsonObject.getString("code"));
Weld weld = weldMapper.selectOne(wrapperWeld);
weld.setSuperInspecStatus(stage);
weldService.updateById(weld);
效验状态 = "已通过";
this.save(verify);
} else {
int math= (int) ((Math.random() * 9 + 1)*1000);
verify.setStatus(VerifyEnum.未通过.getStatus());
this.save(verify);
LambdaQueryWrapper<Verify> wrapperVerify=new LambdaQueryWrapper<>();
wrapperVerify.eq(Verify::getCode,jsonObject.getString("code"));
wrapperVerify.eq(Verify::getStage,stage);
Verify verifyId = verifyMapper.selectOne(wrapperVerify);
QualityProblem qualityProblem = new QualityProblem();
//生成问题编码
qualityProblem.setStageVerifyId(verifyId.getSequenceNbr());
qualityProblem.setCode(jsonObject.getString("code")+问题编码+math);
qualityProblem.setProjectId(jsonObject.getLong("projectId"));
qualityProblem.setGenerateStage(stage);
qualityProblem.setSubmitDate(new Date());
qualityProblemService.save(qualityProblem);
效验状态 = "未通过";
}
}
}
return 效验状态;
}
/** /**
* 主键id查询 (图片和结果)
* 焊接工艺效验
*/
private final Integer 焊前效验数量 = 3;
public String weldEffect(JSONObject jsonObject) {
// Verify verify = new Verify();
// //添加筛选条件
// LambdaQueryWrapper<Verify> wrapper = new LambdaQueryWrapper<>();
// JSONObject targetInfo = jsonObject.getJSONObject("target_info");
// String code = targetInfo.getString("code");
// //筛选出本焊口监检数
// wrapper.eq(Verify::getCode, code);
// //改焊口焊前数据
// Integer verifyCount = verifyMapper.selectCount(wrapper);
// if (verifyCount == 焊前效验数量) {
// wrapper.eq(Verify::getStatus, VerifyEnum.已通过.getStatus());
// //该焊口焊前效验通过数据
// Integer integer = verifyMapper.selectCount(wrapper);
// //判断前三次已经入库
// if (integer == 焊前效验数量) {
// //获取效验接口
// Boolean i = false;
//
//
// verify.setProjectId(jsonObject.getLong("projectId"));
// verify.setCode(jsonObject.getString("code"));
// verify.setTargetInfo(jsonObject.getString("target_info"));
// verify.setSubmitTime(new Date());
// verify.setStage(StageEnum.焊接工艺.getStage());
// if (i) {
// verify.setStatus(VerifyEnum.已通过.getStatus());
// //添加筛选条件
// LambdaQueryWrapper<Weld> wrapperWeld = new LambdaQueryWrapper<>();
// wrapperWeld.eq(Weld::getCode, jsonObject.getString("code"));
// Weld weld = weldMapper.selectOne(wrapperWeld);
// weld.setSuperInspecStatus(StageEnum.焊接工艺.getStage());
//
// weldService.updateById(weld);
//
// 效验状态 = "已通过";
// this.save(verify);
// } else {
// int math= (int) (Math.random()*10000);
// verify.setStatus(VerifyEnum.未通过.getStatus());
// this.save(verify);
// LambdaQueryWrapper<Verify> wrapperVerify=new LambdaQueryWrapper<>();
// wrapperVerify.eq(Verify::getCode,jsonObject.getString("code"));
// wrapperVerify.eq(Verify::getStage,StageEnum.焊接工艺.getStage());
// Verify verifyId = verifyMapper.selectOne(wrapperVerify);
// QualityProblem qualityProblem = new QualityProblem();
// //生成问题编码
// qualityProblem.setStageVerifyId(verifyId.getSequenceNbr());
// qualityProblem.setCode(jsonObject.getString("code")+问题编码+math);
// qualityProblem.setProjectId(jsonObject.getLong("projectId"));
// qualityProblem.setGenerateStage(StageEnum.焊接工艺.getStage());
// qualityProblem.setSubmitDate(new Date());
// qualityProblemService.save(qualityProblem);
// 效验状态 = "未通过";
//
// }
//
// }
//
//
//
// }
//
return effect(jsonObject,焊前效验数量,true);
}
/**
* 管道耐压效验
*/
private final Integer 管道耐压前效验数量 = 4;
public String materialEffect(JSONObject jsonObject){
// Verify verify = new Verify();
// //添加筛选条件
// LambdaQueryWrapper<Verify> wrapper = new LambdaQueryWrapper<>();
// //筛选出本焊口监检数
// wrapper.eq(Verify::getCode, jsonObject.getString("code"));
// //该焊口焊前数据
// Integer verifyCount = verifyMapper.selectCount(wrapper);
// if (verifyCount == 管道耐压前效验数量) {
// wrapper.eq(Verify::getStatus, VerifyEnum.已通过.getStatus());
// //该焊口焊前效验通过数据
// Integer integer = verifyMapper.selectCount(wrapper);
// //判断前四次已经入库
// if (integer == 管道耐压前效验数量) {
// //获取效验接口
// Boolean i = true;
//
//
// verify.setProjectId(jsonObject.getLong("projectId"));
// verify.setCode(jsonObject.getString("code"));
// verify.setTargetInfo(jsonObject.getString("target_info"));
// verify.setSubmitTime(new Date());
// verify.setStage(StageEnum.焊前管材质量.getStage());
// if (i) {
// verify.setStatus(VerifyEnum.已通过.getStatus());
// //添加筛选条件
// LambdaQueryWrapper<Weld> wrapperWeld = new LambdaQueryWrapper<>();
// wrapperWeld.eq(Weld::getCode, jsonObject.getString("code"));
// Weld weld = weldMapper.selectOne(wrapperWeld);
// weld.setSuperInspecStatus(StageEnum.焊前管材质量.getStage());
//
// weldService.updateById(weld);
//
// 效验状态 = "已通过";
// } else {
// int math= (int) (Math.random()*10000);
// verify.setStatus(VerifyEnum.未通过.getStatus());
// this.save(verify);
// LambdaQueryWrapper<Verify> wrapperVerify=new LambdaQueryWrapper<>();
// wrapperVerify.eq(Verify::getCode,jsonObject.getString("code"));
// wrapperVerify.eq(Verify::getStage,StageEnum.焊前管材质量.getStage());
// Verify verifyId = verifyMapper.selectOne(wrapperVerify);
// QualityProblem qualityProblem = new QualityProblem();
// //生成问题编码
// qualityProblem.setStageVerifyId(verifyId.getSequenceNbr());
// qualityProblem.setCode(jsonObject.getString("code")+问题编码+math);
// qualityProblem.setProjectId(jsonObject.getLong("projectId"));
// qualityProblem.setGenerateStage(StageEnum.焊前管材质量.getStage());
// qualityProblem.setSubmitDate(new Date());
// qualityProblemService.save(qualityProblem);
// 效验状态 = "未通过";
//
// }
//
// }
//
// save(verify);
//
// }
//
return effect(jsonObject,管道耐压前效验数量,true);
}
/**
* 敷设效验
*/
private final Integer 敷设效验数量 = 5;
public String layEffect(JSONObject jsonObject){
//
// Verify verify = new Verify();
// //添加筛选条件
// LambdaQueryWrapper<Verify> wrapper = new LambdaQueryWrapper<>();
// //筛选出本焊口监检数
// wrapper.eq(Verify::getCode, jsonObject.getString("code"));
// //该焊口焊前数据
// Integer verifyCount = verifyMapper.selectCount(wrapper);
// if (verifyCount == 管道耐压前效验数量) {
// wrapper.eq(Verify::getStatus, VerifyEnum.已通过.getStatus());
// //该焊口焊前效验通过数据
// Integer integer = verifyMapper.selectCount(wrapper);
// //判断前四次已经入库
// if (integer == 管道耐压前效验数量) {
// //获取效验接口
// Boolean i = true;
//
//
// verify.setProjectId(jsonObject.getLong("projectId"));
// verify.setCode(jsonObject.getString("code"));
// verify.setTargetInfo(jsonObject.getString("target_info"));
// verify.setSubmitTime(new Date());
// verify.setStage(StageEnum.敷设质量.getStage());
// if (i) {
// verify.setStatus(VerifyEnum.已通过.getStatus());
// //添加筛选条件
// LambdaQueryWrapper<Weld> wrapperWeld = new LambdaQueryWrapper<>();
// wrapperWeld.eq(Weld::getCode, jsonObject.getString("code"));
// Weld weld = weldMapper.selectOne(wrapperWeld);
// weld.setSuperInspecStatus(StageEnum.敷设质量.getStage());
//
// weldService.updateById(weld);
//
// 效验状态 = "已通过";
// } else {
// int math= (int) (Math.random()*10000);
// verify.setStatus(VerifyEnum.未通过.getStatus());
// this.save(verify);
// LambdaQueryWrapper<Verify> wrapperVerify=new LambdaQueryWrapper<>();
// wrapperVerify.eq(Verify::getCode,jsonObject.getString("code"));
// wrapperVerify.eq(Verify::getStage,StageEnum.敷设质量.getStage());
// Verify verifyId = verifyMapper.selectOne(wrapperVerify);
// QualityProblem qualityProblem = new QualityProblem();
// //生成问题编码
// qualityProblem.setStageVerifyId(verifyId.getSequenceNbr());
// qualityProblem.setCode(jsonObject.getString("code")+问题编码+math);
// qualityProblem.setProjectId(jsonObject.getLong("projectId"));
// qualityProblem.setGenerateStage(StageEnum.敷设质量.getStage());
// qualityProblem.setSubmitDate(new Date());
// qualityProblemService.save(qualityProblem);
// 效验状态 = "未通过";
//
// }
//
// }
//
// save(verify);
//
// }
return effect(jsonObject,敷设效验数量,false);
}
/**
* 主键id查询
* @param sequenceNbr * @param sequenceNbr
* @return * @return
*/ */
public OpenDto selectById(Long sequenceNbr){ public OpenDto selectById(Long sequenceNbr){
Verify verify = verifyMapper.selectById(sequenceNbr); Verify verify = verifyMapper.selectById(sequenceNbr);
...@@ -1357,8 +759,6 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -1357,8 +759,6 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
openDto.setResult(VerifyEnum.已通过.getName()); openDto.setResult(VerifyEnum.已通过.getName());
} }
//符合性 //符合性
openDto.setAccord("符合"); openDto.setAccord("符合");
//有效性 //有效性
...@@ -1367,106 +767,7 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper ...@@ -1367,106 +767,7 @@ public class VerifyServiceImpl extends BaseService<VerifyDto,Verify,VerifyMapper
return openDto ; return openDto ;
} }
/**
* 评价
* @return
*/
private static final String CONFORM ="符合";
private static final String NOTCONFORM ="不符合";
public Boolean evaluate(JSONObject jsonObject) {
MyPqr pqr = new MyPqr( );
MyWps wps = new MyWps( );
// 初始化
Boolean flag = false;
HashMap<String, String> stringStringHashMap = null;
String stage = jsonObject.getString("stage");
if (!StringUtils.isEmpty(stage)) {
pqr.setWelding_method(jsonObject.getString("pqr_welding_method"));
pqr.setMaterial_a_number(jsonObject.getString("pqr_material_a_number"));
pqr.setMaterial_a_class(jsonObject.getString("pqr_material_a_class"));
pqr.setMaterial_a_thickness(jsonObject.getDouble("pqr_material_a_thickness"));
pqr.setMaterial_a_group(jsonObject.getString("pqr_material_a_group"));
pqr.setMaterial_a_standard(jsonObject.getString("pqr_material_a_standard"));
pqr.setMaterial_b_number(jsonObject.getString("pqr_material_b_number"));
pqr.setMaterial_b_class(jsonObject.getString("pqr_material_b_class"));
pqr.setMaterial_b_thickness(jsonObject.getDouble("pqr_material_b_thickness"));
pqr.setMaterial_b_group(jsonObject.getString("pqr_material_b_group"));
pqr.setMaterial_b_standard(jsonObject.getString("pqr_material_b_standard"));
pqr.setIf_shock(jsonObject.getString("pqr_if_shock"));
pqr.setIf_bend(jsonObject.getString("pqr_if_bend"));
pqr.setGtaw_weld_material_class(jsonObject.getString("pqr_gtaw_weld_material_class"));
pqr.setSmaw_weld_material_class(jsonObject.getString("pqr_smaw_weld_material_class"));
pqr.setSaw_weld_material_class_1(jsonObject.getString("pqr_saw_weld_material_class_1"));
pqr.setSaw_weld_material_class_2(jsonObject.getString("pqr_saw_weld_material_class_2"));
pqr.setGmaw_weld_material_class(jsonObject.getString("pqr_gmaw_weld_material_class"));
pqr.setIf_heat_treatment(jsonObject.getString("pqr_if_heat_treatment"));
pqr.setTemperature(jsonObject.getDouble("pqr_temperature"));
pqr.setCombox_type(jsonObject.getString("pqr_combox_type"));
pqr.setTemperature_time(jsonObject.getDouble("pqr_temperature_time"));
pqr.setMaterial_minT_of_a_b_thickness(jsonObject.getDouble("pqr_material_minT_of_a_b_thickness"));
wps.setWelding_method(jsonObject.getString("wps_welding_method"));
wps.setMaterial_a_number(jsonObject.getString("wps_material_a_number"));
wps.setMaterial_a_class(jsonObject.getString("wps_material_a_class"));
wps.setMaterial_a_thickness(jsonObject.getDouble("wps_material_a_thickness"));
wps.setMaterial_a_group(jsonObject.getString("wps_material_a_group"));
wps.setMaterial_a_standard(jsonObject.getString("wps_material_a_standard"));
wps.setMaterial_b_number(jsonObject.getString("wps_material_b_number"));
wps.setMaterial_b_class(jsonObject.getString("wps_material_b_class"));
wps.setMaterial_b_thickness(jsonObject.getDouble("wps_material_b_thickness"));
wps.setMaterial_b_group(jsonObject.getString("wps_material_b_group"));
wps.setMaterial_b_standard(jsonObject.getString("wps_material_b_standard"));
wps.setIf_shock(jsonObject.getString("wps_if_shock"));
wps.setIf_bend(jsonObject.getString("wps_if_bend"));
wps.setGtaw_weld_material_class(jsonObject.getString("wps_gtaw_weld_material_class"));
wps.setSmaw_weld_material_class(jsonObject.getString("wps_smaw_weld_material_class"));
wps.setSaw_weld_material_class_1(jsonObject.getString("wps_saw_weld_material_class_1"));
wps.setSaw_weld_material_class_2(jsonObject.getString("wps_saw_weld_material_class_2"));
wps.setGmaw_weld_material_class(jsonObject.getString("wps_gmaw_weld_material_class"));
wps.setIf_heat_treatment(jsonObject.getString("wps_if_heat_treatment"));
wps.setTemperature(jsonObject.getDouble("wps_temperature"));
wps.setCombox_type(jsonObject.getString("wps_combox_type"));
wps.setTemperature_time(jsonObject.getDouble("wps_temperature_time"));
wps.setMaterial_minT_of_a_b_thickness(jsonObject.getDouble("wps_material_minT_of_a_b_thickness"));
}
stringStringHashMap = new WeldingQualification( ).equipmentWeldingQualification(pqr, wps);
ArrayList<String> list = new ArrayList<>( );
for(String key:stringStringHashMap.keySet()){
String vaule = stringStringHashMap.get(key);
//如果不是空串
if (vaule !=null&&!vaule.equals("")) {
list.add(vaule);
}
}
// 获取不符合的
List<String> notconform = list.stream( ).filter(b -> b.equals(NOTCONFORM)).collect(Collectors.toList( ));
if (notconform ==null && notconform.size()==0) {
//没有不符合的,更改状态
flag =true;
}
return flag;
}
......
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