fix
This commit is contained in:
@@ -345,11 +345,11 @@ public class SsxSiteDeviceDriver extends AbstractOpcDeviceDriver implements Devi
|
|||||||
}
|
}
|
||||||
String resp = acsToWmsService.applyTask(request);
|
String resp = acsToWmsService.applyTask(request);
|
||||||
JSONObject res_jo = JSONObject.parseObject(resp);
|
JSONObject res_jo = JSONObject.parseObject(resp);
|
||||||
if (StrUtil.equals(res_jo.getString("code"), "200")) {
|
// if (StrUtil.equals(res_jo.getString("code"), "200")) {
|
||||||
this.writing(type);
|
this.writing(type);
|
||||||
this.setRequireSucess(true);
|
this.setRequireSucess(true);
|
||||||
log.info("acs申请任务", this.devicecode, "任务申请成功!");
|
log.info("acs申请任务", this.devicecode, "任务申请成功!");
|
||||||
}
|
// }
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -85,6 +85,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@SneakyThrows
|
||||||
public BaseResponse acsApply(JSONObject param) {
|
public BaseResponse acsApply(JSONObject param) {
|
||||||
String requestNo = param.getString("requestNo");
|
String requestNo = param.getString("requestNo");
|
||||||
String requestMethodCode = param.getString("request_medthod_code"); // 获取请求方法名
|
String requestMethodCode = param.getString("request_medthod_code"); // 获取请求方法名
|
||||||
@@ -101,7 +102,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
|
|||||||
task.apply(param);
|
task.apply(param);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
String message = e.getMessage();
|
String message = e.getMessage();
|
||||||
log.error("ACS请求LMS出现错误: {}", message);
|
log.error("ACS请求LMS出现错误: {}{}", e,e.getMessage());
|
||||||
result.setCode(HttpStatus.HTTP_BAD_REQUEST);
|
result.setCode(HttpStatus.HTTP_BAD_REQUEST);
|
||||||
result.setMessage(message);
|
result.setMessage(message);
|
||||||
result.setRequestNo(requestNo);
|
result.setRequestNo(requestNo);
|
||||||
|
|||||||
@@ -57,7 +57,7 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
|
|||||||
Boolean parent_point = ObjectUtil.isNotEmpty(whereJson.get("parent_point")) ? Boolean.valueOf(whereJson.get("parent_point").toString()) : false;
|
Boolean parent_point = ObjectUtil.isNotEmpty(whereJson.get("parent_point")) ? Boolean.valueOf(whereJson.get("parent_point").toString()) : false;
|
||||||
LambdaQueryWrapper<SchBasePoint> lam = new LambdaQueryWrapper<>();
|
LambdaQueryWrapper<SchBasePoint> lam = new LambdaQueryWrapper<>();
|
||||||
lam.like(ObjectUtil.isNotEmpty(blurry), SchBasePoint::getPoint_code, blurry)
|
lam.like(ObjectUtil.isNotEmpty(blurry), SchBasePoint::getPoint_code, blurry)
|
||||||
.or(ObjectUtil.isNotEmpty(blurry), lam1 -> lam1.like(SchBasePoint::getPoint_name, blurry))
|
// .or(ObjectUtil.isNotEmpty(blurry), lam1 -> lam1.like(SchBasePoint::getPoint_name, blurry))
|
||||||
.eq(ObjectUtil.isNotEmpty(workshop_code), SchBasePoint::getWorkshop_code, workshop_code)
|
.eq(ObjectUtil.isNotEmpty(workshop_code), SchBasePoint::getWorkshop_code, workshop_code)
|
||||||
.eq(ObjectUtil.isNotEmpty(region_code), SchBasePoint::getRegion_code, region_code)
|
.eq(ObjectUtil.isNotEmpty(region_code), SchBasePoint::getRegion_code, region_code)
|
||||||
.eq(ObjectUtil.isNotEmpty(point_type), SchBasePoint::getPoint_type, point_type)
|
.eq(ObjectUtil.isNotEmpty(point_type), SchBasePoint::getPoint_type, point_type)
|
||||||
|
|||||||
Reference in New Issue
Block a user