呵呵自动拼团短信推送

src/main/java/com/caimei365/tools/mapper/HeheMapper.java

@@ -88,4 +88,9 @@ public interface HeheMapper {
      * @param collageId
      */
     void closeCollage(Integer collageId);
+
+    /**
+     * 根据拼团id查询已支付的拼团成员手机号
+     */
+    List<String> getMobilesByCollageId(Integer collageId);
 }

src/main/java/com/caimei365/tools/task/HeheTask.java

@@ -109,6 +109,7 @@ public class HeheTask {
      * 每隔一小时查询拼团一小时内结束的拼团，自动完成拼团
      */
     @Scheduled(cron = "0 0 * * * ?")
+//    @Scheduled(cron = "0 0/5 * * * ?")
     public void collageComplete() {
         log.info("自动完成拼团");
         List<HeheCollageBo> endSoonCollageList = heheMapper.findEndSoonCollage();
@@ -119,6 +120,9 @@ public class HeheTask {
             log.info("拼团id:" + collageId + ":自动完成拼团");
             // 自动拼成拼团
             heheMapper.completeCollage(collageId);
+            List<String> mobileList = heheMapper.getMobilesByCollageId(collageId);
+            // 拼团成功短信推送
+            mobileList.forEach(mobile-> SmsUtil.sendSms(1, mobile, "您的商品已拼团成功，请赶紧登录呵呵商城小程序查看订单吧。"));
             // 关闭其它未支付拼团订单
             List<Integer> orderIdList = heheMapper.findNoPayCollageOrderIds(collageId);
             orderIdList.forEach(noPayOrderId->{

src/main/resources/mapper/HeheMapper.xml

@@ -160,5 +160,11 @@
           and timestampdiff(minute, endTime, NOW()) <![CDATA[ >= ]]> 0
           and status = 0
     </select>
+    <select id="getMobilesByCollageId" resultType="java.lang.String">
+        select chu.mobile from cm_hehe_collage_member chcm
+                                   left join cm_order co on chcm.orderId = co.orderID
+                                   left join cm_hehe_user chu on chcm.userId = chu.userId
+        where collageId = #{collageId} and co.receiptStatus = 3
+    </select>
 
 </mapper>