武汉黄陂军粮-增加WMS立体库接口整体结构

CZT

2023-07-23 988a25cb2ef013e9493da76c3035bcb5bee0da81

武汉黄陂军粮-增加WMS立体库接口整体结构

 igds-api-inte/src/main/java/com/ld/igds/wms/constant/WmsCodeEnum.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,42 @@
package com.ld.igds.wms.constant;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口-响应码
 *
 * @author czt
 */
public enum WmsCodeEnum {

    WMS_CODE_0000("0000", "请求成功"),
    WMS_CODE_1111("1111", "后端服务异常"),
    WMS_CODE_1001("1001", "无权访问"),
    WMS_CODE_1002("1002", "参数有误"),
    WMS_CODE_1003("1003", "无此接口信息"),
    WMS_CODE_1004("1004", "通讯失败")
    ;

    private String code;
    private String msg;

    WmsCodeEnum(String code, String msg) {
        this.code = code;
        this.msg = msg;
    }

    public String getCode() {
        return code;
    }

    public void setCode(String code) {
        this.code = code;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }
	
}

 igds-api-inte/src/main/java/com/ld/igds/wms/constant/WmsConstant.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.ld.igds.wms.constant;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口-接口编码
 *
 * @author czt
 */
public class WmsConstant {

    /**
     * ================= æŽ¥å£ç¼–码 =================
     */
    public static final String API_WMS_1001 = "1001";
    public static final String API_WMS_1002 = "1002";
    public static final String API_WMS_1003 = "1003";
    public static final String API_WMS_1004 = "1004";
}

 igds-api-inte/src/main/java/com/ld/igds/wms/controller/WmsController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,79 @@
package com.ld.igds.wms.controller;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.constant.WmsCodeEnum;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;
import com.ld.igds.wms.manager.WmsManager;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口
 *
 * @author czt
 */
@Slf4j
@RestController
@RequestMapping("api/wms/v1")
public class WmsController {

    @Autowired
    private WmsManager wmsManager;

    /**
     * ä¸šåŠ¡å…¥å£
     * @param request
     * @return
     */
    @ResponseBody
    @RequestMapping("/gateway")
    public WmsResponse gateway(@RequestBody WmsRequest<JSONObject> request) {

        log.info("-----立体库-----收到的消息={}-----", request);

        //判断参数
        if (null == request) {
            return new WmsResponse(WmsCodeEnum.WMS_CODE_1002.getCode(), WmsCodeEnum.WMS_CODE_1002.getMsg());
        }

        //判断接口编码
        if (null == request.getInterfaceId()) {
            return new WmsResponse(WmsCodeEnum.WMS_CODE_1002.getCode(), WmsCodeEnum.WMS_CODE_1002.getMsg());
        }

        //判断数据
        if (null == request.getData()) {
            return new WmsResponse(WmsCodeEnum.WMS_CODE_1002.getCode(), WmsCodeEnum.WMS_CODE_1002.getMsg());
        }

        WmsResponse result;
        try{
            //异步处理，子线程解析事件
            final ExecutorService exec = Executors.newFixedThreadPool(1);
            Callable<String> call = new Callable<String>() {
                public String call() throws Exception {

                    //执行业务操作
                    WmsResponse wmsResponse =  wmsManager.execute(request);
                    return wmsResponse.getMsg();
                }
            };
            exec.submit(call);
            exec.shutdown();
            result = new WmsResponse(WmsCodeEnum.WMS_CODE_0000.getCode(), WmsCodeEnum.WMS_CODE_0000.getMsg());

        }catch (Exception e){

            log.error("----立体库信息解析异常={}-----", e.getLocalizedMessage());

            //后端异常
            result = new WmsResponse(WmsCodeEnum.WMS_CODE_1111.getCode(), WmsCodeEnum.WMS_CODE_1111.getMsg());
        }
        return result;
    }
}

 igds-api-inte/src/main/java/com/ld/igds/wms/data/WmsParam.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,74 @@
package com.ld.igds.wms.data;

import lombok.Data;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口
 * æ•°æ®å°è£…
 *
 * @author czt
 */
@Data
public class WmsParam {

    /**
     * ä»»åŠ¡ç¼–号
     */
    private String taskNo;

    /**
     * å“å
     */
    private String productName;

    /**
     * è§„æ ¼
     */
    private String productType;

    /**
     * ç”Ÿäº§æ—¥æœŸ
     */
    private String productDate;

    /**
     * æ‰¹æ¬¡
     */
    private String productBatch;

    /**
     * æ•°é‡
     */
    private String loadQuantity;

    /**
     * å‡ºåº“类型库位名
     */
    private String fromLocationCode;

    /**
     * å…¥åº“类型库位名
     */
    private String toLocationCode;

    /**
     * ç§»åº“类型库位名
     */
    private String toPort;

    /**
     * æ‰˜ç›˜ç¼–号
     */
    private String containerCode;

    /**
     * æ˜¯å¦åˆæ ¼
     */
    private String passOrNoPass;

    /**
     * ä»“库名称
     */
    private String deptName;

}

 igds-api-inte/src/main/java/com/ld/igds/wms/data/WmsRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
package com.ld.igds.wms.data;

import lombok.Data;
import java.io.Serializable;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口-请求参数
 *
 * @author czt
 */
@Data
public class WmsRequest<T> implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * æŽ¥å£ç¼–码
     */
    private String interfaceId;


    /**
     * è¯·æ±‚时间(yyyy-MM-dd HH:mm:ss)
     */
    private String reqDateTime;

    /**
     * ä¸šåŠ¡æ•°æ®
     */
    private T data;
}

 igds-api-inte/src/main/java/com/ld/igds/wms/data/WmsResponse.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.ld.igds.wms.data;

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口,响应数据封装
 *
 * @author czt
 */
@Data
public class WmsResponse implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * å“åº”编码
     */
    private String code;

    /**
     * å“åº”信息
     */
    private String msg;


    /**
     * å“åº”时间(yyyy-MM-dd HH:mm:ss)
     */
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date resDateTime;


    public WmsResponse() {
        super();
    }

    public WmsResponse(String code, String msg) {
        this.code = code;
        this.msg = msg;
        this.resDateTime = new Date();
    }
}

 igds-api-inte/src/main/java/com/ld/igds/wms/manager/WmsManager.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,54 @@
package com.ld.igds.wms.manager;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.constant.WmsCodeEnum;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;
import com.ld.igds.wms.service.WmsService;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口
 * ä¸šåŠ¡æŽ¥å£åˆ†å‘
 *
 * @author czt
 */
@Component
public class WmsManager implements ApplicationContextAware {

    private static Map<String, WmsService> serviceMap;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        Map<String, WmsService> map = applicationContext.getBeansOfType(WmsService.class);
        serviceMap = new HashMap<>();
        for (String key : map.keySet()) {
            serviceMap.put(map.get(key).getInterfaceId(), map.get(key));
        }
    }


    /**
     * ä¸šåŠ¡æ‰§è¡Œå…¥å£
     * @param req
     * @return
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    public WmsResponse execute(WmsRequest<JSONObject> req) throws Exception{

        WmsService service = serviceMap.get(req.getInterfaceId());

        if(null == service){
            //通讯失败
            return new WmsResponse(WmsCodeEnum.WMS_CODE_1004.getCode(), WmsCodeEnum.WMS_CODE_1004.getMsg());
        }

        return service.execute(req);
    }
}

 igds-api-inte/src/main/java/com/ld/igds/wms/service/WmsService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,29 @@
package com.ld.igds.wms.service;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;

/**
 * æ­¦æ±‰é»„陂军粮-立体库接口
 * ä¸šåŠ¡æŽ¥å£åˆ†å‘
 *
 * @author czt
 */
public interface WmsService {

    /**
     * èŽ·å–接口编码
     *
     * @return
     */
    public String getInterfaceId();

    /**
     * ä¸šåŠ¡æ‰§è¡Œ
     * @param req
     * @return
     * @throws Exception
     */
    public WmsResponse execute(WmsRequest<JSONObject> req) throws Exception;
}

 igds-api-inte/src/main/java/com/ld/igds/wms/service/impl/WmsServiceImpl1001.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.ld.igds.wms.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.constant.WmsCodeEnum;
import com.ld.igds.wms.constant.WmsConstant;
import com.ld.igds.wms.data.WmsParam;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;
import com.ld.igds.wms.service.WmsService;
import org.springframework.stereotype.Service;

/**
 * 1001-入库
 *
 * @author czt
 */
@Service
public class WmsServiceImpl1001 implements WmsService {


    @Override
    public String getInterfaceId() {
        return WmsConstant.API_WMS_1001;
    }

    @SuppressWarnings("unchecked")
    @Override
    public WmsResponse execute(WmsRequest<JSONObject> req){
        //转化请求参数
        WmsParam param = JSONObject.parseObject(req.getData().toString(), WmsParam.class);

        //TODO è§£æžæ•°æ®



        //请求成功
        return new WmsResponse(WmsCodeEnum.WMS_CODE_0000.getCode(), WmsCodeEnum.WMS_CODE_0000.getMsg());
    }
}

 igds-api-inte/src/main/java/com/ld/igds/wms/service/impl/WmsServiceImpl1002.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.ld.igds.wms.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.constant.WmsCodeEnum;
import com.ld.igds.wms.constant.WmsConstant;
import com.ld.igds.wms.data.WmsParam;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;
import com.ld.igds.wms.service.WmsService;
import org.springframework.stereotype.Service;

/**
 * 1002-出库
 *
 * @author czt
 */
@Service
public class WmsServiceImpl1002 implements WmsService {


    @Override
    public String getInterfaceId() {
        return WmsConstant.API_WMS_1001;
    }

    @SuppressWarnings("unchecked")
    @Override
    public WmsResponse execute(WmsRequest<JSONObject> req){
        //转化请求参数
        WmsParam param = JSONObject.parseObject(req.getData().toString(), WmsParam.class);

        //TODO è§£æžæ•°æ®

        

        //请求成功
        return new WmsResponse(WmsCodeEnum.WMS_CODE_0000.getCode(), WmsCodeEnum.WMS_CODE_0000.getMsg());
    }
}

 igds-api-inte/src/main/java/com/ld/igds/wms/service/impl/WmsServiceImpl1003.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.ld.igds.wms.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.constant.WmsCodeEnum;
import com.ld.igds.wms.constant.WmsConstant;
import com.ld.igds.wms.data.WmsParam;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;
import com.ld.igds.wms.service.WmsService;
import org.springframework.stereotype.Service;

/**
 * 1003-移库
 *
 * @author czt
 */
@Service
public class WmsServiceImpl1003 implements WmsService {


    @Override
    public String getInterfaceId() {
        return WmsConstant.API_WMS_1003;
    }

    @SuppressWarnings("unchecked")
    @Override
    public WmsResponse execute(WmsRequest<JSONObject> req){
        //转化请求参数
        WmsParam param = JSONObject.parseObject(req.getData().toString(), WmsParam.class);

        //TODO è§£æžæ•°æ®

        

        //请求成功
        return new WmsResponse(WmsCodeEnum.WMS_CODE_0000.getCode(), WmsCodeEnum.WMS_CODE_0000.getMsg());
    }
}

 igds-api-inte/src/main/java/com/ld/igds/wms/service/impl/WmsServiceImpl1004.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.ld.igds.wms.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.constant.WmsCodeEnum;
import com.ld.igds.wms.constant.WmsConstant;
import com.ld.igds.wms.data.WmsParam;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;
import com.ld.igds.wms.service.WmsService;
import org.springframework.stereotype.Service;

/**
 * 1004-库存
 *
 * @author czt
 */
@Service
public class WmsServiceImpl1004 implements WmsService {


    @Override
    public String getInterfaceId() {
        return WmsConstant.API_WMS_1004;
    }

    @SuppressWarnings("unchecked")
    @Override
    public WmsResponse execute(WmsRequest<JSONObject> req){
        //转化请求参数
        WmsParam param = JSONObject.parseObject(req.getData().toString(), WmsParam.class);

        //TODO è§£æžæ•°æ®

        

        //请求成功
        return new WmsResponse(WmsCodeEnum.WMS_CODE_0000.getCode(), WmsCodeEnum.WMS_CODE_0000.getMsg());
    }
}

 igds-web/pom.xml

@@ -143,12 +143,12 @@
        </dependency>


        <!-- æŽ¥å£åŒ…，包括上海接口和气象接口
        <!-- æŽ¥å£åŒ…，包括上海接口和气象接口-->
        <dependency>
            <groupId>com.ld.igds</groupId>
            <artifactId>igds-api-inte</artifactId>
            <version>${igds.version}</version>
        </dependency> -->
        </dependency>


        <!--  ç§æœ‰åè®®-风正致远-->
@@ -252,54 +252,54 @@
            </plugin>

            <!-- YUI Compressor Maven压缩插件 å¼€å‘包不实用-->
<!--            <plugin>-->
<!--                <groupId>net.alchim31.maven</groupId>-->
<!--                <artifactId>yuicompressor-maven-plugin</artifactId>-->
<!--                <version>1.5.1</version>-->
<!--                <executions>-->
<!--                    <execution>-->
<!--                        <goals>-->
<!--                            <goal>compress</goal>-->
<!--                        </goals>-->
<!--                    </execution>-->
<!--                </executions>-->
<!--                <configuration>-->
<!--                    <encoding>UTF-8</encoding>-->
<!--                    &lt;!&ndash;不显示js可能的错误 &ndash;&gt;-->
<!--                    <jswarn>false</jswarn>-->
<!--                    &lt;!&ndash;是否混淆 &ndash;&gt;-->
<!--                    <nomunge>true</nomunge>-->
<!--                    &lt;!&ndash;若存在已压缩的文件，会先对比源文件是否有改动 æœ‰æ”¹åŠ¨ä¾¿åŽ‹ç¼©ï¼Œæ— æ”¹åŠ¨å°±ä¸åŽ‹ç¼© &ndash;&gt;-->
<!--                    <force>false</force>-->
<!--                    &lt;!&ndash;在指定的列号后插入新行 &ndash;&gt;-->
<!--                    <linebreakpos>-1</linebreakpos>-->
<!--                    &lt;!&ndash;压缩之前先执行聚合文件操作 &ndash;&gt;-->
<!--                    <preProcessAggregates>true</preProcessAggregates>-->
<!--                    &lt;!&ndash;压缩后保存文件后缀 æ— åŽç¼€ &ndash;&gt;-->
<!--                    <nosuffix>true</nosuffix>-->
<!--                    &lt;!&ndash;源目录，即需压缩的根目录 &ndash;&gt;-->
<!--                    <sourceDirectory>src/main/resources</sourceDirectory>-->
<!--                    &lt;!&ndash;输出目录，即压缩后的目录 &ndash;&gt;-->
<!--                    <outputDirectory>target/classes</outputDirectory>-->
<!--                    <force>true</force>-->
<!--                    &lt;!&ndash;压缩js和css文件 &ndash;&gt;-->
<!--                    <includes>-->
<!--                        <include>**/*.js</include>-->
<!--                        <include>**/*.css</include>-->
<!--                    </includes>-->
<!--                    &lt;!&ndash; ä»¥ä¸‹ç›®å½•å’Œæ–‡ä»¶ä¸ä¼šè¢«åŽ‹ç¼© &ndash;&gt;-->
<!--                    <excludes>-->
<!--                        <exclude>**/*.min.js</exclude>-->
<!--                        <exclude>**/*.min.css</exclude>-->
<!--                        <exclude>**/d7/**</exclude>-->
<!--                        <exclude>**/dorado-home/**</exclude>-->
<!--                        <exclude>**/bdf2/**</exclude>-->
<!--                        <exclude>**/css/**</exclude>-->
<!--                        <exclude>**/js/**</exclude>-->
<!--                        <exclude>**/plugins/**</exclude>-->
<!--                    </excludes>-->
<!--                </configuration>-->
<!--            </plugin>-->
            <plugin>
                <groupId>net.alchim31.maven</groupId>
                <artifactId>yuicompressor-maven-plugin</artifactId>
                <version>1.5.1</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>compress</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <encoding>UTF-8</encoding>
                    <!--不显示js可能的错误 -->
                    <jswarn>false</jswarn>
                    <!--是否混淆 -->
                    <nomunge>true</nomunge>
                    <!--若存在已压缩的文件，会先对比源文件是否有改动 æœ‰æ”¹åŠ¨ä¾¿åŽ‹ç¼©ï¼Œæ— æ”¹åŠ¨å°±ä¸åŽ‹ç¼© -->
                    <force>false</force>
                    <!--在指定的列号后插入新行 -->
                    <linebreakpos>-1</linebreakpos>
                    <!--压缩之前先执行聚合文件操作 -->
                    <preProcessAggregates>true</preProcessAggregates>
                    <!--压缩后保存文件后缀 æ— åŽç¼€ -->
                    <nosuffix>true</nosuffix>
                    <!--源目录，即需压缩的根目录 -->
                    <sourceDirectory>src/main/resources</sourceDirectory>
                    <!--输出目录，即压缩后的目录 -->
                    <outputDirectory>target/classes</outputDirectory>
                    <force>true</force>
                    <!--压缩js和css文件 -->
                    <includes>
                        <include>**/*.js</include>
                        <include>**/*.css</include>
                    </includes>
                    <!-- ä»¥ä¸‹ç›®å½•å’Œæ–‡ä»¶ä¸ä¼šè¢«åŽ‹ç¼© -->
                    <excludes>
                        <exclude>**/*.min.js</exclude>
                        <exclude>**/*.min.css</exclude>
                        <exclude>**/d7/**</exclude>
                        <exclude>**/dorado-home/**</exclude>
                        <exclude>**/bdf2/**</exclude>
                        <exclude>**/css/**</exclude>
                        <exclude>**/js/**</exclude>
                        <exclude>**/plugins/**</exclude>
                    </excludes>
                </configuration>
            </plugin>

        </plugins>


 igds-web/src/main/resources/application.yml

@@ -1,7 +1,7 @@
##########################  Server   ########################## ä¸¹æ£±åŸŽå…³çœç²®é£Ÿå‚¨å¤‡åº“
spring:
  profiles:
    active: pro5012
    active: linux
  application:
    name: igds
  main:

 igds-web/src/main/resources/dorado-home/datasources.xml

@@ -76,6 +76,9 @@
    <!--放开上海佑卓接口-->
    <bdf:anonymous-url urlPattern="/api/sh/**" />

    <!--放开武汉黄陂立体库接口-->
    <bdf:anonymous-url urlPattern="/api/wms/**" />

    <!--放开海康流媒体事件接收接口-->
    <bdf:anonymous-url urlPattern="/eventRcv/**" />
    <!--插件推送粮情接收接口-->