单宽带未下单定时器

common/src/main/java/com/winsun/mapper/OrderMapper.java

@@ -155,4 +155,10 @@ public interface OrderMapper extends BaseMapper<Order> {
      * */
      * */
     @Select("SELECT * FROM hhr_order WHERE contact_number = #{phone} and business_package = '预存送流量'")
     @Select("SELECT * FROM hhr_order WHERE contact_number = #{phone} and business_package = '预存送流量'")
     List<Map<String, Object>> selectOrderYcsll(@Param("phone") String phone);
     List<Map<String, Object>> selectOrderYcsll(@Param("phone") String phone);
+
+    /**
+     * 查询单宽为未下单订单
+     * */
+    @Select("SELECT * FROM hhr_order WHERE user_type = '5' and order_status = '未下单'")
+    List<Map<String,Object>> selectDKList();
 }
 }

task/src/main/java/com/winsun/TimingTask/RhZhiNenTask.java

@@ -55,11 +55,35 @@ public class RhZhiNenTask {
     private IntelligenceSendOrder intelligenceSendOrder;
     private IntelligenceSendOrder intelligenceSendOrder;
 
 
     /**
     /**
-     * 下发智能平台订单
+     * 下发智能平台订单 -- 单宽
      *
      *
      */
      */
     @Scheduled(cron = "0 0/5 * * * ? ")
     @Scheduled(cron = "0 0/5 * * * ? ")
-//    @Scheduled(fixedRate=2800000)
+    public void sendZhiNengOrderDK() {
+        log.info("智能平台定时器单宽下单启动");
+        try{
+            // 查询未下单并为单宽的订单
+            List<Map<String,Object>> orders = orderMapper.selectDKList();
+
+            // 发送下单请求
+            for(int i = 0; i < orders.size(); ++i) {
+                intelligenceSendOrder.singleBroadSendOrder(orders.get(i));
+            }
+
+        }catch(Exception e) {
+            e.printStackTrace();
+            log.error("智能平台定时器单宽下单异常");
+            log.error(e.getMessage());
+        }
+    }
+
+
+    /**
+     * 下发智能平台订单 -- 融合
+     *
+     */
+    @Scheduled(cron = "0 0/5 * * * ? ")
+    //    @Scheduled(fixedRate=2800000)
     public void sendZhiNengOrder() {
     public void sendZhiNengOrder() {
         log.info("智能平台定时器下单启动");
         log.info("智能平台定时器下单启动");
         try{
         try{
@@ -70,6 +94,7 @@ public class RhZhiNenTask {
             Calendar calendar = Calendar.getInstance();
             Calendar calendar = Calendar.getInstance();
             // 查询未下单并且融合时间为今天的订单
             // 查询未下单并且融合时间为今天的订单
             Wrapper<Order> wrapper = new EntityWrapper<>();
             Wrapper<Order> wrapper = new EntityWrapper<>();
+            wrapper.in("user_type", "3,10");
             wrapper.eq("order_status", "未下单");
             wrapper.eq("order_status", "未下单");
             wrapper.ge("rh_time", sdf.format(calendar.getTime()));
             wrapper.ge("rh_time", sdf.format(calendar.getTime()));
             calendar.add(Calendar.DATE, 1);
             calendar.add(Calendar.DATE, 1);