bug修改，提供协调平台追溯查询接口

src/main/java/com/glxp/api/controller/inout/IoOrderDetailResultController.java

@@ -3,6 +3,7 @@ package com.glxp.api.controller.inout;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.github.pagehelper.PageInfo;
 import com.glxp.api.annotation.AuthRuleAnnotation;
 import com.glxp.api.common.enums.ResultEnum;
@@ -10,22 +11,24 @@ import com.glxp.api.common.res.BaseResponse;
 import com.glxp.api.common.util.ResultVOUtils;
 import com.glxp.api.constant.ConstantType;
 import com.glxp.api.controller.BaseController;
+import com.glxp.api.entity.auth.AuthCompany;
 import com.glxp.api.entity.basic.BasicBussinessTypeEntity;
 import com.glxp.api.entity.inout.IoOrderDetailBizEntity;
 import com.glxp.api.entity.inout.IoOrderDetailCodeEntity;
 import com.glxp.api.entity.inout.IoOrderEntity;
 import com.glxp.api.entity.system.SysPdfTemplateRelevanceStatemenEntity;
 import com.glxp.api.entity.system.SystemPDFTemplateEntity;
-import com.glxp.api.req.inout.FilterCodeRequest;
+import com.glxp.api.req.inout.*;
-import com.glxp.api.req.inout.FilterOrderDetailResultRequest;
+import com.glxp.api.res.inout.CptTraceOrderResponse;
-import com.glxp.api.req.inout.FilterOrderRequest;
+import com.glxp.api.res.inout.CptTraceResultResponse;
-import com.glxp.api.req.inout.InspectionPDFTemplateRequest;
 import com.glxp.api.res.inout.IoCodeResponse;
 import com.glxp.api.res.inout.IoOrderDetailResultResponse;
+import com.glxp.api.service.auth.AuthCompanyService;
 import com.glxp.api.service.basic.IBasicBussinessTypeService;
 import com.glxp.api.service.inout.*;
 import com.glxp.api.service.system.SystemPDFModuleService;
 import com.glxp.api.service.system.SystemPDFTemplateService;
+import com.glxp.api.util.DateUtil;
 import com.glxp.api.util.JasperUtils;
 import net.sf.jasperreports.engine.JRException;
 import org.springframework.beans.factory.annotation.Value;
@@ -40,10 +43,7 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.text.SimpleDateFormat;
-import java.util.ArrayList;
+import java.util.*;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
 
 /**
  * 单据扫码明细查询接口
@@ -64,6 +64,8 @@ public class IoOrderDetailResultController extends BaseController {
     private SystemPDFModuleService systemPDFModuleService;
     @Value("${file_path}")
     private String filePath;
+    @Resource
+    AuthCompanyService authCompanyService;
 
     /**
      * 查询单据扫码明细列表
@@ -183,7 +185,6 @@ public class IoOrderDetailResultController extends BaseController {
         return ResultVOUtils.success(sysPdfTemplateRelevanceStatemenEntity.getTemplateId());
     }
 
-
     /**
      * 出入库明细打印
      *
@@ -256,4 +257,50 @@ public class IoOrderDetailResultController extends BaseController {
         return ResultVOUtils.success();
     }
 
+
+    /**
+     * 提供UDI协调调用单据明细
+     */
+    @PostMapping("/udiCpt/inout/trace/search")
+    public BaseResponse cptTraceOrder(@RequestBody CptTraceRequest cptTraceRequest) {
+        if (StrUtil.isEmpty(cptTraceRequest.getBatchNo()) || CollUtil.isEmpty(cptTraceRequest.getDiList())) {
+            return ResultVOUtils.error(500, "参数有误！");
+        }
+        AuthCompany authCompany = authCompanyService.getOne(new QueryWrapper<>());
+        List<CptTraceOrderResponse> cptTraceOrderResponses = orderDetailResultService.cptTrace(cptTraceRequest);
+        List<CptTraceResultResponse> cptTraceResultResponses = new ArrayList<>();
+        if (CollUtil.isNotEmpty(cptTraceOrderResponses)) {
+            for (CptTraceOrderResponse cptTraceOrderResponse : cptTraceOrderResponses) {
+
+                CptTraceResultResponse cptTraceResultResponse = new CptTraceResultResponse();
+                cptTraceResultResponse.setBillNo(cptTraceOrderResponse.getBillNo());
+                cptTraceResultResponse.setBillDate(DateUtil.formatDate(cptTraceOrderResponse.getCreateTime()));
+                cptTraceResultResponse.setBillType(cptTraceOrderResponse.getBillType());
+
+                if (cptTraceOrderResponse.getMainAction().equals(ConstantType.TYPE_OUT)) {
+                    if (StrUtil.isNotEmpty(cptTraceOrderResponse.getFromInvCode()))
+                        continue;
+                    cptTraceResultResponse.setInOutType(2);
+                    cptTraceResultResponse.setFromCorp(authCompany.getName());
+                    cptTraceResultResponse.setFromCorpCreditNum(authCompany.getCreditCode());
+
+                } else {
+                    cptTraceResultResponse.setInOutType(1);
+                    cptTraceResultResponse.setFromCorp(cptTraceOrderResponse.getFromCorpName());
+                    cptTraceResultResponse.setFromCorpCreditNum(cptTraceOrderResponse.getCreditNo());
+                    cptTraceResultResponse.setToCorp(authCompany.getName());
+                    cptTraceResultResponse.setToCorpCreditNum(authCompany.getCreditCode());
+                }
+                if (StrUtil.isEmpty(cptTraceOrderResponse.getFromCorpName()) && cptTraceOrderResponse.getMainAction().equals(ConstantType.TYPE_OUT)) {
+                    cptTraceResultResponse.setBillType("使用出库");
+                    cptTraceResultResponse.setToUserInfo("患者使用出库");
+                }
+                cptTraceResultResponses.add(cptTraceResultResponse);
+            }
+        }
+
+        return ResultVOUtils.success(cptTraceResultResponses);
+
+    }
+
 }

src/main/java/com/glxp/api/controller/sync/TestController.java

@@ -0,0 +1,47 @@
+package com.glxp.api.controller.sync;
+
+import cn.hutool.core.util.StrUtil;
+import com.glxp.api.annotation.Log;
+import com.glxp.api.common.res.BaseResponse;
+import com.glxp.api.common.util.ResultVOUtils;
+import com.glxp.api.constant.BusinessType;
+import com.glxp.api.idc.utils.IDCUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.util.List;
+
+@Slf4j
+@RestController
+public class TestController {
+
+    @PostMapping("/test/file/uplaod")
+    @Log(title = "测试上传数据", businessType = BusinessType.INSERT)
+    public BaseResponse uploadProducts(@RequestParam("file") List<MultipartFile> files, @RequestParam("key") String key) {
+        if (StrUtil.isEmpty(key) || !key.equals("glxp6666")) {
+            return ResultVOUtils.error(500, "key不能为空");
+        }
+        String filePath = "D:\\udiwms\\testFile\\";
+        File createFile = new File(filePath);
+        if (!createFile.exists()) {
+            createFile.mkdirs();
+        }
+        for (int i = 0; i < files.size(); i++) {
+            MultipartFile file = files.get(i);
+            if (file.isEmpty()) {
+                return ResultVOUtils.error(500, "上传第" + (i++) + "个文件失败");
+            }
+            String fileName = file.getOriginalFilename();
+            try {
+                IDCUtils.writeFile(file.getBytes(), filePath + file.getName(), file.getOriginalFilename());
+            } catch (Exception e) {
+                log.error("产品信息导入失败", e);
+            }
+        }
+        return ResultVOUtils.success("上传成功");
+    }
+}

src/main/java/com/glxp/api/dao/auth/AuthCompanyMapper.java

@@ -0,0 +1,9 @@
+package com.glxp.api.dao.auth;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.glxp.api.entity.auth.AuthCompany;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface AuthCompanyMapper extends BaseMapper<AuthCompany> {
+}

src/main/java/com/glxp/api/dao/inout/IoOrderDetailResultDao.java

@@ -2,7 +2,9 @@ package com.glxp.api.dao.inout;
 
 import com.glxp.api.dao.BaseMapperPlus;
 import com.glxp.api.entity.inout.IoOrderDetailResultEntity;
+import com.glxp.api.req.inout.CptTraceRequest;
 import com.glxp.api.req.inout.FilterOrderDetailResultRequest;
+import com.glxp.api.res.inout.CptTraceOrderResponse;
 import com.glxp.api.res.inout.IoOrderDetailResultResponse;
 
 import java.util.List;
@@ -25,5 +27,7 @@ public interface IoOrderDetailResultDao extends BaseMapperPlus<IoOrderDetailResu
      */
     List<IoOrderDetailResultResponse> filterOrderList(FilterOrderDetailResultRequest orderDetailResultRequest);
 
+    List<CptTraceOrderResponse> cptTrace(CptTraceRequest cptTraceRequest);
+
 
 }

src/main/java/com/glxp/api/entity/auth/AuthCompany.java

@@ -0,0 +1,38 @@
+package com.glxp.api.entity.auth;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+@Data
+@TableName(value = "auth_company")
+public class AuthCompany {
+    @TableField(value = "`name`")
+    private String name;
+
+    @TableField(value = "category")
+    private Integer category;
+
+    @TableField(value = "creditCode")
+    private String creditCode;
+
+    @TableField(value = "addr")
+    private String addr;
+
+    @TableField(value = "productAddr")
+    private String productAddr;
+
+    /**
+     * 企业类别：1.生产企业，2.流通企业，3。医疗机构
+     */
+    @TableField(value = "classes")
+    private Integer classes;
+
+    @TableField(value = "appId")
+    private String appId;
+
+    @TableField(value = "appSecret")
+    private String appSecret;
+}

src/main/java/com/glxp/api/req/inout/CptTraceRequest.java

@@ -0,0 +1,89 @@
+package com.glxp.api.req.inout;
+
+import lombok.Data;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 客户端查询任务列表实体类
+ */
+@Data
+public class CptTraceRequest {
+
+
+    /**
+     * 按UDI码查询出入库信息
+     */
+    private String udiCode;
+
+    /**
+     * 查询记录表ID外键
+     */
+    private Long produdctRecordIdFk;
+
+    /**
+     * 任务类型   1：关联关系；2：入库；3：出库
+     */
+    private Integer taskType;
+
+    /**
+     * DI标识列表，多级包装会有多个DI
+     * DI标识数组，逗号隔开
+     */
+    private List<String> diList;
+
+    /**
+     * 企业信息ID外键
+     */
+    private Long companyIdFk;
+
+    /**
+     * 医疗器械注册人
+     */
+    private String ylqxzcrbarmc;
+
+    /**
+     * 医疗器械注册人统一社会信用号
+     */
+    private String creditNum;
+
+    /**
+     * 产品名称
+     */
+    private String cpmctymc;
+
+    /**
+     * 规格型号
+     */
+    private String ggxh;
+
+    /**
+     * 批次号
+     */
+    private String batchNo;
+    /**
+     * 生成日期
+     */
+    private String produceDate;
+    /**
+     * 失效日期
+     */
+    private String expireDate;
+
+    /**
+     * 序列号
+     */
+    private String serialNo;
+
+    /**
+     * 任务创建时间
+     */
+    private Date createTime;
+    /**
+     * 任务更新时间
+     */
+    private Date updateTime;
+
+
+}

src/main/java/com/glxp/api/res/inout/CptTraceOrderResponse.java

@@ -0,0 +1,19 @@
+package com.glxp.api.res.inout;
+
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class CptTraceOrderResponse {
+
+    private String billNo;
+    private Date createTime;
+    private String mainAction;
+    private String billType;
+    private String fromCorpName;
+    private String creditNo;
+    private String action;
+    private String fromInvCode;
+    private Integer count;
+}

src/main/java/com/glxp/api/res/inout/CptTraceResultResponse.java

@@ -0,0 +1,146 @@
+package com.glxp.api.res.inout;
+
+import cn.hutool.core.util.StrUtil;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class CptTraceResultResponse {
+
+
+    private Long id;
+
+    /**
+     * 单据号
+     */
+    private String billNo;
+
+    /**
+     * 单据时间
+     */
+    private String billDate;
+
+    /**
+     * 1:入库；2：出库
+     */
+    private Integer inOutType;
+
+    /**
+     * 单据类型
+     */
+    private String billType;
+
+    /**
+     * 发货企业
+     */
+    private String fromCorp;
+
+    /**
+     * 发货企业统一社会信用号
+     */
+    private String fromCorpCreditNum;
+
+    /**
+     * 收货企业
+     */
+    private String toCorp;
+
+    /**
+     * 收货企业统一社会信用号
+     */
+    private String toCorpCreditNum;
+
+    private String toUserInfo;
+
+    /**
+     * 单据创建者
+     */
+    private Long createUser;
+
+    /**
+     * 当前企业信息ID外键
+     */
+    private Long companyIdFk;
+
+    /**
+     * 当前企业名称
+     */
+    private String companyName;
+
+    /**
+     * 当前企业统一社会信用号
+     */
+    private String companyCertNum;
+
+    /**
+     * 客户端类型
+     */
+    private Integer clientType;
+
+    /**
+     * 退货原因（退货时填写）
+     */
+    private String returnReason;
+
+    /**
+     * 销毁原因（销毁时填写）
+     */
+    private String destoryReason;
+
+    /**
+     * 执行销毁人（销毁时填写）
+     */
+    private String excuseUser;
+
+    /**
+     * 执行销毁人证件号（销毁时填写）
+     */
+    private String excuseCode;
+
+    /**
+     * 监督人姓名【销毁出库时填写】
+     */
+    private String superviserUser;
+
+    /**
+     * 监督人证件号【销毁出库时填写】
+     */
+    private String superviserCode;
+
+    /**
+     * 上传着ID
+     */
+    private Long uploadUser;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    //关联信息
+    private String cpmctymc;
+    private String nameCode;
+    private String ggxh;
+    private String ylqxzcrbarmc;
+    private String batchNo;
+    private String produceDate;
+    private String expireDate;
+    private String serialNo;
+    private String udiCode;
+    private String zczbhhzbapzbh;
+    private String recordCode;
+    private Integer count;
+
+    public String getToCorp() {
+        if (StrUtil.isEmpty(toCorp))
+            return toUserInfo;
+        return toCorp;
+    }
+
+}

src/main/java/com/glxp/api/service/auth/AuthCompanyService.java

@@ -0,0 +1,15 @@
+package com.glxp.api.service.auth;
+
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.List;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.glxp.api.entity.auth.AuthCompany;
+import com.glxp.api.dao.auth.AuthCompanyMapper;
+
+@Service
+public class AuthCompanyService extends ServiceImpl<AuthCompanyMapper, AuthCompany> {
+
+
+}
+

src/main/java/com/glxp/api/service/inout/IoOrderDetailResultService.java

@@ -2,7 +2,9 @@ package com.glxp.api.service.inout;
 
 import com.glxp.api.entity.inout.IoOrderDetailCodeEntity;
 import com.glxp.api.entity.inout.IoOrderDetailResultEntity;
+import com.glxp.api.req.inout.CptTraceRequest;
 import com.glxp.api.req.inout.FilterOrderDetailResultRequest;
+import com.glxp.api.res.inout.CptTraceOrderResponse;
 import com.glxp.api.res.inout.IoOrderDetailResultResponse;
 
 import java.util.List;
@@ -24,4 +26,5 @@ public interface IoOrderDetailResultService {
 
     List<IoOrderDetailResultResponse> filterOrderList(FilterOrderDetailResultRequest orderDetailResultRequest);
 
+    List<CptTraceOrderResponse> cptTrace(CptTraceRequest cptTraceRequest);
 }

src/main/java/com/glxp/api/service/inout/impl/IoOrderDetailResultServiceImpl.java

@@ -6,7 +6,9 @@ import com.github.pagehelper.PageHelper;
 import com.glxp.api.dao.inout.IoOrderDetailResultDao;
 import com.glxp.api.entity.inout.IoOrderDetailCodeEntity;
 import com.glxp.api.entity.inout.IoOrderDetailResultEntity;
+import com.glxp.api.req.inout.CptTraceRequest;
 import com.glxp.api.req.inout.FilterOrderDetailResultRequest;
+import com.glxp.api.res.inout.CptTraceOrderResponse;
 import com.glxp.api.res.inout.IoOrderDetailResultResponse;
 import com.glxp.api.service.inout.IoOrderDetailResultService;
 import org.springframework.stereotype.Service;
@@ -72,4 +74,9 @@ public class IoOrderDetailResultServiceImpl implements IoOrderDetailResultServic
         return orderDetailResultDao.filterOrderList(orderDetailResultRequest);
     }
 
+    @Override
+    public List<CptTraceOrderResponse> cptTrace(CptTraceRequest cptTraceRequest) {
+        return orderDetailResultDao.cptTrace(cptTraceRequest);
+    }
+
 }

src/main/java/com/glxp/api/util/udi/UdiInfoUtil.java

@@ -22,6 +22,10 @@ public class UdiInfoUtil {
         if (StrUtil.isNotEmpty(udiProductEntity.getScbssfbhsxrq()) && "否".equals(udiProductEntity.getScbssfbhsxrq())) {
             udiProductEntity.setAllowNoExpire(true);
         }
+        if (StrUtil.isNotEmpty(udiProductEntity.getScbssfbhxlh()) && "否".equals(udiProductEntity.getScbssfbhxlh())) {
+            udiProductEntity.setAllowNoExpire(true);
+        }
+
         return udiProductEntity;
     }
 
@@ -42,6 +46,9 @@ public class UdiInfoUtil {
                 if (StrUtil.isNotEmpty(udiProductEntity.getScbssfbhsxrq()) && "否".equals(udiProductEntity.getScbssfbhsxrq())) {
                     udiProductEntity.setAllowNoExpire(true);
                 }
+                if (StrUtil.isNotEmpty(udiProductEntity.getScbssfbhxlh()) && "否".equals(udiProductEntity.getScbssfbhxlh())) {
+                    udiProductEntity.setAllowNoExpire(true);
+                }
             }
         }
 

src/main/resources/mybatis/mapper/auth/AuthCompanyMapper.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.glxp.api.dao.auth.AuthCompanyMapper">
+    <resultMap id="BaseResultMap" type="com.glxp.api.entity.auth.AuthCompany">
+        <!--@mbg.generated-->
+        <!--@Table auth_company-->
+        <result column="name" jdbcType="VARCHAR" property="name"/>
+        <result column="category" jdbcType="INTEGER" property="category"/>
+        <result column="creditCode" jdbcType="VARCHAR" property="creditCode"/>
+        <result column="addr" jdbcType="VARCHAR" property="addr"/>
+        <result column="productAddr" jdbcType="VARCHAR" property="productAddr"/>
+        <result column="classes" jdbcType="INTEGER" property="classes"/>
+        <result column="appId" jdbcType="VARCHAR" property="appId"/>
+        <result column="appSecret" jdbcType="VARCHAR" property="appSecret"/>
+    </resultMap>
+    <sql id="Base_Column_List">
+        <!--@mbg.generated-->
+        `name`, category, creditCode, addr, productAddr, classes, appId, appSecret
+    </sql>
+</mapper>

src/main/resources/mybatis/mapper/inout/IoOrderDetailResultDao.xml

@@ -74,4 +74,33 @@
             </if>
         </where>
     </select>
+
+
+    <select id="cptTrace" parameterType="com.glxp.api.req.inout.CptTraceRequest"
+            resultType="com.glxp.api.res.inout.CptTraceOrderResponse">
+        select io.billNo,
+               io.createTime,
+               io.mainAction,
+               bbt.`name`        billType,
+               basic_corp.`name` fromCorpName,
+               basic_corp.creditNo,
+               io.action,
+               io.fromInvCode
+        from io_order_detail_result iodr
+                     INNER JOIN io_order io on iodr.orderIdFk = io.billNo
+                     left join basic_corp on io.fromCorp = basic_corp.erpId
+                     INNER JOIN basic_bussiness_type bbt on io.action = bbt.action
+        <where>
+            and bbt.inStock = true
+            <if test="batchNo != null and batchNo != ''">
+                AND batchNo = #{batchNo}
+            </if>
+            <if test="diList != null and diList.size() != 0">
+                AND iodr.`nameCode` in
+                <foreach collection="diList" index="index" item="item" open="(" close=")" separator=",">
+                    #{item}
+                </foreach>
+            </if>
+        </where>
+    </select>
 </mapper>