This commit is contained in:
psh
2024-05-15 16:44:58 +08:00
parent db7eb0d5f9
commit 90cb23708a
6 changed files with 123 additions and 2 deletions

View File

@@ -130,11 +130,13 @@
a.number,
FLOOR( a.number / b.sum * 100 ) AS percentage
FROM
( SELECT productDescription AS NAME, count(*) AS number FROM sch_base_material GROUP BY productDescription ) a,(
( SELECT productDescription AS NAME, count(*) AS number FROM sch_base_material WHERE incomingWeight > 0 GROUP BY productDescription ) a,(
SELECT
count(*) AS sum
FROM
sch_base_material
WHERE
incomingWeight > 0
) b
</select>

View File

@@ -102,4 +102,10 @@ public class PdaController {
return new ResponseEntity<>(pdaService.zpjb(param), HttpStatus.OK);
}
@PostMapping("/ycck")
@Log("废包材异常出库")
@ApiOperation("废包材异常出库")
public ResponseEntity<Object> ycck(){
return new ResponseEntity<>(pdaService.ycck(), HttpStatus.OK);
}
}

View File

@@ -19,4 +19,6 @@ public interface PdaService {
PdaResponseVo zpjb(JSONObject param);
PdaResponseVo ycck();
}

View File

@@ -136,4 +136,21 @@ public class PdaServiceImpl implements PdaService {
}
return PdaResponseVo.pdaResultOk("组盘解绑成功");
}
@Override
public PdaResponseVo ycck() {
JSONObject param=new JSONObject();
SchBasePoint schBasePoint= pointService.getOne(new LambdaQueryWrapper<SchBasePoint>()
.eq(SchBasePoint::getPoint_code, "FBC01"));
param.put("sub_tray",schBasePoint.getVehicle_code2());
param.put("mother_tray",schBasePoint.getVehicle_code());
this.zpjb(param);
param.put("request_medthod_code", "POINTTask");
param.put("request_medthod_name", "点对点任务");
param.put("device_code","FBC01");
param.put("start_point","FBC01");
param.put("next_point","DKT01");
BaseResponse baseResponse=acsToWmsService.acsApply(param);
return PdaResponseVo.pdaResultOk(baseResponse.getMessage());
}
}

View File

@@ -2,6 +2,7 @@ package org.nl.wms.sch.point.controller;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
@@ -13,6 +14,8 @@ import org.nl.system.service.role.dao.SysRole;
import org.nl.system.service.user.ISysUserService;
import org.nl.system.service.user.dto.SysUserDetail;
import org.nl.system.service.user.dto.UserQuery;
import org.nl.wms.ext.service.AcsToWmsService;
import org.nl.wms.ext.service.dto.to.BaseResponse;
import org.nl.wms.sch.point.service.ISchBasePointService;
import org.nl.wms.sch.point.service.dao.SchBasePoint;
import org.springframework.beans.factory.annotation.Autowired;
@@ -39,6 +42,8 @@ public class SchBasePointController {
private ISchBasePointService schBasePointService;
@Autowired
private ISysUserService userService;
@Autowired
private AcsToWmsService acsToWmsService;
@GetMapping
@Log("查询点位管理")
@@ -101,4 +106,22 @@ public class SchBasePointController {
public ResponseEntity<Object> getPointList(@RequestBody(required = false) SchBasePoint region){
return new ResponseEntity<>(schBasePointService.getPointList(region),HttpStatus.OK);
}
@PostMapping("/outbound")
@Log("原材料异常出库")
@ApiOperation("原材料异常出库")
//@SaCheckPermission("@el.check('schBaseRegion:list')")
public ResponseEntity<Object> outbound(@RequestBody JSONObject param){
param.put("request_medthod_code", "POINTTask");
param.put("request_medthod_name", "点对点任务");
param.put("start_point",param.getString("device_code"));
param.put("next_point","FBC01");
SchBasePoint schBasePoint= schBasePointService.getOne(new LambdaQueryWrapper<SchBasePoint>()
.eq(SchBasePoint::getPoint_code, "FBC01"));
if(schBasePoint.getVehicle_qty()==1){
return new ResponseEntity<>(HttpStatus.BAD_REQUEST);
}
BaseResponse baseResponse=acsToWmsService.acsApply(param);
return new ResponseEntity<>(baseResponse,HttpStatus.OK);
}
}