12/27 龙海中医院

src/main/java/com/glxp/mipsdl/client/lhzyy/LhzyyClient.java

@@ -0,0 +1,200 @@
+package com.glxp.mipsdl.client.lhzyy;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.glxp.mipsdl.client.CommonHttpClient;
+import com.glxp.mipsdl.config.ThirdSysConfig;
+import com.glxp.mipsdl.constant.ConstantType;
+import com.glxp.mipsdl.constant.Constants;
+import com.glxp.mipsdl.dao.auth.AuthWarehouseDao;
+import com.glxp.mipsdl.dao.basic.BasicBussinessTypeDao;
+import com.glxp.mipsdl.dao.basic.BasicCorpDao;
+import com.glxp.mipsdl.dao.basic.BasicUdirelDao;
+import com.glxp.mipsdl.dao.inout.IoCodeDao;
+import com.glxp.mipsdl.dao.inout.IoOrderDao;
+import com.glxp.mipsdl.dao.inout.IoOrderDetailBizDao;
+import com.glxp.mipsdl.dao.thrsys.ThrBustypeOriginDao;
+import com.glxp.mipsdl.dao.thrsys.ThrInvWarehouseDao;
+import com.glxp.mipsdl.dao.thrsys.ThrProductsDao;
+import com.glxp.mipsdl.dao.thrsys.ThrSystemBusApiDao;
+import com.glxp.mipsdl.entity.auth.AuthWarehouseEntity;
+import com.glxp.mipsdl.entity.basic.BasicBussinessTypeEntity;
+import com.glxp.mipsdl.entity.basic.BasicUdirelEntity;
+import com.glxp.mipsdl.entity.inout.IoCodeEntity;
+import com.glxp.mipsdl.entity.inout.IoOrderDetailBizEntity;
+import com.glxp.mipsdl.entity.inout.IoOrderEntity;
+import com.glxp.mipsdl.entity.thrsys.ThrCorpEntity;
+import com.glxp.mipsdl.entity.thrsys.ThrInvWarehouseEntity;
+import com.glxp.mipsdl.entity.thrsys.ThrProductsEntity;
+import com.glxp.mipsdl.entity.thrsys.ThrSystemBusApiEntity;
+import com.glxp.mipsdl.http.HttpClient;
+import com.glxp.mipsdl.req.base.*;
+import com.glxp.mipsdl.req.dsxyy.DsOrderRequest;
+import com.glxp.mipsdl.req.lhzyy.LhProductRequest;
+import com.glxp.mipsdl.req.lhzyy.LhUnitRequest;
+import com.glxp.mipsdl.req.post.PostFileThrOrderRequest;
+import com.glxp.mipsdl.req.post.PostThrCorpRequest;
+import com.glxp.mipsdl.req.post.PostThrInvProductsRequest;
+import com.glxp.mipsdl.req.post.PostThrProductsRequest;
+import com.glxp.mipsdl.req.yxzyy.YxBusTypeRequest;
+import com.glxp.mipsdl.req.yxzyy.YxProductRequest;
+import com.glxp.mipsdl.req.yxzyy.YxUnitRequest;
+import com.glxp.mipsdl.res.BaseResponse;
+import com.glxp.mipsdl.service.auth.AuthWarehouseService;
+import com.glxp.mipsdl.service.thrsys.ThrCorpService;
+import com.glxp.mipsdl.service.thrsys.ThrSystemDetailService;
+import com.glxp.mipsdl.util.DateUtil;
+import com.glxp.mipsdl.util.DictUtl;
+import com.glxp.mipsdl.util.ResultVOUtils;
+import com.glxp.mipsdl.util.SubmitOrderUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * 龙海中医院物资系统对接接口实现
+ */
+@Slf4j
+@Service(value = "100016HttpClient") //bean注册名称，使用编码 + HttpClient，文件接口加 FileClient
+public class LhzyyClient extends CommonHttpClient {
+
+    @Resource
+    private ThrSystemDetailService thrSystemDetailService;
+    @Resource
+    private HttpClient httpClient;
+    @Resource
+    private ThrBustypeOriginDao thrBustypeOriginDao;
+    @Resource
+    private IoOrderDao orderDao;
+    @Resource
+    private ThrSystemBusApiDao thrSystemBusApiDao;
+    @Resource
+    private BasicBussinessTypeDao basicBussinessTypeDao;
+    @Resource
+    private BasicCorpDao basicCorpDao;
+    @Resource
+    private IoCodeDao codeDao;
+    @Resource
+    private AuthWarehouseDao authWarehouseDao;
+    @Resource
+    private ThrInvWarehouseDao thrInvWarehouseDao;
+    @Resource
+    private AuthWarehouseService authWarehouseService;
+    @Resource
+    private ThirdSysConfig thirdSysConfig;
+    @Resource
+    private ThrCorpService thrCorpService;
+    @Resource
+    private IoOrderDetailBizDao orderDetailBizDao;
+    @Resource
+    private SubmitOrderUtil submitOrderUtil;
+    @Resource
+    private ThrProductsDao thrProductsDao;
+    @Resource
+    private BasicUdirelDao basicUdirelDao;
+
+    @Override
+    public BaseResponse getUnit(UdiwmsUnitRequest udiwmsUnitRequest) {
+        LhUnitRequest lhUnitRequest = new LhUnitRequest();
+        BeanUtil.copyProperties(udiwmsUnitRequest, lhUnitRequest);
+        String response = httpClient.postJson(thrSystemDetailService.getUrl(Constants.URL_NAME_CORP_URL), lhUnitRequest);
+        BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class);
+        return baseResponse;
+    }
+
+    @Override
+    public BaseResponse getProducts(UdiwmsProductRequest udiwmsProductRequest) {
+        LhProductRequest lhProductRequest = new LhProductRequest();
+        BeanUtil.copyProperties(udiwmsProductRequest, lhProductRequest);
+        String response = httpClient.postJson(thrSystemDetailService.getUrl(Constants.URL_NAME_PI_QUERY_URL), lhProductRequest);
+        BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class);
+        return baseResponse;
+    }
+
+    @Override
+    public BaseResponse getWarehouse(UdiwmsWarehouseRequest udiwmsWarehouseRequest) {
+        String response = httpClient.postJson(thrSystemDetailService.getUrl(Constants.URL_NAME_WAREHOUSE_QUERY_URL), udiwmsWarehouseRequest);
+        BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class);
+        return baseResponse;
+    }
+
+    @Override
+    public BaseResponse getOrderTypes(UdiwmsBusTypeRequest udiwmsBusTypeRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse getOrders(UdiwmsOrderQueryRequest udiwmsOrderQueryRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse submitOrders(UdiwmsOrderRequest udiwmsOrderRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse getInvProducts(UdiwmsInvProductsRequest udiwmsInvProductsRequest) {
+       return  null;
+    }
+
+
+
+    @Override
+    public BaseResponse postProducts(PostThrProductsRequest postThrProductsRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse postCorps(PostThrCorpRequest postThrCorpRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse postOrderDetail(PostFileThrOrderRequest postFileThrOrderRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse postInvProducts(PostThrInvProductsRequest postThrInvProductsRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse testConnect() {
+        UdiwmsUnitRequest udiwmsUnitRequest = new UdiwmsUnitRequest();
+        udiwmsUnitRequest.setPage(1);
+        udiwmsUnitRequest.setLimit(1);
+        BaseResponse baseResponse = getUnit(udiwmsUnitRequest);
+        if (baseResponse.getCode() == 20000) {
+            return ResultVOUtils.success("连接成功");
+        }
+        return ResultVOUtils.error(500, "连接失败！");
+    }
+
+    @Override
+    public BaseResponse queryUdiInvProducts(UdiwmsQueryUdiInvProductsRequest queryUdiInvProductsRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse submitProducts(UdiwmsAddProductsRequest udiwmsAddProductsRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse submitUnit(UdiwmsAddUnitRequest udiwmsAddUnitRequest) {
+        return null;
+    }
+
+    @Override
+    public BaseResponse submitPreInOrders(UdiwmsPreInOrderRequest udiwmsPreInOrderRequest) {
+        return null;
+    }
+}

src/main/java/com/glxp/mipsdl/http/HttpClient.java

@@ -65,6 +65,7 @@ public class HttpClient {
         Date date = new Date();
         //转json字符串时，将空属性转换为空字符串
         String json = JSONObject.toJSONString(object);
+        log.error("发送的请求：" + json);
         log.info(url + "\n" + json);
         String response = "";
         Integer status;

src/main/java/com/glxp/mipsdl/req/base/ListPageRequest.java

@@ -22,8 +22,6 @@ public class ListPageRequest {
     private String orderBy;
     private String sort;
 
-    public Page getPageObj() {
-        return new Page(this.page == null ? 1 : this.page, this.limit == null ? 10 : this.limit);
-    }
+
 
 }

src/main/java/com/glxp/mipsdl/req/base/UdiwmsProductRequest.java

@@ -11,7 +11,6 @@ import java.util.List;
  */
 @Data
 public class UdiwmsProductRequest extends ListPageRequest {
-    private List<ThrProductsEntity> thrProductsEntities;
 
     /**
      * 产品编码

src/main/java/com/glxp/mipsdl/req/lhzyy/LhProductRequest.java

@@ -0,0 +1,11 @@
+package com.glxp.mipsdl.req.lhzyy;
+
+import com.glxp.mipsdl.req.base.UdiwmsProductRequest;
+import lombok.Data;
+
+/**
+ * 龙海中医院获取产品列表接口参数
+ */
+@Data
+public class LhProductRequest extends UdiwmsProductRequest {
+}

src/main/java/com/glxp/mipsdl/req/lhzyy/LhUnitRequest.java

@@ -0,0 +1,14 @@
+package com.glxp.mipsdl.req.lhzyy;
+
+import com.glxp.mipsdl.req.base.UdiwmsUnitRequest;
+import lombok.Data;
+
+import javax.validation.constraints.Max;
+import javax.validation.constraints.Min;
+
+/**
+ * 龙海中医院获取往来单位列表接口参数
+ */
+@Data
+public class LhUnitRequest extends UdiwmsUnitRequest{
+}

src/main/resources/application-pro.yml

@@ -9,19 +9,6 @@ spring:
           username: root
           password: Glxp@6066
           driver-class-name: com.mysql.cj.jdbc.Driver
-        hlfyyySql:
-          driver-class-name: oracle.jdbc.driver.OracleDriver
-          url: jdbc:oracle:thin:@192.168.158.251:1521/hlfy
-          username: PZH
-          password: zy02v4ph
-          hikari:
-            connection-timeout: 60000
-            maximum-pool-size: 60
-            minimum-idle: 10
-        hikari:
-          connection-timeout: 60000
-          maximum-pool-size: 60
-          minimum-idle: 10
     hikari:
       connection-timeout: 60000
       maximum-pool-size: 60