diff --git a/mes/hd/nladmin-system/pom.xml b/mes/hd/nladmin-system/pom.xml index 0f362ec..c9a68ff 100644 --- a/mes/hd/nladmin-system/pom.xml +++ b/mes/hd/nladmin-system/pom.xml @@ -3,7 +3,7 @@ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> - hl_one_wms + yy_lms org.nl 1.0-SNAPSHOT @@ -37,12 +37,6 @@ jetcache-starter-redis-lettuce 2.5.14 - - - org.springframework.boot - spring-boot-starter-data-mongodb - - net.dreamlu diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/MongoDBAppenderBase.java b/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/MongoDBAppenderBase.java deleted file mode 100644 index 77d28ab..0000000 --- a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/MongoDBAppenderBase.java +++ /dev/null @@ -1,54 +0,0 @@ -package org.nl.modules.log; - -import ch.qos.logback.classic.spi.ILoggingEvent; -import ch.qos.logback.core.UnsynchronizedAppenderBase; -import cn.hutool.core.util.ObjectUtil; -import com.mongodb.BasicDBObject; -import lombok.Data; -import org.nl.utils.SpringContextHolder; -import org.slf4j.Marker; -import org.springframework.data.mongodb.core.MongoTemplate; - -import java.net.InetAddress; -import java.net.UnknownHostException; - -/** - * https://www.cnblogs.com/lzghyh/p/14913230.html - * https://juejin.cn/post/6844903488896385037 - * https://cloud.tencent.com/developer/article/1384035 - * https://www.freesion.com/article/229560377/ - *

- * https://cloud.tencent.com/developer/article/1384035 - */ -@Data -public class MongoDBAppenderBase extends UnsynchronizedAppenderBase { - - @Override - protected void append(ILoggingEvent eventObject) { - - MongoTemplate mongoTemplate = SpringContextHolder.getBean(MongoTemplate.class); - - if (mongoTemplate != null) { - final BasicDBObject doc = new BasicDBObject(); - Marker marker = eventObject.getMarker(); - if (!ObjectUtil.isEmpty(marker)) { - doc.append("marker", marker.getName()); - } else { - doc.append("marker", "default"); - } - try { - doc.append("ip", InetAddress.getLocalHost().getHostAddress()); - } catch (UnknownHostException e) { - e.printStackTrace(); - } - - doc.append("level", eventObject.getLevel().toString()); - doc.append("logger", eventObject.getLoggerName()); - doc.append("thread", eventObject.getThreadName()); - doc.append("message", eventObject.getFormattedMessage()); - mongoTemplate.insert(doc, "log"); - } - } - - -} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/rest/RootLogController.java b/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/rest/RootLogController.java deleted file mode 100644 index 0ad0ee4..0000000 --- a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/rest/RootLogController.java +++ /dev/null @@ -1,42 +0,0 @@ - -package org.nl.modules.log.rest; - - -import io.swagger.annotations.Api; -import io.swagger.annotations.ApiOperation; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.nl.annotation.Log; -import org.nl.modules.log.service.RootLogService; -import org.springframework.data.domain.Pageable; -import org.springframework.http.HttpStatus; -import org.springframework.http.ResponseEntity; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; - -import java.util.Map; - -/** - * @author ldjun - * @date 2021-08-19 - **/ -@RestController -@RequiredArgsConstructor -@Api(tags = "系统日志") -@RequestMapping("/api/rootLog") -@Slf4j -public class RootLogController { - - private final RootLogService rootLogService; - - @GetMapping - @Log("查询系统日志") - @ApiOperation("查询系统日志") - //@PreAuthorize("@el.check('point:list')") - public ResponseEntity query(@RequestParam Map whereJson, Pageable page) { - return new ResponseEntity<>(rootLogService.queryAll(whereJson, page), HttpStatus.OK); - } - -} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/service/RootLogService.java b/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/service/RootLogService.java deleted file mode 100644 index b76d889..0000000 --- a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/service/RootLogService.java +++ /dev/null @@ -1,18 +0,0 @@ -package org.nl.modules.log.service; - -import org.springframework.data.domain.Pageable; - -import java.util.Map; - -/** - * 系统日志查询 - */ -public interface RootLogService { - /** - * 查询数据分页 - * @param whereJson 条件 - * @param page 分页参数 - * @return Map - */ - Map queryAll(Map whereJson, Pageable page); -} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/service/impl/RootLogServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/service/impl/RootLogServiceImpl.java deleted file mode 100644 index f01ee14..0000000 --- a/mes/hd/nladmin-system/src/main/java/org/nl/modules/log/service/impl/RootLogServiceImpl.java +++ /dev/null @@ -1,46 +0,0 @@ -package org.nl.modules.log.service.impl; - -import com.alibaba.fastjson.JSONObject; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.nl.modules.log.service.RootLogService; -import org.springframework.data.domain.Pageable; -import org.springframework.data.mongodb.core.MongoTemplate; -import org.springframework.data.mongodb.core.query.Criteria; -import org.springframework.data.mongodb.core.query.Query; -import org.springframework.stereotype.Service; - -import java.util.List; -import java.util.Map; - -/** - * @author ldjun - * @description 服务实现 - * @date 2021-08-19 - **/ -@Service -@RequiredArgsConstructor -@Slf4j -public class RootLogServiceImpl implements RootLogService { - - private final MongoTemplate mongoTemplate; - - @Override - public Map queryAll(Map whereJson, Pageable page) { - //查询条件 - Query query = Query.query(Criteria.where("level").is("INFO")); - - //根据条件得到的总条数 - long totalSize = mongoTemplate.count(query, Map.class, "log_root"); - - //处理分页 - query.skip(page.getPageNumber()).limit(page.getPageSize()); - List list = mongoTemplate.find(query, Map.class, "log_root"); - - //封装前端分页查询结果 - JSONObject result = new JSONObject(); - result.put("content", list); - result.put("totalElements", totalSize); - return result; - } -} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/start/Init.java b/mes/hd/nladmin-system/src/main/java/org/nl/start/Init.java index c0ede50..8277c13 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/start/Init.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/start/Init.java @@ -1,7 +1,5 @@ package org.nl.start; -import cn.hutool.core.util.IdUtil; -import com.alibaba.fastjson.JSONObject; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.nl.modules.quartz.domain.QuartzJob; @@ -10,7 +8,6 @@ import org.nl.modules.quartz.utils.QuartzManage; import org.nl.start.auto.initial.ApplicationAutoInitialExecuter; import org.nl.start.auto.initial.WebAutoInitialExecuter; import org.nl.wql.WQLCore; -import org.nl.wql.core.bean.WQLObject; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.stereotype.Component; @@ -41,56 +38,10 @@ public class Init implements ApplicationRunner { //初始化任务调度 initQuartz(); isStart = true; - // test(); - System.out.println("海亮wms系统启动成功!"); + System.out.println("系统启动成功!"); } - private void test() { - WQLObject deviceTab = WQLObject.getWQLObject("pdm_bi_device"); - JSONObject deviceObj = deviceTab.query("device_id = '1535146229862895616'").uniqueResult(0); - deviceObj.put("workprocedure_id","1535144682756116480"); - String pre = "KZ"; - String name = "刻字"; - for (int i = 10; i < 14 ;i++) { - //设备 - JSONObject s = new JSONObject(deviceObj); - s.put("device_id", IdUtil.getSnowflake(1, 1).nextId()); - s.put("device_code", pre + i ); - s.put("device_name", name + i ); - s.put("extend_code", s.getString("device_code") ); - deviceTab.insert(s); - - /* //接料位 - JSONObject j = new JSONObject(deviceObj); - j.put("device_id", IdUtil.simpleUUID()); - j.put("device_code", pre + i + "J"); - j.put("device_name", pre + i + "J"); - deviceTab.insert(j); - - //满料位 - JSONObject m = new JSONObject(deviceObj); - m.put("device_id", IdUtil.simpleUUID()); - m.put("device_code", pre + i + "M"); - m.put("device_name", pre + i + "M"); - deviceTab.insert(m); - - //倒料位 - JSONObject d = new JSONObject(deviceObj); - d.put("device_id", IdUtil.simpleUUID()); - d.put("device_code", pre + i + "D"); - d.put("device_name", pre + i + "D"); - deviceTab.insert(d); - - //空料位 - JSONObject k = new JSONObject(deviceObj); - k.put("device_id", IdUtil.simpleUUID()); - k.put("device_code", pre + i + "K"); - k.put("device_name", pre + i + "K"); - deviceTab.insert(k);*/ - } - } - private void initQuartz() { log.info("--------------------注入定时任务---------------------"); List quartzJobs = quartzJobRepository.findByIsPauseIsFalse(); diff --git a/mes/hd/nladmin-system/src/main/resources/config/application-dev.yml b/mes/hd/nladmin-system/src/main/resources/config/application-dev.yml index 7ca716c..9015716 100644 --- a/mes/hd/nladmin-system/src/main/resources/config/application-dev.yml +++ b/mes/hd/nladmin-system/src/main/resources/config/application-dev.yml @@ -18,11 +18,10 @@ spring: db-type: com.alibaba.druid.pool.DruidDataSource driverClassName: net.sf.log4jdbc.sql.jdbcapi.DriverSpy #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:47.111.78.178}:${DB_PORT:3306}/${DB_NAME:yongyu_lms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false + url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.81.252}:${DB_PORT:3306}/${DB_NAME:yongyu_lms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false username: ${DB_USER:root} #password: ${DB_PWD:P@ssw0rd} - #password: ${DB_PWD:root} - password: ${DB_PWD:P@ssw0rd} + password: ${DB_PWD:Root.123456} # 初始连接数 initial-size: 5 # 最小连接数 diff --git a/mes/hd/nladmin-system/src/main/resources/config/application.yml b/mes/hd/nladmin-system/src/main/resources/config/application.yml index 0e75762..334120a 100644 --- a/mes/hd/nladmin-system/src/main/resources/config/application.yml +++ b/mes/hd/nladmin-system/src/main/resources/config/application.yml @@ -2,7 +2,7 @@ spring: freemarker: check-template-location: false profiles: - active: prod + active: dev jackson: time-zone: GMT+8 data: 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 d43d24c..a45bcd6 100644 --- a/mes/hd/nladmin-system/src/main/resources/logback-spring.xml +++ b/mes/hd/nladmin-system/src/main/resources/logback-spring.xml @@ -74,11 +74,9 @@ https://juejin.cn/post/6844903775631572999 - - - + diff --git a/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test.java b/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test.java deleted file mode 100644 index a6e6f89..0000000 --- a/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test.java +++ /dev/null @@ -1,369 +0,0 @@ -/* -package org.nl.day01; - -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; -import org.nl.exception.WDKException; -import org.nl.wql.WQL; -import org.nl.wql.core.bean.WQLObject; - -import java.text.SimpleDateFormat; -import java.util.*; - -public class Test { - - */ -/** - * 根据输入天数day，获取距离今天day天数的字符串日期 - * - * @param day - * 距离今天天数 - * @return 如day为0 则输出2019-06-09当天日期 - *//* - - public static String getDateStr(int day) { - SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd"); - Date todayDate = new Date(); - long beforeTime = (todayDate.getTime() / 1000) - 60 * 60 * 24 * day; - todayDate.setTime(beforeTime * 1000); - String beforeDate = formatter.format(todayDate); - return beforeDate; - } - */ -/** - * 更新交货单 - * - * @param ctx - * @param account - *//* - - @WDKTransaction - public void updateDeliveryOrderInfo(String code) { - Date date1 = new Date(); - System.out.println("updateDeliveryOrderInfo发送数据-----------------"); - String url = "http://192.168.0.82:8000/sap/bc/srt/rfc/sap/zfg_ecc_to_zhwl/800/zfg_ecc_to_zhwl/binding"; - String method = "ZfmGetDnZjwl"; - HashMap form = new HashMap<>(); - // 获得前两天日期 - JSONObject ZfmGetSoResponse = null; - if (code.equals("")) { - form.put("IErdatFrm", getDateStr(1)); - form.put("IErdatTo",getDateStr(0)); - form.put("IVbeln", ""); // 非必填字段 - } else { - form.put("IErdatFrm", ""); - form.put("IErdatTo", ""); - form.put("IVbeln", code); // 非必填字段 - } - try { - JSONObject ret = WebServiceUtil.process(url, method, form); - System.out.println("getXML发送数据-----------------" + ret.toString()); - JSONObject Envelope = ret.optJSONObject("soap-env:Envelope"); - JSONObject Body = Envelope.optJSONObject("soap-env:Body"); - ZfmGetSoResponse = Body.optJSONObject("n0:ZfmGetDnZjwlResponse"); - String check = ZfmGetSoResponse.optString("OResultcode"); - if ("1005".equals(check)) { - System.out.println(ZfmGetSoResponse.optString("OResultmsg")); - return; - } else if (!"1000".equals(check)) { - throw new WDKException(ZfmGetSoResponse.optString("OResultmsg")); - } - } catch (Exception e) { - e.printStackTrace(); - } - JSONObject TZtsalesorder = ZfmGetSoResponse.optJSONObject("TZtdn"); - JSONArray item = TZtsalesorder.optJSONArray("item"); - - if (item.size() == 0 || TZtsalesorder == null) { - return; - } - - // 发货通知单（未拆分）主表 - WQLObject wqlMst = WQLObject.getWQLObject("SAL_OD_DeliveryNotice"); - // 发货通知单明细（未拆分）表 - WQLObject wqlDtl = WQLObject.getWQLObject("SAL_OD_DeliveryNoticeDtl"); - // 交货单接口表 - WQLObject wqld = WQLObject.getWQLObject("SAP_OD_Delivery"); - - // 字典表单据类型 - WQLObject wqlDic = WQLObject.getWQLObject("PF_PB_SysDicInfo"); - JSONArray diclist = wqlDic.query("sysdic_type ='TC_SALE_SENDBIZTYPE' and sysdic_para2 !='' ") - .getResultJSONArray(0); - HashMap DicMap = new HashMap<>(); - for (int i = 0; i < diclist.size(); i++) { - JSONObject nowdiclist = diclist.getJSONObject(i); - DicMap.put(nowdiclist.optString("sysdic_para2"), nowdiclist.optString("sysdic_code")); - } - //查询当前仓库 - JSONArray jaStor = WQL.getWO("QSTOST_MTATERUTIL_01") - .addParam("flag", "6") - .process() - .getResultJSONArray(0); - - HashMap mapStor = new HashMap<>(); - for(int i=0;i mapMst = new HashMap(); - for(int i=0;i mapMater = new HashMap<>(); - for(int i=0;i mapCount2 = new HashMap<>(); - mapCount2.put("sysflag", "1"); - // 更新中间主表 - wqld.update(mapCount2, "id in("+sbdtl.toString()+")"); - - Set> entrySet = mapMst.entrySet(); - Iterator> iter = entrySet.iterator(); - //新增主表 - while (iter.hasNext()) - { - Map.Entry entry = iter.next(); - JSONObject jo = entry.getValue(); - if(jo.optInt("detail_count")==0){ - continue; - } - if(jo.optString("is_insert").equals("1")){ - wqlMst.insert(entry.getValue()); - }else if(jo.optString("is_insert").equals("0")){ - wqlMst.update(entry.getValue()); - } - } - Date date2 = new Date(); - System.out.println("共计秒："+(date2.getTime()-date1.getTime())/1000); - System.out.println("销售发货通知数据同步成功！"); - } - - } -*/ diff --git a/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test2.java b/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test2.java deleted file mode 100644 index cf67a6e..0000000 --- a/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test2.java +++ /dev/null @@ -1,62 +0,0 @@ -package org.nl.day01; - -import net.sf.json.JSONObject; - -import java.util.HashMap; - -public class Test2 { - public static void main(String[] args) throws Exception { - - String url = "http://192.168.0.82:8000/sap/bc/srt/rfc/sap/z_sd0002_send_mat_md/800/z_sd0002_send_mat_md/binding"; - String method = "ZSd0002SendMatMd"; //物料接口 - HashMap form = new HashMap(); - form.put("MatnrFr", "24018347S"); - form.put("MatnrTo", "24018347S"); - //非必填字段 - JSONObject ret = WebServiceUtil.process(url, method, form); - System.out.println("getXML返回数据-----------------" + ret.toString()); - JSONObject Envelope = ret.optJSONObject("soap-env:Envelope"); - JSONObject Body = Envelope.optJSONObject("soap-env:Body"); - JSONObject ZfmGetSoResponse = Body.optJSONObject("n0:ZSd0002SendMatMdResponse"); - JSONObject TZtsalesorder = ZfmGetSoResponse.optJSONObject("TZtsalesorder"); - /* JSONArray item = TZtsalesorder.optJSONArray("item"); - System.out.println("例子：查询结果字段OResultmsg-----------------" + ZfmGetSoResponse.optString("OResultmsg")); - System.out.println("例子：查询结果数组size-----------------" + item.size());*/ - - /*String url = "http://192.168.0.82:8000/sap/bc/srt/rfc/sap/zfg_ecc_to_zhwl/800/zfg_ecc_to_zhwl/binding"; - String method="ZfmGetSo"; //获取销售订单 - HashMap form = new HashMap(); - form.put("IErdatFrm", "2022-05-01"); - form.put("IErdatTo", "2022-05-08"); - //非必填字段 - form.put("IVbeln", ""); - JSONObject ret = WebServiceUtil.process(url,method,form); - System.out.println("getXML发送数据-----------------"+ret.toString()); - JSONObject Envelope = ret.getJSONObject("soap-env:Envelope"); - JSONObject Body = Envelope.getJSONObject("soap-env:Body"); - JSONObject ZfmGetSoResponse = Body.getJSONObject("n0:ZfmGetSoResponse"); - JSONObject TZtsalesorder = ZfmGetSoResponse.getJSONObject("TZtsalesorder"); - JSONArray item = TZtsalesorder.optJSONArray("item"); - System.out.println("例子：查询结果字段OResultmsg-----------------"+ZfmGetSoResponse.optString("OResultmsg")); - System.out.println("例子：查询结果数组size-----------------"+item.size());*/ - - - /* String url = "http://192.168.0.82:8000/sap/bc/srt/rfc/sap/zfg_ecc_to_zhwl/800/zfg_ecc_to_zhwl/binding"; - String method = "ZfmGetDnZjwl"; //获取交货单 - HashMap form = new HashMap(); - form.put("IErdatFrm", "2019-05-01"); - form.put("IErdatTo", "2019-05-08"); - //非必填字段 - form.put("IVbeln", ""); - //非必填字段 - JSONObject ret = WebServiceUtil.process(url, method, form); - System.out.println("getXML发送数据-----------------" + ret.toString()); - JSONObject Envelope = ret.optJSONObject("soap-env:Envelope"); - JSONObject Body = Envelope.optJSONObject("soap-env:Body"); - JSONObject ZfmGetDnZjwlResponse = Body.getJSONObject("n0:ZfmGetDnZjwlResponse"); - JSONObject TZtdn = ZfmGetDnZjwlResponse.getJSONObject("TZtdn"); - JSONArray item = TZtdn.getJSONArray("item"); - System.out.println("例子：查询结果字段OResultmsg-----------------" + ZfmGetDnZjwlResponse.getString("OResultmsg")); - System.out.println("例子：查询结果数组size-----------------" + item.size());*/ - } -} diff --git a/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test4.java b/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test4.java deleted file mode 100644 index 05c810e..0000000 --- a/mes/hd/nladmin-system/src/test/java/org/nl/day01/Test4.java +++ /dev/null @@ -1,7 +0,0 @@ -package org.nl.day01; - -public class Test4 { - public static void main(String[] args) { - System.out.println(); - } -} diff --git a/mes/hd/nladmin-system/src/test/java/org/nl/day01/WebServiceUtil.java b/mes/hd/nladmin-system/src/test/java/org/nl/day01/WebServiceUtil.java deleted file mode 100644 index 71c946d..0000000 --- a/mes/hd/nladmin-system/src/test/java/org/nl/day01/WebServiceUtil.java +++ /dev/null @@ -1,190 +0,0 @@ -package org.nl.day01; - -import cn.hutool.core.util.ObjectUtil; -import cn.hutool.json.XML; -import net.sf.json.JSONArray; -import net.sf.json.JSONObject; - -import java.io.BufferedReader; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.io.OutputStream; -import java.net.HttpURLConnection; -import java.net.URL; -import java.util.HashMap; -import java.util.Iterator; - -/** - * 后端调用第三方webservice接口 - * - * @author zds 2018-12-27 16:33:50 - */ -public class WebServiceUtil { - /** - * @param url 第三方系统提供webservice的接口url - * @param method 第三方系统提供webservice对应的方法名 - * @param form 第三方系统提供webservice对应的方法请求参数 - * @return 第三方系统返回的JSONObject调用结果 - * @throws Exception 工具类一般不处理具体异常，抛出由调用方处理，否则容易形成黑箱 - */ - public static JSONObject process(String url, String method, HashMap form) throws Exception { - - - //第一步：创建服务地址 - URL netUrl = new URL(url); - - //第二步：打开一个通向服务地址的连接 - HttpURLConnection connection = (HttpURLConnection) netUrl.openConnection(); - - //第三步：设置参数 - connection.setRequestMethod("POST"); - //设置超时时间 - connection.setConnectTimeout(50000); - - //3.2设置数据格式：content-type - connection.setRequestProperty("content-type", "text/xml;charset=utf-8"); - - //3.3设置输入输出，因为默认新创建的connection没有读写权限， - connection.setDoInput(true); - - connection.setDoOutput(true); - - - //第四步：组织SOAP数据，发送请求 - String soapXML = getXML(form, method); - - //将信息以流的方式发送出去 - OutputStream os = connection.getOutputStream(); - - os.write(soapXML.getBytes()); - - //第五步：接收服务端响应，打印 - - int responseCode = connection.getResponseCode(); - - //返回结果 - String resultStr = null; - if (200 == responseCode) {//表示服务端响应成功 - - //获取当前连接请求返回的数据流 - InputStream is = connection.getInputStream(); - - InputStreamReader isr = new InputStreamReader(is, "utf-8"); - - BufferedReader br = new BufferedReader(isr); - - StringBuilder sb = new StringBuilder(); - - String temp = null; - - while (null != (temp = br.readLine())) { - sb.append(temp); - } - - //打印结果 - String ret = sb.toString(); - if (ret.startsWith("", ""); - else - ret = (new StringBuilder("")).append(ret).toString(); - - resultStr = XML.toJSONObject(ret).toString(); - - - is.close(); - isr.close(); - br.close(); - //关闭连接 - connection.disconnect(); - } - os.close(); - return ObjectUtil.isEmpty(resultStr) ? null : JSONObject.fromObject(resultStr); - } - - /** - * 获得要发送的webservice的xml形式的参数 - * - * @param form查询条件 - * @return - */ - private static String getXML(HashMap form, String method) { - StringBuffer sb = new StringBuffer(); - sb.append(" "); - sb.append(""); - sb.append(""); - sb.append(""); - sb.append(""); - if (method.contains("ZSd0002SendMatMd")) - sb.append(""); - // 设置请求参数 - for (Iterator it = form.keySet().iterator(); it.hasNext(); ) { - String key = it.next(); - String value = form.get(key); - sb.append(" <" + key + ">" + value + ""); - } - if (method.contains("ZSd0002SendMatMd")) - sb.append(""); - sb.append(""); - sb.append(""); - sb.append(""); - System.out.println("getXML发送数据-----------------" + sb.toString()); - return sb.toString(); - - } - - - public static void main(String[] args) throws Exception { - - String url = "http://192.168.0.82:8000/sap/bc/srt/rfc/sap/z_sd0002_send_mat_md/800/z_sd0002_send_mat_md/binding"; - String method = "ZSd0002SendMatMd"; //物料接口 - HashMap form = new HashMap(); - form.put("MatnrFr", "24018862S"); - form.put("MatnrTo", "24018862S"); - //非必填字段 - JSONObject ret = WebServiceUtil.process(url, method, form); - System.out.println("getXML返回数据-----------------" + ret.toString()); - JSONObject Envelope = ret.optJSONObject("soap-env:Envelope"); - JSONObject Body = Envelope.optJSONObject("soap-env:Body"); - JSONObject ZfmGetSoResponse = Body.optJSONObject("n0:ZSd0002SendMatMdResponse"); - JSONObject TZtsalesorder = ZfmGetSoResponse.optJSONObject("TZtsalesorder"); - JSONArray item = TZtsalesorder.optJSONArray("item"); - System.out.println("例子：查询结果字段OResultmsg-----------------" + ZfmGetSoResponse.optString("OResultmsg")); - System.out.println("例子：查询结果数组size-----------------" + item.size()); - - /*String url = "http://192.168.0.82:8000/sap/bc/srt/rfc/sap/zfg_ecc_to_zhwl/800/zfg_ecc_to_zhwl/binding"; - String method="ZfmGetSo"; //获取销售订单 - HashMap form = new HashMap(); - form.put("IErdatFrm", "2022-05-01"); - form.put("IErdatTo", "2022-05-08"); - //非必填字段 - form.put("IVbeln", ""); - JSONObject ret = WebServiceUtil.process(url,method,form); - System.out.println("getXML发送数据-----------------"+ret.toString()); - JSONObject Envelope = ret.getJSONObject("soap-env:Envelope"); - JSONObject Body = Envelope.getJSONObject("soap-env:Body"); - JSONObject ZfmGetSoResponse = Body.getJSONObject("n0:ZfmGetSoResponse"); - JSONObject TZtsalesorder = ZfmGetSoResponse.getJSONObject("TZtsalesorder"); - JSONArray item = TZtsalesorder.optJSONArray("item"); - System.out.println("例子：查询结果字段OResultmsg-----------------"+ZfmGetSoResponse.optString("OResultmsg")); - System.out.println("例子：查询结果数组size-----------------"+item.size());*/ - - - /* String url = "http://192.168.0.82:8000/sap/bc/srt/rfc/sap/zfg_ecc_to_zhwl/800/zfg_ecc_to_zhwl/binding"; - String method = "ZfmGetDnZjwl"; //获取交货单 - HashMap form = new HashMap(); - form.put("IErdatFrm", "2019-05-01"); - form.put("IErdatTo", "2019-05-08"); - //非必填字段 - form.put("IVbeln", ""); - //非必填字段 - JSONObject ret = WebServiceUtil.process(url, method, form); - System.out.println("getXML发送数据-----------------" + ret.toString()); - JSONObject Envelope = ret.optJSONObject("soap-env:Envelope"); - JSONObject Body = Envelope.optJSONObject("soap-env:Body"); - JSONObject ZfmGetDnZjwlResponse = Body.getJSONObject("n0:ZfmGetDnZjwlResponse"); - JSONObject TZtdn = ZfmGetDnZjwlResponse.getJSONObject("TZtdn"); - JSONArray item = TZtdn.getJSONArray("item"); - System.out.println("例子：查询结果字段OResultmsg-----------------" + ZfmGetDnZjwlResponse.getString("OResultmsg")); - System.out.println("例子：查询结果数组size-----------------" + item.size());*/ - } -} diff --git a/mes/hd/nladmin-system/src/test/java/org/nl/mongodb/Test.java b/mes/hd/nladmin-system/src/test/java/org/nl/mongodb/Test.java deleted file mode 100644 index 771192c..0000000 --- a/mes/hd/nladmin-system/src/test/java/org/nl/mongodb/Test.java +++ /dev/null @@ -1,59 +0,0 @@ -package org.nl.mongodb; - -import org.springframework.data.domain.Page; - -public class Test { - - - public Page test2(Integer currentPage, Integer pageSize, Long loanApplyId) { - /* //创建查询对象 - Query query = new Query(); - //设置起始数 - query.skip((currentPage - 1) * pageSize); - //设置查询条数 - query.limit(pageSize); - Criteria criteria = new Criteria(); - criteria.where("loanApplyId").is(loanApplyId); - //查询当前页数据集合 - List ApplyLogList = mongoTemplate.find(query, ApplyLog.class); - //查询总记录数 - int count = (int) mongoTemplate.count(query, ApplyLog.class); - //创建分页实体对象 - Page page = new Page<>(); - //添加每页的集合、数据总条数、总页数 - page.setRecords(ApplyLogList); - page.setSize(count); - page.setTotal(count % pageSize == 0 ? 1 : count / pageSize + 1); - return page; -*/ - return null; - } - - public void test() { - /* int pageNo = 1; - int pageSize = 10; - - // limit限定查询2条 - Query query = Query.query(Criteria.where("user").is("一灰灰blog").and("a").is("b").and("")).with(Sort.by("age")).limit(2); - //Query query = Query.query(Criteria.where("user").is("一灰灰blog")).with(Sort.by("age")).limit(2); - // Pageable pageable = PageRequest.of(page,size); - List result = mongoTemplate.find(query, Map.class, "logdb"); - System.out.println("query: " + query + " | limitPageQuery " + result); - - - // skip()方法来跳过指定数量的数据 - query = Query.query(Criteria.where("user").is("一灰灰blog")).with(Sort.by("age")).skip(2); - result = mongoTemplate.find(query, Map.class, "logdb"); - System.out.println("query: " + query + " | skipPageQuery " + result); - - - - Query query = new Query(new Criteria()); - query.with(Sort.by(Sort.Direction.DESC, "time")); - mongoUtil.start(2, 2, query); - List teachers = mongoTemplate.find(query, Teacher.class); - long count = mongoTemplate.count(query, Teacher.class); - PageHelper pageHelper = mongoUtil.pageHelper(count, teachers);*/ - - } -} diff --git a/mes/hd/pom.xml b/mes/hd/pom.xml index 524055f..f88e6c5 100644 --- a/mes/hd/pom.xml +++ b/mes/hd/pom.xml @@ -5,7 +5,7 @@ 4.0.0 org.nl - hl_one_wms + yy_lms pom 1.0-SNAPSHOT 开发平台