湖里妇幼修改

Lhxyy
yewj 7 months ago
parent 55579ec4bf
commit 2b73138bf9

@ -72,6 +72,7 @@ import org.dom4j.Document;
import org.dom4j.DocumentException; import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper; import org.dom4j.DocumentHelper;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
@ -155,8 +156,6 @@ public class HlfyyyClient extends CommonHttpClient {
private RelCodeDetailService relCodeDetailService; private RelCodeDetailService relCodeDetailService;
@Resource @Resource
private VA001Service va001Service; private VA001Service va001Service;
@ -273,17 +272,17 @@ public class HlfyyyClient extends CommonHttpClient {
List nameList = new ArrayList(); List nameList = new ArrayList();
List registerNoList = new ArrayList(); List registerNoList = new ArrayList();
if(list!=null && list.size() >0 ){ if (list != null && list.size() > 0) {
for (ThrProductsEntity thrProductsEntity : list) { for (ThrProductsEntity thrProductsEntity : list) {
if(StringUtils.isNotEmpty(thrProductsEntity.getCode())){ if (StringUtils.isNotEmpty(thrProductsEntity.getCode())) {
codeList.add(thrProductsEntity.getCode()); codeList.add(thrProductsEntity.getCode());
} }
if(StringUtils.isNotEmpty(thrProductsEntity.getName())){ if (StringUtils.isNotEmpty(thrProductsEntity.getName())) {
nameList.add(thrProductsEntity.getName()); nameList.add(thrProductsEntity.getName());
} }
if(StringUtils.isNotEmpty(thrProductsEntity.getRegisterNo())){ if (StringUtils.isNotEmpty(thrProductsEntity.getRegisterNo())) {
registerNoList.add(thrProductsEntity.getRegisterNo()); registerNoList.add(thrProductsEntity.getRegisterNo());
} }
@ -292,15 +291,15 @@ public class HlfyyyClient extends CommonHttpClient {
} }
LambdaQueryWrapper<VA002> wrapper = new LambdaQueryWrapper(); LambdaQueryWrapper<VA002> wrapper = new LambdaQueryWrapper();
//补充其他查询条件 //补充其他查询条件
wrapper.in(codeList!=null && codeList.size()>0, VA002::getCode,codeList); wrapper.in(codeList != null && codeList.size() > 0, VA002::getCode, codeList);
wrapper.in(nameList!=null && nameList.size()>0, VA002::getName, nameList); wrapper.in(nameList != null && nameList.size() > 0, VA002::getName, nameList);
wrapper.in(registerNoList!=null && registerNoList.size()>0, VA002::getRegisterno, registerNoList); wrapper.in(registerNoList != null && registerNoList.size() > 0, VA002::getRegisterno, registerNoList);
// 保留之前的查询方法怕有用到 // 保留之前的查询方法怕有用到
wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getCode()), VA002::getCode, udiwmsProductRequest.getCode()); wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getCode()), VA002::getCode, udiwmsProductRequest.getCode());
wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getName()), VA002::getName, udiwmsProductRequest.getName()); wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getName()), VA002::getName, udiwmsProductRequest.getName());
wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getRegisterNo()), VA002::getRegisterno, udiwmsProductRequest.getRegisterNo()); wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getRegisterNo()), VA002::getRegisterno, udiwmsProductRequest.getRegisterNo());
wrapper.eq(VA002::getRemark,"Y"); wrapper.eq(VA002::getRemark, "Y");
IPage<VA002> page = va002Mapper.selectPage(new Page<VA002>(udiwmsProductRequest.getPage(), udiwmsProductRequest.getLimit()), wrapper); IPage<VA002> page = va002Mapper.selectPage(new Page<VA002>(udiwmsProductRequest.getPage(), udiwmsProductRequest.getLimit()), wrapper);
List<VA002> physicDictEntities = page.getRecords(); List<VA002> physicDictEntities = page.getRecords();
List<ZzzyyProductsResponse> zzzyyProductsResponseList = null; List<ZzzyyProductsResponse> zzzyyProductsResponseList = null;
@ -309,7 +308,7 @@ public class HlfyyyClient extends CommonHttpClient {
zzzyyProductsResponseList = physicDictEntities.stream().map(dict -> { zzzyyProductsResponseList = physicDictEntities.stream().map(dict -> {
ZzzyyProductsResponse products = new ZzzyyProductsResponse(); ZzzyyProductsResponse products = new ZzzyyProductsResponse();
// BeanUtil.copyProperties(dict,products); // BeanUtil.copyProperties(dict,products);
oracleCompatibleCopy(dict,products); oracleCompatibleCopy(dict, products);
products.setProductType(1); products.setProductType(1);
// products.setRegisterNo(dict.getRegisterno()); // products.setRegisterNo(dict.getRegisterno());
return products; return products;
@ -325,17 +324,17 @@ public class HlfyyyClient extends CommonHttpClient {
List nameList = new ArrayList(); List nameList = new ArrayList();
List registerNoList = new ArrayList(); List registerNoList = new ArrayList();
if(list!=null && list.size() >0 ){ if (list != null && list.size() > 0) {
for (ThrProductsEntity thrProductsEntity : list) { for (ThrProductsEntity thrProductsEntity : list) {
if(StringUtils.isNotEmpty(thrProductsEntity.getCode())){ if (StringUtils.isNotEmpty(thrProductsEntity.getCode())) {
codeList.add(thrProductsEntity.getCode()); codeList.add(thrProductsEntity.getCode());
} }
if(StringUtils.isNotEmpty(thrProductsEntity.getName())){ if (StringUtils.isNotEmpty(thrProductsEntity.getName())) {
nameList.add(thrProductsEntity.getName()); nameList.add(thrProductsEntity.getName());
} }
if(StringUtils.isNotEmpty(thrProductsEntity.getRegisterNo())){ if (StringUtils.isNotEmpty(thrProductsEntity.getRegisterNo())) {
registerNoList.add(thrProductsEntity.getRegisterNo()); registerNoList.add(thrProductsEntity.getRegisterNo());
} }
@ -344,15 +343,15 @@ public class HlfyyyClient extends CommonHttpClient {
} }
LambdaQueryWrapper<VA003> wrapper = new LambdaQueryWrapper(); LambdaQueryWrapper<VA003> wrapper = new LambdaQueryWrapper();
//补充其他查询条件 //补充其他查询条件
wrapper.in(codeList!=null && codeList.size()>0, VA003::getCode,codeList); wrapper.in(codeList != null && codeList.size() > 0, VA003::getCode, codeList);
wrapper.in(nameList!=null && nameList.size()>0, VA003::getName, nameList); wrapper.in(nameList != null && nameList.size() > 0, VA003::getName, nameList);
wrapper.in(registerNoList!=null && registerNoList.size()>0, VA003::getRegisterno, registerNoList); wrapper.in(registerNoList != null && registerNoList.size() > 0, VA003::getRegisterno, registerNoList);
// 保留之前的查询方法怕有用到 // 保留之前的查询方法怕有用到
wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getCode()), VA003::getCode, udiwmsProductRequest.getCode()); wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getCode()), VA003::getCode, udiwmsProductRequest.getCode());
wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getName()), VA003::getName, udiwmsProductRequest.getName()); wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getName()), VA003::getName, udiwmsProductRequest.getName());
wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getRegisterNo()), VA003::getRegisterno, udiwmsProductRequest.getRegisterNo()); wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getRegisterNo()), VA003::getRegisterno, udiwmsProductRequest.getRegisterNo());
wrapper.eq(VA003::getRemark,"Y"); wrapper.eq(VA003::getRemark, "Y");
IPage<VA003> page = va003Mapper.selectPage(new Page<VA003>(udiwmsProductRequest.getPage(), udiwmsProductRequest.getLimit()), wrapper); IPage<VA003> page = va003Mapper.selectPage(new Page<VA003>(udiwmsProductRequest.getPage(), udiwmsProductRequest.getLimit()), wrapper);
List<VA003> physicDictEntities = page.getRecords(); List<VA003> physicDictEntities = page.getRecords();
List<ThrProductsEntity> thrProductsEntityList = null; List<ThrProductsEntity> thrProductsEntityList = null;
@ -360,7 +359,7 @@ public class HlfyyyClient extends CommonHttpClient {
//数据处理以thr_products 返回 //数据处理以thr_products 返回
thrProductsEntityList = physicDictEntities.stream().map(dict -> { thrProductsEntityList = physicDictEntities.stream().map(dict -> {
ThrProductsEntity products = new ThrProductsEntity(); ThrProductsEntity products = new ThrProductsEntity();
oracleCompatibleCopy(dict,products); oracleCompatibleCopy(dict, products);
products.setSpec(dict.getBzgg()); products.setSpec(dict.getBzgg());
products.setProductType(2); products.setProductType(2);
products.setRegisterNo(dict.getRegisterno()); products.setRegisterNo(dict.getRegisterno());
@ -754,7 +753,7 @@ public class HlfyyyClient extends CommonHttpClient {
.selectList(Wrappers.lambdaQuery(IoOrderInvoiceEntity.class).eq(IoOrderInvoiceEntity::getOrderIdFk, orderEntity.getBillNo()) .selectList(Wrappers.lambdaQuery(IoOrderInvoiceEntity.class).eq(IoOrderInvoiceEntity::getOrderIdFk, orderEntity.getBillNo())
.eq(IoOrderInvoiceEntity::getBindRlFk, i.getBindRlFk()) .eq(IoOrderInvoiceEntity::getBindRlFk, i.getBindRlFk())
.eq(StrUtil.isNotEmpty(i.getBatchNo()), IoOrderInvoiceEntity::getBatchNo, i.getBatchNo()). .eq(StrUtil.isNotEmpty(i.getBatchNo()), IoOrderInvoiceEntity::getBatchNo, i.getBatchNo()).
groupBy(IoOrderInvoiceEntity::getInvoiceEncode)); groupBy(IoOrderInvoiceEntity::getInvoiceEncode));
if (CollectionUtil.isNotEmpty(invoiceList)) { if (CollectionUtil.isNotEmpty(invoiceList)) {
fphm = invoiceList.stream().map(IoOrderInvoiceEntity::getInvoiceEncode).collect(Collectors.joining(",")); fphm = invoiceList.stream().map(IoOrderInvoiceEntity::getInvoiceEncode).collect(Collectors.joining(","));
if (invoiceList.get(0).getInvoiceDate() != null) if (invoiceList.get(0).getInvoiceDate() != null)
@ -1143,7 +1142,8 @@ public class HlfyyyClient extends CommonHttpClient {
udiwmsWarehouseRequest.setDatabaseProductName(getDataSourceType()); udiwmsWarehouseRequest.setDatabaseProductName(getDataSourceType());
PageSimpleResponseNew<VA004> pageSimpleResponseNew = va004Service.filterList(udiwmsWarehouseRequest); PageSimpleResponseNew<VA004> pageSimpleResponseNew = va004Service.filterList(udiwmsWarehouseRequest);
log.info("解析四川武平县医院返回仓库信息,返回结果:{}", pageSimpleResponseNew.getList()); log.info("解析四川武平县医院返回仓库信息,返回结果:{}", pageSimpleResponseNew.getList());
return ResultVOUtils.success(pageSimpleResponseNew); } return ResultVOUtils.success(pageSimpleResponseNew);
}
@Override @Override
public BaseResponse testConnect() { public BaseResponse testConnect() {
@ -1446,7 +1446,8 @@ public class HlfyyyClient extends CommonHttpClient {
return udiwmsPreInOrderRequest; return udiwmsPreInOrderRequest;
} }
@Value("${DBTYPE}")
private String DBTYPE;
/** /**
* -------------------------------------------------------------------------------------------------------- * --------------------------------------------------------------------------------------------------------
*/ */
@ -1459,8 +1460,8 @@ public class HlfyyyClient extends CommonHttpClient {
@Override @Override
public BaseResponse getPrescribes(UdiwmsBasicSkPrescribeRequest udiwmsBasicSkPrescribeRequest) { public BaseResponse getPrescribes(UdiwmsBasicSkPrescribeRequest udiwmsBasicSkPrescribeRequest) {
if (IntUtil.value(udiwmsBasicSkPrescribeRequest.getInOutType()) == 0) { if (IntUtil.value(udiwmsBasicSkPrescribeRequest.getInOutType()) == 0) {
udiwmsBasicSkPrescribeRequest.setDatabaseProductName(getDataSourceType()); udiwmsBasicSkPrescribeRequest.setDatabaseProductName(DBTYPE);
IPage<VA010> iPage = va010Service.getList(new Page<VA010>(udiwmsBasicSkPrescribeRequest.getPage(), udiwmsBasicSkPrescribeRequest.getLimit()),udiwmsBasicSkPrescribeRequest); IPage<VA010> iPage = va010Service.getList(new Page<VA010>(udiwmsBasicSkPrescribeRequest.getPage(), udiwmsBasicSkPrescribeRequest.getLimit()), udiwmsBasicSkPrescribeRequest);
// List<VA010> list = iPage.getRecords(); // List<VA010> list = iPage.getRecords();
// PageInfo<VA010> pageInfo = new PageInfo<>(list); // PageInfo<VA010> pageInfo = new PageInfo<>(list);
// PageSimpleResponse<VA010> pageSimpleResponse = new PageSimpleResponse<>(); // PageSimpleResponse<VA010> pageSimpleResponse = new PageSimpleResponse<>();
@ -1814,6 +1815,7 @@ public class HlfyyyClient extends CommonHttpClient {
return ResultVOUtils.error(500, "下载失败!"); return ResultVOUtils.error(500, "下载失败!");
} }
} }
public static List<IoCollectOrderBiz> summarizeByCode(List<IoCollectOrderBiz> bizList) { public static List<IoCollectOrderBiz> summarizeByCode(List<IoCollectOrderBiz> bizList) {
Map<String, IoCollectOrderBiz> summarizedMap = new HashMap<>(); Map<String, IoCollectOrderBiz> summarizedMap = new HashMap<>();
@ -1904,7 +1906,6 @@ public class HlfyyyClient extends CommonHttpClient {
} }
public BaseResponse optionUploadCollectOrder3505(IoCollectOrder ioCollectOrder) { public BaseResponse optionUploadCollectOrder3505(IoCollectOrder ioCollectOrder) {
//摆药流水号 //摆药流水号
// String stoout_no = ioCollectOrder.getBackupOrderRemark1(); // String stoout_no = ioCollectOrder.getBackupOrderRemark1();
@ -2161,16 +2162,16 @@ public class HlfyyyClient extends CommonHttpClient {
@Override @Override
public BaseResponse getBuyType() { public BaseResponse getBuyType() {
Map<String,String[]> buyTypeMap= new HashMap<>(); Map<String, String[]> buyTypeMap = new HashMap<>();
buyTypeMap.put("buyType_3501",buyType_3501); buyTypeMap.put("buyType_3501", buyType_3501);
buyTypeMap.put("buyType_3502",buyType_3502); buyTypeMap.put("buyType_3502", buyType_3502);
buyTypeMap.put("buyType_3505",buyType_3505); buyTypeMap.put("buyType_3505", buyType_3505);
buyTypeMap.put("buyType_3506",buyType_3506); buyTypeMap.put("buyType_3506", buyType_3506);
return ResultVOUtils.success(buyTypeMap); return ResultVOUtils.success(buyTypeMap);
} }
public void oracleCompatibleCopy(Object source, Object target) { public void oracleCompatibleCopy(Object source, Object target) {
try { try {
Class sourceClass = source.getClass();//得到对象的Class Class sourceClass = source.getClass();//得到对象的Class
Class targetClass = target.getClass();//得到对象的Class Class targetClass = target.getClass();//得到对象的Class
@ -2178,24 +2179,24 @@ public class HlfyyyClient extends CommonHttpClient {
Field[] sourceFields = sourceClass.getDeclaredFields();//得到Class对象的所有属性 Field[] sourceFields = sourceClass.getDeclaredFields();//得到Class对象的所有属性
Field[] targetFields = targetClass.getDeclaredFields();//得到Class对象的所有属性 Field[] targetFields = targetClass.getDeclaredFields();//得到Class对象的所有属性
for(Field sourceField : sourceFields){ for (Field sourceField : sourceFields) {
sourceField.setAccessible(true); sourceField.setAccessible(true);
String name = sourceField.getName();//属性名 String name = sourceField.getName();//属性名
Class type = sourceField.getType();//属性类型 Class type = sourceField.getType();//属性类型
Object value = sourceField.get(source); Object value = sourceField.get(source);
for(Field targetField : targetFields){ for (Field targetField : targetFields) {
targetField.setAccessible(true); targetField.setAccessible(true);
String targetName = targetField.getName();//目标对象的属性名 String targetName = targetField.getName();//目标对象的属性名
if(targetName.toLowerCase().equals(name.toLowerCase()) && !Objects.isNull(value)){ if (targetName.toLowerCase().equals(name.toLowerCase()) && !Objects.isNull(value)) {
targetField.set(target,value); targetField.set(target, value);
} }
} }
} }
}catch (Exception e){ } catch (Exception e) {
BeanUtil.copyProperties(source,target); BeanUtil.copyProperties(source, target);
} }

@ -14,3 +14,4 @@ import org.apache.ibatis.annotations.Param;
public interface VA010Mapper extends BaseMapper<VA010> { public interface VA010Mapper extends BaseMapper<VA010> {
IPage<VA010> getList(Page page, @Param("req") UdiwmsBasicSkPrescribeRequest udiwmsBasicSkPrescribeRequest); IPage<VA010> getList(Page page, @Param("req") UdiwmsBasicSkPrescribeRequest udiwmsBasicSkPrescribeRequest);
} }

@ -21,6 +21,7 @@ THIRD_NAME: thirdName
#UDI管理系统地址 #UDI管理系统地址
UDIWMS_IP: http://127.0.0.1:9991 UDIWMS_IP: http://127.0.0.1:9991
DBTYPE: Oracle
#mybatis-plus配置 #mybatis-plus配置
mybatis-plus: mybatis-plus:
@ -40,3 +41,5 @@ ok:
write-timeout: 30000 write-timeout: 30000
max-idle-connections: 200 max-idle-connections: 200
keep-alive-duration: 300 keep-alive-duration: 300

@ -17,57 +17,77 @@
</resultMap> </resultMap>
<sql id="Base_Column_List"> <sql id="Base_Column_List">
<!--@mbg.generated--> <!--@mbg.generated-->
CODE, SICKCODE, SICKNAME, PRESCRIBEDATE, CREATEDR, AMOUNT, DEPTCODE, DEPTNAME, DIAGNOSIS, CODE,
SICKCODE,
SICKNAME,
PRESCRIBEDATE,
CREATEDR,
AMOUNT,
DEPTCODE,
DEPTNAME,
DIAGNOSIS,
REMARK REMARK
</sql> </sql>
<select id="getList" resultType="com.glxp.mipsdl.entity.hlfyyy.VA010"> <select id="getList" resultType="com.glxp.mipsdl.entity.hlfyyy.VA010">
select SELECT
<include refid="Base_Column_List"> <include refid="Base_Column_List" />
</include> FROM
from v_a010 WHERE 1=1 v_a010
<if test="req.busType == 'YPCF002'"> WHERE
AND REMARK ='门诊' 1 = 1
</if> <!-- 业务类型条件 -->
<if test="req.busType != 'YPCF002'"> <if test="req.busType != null">
AND REMARK !='门诊' AND REMARK =
</if> <choose>
<if test="req.databaseProductName == 'MySQL'"> <when test="req.busType == 'YPCF002'"> '门诊' </when>
<if test="req.startTime != '' and req.startTime != null and req.endTime != '' and req.endTime != null"> <otherwise> '非门诊' </otherwise>
AND STR_TO_DATE(PRESCRIBEDATE, '%e/%c/%Y %H:%i:%s') >= #{req.startTime} AND STR_TO_DATE(PRESCRIBEDATE, '%e/%c/%Y %H:%i:%s') &lt; #{req.endTime} </choose>
</if> </if>
<if test="req.code != '' and req.code != null">
AND CODE = #{req.code}
</if>
<if test="req.fromCorpName != '' and req.fromCorpName != null">
AND DEPTNAME = #{req.fromCorpName}
</if>
<if test="req.key != '' and req.key != null">
AND CODE like concat('%', #{req.key}, '%')
or DEPTNAME like concat('%', #{req.key}, '%')
<!-- or STR_TO_DATE(PRESCRIBEDATE, '%e/%c/%Y %H:%i:%s') = #{req.key}-->
</if>
group by CODE
order by STR_TO_DATE(PRESCRIBEDATE, '%e/%c/%Y %H:%i:%s') desc
</if>
<if test="req.databaseProductName == 'Oracle'">
<if test="req.startTime != '' and req.startTime != null and req.endTime != '' and req.endTime != null">
AND TO_DATE(PRESCRIBEDATE, 'dd/MM/yyyy HH:mm:ss') >= #{req.startTime} AND TO_DATE(PRESCRIBEDATE, 'dd/MM/yyyy HH:mm:ss') &lt; #{req.endTime}
</if> <!-- 时间范围条件 -->
<if test="req.code != '' and req.code != null"> <if test="req.startTime != null and req.endTime != null">
AND CODE = #{req.code} AND
</if> <choose>
<if test="req.fromCorpName != '' and req.fromCorpName != null"> <when test="req.databaseProductName == 'MySQL'">
AND DEPTNAME = #{req.fromCorpName} <![CDATA[
</if> STR_TO_DATE(PRESCRIBEDATE, '%e/%c/%Y %H:%i:%s') >= #{req.startTime}
<if test="req.key != '' and req.key != null"> AND STR_TO_DATE(PRESCRIBEDATE, '%e/%c/%Y %H:%i:%s') < #{req.endTime}
AND CODE like '%' || #{req.key} || '%' ]]>
or DEPTNAME '%' || #{req.key} || '%' </when>
<!-- or TO_DATE(PRESCRIBEDATE, 'dd/MM/yyyy HH:mm:ss') = #{req.key}--> <when test="req.databaseProductName == 'Oracle'">
</if> <![CDATA[
group by CODE TO_DATE(PRESCRIBEDATE, 'dd/MM/yyyy HH:mm:ss') >= #{req.startTime}
order by TO_DATE(PRESCRIBEDATE, 'dd/MM/yyyy HH:mm:ss') desc AND TO_DATE(PRESCRIBEDATE, 'dd/MM/yyyy HH:mm:ss') < #{req.endTime}
]]>
</when>
</choose>
</if>
</if> <!-- 其他条件 -->
<if test="req.code != null and req.code != ''">
AND CODE = #{req.code}
</if>
<if test="req.fromCorpName != null and req.fromCorpName != ''">
AND DEPTNAME = #{req.fromCorpName}
</if>
<if test="req.key != null and req.key != ''">
AND (
CODE LIKE CONCAT('%', #{req.key}, '%')
OR DEPTNAME LIKE CONCAT('%', #{req.key}, '%')
)
</if>
<!-- 分组和排序 -->
GROUP BY CODE
ORDER BY
<choose>
<when test="req.databaseProductName == 'MySQL'">
PRESCRIBEDATE DESC
</when>
<when test="req.databaseProductName == 'Oracle'">
PRESCRIBEDATE DESC
</when>
</choose>
</select> </select>
</mapper> </mapper>

Loading…
Cancel
Save