From bec170a530bbeecea2c5feeb38bb007157c01fd6 Mon Sep 17 00:00:00 2001 From: zhangzhiqiang Date: Mon, 26 Jun 2023 08:50:08 +0800 Subject: [PATCH] =?UTF-8?q?rev:sap=E5=90=8C=E6=AD=A5=E9=94=80=E5=94=AE?= =?UTF-8?q?=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mes/hd/nladmin-system/pom.xml | 10 ++-- .../nl/modules/common/utils/StringUtils.java | 32 ++++-------- .../sap/service/impl/WmsToSapServiceImpl.java | 38 ++++++++++---- .../impl/MdPbClassstandardServiceImpl.java | 3 +- .../PdmProduceWorkorderController.java | 23 +++++++-- .../impl/IPdmProduceWorkorderServiceImpl.java | 1 + .../src/main/resources/logback-spring.xml | 50 +++++++++++-------- .../product_manage/workorder/ViewDialog.vue | 7 ++- .../workorder/produceshiftorder.js | 12 ++++- .../staging/kzStaging/index.vue | 25 +++++++++- 10 files changed, 133 insertions(+), 68 deletions(-) diff --git a/mes/hd/nladmin-system/pom.xml b/mes/hd/nladmin-system/pom.xml index 48c80fe6..242486c9 100644 --- a/mes/hd/nladmin-system/pom.xml +++ b/mes/hd/nladmin-system/pom.xml @@ -58,11 +58,11 @@ - - com.yomahub - tlog-all-spring-boot-starter - 1.5.0 - + + + + + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/modules/common/utils/StringUtils.java b/mes/hd/nladmin-system/src/main/java/org/nl/modules/common/utils/StringUtils.java index b11dc81d..e7343094 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/modules/common/utils/StringUtils.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/modules/common/utils/StringUtils.java @@ -143,34 +143,24 @@ public class StringUtils { * 获取ip地址 */ public static String getIp(HttpServletRequest request) { - // TODO 不解析IP地址 - if(true){ - return "127.0.0.1"; - } - - String ip = request.getHeader("x-forwarded-for"); - if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) { + String ip = request.getHeader("X-Forwarded-For"); + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("Proxy-Client-IP"); } - if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) { + + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("WL-Proxy-Client-IP"); } - if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) { + + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { ip = request.getRemoteAddr(); } - String comma = ","; - String localhost = "127.0.0.1"; - if (ip.contains(comma)) { - ip = ip.split(",")[0]; - } - if (localhost.equals(ip)) { - // 获取本机真正的ip地址 - try { - ip = InetAddress.getLocalHost().getHostAddress(); - } catch (UnknownHostException e) { - log.error(e.getMessage(), e); - } + + if (ip != null && ip.contains(",")) { + String[] ipArray = ip.split(","); + ip = ipArray[0]; } + return ip; } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/sap/service/impl/WmsToSapServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/sap/service/impl/WmsToSapServiceImpl.java index e855f82c..93d82246 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/sap/service/impl/WmsToSapServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/sap/service/impl/WmsToSapServiceImpl.java @@ -6,6 +6,7 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.json.XML; @@ -14,6 +15,15 @@ import org.nl.modules.common.exception.BadRequestException; import org.nl.modules.wql.core.bean.WQLObject; import org.nl.common.utils.WebServiceUtil; import org.nl.wms.ext.sap.service.WmsToSapService; +import org.nl.wms.masterdata_manage.master.service.customer.IMdCsCustomerbaseService; +import org.nl.wms.masterdata_manage.master.service.customer.dao.MdCsCustomerbase; +import org.nl.wms.masterdata_manage.service.master.IMdPbMeasureunitService; +import org.nl.wms.masterdata_manage.service.master.dao.MdPbMeasureunit; +import org.nl.wms.masterdata_manage.service.material.IMdMeMaterialbaseService; +import org.nl.wms.masterdata_manage.service.material.dao.MdMeMaterialbase; +import org.nl.wms.mps_manage.ordermanage.service.saleOrder.IMpsSaleOrderService; +import org.nl.wms.mps_manage.ordermanage.service.saleOrder.dao.MpsSaleOrder; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.text.SimpleDateFormat; @@ -25,6 +35,15 @@ import java.util.HashMap; @Slf4j public class WmsToSapServiceImpl implements WmsToSapService { + @Autowired + private IMdPbMeasureunitService mdPbMeasureunitService; + @Autowired + private IMdMeMaterialbaseService materialbaseService; + @Autowired + private IMdCsCustomerbaseService customerbaseService; + @Autowired + private IMpsSaleOrderService saleOrderService; + @Override public JSONObject getMater(JSONObject form) { return null; @@ -103,7 +122,7 @@ public class WmsToSapServiceImpl implements WmsToSapService { for (int i = 0; i < item.size(); i++) { JSONObject row = item.getJSONObject(i); boolean need_update = false; - JSONObject sale_jo = WQLObject.getWQLObject("pcs_sale_order").query("sale_code = '" + row.getString("Vbeln") + "' AND seq_no = '" + row.getString("Posnr") + "'").uniqueResult(0); + JSONObject sale_jo = WQLObject.getWQLObject("pcs_sale_order").query("sale_code = '" + + "' AND seq_no = '" + + "'").uniqueResult(0); if (ObjectUtil.isEmpty(sale_jo)) { sale_jo = new JSONObject(); sale_jo.put("sale_id", IdUtil.getSnowflake(1, 1).nextId()); @@ -119,38 +138,39 @@ public class WmsToSapServiceImpl implements WmsToSapService { sale_jo.put("sale_type", row.getString("Auart")); String material_code = row.getString("Matnr").replaceAll("^(0+)", ""); //获取物料对应的物料标识 - JSONObject mater_jo = WQLObject.getWQLObject("MD_ME_MaterialBase").query("material_code = '" + material_code + "'").uniqueResult(0); + MdMeMaterialbase mater_jo = materialbaseService.getOne(new QueryWrapper().eq("material_code", material_code)); if (ObjectUtil.isEmpty(mater_jo)) { sale_jo.put("material_id", "0"); sale_jo.put("is_success", "0"); sale_jo.put("remark", "未查询到该销售订单对应的物料主数据：" + material_code); err_num++; } else { - String material_id = mater_jo.getString("material_id"); + String material_id =mater_jo.getMaterial_id(); sale_jo.put("material_id", material_id); } sale_jo.put("status", "10"); sale_jo.put("sale_qty", row.getString("Kwmeng")); sale_jo.put("produce_seq", "1"); String cust_code = row.getString("Kunnr"); - JSONObject cust_jo = WQLObject.getWQLObject("md_cs_customerbase").query("cust_code = '" + cust_code + "'").uniqueResult(0); + MdCsCustomerbase cust_jo = customerbaseService.getOne(new QueryWrapper().eq("cust_code", cust_code)); if (ObjectUtil.isNotEmpty(cust_jo)) { - sale_jo.put("cust_id", cust_jo.getString("cust_id")); - sale_jo.put("cust_code", cust_jo.getString("cust_code")); - sale_jo.put("cust_name", cust_jo.getString("cust_name")); + sale_jo.put("cust_id", cust_jo.getCust_id()); + sale_jo.put("cust_code", cust_jo.getCust_code()); + sale_jo.put("cust_name", cust_jo.getCust_name()); } else { sale_jo.put("is_success", "0"); sale_jo.put("remark", "未查询到该销售订单对应的客户信息：" + cust_code); err_num++; } String unit_code = row.getString("Vrkme"); - JSONObject unit_jo = WQLObject.getWQLObject("md_pb_measureunit").query("unit_name = '" + unit_code + "'").uniqueResult(0); + MdPbMeasureunit unit_jo = mdPbMeasureunitService.getOne(new QueryWrapper() + .eq("unit_name", unit_code)); if (ObjectUtil.isEmpty(unit_jo)) { sale_jo.put("qty_unit_id", "0"); sale_jo.put("remark", "未查询到该销售订单对应的单位信息：" + unit_code); err_num++; } else { - sale_jo.put("qty_unit_id", unit_jo.getString("measure_unit_id")); + sale_jo.put("qty_unit_id", unit_jo.getMeasure_unit_id()); } sale_jo.put("plandeliver_date", row.getString("Edatu")); sale_jo.put("create_id", SecurityUtils.getCurrentUserId()); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/service/classstandard/impl/MdPbClassstandardServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/service/classstandard/impl/MdPbClassstandardServiceImpl.java index 7ba6ffea..167fac99 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/service/classstandard/impl/MdPbClassstandardServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/service/classstandard/impl/MdPbClassstandardServiceImpl.java @@ -127,7 +127,8 @@ public class MdPbClassstandardServiceImpl extends ServiceImpl> list = this.listMaps(query); return getMaps(list); 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 e1683602..f08a8bc1 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 @@ -169,16 +169,29 @@ public class PdmProduceWorkorderController { @ApiOperation("报工数修改") @SaIgnore 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"); + Page page = null; + if (pageQuery.getPage() != null && pageQuery.getSize() !=null){ + 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()); + if (page!=null){ + build.setTotalElements(page.getTotal()); + } return new ResponseEntity<>(build, HttpStatus.OK); } + @PostMapping("/reportQuery3") + @Log("工单报工数") + @ApiOperation("工单报工数") + @SaIgnore + public ResponseEntity reportQuery3(@RequestBody ReportQuery param) { + return new ResponseEntity<>(TableDataInfo.build(iPdmProduceWorkorderService.reportQuery(param)), HttpStatus.OK); + } + @Log("导出数据") @ApiOperation("导出数据") @PostMapping(value = "/download") 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 c13e3454..f49943d9 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 @@ -633,6 +633,7 @@ public class IPdmProduceWorkorderServiceImpl extends ServiceImpl - http://192.168.46.225:9200/_bulk + http://127.0.0.1:9200/_bulk ${esIndex} mes_log es-logger @@ -79,10 +79,8 @@ https://juejin.cn/post/6844903775631572999 - true - + ${log.pattern} - @@ -100,15 +98,14 @@ https://juejin.cn/post/6844903775631572999 20GB - - + %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n - + 0 500 @@ -120,7 +117,6 @@ https://juejin.cn/post/6844903775631572999 - @@ -129,6 +125,10 @@ https://juejin.cn/post/6844903775631572999 + + + + @@ -168,6 +168,10 @@ https://juejin.cn/post/6844903775631572999 + + + + @@ -177,26 +181,36 @@ https://juejin.cn/post/6844903775631572999 + + + - + + - + + - + + - + + - + + \ - + + - + + \ @@ -211,11 +225,5 @@ https://juejin.cn/post/6844903775631572999 - - - - - - diff --git a/mes/qd/src/views/wms/product_manage/workorder/ViewDialog.vue b/mes/qd/src/views/wms/product_manage/workorder/ViewDialog.vue index 42f962f2..94965ce2 100644 --- a/mes/qd/src/views/wms/product_manage/workorder/ViewDialog.vue +++ b/mes/qd/src/views/wms/product_manage/workorder/ViewDialog.vue @@ -169,8 +169,7 @@ - 取 消 - 确定 + 关 闭 @@ -257,7 +256,7 @@ export default { open() { this.getworkprocedure() this.getMaterialClass() - crudProduceshiftorder.reportQuery({ workorder_id: this.form.workorder_id }).then(res => { + crudProduceshiftorder.reportQuery3({ workorder_id: this.form.workorder_id }).then(res => { this.tableData = res.content }) }, @@ -276,7 +275,7 @@ export default { 'material_id': this.form.material_id } crudClassstandard.queryClassById(param).then(res => { - this.form.class_name = res.content[0].class_name + this.$set(this.form,'class_name',res.content[0].class_name) }) }, getworkprocedure() { 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 44d2ba5a..a617dae5 100644 --- a/mes/qd/src/views/wms/product_manage/workorder/produceshiftorder.js +++ b/mes/qd/src/views/wms/product_manage/workorder/produceshiftorder.js @@ -104,6 +104,7 @@ export function getReportWork(data) { } export function reportQuery(data) { + console.log(data) return request({ url: '/api/produceWorkorder/reportQuery2', method: 'get', @@ -111,6 +112,15 @@ export function reportQuery(data) { }) } + +export function reportQuery3(data) { + return request({ + url: '/api/produceWorkorder/reportQuery3', + method: 'post', + data + }) +} + export function excelImport(data) { return request({ url: 'api/produceWorkorder/excelImport', @@ -142,4 +152,4 @@ export function reportApprove(data) { }) } -export default { add, addRows, edit, del, submits, reportApprove, unSubmits, getTable, openStart, saveReport, finish, getReportWork, forceFinish, reportQuery, excelImport, getNotWorkDeviceByWorkproceduceId, replaceDevice } +export default { add, addRows, edit, del, submits, reportApprove, unSubmits, getTable, openStart, saveReport, finish, getReportWork, forceFinish, reportQuery, reportQuery3, excelImport, getNotWorkDeviceByWorkproceduceId, replaceDevice } diff --git a/mes/qd/src/views/wms/staging_manage/staging/kzStaging/index.vue b/mes/qd/src/views/wms/staging_manage/staging/kzStaging/index.vue index 14242cbe..7be83973 100644 --- a/mes/qd/src/views/wms/staging_manage/staging/kzStaging/index.vue +++ b/mes/qd/src/views/wms/staging_manage/staging/kzStaging/index.vue @@ -44,7 +44,18 @@ - + + + 设置空位 + + { + structIds.push(item.workorder_id) + }) + alert(structIds) + // crudProduceshiftorder.submits(orders).then(res => { + // this.crud.notify('下发成功', CRUD.NOTIFICATION_TYPE.SUCCESS) + // this.crud.toQuery() + // }) + }, // 取消下发 setMaterValue(row) { this.materialForm.material_id = row.material_id this.materialForm.material_code = row.material_code