Browse Source

opt: 任务。任务配置

master
李永德 11 months ago
parent
commit
bf5696c15f
  1. 6
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Searcher.java
  2. 2
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/system/controller/lucence/LuceneController.java
  3. 5
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/impl/LuceneServiceImpl.java
  4. 2
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/param/impl/SysParamServiceImpl.java
  5. 12
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java
  6. 19
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/controller/PdaController.java
  7. 7
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskController.java
  8. 6
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskconfigController.java
  9. 4
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskService.java
  10. 3
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskconfigService.java
  11. 5
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/SchBaseTask.java
  12. 5
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/mapper/SchBaseTaskMapper.java
  13. 36
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/mapper/SchBaseTaskMapper.xml
  14. 15
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dto/SchBaseTaskQuery.java
  15. 34
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java
  16. 8
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskconfigServiceImpl.java
  17. 4
      lms/nladmin-ui/src/views/lucene/index.vue
  18. 4
      lms/nladmin-ui/src/views/system/param/index.vue
  19. 8
      lms/nladmin-ui/src/views/wms/sch/task/config/schBaseTaskconfig.js
  20. 30
      lms/nladmin-ui/src/views/wms/sch/task/index.vue

6
lms/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Searcher.java

@ -107,14 +107,10 @@ public class Searcher {
for (ScoreDoc scoreDoc : scoreDocs) { for (ScoreDoc scoreDoc : scoreDocs) {
Document doc = reader.document(scoreDoc.doc); Document doc = reader.document(scoreDoc.doc);
String logInfo = LogMessageConstant.COLOR_CYAN + doc.get(LogMessageConstant.FIELD_LABEL) + String logInfo = LogMessageConstant.COLOR_RED + doc.get(LogMessageConstant.FIELD_TIMESTAMP) +
LogMessageConstant.COLOR_RESET + " - " + LogMessageConstant.COLOR_RESET + " - " +
LogMessageConstant.COLOR_BLUE + doc.get(LogMessageConstant.FIELD_IP) + LogMessageConstant.COLOR_BLUE + doc.get(LogMessageConstant.FIELD_IP) +
LogMessageConstant.COLOR_RESET + " - " + LogMessageConstant.COLOR_RESET + " - " +
LogMessageConstant.COLOR_YELLOW + doc.get(LogMessageConstant.FIELD_TRACEID) +
LogMessageConstant.COLOR_RESET + " - " +
LogMessageConstant.COLOR_RED + doc.get(LogMessageConstant.FIELD_TIMESTAMP) +
LogMessageConstant.COLOR_RESET + " - " +
LogMessageConstant.COLOR_GREEN + "[" + doc.get(LogMessageConstant.FIELD_THREAD) + "]" + LogMessageConstant.COLOR_GREEN + "[" + doc.get(LogMessageConstant.FIELD_THREAD) + "]" +
LogMessageConstant.COLOR_RESET + " - " + LogMessageConstant.COLOR_RESET + " - " +
LogMessageConstant.COLOR_BLACK + doc.get(LogMessageConstant.FIELD_LEVEL) + LogMessageConstant.COLOR_BLACK + doc.get(LogMessageConstant.FIELD_LEVEL) +

2
lms/nladmin-system/nlsso-server/src/main/java/org/nl/system/controller/lucence/LuceneController.java

@ -38,6 +38,6 @@ public class LuceneController {
@PostMapping("/deleteAllLog") @PostMapping("/deleteAllLog")
public ResponseEntity<Object> deleteAllLog() { public ResponseEntity<Object> deleteAllLog() {
luceneService.deleteAllLog(); luceneService.deleteAllLog();
return new ResponseEntity<>(HttpStatus.NO_CONTENT); return new ResponseEntity<>(HttpStatus.OK);
} }
} }

5
lms/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/impl/LuceneServiceImpl.java

@ -61,7 +61,10 @@ public class LuceneServiceImpl implements LuceneService {
IndexWriter writer = LuceneAppender.indexWriter; IndexWriter writer = LuceneAppender.indexWriter;
// 创建一个匹配所有文档的查询 // 创建一个匹配所有文档的查询
MatchAllDocsQuery query = new MatchAllDocsQuery(); MatchAllDocsQuery query = new MatchAllDocsQuery();
writer.deleteDocuments(query); // 获取删除的文档数量
long deletedDocs = writer.deleteDocuments(query);
// 输出删除的文档数量
System.out.println("Deleted " + deletedDocs + " documents");
writer.commit(); writer.commit();
} }

2
lms/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/param/impl/SysParamServiceImpl.java

@ -49,6 +49,8 @@ public class SysParamServiceImpl extends ServiceImpl<SysParamMapper, Param> impl
IPage<Param> pages = new Page<>(page.getPage() + 1, page.getSize()); IPage<Param> pages = new Page<>(page.getPage() + 1, page.getSize());
LambdaQueryWrapper<Param> lam = new QueryWrapper<Param>().lambda(); LambdaQueryWrapper<Param> lam = new QueryWrapper<Param>().lambda();
lam.like(ObjectUtil.isNotEmpty(code), Param::getCode, code) lam.like(ObjectUtil.isNotEmpty(code), Param::getCode, code)
.or(ObjectUtil.isNotEmpty(code))
.like(ObjectUtil.isNotEmpty(code), Param::getName, code)
.orderByAsc(Param::getCreate_time); .orderByAsc(Param::getCreate_time);
paramMapper.selectPage(pages, lam); paramMapper.selectPage(pages, lam);
return pages; return pages;

12
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java

@ -430,13 +430,15 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
String getStation = request.getGet_station(); String getStation = request.getGet_station();
String putStation = request.getPut_station(); String putStation = request.getPut_station();
// 查找当前点位中的信息,如果acs没有提供,就获取点位上的数据,如果点位没有,则数据失效 // 查找当前点位中的信息,如果acs没有提供,就获取点位上的数据,如果点位没有,则数据失效
// 拆垛位
SchBasePoint pickupPoint = pointService.getById(getStation); SchBasePoint pickupPoint = pointService.getById(getStation);
// 码垛位
SchBasePoint putPoint = pointService.getById(putStation); SchBasePoint putPoint = pointService.getById(putStation);
if (request.getGet_station_vehicle_code() == null || request.getGet_station_vehicle_code().equals("0")) { if (request.getGet_station_vehicle_code() == null || "0".equals(request.getGet_station_vehicle_code())) {
request.setGet_station_vehicle_code(pickupPoint.getVehicle_code()); throw new BadRequestException("取砖位的载具编码不能为空");
} }
if (request.getPut_station_vehicle_code() == null || request.getPut_station_vehicle_code().equals("0")) { if (request.getPut_station_vehicle_code() == null || "0".equals(request.getPut_station_vehicle_code())) {
request.setPut_station_vehicle_code(putPoint.getVehicle_code()); throw new BadRequestException("放置位的载具编码不能为空");
} }
// 获取工单 // 获取工单
PdmBdWorkorder productionTask = workorderService.getDeviceProductionTask(pickupPoint.getParent_point_code()); PdmBdWorkorder productionTask = workorderService.getDeviceProductionTask(pickupPoint.getParent_point_code());
@ -703,7 +705,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
taskResponse.setMessage("静置完成"); taskResponse.setMessage("静置完成");
taskResponse.setWeight(one.getMaterial_weight().toString()); taskResponse.setWeight(one.getMaterial_weight().toString());
taskResponse.setMudBatch(one.getPcsn()); taskResponse.setMudBatch(one.getPcsn());
// todo: 泥料数据删除 // 泥料数据删除
List<PdmBdRequestMaterialRecord> list = requestMaterialRecordService.list(new LambdaQueryWrapper<PdmBdRequestMaterialRecord>() List<PdmBdRequestMaterialRecord> list = requestMaterialRecordService.list(new LambdaQueryWrapper<PdmBdRequestMaterialRecord>()
.eq(PdmBdRequestMaterialRecord::getDevice_code, yjDeviceCode) .eq(PdmBdRequestMaterialRecord::getDevice_code, yjDeviceCode)
.eq(ObjectUtil.isNotEmpty(productionTask), PdmBdRequestMaterialRecord::getWorkorder_id, productionTask.getWorkorder_code()) .eq(ObjectUtil.isNotEmpty(productionTask), PdmBdRequestMaterialRecord::getWorkorder_id, productionTask.getWorkorder_code())

19
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/controller/PdaController.java

@ -3,6 +3,7 @@ package org.nl.wms.pda.controller;
import cn.dev33.satoken.annotation.SaIgnore; import cn.dev33.satoken.annotation.SaIgnore;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.nl.common.annotation.Limit;
import org.nl.common.logging.annotation.Log; import org.nl.common.logging.annotation.Log;
import org.nl.wms.das.device.check.service.IDasDeviceCheckRecordService; import org.nl.wms.das.device.check.service.IDasDeviceCheckRecordService;
import org.nl.wms.das.device.check.service.dao.DasDeviceCheckRecord; import org.nl.wms.das.device.check.service.dao.DasDeviceCheckRecord;
@ -44,56 +45,48 @@ public class PdaController {
@PostMapping("/deviceCheck/verify") @PostMapping("/deviceCheck/verify")
@Log("设备点检") @Log("设备点检")
public ResponseEntity<Object> deviceCheck(@Validated @RequestBody DasDeviceCheckRecord entity) { public ResponseEntity<Object> deviceCheck(@Validated @RequestBody DasDeviceCheckRecord entity) {
return new ResponseEntity<>(deviceCheckRecordService.create(entity), HttpStatus.OK); return new ResponseEntity<>(deviceCheckRecordService.create(entity), HttpStatus.OK);
} }
@PostMapping("/deviceCheck/deviceInfo") @PostMapping("/deviceCheck/deviceInfo")
@Log("设备下拉框数据") @Log("设备下拉框数据")
public ResponseEntity<Object> deviceInfo() { public ResponseEntity<Object> deviceInfo() {
return new ResponseEntity<>(pdaService.getDeviceInfo(), HttpStatus.OK); return new ResponseEntity<>(pdaService.getDeviceInfo(), HttpStatus.OK);
} }
@PostMapping("/deviceCheck/deviceStatus") @PostMapping("/deviceCheck/deviceStatus")
@Log("设备状态下拉框数据") @Log("设备状态下拉框数据")
public ResponseEntity<Object> deviceStatus() { public ResponseEntity<Object> deviceStatus() {
return new ResponseEntity<>(pdaService.getDeviceStatus(), HttpStatus.OK); return new ResponseEntity<>(pdaService.getDeviceStatus(), HttpStatus.OK);
} }
@PostMapping("/deviceSwitchover/deviceAction") @PostMapping("/deviceSwitchover/deviceAction")
@Log("设备动作下拉框数据") @Log("设备动作下拉框数据")
public ResponseEntity<Object> deviceAction() { public ResponseEntity<Object> deviceAction() {
return new ResponseEntity<>(pdaService.deviceAction(), HttpStatus.OK); return new ResponseEntity<>(pdaService.deviceAction(), HttpStatus.OK);
} }
@PostMapping("/deviceSwitchover/verify") @PostMapping("/deviceSwitchover/verify")
@Log("设备动作切换") @Log("设备动作切换")
public ResponseEntity<Object> deviceSwitchover(@Validated @RequestBody DasDeviceOperationRecord entity) { public ResponseEntity<Object> deviceSwitchover(@Validated @RequestBody DasDeviceOperationRecord entity) {
return new ResponseEntity<>(deviceOperationRecordService.create(entity), HttpStatus.OK); return new ResponseEntity<>(deviceOperationRecordService.create(entity), HttpStatus.OK);
} }
@PostMapping("/group/getPressCode") @PostMapping("/group/getPressCode")
@Log("获取压机编码") @Log("获取压机编码")
public ResponseEntity<Object> getPressCode() { public ResponseEntity<Object> getPressCode() {
return new ResponseEntity<>(pdaService.getDeviceInfo(), HttpStatus.OK); return new ResponseEntity<>(pdaService.getDeviceInfo(), HttpStatus.OK);
} }
@PostMapping("/group/getVehicleType") @PostMapping("/group/getVehicleType")
@Log("获取载具类型") @Log("获取载具类型")
public ResponseEntity<Object> getVehicleType() { public ResponseEntity<Object> getVehicleType() {
return new ResponseEntity<>(pdaService.getVehicleType(), HttpStatus.OK); return new ResponseEntity<>(pdaService.getVehicleType(), HttpStatus.OK);
} }
@PostMapping("/group/getPressWorkOrder") @PostMapping("/group/getPressWorkOrder")
@Log("获取工单编码") @Log("获取工单编码")
@Deprecated @Deprecated
public ResponseEntity<Object> getPressWorkOrder(@RequestBody JSONObject param) { public ResponseEntity<Object> getPressWorkOrder(@RequestBody JSONObject param) {
return new ResponseEntity<>(workorderService.getDeviceProductionTask(param.getString("point_code")), HttpStatus.OK); return new ResponseEntity<>(workorderService.getDeviceProductionTask(param.getString("point_code")), HttpStatus.OK);
@ -101,56 +94,48 @@ public class PdaController {
@PostMapping("/group/manual") @PostMapping("/group/manual")
@Log("人工组盘") @Log("人工组盘")
public ResponseEntity<PdaResponseVo> manualDiskAssembly(@Validated @RequestBody ManualGroupDto entity) { public ResponseEntity<PdaResponseVo> manualDiskAssembly(@Validated @RequestBody ManualGroupDto entity) {
return new ResponseEntity<>(pdaService.manualCreateByPda(entity), HttpStatus.OK); return new ResponseEntity<>(pdaService.manualCreateByPda(entity), HttpStatus.OK);
} }
@PostMapping("/move/getBlendingCode") @PostMapping("/move/getBlendingCode")
@Log("获取混碾机编码") @Log("获取混碾机编码")
public ResponseEntity<Object> getBlendingCode() { public ResponseEntity<Object> getBlendingCode() {
return new ResponseEntity<>(pdaService.getBlendingCode(), HttpStatus.OK); return new ResponseEntity<>(pdaService.getBlendingCode(), HttpStatus.OK);
} }
@PostMapping("/move/sendTask") @PostMapping("/move/sendTask")
@Log("生成混碾->压机任务") @Log("生成混碾->压机任务")
public ResponseEntity<PdaResponseVo> sendTask(@Validated @RequestBody BlendingMoveDto blendingMoveDto) { public ResponseEntity<PdaResponseVo> sendTask(@Validated @RequestBody BlendingMoveDto blendingMoveDto) {
return new ResponseEntity<>(pdaService.sendTask(blendingMoveDto), HttpStatus.OK); return new ResponseEntity<>(pdaService.sendTask(blendingMoveDto), HttpStatus.OK);
} }
@PostMapping("/forcedResting/show") @PostMapping("/forcedResting/show")
@Log("显示静置时长") @Log("显示静置时长")
public ResponseEntity<Object> forcedRestingShow() { public ResponseEntity<Object> forcedRestingShow() {
return new ResponseEntity<>(pdaService.forcedRestingShow(), HttpStatus.OK); return new ResponseEntity<>(pdaService.forcedRestingShow(), HttpStatus.OK);
} }
@PostMapping("/forcedResting/submit") @PostMapping("/forcedResting/submit")
@Log("强制静置") @Log("强制静置")
public ResponseEntity<PdaResponseVo> forcedResting(@Validated @RequestBody ForcedRestingDto forcedRestingDto) { public ResponseEntity<PdaResponseVo> forcedResting(@Validated @RequestBody ForcedRestingDto forcedRestingDto) {
return new ResponseEntity<>(pdaService.forcedResting(forcedRestingDto), HttpStatus.OK); return new ResponseEntity<>(pdaService.forcedResting(forcedRestingDto), HttpStatus.OK);
} }
@PostMapping("/manualSorting/orders") @PostMapping("/manualSorting/orders")
@Log("人工分拣-显示工单") @Log("人工分拣-显示工单")
public ResponseEntity<Object> manualOrders() { public ResponseEntity<Object> manualOrders() {
return new ResponseEntity<>(pdaService.manualOrders(), HttpStatus.OK); return new ResponseEntity<>(pdaService.manualOrders(), HttpStatus.OK);
} }
@PostMapping("/manualSorting/productionScheduling") @PostMapping("/manualSorting/productionScheduling")
@Log("人工分拣-开工") @Log("人工分拣-开工")
public ResponseEntity<PdaResponseVo> productionScheduling(@Validated @RequestBody ManualSortingDto manualSortingDto) { public ResponseEntity<PdaResponseVo> productionScheduling(@Validated @RequestBody ManualSortingDto manualSortingDto) {
return new ResponseEntity<>(pdaService.productionScheduling(manualSortingDto), HttpStatus.OK); return new ResponseEntity<>(pdaService.productionScheduling(manualSortingDto), HttpStatus.OK);
} }
@PostMapping("/manualSorting/productionComplete") @PostMapping("/manualSorting/productionComplete")
@Log("人工分拣-完工") @Log("人工分拣-完工")
public ResponseEntity<PdaResponseVo> productionComplete(@Validated @RequestBody ManualSortingDto manualSortingDto) { public ResponseEntity<PdaResponseVo> productionComplete(@Validated @RequestBody ManualSortingDto manualSortingDto) {
return new ResponseEntity<>(pdaService.productionComplete(manualSortingDto), HttpStatus.OK); return new ResponseEntity<>(pdaService.productionComplete(manualSortingDto), HttpStatus.OK);
} }
@ -227,7 +212,7 @@ public class PdaController {
@PostMapping("/manualSorting/bindingVehicle") @PostMapping("/manualSorting/bindingVehicle")
@Log("人工分拣-载具绑定") @Log("人工分拣-载具绑定")
@Limit(period = 2, count = 1)
public ResponseEntity<PdaResponseVo> bindingVehicle(@Validated @RequestBody VehicleBindingDto vehicleBindingDto) { public ResponseEntity<PdaResponseVo> bindingVehicle(@Validated @RequestBody VehicleBindingDto vehicleBindingDto) {
return new ResponseEntity<>(pdaService.bindingVehicle(vehicleBindingDto), HttpStatus.OK); return new ResponseEntity<>(pdaService.bindingVehicle(vehicleBindingDto), HttpStatus.OK);
} }

7
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskController.java

@ -7,6 +7,7 @@ import org.nl.common.domain.query.PageQuery;
import org.nl.common.logging.annotation.Log; import org.nl.common.logging.annotation.Log;
import org.nl.wms.sch.task.service.ISchBaseTaskService; import org.nl.wms.sch.task.service.ISchBaseTaskService;
import org.nl.wms.sch.task.service.dao.SchBaseTask; import org.nl.wms.sch.task.service.dao.SchBaseTask;
import org.nl.wms.sch.task.service.dto.SchBaseTaskQuery;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
@ -33,13 +34,12 @@ public class SchBaseTaskController {
@Log("查询任务管理") @Log("查询任务管理")
//@SaCheckPermission("@el.check('schBaseTask:list')") //@SaCheckPermission("@el.check('schBaseTask:list')")
public ResponseEntity<Object> query(@RequestParam Map whereJson, PageQuery page) { public ResponseEntity<Object> query(SchBaseTaskQuery whereJson, PageQuery page) {
return new ResponseEntity<>(TableDataInfo.build(schBaseTaskService.queryAll(whereJson, page)), HttpStatus.OK); return new ResponseEntity<>(TableDataInfo.build(schBaseTaskService.queryAll(whereJson, page)), HttpStatus.OK);
} }
@PostMapping @PostMapping
@Log("新增任务管理") @Log("新增任务管理")
//@SaCheckPermission("@el.check('schBaseTask:add')") //@SaCheckPermission("@el.check('schBaseTask:add')")
public ResponseEntity<Object> create(@Validated @RequestBody SchBaseTask entity) { public ResponseEntity<Object> create(@Validated @RequestBody SchBaseTask entity) {
schBaseTaskService.create(entity); schBaseTaskService.create(entity);
@ -48,7 +48,6 @@ public class SchBaseTaskController {
@PutMapping @PutMapping
@Log("修改任务管理") @Log("修改任务管理")
//@SaCheckPermission("@el.check('schBaseTask:edit')") //@SaCheckPermission("@el.check('schBaseTask:edit')")
public ResponseEntity<Object> update(@Validated @RequestBody SchBaseTask entity) { public ResponseEntity<Object> update(@Validated @RequestBody SchBaseTask entity) {
schBaseTaskService.update(entity); schBaseTaskService.update(entity);
@ -66,7 +65,6 @@ public class SchBaseTaskController {
@GetMapping("/taskStatusList") @GetMapping("/taskStatusList")
@Log("任务状态下拉框") @Log("任务状态下拉框")
@SaIgnore @SaIgnore
//@SaCheckPermission("@el.check('schBaseTask:list')") //@SaCheckPermission("@el.check('schBaseTask:list')")
public ResponseEntity<Object> getTaskStatusList() { public ResponseEntity<Object> getTaskStatusList() {
@ -75,7 +73,6 @@ public class SchBaseTaskController {
@PutMapping("/operation") @PutMapping("/operation")
@Log("任务操作") @Log("任务操作")
//@SaCheckPermission("task:edit") //@SaCheckPermission("task:edit")
public ResponseEntity<Object> update(@RequestBody Map<String, Object> map) { public ResponseEntity<Object> update(@RequestBody Map<String, Object> map) {
schBaseTaskService.operation(map); schBaseTaskService.operation(map);

6
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskconfigController.java

@ -63,4 +63,10 @@ public class SchBaseTaskconfigController {
schBaseTaskconfigService.deleteAll(ids); schBaseTaskconfigService.deleteAll(ids);
return new ResponseEntity<>(HttpStatus.OK); return new ResponseEntity<>(HttpStatus.OK);
} }
@PostMapping("/getTaskConfigList")
@Log("获取下拉框")
public ResponseEntity<Object> getTaskConfigList() {
return new ResponseEntity<>(schBaseTaskconfigService.getTaskConfigList(), HttpStatus.OK);
}
} }

4
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskService.java

@ -7,6 +7,8 @@ import com.baomidou.mybatisplus.extension.service.IService;
import org.nl.common.domain.query.PageQuery; import org.nl.common.domain.query.PageQuery;
import org.nl.wms.ext.acs.service.dto.to.BaseRequest; import org.nl.wms.ext.acs.service.dto.to.BaseRequest;
import org.nl.wms.sch.task.service.dao.SchBaseTask; import org.nl.wms.sch.task.service.dao.SchBaseTask;
import org.nl.wms.sch.task.service.dao.SchBaseTaskconfig;
import org.nl.wms.sch.task.service.dto.SchBaseTaskQuery;
import org.nl.wms.sch.task_manage.task.core.TaskStatus; import org.nl.wms.sch.task_manage.task.core.TaskStatus;
import java.math.BigDecimal; import java.math.BigDecimal;
@ -28,7 +30,7 @@ public interface ISchBaseTaskService extends IService<SchBaseTask> {
* @param pageable 分页参数 * @param pageable 分页参数
* @return IPage<SchBaseTask> * @return IPage<SchBaseTask>
*/ */
IPage<SchBaseTask> queryAll(Map whereJson, PageQuery pageable); IPage<SchBaseTask> queryAll(SchBaseTaskQuery whereJson, PageQuery pageable);
/** /**

3
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskconfigService.java

@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
import org.nl.common.domain.query.PageQuery; import org.nl.common.domain.query.PageQuery;
import org.nl.wms.sch.task.service.dao.SchBaseTaskconfig; import org.nl.wms.sch.task.service.dao.SchBaseTaskconfig;
import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
@ -44,4 +45,6 @@ public interface ISchBaseTaskconfigService extends IService<SchBaseTaskconfig> {
* @param ids / * @param ids /
*/ */
void deleteAll(Set<String> ids); void deleteAll(Set<String> ids);
List<SchBaseTaskconfig> getTaskConfigList();
} }

5
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/SchBaseTask.java

@ -1,6 +1,7 @@
package org.nl.wms.sch.task.service.dao; package org.nl.wms.sch.task.service.dao;
import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data; import lombok.Data;
@ -117,5 +118,9 @@ public class SchBaseTask implements Serializable {
private String update_time; private String update_time;
@TableField(exist = false)
private String config_name;
@TableField(exist = false)
private String task_name;
} }

5
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/mapper/SchBaseTaskMapper.java

@ -1,9 +1,12 @@
package org.nl.wms.sch.task.service.dao.mapper; package org.nl.wms.sch.task.service.dao.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.nl.wms.sch.task.service.dao.SchBaseTask; import org.nl.wms.sch.task.service.dao.SchBaseTask;
import org.nl.wms.sch.task.service.dto.SchBaseTaskQuery;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.List;
/** /**
* @author lyd * @author lyd
@ -16,4 +19,6 @@ public interface SchBaseTaskMapper extends BaseMapper<SchBaseTask> {
BigDecimal getCallMaterialCarryingByDevice(String deviceCode); BigDecimal getCallMaterialCarryingByDevice(String deviceCode);
int getCarryingByDevice(String deviceCode, String taskConfig); int getCarryingByDevice(String deviceCode, String taskConfig);
IPage<SchBaseTask> selectPageLeftJoin(IPage<SchBaseTask> pages, SchBaseTaskQuery whereJson, List<String> collect);
} }

36
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/mapper/SchBaseTaskMapper.xml

@ -33,4 +33,40 @@
AND t.task_status IN ('1', '2', '3', '4') AND t.task_status IN ('1', '2', '3', '4')
AND p1.parent_point_code = p2.parent_point_code AND p1.parent_point_code = p2.parent_point_code
</select> </select>
<select id="selectPageLeftJoin" resultType="org.nl.wms.sch.task.service.dao.SchBaseTask">
SELECT
t.*,
tc.config_name,
tc.task_name
FROM
`sch_base_task` t
LEFT JOIN sch_base_taskconfig tc ON tc.config_code = t.config_code
<where>
<if test="whereJson.task_code != null">
AND t.task_code = #{whereJson.task_code}
</if>
<if test="whereJson.config_code != null">
AND t.config_code = #{whereJson.config_code}
</if>
<if test="whereJson.unFinished != null">
AND t.task_status <![CDATA[<=]]> #{whereJson.unFinished}
</if>
<if test="whereJson.vehicle_code != null">
AND t.vehicle_code = #{whereJson.vehicle_code}
</if>
<if test="whereJson.end_time != null">
AND t.create_time <![CDATA[<=]]> #{query.end_time}
</if>
<if test="whereJson.begin_time != null">
AND t.create_time <![CDATA[>=]]> #{query.begin_time}
</if>
<if test="collect != null and collect != ''">
AND t.task_status IN
<foreach collection="collect" item="code" separator="," open="(" close=")">
#{code}
</foreach>
</if>
</where>
ORDER BY t.create_time DESC
</select>
</mapper> </mapper>

15
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dto/SchBaseTaskQuery.java

@ -1,12 +1,25 @@
package org.nl.wms.sch.task.service.dto; package org.nl.wms.sch.task.service.dto;
import lombok.Data;
import org.nl.common.domain.query.BaseQuery; import org.nl.common.domain.query.BaseQuery;
import org.nl.wms.sch.task.service.dao.SchBaseTask; import org.nl.wms.sch.task.service.dao.SchBaseTask;
import java.io.Serializable;
/** /**
* @author lyd * @author lyd
* @date 2023-05-15 * @date 2023-05-15
**/ **/
public class SchBaseTaskQuery extends BaseQuery<SchBaseTask> { @Data
public class SchBaseTaskQuery implements Serializable {
private String task_code;
private String vehicle_code;
private String point_code;
private String begin_time;
private String end_time;
private String more_task_status;
private String unFinished;
private String config_code;
} }

34
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java

@ -17,8 +17,10 @@ import org.nl.common.exception.BadRequestException;
import org.nl.common.utils.SecurityUtils; import org.nl.common.utils.SecurityUtils;
import org.nl.wms.sch.task.service.ISchBaseTaskService; import org.nl.wms.sch.task.service.ISchBaseTaskService;
import org.nl.wms.sch.task.service.dao.SchBaseTask; import org.nl.wms.sch.task.service.dao.SchBaseTask;
import org.nl.wms.sch.task.service.dao.SchBaseTaskconfig;
import org.nl.wms.sch.task.service.dao.mapper.SchBaseTaskMapper; import org.nl.wms.sch.task.service.dao.mapper.SchBaseTaskMapper;
import org.nl.wms.sch.task.service.dao.mapper.SchBaseTaskconfigMapper; import org.nl.wms.sch.task.service.dao.mapper.SchBaseTaskconfigMapper;
import org.nl.wms.sch.task.service.dto.SchBaseTaskQuery;
import org.nl.wms.sch.task_manage.AbstractTask; import org.nl.wms.sch.task_manage.AbstractTask;
import org.nl.wms.sch.task_manage.task.TaskFactory; import org.nl.wms.sch.task_manage.task.TaskFactory;
import org.nl.wms.sch.task_manage.task.core.TaskStatus; import org.nl.wms.sch.task_manage.task.core.TaskStatus;
@ -50,39 +52,17 @@ public class SchBaseTaskServiceImpl extends ServiceImpl<SchBaseTaskMapper, SchBa
private TaskFactory taskFactory; private TaskFactory taskFactory;
@Override @Override
public IPage<SchBaseTask> queryAll(Map whereJson, PageQuery page) { public IPage<SchBaseTask> queryAll(SchBaseTaskQuery whereJson, PageQuery page) {
String task_code = ObjectUtil.isNotEmpty(whereJson.get("task_code")) List<String> collect = ObjectUtil.isNotEmpty(whereJson.getMore_task_status())
? whereJson.get("task_code").toString() : null; ? Arrays.stream(whereJson.getMore_task_status().split(",")).collect(Collectors.toList()) : null;
String vehicle_code = ObjectUtil.isNotEmpty(whereJson.get("vehicle_code"))
? whereJson.get("vehicle_code").toString() : null;
String point_code = ObjectUtil.isNotEmpty(whereJson.get("point_code"))
? whereJson.get("point_code").toString() : null;
String begin_time = ObjectUtil.isNotEmpty(whereJson.get("begin_time"))
? whereJson.get("begin_time").toString() : null;
String end_time = ObjectUtil.isNotEmpty(whereJson.get("end_time"))
? whereJson.get("end_time").toString() : null;
String more_task_status = ObjectUtil.isNotEmpty(whereJson.get("more_task_status"))
? whereJson.get("more_task_status").toString() : null;
List<String> collect = ObjectUtil.isNotEmpty(more_task_status)
? Arrays.stream(more_task_status.split(",")).collect(Collectors.toList()) : null;
String unFinished = null;
if (collect != null) { if (collect != null) {
if (collect.contains(TaskStatus.UNFINISHED.getCode())) { if (collect.contains(TaskStatus.UNFINISHED.getCode())) {
collect = null; collect = null;
unFinished = TaskStatus.EXECUTING.getCode(); whereJson.setUnFinished(TaskStatus.EXECUTING.getCode());
} }
} }
LambdaQueryWrapper<SchBaseTask> lam = new LambdaQueryWrapper<>();
lam.eq(ObjectUtil.isNotEmpty(task_code), SchBaseTask::getTask_code, task_code)
.eq(ObjectUtil.isNotEmpty(vehicle_code), SchBaseTask::getVehicle_code, vehicle_code)
.eq(ObjectUtil.isNotEmpty(point_code), SchBaseTask::getPoint_code1, point_code)
.ge(ObjectUtil.isNotEmpty(begin_time), SchBaseTask::getCreate_time, begin_time)
.le(ObjectUtil.isNotEmpty(end_time), SchBaseTask::getCreate_time, end_time)
.in(ObjectUtil.isNotEmpty(collect), SchBaseTask::getTask_status, collect)
.le(ObjectUtil.isNotEmpty(unFinished), SchBaseTask::getTask_status, unFinished)
.orderByDesc(SchBaseTask::getUpdate_time);
IPage<SchBaseTask> pages = new Page<>(page.getPage() + 1, page.getSize()); IPage<SchBaseTask> pages = new Page<>(page.getPage() + 1, page.getSize());
schBaseTaskMapper.selectPage(pages, lam); pages = schBaseTaskMapper.selectPageLeftJoin(pages, whereJson, collect);
return pages; return pages;
} }

8
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskconfigServiceImpl.java

@ -18,8 +18,10 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Arrays; import java.util.Arrays;
import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.function.Consumer;
/** /**
* @author lyd * @author lyd
@ -39,6 +41,7 @@ public class SchBaseTaskconfigServiceImpl extends ServiceImpl<SchBaseTaskconfigM
String workshop_code = ObjectUtil.isNotEmpty(whereJson.get("workshop_code")) ? whereJson.get("workshop_code").toString() : null; String workshop_code = ObjectUtil.isNotEmpty(whereJson.get("workshop_code")) ? whereJson.get("workshop_code").toString() : null;
LambdaQueryWrapper<SchBaseTaskconfig> lam = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SchBaseTaskconfig> lam = new LambdaQueryWrapper<>();
lam.like(ObjectUtil.isNotEmpty(blurry), SchBaseTaskconfig::getConfig_name, blurry) lam.like(ObjectUtil.isNotEmpty(blurry), SchBaseTaskconfig::getConfig_name, blurry)
.or(ObjectUtil.isNotEmpty(blurry), la -> la.like( SchBaseTaskconfig::getConfig_code, blurry))
.eq(ObjectUtil.isNotEmpty(workshop_code), SchBaseTaskconfig::getWorkshop_code, workshop_code); .eq(ObjectUtil.isNotEmpty(workshop_code), SchBaseTaskconfig::getWorkshop_code, workshop_code);
IPage<SchBaseTaskconfig> pages = new Page<>(page.getPage() + 1, page.getSize()); IPage<SchBaseTaskconfig> pages = new Page<>(page.getPage() + 1, page.getSize());
schBaseTaskconfigMapper.selectPage(pages, lam); schBaseTaskconfigMapper.selectPage(pages, lam);
@ -127,4 +130,9 @@ public class SchBaseTaskconfigServiceImpl extends ServiceImpl<SchBaseTaskconfigM
schBaseTaskconfigMapper.deleteBatchIds(ids); schBaseTaskconfigMapper.deleteBatchIds(ids);
} }
@Override
public List<SchBaseTaskconfig> getTaskConfigList() {
return this.list();
}
} }

4
lms/nladmin-ui/src/views/lucene/index.vue

@ -144,6 +144,10 @@ export default {
toDeleteLog() { toDeleteLog() {
luceneOperation.deleteAllLog().then(res => { luceneOperation.deleteAllLog().then(res => {
this.crud.notify('删除成功', CRUD.NOTIFICATION_TYPE.SUCCESS) this.crud.notify('删除成功', CRUD.NOTIFICATION_TYPE.SUCCESS)
this.crud.toQuery()
}).finally(() => {
this.crud.notify('删除成功', CRUD.NOTIFICATION_TYPE.SUCCESS)
this.crud.toQuery()
}) })
}, },
getTagList() { getTagList() {

4
lms/nladmin-ui/src/views/system/param/index.vue

@ -10,12 +10,12 @@
label-width="80px" label-width="80px"
label-suffix=":" label-suffix=":"
> >
<el-form-item label="参数编码"> <el-form-item label="模糊查询">
<el-input <el-input
v-model="query.code" v-model="query.code"
clearable clearable
style="width: 240px" style="width: 240px"
placeholder="参数编码" placeholder="编码/名称"
/> />
</el-form-item> </el-form-item>
<rrOperation /> <rrOperation />

8
lms/nladmin-ui/src/views/wms/sch/task/config/schBaseTaskconfig.js

@ -7,6 +7,12 @@ export function add(data) {
data data
}) })
} }
export function getTaskConfigList() {
return request({
url: 'api/schBaseTaskconfig/getTaskConfigList',
method: 'post'
})
}
export function del(ids) { export function del(ids) {
return request({ return request({
@ -24,4 +30,4 @@ export function edit(data) {
}) })
} }
export default { add, edit, del } export default { add, edit, del, getTaskConfigList }

30
lms/nladmin-ui/src/views/wms/sch/task/index.vue

@ -15,7 +15,7 @@
<el-input <el-input
v-model="query.task_code" v-model="query.task_code"
clearable clearable
style="width: 180px" style="width: 240px"
placeholder="任务号" placeholder="任务号"
@keyup.enter.native="crud.toQuery" @keyup.enter.native="crud.toQuery"
/> />
@ -25,16 +25,29 @@
<el-input <el-input
v-model="query.vehicle_code" v-model="query.vehicle_code"
clearable clearable
style="width: 180px" style="width: 240px"
placeholder="载具号" placeholder="载具号"
@keyup.enter.native="crud.toQuery" @keyup.enter.native="crud.toQuery"
/> />
</el-form-item> </el-form-item>
<el-form-item label="任务名称">
<label slot="label">任务名称:</label>
<el-select v-model="query.config_code" placeholder="请选择" style="width: 240px" @change="crud.toQuery" clearable>
<el-option
v-for="item in taskConfigList"
:key="item.config_id"
:label="item.task_name"
:value="item.config_code">
<span style="float: left">{{ item.config_code }}</span>
<span style="float: right; color: #8492a6; font-size: 13px">{{ item.task_name }}</span>
</el-option>
</el-select>
</el-form-item>
<el-form-item label="点位编码"> <el-form-item label="点位编码">
<el-input <el-input
v-model="query.point_code" v-model="query.point_code"
clearable clearable
style="width: 180px" style="width: 240px"
placeholder="起点" placeholder="起点"
@keyup.enter.native="crud.toQuery" @keyup.enter.native="crud.toQuery"
/> />
@ -179,6 +192,7 @@
</el-table-column> </el-table-column>
<el-table-column prop="remark" label="提示信息" :min-width="flexWidth('remark',crud.data,'提示信息')" /> <el-table-column prop="remark" label="提示信息" :min-width="flexWidth('remark',crud.data,'提示信息')" />
<el-table-column prop="config_code" label="配置编码" :min-width="flexWidth('config_code',crud.data,'配置编码')" /> <el-table-column prop="config_code" label="配置编码" :min-width="flexWidth('config_code',crud.data,'配置编码')" />
<el-table-column prop="task_name" label="配置名称" :min-width="flexWidth('task_name',crud.data,'任务名称')" />
<el-table-column prop="point_code1" label="起点1" :min-width="flexWidth('point_code1',crud.data,'点位1')" /> <el-table-column prop="point_code1" label="起点1" :min-width="flexWidth('point_code1',crud.data,'点位1')" />
<el-table-column prop="point_code2" label="终点1" :min-width="flexWidth('point_code2',crud.data,'点位2')" /> <el-table-column prop="point_code2" label="终点1" :min-width="flexWidth('point_code2',crud.data,'点位2')" />
<el-table-column prop="point_code3" label="起点2" :min-width="flexWidth('point_code3',crud.data,'点位3')" /> <el-table-column prop="point_code3" label="起点2" :min-width="flexWidth('point_code3',crud.data,'点位3')" />
@ -244,6 +258,7 @@
<script> <script>
import crudSchBaseTask from './schBaseTask' import crudSchBaseTask from './schBaseTask'
import crudSchBaseTaskconfig from './config/schBaseTaskconfig'
import CRUD, { crud, form, header, presenter } from '@crud/crud' import CRUD, { crud, form, header, presenter } from '@crud/crud'
import rrOperation from '@crud/RR.operation' import rrOperation from '@crud/RR.operation'
import crudOperation from '@crud/CRUD.operation' import crudOperation from '@crud/CRUD.operation'
@ -307,17 +322,24 @@ export default {
}, },
rules: { rules: {
}, },
taskStatusList: [] taskStatusList: [],
taskConfigList: []
} }
}, },
created() { created() {
this.getTaskStatusList() this.getTaskStatusList()
this.getTaskConfigList()
}, },
methods: { methods: {
// false // false
[CRUD.HOOK.beforeRefresh]() { [CRUD.HOOK.beforeRefresh]() {
return true return true
}, },
getTaskConfigList() {
crudSchBaseTaskconfig.getTaskConfigList().then(res => {
this.taskConfigList = res
})
},
hand(value) { hand(value) {
this.crud.toQuery() this.crud.toQuery()
}, },

Loading…
Cancel
Save