From 00788a1299d764b48e57fd457a2656f0bf3474b0 Mon Sep 17 00:00:00 2001
From: zhaoxiaohao <279049017@qq.com>
Date: Tue, 17 Nov 2020 11:28:47 +0800
Subject: [PATCH] 修改  为https 后兼容以前的http 数据

---
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ProductOrderDetailServiceImpl.java |   56 +++++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 49 insertions(+), 7 deletions(-)

diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ProductOrderDetailServiceImpl.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ProductOrderDetailServiceImpl.java
index a672c0a..b58b730 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ProductOrderDetailServiceImpl.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ProductOrderDetailServiceImpl.java
@@ -2,9 +2,11 @@
 
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.kidgrow.common.constant.CommonConstant;
 import com.kidgrow.common.model.*;
 import com.kidgrow.common.service.impl.SuperServiceImpl;
 import com.kidgrow.common.utils.DateUtils;
+import com.kidgrow.common.utils.StringUtils;
 import com.kidgrow.oprationcenter.feign.DiagnosticService;
 import com.kidgrow.oprationcenter.mapper.ConsumptionRecordMapper;
 import com.kidgrow.oprationcenter.mapper.ProductOrderDetailMapper;
@@ -14,6 +16,7 @@
 import com.kidgrow.oprationcenter.service.IProductOrderDetailService;
 import com.kidgrow.oprationcenter.service.IProductOrderService;
 import com.kidgrow.oprationcenter.vo.*;
+import com.kidgrow.redis.util.RedisUtils;
 import com.kidgrow.usercenter.feign.SysDoctorService;
 import com.kidgrow.usercenter.feign.SysHospitalService;
 import com.kidgrow.usercenter.model.SysHospital;
@@ -48,6 +51,8 @@
     private ConsumptionRecordMapper consumptionRecordMapper;
     @Autowired
     private IProductOrderService iProductOrderService;
+    @Autowired
+    private RedisUtils redisUtils;
     /**
      * 列表
      * @param params
@@ -70,26 +75,52 @@
     }
 
     /**
-     * 判定医院科室的套餐是否到期 以及到期时间
+     * 判定医院科室的套餐是否到期 以及剩余的读片量
      * @param hospitalId
      * @param departmentId
+     * @param diagnosticId
      * @return
      */
-    public ResultBody<UserProductData> UserProductDetailData(Long hospitalId,Long departmentId)
+    @Override
+    public ResultBody<UserProductData> userProductDetailData(Long hospitalId,Long departmentId,String diagnosticId)
     {
         UserProductData userProductData=new UserProductData();
-        userProductData.setEnd(true);
+        userProductData.setIsEnd(true);
+        userProductData.setRecordCount(0);
+        userProductData.setAilightCount(0);
+        userProductData.setLimitDays(0);
         UserProductDetail userProductDetail = this.getUserProductDetail(hospitalId, departmentId);
         if (userProductDetail != null) {
             //合并集合
             userProductDetail.getProductOrderJoinDetailListShare().addAll(userProductDetail.getProductOrderJoinDetailsListDep());
             List<ProductOrderJoinDetail> productOrderJoinDetailList = userProductDetail.getProductOrderJoinDetailListShare();
             if (productOrderJoinDetailList.size() > 0) {
-                userProductData.setEnd(false);
+                userProductData.setIsEnd(false);
                 //合并后按id排序并筛除已用完的套餐
-                List<ProductOrderJoinDetail> productOrderJoinDetailsNewList = productOrderJoinDetailList.stream().filter(f -> f.getAilightCount() >= 0).sorted(Comparator.comparing(ProductOrderJoinDetail::getProEndtime).reversed()).collect(Collectors.toList());
-                userProductData.setMaxEndTime(productOrderJoinDetailsNewList.get(0).getProEndtime());
+                List<ProductOrderJoinDetail> productOrderJoinDetailsNewList = productOrderJoinDetailList.stream().filter(f -> f.getAilightCount() >= 0).sorted(Comparator.comparing(ProductOrderJoinDetail::getProEndtime)).collect(Collectors.toList());
+                for (int i = 0; i <productOrderJoinDetailsNewList.size(); i++) {
+                    userProductData.setAilightCount(productOrderJoinDetailsNewList.get(i).getAilightCount());
+                    userProductData.setRecordCount(productOrderJoinDetailsNewList.get(i).getRecordCount());
+                    Double days=DateUtils.getDays(new Date(),productOrderJoinDetailsNewList.get(i).getProEndtime());
+                    if (i<productOrderJoinDetailsNewList.size()-1) {
+                        //按照结束日期正序排序后,如果第二条的开始时间减去第一条的结束时间 差值大于0  说明套餐间有中断 则以当前这条套餐作为当前套餐的剩余天数
+                        Double daysTemp=DateUtils.getDays(productOrderJoinDetailsNewList.get(i).getProEndtime(),
+                                productOrderJoinDetailsNewList.get(i+1).getProBegintime());
+                        if (daysTemp>0) {
+                            userProductData.setLimitDays(Integer.valueOf(Double.valueOf(days).intValue()));
+                        }
+                    }
+                    else
+                    {
+                        userProductData.setLimitDays(Integer.valueOf(Double.valueOf(days).intValue()));
+                    }
+                }
             }
+        }
+        //是否已经结束
+        if (userProductData.getIsEnd()&& StringUtils.isNotBlank(diagnosticId)) {
+            //写入redis中,防止扣非后不能生成报告
+            redisUtils.lSet(CommonConstant.SAAS_LAST_SERVER+diagnosticId,diagnosticId);
         }
         return ResultBody.ok().data(userProductData);
     }
@@ -170,6 +201,10 @@
     public List<OrderChartVo> proCountChart() {
         return baseMapper.proCountChart();
     }
+	@Override
+    public int getUserdProduct(Long hospitalId, Long departmentId) {
+        return baseMapper.getUserdProduct(hospitalId,departmentId);
+    }
     /**
      *获取该科室下的所有的套餐信息
      * @param params
@@ -181,6 +216,14 @@
         List<ProductOrderDetail> list  =
                 baseMapper.departmentProductDetail(page, Long.parseLong(params.get("hospitalId").toString()),Long.parseLong(params.get("departmentId").toString()));
         return PageResult.<ProductOrderDetail>builder().data(list).code(0).count(page.getTotal()).build();
+    }
+
+    @Override
+    public PageResult<ProductEndVo> productEndList(Map<String, Object> params) {
+        Page<ProductEndVo> page = new Page<>(MapUtils.getInteger(params, "page"), MapUtils.getInteger(params, "limit"));
+        List<ProductEndVo> list  =
+                baseMapper.productEndList(page,MapUtils.getIntValue(params,"monthPar"),MapUtils.getIntValue(params,"aiCountPar"));
+        return PageResult.<ProductEndVo>builder().data(list).code(0).count(page.getTotal()).build();
     }
 
     /**
@@ -205,7 +248,6 @@
         List<GroupProductDetail> list  =  baseMapper.groupProductDetail(page,params);
         return PageResult.<GroupProductDetail>builder().data(list).code(0).count(page.getTotal()).build();
     }
-
     /**
    * 根据ProductOrderDetail对象当做查询条件进行查询
    * @param productOrderDetail

--
Gitblit v1.8.0