This commit is contained in:
2023-01-09 09:58:06 +08:00
parent a4e283b341
commit 0686beac3d
2 changed files with 14 additions and 7 deletions

View File

@@ -57,7 +57,6 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
* @param string 条件 * @param string 条件
* @returnzss * @returnzss
*/ */
@LokiLog(type = LokiLogType.ACS_TO_LMS)
@Override @Override
public Map<String, Object> receiveTaskStatusAcs(String string) { public Map<String, Object> receiveTaskStatusAcs(String string) {
JSONArray array = JSONArray.parseArray(string); JSONArray array = JSONArray.parseArray(string);
@@ -129,7 +128,6 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
return result; return result;
} }
@LokiLog(type = LokiLogType.ACS_TO_LMS)
@Override @Override
public String againApply(String task_id) { public String againApply(String task_id) {
log.info("输入参数:" + task_id); log.info("输入参数:" + task_id);
@@ -153,13 +151,11 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
return point_code; return point_code;
} }
@LokiLog(type = LokiLogType.ACS_TO_LMS)
@Override @Override
public Map<String, Object> receivePointStatusFromAcs(Map<String, String> jsonObject) { public Map<String, Object> receivePointStatusFromAcs(Map<String, String> jsonObject) {
return null; return null;
} }
@LokiLog(type = LokiLogType.ACS_TO_LMS)
@Override @Override
public Map<String, Object> orderFinish(String string) { public Map<String, Object> orderFinish(String string) {
JSONObject orderJson = JSONObject.parseObject(string); JSONObject orderJson = JSONObject.parseObject(string);
@@ -182,8 +178,8 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
return result; return result;
} }
@LokiLog(type = LokiLogType.ACS_TO_LMS)
@Override @Override
@LokiLog(type = LokiLogType.ACS_TO_LMS)
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public JSONObject apply(JSONObject whereJson) { public JSONObject apply(JSONObject whereJson) {
String type = whereJson.getString("type"); String type = whereJson.getString("type");
@@ -204,6 +200,8 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
* 4.出库口申请入发货区任务 * 4.出库口申请入发货区任务
*/ */
if (type.equals("1")) { if (type.equals("1")) {
boolean checked = true;
boolean auto_div = false;
if (ObjectUtil.isEmpty(vehicle_code)) throw new BadRequestException("ACS申请任务失败载具不能为空"); if (ObjectUtil.isEmpty(vehicle_code)) throw new BadRequestException("ACS申请任务失败载具不能为空");
//通过该木箱码查询对应的分配明细 //通过该木箱码查询对应的分配明细
JSONArray dis_rows = WQLObject.getWQLObject("st_ivt_iostorinvdis").query("work_status = '00' AND box_no = '" + vehicle_code + "'").getResultJSONArray(0); JSONArray dis_rows = WQLObject.getWQLObject("st_ivt_iostorinvdis").query("work_status = '00' AND box_no = '" + vehicle_code + "'").getResultJSONArray(0);
@@ -221,6 +219,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
dis_map.put("sect_name",dis_row.getString("sect_name")); dis_map.put("sect_name",dis_row.getString("sect_name"));
dis_map.put("struct_id",dis_row.getString("struct_id")); dis_map.put("struct_id",dis_row.getString("struct_id"));
dis_map.put("struct_code",dis_row.getString("struct_code")); dis_map.put("struct_code",dis_row.getString("struct_code"));
if (StrUtil.isNotEmpty(dis_row.getString("struct_code"))){
auto_div = true;
checked = false;
}
dis_map.put("struct_name",dis_row.getString("struct_name")); dis_map.put("struct_name",dis_row.getString("struct_name"));
dis_map.put("iostorinv_id",dis_row.getString("iostorinv_id")); dis_map.put("iostorinv_id",dis_row.getString("iostorinv_id"));
dis_list.add(dis_map); dis_list.add(dis_map);
@@ -231,7 +233,8 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
map.put("tableMater", dis_list); map.put("tableMater", dis_list);
map.put("point_code", device_code); map.put("point_code", device_code);
map.put("sect_id", sect_jo.getString("sect_id")); map.put("sect_id", sect_jo.getString("sect_id"));
map.put("checked", true); map.put("checked", checked);
map.put("auto_div", auto_div);
map.put("auto_issue", "1"); map.put("auto_issue", "1");
//自动分配货位并下发任务 //自动分配货位并下发任务
rawAssistIStorService.divStruct(map); rawAssistIStorService.divStruct(map);

View File

@@ -469,9 +469,13 @@ public class RawAssistIStorServiceImpl implements RawAssistIStorService {
JSONObject whereJson2 = JSONObject.parseObject(JSON.toJSONString(whereJson)); JSONObject whereJson2 = JSONObject.parseObject(JSON.toJSONString(whereJson));
HashMap<String, String> map = rows.get(0); HashMap<String, String> map = rows.get(0);
Boolean auto_div = false;
if (whereJson2.containsKey("auto_div")){
auto_div = whereJson2.getBoolean("auto_div");
}
//判断该载具是否已经分配货位或者起点 //判断该载具是否已经分配货位或者起点
JSONArray now_dis_rows = WQL.getWO("QST_IVT_RAWASSISTISTOR").addParam("flag", "17").addParam("box_no", map.get("box_no")).process().getResultJSONArray(0); JSONArray now_dis_rows = WQL.getWO("QST_IVT_RAWASSISTISTOR").addParam("flag", "17").addParam("box_no", map.get("box_no")).process().getResultJSONArray(0);
if (now_dis_rows.size() > 0) { if (now_dis_rows.size() > 0 && !auto_div) {
throw new BadRequestException("该木箱已经分配过货位,无法继续分配!"); throw new BadRequestException("该木箱已经分配过货位,无法继续分配!");
} }