From abba1aff81da3cc9d74d75f64cbd48d25716aec3 Mon Sep 17 00:00:00 2001
From: luliqiang <kidgrow>
Date: Fri, 12 Mar 2021 19:19:10 +0800
Subject: [PATCH] 1、增加对于套餐中的剩余读片量、有效开始日期、结束日期的加密 2、增加扣费过程中对于剩余读片量的加密 3、为下载私有云数据库增加合同与明细的查询Feign接口 4、修改合作商数据库(影像版API)的合同与明细的查询bug

---
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderDetailController.java |  159 +++++++++++++++-------
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/IProductOrderDetailService.java         |    8 +
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/PartnerDockingInfoServiceImpl.java |   64 ++++----
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/fallback/ProductOrderFallbackFactory.java |   16 ++
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java       |   16 ++
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ConsumptionRecordServiceImpl.java  |   16 ++
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/model/ProductOrderDetail.java                   |   14 ++
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/ProductOrderService.java                  |   26 +++
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ProductOrderDetailServiceImpl.java |   88 ++++++++++++
 9 files changed, 323 insertions(+), 84 deletions(-)

diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/ProductOrderService.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/ProductOrderService.java
index ad4e281..3e98292 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/ProductOrderService.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/ProductOrderService.java
@@ -34,4 +34,30 @@
      */
     @PostMapping(value = "/contract/getStatus")
     ResultBody getStatus(@RequestBody ProductOrder productOrder);
+
+    /**
+     * 私有云套餐验证
+     * @param params 参数
+     *      hospitalId 医院ID
+     *      departmentId  科室ID
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    @PostMapping("/productorderdetail/verificateProductOrderDetail")
+    ResultBody verificateProductOrderDetail(@RequestBody Map<String,Object> params);
+
+    /**
+     * 根据Map的条件获取合同列表
+     * @param params
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    @PostMapping("/contract/findProductOrderListByMap")
+    ResultBody findProductOrderListByMap(@RequestBody Map<String, Object> params);
+
+    /**
+     * 根据Map的条件获取合同明细(套餐)列表
+     * @param params
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    @PostMapping("/productorderdetail/findProductOrderDetailListByMap")
+    ResultBody findProductOrderDetailListByMap(@RequestBody Map<String, Object> params);
 }
diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/fallback/ProductOrderFallbackFactory.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/fallback/ProductOrderFallbackFactory.java
index 7f1bfce..df86108 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/fallback/ProductOrderFallbackFactory.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/feign/fallback/ProductOrderFallbackFactory.java
@@ -6,6 +6,7 @@
 import feign.hystrix.FallbackFactory;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.RequestBody;
 
 import java.util.Map;
 @Slf4j
@@ -23,6 +24,21 @@
             public ResultBody getStatus(ProductOrder productOrder) {
                 return ResultBody.failed().msg("获取正式和试用的的FeignClient接口失败");
             }
+
+            @Override
+            public ResultBody verificateProductOrderDetail(@RequestBody Map<String,Object> params){
+                return ResultBody.failed().msg("私有云套餐验证的FeignClient接口失败");
+            }
+
+            @Override
+            public ResultBody findProductOrderListByMap(@RequestBody Map<String, Object> params){
+                return ResultBody.failed().msg("获取合同列表的FeignClient接口失败");
+            }
+
+            @Override
+            public ResultBody findProductOrderDetailListByMap(@RequestBody Map<String, Object> params){
+                return ResultBody.failed().msg("获取合同明细(套餐)列表的FeignClient接口失败");
+            }
         };
     }
 }
diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/model/ProductOrderDetail.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/model/ProductOrderDetail.java
index 633d2fa..6a8f53d 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/model/ProductOrderDetail.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-api/src/main/java/com/kidgrow/oprationcenter/model/ProductOrderDetail.java
@@ -84,6 +84,10 @@
      */
     @NotNull(message = "读片量不能为空")
     private Integer ailightCount;
+    /**
+     * 读片量加密串
+     */
+    private String ailightCountEncryption;
 
     /**
      * 报告量
@@ -96,11 +100,21 @@
     @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
     private Date proBegintime;
     /**
+     * 有效的开始时间加密串
+     */
+    private String proBegintimeEncryption;
+
+    /**
      * 有效的结束时间
      */
     @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
     private Date proEndtime;
     /**
+     * 有效的结束时间加密串
+     */
+    private String proEndtimeEncryption;
+
+    /**
      * 状态,1启用,0停用
      */
     private Boolean enabled;
diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/IProductOrderDetailService.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/IProductOrderDetailService.java
index 066ea2b..5c86d6e 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/IProductOrderDetailService.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/IProductOrderDetailService.java
@@ -144,5 +144,13 @@
      */
     int getUserdProduct(Long hospitalId,Long departmentId);
 
+    /**
+     * 私有云套餐验证
+     * @param hospitalId 医院ID
+     * @param departmentId  科室ID
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    ResultBody verificateProductOrderDetail(Long hospitalId, Long departmentId );
+
 }
 
diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ConsumptionRecordServiceImpl.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ConsumptionRecordServiceImpl.java
index 0602227..b288170 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ConsumptionRecordServiceImpl.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ConsumptionRecordServiceImpl.java
@@ -6,6 +6,7 @@
 import com.kidgrow.common.model.PageResult;
 import com.kidgrow.common.model.ResultBody;
 import com.kidgrow.common.service.impl.SuperServiceImpl;
+import com.kidgrow.common.utils.AesUtils;
 import com.kidgrow.common.utils.DateUtils;
 import com.kidgrow.common.utils.StringUtils;
 import com.kidgrow.oprationcenter.mapper.ConsumptionRecordMapper;
@@ -266,7 +267,7 @@
      */
     @Transactional(rollbackFor = Exception.class)
     @Override
-    public ResultBody consumptionAIFail(ConsumptionRequest consumptionRequest) {
+    public ResultBody consumptionAIFail(ConsumptionRequest consumptionRequest)  {
         //默认的业务返回码
         int bcode = -1;
         //记录类型
@@ -338,6 +339,13 @@
                         if (productOrderDetail != null) {
                             //退还金额
                             productOrderDetail.setAilightCount(productOrderDetail.getAilightCount() + consumptionRecord.getConsumptionCount());
+                            // 对于读片量进行加密
+                            try {
+                                productOrderDetail.setAilightCountEncryption(AesUtils.encrypt(productOrderDetail.getAilightCount().toString()));
+                            } catch (Exception e) {
+                                e.printStackTrace();
+                            }
+
                             productOrderDetail.setUpdateTime(new Date());
                             //退费
                             boolean consumptionRe = productOrderDetailService.saveOrUpdate(productOrderDetail);
@@ -504,6 +512,12 @@
                 productOrderDetail.setAilightCount(productOrderDetail.getAilightCount() - consumptionRequest.getConsumptionCount());
             }
         }
+        // 对于读片量进行加密
+        try {
+            productOrderDetail.setAilightCountEncryption(AesUtils.encrypt(productOrderDetail.getAilightCount().toString()));
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
         //3.1扣费!
         boolean consumptionRe = productOrderDetailService.saveOrUpdate(productOrderDetail);
         if (consumptionRe) {
diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/PartnerDockingInfoServiceImpl.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/PartnerDockingInfoServiceImpl.java
index 4b65b36..fb8f716 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/PartnerDockingInfoServiceImpl.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/PartnerDockingInfoServiceImpl.java
@@ -9,13 +9,10 @@
 import com.kidgrow.common.service.impl.SuperServiceImpl;
 import com.kidgrow.common.utils.EncryptUtils;
 import com.kidgrow.oprationcenter.mapper.PartnerDockingInfoMapper;
-import com.kidgrow.oprationcenter.model.PartnerDockingInfo;
-import com.kidgrow.oprationcenter.model.PartnerInfo;
-import com.kidgrow.oprationcenter.model.ProductOrder;
-import com.kidgrow.oprationcenter.model.ProductOrderRecord;
+import com.kidgrow.oprationcenter.model.*;
 import com.kidgrow.oprationcenter.service.IPartnerDockingInfoService;
 import com.kidgrow.oprationcenter.service.IPartnerInfoService;
-import com.kidgrow.oprationcenter.service.IProductOrderRecordService;
+import com.kidgrow.oprationcenter.service.IProductOrderDetailService;
 import com.kidgrow.oprationcenter.service.IProductOrderService;
 import com.kidgrow.usercenter.feign.SysDepartmentService;
 import com.kidgrow.usercenter.feign.SysDoctorService;
@@ -71,7 +68,7 @@
     IProductOrderService productOrderService;
 
     @Autowired
-    IProductOrderRecordService productOrderRecordService;
+    IProductOrderDetailService productOrderDetailService;
 
     /**
      * 列表
@@ -333,44 +330,44 @@
                         orderMap.put("order_id", productOrder.getId());
                         orderMap.put("enabled", 1);
                         orderMap.put("is_del", 0);
-                        List<ProductOrderRecord> productOrderRecordList = productOrderRecordService.listByMap(orderMap);
+                        List<ProductOrderDetail> productOrderDetailList = productOrderDetailService.listByMap(orderMap);
 
-                        if ((productOrderRecordList != null) && (productOrderRecordList.size() > 0)) {
+                        if ((productOrderDetailList != null) && (productOrderDetailList.size() > 0)) {
 
-                            for (i = 0; i < productOrderRecordList.size(); i++) {
-                                ProductOrderRecord productOrderRecord = productOrderRecordList.get(i);
-                                createTime = "'" + dateTimeFormat.format(productOrderRecord.getCreateTime()) + "'";
-                                updateTime = (productOrderRecord.getUpdateTime() == null) ? "NULL" : "'" + dateTimeFormat.format(productOrderRecord.getUpdateTime()) + "'";
+                            for (int j = 0; j < productOrderDetailList.size(); j++) {
+                                ProductOrderDetail productOrderDetail = productOrderDetailList.get(j);
+                                createTime = "'" + dateTimeFormat.format(productOrderDetail.getCreateTime()) + "'";
+                                updateTime = (productOrderDetail.getUpdateTime() == null) ? "NULL" : "'" + dateTimeFormat.format(productOrderDetail.getUpdateTime()) + "'";
                                 serviceSQL += "INSERT INTO order_detail VALUES( " +
-                                        productOrderRecord.getId() + ", " +
-                                        productOrderRecord.getOrderId() + ", " +
-                                        productOrderRecord.getProId() + ", " +
-                                        productOrderRecord.getProType() + ", " +
-                                        "'" + productOrderRecord.getProName() + "', " +
-                                        productOrderRecord.getAilightCount() + ", " +
-                                        productOrderRecord.getRecordCount() + ", " +
-                                        "'" + dateFormat.format(productOrderRecord.getProBegintime()) + "', " +
-                                        "'" + dateFormat.format(productOrderRecord.getProEndtime()) + "', " +
-                                        productOrderRecord.getIsShare() + ", " +
+                                        productOrderDetail.getId() + ", " +
+                                        productOrderDetail.getOrderId() + ", " +
+                                        productOrderDetail.getProId() + ", " +
+                                        productOrderDetail.getProType() + ", " +
+                                        "'" + productOrderDetail.getProName() + "', " +
+                                        productOrderDetail.getAilightCount() + ", " +
+                                        productOrderDetail.getRecordCount() + ", " +
+                                        "'" + dateFormat.format(productOrderDetail.getProBegintime()) + "', " +
+                                        "'" + dateFormat.format(productOrderDetail.getProEndtime()) + "', " +
+                                        productOrderDetail.getIsShare() + ", " +
                                         "0, 0, " +
                                         // 服务验证字符串【合作商ID、医院ID、科室ID、产品ID、开始日期、结束日期、读片数量、报告数量、已使用读片数量、已使用报告数量】
                                         "'" + EncryptUtils.encryptAES((partnerDockingInfo.getPartnerId().toString() + "|" +
                                         partnerDockingInfo.getHospitalId().toString() + "|" +
                                         partnerDockingInfo.getDepartmentId().toString() + "|" +
-                                        productOrderRecord.getProId().toString() + "|" +
-                                        dateFormat.format(productOrderRecord.getProBegintime()) + "|" +
-                                        dateFormat.format(productOrderRecord.getProEndtime()) + "|" +
-                                        productOrderRecord.getAilightCount().toString() + "|" +
-                                        productOrderRecord.getRecordCount() + "|" +
+                                        productOrderDetail.getProId().toString() + "|" +
+                                        dateFormat.format(productOrderDetail.getProBegintime()) + "|" +
+                                        dateFormat.format(productOrderDetail.getProEndtime()) + "|" +
+                                        productOrderDetail.getAilightCount().toString() + "|" +
+                                        productOrderDetail.getRecordCount() + "|" +
                                         "0|0"), SecurityConstants.AES_KEY) + "', " +
-                                        productOrderRecord.getIsDel() + ", " +
-                                        productOrderRecord.getEnabled() + ", " +
+                                        productOrderDetail.getIsDel() + ", " +
+                                        productOrderDetail.getEnabled() + ", " +
                                         createTime + ", " +
-                                        productOrderRecord.getCreateUserId() + ", " +
-                                        "'" + productOrderRecord.getCreateUserName() + "', " +
+                                        productOrderDetail.getCreateUserId() + ", " +
+                                        "'" + productOrderDetail.getCreateUserName() + "', " +
                                         updateTime + ", " +
-                                        productOrderRecord.getUpdateUserId() + ", " +
-                                        "'" + productOrderRecord.getUpdateUserName() + "' " +
+                                        productOrderDetail.getUpdateUserId() + ", " +
+                                        "'" + productOrderDetail.getUpdateUserName() + "' " +
                                         ");\n\r";
                             }
                         } else {
@@ -405,5 +402,4 @@
         return dbSql;
     }
 
-    ;
 }
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 82410ab..029ff37 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
@@ -1,10 +1,12 @@
 package com.kidgrow.oprationcenter.service.impl;
 
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 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.AesUtils;
 import com.kidgrow.common.utils.DateUtils;
 import com.kidgrow.common.utils.StringUtils;
 import com.kidgrow.oprationcenter.feign.DiagnosticService;
@@ -29,6 +31,7 @@
 import org.springframework.cglib.beans.BeanCopier;
 import org.springframework.stereotype.Service;
 
+import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -442,4 +445,89 @@
             return ResultBody.failed("医院和科室数据有误!");
         }
     }
+
+    /**
+     * 私有云套餐验证
+     * @param hospitalId 医院ID
+     * @param departmentId  科室ID
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    public ResultBody verificateProductOrderDetail(Long hospitalId, Long departmentId ){
+        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+
+        // 查询科室可用的合同列表【当前日期在合同开始、结束日期之间】
+        List<ProductOrder> productOrderList = iProductOrderService.list(
+                new QueryWrapper<ProductOrder>()
+                    .eq("hospital_id",hospitalId)
+                    .eq("department_id",departmentId)
+                    //.le("contract_begin_time",dateFormat.format(DateTime.now()))
+                    //.ge("contract_end_time",dateFormat.format(DateTime.now()))
+                    .eq("enabled",1)
+                    .eq("is_del",0)
+        );
+
+        if ((productOrderList != null) && (productOrderList.size() > 0)) {
+            for (int i = 0 ; i < productOrderList.size(); i++) {
+
+                ProductOrder productOrder = productOrderList.get(i);
+                // 查询合同可用的套餐【当前日期在套餐开始、结束日期之间,剩余读片量大于零】
+                List<ProductOrderDetail> productOrderDetailList = baseMapper.selectList(
+                        new QueryWrapper<ProductOrderDetail>()
+                                .eq("order_id",productOrder.getId())
+                                //.le("pro_begintime",dateFormat.format(DateTime.now()))
+                                //.ge("pro_endtime",dateFormat.format(DateTime.now()))
+                                //.gt("order_ailight_count",0)
+                                //.gt("order_ailight_count - ailight_count",0)
+                                .eq("enabled",1)
+                                .eq("is_del",0)
+
+                );
+                if ((productOrderDetailList != null) && (productOrderDetailList.size() > 0)) {
+                    try {
+                        for (int j = 0; j < productOrderDetailList.size(); j++) {
+                            ProductOrderDetail productOrderDetail = productOrderDetailList.get(j);
+                            if ((productOrderDetail.getAilightCountEncryption() == null) || (productOrderDetail.getAilightCountEncryption().isEmpty())) {
+                                log.error("可用读片数量验证串为空");
+                                return ResultBody.failed("可用读片数量验证串为空");
+                            }
+                            if ((productOrderDetail.getProBegintimeEncryption() == null) || (productOrderDetail.getProBegintimeEncryption().isEmpty())) {
+                                log.error("套餐开始日期验证串为空");
+                                return ResultBody.failed("套餐开始日期验证串为空");
+                            }
+                            if ((productOrderDetail.getProEndtimeEncryption() == null) || (productOrderDetail.getProEndtimeEncryption().isEmpty())) {
+                                log.error("套餐结束日期验证串为空");
+                                return ResultBody.failed("套餐结束日期验证串为空");
+                            }
+
+                            String ailightCount = AesUtils.desEncrypt(productOrderDetail.getAilightCountEncryption());
+                            String proBeginTime = AesUtils.desEncrypt(productOrderDetail.getProBegintimeEncryption());
+                            String proEndTime = AesUtils.desEncrypt(productOrderDetail.getProEndtimeEncryption());
+
+                            if ((ailightCount.isEmpty()) || (!productOrderDetail.getAilightCount().toString().equals(ailightCount))) {
+                                log.error("可用读片数量验证失败");
+                                return ResultBody.failed("可用读片数量验证失败");
+                            }
+                            if ((proBeginTime.isEmpty()) || (!dateFormat.format(productOrderDetail.getProBegintime()).equals(proBeginTime))) {
+                                log.error("套餐开始日期验证失败");
+                                return ResultBody.failed("套餐开始日期验证失败");
+                            }
+                            if ((proEndTime.isEmpty()) || (!dateFormat.format(productOrderDetail.getProEndtime()).equals(proEndTime))) {
+                                log.error("套餐结束日期验证失败");
+                                return ResultBody.failed("套餐结束日期验证失败");
+                            }
+
+                        }
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                        return ResultBody.failed(e.getMessage());
+                    }
+
+                }
+            }
+//        } else {
+//            return ResultBody.failed("无有效的合同");
+        }
+        log.error("私有云套餐验证通过");
+        return ResultBody.ok().msg("私有云套餐验证通过");
+    }
 }
diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java
index b1996c0..cfe1f36 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java
@@ -198,4 +198,20 @@
         return productOrderService.getStatus(productOrder);
     }
 
+    /**
+     * 根据Map的条件获取合同列表
+     * @param params
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    @ApiOperation(value = "根据Map的条件获取合同列表")
+    @PostMapping("/findProductOrderListByMap")
+    public ResultBody findProductOrderListByMap(@RequestBody Map<String, Object> params) {
+        List<ProductOrder> productOrderList = productOrderService.listByMap(params);
+        if ((productOrderList!=null) && (productOrderList.size() > 0)) {
+            return ResultBody.ok().data(productOrderList);
+        } else {
+            return ResultBody.failed();
+        }
+    }
+
 }
diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderDetailController.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderDetailController.java
index e6311d1..8b4fce7 100644
--- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderDetailController.java
+++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderDetailController.java
@@ -4,6 +4,7 @@
 import com.kidgrow.common.constant.CommonConstant;
 import com.kidgrow.common.controller.BaseController;
 import com.kidgrow.common.model.*;
+import com.kidgrow.common.utils.AesUtils;
 import com.kidgrow.common.utils.DateUtils;
 import com.kidgrow.oprationcenter.model.HospitalInfo;
 import com.kidgrow.oprationcenter.model.ProductOrder;
@@ -31,6 +32,7 @@
 
 import javax.servlet.http.HttpServletRequest;
 import javax.validation.Valid;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 
@@ -58,6 +60,7 @@
     private IProductOrderService productOrderService;
     @Autowired
     private SysUserService sysUserServiceFeign;
+
     /**
      * 列表
      */
@@ -91,6 +94,7 @@
         }
         return productOrderDetailService.all(params);
     }
+
     /**
      * 列表
      */
@@ -143,6 +147,7 @@
         }
         return productOrderDetailService.groupList(params);
     }
+
     /**
      * 查询到期列表
      */
@@ -159,6 +164,7 @@
         }
         return productOrderDetailService.productEndList(params);
     }
+
     /**
      * 获取医院套餐是否到期和到期时间
      * data内 isend为true说明套餐到期
@@ -172,8 +178,8 @@
 
     @ApiOperation(value = "获取医院套餐是否到期和到期时间")
     @GetMapping("/UserProductDetailData")
-    public ResultBody<UserProductData> serProductDetailData(@RequestParam Long hospitalId, @RequestParam Long departmentId,@RequestParam String diagnosticId) {
-        return productOrderDetailService.userProductDetailData(hospitalId, departmentId,diagnosticId);
+    public ResultBody<UserProductData> serProductDetailData(@RequestParam Long hospitalId, @RequestParam Long departmentId, @RequestParam String diagnosticId) {
+        return productOrderDetailService.userProductDetailData(hospitalId, departmentId, diagnosticId);
     }
 
     /**
@@ -187,7 +193,7 @@
     @ApiOperation(value = "获取医院套餐是否到期和到期时间")
     @PostMapping("/serviceperiod")
     public ResultBody<UserProductData> servicePeriod(@RequestBody HospitalInfo hospitalInfo) {
-        return productOrderDetailService.userProductDetailData(hospitalInfo.getHospitalId(), hospitalInfo.getDepartmentId(),hospitalInfo.getDiagnosticId());
+        return productOrderDetailService.userProductDetailData(hospitalInfo.getHospitalId(), hospitalInfo.getDepartmentId(), hospitalInfo.getDiagnosticId());
     }
 
     /**
@@ -215,7 +221,7 @@
      */
     @ApiOperation(value = "保存")
     @PostMapping
-    public ResultBody save(@Valid @RequestBody ProductOrderDetail productOrderDetail, BindingResult bindingResult, @LoginUser SysUser sysUser) {
+    public ResultBody save(@Valid @RequestBody ProductOrderDetail productOrderDetail, BindingResult bindingResult, @LoginUser SysUser sysUser)  {
         List<String> errMsg = new ArrayList<>();
         if (bindingResult.hasErrors()) {
             for (ObjectError error : bindingResult.getAllErrors()) {
@@ -227,6 +233,18 @@
             if (organizations.size() > 0) {
                 productOrderDetail.setCreateUserOrgCode(organizations.get(organizations.size() - 1).getOrgCode());
             }
+            // 对于读片量、产品有效的开始、结束日期进行加密
+            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+            if ((productOrderDetail.getAilightCountEncryption() == null) || (productOrderDetail.getAilightCountEncryption().isEmpty())) {
+                try {
+                    productOrderDetail.setAilightCountEncryption(AesUtils.encrypt(productOrderDetail.getAilightCount().toString()));
+                    productOrderDetail.setProBegintimeEncryption(AesUtils.encrypt(dateFormat.format(productOrderDetail.getProBegintime())));
+                    productOrderDetail.setProEndtimeEncryption(AesUtils.encrypt(dateFormat.format(productOrderDetail.getProEndtime())));
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+
             boolean v = productOrderDetailService.saveOrUpdate(productOrderDetail);
             if (v) {
                 return ResultBody.ok().data(productOrderDetail).msg("保存成功");
@@ -242,7 +260,7 @@
     @ApiOperation(value = "保存")
     @PostMapping("/saveall")
     @Transactional(rollbackFor = Exception.class)
-    public ResultBody batchInsert(@Valid @RequestBody List<ProductOrderDetail> list,BindingResult bindingResult) {
+    public ResultBody batchInsert(@Valid @RequestBody List<ProductOrderDetail> list, BindingResult bindingResult) {
         List<String> errMsg = new ArrayList<>();
         if (bindingResult.hasErrors()) {
             for (ObjectError error : bindingResult.getAllErrors()) {
@@ -254,12 +272,12 @@
             ProductOrder productOrder = productOrderService.getById(list.get(0).getOrderId());
             if (productOrder != null) {
                 //是否管理人员
-                boolean ismanager=false,
+                boolean ismanager = false,
                         //是否有待审核套餐
-                        isenabled=false;
+                        isenabled = false;
                 //如果是超管,高管,销售部门管理  则不受次数限制
-                ResultBody<LoginAppUser> loginAppUserTemp=sysUserServiceFeign.getLoginAppUser();
-                LoginAppUser loginAppUser=loginAppUserTemp.getData();
+                ResultBody<LoginAppUser> loginAppUserTemp = sysUserServiceFeign.getLoginAppUser();
+                LoginAppUser loginAppUser = loginAppUserTemp.getData();
                 if (loginAppUser != null) {
 
                     List<SysRole> sysRoleList = loginAppUser.getRoles();
@@ -270,7 +288,7 @@
                                     roleName.equals(CommonConstant.SALE_MANAGER_ROLE_CODE) ||
                                     roleName.equals(CommonConstant.PC_ADMIN_ROLE_CODE) ||
                                     roleName.equals(CommonConstant.OPRATIONMANAGER_ROLE_CODE)) {
-                                ismanager=true;
+                                ismanager = true;
                                 break;
                             }
                         }
@@ -280,13 +298,27 @@
                     int counts = productOrderDetailService.getEnabledCount(productOrder.getDepartmentId());
                     if (counts >= CommonConstant.MAX_FREE_COUNT) {
                         //超过了限定次数  将试用套餐改为禁用 待审核
-                        for (int i = 0; i <list.size() ; i++) {
-                            if (list.get(i).getProType()==0) {
+                        for (int i = 0; i < list.size(); i++) {
+                            if (list.get(i).getProType() == 0) {
                                 //试用套餐
                                 list.get(i).setEnabled(false);
-                                isenabled=true;
+                                isenabled = true;
                             }
                         }
+                    }
+                }
+                // 对于读片量、产品有效的开始、结束日期进行加密
+                SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+                for (int i = 0; i < list.size(); i++) {
+                    if ((list.get(i).getAilightCountEncryption() == null) || (list.get(i).getAilightCountEncryption().isEmpty())) {
+                        try {
+                            list.get(i).setAilightCountEncryption(AesUtils.encrypt(list.get(i).getAilightCount().toString()));
+                            list.get(i).setProBegintimeEncryption(AesUtils.encrypt(dateFormat.format(list.get(i).getProBegintime())));
+                            list.get(i).setProEndtimeEncryption(AesUtils.encrypt(dateFormat.format(list.get(i).getProEndtime())));
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+
                     }
                 }
                 //写充值套餐给用户
@@ -320,9 +352,7 @@
                 if (v && r && p) {
                     if (isenabled) {
                         return ResultBody.ok().data(list.size()).msg("充值成功,但是试用套餐需要管理审核才可使用!");
-                    }
-                    else
-                    {
+                    } else {
                         return ResultBody.ok().data(list.size()).msg("产品充值成功...");
                     }
                 } else {
@@ -396,71 +426,102 @@
 
     /**
      * 统计获取数据量
-     * @param datatype
-     * 0 试用审核量
-     * 1 套餐总量
-     * 2 未处理用户反馈
-     * 3 未处理数据需求
+     *
+     * @param datatype 0 试用审核量
+     *                 1 套餐总量
+     *                 2 未处理用户反馈
+     *                 3 未处理数据需求
      * @return
      */
     @ApiOperation(value = "统计获取数据量")
     @GetMapping("/oprationChart")
     public ResultBody oprationChart(int datatype) {
-        int counts=productOrderDetailService.oprationChart(datatype);
-        return ResultBody.ok().data(counts).msg("数据获取成功!") ;
+        int counts = productOrderDetailService.oprationChart(datatype);
+        return ResultBody.ok().data(counts).msg("数据获取成功!");
     }
 
     /**
      * 按指定类型统计合同数量
-     * @param params
-     *    datatype     1 按年
-     *                 2 按月
-     *                 3 按天
-     *                 4 按周
-     *    beginTime 查询时间段的开始时间
-     *    endTime   结束时间
+     *
+     * @param params datatype     1 按年
+     *               2 按月
+     *               3 按天
+     *               4 按周
+     *               beginTime 查询时间段的开始时间
+     *               endTime   结束时间
      * @return
      */
     @ApiOperation(value = "按指定类型统计合同数量")
     @GetMapping("/productOrderChart")
-    public ResultBody productOrderChart(@RequestParam  Map<String, Object> params) {
-        List<OrderChartVo> orderChartVo=productOrderDetailService.productOrderChart(params);
-        return ResultBody.ok().data(orderChartVo).msg("数据获取成功!") ;
+    public ResultBody productOrderChart(@RequestParam Map<String, Object> params) {
+        List<OrderChartVo> orderChartVo = productOrderDetailService.productOrderChart(params);
+        return ResultBody.ok().data(orderChartVo).msg("数据获取成功!");
     }
 
     /**
      * 统计产品的使用数量
-     * @return  ccount 是数量
-     *          units 是产品名称
+     *
+     * @return ccount 是数量
+     * units 是产品名称
      */
     @ApiOperation(value = "统计产品的使用数量")
     @GetMapping("/proCountChart")
     public ResultBody proCountChart() {
-        List<OrderChartVo> orderChartVo=productOrderDetailService.proCountChart();
-        return ResultBody.ok().data(orderChartVo).msg("数据获取成功!") ;
+        List<OrderChartVo> orderChartVo = productOrderDetailService.proCountChart();
+        return ResultBody.ok().data(orderChartVo).msg("数据获取成功!");
     }
 
     /**
      * 获取软件服务周期 和 读片总量
-     *
      */
     @ApiOperation(value = "获取软件服务周期")
     @GetMapping("/getContractBeginEndTimeAndNum")
     public ResultBody getContractBeginEndTimeAndNum(@RequestParam("departmentId") Long departmentId) {
-       Map<String,Object> map = new HashMap<>();
-        map.put("department_id",departmentId);
-        map.put("enabled",true);
-        map.put("is_del",false);
+        Map<String, Object> map = new HashMap<>();
+        map.put("department_id", departmentId);
+        map.put("enabled", true);
+        map.put("is_del", false);
         List<ProductOrder> productOrders = productOrderService.listByMap(map);
         map = new HashMap<>();
-        if(productOrders!=null&&productOrders.size()>0){
-            IntSummaryStatistics intSummaryStatistics = productOrders.stream().filter(a-> a.getContractNum()!=null&&a.getEnabled()).mapToInt((x) -> x.getContractNum()).summaryStatistics();
-            Date minDate = productOrders.stream().filter(a->a.getEnabled()).map(e -> e.getContractBeginTime()).min((e1, e2) -> e1.compareTo(e2)).get();
-            Date manDate = productOrders.stream().filter(a->a.getEnabled()).map(e -> e.getContractEndTime()).max((e1, e2) -> e1.compareTo(e2)).get();
+        if (productOrders != null && productOrders.size() > 0) {
+            IntSummaryStatistics intSummaryStatistics = productOrders.stream().filter(a -> a.getContractNum() != null && a.getEnabled()).mapToInt((x) -> x.getContractNum()).summaryStatistics();
+            Date minDate = productOrders.stream().filter(a -> a.getEnabled()).map(e -> e.getContractBeginTime()).min((e1, e2) -> e1.compareTo(e2)).get();
+            Date manDate = productOrders.stream().filter(a -> a.getEnabled()).map(e -> e.getContractEndTime()).max((e1, e2) -> e1.compareTo(e2)).get();
             map.put("count", intSummaryStatistics.getSum());
-            map.put("beginTime",DateUtils.formatDate(minDate,"yyyy-MM-dd HH:mm:ss"));
-            map.put("endTime",DateUtils.formatDate(manDate,"yyyy-MM-dd HH:mm:ss"));
+            map.put("beginTime", DateUtils.formatDate(minDate, "yyyy-MM-dd HH:mm:ss"));
+            map.put("endTime", DateUtils.formatDate(manDate, "yyyy-MM-dd HH:mm:ss"));
         }
-        return  ResultBody.ok().data(map);
+        return ResultBody.ok().data(map);
+    }
+
+    /**
+     * 私有云套餐验证
+     * @param params 参数
+     *      hospitalId 医院ID
+     *      departmentId  科室ID
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    @ApiOperation(value = "私有云套餐验证")
+    @PostMapping("/verificateProductOrderDetail")
+    public ResultBody verificateProductOrderDetail(@RequestBody Map<String,Object> params  ){
+        Long hospitalId = Long.valueOf(params.get("hospitalId").toString());
+        Long departmentId = Long.valueOf(params.get("departmentId").toString());
+        return productOrderDetailService.verificateProductOrderDetail(hospitalId,departmentId);
+    }
+
+    /**
+     * 根据Map的条件获取合同明细(套餐)列表
+     * @param params
+     * @return com.kidgrow.common.model.ResultBody
+     */
+    @ApiOperation(value = "根据Map的条件获取合同明细(套餐)列表")
+    @PostMapping("/findProductOrderDetailListByMap")
+    public ResultBody findProductOrderDetailListByMap(@RequestBody Map<String, Object> params) {
+        List<ProductOrderDetail> productOrderDetailList = productOrderDetailService.listByMap(params);
+        if ((productOrderDetailList!=null) && (productOrderDetailList.size() > 0)) {
+            return ResultBody.ok().data(productOrderDetailList);
+        } else {
+            return ResultBody.failed();
+        }
     }
 }

--
Gitblit v1.8.0