From b762ec097a64a08b4233ca278fb6d4b2463725d2 Mon Sep 17 00:00:00 2001 From: baoge <751575283@qq.com> Date: Mon, 17 Apr 2023 11:22:36 +0800 Subject: [PATCH 01/19] =?UTF-8?q?rev:=E4=BF=AE=E6=94=B9=E5=8D=8A=E6=88=90?= =?UTF-8?q?=E5=93=81=E5=87=BA=E5=BA=93=E9=A1=B5=E9=9D=A2=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mes/qd/src/api/wms/st/out/semiProductOut.js | 351 +++++++++-------- mes/qd/src/views/wms/st/productOut/AddDtl.vue | 2 +- .../views/wms/st/productOut/ViewDialog.vue | 150 +++---- .../views/wms/st/semiProductIn/AddDialog.vue | 245 ++++++++---- .../views/wms/st/semiProductOut/AddDialog.vue | 368 ++++++++++++------ .../views/wms/st/semiProductOut/AddDtl.vue | 114 ++++-- 6 files changed, 714 insertions(+), 516 deletions(-) diff --git a/mes/qd/src/api/wms/st/out/semiProductOut.js b/mes/qd/src/api/wms/st/out/semiProductOut.js index 8d4c1e1c..caeea7c9 100644 --- a/mes/qd/src/api/wms/st/out/semiProductOut.js +++ b/mes/qd/src/api/wms/st/out/semiProductOut.js @@ -1,228 +1,261 @@ import request from '@/utils/request' export function add(data) { - return request({ - url: 'api/productOut', - method: 'post', - data - }) + return request({ + url: 'api/semiProductOut', + method: 'post', + data + }) } export function del(ids) { - return request({ - url: 'api/productOut/', - method: 'delete', - data: ids - }) + return request({ + url: 'api/semiProductOut/', + method: 'delete', + data: ids + }) } export function edit(data) { - return request({ - url: 'api/productOut', - method: 'put', - data - }) + return request({ + url: 'api/semiProductOut', + method: 'put', + data + }) } export function getOutBillDtl(data) { - return request({ - url: '/api/productOut/getOutBillDtl', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/getOutBillDtl', + method: 'post', + data + }) } export function getOutBillDis(data) { - return request({ - url: '/api/productOut/getOutBillDis', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/getOutBillDis', + method: 'post', + data + }) } export function getOutBillDisDtl(params) { - return request({ - url: '/api/productOut/getOutBillDisDtl', - method: 'get', - params - }) + return request({ + url: '/api/semiProductOut/getOutBillDisDtl', + method: 'get', + params + }) } export function getOutBillTask(params) { - return request({ - url: '/api/productOut/getOutBillTask', - method: 'get', - params - }) + return request({ + url: '/api/semiProductOut/getOutBillTask', + method: 'get', + params + }) } export function getInvTypes() { - return request({ - url: '/api/productOut/getInvTypes', - method: 'get' - }) + return request({ + url: '/api/semiProductOut/getInvTypes', + method: 'get' + }) } export function insertDtl(data) { - return request({ - url: '/api/productOut/insertDtl', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/insertDtl', + method: 'post', + data + }) } export function allDiv(data) { - return request({ - url: '/api/productOut/allDiv', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/allDiv', + method: 'post', + data + }) } export function allDivOne(data) { - return request({ - url: '/api/productOut/allDivOne', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/allDivOne', + method: 'post', + data + }) } export function allCancel(data) { - return request({ - url: '/api/productOut/allCancel', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/allCancel', + method: 'post', + data + }) } export function oneCancel(data) { - return request({ - url: '/api/productOut/oneCancel', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/oneCancel', + method: 'post', + data + }) } export function setPoint(data) { - return request({ - url: '/api/productOut/setPoint', - method: 'post', - data - }) + + return request({ + url: '/api/semiProductOut/setPoint', + method: 'post', + data + }) } export function oneSetPoint(data) { - return request({ - url: '/api/productOut/oneSetPoint', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/oneSetPoint', + method: 'post', + data + }) } export function getStructIvt(params) { - return request({ - url: '/api/productOut/getStructIvt', - method: 'get', - params - }) + return request({ + url: '/api/semiProductOut/getStructIvt', + method: 'get', + params + }) } export function manualDiv(data) { - return request({ - url: '/api/productOut/manualDiv', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/manualDiv', + method: 'post', + data + }) } export function confirm(data) { - return request({ - url: '/api/productOut/confirm', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/confirm', + method: 'post', + data + }) } export function issueTask(data) { - return request({ - url: '/api/productOut/issueTask', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/issueTask', + method: 'post', + data + }) } export function finishTask(data) { - return request({ - url: '/api/productOut/finishTask', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/finishTask', + method: 'post', + data + }) } export function cancleTaskfinish(data) { - return request({ - url: '/api/productOut/cancleTaskfinish', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/cancleTaskfinish', + method: 'post', + data + }) } export function paramByCodeType(data) { - return request({ - url: '/api/productOut/paramByCodeType', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/paramByCodeType', + method: 'post', + data + }) } export function schAreaType(data) { - return request({ - url: '/api/productOut/schAreaType', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/schAreaType', + method: 'post', + data + }) } export function backConfirm(data) { - return request({ - url: '/api/productOut/backConfirm', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/backConfirm', + method: 'post', + data + }) } export function getType() { - return request({ - url: '/api/productOut/getType', - method: 'get' - }) + return request({ + url: '/api/semiProductOut/getType', + method: 'get' + }) } export function moneySubmit(data) { - return request({ - url: '/api/productOut/moneySubmit', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/moneySubmit', + method: 'post', + data + }) } export function getDisNum(data) { - return request({ - url: '/api/productOut/getDisNum', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/getDisNum', + method: 'post', + data + }) } export function queryBox(data) { - return request({ - url: '/api/productOut/queryBox', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/queryBox', + method: 'post', + data + }) } export function getOutBillTask2(data) { - return request({ - url: '/api/productOut/getOutBillTask2', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/getOutBillTask2', + method: 'post', + data + }) } export function cancelTask(data) { - return request({ - url: '/api/productOut/cancelTask', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/cancelTask', + method: 'post', + data + }) } export function allSetPoint(data) { - return request({ - url: '/api/productOut/allSetPoint', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/allSetPoint', + method: 'post', + data + }) } export function oneSetPoint2(data) { - return request({ - url: '/api/productOut/oneSetPoint2', - method: 'post', - data - }) + return request({ + url: '/api/semiProductOut/oneSetPoint2', + method: 'post', + data + }) +} +export default { + add, + edit, + del, + allDiv, + allCancel, + getOutBillDtl, + getOutBillDis, + setPoint, + oneSetPoint, + getOutBillTask, + getStructIvt, + manualDiv, + confirm, + issueTask, + finishTask, + cancleTaskfinish, + getInvTypes, + paramByCodeType, + schAreaType, + backConfirm, + getOutBillDisDtl, + getType, + allDivOne, + moneySubmit, + getDisNum, + queryBox, + getOutBillTask2, + oneCancel, + cancelTask, + allSetPoint, + oneSetPoint2 } -export default { add, edit, del, allDiv, allCancel, getOutBillDtl, getOutBillDis, setPoint, oneSetPoint, getOutBillTask, getStructIvt, manualDiv, confirm, issueTask, finishTask, cancleTaskfinish, getInvTypes, paramByCodeType, schAreaType, backConfirm, getOutBillDisDtl, getType, allDivOne, moneySubmit, getDisNum, queryBox, getOutBillTask2, oneCancel, cancelTask, allSetPoint, oneSetPoint2 } diff --git a/mes/qd/src/views/wms/st/productOut/AddDtl.vue b/mes/qd/src/views/wms/st/productOut/AddDtl.vue index 2c67efa6..3dc1c400 100644 --- a/mes/qd/src/views/wms/st/productOut/AddDtl.vue +++ b/mes/qd/src/views/wms/st/productOut/AddDtl.vue @@ -81,7 +81,7 @@ export default { components: { rrOperation, pagination }, cruds() { return CRUD({ - title: '用户', url: 'api/productOut/addDtl', + title: '用户', url: 'api/semiProductOut/addDtl', optShow: { add: false, edit: false, diff --git a/mes/qd/src/views/wms/st/productOut/ViewDialog.vue b/mes/qd/src/views/wms/st/productOut/ViewDialog.vue index 6d2f6669..daea24ca 100644 --- a/mes/qd/src/views/wms/st/productOut/ViewDialog.vue +++ b/mes/qd/src/views/wms/st/productOut/ViewDialog.vue @@ -1,69 +1,28 @@ - From 70e84ce4da74937f81c0e84da7f51127fd7723f6 Mon Sep 17 00:00:00 2001 From: liuxy Date: Tue, 6 Jun 2023 17:20:33 +0800 Subject: [PATCH 02/19] =?UTF-8?q?add=EF=BC=9A=E6=88=90=E5=93=81=E5=BA=93?= =?UTF-8?q?=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../structIvt/StIvtStructivtCpController.java | 13 ++ .../structIvt/IStIvtStructivtCpService.java | 10 ++ .../dao/mapper/StIvtStructivtCpMapper.java | 3 + .../dao/mapper/StIvtStructivtCpMapper.xml | 40 +++++ .../service/structIvt/dto/CpIvtQuery.java | 27 ++++ .../impl/StIvtStructivtCpServiceImpl.java | 15 ++ .../product/productIvt/index.vue | 150 ++++++++++++++++++ .../product/productIvt/productivt.js | 31 ++++ 8 files changed, 289 insertions(+) create mode 100644 mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dto/CpIvtQuery.java create mode 100644 mes/qd/src/views/wms/storage_manage/product/productIvt/index.vue create mode 100644 mes/qd/src/views/wms/storage_manage/product/productIvt/productivt.js diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/controller/structIvt/StIvtStructivtCpController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/controller/structIvt/StIvtStructivtCpController.java index 1ca07fcf..90e71582 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/controller/structIvt/StIvtStructivtCpController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/controller/structIvt/StIvtStructivtCpController.java @@ -2,15 +2,20 @@ package org.nl.wms.storage_manage.productmanage.controller.structIvt; import io.swagger.annotations.ApiOperation; import org.nl.common.anno.Log; +import org.nl.common.domain.query.PageQuery; import org.nl.wms.storage_manage.productmanage.service.structIvt.IStIvtStructivtCpService; +import org.nl.wms.storage_manage.productmanage.service.structIvt.dto.CpIvtQuery; import org.nl.wms.storage_manage.rawmanage.service.structIvt.dto.StructIvtYLQuery; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; +import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.util.Map; + /** *

* 仓位库存表 前端控制器 @@ -26,6 +31,14 @@ public class StIvtStructivtCpController { @Autowired private IStIvtStructivtCpService iStIvtStructivtCpService; + + @GetMapping + @Log("成品库存查询") + @ApiOperation("成品库存查询") + public ResponseEntity query(CpIvtQuery query, PageQuery page) { + return new ResponseEntity<>(iStIvtStructivtCpService.packageQuery(query,page), HttpStatus.OK); + } + @PostMapping("/getStructIvt") @Log("查询库存") @ApiOperation("查询库存") diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/IStIvtStructivtCpService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/IStIvtStructivtCpService.java index b89401dd..7a4c8f04 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/IStIvtStructivtCpService.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/IStIvtStructivtCpService.java @@ -2,7 +2,9 @@ package org.nl.wms.storage_manage.productmanage.service.structIvt; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.extension.service.IService; +import org.nl.common.domain.query.PageQuery; import org.nl.wms.storage_manage.productmanage.service.structIvt.dao.StIvtStructivtCp; +import org.nl.wms.storage_manage.productmanage.service.structIvt.dto.CpIvtQuery; import org.nl.wms.storage_manage.rawmanage.service.structIvt.dto.StructIvtYLQuery; import java.util.List; @@ -18,6 +20,13 @@ import java.util.Map; */ public interface IStIvtStructivtCpService extends IService { + + /** + * 成品库存查询 + * @param query / + */ + Object packageQuery(CpIvtQuery query, PageQuery page); + /** * 成品库存更新 * @param json @@ -58,4 +67,5 @@ public interface IStIvtStructivtCpService extends IService { * } */ List getStructIvtMore(StructIvtYLQuery whereJson); + } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.java index 8f4dc19a..cd3c9df1 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.java @@ -3,7 +3,9 @@ package org.nl.wms.storage_manage.productmanage.service.structIvt.dao.mapper; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Param; +import org.nl.common.domain.query.PageQuery; import org.nl.wms.storage_manage.productmanage.service.structIvt.dao.StIvtStructivtCp; +import org.nl.wms.storage_manage.productmanage.service.structIvt.dto.CpIvtQuery; import org.nl.wms.storage_manage.rawmanage.service.structIvt.dto.StructIvtYLQuery; import java.util.List; @@ -27,4 +29,5 @@ public interface StIvtStructivtCpMapper extends BaseMapper { List getStructIvtMoreBox(JSONObject json); + List packageQuery(@Param("query") CpIvtQuery query); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.xml b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.xml index 4c9bf7f5..e44d6174 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.xml +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dao/mapper/StIvtStructivtCpMapper.xml @@ -138,4 +138,44 @@ + + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dto/CpIvtQuery.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dto/CpIvtQuery.java new file mode 100644 index 00000000..e02b21b9 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/dto/CpIvtQuery.java @@ -0,0 +1,27 @@ +package org.nl.wms.storage_manage.productmanage.service.structIvt.dto; + +import lombok.Data; +import org.nl.common.domain.query.BaseQuery; +import org.nl.common.domain.query.QParam; +import org.nl.common.enums.QueryTEnum; +import org.nl.wms.storage_manage.productmanage.service.structIvt.dao.StIvtStructivtCp; + +/* + * @author LXY + * @Date 2023/5/4 19:49 + */ +@Data +public class CpIvtQuery extends BaseQuery { + + + private String struct_code; + + private String material_code; + + @Override + public void paramMapping() { + super.doP.put("struct_code", QParam.builder().k(new String[]{"struct_code"}).type(QueryTEnum.LK).build()); + } + + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/impl/StIvtStructivtCpServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/impl/StIvtStructivtCpServiceImpl.java index 78a2a1ba..3da06584 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/impl/StIvtStructivtCpServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/structIvt/impl/StIvtStructivtCpServiceImpl.java @@ -6,6 +6,10 @@ import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.github.pagehelper.Page; +import com.github.pagehelper.PageHelper; +import org.nl.common.TableDataInfo; +import org.nl.common.domain.query.PageQuery; import org.nl.common.utils.IdUtil; import org.nl.modules.common.exception.BadRequestException; import org.nl.wms.masterdata_manage.service.material.IMdMeMaterialbaseService; @@ -17,11 +21,13 @@ import org.nl.wms.masterdata_manage.storage.service.storage.dao.StIvtStructattr; import org.nl.wms.storage_manage.productmanage.service.structIvt.IStIvtStructivtCpService; import org.nl.wms.storage_manage.productmanage.service.structIvt.dao.StIvtStructivtCp; import org.nl.wms.storage_manage.productmanage.service.structIvt.dao.mapper.StIvtStructivtCpMapper; +import org.nl.wms.storage_manage.productmanage.service.structIvt.dto.CpIvtQuery; import org.nl.wms.storage_manage.productmanage.util.ChangeIvtUtil; import org.nl.wms.storage_manage.rawmanage.service.structIvt.dto.StructIvtYLQuery; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.bind.annotation.RequestBody; import java.math.BigDecimal; import java.util.ArrayList; @@ -48,6 +54,15 @@ public class StIvtStructivtCpServiceImpl extends ServiceImpl page = PageHelper.startPage(pageQuery.getPage() + 1, pageQuery.getSize()); + TableDataInfo build = TableDataInfo.build(this.baseMapper.packageQuery(query)); + build.setTotalElements(page.getTotal()); + + return build; + } + @Override @Transactional(rollbackFor = Exception.class) public void UpdateIvt(JSONObject json) { diff --git a/mes/qd/src/views/wms/storage_manage/product/productIvt/index.vue b/mes/qd/src/views/wms/storage_manage/product/productIvt/index.vue new file mode 100644 index 00000000..298a9b4a --- /dev/null +++ b/mes/qd/src/views/wms/storage_manage/product/productIvt/index.vue @@ -0,0 +1,150 @@ + + + + diff --git a/mes/qd/src/views/wms/storage_manage/product/productIvt/productivt.js b/mes/qd/src/views/wms/storage_manage/product/productIvt/productivt.js new file mode 100644 index 00000000..bd560a4d --- /dev/null +++ b/mes/qd/src/views/wms/storage_manage/product/productIvt/productivt.js @@ -0,0 +1,31 @@ +import request from '@/utils/request' + +export function add(data) { + return request({ + url: '/api/stIvtStructivtCp', + method: 'post', + data + }) +} + +export function del(ids) { + return request({ + url: '/api/stIvtStructivtCp/delete', + method: 'post', + data: ids + }) +} + +export function edit(data) { + return request({ + url: '/api/stIvtStructivtCp/update', + method: 'post', + data + }) +} + +export default { + add, + edit, + del +} From 4fed94c420c8f6ecf6ba431c8a96bb70aae5bbb6 Mon Sep 17 00:00:00 2001 From: jiaoliming Date: Tue, 6 Jun 2023 17:24:29 +0800 Subject: [PATCH 03/19] fix: --- .../org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java index 42e51f16..cbcbf7b8 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java @@ -711,6 +711,9 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { if (code.equals("to_start_checking")) { hailiangAutoCacheLineDeviceDriver.writing("to_task", "1001"); } + if (code.equals("to_check_finish")){ + hailiangAutoCacheLineDeviceDriver.writing("to_task", "0"); + } } } JSONObject resultJson = new JSONObject(); From ee2b98ff01d635b99bd2332169bbdd768e2505c4 Mon Sep 17 00:00:00 2001 From: jiaoliming Date: Tue, 6 Jun 2023 17:27:03 +0800 Subject: [PATCH 04/19] Revert "fix:" This reverts commit 4fed94c420c8f6ecf6ba431c8a96bb70aae5bbb6. --- .../org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java index cbcbf7b8..42e51f16 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java @@ -711,9 +711,6 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { if (code.equals("to_start_checking")) { hailiangAutoCacheLineDeviceDriver.writing("to_task", "1001"); } - if (code.equals("to_check_finish")){ - hailiangAutoCacheLineDeviceDriver.writing("to_task", "0"); - } } } JSONObject resultJson = new JSONObject(); From ce9e6e80a88b5b13e93c20930dbbbad4ee7c374f Mon Sep 17 00:00:00 2001 From: gengby <858962040@qq.com> Date: Tue, 6 Jun 2023 17:31:00 +0800 Subject: [PATCH 05/19] =?UTF-8?q?rev=20=E7=BC=93=E5=AD=98=E7=BA=BF?= =?UTF-8?q?=E5=8F=8D=E9=A6=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../HailiangAutoCacheLineDeviceDriver.java | 16 ++++++++-------- .../wms/service/impl/AcsToWmsServiceImpl.java | 8 ++++---- .../wms/service/impl/WmsToAcsServiceImpl.java | 2 +- .../instruction/service/InstructionService.java | 2 +- .../service/impl/InstructionServiceImpl.java | 12 ++++++------ .../nl/modules/quartz/task/AutoCreateInst.java | 6 +++--- 6 files changed, 23 insertions(+), 23 deletions(-) diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/hailiang_one/hailiang_auto_cache_line/HailiangAutoCacheLineDeviceDriver.java b/wcs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/hailiang_one/hailiang_auto_cache_line/HailiangAutoCacheLineDeviceDriver.java index 0bbb62ac..9131d938 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/hailiang_one/hailiang_auto_cache_line/HailiangAutoCacheLineDeviceDriver.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/hailiang_one/hailiang_auto_cache_line/HailiangAutoCacheLineDeviceDriver.java @@ -477,7 +477,7 @@ public class HailiangAutoCacheLineDeviceDriver extends AbstractOpcDeviceDriver i } else if (agvphase == 0x0C || agvphase == 0x23) { //agv送满框1完毕或送满框2完毕 //需要判断缓存线工作模式联机,对接位有货,任务号不为0,对接位条码正常才反馈agv以及电气放货完成 - if (mode == 1 && in_finish == 1 && task != 0 && docking_barcode != 0 && error != 35 && ObjectUtil.isNotEmpty(inst) && Integer.parseInt(inst.getInstruction_code()) == task) { + if (mode == 1 && task != 0 && docking_barcode != 0 && error != 34 && ObjectUtil.isNotEmpty(inst) && Integer.parseInt(inst.getInstruction_code()) == task) { if (inst != null) { TaskDto taskDto = taskserver.findByCodeFromCache(inst.getTask_code()); if (taskDto != null) { @@ -504,9 +504,9 @@ public class HailiangAutoCacheLineDeviceDriver extends AbstractOpcDeviceDriver i if (prepare_ready != 1) { noFeedMessage += "准备位未就绪,"; } - if (in_ready != 1) { - noFeedMessage += "对接位入箱未就绪,"; - } +// if (in_ready != 1) { +// noFeedMessage += "对接位入箱未就绪,"; +// } if (error == 35) { noFeedMessage += "准备位条码异常,"; } @@ -672,7 +672,7 @@ public class HailiangAutoCacheLineDeviceDriver extends AbstractOpcDeviceDriver i } } else if (agvphase == 0x15 || agvphase == 0x19) { //缓存线出满框送回空框完毕 - if (mode == 1 && in_finish == 1 && ObjectUtil.isNotEmpty(inst)) { + if (mode == 1 && docking_barcode > 0 && error != 34 && ObjectUtil.isNotEmpty(inst)) { this.writing("to_agv_put_finish", "1"); inst.setExecute_status(InstActionEnum.EXECUTE_PUT_EMPTY_FINISH.getCode()); instructionService.update(inst); @@ -687,9 +687,9 @@ public class HailiangAutoCacheLineDeviceDriver extends AbstractOpcDeviceDriver i this.set(0, 0, null); } else { String noFeedMessage = this.noFeedMessage(); - if (in_finish != 1) { - noFeedMessage += "电气未上报对接位入箱完成,"; - } +// if (in_finish != 1) { +// noFeedMessage += "电气未上报对接位入箱完成,"; +// } this.noFeedAgvMessage = this.replace(noFeedMessage); } } diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToWmsServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToWmsServiceImpl.java index 8662c999..1baa27bc 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToWmsServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToWmsServiceImpl.java @@ -36,10 +36,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { @Override public HttpResponse applyTaskToWms(JSONObject param) { - log.info("acs开始向mes请求任务,请求参数:{}", JSON.toJSONString(param)); try { MDC.put(log_file_type, log_type); if (StrUtil.equals(paramService.findByCode(AcsConfig.HASWMS).getValue(), "1")) { + log.info("acs开始向mes请求任务,请求参数:{}", JSON.toJSONString(param)); String wmsurl = paramService.findByCode(AcsConfig.WMSURL).getValue(); AddressDto addressDto = addressService.findByCode("applyTaskToWms"); String url = wmsurl + addressDto.getMethods_url(); @@ -203,10 +203,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { @Override public HttpResponse applyScannerTask(JSONObject map) { - log.info("acs开始向mes申请扫码器任务,请求参数:{}", JSON.toJSONString(map)); try { MDC.put(log_file_type, log_type); if (StrUtil.equals(paramService.findByCode(AcsConfig.HASWMS).getValue(), "1")) { + log.info("acs开始向mes申请扫码器任务,请求参数:{}", JSON.toJSONString(map)); String wmsUrl = paramService.findByCode(AcsConfig.WMSURL).getValue(); AddressDto addressDto = addressService.findByCode("applyScannerTask"); String methods_url = addressDto.getMethods_url(); @@ -230,10 +230,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { @Override public HttpResponse feedCacheLineBarcodes(JSONObject map) { - log.info("acs开始向mes反馈缓存线条码,请求参数:{}", JSON.toJSONString(map)); try { MDC.put(log_file_type, log_type); if (StrUtil.equals(paramService.findByCode(AcsConfig.HASWMS).getValue(), "1")) { + log.info("acs开始向mes反馈缓存线条码,请求参数:{}", JSON.toJSONString(map)); String wmsUrl = paramService.findByCode(AcsConfig.WMSURL).getValue(); AddressDto addressDto = addressService.findByCode("feedCacheLineBarcodes"); String methods_url = addressDto.getMethods_url(); @@ -257,10 +257,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { @Override public HttpResponse feedCacheLineTask(JSONObject param) { - log.info("acs开始向mes反馈缓存线任务号,请求参数:{}", JSON.toJSONString(param)); try { MDC.put(log_file_type, log_type); if (StrUtil.equals(paramService.findByCode(AcsConfig.HASWMS).getValue(), "1")) { + log.info("acs开始向mes反馈缓存线任务号,请求参数:{}", JSON.toJSONString(param)); String wmsUrl = paramService.findByCode(AcsConfig.WMSURL).getValue(); AddressDto addressDto = addressService.findByCode("feedCacheLineTask"); String methods_url = addressDto.getMethods_url(); diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java index 42e51f16..aa11aa2f 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java @@ -710,7 +710,7 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { hailiangAutoCacheLineDeviceDriver.writing(code, value); if (code.equals("to_start_checking")) { hailiangAutoCacheLineDeviceDriver.writing("to_task", "1001"); - } + } } } JSONObject resultJson = new JSONObject(); diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/InstructionService.java b/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/InstructionService.java index 8f481493..b0622e69 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/InstructionService.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/InstructionService.java @@ -349,5 +349,5 @@ public interface InstructionService { */ void removeCacheLinePhase(Instruction dto); - Instruction findInstByPutDeviceCode(String put_device_code); + Instruction findInstByDeviceCode(String device_code); } diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java index e06f704c..933917e0 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java @@ -1333,8 +1333,8 @@ public class InstructionServiceImpl implements InstructionService, ApplicationAu if (putDevice != null) { if (startDevice.getDeviceDriver() instanceof HailiangAutoCacheLineDeviceDriver) { hailiangAutoCacheLineDeviceDriver = (HailiangAutoCacheLineDeviceDriver) startDevice.getDeviceDriver(); - if (hailiangAutoCacheLineDeviceDriver.getItemProtocol().getOpcIntegerValue("task") != 0) { - throw new BadRequestException("缓存线已存在任务,稍后下发!"); + if (hailiangAutoCacheLineDeviceDriver.getItemProtocol().getOpcIntegerValue("task") != 0 || !hailiangAutoCacheLineDeviceDriver.getIsonline()) { + throw new BadRequestException("缓存线已存在任务或设备不在线,稍后下发!"); } else if (hailiangAutoCacheLineDeviceDriver.getItemProtocol().getOpcIntegerValue("task") == 0) { //下发电气单出 to_task_type = "4"; @@ -1348,8 +1348,8 @@ public class InstructionServiceImpl implements InstructionService, ApplicationAu } if (putDevice.getDeviceDriver() instanceof HailiangAutoCacheLineDeviceDriver) { hailiangAutoCacheLineDeviceDriver = (HailiangAutoCacheLineDeviceDriver) putDevice.getDeviceDriver(); - if (hailiangAutoCacheLineDeviceDriver.getItemProtocol().getOpcIntegerValue("task") != 0) { - throw new BadRequestException("缓存线已存在任务,稍后下发!"); + if (hailiangAutoCacheLineDeviceDriver.getItemProtocol().getOpcIntegerValue("task") != 0 || !hailiangAutoCacheLineDeviceDriver.getIsonline()) { + throw new BadRequestException("缓存线已存在任务或设备不在线,稍后下发!"); } else if (tasksByLinNum.size() == 1 && hailiangAutoCacheLineDeviceDriver.getItemProtocol().getOpcIntegerValue("task") == 0) { //下发电气单入 to_task_type = "2"; @@ -1450,12 +1450,12 @@ public class InstructionServiceImpl implements InstructionService, ApplicationAu } @Override - public Instruction findInstByPutDeviceCode(String put_device_code) { + public Instruction findInstByDeviceCode(String device_code) { return Optional .ofNullable(this.instructions) .orElse(new CopyOnWriteArrayList<>()) .stream() - .filter(i -> i.getPut_device_code().equals(put_device_code)) + .filter(i -> i.getPut_device_code().equals(device_code) || i.getStart_device_code().equals(device_code) || i.getNext_device_code().equals(device_code)) .findFirst() .orElse(null); } diff --git a/wcs/nladmin-system/src/main/java/org/nl/modules/quartz/task/AutoCreateInst.java b/wcs/nladmin-system/src/main/java/org/nl/modules/quartz/task/AutoCreateInst.java index 4548932b..c362fb3d 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/modules/quartz/task/AutoCreateInst.java +++ b/wcs/nladmin-system/src/main/java/org/nl/modules/quartz/task/AutoCreateInst.java @@ -94,7 +94,7 @@ public class AutoCreateInst { Device device = deviceAppService.findDeviceByCode(put_device_code); if (device != null && device.getDeviceDriver() instanceof HailiangAutoCacheLineDeviceDriver) { hailiangAutoCacheLineDeviceDriver = (HailiangAutoCacheLineDeviceDriver) device.getDeviceDriver(); - if (hailiangAutoCacheLineDeviceDriver.getTask() != 0) { + if (hailiangAutoCacheLineDeviceDriver.getTask() != 0 || instructionService.findInstByDeviceCode(put_device_code) != null) { continue; } } @@ -105,7 +105,7 @@ public class AutoCreateInst { Device device = deviceAppService.findDeviceByCode(start_device_code); if (device != null && device.getDeviceDriver() instanceof HailiangAutoCacheLineDeviceDriver) { hailiangAutoCacheLineDeviceDriver = (HailiangAutoCacheLineDeviceDriver) device.getDeviceDriver(); - if (hailiangAutoCacheLineDeviceDriver.getTask() != 0) { + if (hailiangAutoCacheLineDeviceDriver.getTask() != 0 || instructionService.findInstByDeviceCode(start_device_code) != null) { continue; } } @@ -143,7 +143,7 @@ public class AutoCreateInst { Device device = deviceAppService.findDeviceByCode(taskDto1.getPut_device_code()); if (device != null && device.getDeviceDriver() instanceof HailiangAutoCacheLineDeviceDriver) { hailiangAutoCacheLineDeviceDriver = (HailiangAutoCacheLineDeviceDriver) device.getDeviceDriver(); - if (hailiangAutoCacheLineDeviceDriver.getTask() != 0) { + if (hailiangAutoCacheLineDeviceDriver.getTask() != 0 || instructionService.findInstByDeviceCode(taskDto1.getPut_device_code()) != null) { continue; } } From 1d52b58d6a4231e3b90180e6934657113fcd4e25 Mon Sep 17 00:00:00 2001 From: jiaoliming Date: Tue, 6 Jun 2023 17:38:15 +0800 Subject: [PATCH 06/19] =?UTF-8?q?=20fix=EF=BC=9A=E7=9B=98=E7=82=B9?= =?UTF-8?q?=E5=AE=8C=E6=88=90=E6=B8=85=E9=99=A4=E4=BB=BB=E5=8A=A1=E5=8F=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: jiaoliming --- .../org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java index aa11aa2f..cbcbf7b8 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java @@ -710,7 +710,10 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { hailiangAutoCacheLineDeviceDriver.writing(code, value); if (code.equals("to_start_checking")) { hailiangAutoCacheLineDeviceDriver.writing("to_task", "1001"); - } + } + if (code.equals("to_check_finish")){ + hailiangAutoCacheLineDeviceDriver.writing("to_task", "0"); + } } } JSONObject resultJson = new JSONObject(); From 29012daacdf7c545f282e1adcd360d9d23e17c2d Mon Sep 17 00:00:00 2001 From: zhangzhiqiang Date: Tue, 6 Jun 2023 19:33:09 +0800 Subject: [PATCH 07/19] =?UTF-8?q?add:=E6=B7=BB=E5=8A=A0=E6=B7=B1=E5=9D=91?= =?UTF-8?q?=E8=AE=BE=E5=A4=87=E7=89=A9=E6=96=99=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/nl/common/domain/query/PageQuery.java | 11 ++--- .../java/org/nl/common/enums/AcsTaskEnum.java | 2 + .../org/nl/config/mybatis/CodeGenerator.java | 4 +- .../PdmBiPersoncorrdeviceController.java | 21 ++++++++++ .../IPdmBiPersoncorrdeviceService.java | 16 ++++++++ .../userdevice/dao/PdmBiPersoncorrdevice.java | 34 +++++++++++++++ .../mapper/PdmBiPersoncorrdeviceMapper.java | 16 ++++++++ .../xml/PdmBiPersoncorrdeviceMapper.xml | 5 +++ .../PdmBiPersoncorrdeviceServiceImpl.java | 20 +++++++++ .../device/SpecialDeviceController.java | 30 ++++++-------- .../ProduceshiftorderController.java | 8 ++++ .../IPdmProduceWorkorderService.java | 3 +- .../impl/IPdmProduceWorkorderServiceImpl.java | 41 ++++++++----------- .../resources/config/application-dev3.yml | 5 ++- .../product_manage/workorder/UploadDialog.vue | 2 +- .../wms/scheduler_manage/scheduler/index.vue | 2 +- 16 files changed, 164 insertions(+), 56 deletions(-) create mode 100644 mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/controller/userdevice/PdmBiPersoncorrdeviceController.java create mode 100644 mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/IPdmBiPersoncorrdeviceService.java create mode 100644 mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/PdmBiPersoncorrdevice.java create mode 100644 mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/PdmBiPersoncorrdeviceMapper.java create mode 100644 mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/xml/PdmBiPersoncorrdeviceMapper.xml create mode 100644 mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/impl/PdmBiPersoncorrdeviceServiceImpl.java diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/PageQuery.java b/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/PageQuery.java index 61e88cc9..cf0af3b1 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/PageQuery.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/PageQuery.java @@ -45,15 +45,15 @@ public class PageQuery implements Serializable { /** * 当前记录起始索引 默认值 */ - public static final int DEFAULT_PAGE_NUM = 1; + public static final int DEFAULT_PAGE_NUM = 0; /** * 每页显示记录数 默认值 默认查全部 */ - public static final int DEFAULT_PAGE_SIZE = Integer.MAX_VALUE; + public static final int DEFAULT_PAGE_SIZE = 10; public Page build() { - Integer pageNum = ObjectUtil.defaultIfNull(getPage(), DEFAULT_PAGE_NUM) + 1; + Integer pageNum = ObjectUtil.defaultIfNull(getPage(), DEFAULT_PAGE_NUM); Integer pageSize = ObjectUtil.defaultIfNull(getSize(), DEFAULT_PAGE_SIZE); if (pageNum <= 0) { pageNum = DEFAULT_PAGE_NUM; @@ -75,10 +75,7 @@ public class PageQuery implements Serializable { public Page build(Class r) { Integer pageNum = ObjectUtil.defaultIfNull(getPage(), DEFAULT_PAGE_NUM); Integer pageSize = ObjectUtil.defaultIfNull(getSize(), DEFAULT_PAGE_SIZE); - if (pageNum <= 0) { - pageNum = DEFAULT_PAGE_NUM; - } - Page page = new Page<>(pageNum, pageSize); + Page page = new Page<>(pageNum+1, pageSize); if (StringUtils.isNotBlank(sort)){ String[] split = sort.split(","); for (int i = 0; i < (split.length & ~1); i=i+2) { diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java b/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java index f575be13..c8a3f919 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java @@ -58,7 +58,9 @@ public enum AcsTaskEnum { ACS_TASK_TYPE_NOBLE_SINGLE_TASK("2","诺宝单工任务"), ACS_TASK_TYPE_NOBLE_SINGLE_ENTRY_TASK("3","诺宝单入-单任务"), ACS_TASK_TYPE_NOBLE_DOUBLE_ENTRY_TASK("4","诺宝双入-双任务"), + ACS_TASK_TYPE_NOBLE_POINT_POINT_TASK("5","诺宝点对点任务"), + ACS_TASK_TYPE_WEIGHING_TASK_OF_PS20("6","PS20称重任务(刻字-包装)"), ACS_TASK_TYPE_NON_WEIGHING_TASK_OF_PS20("7","PS20不称重任务(刻字-包装)"), diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/config/mybatis/CodeGenerator.java b/mes/hd/nladmin-system/src/main/java/org/nl/config/mybatis/CodeGenerator.java index 960f43a4..91d8e99a 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/config/mybatis/CodeGenerator.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/config/mybatis/CodeGenerator.java @@ -57,10 +57,10 @@ public class CodeGenerator { mpg.setGlobalConfig(gc); // 数据源配置 DataSourceConfig dsc = new DataSourceConfig(); - dsc.setUrl("jdbc:mysql://192.168.81.252:3306/hl_one_mes_xc?serverTimezone=GMT&setUnicode=true&characterEncoding=utf8"); + dsc.setUrl("jdbc:mysql://192.168.46.5:3306/hl_one_mes_test?serverTimezone=GMT&setUnicode=true&characterEncoding=utf8"); dsc.setDriverName("com.mysql.cj.jdbc.Driver"); dsc.setUsername("root"); - dsc.setPassword("Root.123456"); + dsc.setPassword("123456"); mpg.setDataSource(dsc); // 包配置 PackageConfig pc = new PackageConfig(); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/controller/userdevice/PdmBiPersoncorrdeviceController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/controller/userdevice/PdmBiPersoncorrdeviceController.java new file mode 100644 index 00000000..f0853c09 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/controller/userdevice/PdmBiPersoncorrdeviceController.java @@ -0,0 +1,21 @@ +package org.nl.wms.device_manage.controller.userdevice; + + +import org.springframework.web.bind.annotation.RequestMapping; + +import org.springframework.web.bind.annotation.RestController; + +/** + *

+ * 人员设备关系表 前端控制器 + *

+ * + * @author generator + * @since 2023-06-06 + */ +@RestController +@RequestMapping("/pdmBiPersoncorrdevice") +public class PdmBiPersoncorrdeviceController { + +} + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/IPdmBiPersoncorrdeviceService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/IPdmBiPersoncorrdeviceService.java new file mode 100644 index 00000000..559e3fd2 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/IPdmBiPersoncorrdeviceService.java @@ -0,0 +1,16 @@ +package org.nl.wms.device_manage.service.userdevice; + +import org.nl.wms.device_manage.service.userdevice.dao.PdmBiPersoncorrdevice; +import com.baomidou.mybatisplus.extension.service.IService; + +/** + *

+ * 人员设备关系表 服务类 + *

+ * + * @author generator + * @since 2023-06-06 + */ +public interface IPdmBiPersoncorrdeviceService extends IService { + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/PdmBiPersoncorrdevice.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/PdmBiPersoncorrdevice.java new file mode 100644 index 00000000..077276b5 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/PdmBiPersoncorrdevice.java @@ -0,0 +1,34 @@ +package org.nl.wms.device_manage.service.userdevice.dao; + +import com.baomidou.mybatisplus.annotation.TableName; +import java.io.Serializable; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *

+ * 人员设备关系表 + *

+ * + * @author generator + * @since 2023-06-06 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("pdm_bi_personcorrdevice") +public class PdmBiPersoncorrdevice implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 用户id + */ + private String user_id; + + /** + * 设备标识 + */ + private String device_code; + + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/PdmBiPersoncorrdeviceMapper.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/PdmBiPersoncorrdeviceMapper.java new file mode 100644 index 00000000..ce8c5c96 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/PdmBiPersoncorrdeviceMapper.java @@ -0,0 +1,16 @@ +package org.nl.wms.device_manage.service.userdevice.dao.mapper; + +import org.nl.wms.device_manage.service.userdevice.dao.PdmBiPersoncorrdevice; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; + +/** + *

+ * 人员设备关系表 Mapper 接口 + *

+ * + * @author generator + * @since 2023-06-06 + */ +public interface PdmBiPersoncorrdeviceMapper extends BaseMapper { + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/xml/PdmBiPersoncorrdeviceMapper.xml b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/xml/PdmBiPersoncorrdeviceMapper.xml new file mode 100644 index 00000000..f0e0fc83 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/dao/mapper/xml/PdmBiPersoncorrdeviceMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/impl/PdmBiPersoncorrdeviceServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/impl/PdmBiPersoncorrdeviceServiceImpl.java new file mode 100644 index 00000000..bc9ebd44 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/service/userdevice/impl/PdmBiPersoncorrdeviceServiceImpl.java @@ -0,0 +1,20 @@ +package org.nl.wms.device_manage.service.userdevice.impl; + +import org.nl.wms.device_manage.service.userdevice.dao.PdmBiPersoncorrdevice; +import org.nl.wms.device_manage.service.userdevice.dao.mapper.PdmBiPersoncorrdeviceMapper; +import org.nl.wms.device_manage.service.userdevice.IPdmBiPersoncorrdeviceService; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.springframework.stereotype.Service; + +/** + *

+ * 人员设备关系表 服务实现类 + *

+ * + * @author generator + * @since 2023-06-06 + */ +@Service +public class PdmBiPersoncorrdeviceServiceImpl extends ServiceImpl implements IPdmBiPersoncorrdeviceService { + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java index cb21270e..18519171 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java @@ -23,6 +23,7 @@ import org.nl.wms.product_manage.备份pdm.service.DeviceService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; +import org.springframework.util.CollectionUtils; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; @@ -43,26 +44,21 @@ public class SpecialDeviceController { @Autowired private IPdmBiDeviceService iDeviceService; - @PostMapping("/query") + @GetMapping("/query") @ApiOperation("查询生产设备") @SaIgnore - public ResponseEntity query(@RequestBody DeviceQuery query) { - List list = iDeviceService.list(query.build()); - Set materials = list.stream().map(PdmBiDevice::getMaterial_id).collect(Collectors.toSet()); - Map materialMap = materialbaseService.list(new QueryWrapper().in("material_id", materials)).stream().collect(HashMap::new, (k, v) -> k.put(v.getMaterial_id(), v), HashMap::putAll); - List result = new ArrayList<>(); - for (PdmBiDevice pdmBiDevice : list) { - Map map = new HashMap<>(); - map.put("device_code",pdmBiDevice.getDevice_code()); - map.put("product_area",pdmBiDevice.getProduct_area()); - map.put("material_id",pdmBiDevice.getMaterial_id()); - MdMeMaterialbase materialbase = materialMap.get("pdmBiDevice.getMaterial_id()"); - map.put("material_name",materialbase!=null?materialbase.getMaterial_name():""); - map.put("material_spec",materialbase!=null?materialbase.getMaterial_spec():""); - map.put("deviceinstor_qty",pdmBiDevice.getDeviceinstor_qty()); - result.add(map); + public ResponseEntity query(DeviceQuery query,PageQuery page) { + Page> list = iDeviceService.pageMaps(page.build(PdmBiDevice.class), query.build()); + if (!CollectionUtils.isEmpty(list.getRecords())){ + Set materials = list.getRecords().stream().map(a->a.get("material_id")).collect(Collectors.toSet()); + Map materialMap = materialbaseService.list(new QueryWrapper().in("material_id", materials)).stream().collect(HashMap::new, (k, v) -> k.put(v.getMaterial_id(), v), HashMap::putAll); + for (Map pdmBiDevice : list.getRecords()) { + MdMeMaterialbase materialbase = materialMap.get(pdmBiDevice.get("material_id")); + pdmBiDevice.put("material_name",materialbase!=null?materialbase.getMaterial_name():""); + pdmBiDevice.put("material_spec",materialbase!=null?materialbase.getMaterial_spec():""); + } } - return new ResponseEntity<>(TableDataInfo.build(result), HttpStatus.OK); + return new ResponseEntity<>(TableDataInfo.build(list), HttpStatus.OK); } @PostMapping("/update") diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/ProduceshiftorderController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/ProduceshiftorderController.java index 39a97d37..1be3d857 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/ProduceshiftorderController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/ProduceshiftorderController.java @@ -108,6 +108,14 @@ public class ProduceshiftorderController{ public ResponseEntity saveReport(@RequestBody JSONObject param) { return new ResponseEntity<>(iPdmProduceWorkorderService.report(param), HttpStatus.OK); } + @PostMapping("/unqualReport") + @Log("工单不合格报工") + @ApiOperation("工单不合格报工") + public ResponseEntity unqualReport(@RequestBody JSONObject param) { + iPdmProduceWorkorderService.unqualReport(param); + return new ResponseEntity<>(HttpStatus.OK); + } + @PostMapping("/finish") @Log("看板强制完成") diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/IPdmProduceWorkorderService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/IPdmProduceWorkorderService.java index f64326d4..d3f3f26d 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/IPdmProduceWorkorderService.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/IPdmProduceWorkorderService.java @@ -108,12 +108,13 @@ public interface IPdmProduceWorkorderService extends IService().eq("workorder_id", param.getString("workorder_id"))); // if (workorder.getWorkorder_status().equals(WorkerOrderEnum.COMPLETE.getCode()) || workorder.getWorkorder_status().equals(WorkerOrderEnum.FORCE_COMPLETE.getCode())) { // throw new BadRequestException(param.getString("workorder_id") + "当前工单已经完工不允许报工"); // } + Assert.notNull(workorder,"当前工单不存在"); PdmProduceWorkorderrecord one = reportRecordService.getOne(new QueryWrapper() .eq("workorder_id", param.getString("workorder_id")).eq("report_status", ReportEnum.REPORT_STATUS.code("生成"))); - if (one == null) { - throw new BadRequestException(param.getString("workorder_id") + "当前工单没有生成状态的报工记录"); - } + Assert.notNull(one,param.getString("workorder_id") + "当前工单没有生成状态的报工记录"); workorder.setReport_qty(workorder.getReport_qty().add(param.getBigDecimal("report_qty"))); - workorder.setNok_qty(workorder.getReport_qty().add(param.getBigDecimal("nok_qty"))); - workorder.setRepare_qty(workorder.getReport_qty().add(param.getBigDecimal("repare_qty"))); if (workorder.getPlan_qty().doubleValue() <= workorder.getReport_qty().doubleValue()) { workorder.setWorkorder_status(WorkerOrderEnum.COMPLETE.getCode()); } @@ -609,14 +606,22 @@ public class IPdmProduceWorkorderServiceImpl extends ServiceImpl() .set("report_qty", param.getBigDecimal("report_qty")) - .set("nok_qty", param.getBigDecimal("nok_qty")) - .set("repare_qty", param.getBigDecimal("repare_qty")) .set("report_status", ReportEnum.REPORT_STATUS.code("报工")) .set("needproduct_qty", Math.max(0,workorder.getPlan_qty().intValue() - workorder.getReport_qty().intValue())) .eq("macoperate_id", one.getMacoperate_id())); return one.getMacoperate_id(); } + @Override + public void unqualReport(JSONObject param) { + Assert.notNull(new Object[]{param, param.get("report_qty"),param.getString("workorder_id")}, "请求参数不能为空"); + PdmProduceWorkorder workorder = this.getOne(new QueryWrapper().eq("workorder_id", param.getString("workorder_id"))); + Assert.notNull(workorder,"当前工单不存在"); + workorder.setRepare_qty(param.getBigDecimal("nok_qty")); + workorder.setRepare_qty(param.getBigDecimal("repare_qty")); + workorder.setReal_qty(null); + this.updateById(workorder); + } @Override @Transactional @@ -647,23 +652,9 @@ public class IPdmProduceWorkorderServiceImpl extends ServiceImpl packageWorkorderQty(List record, List itemRecord) { List ids = itemRecord.stream().map(PdmProduceWorkorderrecord::getMacoperate_id).collect(Collectors.toList()); List oldRecord = record.stream().filter(item -> ids.contains(item.getMacoperate_id())).collect(Collectors.toList()); - long old_nok_qty = oldRecord.stream().mapToLong(a->a.getNok_qty().longValue()).sum(); - long new_nok_qty = itemRecord.stream().mapToLong(a->a.getNok_qty().longValue()).sum(); - long old_repare_qty = oldRecord.stream().mapToLong(a->a.getRepare_qty().longValue()).sum(); - long new_repare_qty = itemRecord.stream().mapToLong(a->a.getRepare_qty().longValue()).sum(); long old_report_qty = oldRecord.stream().mapToLong(a->a.getReport_qty().longValue()).sum(); long new_report_qty = itemRecord.stream().mapToLong(a->a.getReport_qty().longValue()).sum(); - List list = new ArrayList<>(); - Map nok_qty = new HashMap<>(); - nok_qty.put("field", "nok_qty"); - nok_qty.put("value", Math.abs(new_nok_qty - old_nok_qty)); - nok_qty.put("add", new_nok_qty > old_nok_qty); - list.add(nok_qty); - Map repare_qty = new HashMap<>(); - repare_qty.put("field", "repare_qty"); - repare_qty.put("value", Math.abs(new_repare_qty - old_repare_qty)); - repare_qty.put("add", new_repare_qty > old_repare_qty); - list.add(repare_qty); + List list = new ArrayList<>(); Map report_qty = new HashMap<>(); report_qty.put("field", "report_qty"); report_qty.put("value", Math.abs(new_report_qty - old_report_qty)); diff --git a/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml b/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml index 4a195bc6..934d0dbd 100644 --- a/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml +++ b/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml @@ -23,10 +23,11 @@ spring: db-type: com.alibaba.druid.pool.DruidDataSource driverClassName: net.sf.log4jdbc.sql.jdbcapi.DriverSpy # url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_mes_test}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false - url: jdbc:log4jdbc:mysql://${DB_HOST:localhost}:${DB_PORT:3306}/${DB_NAME:hl_one_mes}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false + url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_mes_test}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false + # url: jdbc:log4jdbc:mysql://${DB_HOST:localhost}:${DB_PORT:3306}/${DB_NAME:hl_one_mes}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false username: ${DB_USER:root} # password: ${DB_PWD:123456} - password: ${DB_PWD:942464Yy} + password: ${DB_PWD:123456} # 初始连接数 initial-size: 5 diff --git a/mes/qd/src/views/wms/product_manage/workorder/UploadDialog.vue b/mes/qd/src/views/wms/product_manage/workorder/UploadDialog.vue index da5672f9..d7526503 100644 --- a/mes/qd/src/views/wms/product_manage/workorder/UploadDialog.vue +++ b/mes/qd/src/views/wms/product_manage/workorder/UploadDialog.vue @@ -38,7 +38,7 @@ + + diff --git a/mes/qd/src/views/wms/device_manage/userDeviceReplate/index.vue b/mes/qd/src/views/wms/device_manage/userDeviceReplate/index.vue new file mode 100644 index 00000000..f31200cf --- /dev/null +++ b/mes/qd/src/views/wms/device_manage/userDeviceReplate/index.vue @@ -0,0 +1,293 @@ + + + + + + + diff --git a/mes/qd/src/views/wms/device_manage/userDeviceReplate/role.js b/mes/qd/src/views/wms/device_manage/userDeviceReplate/role.js new file mode 100644 index 00000000..6932c75d --- /dev/null +++ b/mes/qd/src/views/wms/device_manage/userDeviceReplate/role.js @@ -0,0 +1,57 @@ +import request from '@/utils/request' + +// 获取所有的Role +export function getAll() { + return request({ + url: 'api/sysRole/all', + method: 'get' + }) +} + +export function add(data) { + return request({ + url: 'api/sysRole', + method: 'post', + data + }) +} + +export function get(id) { + return request({ + url: 'api/sysRole/' + id, + method: 'get' + }) +} + +export function getLevel() { + return request({ + url: 'api/sysRole/level', + method: 'get' + }) +} + +export function del(ids) { + return request({ + url: 'api/sysRole', + method: 'delete', + data: ids + }) +} + +export function edit(data) { + return request({ + url: 'api/sysRole', + method: 'put', + data + }) +} + +export function editMenu(data) { + return request({ + url: 'api/sysRole/menu', + method: 'put', + data + }) +} + +export default { add, edit, del, get, editMenu, getLevel } From 4d446905daf83992c3199051f07ac16ecd42bfaf Mon Sep 17 00:00:00 2001 From: zhangzhiqiang Date: Wed, 7 Jun 2023 17:42:48 +0800 Subject: [PATCH 09/19] =?UTF-8?q?rev:=E6=B7=B1=E5=9D=91=E8=AE=BE=E5=A4=87?= =?UTF-8?q?=E9=A1=B5=E9=9D=A2=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue b/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue index d07a1cc2..23a3782b 100644 --- a/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue +++ b/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue @@ -66,7 +66,7 @@ + From 105e5d52e9333ae61f572a21ba7c9b6dae97d83c Mon Sep 17 00:00:00 2001 From: liuxy Date: Thu, 8 Jun 2023 09:56:15 +0800 Subject: [PATCH 10/19] =?UTF-8?q?rev=EF=BC=9A=E6=B7=B1=E5=9D=91=E8=AE=BE?= =?UTF-8?q?=E5=A4=87=E7=89=A9=E6=96=99=E9=A1=B5=E9=9D=A2=E6=8A=A5=E9=94=99?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue b/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue index d07a1cc2..f8eacf4d 100644 --- a/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue +++ b/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue @@ -66,7 +66,7 @@ + @@ -88,7 +88,7 @@ - diff --git a/mes/qd/src/views/wms/pcs/deliveryorder/index.vue b/mes/qd/src/views/wms/pcs/deliveryorder/index.vue deleted file mode 100644 index 8a254dae..00000000 --- a/mes/qd/src/views/wms/pcs/deliveryorder/index.vue +++ /dev/null @@ -1,283 +0,0 @@ - - - - - From b237b67f6b2db819541eadce9a4a84da6e7ff8d1 Mon Sep 17 00:00:00 2001 From: zhangzhiqiang Date: Thu, 8 Jun 2023 16:44:43 +0800 Subject: [PATCH 12/19] =?UTF-8?q?rev:=E6=B7=B1=E5=9D=91=E7=9B=B8=E5=85=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../acs/service/impl/AcsToWmsServiceImpl.java | 18 +- .../ext/acs/service/impl/AgvInstService.java | 12 +- .../device/SpecialDeviceController.java | 1 + .../sch/tasks/SpeMachinery/SpeEmpTask.java | 1 - .../sch/tasks/SpeMachinery/SpeFullTask.java | 1 - .../service/device/IPdmBiDeviceService.java | 3 +- .../service/device/dao/PdmBiDevice.java | 1 + .../device/dao/mapper/PdmBiDeviceMapper.java | 4 +- .../device/dao/mapper/PdmBiDeviceMapper.xml | 26 +- .../device/impl/PdmBiDeviceServiceImpl.java | 22 +- .../device_manage/deviceMaterial/index.vue | 12 +- .../views/wms/pcs/deliveryorder/Dialog.vue | 93 ++++++ .../src/views/wms/pcs/deliveryorder/index.vue | 283 ++++++++++++++++++ 13 files changed, 462 insertions(+), 15 deletions(-) create mode 100644 mes/qd/src/views/wms/pcs/deliveryorder/Dialog.vue create mode 100644 mes/qd/src/views/wms/pcs/deliveryorder/index.vue diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java index cf0e2142..7055b90f 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java @@ -28,6 +28,8 @@ import org.nl.wms.product_manage.sch.manage.AbstractAcsTask; import org.nl.wms.product_manage.sch.service.TaskService; import org.nl.wms.product_manage.sch.service.dto.TaskDto; import org.nl.wms.product_manage.sch.tasks.WashMachineryTask; +import org.nl.wms.product_manage.service.device.IPdmBiDeviceService; +import org.nl.wms.product_manage.service.device.dao.PdmBiDevice; import org.nl.wms.product_manage.service.workorder.IPdmProduceWorkorderService; import org.nl.wms.product_manage.service.workorder.dao.PdmProduceWorkorder; import org.nl.wms.storage_manage.CHANGE_BILL_TYPE_ENUM; @@ -60,6 +62,8 @@ public class AcsToWmsServiceImpl implements AcsToWmsService{ private CacheLineHandService cacheLineHandService; @Autowired private IPdmProduceWorkorderService workorderService; + @Autowired + private IPdmBiDeviceService deviceService; @@ -139,7 +143,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService{ if (taskHandler!=null){ taskHandler.updateTaskStatus(row,status); } - //发布一个任务执行事件 + //发布一个任务执行事件:服务跟任务不一样,可以同事存在 TaskEvent event = TaskEvent.builder() .task_id(task_id) .task_type(taskDto.getTask_type()) @@ -261,8 +265,16 @@ public class AcsToWmsServiceImpl implements AcsToWmsService{ while (iterator.hasNext()){ String deviceCode = (String)iterator.next(); if (!StringUtils.isEmpty(deviceCode)){ - String qty = String.valueOf(param.get(deviceCode)); - deviceTab.update(MapOf.of("deviceinstor_qty",qty),"device_code = '"+deviceCode+"'"); + Map item = (Map)param.get(deviceCode); + Object qty = item.get("qty"); + Object weight = item.get("weight"); + UpdateWrapper wrapper = new UpdateWrapper<>(); + wrapper.set("deviceinstor_qty",qty); + if (weight!=null){ + wrapper.set("deviceinstor_weight",weight); + } + wrapper.eq("device_code",deviceCode); + deviceService.update(wrapper); } } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AgvInstService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AgvInstService.java index 50b5c3cd..d67e8937 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AgvInstService.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AgvInstService.java @@ -27,6 +27,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; +import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; @@ -78,14 +79,17 @@ public class AgvInstService { Map query = MapOf.of("workprocedure_id", basePointService.getWorkprodureByCode(next.getId()).get("workprocedure_id") , "qty", quantity,"spec",workprodure.get("spec")); //判断缓存线是不是去深坑清洗:深坑区域15个点:判断空的物料坑位: + List> collect = new ArrayList<>(); if (next.getName().equals("深坑清洗")){ - query.put("material_id",task.getString("material_id")); -// query.put("qty",quantity) 深坑物料需要转重量 task.put("task_type",AcsTaskEnum.TASK_PRODUCT_WASH.getCode()); task.put("task_name",AcsTaskEnum.TASK_PRODUCT_WASH.getDesc()); - + query.put("material_id",task.getString("material_id")); +// query.put("qty",quantity) 深坑物料需要转重量 + collect = deviceService.workproceduceDevicesWeight(query); + }else { + collect = deviceService.workproceduceDevicesQty(query); } - List> collect = deviceService.workproceduceDevices(query); + log.info("调度任务分配点位信息:", JSON.toJSONString(collect)); List> list = collect.stream().filter(stringStringMap -> stringStringMap.get("tasks") == null || stringStringMap.get("materials").contains(task.getString("material_id"))).collect(Collectors.toList()); task.put("acs_task_type",AcsTaskEnum.ACS_TASK_TYPE_NOBLE_SINGLE_TASK.getCode()); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java index 18519171..159e64c8 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/device/SpecialDeviceController.java @@ -46,6 +46,7 @@ public class SpecialDeviceController { @GetMapping("/query") @ApiOperation("查询生产设备") + @Log("深坑物料") @SaIgnore public ResponseEntity query(DeviceQuery query,PageQuery page) { Page> list = iDeviceService.pageMaps(page.build(PdmBiDevice.class), query.build()); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeEmpTask.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeEmpTask.java index fccbbd3a..a429274c 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeEmpTask.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeEmpTask.java @@ -202,7 +202,6 @@ public class SpeEmpTask extends AbstractAcsTask { if (!("fall_finish"+task.getTask_id()).equals(device.getRemark())){ iDeviceService.update(new UpdateWrapper() .set("material_id", task.getMaterial_id()) - .set("deviceinstor_qty",device.getDeviceinstor_qty().add(task.getMaterial_qty())) .set("remark","fall_finish"+task.getTask_id()) .eq("device_code", task.getPoint_code2())); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeFullTask.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeFullTask.java index a55be15b..4d1925b6 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeFullTask.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/sch/tasks/SpeMachinery/SpeFullTask.java @@ -265,7 +265,6 @@ public class SpeFullTask extends AbstractAcsTask { if (!("fall_finish"+task.getTask_id()).equals(one.getRemark())){ deviceService.update(new UpdateWrapper() .set("material_id", task.getMaterial_id()) - .set("deviceinstor_qty",one.getDeviceinstor_qty().add(task.getMaterial_qty())) .set("remark","fall_finish"+task.getTask_id()) .eq("device_code", task.getPoint_code2())); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/IPdmBiDeviceService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/IPdmBiDeviceService.java index 9428e420..28a021ee 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/IPdmBiDeviceService.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/IPdmBiDeviceService.java @@ -25,7 +25,8 @@ public interface IPdmBiDeviceService extends IService { * @param param * @return */ - List workproceduceDevices(Map param); + List workproceduceDevicesQty(Map param); + List workproceduceDevicesWeight(Map param); /** * 根据点位查询对应设备 diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/PdmBiDevice.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/PdmBiDevice.java index 9e3e4f69..4744105d 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/PdmBiDevice.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/PdmBiDevice.java @@ -98,6 +98,7 @@ public class PdmBiDevice implements Serializable { * 设备实时来料仓数:用于数量校验 */ private BigDecimal deviceinstor_qty; + private BigDecimal deviceinstor_weight; /** * 设备实时产品仓数 diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.java index 115bc281..d860d200 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.java @@ -19,7 +19,9 @@ public interface PdmBiDeviceMapper extends BaseMapper { List getNotWorkDevice(Map query); - List workproceduceDevices(Map query); + List workproceduceDevicesQty(Map query); + + List workproceduceDevicesWeight(Map query); PdmBiDevice getDeviceByPoint(String pointCode); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.xml b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.xml index dda8af9f..72d62b99 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.xml +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/device/dao/mapper/PdmBiDeviceMapper.xml @@ -18,7 +18,7 @@ from PDM_produce_workOrder o where '5' > o.workorder_status and o.is_delete = '0' ) - select GROUP_CONCAT(sch_base_task.task_id) as tasks,GROUP_CONCAT(sch_base_task.material_id) as materials, pdm_bi_device.inupperlimit_qty - ifnull( sum( sch_base_task.material_qty ), 0 ) - pdm_bi_device.deviceinstor_qty AS currentQty, @@ -39,6 +39,30 @@ GROUP BY pdm_bi_device.device_code HAVING currentQty > #{qty} + + + select GROUP_CONCAT(sch_base_task.task_id) as tasks,GROUP_CONCAT(sch_base_task.material_id) as materials,GROUP_CONCAT(md_me_materialbase.net_weight) as weights, - pdm_bi_device.inupperlimit_qty - ifnull( sum( sch_base_task.material_qty*md_me_materialbase.net_weight ), 0 ) - pdm_bi_device.deviceinstor_qty AS currentQty, + pdm_bi_device.inupperlimit_qty - ifnull( sum( sch_base_task.material_qty*md_me_materialbase.net_weight ), 0 ) - pdm_bi_device.deviceinstor_weight AS currentQty, pdm_bi_device.device_code, + pdm_bi_device.inupperlimit_qty, sch_base_point.point_code from sch_base_point left join pdm_bi_device on pdm_bi_device.device_code = sch_base_point.device_code @@ -58,7 +59,7 @@ and (pdm_bi_device.spec = #{spec} or pdm_bi_device.spec is null) GROUP BY pdm_bi_device.device_code - HAVING currentQty > #{qty} + HAVING currentQty > #{qty} and pdm_bi_device.inupperlimit_qty > currentQty diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/ReportQuery.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/ReportQuery.java index 02e621f7..c5c2f1c3 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/ReportQuery.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/ReportQuery.java @@ -20,10 +20,12 @@ public class ReportQuery { private String workorder_code; private String workorder_id; private String report; - private String start_time; + private String begin_time; private String end_time; + private String shift_type_scode; private String user_id; private Boolean is_report =false; private String report_status; + private String orderby; } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/WorkorderQuery.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/WorkorderQuery.java index 019065eb..5436212b 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/WorkorderQuery.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/dto/WorkorderQuery.java @@ -18,6 +18,7 @@ import java.util.Map; public class WorkorderQuery extends BaseQuery { private String workorder_code; + private String device_code; private String material; private String order_status; private String workprocedure_code; diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/impl/IPdmProduceWorkorderServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/impl/IPdmProduceWorkorderServiceImpl.java index c2a3f5ed..1d488e2d 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/impl/IPdmProduceWorkorderServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/service/workorder/impl/IPdmProduceWorkorderServiceImpl.java @@ -152,6 +152,7 @@ public class IPdmProduceWorkorderServiceImpl extends ServiceImpl() - .set("nok_qty",param.getBigDecimal("nok_qty")) - .set("repare_qty",param.getBigDecimal("repare_qty")) - .set("report_qty",param.getBigDecimal("report_qty")) + UpdateWrapper updateWrapper = new UpdateWrapper<>(); + if (param.getBigDecimal("nok_qty")!=null){ + updateWrapper.set("nok_qty",param.getBigDecimal("nok_qty")); + } + if (param.getBigDecimal("repare_qty")!=null){ + updateWrapper.set("repare_qty",param.getBigDecimal("repare_qty")); + } + updateWrapper.set("report_qty",param.getBigDecimal("report_qty")); + reportRecordService.update(updateWrapper .eq("macoperate_id", param.getString("macoperate_id"))); } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/task/impl/SchBaseTaskServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/task/impl/SchBaseTaskServiceImpl.java index 91f30a18..a8cfd726 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/task/impl/SchBaseTaskServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/task/impl/SchBaseTaskServiceImpl.java @@ -68,8 +68,9 @@ public class SchBaseTaskServiceImpl extends ServiceImpl().eq("task_id", task_id)); JSONArray array = new JSONArray(); - array.add(taskObj); + array.add(JSON.toJSON(task)); wms.issueTaskToAcs(array); }catch (Exception ex){ taskObj.setTask_status(StatusEnum.TASK_START_ERROR.getCode()); diff --git a/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml b/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml index 308d1e43..a1268ad0 100644 --- a/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml +++ b/mes/hd/nladmin-system/src/main/resources/config/application-dev3.yml @@ -10,24 +10,24 @@ spring: reactive: #endpoints: 172.31.185.110:8200,172.31.154.9:8200 #内网 # endpoints: 47.96.133.178:8200 #外网 - endpoints: http://192.168.46.225:9200 #外网 + endpoints: http://127.0.0.1:9200 #外网 elasticsearch: rest: #uris: 172.31.185.110:8200,172.31.154.9:8200 #内网 # uris: 47.96.133.178:8200 #外网 - uris: http://192.168.46.225:9200 #外网 - # username: elastic - # password: 123456 + uris: http://127.0.0.1:9200 #外网 +# username: elastic +# password: 123456 datasource: druid: db-type: com.alibaba.druid.pool.DruidDataSource driverClassName: net.sf.log4jdbc.sql.jdbcapi.DriverSpy # url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_mes_test}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false # url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_mes_test}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false - url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_mes}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false + url: jdbc:log4jdbc:mysql://${DB_HOST:127.0.0.1}:${DB_PORT:3306}/${DB_NAME:hl_one_mes}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false username: ${DB_USER:root} # password: ${DB_PWD:123456} - password: ${DB_PWD:123456} + password: ${DB_PWD:942464Yy} # 初始连接数 initial-size: 5 diff --git a/mes/hd/nladmin-system/src/main/resources/logback-spring.xml b/mes/hd/nladmin-system/src/main/resources/logback-spring.xml index 7f2c8ca5..c26c828a 100644 --- a/mes/hd/nladmin-system/src/main/resources/logback-spring.xml +++ b/mes/hd/nladmin-system/src/main/resources/logback-spring.xml @@ -146,9 +146,8 @@ https://juejin.cn/post/6844903775631572999 - + - diff --git a/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue b/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue index 0f1a3a2f..3f2205cc 100644 --- a/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue +++ b/mes/qd/src/views/wms/device_manage/deviceMaterial/index.vue @@ -1,45 +1,50 @@ - @@ -97,13 +96,13 @@ import CRUD, { presenter, header, form } from '@crud/crud' import crudOperation from '@crud/CRUD.operation' import pagination from '@crud/Pagination' import rrOperation from '@crud/RR.operation' -import MaterDtl from '@/views/wms/pub/MaterDialog' const defaultForm = { product_area: 'A1', workprocedure_id: '1535144552481034240', device_code: null, material_id: null, material_name: null, material_spec: null, deviceinstor_qty: null, deviceinstor_weight: null, remark: null } export default { name: 'SKdevice', - components: { crudOperation, pagination, rrOperation, MaterDtl }, + components: { crudOperation, pagination, rrOperation }, + dicts: ['product_area'], cruds() { return [ CRUD({ title: '深坑设备物料', url: 'api/specialDevice/query', query: { product_area: 'A1', workprocedure_id: '1535144552481034240' }, idField: 'device_code', crudMethod: { ...crudDevice }}) @@ -141,13 +140,6 @@ export default { }).catch(() => { }) }, - setMaterValue(row) { - this.nowrow.material_id = row.material_id - this.nowrow.material_code = row.material_code - this.nowrow.material_name = row.material_name - this.nowrow.material_spec = row.material_spec - this.tableData.splice(this.nowindex, 1, this.nowrow) // 通过splice 替换数据 触发视图更新 - } } } diff --git a/mes/qd/src/views/wms/device_manage/deviceMaterial/备份.vue b/mes/qd/src/views/wms/device_manage/deviceMaterial/备份.vue new file mode 100644 index 00000000..8d8609d3 --- /dev/null +++ b/mes/qd/src/views/wms/device_manage/deviceMaterial/备份.vue @@ -0,0 +1,156 @@ + + + + + diff --git a/mes/qd/src/views/wms/product_manage/workorder/index.vue b/mes/qd/src/views/wms/product_manage/workorder/index.vue index 919cfcda..f93625e7 100644 --- a/mes/qd/src/views/wms/product_manage/workorder/index.vue +++ b/mes/qd/src/views/wms/product_manage/workorder/index.vue @@ -48,7 +48,16 @@ class="filter-item" /> - + + + --> - - - - - + + + - @@ -413,6 +419,9 @@ + + + @@ -579,6 +588,9 @@ export default { this.initClass3() }, methods: { + databaseUploadApi(){ + + }, formatBoolean: function(row, column) { var ret = '' if (row[column.property] === true) { diff --git a/mes/qd/src/views/wms/product_manage/workorder/produceshiftorder.js b/mes/qd/src/views/wms/product_manage/workorder/produceshiftorder.js index af73563c..44d2ba5a 100644 --- a/mes/qd/src/views/wms/product_manage/workorder/produceshiftorder.js +++ b/mes/qd/src/views/wms/product_manage/workorder/produceshiftorder.js @@ -106,7 +106,7 @@ export function getReportWork(data) { export function reportQuery(data) { return request({ url: '/api/produceWorkorder/reportQuery2', - method: 'post', + method: 'get', data }) } diff --git a/mes/qd/src/views/wms/product_manage/workorder/reportDialog.vue b/mes/qd/src/views/wms/product_manage/workorder/reportDialog.vue index 3dbdb1fe..ecfb875a 100644 --- a/mes/qd/src/views/wms/product_manage/workorder/reportDialog.vue +++ b/mes/qd/src/views/wms/product_manage/workorder/reportDialog.vue @@ -4,29 +4,51 @@ append-to-body fullscreen :visible.sync="dialogVisible" - @open="open" @close="close" > - - +
+ - + + + + + + + + + - - 查询 - + - - +
工单生产记录详情 @@ -38,7 +60,8 @@ - - - - - - - + + + + + + + + + + + @@ -89,8 +112,7 @@ - - + 取 消 确定 @@ -101,12 +123,56 @@ + + diff --git a/mes/qd/src/views/wms/scheduler_manage/task/index.vue b/mes/qd/src/views/wms/scheduler_manage/task/index.vue index 69a2965c..4576e823 100644 --- a/mes/qd/src/views/wms/scheduler_manage/task/index.vue +++ b/mes/qd/src/views/wms/scheduler_manage/task/index.vue @@ -151,21 +151,21 @@ style="width: 100%;" @selection-change="crud.selectionChangeHandler" > - - - + + - - + + + From afe0866aed9b8dc835e593fd06b6e68a0af192d1 Mon Sep 17 00:00:00 2001 From: gengby <858962040@qq.com> Date: Tue, 13 Jun 2023 09:39:26 +0800 Subject: [PATCH 19/19] =?UTF-8?q?rev=20=E5=88=86=E9=A1=B5=E3=80=81?= =?UTF-8?q?=E4=B8=8B=E5=8F=91plc=E4=B8=A4=E6=AC=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/InstructionServiceImpl.java | 8 ++++---- .../src/main/java/org/nl/acs/opc/OpcUtl.java | 2 +- .../service/impl/ProduceshiftorderServiceImpl.java | 10 ++++++---- .../org/nl/acs/task/service/impl/TaskServiceImpl.java | 9 +++++---- .../java/org/nl/acs/task/service/wql/QTASK_QUERY.wql | 4 +--- 5 files changed, 17 insertions(+), 16 deletions(-) diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java index b6861836..142b7f17 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/instruction/service/impl/InstructionServiceImpl.java @@ -128,12 +128,12 @@ public class InstructionServiceImpl implements InstructionService, ApplicationAu return true; }) .sorted((inst1, inst2) -> (inst1.getInstruction_code().compareTo(inst2.getInstruction_code()))) - .skip((currentPageNumber - 1) * pageMaxSize) - .limit(pageMaxSize) .collect(Collectors.toList()); + List skipList = instructionList.stream().skip((currentPageNumber - 1) * pageMaxSize) + .limit(pageMaxSize).collect(Collectors.toList()); JSONObject jo = new JSONObject(); - jo.put("content", instructionList); - jo.put("totalElements", this.instructions.size()); + jo.put("content", skipList); + jo.put("totalElements", instructionList.size()); return jo; } diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java index f448de73..b513eea4 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java @@ -40,7 +40,7 @@ public class OpcUtl { Map e=null; try{ e=group.write(requests); - group.write(requests); + //group.write(requests); }catch (Exception e1){ try{ e= group.write(requests); diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/order/service/impl/ProduceshiftorderServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/order/service/impl/ProduceshiftorderServiceImpl.java index 75d234b0..aa4ce8c8 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/order/service/impl/ProduceshiftorderServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/order/service/impl/ProduceshiftorderServiceImpl.java @@ -116,9 +116,12 @@ public class ProduceshiftorderServiceImpl implements ProduceshiftorderService, A .skip((currentPageNumber - 1) * pageMaxSize) .limit(pageMaxSize) .collect(Collectors.toList()); + List skipList = orderList.stream().skip((currentPageNumber - 1) * pageMaxSize) + .limit(pageMaxSize) + .collect(Collectors.toList()); JSONObject jo = new JSONObject(); - jo.put("content", orderList); - jo.put("totalElements", this.order.size()); + jo.put("content", skipList); + jo.put("totalElements", orderList.size()); return jo; } @@ -147,7 +150,7 @@ public class ProduceshiftorderServiceImpl implements ProduceshiftorderService, A @Override public ProduceshiftorderDto findByCode(String code) { WQLObject wo = WQLObject.getWQLObject("acs_produceshiftorder"); - JSONObject json = wo.query("order_code ='" + code + "' and is_deleted = '0'","create_time").uniqueResult(0); + JSONObject json = wo.query("order_code ='" + code + "' and is_deleted = '0'", "create_time").uniqueResult(0); if (ObjectUtil.isEmpty(json)) { return null; } @@ -450,7 +453,6 @@ public class ProduceshiftorderServiceImpl implements ProduceshiftorderService, A } - @Override public void addDeviceIsOnline(String device_code, ProduceshiftorderDto dto) { WQLObject wo = WQLObject.getWQLObject("acs_deviceisonline"); diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/impl/TaskServiceImpl.java b/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/impl/TaskServiceImpl.java index 81619542..c8cc907f 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/impl/TaskServiceImpl.java +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/impl/TaskServiceImpl.java @@ -171,12 +171,13 @@ public class TaskServiceImpl implements TaskService, ApplicationAutoInitial { return true; }) .sorted((task1, task2) -> DateUtil.compare(DateUtil.parseDate(task1.getCreate_time()), DateUtil.parse(task2.getCreate_time()))) - .skip((currentPageNumber - 1) * pageMaxSize) - .limit(pageMaxSize) .collect(Collectors.toList()); + List skipList = taskList.stream().skip((currentPageNumber - 1) * pageMaxSize) + .limit(pageMaxSize) + .collect(Collectors.toList()); JSONObject jo = new JSONObject(); - jo.put("content", taskList); - jo.put("totalElements", this.tasks.size()); + jo.put("content", skipList); + jo.put("totalElements", taskList.size()); return jo; } diff --git a/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/wql/QTASK_QUERY.wql b/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/wql/QTASK_QUERY.wql index 47421336..4bb1d83e 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/wql/QTASK_QUERY.wql +++ b/wcs/nladmin-system/src/main/java/org/nl/acs/task/service/wql/QTASK_QUERY.wql @@ -107,9 +107,7 @@ IF 输入.flag = "2" OR task.next_point_code LIKE CONCAT ( '%', 输入.point_code, '%') OR - task.start_point_code2 LIKE CONCAT ( '%', 输入.point_code, '%' ) - OR - task.next_point_code2 LIKE CONCAT ( '%', 输入.point_code, '%') + task.put_point_code LIKE CONCAT ( '%', 输入.point_code, '%' ) ) ENDOPTION OPTION 输入.create_time <> ""