生产管理修改

liweidong
李涛 2 days ago
parent 96ca75390e
commit 000504dea6
  1. 110
      blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/ReviewSheetServiceImpl.java

@ -55,15 +55,19 @@ import org.springblade.wms.pojo.entity.SyDockingLog;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy;
import org.springframework.http.HttpEntity;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import org.springframework.web.client.RestTemplate;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
/**
* [生产处置单] 服务实现类
*
@ -113,24 +117,24 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
}
@Resource
IWorkPlanService workPlanService;
IWorkPlanService workPlanService;
@Override
public ReviewSheetDetailVO getByCardNo(Long id,String woCode) {
public ReviewSheetDetailVO getByCardNo(Long id, String woCode) {
ReviewSheet vo = baseMapper.getById(id);
Long ppsId = vo.getPpsId();
List<ReviewSheetInitVO> listplan = baseMapper.getByCardNo(woCode,ppsId);
List<ReviewSheetInitVO> listplan = baseMapper.getByCardNo(woCode, ppsId);
ReviewSheetDetailVO detaiinit = new ReviewSheetDetailVO() ;
ReviewSheetDetailVO detaiinit = new ReviewSheetDetailVO();
// Long ppsId = vo.getPpsId();
// List<ReviewSheetDetailVO> detailVOList = new ArrayList<>();
// QueryWrapper<WorkPlan> qwplan = new QueryWrapper<>();
// qwplan.eq("PPS_ID", ppsId);
// List<WorkPlan> listplan = workPlanService.list(qwplan);
if(listplan != null && listplan.size() > 0){
if (listplan != null && listplan.size() > 0) {
List<Long> ids = listplan.stream().map(ReviewSheetInitVO::getWpId).toList();
@ -141,9 +145,9 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
qw.orderByDesc("CREATE_TIME");
List<ReviewSheet> list = list(qw);
if(list != null && list.size() > 0){
if (list != null && list.size() > 0) {
ReviewSheet rs = list.get(0);
ReviewSheetInitVO detailVO = baseMapper.getById( rs.getId());
ReviewSheetInitVO detailVO = baseMapper.getById(rs.getId());
detaiinit = ReviewSheetDetailWrapper.build().entityVO(detailVO);
setDetailVOValue(detaiinit);
return detaiinit;
@ -181,16 +185,16 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
@Override
public void setInitVOValue(ReviewSheetInitVO vo) {
if(null != vo.getReviewUserId()){
if (null != vo.getReviewUserId()) {
R<UserInfo> rUICR = userClient.userInfo(vo.getReviewUserId());
if(null != rUICR && null !=rUICR.getData() && null != rUICR.getData().getUser()){
if (null != rUICR && null != rUICR.getData() && null != rUICR.getData().getUser()) {
vo.setReviewUserRealName(rUICR.getData().getUser().getRealName());
}
if(null != vo.getReviewStatus()){
if(3==vo.getReviewStatus()){
if (null != vo.getReviewStatus()) {
if (3 == vo.getReviewStatus()) {
vo.setReviewStatusName("通过");
}
if(4==vo.getReviewStatus()){
if (4 == vo.getReviewStatus()) {
vo.setReviewStatusName("未通过");
}
}
@ -484,7 +488,7 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
List<ReviewFault> listF = null;
if(null != vo.getFaultList() && vo.getFaultList().size() > 0){
if (null != vo.getFaultList() && !vo.getFaultList().isEmpty()) {
// 关联rsId
for (ReviewFaultVO voF : vo.getFaultList()) {
voF.setReviewSheetId(vo.getId());
@ -494,16 +498,13 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
faultService.saveOrUpdateBatch(listF);
}
// 删除
if (StringUtils.isNotBlank(vo.getDutyDeleteIds())) {
dutyService.deleteLogic(Func.toLongList(vo.getDutyDeleteIds()));
}
List<ReviewDuty> listD = null;
if(null != vo.getDutyList() && vo.getDutyList().size() > 0){
if (null != vo.getDutyList() && !vo.getDutyList().isEmpty()) {
// 关联rsId
for (ReviewDutyVO voD : vo.getDutyList()) {
voD.setReviewSheetId(vo.getId());
@ -513,7 +514,6 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
dutyService.saveOrUpdateBatch(listD);
}
// 审理单
ReviewSheet rs = getById(vo.getId()); // 从数据库中查到
log.info("ReviewSheet rs = {}", rs);
@ -525,10 +525,7 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
Integer bizType = vo.getBizType();
// biz类型
rs.setBizType(bizType);
if (
ReviewSheetConst.BizType.T_SELF_REDO.equals(rs.getBizType()) ||
ReviewSheetConst.BizType.T_SELF_SCRAP.equals(rs.getBizType())
) {
if (ReviewSheetConst.BizType.T_SELF_REDO.equals(rs.getBizType()) || ReviewSheetConst.BizType.T_SELF_SCRAP.equals(rs.getBizType())) {
if (ReviewSheetConst.SUBMIT_TYPE.T_SELF.equals(submitType)) { // 内部提交
// 当前状态
rs.setStatus(ReviewSheetConst.STATUS.S_JUDGE);
@ -570,17 +567,17 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
dto.setMdsItemCode(dto.getPreCode());
dto.setTrialStatus(rs.getReviewStatus().toString());
dto.setHearDis(rs.getSubmitType().toString());
dto.setTrialType(rs.getReviewOrderMode()+"");
dto.setTrialType(rs.getReviewOrderMode() + "");
dto.setPreCode(rs.getUpCode());
dto.setProporTion(rs.getScale());
dto.setSubQty(rs.getUnqualifiedQty());
List<ReviewDutyDTO> vods = new ArrayList<>();
if(null != listD && listD.size() > 0){
for(ReviewDuty vod : listD){
if (null != listD && listD.size() > 0) {
for (ReviewDuty vod : listD) {
ReviewDutyDTO vodDTO = new ReviewDutyDTO();
vodDTO.setTrialId(vod.getReviewSheetId()+"");
vodDTO.setTrialId(vod.getReviewSheetId() + "");
vodDTO.setReqQty(vod.getQty());
vodDTO.setUnit(vod.getUnit());
vodDTO.setCorrBatchNo(vod.getRelevantBatch());
@ -589,13 +586,13 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
}
List<ReviewFaultDTO> vofs = new ArrayList<>();
if(null != listF && listF.size() > 0){
for(ReviewFault vof : listF){
if (null != listF && listF.size() > 0) {
for (ReviewFault vof : listF) {
ReviewFaultDTO vofDTO = new ReviewFaultDTO();
vofDTO.setTrialId(vof.getReviewSheetId()+"");
vofDTO.setFaultType(vof.getNgType2Id()+"");
vofDTO.setQuestClass(vof.getNgType3Id()+"");
vofDTO.setQuestSubclass(vof.getNgType4Id()+"");
vofDTO.setTrialId(vof.getReviewSheetId() + "");
vofDTO.setFaultType(vof.getNgType2Id() + "");
vofDTO.setQuestClass(vof.getNgType3Id() + "");
vofDTO.setQuestSubclass(vof.getNgType4Id() + "");
vofDTO.setProportion(vof.getScale());
vofDTO.setFaultQty(vof.getQty());
vofDTO.setDescribe(vof.getMemo());
@ -603,29 +600,24 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
}
}
// JSONObject obj = new JSONObject();
// obj.put("qmsRepairApplyDTO", dto);
// obj.put("qmsRepairPartList", vods);
// obj.put("qmsRepairMalfList", vofs);
// HttpEntity<JSONObject> entity = new HttpEntity<>(obj, headers);
// ResponseEntity<JSONObject> responseEntity;
// JSONObject responseBody;
// try {
//// responseEntity = httpClientTemplate.postForEntity("http://192.168.119.68:10113" +
//// "/api/mms/qms/qmsrepairapply/qmsRepairApplyRest/saveQmsRepairApply/v1", entity, JSONObject.class);
//
// responseEntity = httpClientTemplate.postForEntity(newErpUrl +
// "/api/mms/qms/qmsrepairapply/qmsRepairApplyRest/saveQmsRepairApply/v1", entity, JSONObject.class);
// JSONObject result = responseEntity.getBody();
//
// responseBody = result.getJSONObject("responseBody");
// if (responseBody == null) {
// throw new BusinessException("审理单,接口返回值null");
// }
// } catch (Exception e) {
// throw new RuntimeException("审理单,接口返回值null");
// }
JSONObject obj = new JSONObject();
obj.put("qmsRepairApplyDTO", dto);
obj.put("qmsRepairPartList", vods);
obj.put("qmsRepairMalfList", vofs);
HttpEntity<JSONObject> entity = new HttpEntity<>(obj, headers);
ResponseEntity<JSONObject> responseEntity;
JSONObject responseBody;
try {
responseEntity = httpClientTemplate.postForEntity(newErpUrl + "/api/mms/qms/qmsrepairapply/qmsRepairApplyRest/saveQmsRepairApply/v1", entity, JSONObject.class);
JSONObject result = responseEntity.getBody();
responseBody = result.getJSONObject("responseBody");
if (responseBody == null) {
throw new ServiceException("审理单,接口返回值null");
}
} catch (Exception e) {
throw new ServiceException("审理单,接口返回值null");
}
}
return R.success("成功");
}
@ -642,10 +634,10 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
rs.setMemo(memo);
// 修改状态, 内部审理没有审理状态概念。
rs.setStatus(ReviewSheetConst.STATUS.S_COMPLETE);
if(1==selfReviewFlag){
if (1 == selfReviewFlag) {
//通过
rs.setReviewStatus((short) 3);
}else{
} else {
//驳回
rs.setReviewStatus((short) 4);
}
@ -742,8 +734,8 @@ public class ReviewSheetServiceImpl extends EnBaseServiceImpl<ReviewSheetMapper,
public IPage<PpmReportDetailDTO> listErp(IPage<PpmReportDetailDTO> page, ReviewSheetErpSearch search) {
// List<PpmReportDetailDTO> listVO = baseMapper.listErpNew(page, search);
ErpQueryRequest erpQueryRequest = new ErpQueryRequest();
erpQueryRequest.setCurrent(Integer.parseInt(page.getCurrent()+""));
erpQueryRequest.setSize(Integer.parseInt(page.getSize()+""));
erpQueryRequest.setCurrent(Integer.parseInt(page.getCurrent() + ""));
erpQueryRequest.setSize(Integer.parseInt(page.getSize() + ""));
erpQueryRequest.setSearch(search);
List<PpmReportDetailDTO> listVO = erpMesRbPkpqryClient.listErpNew(erpQueryRequest);
for (PpmReportDetailDTO oneVO : listVO) {

Loading…
Cancel
Save