订单定时任务

pom.xml

@@ -230,6 +230,22 @@
 			<!--<artifactId>spring-boot-starter-test</artifactId>-->
 			<!--<scope>test</scope>-->
 		<!--</dependency>-->
+		<!--elasticsearch-->
+		<dependency>
+			<groupId>org.elasticsearch</groupId>
+			<artifactId>elasticsearch</artifactId>
+			<version>7.6.2</version>
+		</dependency>
+		<dependency>
+			<groupId>org.elasticsearch.client</groupId>
+			<artifactId>elasticsearch-rest-high-level-client</artifactId>
+			<version>7.6.2</version>
+		</dependency>
+		<dependency>
+			<groupId>org.elasticsearch.client</groupId>
+			<artifactId>elasticsearch-rest-client</artifactId>
+			<version>7.6.2</version>
+		</dependency>
 	</dependencies>
 
 	<build>

src/main/java/com/szwl/controller/ScheduledService.java

@@ -1,6 +1,7 @@
 package com.szwl.controller;
 
 import com.szwl.service.TDepartmentService;
+import com.szwl.service.TOrderTaskService;
 import com.szwl.service.TShandeMchService;
 import com.szwl.service.es.EsTCoinOrderService;
 import com.szwl.service.es.EsTOrderService;
@@ -10,6 +11,8 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.net.InetAddress;
+import java.net.UnknownHostException;
 import java.text.ParseException;
 import java.util.Calendar;
 
@@ -22,21 +25,76 @@ public class ScheduledService {
     @Autowired
     private TShandeMchService tShandeMchService;
     @Autowired
+    private TOrderTaskService orderTaskService;
+    @Autowired
     EsTCoinOrderService esTCoinOrderService;
     @Autowired
     EsTOrderService esTOrderService;
+
+        //8点到22点，每隔30秒去重发订单
+    @Scheduled(cron = "0/30 * 8-22 * * ?")
+    public void checkOrder() throws ParseException {
+//        orderTaskService.checkOrder();
+        int i = 0;
+        try {
+            String hostAddress = InetAddress.getLocalHost().getHostAddress();
+            if(hostAddress.equals("10.0.0.153")){
+                orderTaskService.checkOrder();
+                i++;
+            }
+//            if(hostAddress.equals("10.0.0.152")){
+//                i++;
+//            }
+
+        } catch (UnknownHostException e) {
+            e.printStackTrace();
+        }
+    }
+        //每天凌晨删除订单定时发送表
+    @Scheduled(cron = "30 05 1 * * ?")
+    public void removeOrder(){
+        int i = 0;
+        try {
+            String hostAddress = InetAddress.getLocalHost().getHostAddress();
+            if(hostAddress.equals("10.0.0.153")){
+                orderTaskService.removeOrder();
+                i++;
+            }
+//            if(hostAddress.equals("10.0.0.152")){
+//                i++;
+//            }
+
+        } catch (UnknownHostException e) {
+            e.printStackTrace();
+        }
+
+    }
+
+//    在每小时的29分执行一次 es同步数据
+    @Scheduled(cron = "0 29 * * * ?")
+    public void tongbuEs() throws ParseException {
+        int i = 0;
+        try {
+            String hostAddress = InetAddress.getLocalHost().getHostAddress();
+            if(hostAddress.equals("10.0.0.153")){
+                esTOrderService.tongbuByHour();
+                esTCoinOrderService.tongbuByHour();
+                i++;
+            }
+//            if(hostAddress.equals("10.0.0.152")){
+//                i++;
+//            }
+
+        } catch (UnknownHostException e) {
+            e.printStackTrace();
+        }
+
+    }
 //    //每天凌晨统计/核对杉德支付的金额表
 //    @Scheduled(cron = "30 05 0 * * ?")
 //    public void shandejiesuan(){
 //        tShandeMchService.jiesuan();
 //    }
 //
-//    //在每小时的20分执行一次 es同步数据
-//    @Scheduled(cron = "0 20 * * * ?")
-//    public void tongbuEs() throws ParseException {
-//        esTOrderService.tongbuByHour();
-//        esTCoinOrderService.tongbuByHour();
-//    }
-
 
 }

src/main/java/com/szwl/controller/TOrderController.java

@@ -253,6 +253,29 @@ public class TOrderController {
             query.orderByDesc(TOrder::getCreateDate);
             Page<TOrder> page = new Page<>(current, size, true);
             IPage<TOrder> iPage = orderService.page(page, query);
+            //显示订单所属机器的设备名称
+            if(admin.getType()!=null&&admin.getType()<2){
+                //公司人员
+                List<TOrder> orderList = iPage.getRecords();
+                if(orderList.size()>0){
+                    for(TOrder order:orderList){
+                        TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(order.getClientId()));
+                        order.setEs(equipment.getName());
+                    }
+                    iPage.setRecords(orderList);
+                }
+            }
+            if(admin.getType()!=null&&admin.getType()>1){
+                //商家
+                List<TOrder> orderList = iPage.getRecords();
+                if(orderList.size()>0){
+                    TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(orderList.get(0).getClientId()));
+                    for(TOrder order:orderList){
+                        order.setEs(equipment.getName());
+                    }
+                }
+                iPage.setRecords(orderList);
+            }
             return R.ok(iPage);
         };
 
@@ -369,6 +392,29 @@ public class TOrderController {
             }
             Page<TCoinOrder> page = new Page<>(current, size, true);
             IPage<TCoinOrder> iPage = coinOrderService.page(page, query);
+            //显示订单所属机器的设备名称
+            if(admin.getType()!=null&&admin.getType()<2){
+                //公司人员
+                List<TCoinOrder> orderList = iPage.getRecords();
+                if(orderList.size()>0){
+                    for(TCoinOrder order:orderList){
+                        TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(order.getClientId()));
+                        order.setEs(equipment.getName());
+                    }
+                    iPage.setRecords(orderList);
+                }
+            }
+            if(admin.getType()!=null&&admin.getType()>1){
+                //商家
+                List<TCoinOrder> orderList = iPage.getRecords();
+                if(orderList.size()>0){
+                    TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(orderList.get(0).getClientId()));
+                    for(TCoinOrder order:orderList){
+                        order.setEs(equipment.getName());
+                    }
+                }
+                iPage.setRecords(orderList);
+            }
             return R.ok(iPage);
         }
         return R.ok();
@@ -786,7 +832,7 @@ public class TOrderController {
         }else{
             //查去年的数据找数据库
             String endDate = param.getEndDate();
-            String toYear = "2022-01-01 00:00:00";
+            String toYear = "2022-07-01 00:00:00";
             Date date = new Date();
             Date year = new Date();
             SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

src/main/java/com/szwl/controller/TOrderTaskController.java

@@ -0,0 +1,21 @@
+package com.szwl.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author wuhs
+ * @since 2023-02-27
+ */
+@RestController
+@RequestMapping("/tOrderTask")
+public class TOrderTaskController {
+
+}
+

src/main/java/com/szwl/feign/SzwlFeign.java

@@ -35,7 +35,7 @@ public interface SzwlFeign {
     ResponseModel<TEquipment> findEquipmentByClientId(@RequestParam String clientId);
     @PostMapping("/tEquipment/getEquipmentByNameAndId")
     ResponseModel<TEquipment> getEquipmentByNameAndId(@RequestBody TEquipment equipment);
-    @PostMapping("/tEquipment/findById")
+    @PostMapping("/tEquipment/findById2")
     ResponseModel<TEquipment> findById(@RequestParam String id);
     @GetMapping("/tAdmin/pageAdmin2")
     ResponseModel<IPage<TAdmin>>  pageAdmin2(@RequestParam(value = "current") long current, @RequestParam(value = "size") long size);

src/main/java/com/szwl/mapper/TOrderTaskMapper.java

@@ -0,0 +1,16 @@
+package com.szwl.mapper;
+
+import com.szwl.model.entity.TOrderTask;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author wuhs
+ * @since 2023-02-27
+ */
+public interface TOrderTaskMapper extends BaseMapper<TOrderTask> {
+
+}

src/main/java/com/szwl/mapper/xml/TOrderTaskMapper.xml

@@ -0,0 +1,53 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.szwl.mapper.TOrderTaskMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.szwl.model.entity.TOrderTask">
+        <id column="id" property="id" />
+        <result column="create_date" property="createDate" />
+        <result column="modify_date" property="modifyDate" />
+        <result column="admin_id" property="adminId" />
+        <result column="admin_proportion" property="adminProportion" />
+        <result column="agency_id" property="agencyId" />
+        <result column="agency_proportion" property="agencyProportion" />
+        <result column="alt_info" property="altInfo" />
+        <result column="client_id" property="clientId" />
+        <result column="equipment_id" property="equipmentId" />
+        <result column="frp_code" property="frpCode" />
+        <result column="merchant_id" property="merchantId" />
+        <result column="merchant_proportion" property="merchantProportion" />
+        <result column="pay_date" property="payDate" />
+        <result column="personage_id" property="personageId" />
+        <result column="personage_proportion" property="personageProportion" />
+        <result column="price" property="price" />
+        <result column="product_id" property="productId" />
+        <result column="product_desc" property="productDesc" />
+        <result column="product_name" property="productName" />
+        <result column="product_no" property="productNo" />
+        <result column="refund_date" property="refundDate" />
+        <result column="sn" property="sn" />
+        <result column="status" property="status" />
+        <result column="type" property="type" />
+        <result column="trx_no" property="trxNo" />
+        <result column="refund_trx_no" property="refundTrxNo" />
+        <result column="es" property="es" />
+        <result column="refund_amount" property="refundAmount" />
+        <result column="note" property="note" />
+        <result column="pay_platform" property="payPlatform" />
+        <result column="is_settlement" property="isSettlement" />
+        <result column="wx_id" property="wxId" />
+        <result column="proportion_desc" property="proportionDesc" />
+        <result column="marketing_amount" property="marketingAmount" />
+        <result column="coupons" property="coupons" />
+        <result column="refund_marketing_amount" property="refundMarketingAmount" />
+        <result column="order_status" property="orderStatus" />
+        <result column="product_number" property="productNumber" />
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id, create_date, modify_date, admin_id, admin_proportion, agency_id, agency_proportion, alt_info, client_id, equipment_id, frp_code, merchant_id, merchant_proportion, pay_date, personage_id, personage_proportion, price, product_id, product_desc, product_name, product_no, refund_date, sn, status, type, trx_no, refund_trx_no, es, refund_amount, note, pay_platform, is_settlement, wx_id, proportion_desc, marketing_amount, coupons, refund_marketing_amount, order_status, product_number
+    </sql>
+
+</mapper>

src/main/java/com/szwl/model/entity/TCoinOrder.java

@@ -66,6 +66,10 @@ public class TCoinOrder implements Serializable {
 
     @ApiModelProperty(value = "支付时间;")
     private Date payDate;
+    @ApiModelProperty(value = ";")
+    private String note;
 
+    @ApiModelProperty(value = "商品数量;")
+    private Integer productNumber=1;
 
 }

src/main/java/com/szwl/model/entity/TOrder.java

@@ -85,6 +85,9 @@ public class TOrder implements Serializable {
     @ApiModelProperty(value = "商品名称;")
     private String productName;
 
+    @ApiModelProperty(value = "商品数量;")
+    private Integer productNumber=1;
+
     @ApiModelProperty(value = "商品名称;")
     private String productDesc;
 

src/main/java/com/szwl/model/entity/TOrderTask.java

@@ -0,0 +1,113 @@
+package com.szwl.model.entity;
+
+import java.math.BigDecimal;
+import com.baomidou.mybatisplus.annotation.IdType;
+import java.util.Date;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author wuhs
+ * @since 2023-02-27
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ApiModel(value="TOrderTask对象", description="")
+public class TOrderTask implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    private Date createDate;
+
+    private Date modifyDate;
+
+    private Long adminId;
+
+    private BigDecimal adminProportion;
+
+    private Long agencyId;
+
+    private BigDecimal agencyProportion;
+
+    private String altInfo;
+
+    private String clientId;
+
+    private Long equipmentId;
+
+    private String frpCode;
+
+    private Long merchantId;
+
+    private BigDecimal merchantProportion;
+
+    private Date payDate;
+
+    private Long personageId;
+
+    private BigDecimal personageProportion;
+
+    private BigDecimal price;
+
+    private Long productId;
+
+    private String productDesc;
+
+    private String productName;
+
+    private String productNo;
+
+    private Date refundDate;
+
+    private String sn;
+
+    private Integer status;
+
+    private Integer type;
+
+    private String trxNo;
+
+    private String refundTrxNo;
+
+    private String es;
+
+    private BigDecimal refundAmount;
+
+    private String note;
+
+    @ApiModelProperty(value = "支付平台  0或null为汇聚，1为杉德支付")
+    private String payPlatform;
+
+    @ApiModelProperty(value = "是否结算 0或null为未结算，1已结算。仅杉德支付有这个")
+    private String isSettlement;
+
+    private Long wxId;
+
+    private String proportionDesc;
+
+    private BigDecimal marketingAmount;
+
+    private String coupons;
+
+    @ApiModelProperty(value = "退款营销金额")
+    private BigDecimal refundMarketingAmount;
+
+    @ApiModelProperty(value = "订单状态；0：排队中，1：正在制作，2：已制作")
+    private String orderStatus;
+
+    @ApiModelProperty(value = "商品数量")
+    private Integer productNumber;
+
+
+}

src/main/java/com/szwl/service/TEquipmentService.java

@@ -13,4 +13,8 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface TEquipmentService extends IService<TEquipment> {
 
+    /**
+     * 发送信息，1：个推，2：MQ
+     */
+    public String sentMessage(String clientId, String json);
 }

src/main/java/com/szwl/service/TOrderTaskService.java

@@ -0,0 +1,19 @@
+package com.szwl.service;
+
+import com.szwl.model.entity.TOrderTask;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author wuhs
+ * @since 2023-02-27
+ */
+public interface TOrderTaskService extends IService<TOrderTask> {
+    //8点到22点，每隔30秒去重发订单
+    void checkOrder();
+
+    void removeOrder();
+}

src/main/java/com/szwl/service/es/EsTCoinOrderService.java

@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.szwl.model.entity.TCoinOrder;
+import com.szwl.model.entity.TOrder;
 import com.szwl.model.query.TCoinOrderParam;
 import com.szwl.model.utils.DateUtils;
 import com.szwl.service.TCoinOrderService;
@@ -87,6 +88,10 @@ public class EsTCoinOrderService extends EsBaseService<TCoinOrder, TCoinOrderPar
 //                    example.setOffset(offset);
 //                    List<TCoinOrder> list = tCoinOrderService.selectByOption(example);
                     LambdaQueryWrapper<TCoinOrder> query = Wrappers.lambdaQuery();
+                    SimpleDateFormat ft = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                    String time = "2022-07-01 00:00:00";
+                    Date date = ft.parse(time);
+                    query.gt(TCoinOrder::getCreateDate,date);
                     Page<TCoinOrder> page = new Page<>(offset, limit, true);
                     IPage<TCoinOrder> iPage = tCoinOrderService.page(page, query);
                     List<TCoinOrder> list = iPage.getRecords();

src/main/java/com/szwl/service/es/EsTOrderService.java

@@ -103,6 +103,10 @@ public class EsTOrderService extends EsBaseService<TOrder, TOrderParam> {
 //                    example.setOffset(offset);
 //                    List<TOrder> list = tOrderService.selectByOption(example);
                     LambdaQueryWrapper<TOrder> query = Wrappers.lambdaQuery();
+                    SimpleDateFormat ft = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                    String time = "2022-07-01 00:00:00";
+                    Date date = ft.parse(time);
+                    query.gt(TOrder::getCreateDate,date);
                     Page<TOrder> page = new Page<>(offset, limit, true);
                     IPage<TOrder> iPage = tOrderService.page(page, query);
                     List<TOrder> list = iPage.getRecords();

src/main/java/com/szwl/service/impl/TEquipmentServiceImpl.java

@@ -1,9 +1,16 @@
 package com.szwl.service.impl;
 
+import com.szwl.feign.SzwlFeign;
+import com.szwl.model.bo.R;
 import com.szwl.model.entity.TEquipment;
 import com.szwl.mapper.TEquipmentMapper;
+import com.szwl.model.utils.PushUtils;
 import com.szwl.service.TEquipmentService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.amqp.core.MessageProperties;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 /**
@@ -16,5 +23,33 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class TEquipmentServiceImpl extends ServiceImpl<TEquipmentMapper, TEquipment> implements TEquipmentService {
+    @Autowired
+    private AmqpTemplate amqpTemplate;
+
+    @Autowired
+    SzwlFeign szwlFeign;
+    @Override
+    public String sentMessage(String clientId, String json) {
+        TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(clientId));
+        if (equipment == null) {
+            return "该设备不存在";
+        }
+        String channel = equipment.getChannel();
+        String equimentType = equipment.getEquimentType();
+        if(StringUtils.isEmpty(channel)||channel.equals("1")||StringUtils.isEmpty(equimentType)){
+            //用个推
+            PushUtils.push(equipment.getGtClientId(), "", "", json);
+        }
+        if(StringUtils.isNotEmpty(channel)&&channel.equals("2")&&StringUtils.isNotEmpty(equimentType)){
+            //用Mq
+            //1 创建消息
+            MessageProperties messageProperties = new MessageProperties();
+            messageProperties.setContentType("text/plain");
+            org.springframework.amqp.core.Message message = new org.springframework.amqp.core.Message(json.getBytes(), messageProperties);
+            amqpTemplate.send(equimentType, clientId, message);
+            System.out.println("mq发送成功，clientId="+clientId+"&json="+json);
+        }
+        return "success";
+    }
 
 }

src/main/java/com/szwl/service/impl/TOrderTaskServiceImpl.java

@@ -0,0 +1,90 @@
+package com.szwl.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.szwl.model.entity.TOrder;
+import com.szwl.model.entity.TOrderTask;
+import com.szwl.mapper.TOrderTaskMapper;
+import com.szwl.model.utils.PushUtils;
+import com.szwl.service.TEquipmentService;
+import com.szwl.service.TOrderTaskService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author wuhs
+ * @since 2023-02-27
+ */
+@Service
+public class TOrderTaskServiceImpl extends ServiceImpl<TOrderTaskMapper, TOrderTask> implements TOrderTaskService {
+    @Autowired
+    TEquipmentService equipmentService;
+    @Override
+    //8点到22点，每隔30秒去重发订单
+    public void checkOrder() {
+        //获取当前时间5分钟前的时间
+        Calendar myTime = Calendar.getInstance();
+        myTime.add(Calendar.MINUTE,-5);
+        Date beforeM = myTime.getTime();
+        LambdaQueryWrapper<TOrderTask> query = Wrappers.lambdaQuery();
+        query.eq(TOrderTask::getOrderStatus,"-1");
+        query.eq(TOrderTask::getStatus,"1");
+        query.gt(TOrderTask::getPayDate,beforeM);
+        List<TOrderTask> orderTaskList = list(query);
+        for(TOrderTask orderTask : orderTaskList){
+            JSONObject kindData1 = new JSONObject();
+            kindData1.put("sn", orderTask.getSn());
+            kindData1.put("productDesc", orderTask.getProductDesc());
+            String s = orderTask.getAgencyId().toString();
+            if(s.length()>6){
+                s = s.substring(s.length()-6,s.length());
+            }
+            kindData1.put("mealCode", s);
+            sendMqTwo(orderTask.getClientId(),kindData1.toString());
+        }
+    }
+
+    @Override
+    public void removeOrder() {
+        LambdaQueryWrapper<TOrderTask> query = Wrappers.lambdaQuery();
+        remove(query);
+    }
+
+    //发送两次mq
+    private void sendMqTwo(String clientId, String kind) {
+        // 定时任务1
+        TimerTask timerTask = new TimerTask() {
+            @Override
+            public void run() {
+                equipmentService.sentMessage(clientId, PushUtils.buildJson("cardPayXCX", kind).toString());
+                System.out.println("运行定时任务1：" + clientId);
+
+            }
+        };
+        // 定时任务2
+        TimerTask timerTask1 = new TimerTask() {
+            @Override
+            public void run() {
+                equipmentService.sentMessage(clientId, PushUtils.buildJson("cardPayXCX", kind).toString());
+                System.out.println("运行定时任务1：" + clientId);
+
+            }
+        };
+        // 计时器
+        Timer timer = new Timer();
+        // 添加执行任务（延迟 5s 执行）
+        timer.schedule(timerTask, 5000);
+        Timer timer1 = new Timer();
+        timer1.schedule(timerTask1, 10000);
+//        equipmentService.sentMessage(clientId, PushUtils.buildJson("cardPayXCX", kind).toString());
+
+    }
+}

src/test/java/com/szwl/AutoGeneratorTests.java

@@ -39,7 +39,7 @@ class AutoGeneratorTests {
 		//配置数据源
 		DataSourceConfig dataSourceConfig = new DataSourceConfig();
 		dataSourceConfig.setDriverName("com.mysql.cj.jdbc.Driver")
-				.setUrl("jdbc:mysql://rm-wz995mu26a1479kz0so.mysql.rds.aliyuncs.com:3306/szwl")
+				.setUrl("jdbc:mysql://rm-wz995mu26a1479kz0so.mysql.rds.aliyuncs.com:3306/orderdb")
 				.setUsername("root").setPassword("sunzee@020");
 
 		//策略配置