UDI
/
udi-cpt-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

代码备份

Browse Source
cert
anthonywj 2 years ago
parent b8c8a81faf
commit c166838758
14 changed files with 108 additions and 72 deletions

2
pom.xml
Unescape Escape View File

@ -378,7 +378,7 @@
</dependencies>
<build>
<finalName>UDI_WMS_MC</finalName>
<finalName>UDI_CPT_SERVER</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>

9
src/main/java/com/glxp/api/controller/trace/TraceOrderController.java
Unescape Escape View File

@ -1,32 +1,23 @@
package com.glxp.api.controller.trace;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
import com.github.pagehelper.PageInfo;
import com.glxp.api.annotation.AuthRuleAnnotation;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import com.glxp.api.controller.BaseController;
import com.glxp.api.entity.basic.UdiEntity;
import com.glxp.api.entity.trace.TraceOrderEntity;
import com.glxp.api.req.trace.TraceOrderDetailRequest;
import com.glxp.api.req.trace.TraceOrderUploadRequest;
import com.glxp.api.res.PageSimpleResponse;
import com.glxp.api.res.trace.TraceOrderResponse;
import com.glxp.api.service.trace.TraceOrderService;
import com.glxp.api.util.udi.FilterUdiUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import springfox.documentation.annotations.ApiIgnore;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
@ApiIgnore

1
src/main/java/com/glxp/api/controller/trace/UdiTraceController.java
Unescape Escape View File

@ -151,7 +151,6 @@ public class UdiTraceController extends BaseController {
}
return ResultVOUtils.success(traceRecordLogEntity);
}

3
src/main/java/com/glxp/api/dao/basic/BasicUdiRelMapper.java
Unescape Escape View File

@ -23,4 +23,7 @@ public interface BasicUdiRelMapper extends BaseMapper<BasicUdiRelEntity> {
List<String> findDiList(@Param("uuid") String uuid);
List<String> findDiListByProduct(FilterUdiRelRequest filterUdiRelRequest);
}

20
src/main/java/com/glxp/api/entity/trace/TraceOrderEntity.java
Unescape Escape View File

@ -16,6 +16,7 @@ import lombok.Data;
@Data
@TableName(value = "trace_order")
public class TraceOrderEntity implements Serializable {
@TableId(value = "id", type = IdType.INPUT)
private Long id;
@ -67,6 +68,13 @@ public class TraceOrderEntity implements Serializable {
@TableField(value = "toCorpCreditNum")
private String toCorpCreditNum;
/**
* 使用者信息 （医疗机构实际使用者信息）
*/
@TableField(value = "toUserInfo")
private String toUserInfo;
/**
* 单据创建者
*/
@ -79,6 +87,13 @@ public class TraceOrderEntity implements Serializable {
@TableField(value = "companyIdFk")
private Long companyIdFk;
/**
* 当前企业统一社会信用号
*/
@TableField(value = "companyCertNum")
private String companyCertNum;
/**
* 客户端类型
*/
@ -144,6 +159,11 @@ public class TraceOrderEntity implements Serializable {
@TableField(value = "traceProductIdFk")
private Long traceProductIdFk;
/**
* 单据源头类型：1:起始位置（例如:生产企业) 2: 中间位置:（流通企业）3：结束位置:(例如：医疗机构使用，或一些销毁等)
*/
@TableField(value = "sourceType")
private Long sourceType;
private static final long serialVersionUID = 1L;
}

2
src/main/java/com/glxp/api/entity/trace/TraceTaskNoticeEntity.java
Unescape Escape View File

@ -27,7 +27,7 @@ public class TraceTaskNoticeEntity implements Serializable {
private Long produdctRecordIdFk;
/**
* 任务类型 1：关联关系；2:出入库
* 任务类型 1：关联关系；2:出入库单据
*/
@TableField(value = "taskType")
private Integer taskType;

13
src/main/java/com/glxp/api/res/trace/TraceOrderResponse.java
Unescape Escape View File

@ -21,7 +21,7 @@ public class TraceOrderResponse {
/**
* 1:入库；2：出库
*/
private Byte inOutType;
private Integer inOutType;
/**
* 单据类型
@ -48,21 +48,28 @@ public class TraceOrderResponse {
*/
private String toCorpCreditNum;
private String toUserInfo;
/**
* 单据创建者
*/
private Long createUser;
/**
* 企业信息ID外键
* 当前企业信息ID外键
*/
private Long companyIdFk;
/**
* 企业名称
* 当前企业名称
*/
private String companyName;
/**
* 当前企业统一社会信用号
*/
private String companyCertNum;
/**
* 客户端类型
*/

10
src/main/java/com/glxp/api/service/basic/BasicUdiRelService.java
Unescape Escape View File

@ -60,4 +60,14 @@ public class BasicUdiRelService extends ServiceImpl<BasicUdiRelMapper, BasicUdiR
return null;
}
public List<String> findDiListByProduct(FilterUdiRelRequest filterUdiRelRequest) {
if (StrUtil.isNotEmpty(filterUdiRelRequest.getNameCode())) {
BasicUdiRelResponse basicUdiRelResponse = findByProductNameCode(filterUdiRelRequest.getNameCode());
return basicUdiRelMapper.findDiList(basicUdiRelResponse.getUuid());
} else {
return basicUdiRelMapper.findDiListByProduct(filterUdiRelRequest);
}
}
}

31
src/main/java/com/glxp/api/service/trace/TraceOrderService.java
Unescape Escape View File

@ -1,16 +1,37 @@
package com.glxp.api.service.trace;
import com.glxp.api.entity.trace.TraceOrderEntity;
import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageHelper;
import com.glxp.api.req.trace.TraceOrderDetailRequest;
import com.glxp.api.req.trace.TraceOrderRequest;
import com.glxp.api.res.trace.TraceOrderResponse;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.glxp.api.dao.trace.TraceOrderMapper;
import com.glxp.api.entity.trace.TraceOrderEntity;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
public interface TraceOrderService extends IService<TraceOrderEntity>{
@Service
public class TraceOrderService extends ServiceImpl<TraceOrderMapper, TraceOrderEntity> {
@Resource
TraceOrderMapper traceOrderMapper;
List<TraceOrderResponse> queryTraceOrderList(TraceOrderDetailRequest traceOrderDetailRequest);
public List<TraceOrderResponse> queryTraceOrderList(TraceOrderDetailRequest traceOrderDetailRequest) {
if (traceOrderDetailRequest == null) {
return Collections.emptyList();
}
if (traceOrderDetailRequest.getPage() != null) {
int offset = (traceOrderDetailRequest.getPage() - 1) * traceOrderDetailRequest.getLimit();
PageHelper.offsetPage(offset, traceOrderDetailRequest.getLimit());
}
return traceOrderMapper.queryTraceOrderList(traceOrderDetailRequest);
}
List<TraceOrderEntity> findByProductIdFk(Long traceProductIdFk) {
return traceOrderMapper.selectList(new QueryWrapper<TraceOrderEntity>().eq("traceProductIdFk", traceProductIdFk));
}
}

35
src/main/java/com/glxp/api/service/trace/UdiTraceService.java
Unescape Escape View File

@ -6,6 +6,7 @@ import com.glxp.api.entity.trace.MqTraceMessage;
import com.glxp.api.entity.trace.TraceProductDetailEntity;
import com.glxp.api.entity.trace.TraceRecordLogEntity;
import com.glxp.api.entity.trace.TraceTaskNoticeEntity;
import com.glxp.api.req.basic.FilterUdiRelRequest;
import com.glxp.api.req.trace.TraceRecordRequest;
import com.glxp.api.res.basic.BasicUdiRelResponse;
import com.glxp.api.service.basic.BasicUdiProductService;
@ -109,21 +110,28 @@ public class UdiTraceService {
//1.查询生产订单信息是否已上传
if (traceProductDetailEntity.getManuStatus() != 3) {
//生产订单关联关系
if (traceProductDetailEntity.getManuStatus() == 2) {
TraceTaskNoticeEntity taskNoticeEntity = traceTaskNoticeService.findTask(1, traceProductDetailEntity.getId());
if (taskNoticeEntity == null) {
createTraceNotice(1, traceProductDetailEntity, companyId);
pushMq(traceProductDetailEntity, companyId);
} else if (taskNoticeEntity.getStatus() == 4) {
//任务超时未处理，重新推送消息
pushMq(traceProductDetailEntity, companyId);
}
//生产订单关联关系
if (traceProductDetailEntity.getManuStatus() == 1) { //生产订单未处理
createTraceNotice(1, traceProductDetailEntity, companyId);
pushMq(traceProductDetailEntity, companyId);
} else if (traceProductDetailEntity.getManuStatus() == 2) { //生产订单处理未完成
TraceTaskNoticeEntity taskNoticeEntity = traceTaskNoticeService.findTask(1, traceProductDetailEntity.getId());
if (taskNoticeEntity == null) {
createTraceNotice(1, traceProductDetailEntity, companyId);
pushMq(traceProductDetailEntity, companyId);
} else if (taskNoticeEntity.getStatus() == 4) {
//任务超时未处理，重新推送消息
pushMq(traceProductDetailEntity, companyId);
}
}
//2.查询出入库单消息是否已经上传
if (traceProductDetailEntity.getStatus() == 1) { //出入库订单未处理
createTraceNotice(2, traceProductDetailEntity, companyId);
pushMq(traceProductDetailEntity, companyId);
} else if (traceProductDetailEntity.getStatus() == 2) { //出入库订单未处理完成
}
}
@ -146,8 +154,9 @@ public class UdiTraceService {
traceTaskNoticeEntity.setExpireDate(traceProductDetailEntity.getExpireDate());
traceTaskNoticeEntity.setSerialNo(traceProductDetailEntity.getSerialNo());
traceTaskNoticeEntity.setCreateTime(new Date());
// List<String> diList = basicUdiRelService.getBaseMapper().findDiList(basicUdiRelResponse.getUuid());
// traceTaskNoticeEntity.setDiList(diList);
FilterUdiRelRequest filterUdiRelRequest = new FilterUdiRelRequest();
List<String> diList = basicUdiRelService.findDiListByProduct(filterUdiRelRequest);
traceTaskNoticeEntity.setDiList(diList);
traceTaskNoticeService.save(traceTaskNoticeEntity);
return traceTaskNoticeEntity;
}

34
src/main/java/com/glxp/api/service/trace/impl/TraceOrderServiceImpl.java
Unescape Escape View File

@ -1,34 +0,0 @@
package com.glxp.api.service.trace.impl;
import com.github.pagehelper.PageHelper;
import com.glxp.api.req.trace.TraceOrderDetailRequest;
import com.glxp.api.req.trace.TraceOrderRequest;
import com.glxp.api.res.trace.TraceOrderResponse;
import com.glxp.api.service.trace.TraceOrderService;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.glxp.api.dao.trace.TraceOrderMapper;
import com.glxp.api.entity.trace.TraceOrderEntity;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
@Service
public class TraceOrderServiceImpl extends ServiceImpl<TraceOrderMapper, TraceOrderEntity> implements TraceOrderService {
@Resource
TraceOrderMapper traceOrderMapper;
@Override
public List<TraceOrderResponse> queryTraceOrderList(TraceOrderDetailRequest traceOrderDetailRequest) {
if (traceOrderDetailRequest == null) {
return Collections.emptyList();
}
if (traceOrderDetailRequest.getPage() != null) {
int offset = (traceOrderDetailRequest.getPage() - 1) * traceOrderDetailRequest.getLimit();
PageHelper.offsetPage(offset, traceOrderDetailRequest.getLimit());
}
return traceOrderMapper.queryTraceOrderList(traceOrderDetailRequest);
}
}

8
src/main/resources/application-pro.yml
Unescape Escape View File

@ -3,7 +3,7 @@ server:
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://127.0.0.1:3306/udi_cpt?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
jdbc-url: jdbc:mysql://192.168.0.66:3364/udi_cpt?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
username: root
password: Glxp@6066
hikari:
@ -18,7 +18,7 @@ spring:
timeout: 300
jedis:
pool:
max-active: 8
max-active: 16
max-wait: -1
max-idle: 8
min-idle: 0
@ -43,12 +43,12 @@ logging:
level:
com.glxp.api.dao: debug
file_path: D:/udi/udiwms/udiwmsfile/
file_path: D:/udi/cpt/udiwmsfile/
UDI_KEY: 6b137c66-6286-46c6-8efa-c2f5dd9237df
UDI_SERVER_URL: https://www.udims.com/UDI_DL_Server_test
SPMS_KEY: lCOdWCBKS6Kw45wdnnqUTELXyuSKnXEs
back_file_path: D:/share/udisps/back/
back_file_path: D:/share/cpt/back/
API_KEY: 1101
API_SECRET: zBITspLNvuoEd4FaamlSoqxRHmNsmQ9L

2
src/main/resources/application.yml
Unescape Escape View File

@ -1,6 +1,6 @@
spring:
profiles:
active: dev
active: pro
jmx:
enabled: false
servlet:

10
src/main/resources/mybatis/mapper/basic/BasicUdiRelMapper.xml
Unescape Escape View File

@ -124,4 +124,14 @@
from basic_udi_product
where uuid = #{uuid}
</select>
<select id="findDiListByProduct"
resultType="java.lang.String">
select nameCode
from basic_udi_product
where basic_udi_product.ylqxzcrbarmc = #{ylqxzcrbarmc}
and basic_udi_product.cpmctymc = #{cpmctymc}
and basic_udi_product.ggxh = #{ggxh}
</select>
</mapper>

Write Preview
Loading…
Cancel
Save