From 995cd95460fbd214c3ea0c70f0c6ffe3e1dbe54b Mon Sep 17 00:00:00 2001
From: liquanyu <liquanyu@lymsh.com>
Date: Tue, 30 Mar 2021 10:59:40 +0800
Subject: [PATCH] update

---
 .../permission/dao/master/CouponMapper.java        |  1 +
 .../platform/permission/service/CouponService.java |  8 +++
 .../permission/service/impl/CouponServiceImpl.java | 12 ++++
 .../main/resources/mainOrm/master/CouponMapper.xml | 22 ++++++++
 .../com/lyms/platform/query/PatientsQuery.java     | 13 ++++-
 .../operate/web/controller/TestController.java     | 11 ++++
 .../platform/operate/web/facade/PatientFacade.java | 66 +++++++++++++++++++++-
 7 files changed, 131 insertions(+), 2 deletions(-)

diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/CouponMapper.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/CouponMapper.java
index 787f204..00eb7dd 100644
--- a/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/CouponMapper.java
+++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/CouponMapper.java
@@ -13,6 +13,7 @@ import java.util.Set;
  */
 public interface CouponMapper {
     List<CouponInfo> findList(Map<String, Object> params);
+    List<CouponInfo> findLists(Map<String, Object> params);
     List<Map<String,Object>> findCouponList(Map<String, Object> params);
 
     List<CouponInfo> findErrorData();
diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/CouponService.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/CouponService.java
index 734f203..7e2b92b 100644
--- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/CouponService.java
+++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/CouponService.java
@@ -1,6 +1,7 @@
 package com.lyms.platform.permission.service;
 
 import com.lyms.platform.common.result.BaseObjectResponse;
+import com.lyms.platform.permission.model.CouponInfo;
 
 import java.util.Date;
 import java.util.List;
@@ -61,4 +62,11 @@ public interface CouponService{
     String findByType(String id, int i);
 
     void invalid2(String pid, Date created, String s);
+
+    /**
+     * 获取用户能用的优惠劵数量
+     * @param userId
+     * @return
+     */
+    int getUserCouponCanUseCount(String userId);
 }
diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/CouponServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/CouponServiceImpl.java
index e5b25de..07e163e 100644
--- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/CouponServiceImpl.java
+++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/CouponServiceImpl.java
@@ -690,6 +690,18 @@ public class CouponServiceImpl implements CouponService {
     }
 
     @Override
+    public int getUserCouponCanUseCount(String userId) {
+
+        Map<String, Object> param = new HashMap<>();
+        param.put("userId", userId);
+        param.put("type", 2);
+        param.put("status", 1);
+        List<CouponInfo> couponInfos = couponMapper.findLists(param);
+
+        return couponInfos.size();
+    }
+
+    @Override
     public List<Map<String, Object>> queryCouponItemsByType(Map<String, Object> params) {
         return couponMapper.queryCouponItemsByType(params);
     }
diff --git a/platform-biz-service/src/main/resources/mainOrm/master/CouponMapper.xml b/platform-biz-service/src/main/resources/mainOrm/master/CouponMapper.xml
index 8539e2a..0cca93e 100644
--- a/platform-biz-service/src/main/resources/mainOrm/master/CouponMapper.xml
+++ b/platform-biz-service/src/main/resources/mainOrm/master/CouponMapper.xml
@@ -61,6 +61,28 @@
     </select>
 
 
+    <select id="findLists" parameterType="map" resultMap="couponInfoMap">
+        select id,
+        <include refid="columnList"/>
+        from coupon_info
+        <where>
+            <if test="userId != null">
+                and user_id = #{userId}
+            </if>
+            <if test="code != null">
+                and sequence_id = #{code}
+            </if>
+            <if test="hospitalId != null">
+                and create_hospital_id = #{hospitalId}
+            </if>
+            <if test="status != null">
+                and status = #{status}
+            </if>
+        </where>
+    </select>
+
+
+
     <select id="findCouponList" parameterType="map" resultType="map">
         select b.actual_start, b.actual_end, b.unit_type, a.create_hospital_id, c.type, c.area_type,a.status
         from coupon_info a, coupon_template b, coupon_type c
diff --git a/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java b/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java
index 52c8a84..114513c 100644
--- a/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java
+++ b/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java
@@ -376,7 +376,8 @@ public class PatientsQuery extends BaseQuery implements IConvertToNativeQuery {
 
     private String lowerHairOgrId;
 
-
+    // 是否发放过优惠券
+    private Boolean isSendCoupon;
     //条码号
     private  String numberCode;
 
@@ -391,6 +392,13 @@ public class PatientsQuery extends BaseQuery implements IConvertToNativeQuery {
     private Date firstCheckTimeStart;
     private Date firstCheckTimeEnd;
 
+    public Boolean getIsSendCoupon() {
+        return isSendCoupon;
+    }
+
+    public void setIsSendCoupon(Boolean isSendCoupon) {
+        this.isSendCoupon = isSendCoupon;
+    }
 
     public String getFirstCheckId() {
         return firstCheckId;
@@ -539,6 +547,9 @@ public class PatientsQuery extends BaseQuery implements IConvertToNativeQuery {
         if (null != pcensusTypeId) {
             condition = condition.and("pcensusTypeId", pcensusTypeId, MongoOper.IS);
         }
+        if (null != isSendCoupon) {
+            condition = condition.and("isSendCoupon", isSendCoupon, MongoOper.IS);
+        }
         if (null != numberCode) {
             condition = condition.and("numberCode", numberCode, MongoOper.IS);
         }
diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
index 0758b49..b1bb1b7 100644
--- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
+++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
@@ -165,6 +165,11 @@ public class TestController extends BaseController {
     @Autowired
     private SieveService sieveService;
 
+
+
+    @Autowired
+    private PatientFacade patientFacade;
+
     @Autowired
     private BabySieveFacede babySieveFacede;
 
@@ -220,6 +225,12 @@ public class TestController extends BaseController {
         babySieveFacede.babyShortMessageQhdTimerWork();
         return null;
     }
+    @RequestMapping(method = RequestMethod.GET, value = "/noticeCouponUser")
+    @ResponseBody
+    public BaseResponse noticeCouponUser() {
+        patientFacade.noticeCouponUser();
+        return null;
+    }
 
     /**
      * 功能描述 衡水线上修改采样孕周数据问题
diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientFacade.java
index 6fe1961..7f3ce5b 100644
--- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientFacade.java
+++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientFacade.java
@@ -26,6 +26,7 @@ import com.lyms.platform.permission.dao.master.CouponMapper;
 import com.lyms.platform.permission.model.Organization;
 import com.lyms.platform.permission.model.OrganizationQuery;
 import com.lyms.platform.permission.model.Users;
+import com.lyms.platform.permission.service.CouponService;
 import com.lyms.platform.permission.service.OrganizationService;
 import com.lyms.platform.permission.service.UsersService;
 import com.lyms.platform.pojo.*;
@@ -1203,7 +1204,7 @@ public class PatientFacade extends BaseServiceImpl {
      * @param list
      */
     private static void ListSort(List <Patients> list) {
-        Collections.sort(list, new Comparator <Patients>() {
+        Collections.sort(list, new Comparator<Patients>() {
             @Override
             public int compare(Patients o1, Patients o2) {
                 SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm");
@@ -3142,4 +3143,67 @@ public class PatientFacade extends BaseServiceImpl {
         baseResponse.setObject(result);
         return baseResponse;
     }
+
+
+    /**
+     * 30孕周的孕妇 提醒孕妇还有多少优惠劵没有使用
+     */
+    public void noticeCouponUser()
+    {
+
+        PatientsQuery patientsQuery = new PatientsQuery();
+        Date endDate = DateUtil.addDay(DateUtil.parseYMD(DateUtil.getyyyy_MM_dd(new Date())), -(30 * 7));
+        patientsQuery.setLastMensesStart(endDate);
+        patientsQuery.setLastMensesEnd(endDate);
+        patientsQuery.setYn(YnEnums.YES.getId());
+        patientsQuery.setIsSendCoupon(true);
+        List<Patients> patients = patientsService.queryPatient(patientsQuery);
+        if (CollectionUtils.isNotEmpty(patients))
+        {
+
+            for (Patients patient : patients)
+            {
+                int count = couponService.getUserCouponCanUseCount(patient.getPid());
+                if (count == 0)
+                {
+                    continue;
+                }
+
+                List<MsgRequest> messages = new ArrayList<>();
+                MsgRequest mr = new MsgRequest();
+                mr.setFirst("您还有"+count+"张优惠券未使用，去医院产检时，记得同时使用，主动把优惠券出示给医护人员！");
+                mr.setObjType(ServiceObjEnums.YUNOBJ.getId());
+                mr.setPhone(patient.getPhone());
+
+                mr.setTimeType(SmsTimeTypeEnums.NO_ONTIME.getId());
+                mr.setPlanTime(DateUtil.getyyyy_MM_dd(new Date())+" 16:00:00");
+
+                mr.setTypeId(ProjectTypeEnums.YNXT.getId());
+                mr.setSubTypeId(SmsServiceEnums.FWKT.getId());
+                mr.setStatus(SmsStatusEnums.WFS.getId());
+                mr.setHospitalId(patient.getHospitalId());
+                mr.setTempId(patient.getId());
+                mr.setPatientId(patient.getId());
+                mr.setSmsStatus(SmsStatusEnums.WFS.getId());
+                mr.setServiceType(2);  //判断发送类型
+
+                mr.setKeyword1("优惠劵提醒");
+                mr.setKeyword2(DateUtil.getyyyy_MM_dd(new Date()));
+                mr.setRemark("");
+                mr.setCreated(DateUtil.getyyyy_MM_dd_hms(new Date()));
+
+                mr.setWxTempId(WxTempleteIdEnums.YUN_FU_OPEN.getId());
+                messages.add(mr);
+                ExceptionUtils.catchException("patient build msg = " + messages);
+                if (CollectionUtils.isNotEmpty(messages)) {
+                    smsConfigFacade.saveMsg(messages, patient.getHospitalId());
+                }
+
+            }
+        }
+    }
+
+
+    @Autowired
+    private CouponService couponService;
 }
-- 
1.8.3.1