fix: 半条任务只针对B2烘箱

This commit is contained in:
2025-03-16 22:17:51 +08:00
parent f4b61a103d
commit a8878b77a0

View File

@@ -217,6 +217,8 @@ public class CallEmpReelTask extends AbstractAcsTask {
cache_param.put("product_area", jsonIvt.getString("product_area")); cache_param.put("product_area", jsonIvt.getString("product_area"));
JSONObject cache_jo = WQL.getWO("PDA_COOLIN").addParamMap(cache_param).process().uniqueResult(0); JSONObject cache_jo = WQL.getWO("PDA_COOLIN").addParamMap(cache_param).process().uniqueResult(0);
if (ObjectUtil.isEmpty(cache_jo) || ObjectUtil.isEmpty(cache_jo.getString("point_code"))) { if (ObjectUtil.isEmpty(cache_jo) || ObjectUtil.isEmpty(cache_jo.getString("point_code"))) {
// B1才创建半条任务
if ("B1".equals(jsonTask.getString("product_area"))) {
// 创建半条任务 // 创建半条任务
JSONObject jo = new JSONObject(); JSONObject jo = new JSONObject();
jo.put("task_id", IdUtil.getSnowflake(1, 1).nextId()); jo.put("task_id", IdUtil.getSnowflake(1, 1).nextId());
@@ -235,6 +237,10 @@ public class CallEmpReelTask extends AbstractAcsTask {
jo.put("create_time", DateUtil.now()); jo.put("create_time", DateUtil.now());
jo.put("acs_task_type", "6"); jo.put("acs_task_type", "6");
taskTab.insert(jo); taskTab.insert(jo);
} else {
throw new BadRequestException("找不到对应的半成品缓存位");
}
} else { } else {
JSONObject param = new JSONObject(); JSONObject param = new JSONObject();
param.put("point_code1", point_code4); param.put("point_code1", point_code4);