fix: 新增混碾指定压机

This commit is contained in:
2023-12-28 16:14:56 +08:00
parent b01b4639e6
commit e64f2f354b
12 changed files with 97 additions and 8 deletions

View File

@@ -82,4 +82,11 @@ public class DeviceController {
return new ResponseEntity<>(deviceService.getAllRegions(),HttpStatus.OK);
}
@PostMapping("/getYjDeviceList")
@ApiOperation("查询压机生产设备")
//@SaCheckPermission("device:list")
public ResponseEntity<Object> getYjDeviceList(){
return new ResponseEntity<>(deviceService.getYjDeviceList(),HttpStatus.OK);
}
}

View File

@@ -72,4 +72,10 @@ public interface DeviceService {
* @return
*/
JSONArray getAllRegions();
/**
* 压机设备下拉框
* @return
*/
JSONArray getYjDeviceList();
}

View File

@@ -122,4 +122,5 @@ public class WorkorderDto implements Serializable {
private String gg;
private String kh;
private String associated_device;
}

View File

@@ -146,4 +146,11 @@ public class DeviceServiceImpl implements DeviceService {
return resultJSONArray;
}
@Override
public JSONArray getYjDeviceList() {
WQLObject wo = WQLObject.getWQLObject("pdm_bi_device");
JSONArray resultJSONArray = wo.query("region_code = 'YZ' AND device_model = '4'").getResultJSONArray(0);
return resultJSONArray;
}
}

View File

@@ -104,19 +104,28 @@ public class HLSendMaterialTask extends AbstractAcsTask {
.process()
.uniqueResult(0);
} else if ("2".equals(startPointType)) {
// 通过工单的关联压机送到对应位置,如果不满足就走以下流程
nextPoint = WQL.getWO("SEND_MATERIAL_TASK")
.addParam("flag", "4")
.addParam("material_id", task.getString("material_id"))
.addParam("flag", "8")
.addParam("device_code", startPoint.getString("device_code"))
.process()
.uniqueResult(0);
if (ObjectUtil.isEmpty(nextPoint)) {
if (ObjectUtil.isEmpty(nextPoint) || ObjectUtil.isEmpty(nextPoint.get("point_code"))) {
// 先去普通压机困料货位
nextPoint = WQL.getWO("SEND_MATERIAL_TASK")
.addParam("flag", "5")
.addParam("flag", "4")
.addParam("material_id", task.getString("material_id"))
.process()
.uniqueResult(0);
if (ObjectUtil.isEmpty(nextPoint)) {
// 公共货位
nextPoint = WQL.getWO("SEND_MATERIAL_TASK")
.addParam("flag", "5")
.process()
.uniqueResult(0);
}
}
}
if (ObjectUtil.isNotEmpty(nextPoint)) {
task.put("task_status", TaskStatus.START_AND_END.value());
task.put("point_code2", nextPoint.getString("point_code"));

View File

@@ -16,6 +16,7 @@
输入.flag TYPEAS s_string
输入.material_id TYPEAS f_string
输入.vd_id TYPEAS f_string
输入.device_code TYPEAS s_string
[临时表]
--这边列出来的临时表就会在运行期动态创建
@@ -159,3 +160,16 @@
ENDSELECT
ENDQUERY
ENDIF
IF 输入.flag = "8"
QUERY
SELECT
p.*
FROM
`pdm_bd_workorder` wo
LEFT JOIN sch_base_point p ON p.device_code = wo.associated_device AND p.region_code = 'KLHJ'
AND p.point_type = '3' AND p.point_status = '1' AND p.lock_type = '1' AND p.is_used = '1'
WHERE wo.order_status = '3' AND wo.device_code = 输入.device_code
ENDSELECT
ENDQUERY
ENDIF

View File

@@ -8,7 +8,7 @@ spring:
driverClassName: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
url: jdbc:log4jdbc:mysql://${DB_HOST:127.0.0.1}:${DB_PORT:3306}/${DB_NAME:yksh_lms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useOldAliasMetadataBehavior=true
username: ${DB_USER:root}
password: ${DB_PWD:123456}
password: ${DB_PWD:12356}
# 初始连接数
initial-size: 5
# 最小连接数

View File

@@ -2,7 +2,7 @@ spring:
freemarker:
check-template-location: false
profiles:
active: prod
active: dev
jackson:
time-zone: GMT+8
data:

View File

@@ -36,4 +36,15 @@ public class TempTest {
.getResultJSONArray(0);
info.forEach(System.out::println);
}
@Test
public void test02() {
JSONArray cupData = WQLObject.getWQLObject("st_ivt_vehicle_detail").query("is_delete = '0' AND vehicle_type = '1'").getResultJSONArray(0);
System.out.println("data" + cupData);
// 处理
System.out.println("ssss" + String.format("%.2f", cupData.stream().filter(o -> "1".equals(((JSONObject) o).getString("stand_status"))).mapToDouble(o -> ((JSONObject) o).getDoubleValue("weight")).sum() / 1000));
System.out.println("opop" + String.format("%.2f", cupData.stream().filter(o -> "23".contains(((JSONObject) o).getString("stand_status"))).mapToDouble(o -> ((JSONObject) o).getDoubleValue("weight")).sum() / 1000));
List<Object> standStatus = cupData.stream().filter(o -> "23".contains(((JSONObject) o).getString("stand_status"))).collect(Collectors.toList());
System.out.println("sdf");
}
}