diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java b/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java index 99c21374..32cd6204 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java @@ -9,6 +9,7 @@ import java.util.Date; import org.nl.common.enums.QueryTEnum; import org.nl.common.utils.MapOf; +import org.springframework.format.annotation.DateTimeFormat; import sun.reflect.generics.reflectiveObjects.ParameterizedTypeImpl; import java.lang.reflect.Type; @@ -33,8 +34,8 @@ public class BaseQuery { /** * 创建时间范围查询 */ - private Date start_time; - private Date end_time; + private String start_time; + private String end_time; /** diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/bigScreen/rest/DeviceScreenController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/bigScreen/rest/DeviceScreenController.java index c7a6a530..54faceba 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/bigScreen/rest/DeviceScreenController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/bigScreen/rest/DeviceScreenController.java @@ -49,7 +49,6 @@ public class DeviceScreenController { } @PostMapping("/deviceManage") - @Log("设备管理") @ApiOperation("设备管理") public ResponseEntity deviceManage(@RequestBody JSONObject whereJson) { return new ResponseEntity<>(deviceScreenService.deviceManage(whereJson), HttpStatus.OK); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/PdmProduceWorkorderController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/PdmProduceWorkorderController.java index eb1d1716..f3232273 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/PdmProduceWorkorderController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/product_manage/controller/workorder/PdmProduceWorkorderController.java @@ -5,6 +5,8 @@ import cn.dev33.satoken.annotation.SaIgnore; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.github.pagehelper.Page; +import com.github.pagehelper.PageHelper; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; @@ -30,6 +32,7 @@ import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.util.Arrays; import java.util.List; +import java.util.Map; /** *

@@ -159,17 +162,19 @@ public class PdmProduceWorkorderController { return new ResponseEntity<>(TableDataInfo.build(iPdmProduceWorkorderService.reportQuery(param)),HttpStatus.OK); } - @PostMapping("/reportQuery2") + @GetMapping("/reportQuery2") @Log("报工数修改") @ApiOperation("报工数修改") @SaIgnore - public ResponseEntity reportQuery2(@RequestBody ReportQuery param) { - return new ResponseEntity<>(TableDataInfo.build(iPdmProduceWorkorderService.reportQuery(param)),HttpStatus.OK); + public ResponseEntity reportQuery2(ReportQuery param ,PageQuery pageQuery) { + Page page = PageHelper + .startPage(pageQuery.getPage()+1, pageQuery.getSize()) + .setOrderBy("workorder_code desc,seq_number asc"); + param.setOrderby("true"); + List list = iPdmProduceWorkorderService.reportQuery(param); + TableDataInfo build = TableDataInfo.build(list); + build.setTotalElements(page.getTotal()); + return new ResponseEntity<>(build,HttpStatus.OK); } - - - - - } 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 f1abcfa2..ab310938 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 @@ -15,6 +15,7 @@ import org.nl.common.enums.StatusEnum; import org.nl.common.enums.WorkerOrderEnum; import org.nl.common.utils.IdUtil; import org.nl.common.utils.MapOf; +import org.nl.common.utils.RedissonUtils; import org.nl.common.utils.SecurityUtils; import org.nl.modules.common.exception.BadRequestException; import org.nl.modules.system.util.CodeUtil; @@ -80,7 +81,9 @@ public class SpeEmpTask extends AbstractAcsTask { public void updateTaskStatus(JSONObject param,String status) { SchBaseTask task = taskService.getOne(new QueryWrapper().eq("task_id", param.getString("task_id"))); try { - SpeHandles.get(task.getTask_name()).handle(param,status,task); + RedissonUtils.lock(()->{ + SpeHandles.get(task.getTask_name()).handle(param,status,task); + },param.getString("task_id")+status,2); }catch (Exception ex){ log.error("更新状态异常updateTaskStatus param:{},status:{},ex:{}",param,status,ex); throw ex; 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 d652b1af..7ef63ec2 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 @@ -14,6 +14,7 @@ import org.nl.common.enums.StatusEnum; import org.nl.common.enums.WorkerOrderEnum; import org.nl.common.utils.IdUtil; import org.nl.common.utils.MapOf; +import org.nl.common.utils.RedissonUtils; import org.nl.common.utils.SecurityUtils; import org.nl.modules.common.exception.BadRequestException; import org.nl.modules.system.util.CodeUtil; @@ -81,7 +82,9 @@ public class SpeFullTask extends AbstractAcsTask { SchBaseTask task = taskService.getById(param.getString("task_id")); pointService.update(new UpdateWrapper().set("lock_type","0").in("point_code",task.getPoint_code1(),task.getPoint_code2(),task.getPoint_code3())); try { - SpeHandles.get(task.getTask_name()).handle(param,status,task); + RedissonUtils.lock(()->{ + SpeHandles.get(task.getTask_name()).handle(param,status,task); + },param.getString("task_id")+status,2); }catch (Exception ex){ log.error(OPT_NAME+"updateStatus error:{}",ex); throw ex; @@ -276,6 +279,14 @@ public class SpeFullTask extends AbstractAcsTask { .set("task_status",StatusEnum.TASK_FINISH.getCode()) .set("update_name","acs") .set("update_time",DateUtil.now()).eq("task_id",task.getTask_id())); + PdmBiDevice one = deviceService.getOne(new QueryWrapper().eq("device_code", task.getPoint_code2())); + 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())); + } break; case STATUS_CANNEL: cancel(param.getString("task_id")); 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 df9d90ee..a0f7ff91 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 @@ -40,8 +40,9 @@ 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" > - - - + + - - + + +