中网小程序微信国际（香港）支付schedule模块提交

kmall-schedule/kmall-schedule.iml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_5">
+    <output url="file://$MODULE_DIR$/target/classes" />
+    <output-test url="file://$MODULE_DIR$/target/test-classes" />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
+      <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
+      <excludeFolder url="file://$MODULE_DIR$/target" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

kmall-schedule/pom.xml

@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>kmall-pt-global</artifactId>
+        <groupId>com.kmall</groupId>
+        <version>3.1.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>kmall-schedule</artifactId>
+    <packaging>jar</packaging>
+    <description>定时任务模块</description>
+
+    <properties>
+        <quartz-version>2.2.3</quartz-version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.kmall</groupId>
+            <artifactId>kmall-common</artifactId>
+            <version>${kmall-version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.quartz-scheduler</groupId>
+            <artifactId>quartz</artifactId>
+            <version>${quartz-version}</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>c3p0</artifactId>
+                    <groupId>c3p0</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+    </dependencies>
+
+</project>

kmall-schedule/src/main/java/com/kmall/schedule/controller/ScheduleJobController.java

@@ -0,0 +1,133 @@
+package com.kmall.schedule.controller;
+
+import com.kmall.common.annotation.SysLog;
+import com.kmall.schedule.entity.ScheduleJobEntity;
+import com.kmall.schedule.service.ScheduleJobService;
+import com.kmall.common.utils.PageUtils;
+import com.kmall.common.utils.Query;
+import com.kmall.common.utils.R;
+import com.kmall.common.validator.ValidatorUtils;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 定时任务
+ *
+ * @author Scott
+ * @email
+ * @date 2016年11月28日 下午2:16:40
+ */
+@RestController
+@RequestMapping("/sys/schedule")
+public class ScheduleJobController {
+    @Autowired
+    private ScheduleJobService scheduleJobService;
+
+    /**
+     * 定时任务列表
+     */
+    @RequestMapping("/list")
+    @RequiresPermissions("sys:schedule:list")
+    public R list(@RequestParam Map<String, Object> params) {
+        //查询列表数据
+        Query query = new Query(params);
+        List<ScheduleJobEntity> jobList = scheduleJobService.queryList(query);
+        int total = scheduleJobService.queryTotal(query);
+
+        PageUtils pageUtil = new PageUtils(jobList, total, query.getLimit(), query.getPage());
+
+        return R.ok().put("page", pageUtil);
+    }
+
+    /**
+     * 定时任务信息
+     */
+    @RequestMapping("/info/{jobId}")
+    @RequiresPermissions("sys:schedule:info")
+    public R info(@PathVariable("jobId") Long jobId) {
+        ScheduleJobEntity schedule = scheduleJobService.queryObject(jobId);
+
+        return R.ok().put("schedule", schedule);
+    }
+
+    /**
+     * 保存定时任务
+     */
+    @SysLog("保存定时任务")
+    @RequestMapping("/save")
+    @RequiresPermissions("sys:schedule:save")
+    public R save(@RequestBody ScheduleJobEntity scheduleJob) {
+        ValidatorUtils.validateEntity(scheduleJob);
+
+        scheduleJobService.save(scheduleJob);
+
+        return R.ok();
+    }
+
+    /**
+     * 修改定时任务
+     */
+    @SysLog("修改定时任务")
+    @RequestMapping("/update")
+    @RequiresPermissions("sys:schedule:update")
+    public R update(@RequestBody ScheduleJobEntity scheduleJob) {
+        ValidatorUtils.validateEntity(scheduleJob);
+
+        scheduleJobService.update(scheduleJob);
+
+        return R.ok();
+    }
+
+    /**
+     * 删除定时任务
+     */
+    @SysLog("删除定时任务")
+    @RequestMapping("/delete")
+    @RequiresPermissions("sys:schedule:delete")
+    public R delete(@RequestBody Long[] jobIds) {
+        scheduleJobService.deleteBatch(jobIds);
+
+        return R.ok();
+    }
+
+    /**
+     * 立即执行任务
+     */
+    @SysLog("立即执行任务")
+    @RequestMapping("/run")
+    @RequiresPermissions("sys:schedule:run")
+    public R run(@RequestBody Long[] jobIds) {
+        scheduleJobService.run(jobIds);
+
+        return R.ok();
+    }
+
+    /**
+     * 暂停定时任务
+     */
+    @SysLog("暂停定时任务")
+    @RequestMapping("/pause")
+    @RequiresPermissions("sys:schedule:pause")
+    public R pause(@RequestBody Long[] jobIds) {
+        scheduleJobService.pause(jobIds);
+
+        return R.ok();
+    }
+
+    /**
+     * 恢复定时任务
+     */
+    @SysLog("恢复定时任务")
+    @RequestMapping("/resume")
+    @RequiresPermissions("sys:schedule:resume")
+    public R resume(@RequestBody Long[] jobIds) {
+        scheduleJobService.resume(jobIds);
+
+        return R.ok();
+    }
+
+}

kmall-schedule/src/main/java/com/kmall/schedule/controller/ScheduleJobLogController.java

@@ -0,0 +1,56 @@
+package com.kmall.schedule.controller;
+
+import com.kmall.schedule.entity.ScheduleJobLogEntity;
+import com.kmall.schedule.service.ScheduleJobLogService;
+import com.kmall.common.utils.PageUtils;
+import com.kmall.common.utils.Query;
+import com.kmall.common.utils.R;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 定时任务日志
+ *
+ * @author Scott
+ * @email
+ * @date 2016年12月1日 下午10:39:52
+ */
+@RestController
+@RequestMapping("/sys/scheduleLog")
+public class ScheduleJobLogController {
+    @Autowired
+    private ScheduleJobLogService scheduleJobLogService;
+
+    /**
+     * 定时任务日志列表
+     */
+    @RequestMapping("/list")
+    @RequiresPermissions("sys:schedule:log")
+    public R list(@RequestParam Map<String, Object> params) {
+        //查询列表数据
+        Query query = new Query(params);
+        List<ScheduleJobLogEntity> jobList = scheduleJobLogService.queryList(query);
+        int total = scheduleJobLogService.queryTotal(query);
+
+        PageUtils pageUtil = new PageUtils(jobList, total, query.getLimit(), query.getPage());
+
+        return R.ok().put("page", pageUtil);
+    }
+
+    /**
+     * 定时任务日志信息
+     */
+    @RequestMapping("/info/{logId}")
+    public R info(@PathVariable("logId") Long logId) {
+        ScheduleJobLogEntity log = scheduleJobLogService.queryObject(logId);
+
+        return R.ok().put("log", log);
+    }
+}

kmall-schedule/src/main/java/com/kmall/schedule/dao/OrderWXPayRecordMapper.java

@@ -0,0 +1,34 @@
+package com.kmall.schedule.dao;
+
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+
+@Component
+public interface OrderWXPayRecordMapper {
+
+    /**
+     * 根据交易状态查询支付记录
+     *
+     * @param tradeStates
+     * @return 支付记录
+     */
+    List<Map> queryRecordList(List<String> tradeStates);
+
+    /**
+     * 根据订单编号查询支付记录
+     *
+     * @param out_trade_no 订单编号
+     * @return 支付记录
+     */
+    List<Map> getRecordsByOutTradeNo(String out_trade_no);
+
+    /**
+     * 修改记录
+     *
+     * @param params
+     * @return
+     */
+    int update(Map params);
+}

kmall-schedule/src/main/java/com/kmall/schedule/dao/QzGroupMapper.java

@@ -0,0 +1,34 @@
+package com.kmall.schedule.dao;
+
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author zhouzhengde(CN)
+ * @date 2017/12/4.
+ */
+@Component
+public interface QzGroupMapper {
+    /**
+     * 查询快要过期的团购
+     *
+     * @return
+     */
+    List<Map> queryRemindGroupList();
+
+    /**
+     * 查询过期的团购
+     *
+     * @return
+     */
+    List<Map> queryPastGroupList();
+
+    /**
+     * 更新过期的团购单
+     *
+     * @return
+     */
+    int updatePastGroup(Map params);
+}

kmall-schedule/src/main/java/com/kmall/schedule/dao/QzOrderMapper.java

@@ -0,0 +1,71 @@
+package com.kmall.schedule.dao;
+
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author zhouzhengde(CN)
+ * @date 2017/12/4.
+ */
+@Component
+public interface QzOrderMapper {
+    /**
+     * 查询未评价
+     *
+     * @return
+     */
+    List<Map> queryrderUnEvaluateList();
+
+    /**
+     * 查询过期订单
+     *
+     * @return
+     */
+    List<Map> queryPastOrderList();
+
+    /**
+     * 更新过期订单
+     *
+     * @return
+     */
+    void unpayPastUpdate();
+
+    void updateStockNum(Map param);
+
+    List<Map> queryRefundOrderList();
+
+    void updateOrderRefund(Map param);
+
+    void updateOrderInfo(Map param);
+
+    void updateOrderProcessRecord(Map param);
+
+    List<Map> queryPayingOrderList();
+
+    List<Map> queryShipmentOrderList();
+
+    List<Map> queryShipmentBondedOrderList();
+
+    void updateShipmentOrder(Map param);
+
+    List<Map> queryReceiptOrderList();
+
+    void insertComment(Map param);
+
+    void updateReceiptOrderByCommentCount();
+
+    int insertPinganResponseDto(Map fromObject);
+
+    Map queryOrder(String orderSn);
+
+    List<Map> queryWXPaySuccessRecords(String orderSn);
+
+    int updatePayOrderByOutNo(Map fromObject);
+
+    List<Map> queryPinganPayingOrderList();
+
+    BigDecimal getTotalActualPriceByMerchOrderSn(String merchOrderSn);
+}

kmall-schedule/src/main/java/com/kmall/schedule/dao/ScheduleJobDao.java

@@ -0,0 +1,21 @@
+package com.kmall.schedule.dao;
+
+import com.kmall.common.dao.BaseDao;
+import com.kmall.schedule.entity.ScheduleJobEntity;
+
+import java.util.Map;
+
+/**
+ * 定时任务
+ *
+ * @author Scott
+ * @email
+ * @date 2016年12月1日 下午10:29:57
+ */
+public interface ScheduleJobDao extends BaseDao<ScheduleJobEntity> {
+
+    /**
+     * 批量更新状态
+     */
+    int updateBatch(Map<String, Object> map);
+}

kmall-schedule/src/main/java/com/kmall/schedule/dao/ScheduleJobLogDao.java

@@ -0,0 +1,15 @@
+package com.kmall.schedule.dao;
+
+import com.kmall.common.dao.BaseDao;
+import com.kmall.schedule.entity.ScheduleJobLogEntity;
+
+/**
+ * 定时任务日志
+ *
+ * @author Scott
+ * @email
+ * @date 2016年12月1日 下午10:30:02
+ */
+public interface ScheduleJobLogDao extends BaseDao<ScheduleJobLogEntity> {
+
+}

kmall-schedule/src/main/java/com/kmall/schedule/entity/ScheduleJobEntity.java

@@ -0,0 +1,169 @@
+package com.kmall.schedule.entity;
+
+import org.hibernate.validator.constraints.NotBlank;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 定时器
+ *
+ * @author Scott
+ * @email
+ * @date 2016年11月28日 下午12:54:44
+ */
+public class ScheduleJobEntity implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 任务调度参数key
+     */
+    public static final String JOB_PARAM_KEY = "JOB_PARAM_KEY";
+
+    /**
+     * 任务id
+     */
+    private Long jobId;
+
+    /**
+     * spring bean名称
+     */
+    @NotBlank(message = "bean名称不能为空")
+    private String beanName;
+
+    /**
+     * 方法名
+     */
+    @NotBlank(message = "方法名称不能为空")
+    private String methodName;
+
+    /**
+     * 参数
+     */
+    private String params;
+
+    /**
+     * cron表达式
+     */
+    @NotBlank(message = "cron表达式不能为空")
+    private String cronExpression;
+
+    /**
+     * 任务状态
+     */
+    private Integer status;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 设置：任务id
+     *
+     * @param jobId 任务id
+     */
+    public void setJobId(Long jobId) {
+        this.jobId = jobId;
+    }
+
+    /**
+     * 获取：任务id
+     *
+     * @return Long
+     */
+    public Long getJobId() {
+        return jobId;
+    }
+
+    public String getBeanName() {
+        return beanName;
+    }
+
+    public void setBeanName(String beanName) {
+        this.beanName = beanName;
+    }
+
+    public String getMethodName() {
+        return methodName;
+    }
+
+    public void setMethodName(String methodName) {
+        this.methodName = methodName;
+    }
+
+    public String getParams() {
+        return params;
+    }
+
+    public void setParams(String params) {
+        this.params = params;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    /**
+     * 设置：任务状态
+     *
+     * @param status 任务状态
+     */
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    /**
+     * 获取：任务状态
+     *
+     * @return String
+     */
+    public Integer getStatus() {
+        return status;
+    }
+
+    /**
+     * 设置：cron表达式
+     *
+     * @param cronExpression cron表达式
+     */
+    public void setCronExpression(String cronExpression) {
+        this.cronExpression = cronExpression;
+    }
+
+    /**
+     * 获取：cron表达式
+     *
+     * @return String
+     */
+    public String getCronExpression() {
+        return cronExpression;
+    }
+
+    /**
+     * 设置：创建时间
+     *
+     * @param createTime 创建时间
+     */
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    /**
+     * 获取：创建时间
+     *
+     * @return Date
+     */
+    public Date getCreateTime() {
+        return createTime;
+    }
+}

kmall-schedule/src/main/java/com/kmall/schedule/entity/ScheduleJobLogEntity.java

@@ -0,0 +1,133 @@
+package com.kmall.schedule.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 定时执行日志
+ *
+ * @author Scott
+ * @email
+ * @date 2016年12月1日 下午10:26:18
+ */
+public class ScheduleJobLogEntity implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 日志id
+     */
+    private Long logId;
+
+    /**
+     * 任务id
+     */
+    private Long jobId;
+
+    /**
+     * spring bean名称
+     */
+    private String beanName;
+
+    /**
+     * 方法名
+     */
+    private String methodName;
+
+    /**
+     * 参数
+     */
+    private String params;
+
+    /**
+     * 任务状态    0：成功    1：失败
+     */
+    private Integer status;
+
+    /**
+     * 失败信息
+     */
+    private String error;
+
+    /**
+     * 耗时(单位：毫秒)
+     */
+    private Integer times;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    public Long getLogId() {
+        return logId;
+    }
+
+    public void setLogId(Long logId) {
+        this.logId = logId;
+    }
+
+    public Long getJobId() {
+        return jobId;
+    }
+
+    public void setJobId(Long jobId) {
+        this.jobId = jobId;
+    }
+
+    public String getBeanName() {
+        return beanName;
+    }
+
+    public void setBeanName(String beanName) {
+        this.beanName = beanName;
+    }
+
+    public String getMethodName() {
+        return methodName;
+    }
+
+    public void setMethodName(String methodName) {
+        this.methodName = methodName;
+    }
+
+    public String getParams() {
+        return params;
+    }
+
+    public void setParams(String params) {
+        this.params = params;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public String getError() {
+        return error;
+    }
+
+    public void setError(String error) {
+        this.error = error;
+    }
+
+    public Integer getTimes() {
+        return times;
+    }
+
+    public void setTimes(Integer times) {
+        this.times = times;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+}

kmall-schedule/src/main/java/com/kmall/schedule/quartz/OrderTask.java

@@ -0,0 +1,103 @@
+package com.kmall.schedule.quartz;
+
+import com.kmall.schedule.service.QzOrderService;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component("orderTask")
+public class OrderTask {
+    private static Log logger = LogFactory.getLog(OrderTask.class);
+
+    @Autowired
+    QzOrderService qzOrderService;
+
+    /**
+     * 方法描述：拼团进度通知
+     * 每日凌晨2:00
+     */
+    /*@Scheduled(cron = "0 0 2 * * ?")
+    public void groupProgressRemind() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>groupProgressRemind is start ");
+        qzOrderService.groupProgressRemind();
+        logger.info(">>>>>>>>>>>>>>>>>>>>groupProgressRemind is end ");
+    }*/
+
+    /**
+     * 未评价订单(发送微信模版消息提醒用户)
+     * 每日凌晨2:00
+     */
+    @Scheduled(cron = "0 0 2 * * ?")
+    public void orderUnEvaluateRemind() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>groupProgressRemind is start ");
+        qzOrderService.orderUnEvaluateRemind();
+        logger.info(">>>>>>>>>>>>>>>>>>>>groupProgressRemind is end ");
+    }
+    /**
+     * 方法描述：更新过期未支付订单
+     * 二分钟更新未付款订单
+     */
+    @Scheduled(fixedRate = 1000 * 60 * 2)
+    public void unpayPastUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>unpayPastUpdate is start ");
+        qzOrderService.unpayPastUpdate();
+        logger.info(">>>>>>>>>>>>>>>>>>>>unpayPastUpdate is end ");
+    }
+
+    /**
+     * 方法描述：查询已申请退款订单以及退款中订单，查询微信退款更新订单状态
+     * 二分钟更新订单
+     */
+    @Scheduled(fixedRate = 1000 * 60 * 1)
+    public void refundUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>refundUpdate is start ");
+        qzOrderService.refundUpdate();
+        logger.info(">>>>>>>>>>>>>>>>>>>>refundUpdate is end ");
+    }
+
+    /**
+     * 方法描述：查询支付中的订单以及小程序更新支付信息异常订单，查询微信订单信息更新订单状态
+     * 二分钟更新订单
+     */
+    @Scheduled(fixedRate = 1000 * 60 * 1)
+    public void orderQueryUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>orderQueryUpdate is start ");
+        qzOrderService.orderQueryUpdate();
+        logger.info(">>>>>>>>>>>>>>>>>>>>orderQueryUpdate is end ");
+    }
+
+    /**
+     * 方法描述：查询支付中的订单以及小程序更新支付信息异常订单，查询平安订单信息更新订单状态
+     * 二分钟更新订单
+     */
+    @Scheduled(fixedRate = 1000 * 60 * 1)
+    public void pinganOrderQueryUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>pinganOrderQueryUpdate is start ");
+        qzOrderService.pinganOrderQueryUpdate();
+        logger.info(">>>>>>>>>>>>>>>>>>>>pinganOrderQueryUpdate is end ");
+    }
+
+    /**
+     * 方法描述：商品发货后7天自动确认收货
+     */
+    @Scheduled(cron = "0 0 2 * * ?")
+    public void shipmentOrderAutoTakeGoods() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>shipmentOrderAutoTakeGoods is start ");
+        qzOrderService.shipmentOrderAutoTakeGoods();
+        logger.info(">>>>>>>>>>>>>>>>>>>>shipmentOrderAutoTakeGoods is end ");
+    }
+
+    /**
+     * 方法描述：确认收货后30天自动确认好评
+     */
+    @Scheduled(cron = "0 0 2 * * ?")
+    public void receiptOrderAutoComment() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>receiptOrderAutoComment is start ");
+        qzOrderService.receiptOrderAutoComment();
+        logger.info(">>>>>>>>>>>>>>>>>>>>receiptOrderAutoComment is end ");
+    }
+}
+
+

kmall-schedule/src/main/java/com/kmall/schedule/service/QzOrderService.java

@@ -0,0 +1,1096 @@
+package com.kmall.schedule.service;
+
+import com.kmall.common.constant.Dict;
+import com.kmall.common.utils.*;
+import com.kmall.common.utils.wechat.*;
+import com.kmall.common.utils.wechat.wxglobal.WechatGlobalUtil;
+import com.kmall.common.utils.wechat.wxglobal.dto.WechatGlobalRefundQueryDto;
+import com.kmall.common.utils.wechat.wxglobal.dto.WechatGlobalRefundQueryResult;
+import com.kmall.common.utils.wechat.wxglobal.dto.WechatGlobalUniformNotifyResult;
+import com.kmall.schedule.dao.OrderWXPayRecordMapper;
+import com.kmall.schedule.dao.QzGroupMapper;
+import com.kmall.schedule.dao.QzOrderMapper;
+import com.kmall.common.dao.TemplateConfDao;
+import com.kmall.common.entity.TemplateConfVo;
+import com.kmall.common.utils.*;
+import com.kmall.common.utils.pingan.PinganUtil;
+import com.kmall.common.utils.pingan.dto.PinganPayOrderDto;
+import com.kmall.common.utils.pingan.dto.PinganResponseDto;
+import com.kmall.common.utils.wechat.ReaderXmlForDOM4J;
+import com.kmall.common.utils.wechat.WechatRefundApiResult;
+import com.kmall.common.utils.wechat.WechatRefundQueryResult;
+import com.kmall.common.utils.wechat.WechatUtil;
+import com.kmall.common.utils.wxtemplate.TemplateData;
+import com.kmall.common.utils.wxtemplate.WxTemplate;
+import com.kmall.common.utils.wxtemplate.WxTemplateUtil;
+import com.kmall.schedule.quartz.OrderTask;
+import net.sf.json.JSONObject;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.math.BigDecimal;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * 微信提醒任务
+ *
+ * @author zhouzhengde(CN)
+ * @date 2017/12/4.
+ */
+@Service
+public class QzOrderService {
+    private static Log logger = LogFactory.getLog(OrderTask.class);
+    @Autowired
+    private TemplateConfDao templateConfDao;
+    @Autowired
+    private QzGroupMapper qzGroupMapper;
+    @Autowired
+    private QzOrderMapper qzOrderMapper;
+    @Autowired
+    private OrderWXPayRecordMapper orderWXPayRecordMapper;
+
+    /**
+     * todo 一期暂时不实现团购
+     * 团购进度提醒，提前一天提醒(发送微信模版消息提醒用户)
+     */
+    @Transactional
+    public void groupProgressRemind() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>groupProgressRemind is start ");
+        TemplateConfVo templateConfVo =
+                templateConfDao.queryByTypeId(4); //  模板类型 1订单付款成功 2团购成功 3拼团失败通知 4拼团进度 5 6 7订单配送 8订单评价提醒
+        if (null == templateConfVo) {
+            return;
+        }
+        List<Map> groupList = qzGroupMapper.queryRemindGroupList();
+
+        if (null != groupList && groupList.size() > 0) {
+            for (Map map : groupList) {
+                Long id = MapUtils.getLong("id", map);
+                String open_id = MapUtils.getString("open_id", map);
+                Long group_id = MapUtils.getLong("group_id", map);
+                Integer attend_num = MapUtils.getInteger("attend_num", map);
+                String name = MapUtils.getString("name", map);
+                Date open_time = MapUtils.getDate("open_time", map);
+                Date end_time = MapUtils.getDate("end_time", map);
+                String form_id = MapUtils.getString("form_id", map);
+                BigDecimal retail_min_price = MapUtils.getBigDecimal("retail_min_price", map);
+                if (StringUtils.isNullOrEmpty(form_id)) {
+                    continue;
+                }
+                WxTemplate tem = new WxTemplate();
+                tem.setTemplate_id(templateConfVo.getTemplateId());
+                //                tem.setTopcolor("#00DD00");
+                tem.setTouser(open_id);
+                tem.setPage("/pages/groupDetail/groupDetail?id=" + group_id);
+                tem.setForm_id(form_id);
+
+                List<TemplateData> paras = new ArrayList<TemplateData>();
+                paras.add(new TemplateData("keyword1", name, "#000000"));
+                paras.add(new TemplateData("keyword2", DateUtils.format(open_time, DateUtils.DATE_PATTERN), "#000000"));
+                paras.add(new TemplateData("keyword3", "已有" + attend_num + "人参与", "#000000"));
+                //剩余时长
+                long time = (end_time.getTime() - System.currentTimeMillis()) / 1000;
+                long hour = time / 3600;
+                long minite = time / 60 % 60;
+                long second = (time - hour * 3600 - minite * 60);
+                String body = hour + "时" + minite + "分" + second + "秒";
+                paras.add(new TemplateData("keyword3", body, "#000000"));
+                paras.add(new TemplateData("keyword4", retail_min_price.setScale(2, BigDecimal.ROUND_HALF_DOWN).toString() + "元", "#000000"));
+                paras.add(new TemplateData("keyword5", templateConfVo.getDesc(), "#000000"));
+                tem.setData(paras);
+                WxTemplateUtil.sendMessage(tem);
+            }
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>groupProgressRemind is end ");
+    }
+
+    /**
+     * todo 一期暂时不实现团购
+     * 更新过期的团购订单(发送微信模版消息提醒用户)
+     */
+    @Transactional
+    public void pastGroupRemind() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>pastGroupRemind is start ");
+        TemplateConfVo templateConfVo =
+                templateConfDao.queryByTypeId(3); //  模板类型 1订单付款成功 2团购成功 3拼团失败通知 4拼团进度 5 6 7订单配送 8订单评价提醒
+        if (null == templateConfVo) {
+            return;
+        }
+        List<Map> groupList = qzGroupMapper.queryPastGroupList();
+
+        if (null != groupList && groupList.size() > 0) {
+            for (Map map : groupList) {
+                Long id = MapUtils.getLong("id", map);
+                String open_id = MapUtils.getString("open_id", map);
+                Long group_id = MapUtils.getLong("group_id", map);
+                Integer attend_num = MapUtils.getInteger("attend_num", map);
+                String name = MapUtils.getString("name", map);
+                String form_id = MapUtils.getString("form_id", map);
+                Integer min_open_group = MapUtils.getInteger("min_open_group", map);
+                BigDecimal retail_min_price = MapUtils.getBigDecimal("retail_min_price", map);
+                if (StringUtils.isNullOrEmpty(form_id)) {
+                    continue;
+                }
+                WxTemplate tem = new WxTemplate();
+                tem.setTemplate_id(templateConfVo.getTemplateId());
+//                tem.setTopcolor("#00DD00");
+                tem.setTouser(open_id);
+                tem.setPage("/pages/groupDetail/groupDetail?id=" + group_id);
+                tem.setForm_id(form_id);
+
+                List<TemplateData> paras = new ArrayList<TemplateData>();
+                paras.add(new TemplateData("keyword1", name, "#000000"));
+                paras.add(new TemplateData("keyword2", attend_num + "/" + min_open_group, "#000000"));
+                paras.add(new TemplateData("keyword3", retail_min_price + "元", "#000000"));
+                paras.add(new TemplateData("keyword4", templateConfVo.getDesc(), "#000000"));
+                tem.setData(paras);
+                WxTemplateUtil.sendMessage(tem);
+                // 更新团购失败订单
+                Map updateFailParams = new HashMap();
+                updateFailParams.put("id", id);
+                qzGroupMapper.updatePastGroup(updateFailParams);
+            }
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>pastGroupRemind is end ");
+    }
+
+    /**
+     * 未评价订单(发送微信模版消息提醒用户)
+     */
+    @Transactional
+    public void orderUnEvaluateRemind() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>orderUnEvaluateRemind is start ");
+        TemplateConfVo templateConfVo =
+                templateConfDao.queryByTypeId(8); //  模板类型 1订单付款成功 2团购成功 3拼团失败通知 4拼团进度 5 6 7订单配送 8订单评价提醒
+        if (null == templateConfVo) {
+            return;
+        }
+        List<Map> unEvaluateList = qzOrderMapper.queryrderUnEvaluateList();
+
+        if (null != unEvaluateList && unEvaluateList.size() > 0) {
+            for (Map map : unEvaluateList) {
+                Long id = MapUtils.getLong("id", map);
+                String form_id = MapUtils.getString("form_id", map);
+                String order_sn = MapUtils.getString("order_sn", map);
+                String open_id = MapUtils.getString("open_id", map);
+                String goods_name = MapUtils.getString("goods_name", map);
+                if (StringUtils.isNullOrEmpty(form_id)) {
+                    continue;
+                }
+                WxTemplate tem = new WxTemplate();
+                tem.setTemplate_id(templateConfVo.getTemplateId());
+//                tem.setTopcolor("#00DD00");
+                tem.setTouser(open_id);
+                tem.setPage("/pages/ucenter/orderDetail/orderDetail?id=" + id);
+                tem.setForm_id(form_id);
+
+                List<TemplateData> paras = new ArrayList<TemplateData>();
+                paras.add(new TemplateData("keyword1", goods_name, "#000000"));
+                paras.add(new TemplateData("keyword2", order_sn, "#000000"));
+                paras.add(new TemplateData("keyword3", templateConfVo.getDesc(), "#000000"));
+                tem.setData(paras);
+                WxTemplateUtil.sendMessage(tem);
+            }
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>orderUnEvaluateRemind is end ");
+    }
+
+    /**
+     * 更新过期未支付订单
+     */
+    @Transactional
+    public void unpayPastUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>unpayPastUpdate is start ");
+        logger.info(">>>>>>>>>>>>>>>>>>>>更新过期未支付订单 ");
+        // 获取快过期订单
+        List<Map> pastOrderList = qzOrderMapper.queryPastOrderList();
+        if (null != pastOrderList && pastOrderList.size() > 0) {
+            for (Map map : pastOrderList) {
+                Integer number = MapUtils.getInteger("number", map);
+                Integer stock_num = MapUtils.getInteger("stock_num", map);
+                Long storeRelaId = MapUtils.getLong("storeRelaId", map);
+                Map param = new HashMap();
+                param.put("id", storeRelaId);
+                param.put("stock_num", stock_num + number);
+                qzOrderMapper.updateStockNum(param);
+            }
+            qzOrderMapper.unpayPastUpdate();
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>unpayPastUpdate is end ");
+    }
+
+    /**
+     * 更新退款中的，或小程序更新退款信息异常订单
+     */
+    @Transactional
+    public void refundUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>refundUpdate is start ");
+        logger.info(">>>>>>>>>>>>>>>>>>>>查询已申请退款订单以及退款中订单，查询微信退款信息更新订单状态 ");
+        // 获取退款中或更新退款信息异常订单
+        List<Map> refundOrderList = qzOrderMapper.queryRefundOrderList();
+        if (null != refundOrderList && refundOrderList.size() > 0) {
+            for (Map map : refundOrderList) {
+                String pay_flag = MapUtils.getString("pay_flag", map);
+                String orderId = MapUtils.getString("order_id", map);
+                if(org.apache.commons.lang.StringUtils.isNotEmpty(pay_flag)) {
+                    if (pay_flag.equalsIgnoreCase("wxglobalpay")) {//微信国际支付
+                        wxGlobalRefundQuery(map);
+                    } else if (pay_flag.equalsIgnoreCase("weixin")) {//微信支付、平安支付、线下扫码支付
+                        wxRefundquery(map);
+                    } else if (pay_flag.equalsIgnoreCase("pingan")) {
+                        pinganRefundquery(map);
+                    }
+                }else{
+                    logger.info(">>>>>>>>>>>>>>>>>>>>refundUpdate 订单编号【"+orderId+"】的支付方式不能为空！ ");
+                }
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>refundUpdate 未查到退款数据 ");
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>refundUpdate is end ");
+    }
+
+    /**
+     * 微信支付、线下扫码支付共用微信查询订单api
+     * @param map
+     */
+    private void  wxRefundquery(Map map){
+        logger.info(">>>>>>>>>>>>>>>>>>>>wxRefundquery 微信退款查询接口调用");
+        String out_trade_no = MapUtils.getString("merch_order_sn", map);
+        String order_id = MapUtils.getString("order_id", map);
+        String order_sn_wx = MapUtils.getString("order_sn_wx", map);
+        String out_refund_no = MapUtils.getString("out_refund_no", map);
+        Integer is_onffline_order = MapUtils.getInteger("is_onffline_order", map);
+        if (is_onffline_order == 1) {
+            out_trade_no = order_sn_wx;
+        }
+        WechatRefundQueryResult result = WechatUtil.wxRefundquery(out_trade_no);
+        if (result.getReturn_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+            if (result.getResult_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+                Map refundRaram = new HashMap();
+                Map orderRaram = new HashMap();
+                int msgCount = Integer.parseInt(result.getRefund_count());
+                for (int i = 0; i < msgCount; i++) {
+                    WechatRefundQueryResult querySuccessResponseDto =
+                            ReaderXmlForDOM4J.parse(result.getXmlStr(), i);
+                    if(out_refund_no.equalsIgnoreCase(querySuccessResponseDto.getOut_refund_no())) {
+                        result.setRefund_success_time(querySuccessResponseDto.getRefund_success_time());
+                        result.setOut_refund_no(querySuccessResponseDto.getOut_refund_no());
+                        result.setRefund_account(querySuccessResponseDto.getRefund_account());
+                        result.setRefund_channel(querySuccessResponseDto.getRefund_channel());
+                        result.setRefund_fee(querySuccessResponseDto.getRefund_fee());
+                        result.setRefund_id(querySuccessResponseDto.getRefund_id());
+                        result.setRefund_recv_accout(querySuccessResponseDto.getRefund_recv_accout());
+                        result.setRefund_status(querySuccessResponseDto.getRefund_status());
+
+                        Date successTime = DateUtils.strToDate(result.getRefund_success_time());
+                        refundRaram.put("refundTime", successTime);
+                        refundRaram.put("outRefundNo", result.getOut_refund_no());
+                        refundRaram.put("refundId", result.getRefund_id());
+                        refundRaram.put("refundMoney",
+                                BigDecimal.valueOf(Long.valueOf(result.getRefund_fee()))
+                                        .divide(Constant.ONE_HUNDRED));
+                        if (result.getRefund_status().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_2.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款成功");
+                            orderRaram.put("payStatus", Dict.payStatus.item_4.getItem());
+                        } else if (result.getRefund_status().equalsIgnoreCase("REFUNDCLOSE")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款关闭");
+                            orderRaram.put("payStatus", Dict.payStatus.item_5.getItem());
+                        } else if (result.getRefund_status().equalsIgnoreCase("CHANGE")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款异常");
+                            orderRaram.put("payStatus", Dict.payStatus.item_6.getItem());
+                        } else if (result.getRefund_status().equalsIgnoreCase("PROCESSING")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_5.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款处理中");
+                            orderRaram.put("payStatus", Dict.payStatus.item_3.getItem());
+                        }
+                        refundRaram.put("refundRecvAccout", result.getRefund_recv_accout());
+                        refundRaram.put("orderRefundId", result.getOut_refund_no());
+                        qzOrderMapper.updateOrderRefund(refundRaram);//更新订单退款信息
+                    }
+                }
+                orderRaram.put("orderStatus", Dict.orderStatus.item_401.getItem());
+                orderRaram.put("orderId", order_id);
+                orderRaram.put("payTransactionId", result.getTransaction_id());
+                qzOrderMapper.updateOrderInfo(orderRaram);
+            } else {
+                logger.info(">>>>>>>>>>>>>>>>>>>>wxRefundquery 微信退款查询接口返回失败信息：code 【" + result.getErr_code() +
+                        "】，des【" + result.getErr_code_des() + "】");
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>wxRefundquery 微信退款查询接口调用失败： " + result.getReturn_msg());
+        }
+    }
+
+    /**
+     * 平安支付查询订单api
+     * @param map
+     */
+    private void  pinganRefundquery(Map map){
+        logger.info(">>>>>>>>>>>>>>>>>>>>pinganRefundquery 平安退款查询接口调用");
+        String outNo = MapUtils.getString("merch_order_sn", map);
+        String outRefundNo = MapUtils.getString("out_refund_no", map);
+        String orderId = MapUtils.getString("order_id", map);
+
+        PinganResponseDto response = PinganUtil.pinganQueryRefund(null, outRefundNo);
+        if (!Objects.isNull(response)) {
+            response.setOutNo(outNo);
+            response.setCreateTime(new Date());
+            qzOrderMapper.insertPinganResponseDto(MapBeanUtil.fromObject(response));
+
+            if ("0".equals(response.getErrcode()) && StringUtils.isNotEmpty(response.getDatajson())) {
+                JSONObject refundResult = JSONObject.fromObject(response.getDatajson());
+                String tradeResult = refundResult.getString("trade_result");
+
+                JSONObject result = JSONObject.fromObject(tradeResult);
+                Map refundParam = new HashMap();
+                Map orderParam = new HashMap();
+
+                String refundCount= MapUtils.getString("refund_count", result);
+                if (!StringUtils.isNullOrEmpty(refundCount) && !"null".equals(refundCount)) {
+                    int msgCount = Integer.parseInt(refundCount);
+                    for (int i = 0; i < msgCount; i++) {
+                        WechatRefundQueryResult refundQueryResult = PinganUtil.buildWechatRefundQueryResult(result, i);
+                        if (outRefundNo.equalsIgnoreCase(refundQueryResult.getOut_refund_no())) {
+                            Date successTime = DateUtils.strToDate(refundQueryResult.getRefund_success_time());
+                            refundParam.put("refundTime", successTime);
+                            refundParam.put("outRefundNo", refundQueryResult.getOut_refund_no());
+                            refundParam.put("refundId", refundQueryResult.getRefund_id());
+                            refundParam.put("refundMoney",
+                                    BigDecimal.valueOf(Long.valueOf(refundQueryResult.getRefund_fee()))
+                                            .divide(Constant.ONE_HUNDRED));
+                            if (refundQueryResult.getRefund_status().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+                                refundParam.put("refundStatus", Dict.RefundStatus.item_2.getItem());
+                                refundParam.put("wechat_refund_status_des", "退款成功");
+                                orderParam.put("payStatus", Dict.payStatus.item_4.getItem());
+                            } else if (refundQueryResult.getRefund_status().equalsIgnoreCase("REFUNDCLOSE")) {
+                                refundParam.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                                refundParam.put("wechat_refund_status_des", "退款关闭");
+                                orderParam.put("payStatus", Dict.payStatus.item_5.getItem());
+                            } else if (refundQueryResult.getRefund_status().equalsIgnoreCase("CHANGE")) {
+                                refundParam.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                                refundParam.put("wechat_refund_status_des", "退款异常");
+                                orderParam.put("payStatus", Dict.payStatus.item_6.getItem());
+                            } else if (refundQueryResult.getRefund_status().equalsIgnoreCase("PROCESSING")) {
+                                refundParam.put("refundStatus", Dict.RefundStatus.item_5.getItem());
+                                refundParam.put("wechat_refund_status_des", "退款处理中");
+                                orderParam.put("payStatus", Dict.payStatus.item_3.getItem());
+                            }
+                            refundParam.put("refundRecvAccout", refundQueryResult.getRefund_recv_accout());
+                            refundParam.put("orderRefundId", refundQueryResult.getOut_refund_no());
+                            qzOrderMapper.updateOrderRefund(refundParam);//更新订单退款信息
+                        }
+                    }
+                } else {
+                    WechatRefundQueryResult refundQueryResult = PinganUtil.buildWechatRefundQueryResult(result);
+                    if (outRefundNo.equalsIgnoreCase(refundQueryResult.getOut_refund_no())) {
+                        Date successTime = DateUtils.strToDate(refundQueryResult.getRefund_success_time());
+                        refundParam.put("refundTime", successTime);
+                        refundParam.put("outRefundNo", refundQueryResult.getOut_refund_no());
+                        refundParam.put("refundId", refundQueryResult.getRefund_id());
+                        refundParam.put("refundMoney",
+                                BigDecimal.valueOf(Long.valueOf(refundQueryResult.getRefund_fee()))
+                                        .divide(Constant.ONE_HUNDRED));
+                        if (refundQueryResult.getRefund_status().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+                            refundParam.put("refundStatus", Dict.RefundStatus.item_2.getItem());
+                            refundParam.put("wechat_refund_status_des", "退款成功");
+                            orderParam.put("payStatus", Dict.payStatus.item_4.getItem());
+                        } else if (refundQueryResult.getRefund_status().equalsIgnoreCase("REFUNDCLOSE")) {
+                            refundParam.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundParam.put("wechat_refund_status_des", "退款关闭");
+                            orderParam.put("payStatus", Dict.payStatus.item_5.getItem());
+                        } else if (refundQueryResult.getRefund_status().equalsIgnoreCase("CHANGE")) {
+                            refundParam.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundParam.put("wechat_refund_status_des", "退款异常");
+                            orderParam.put("payStatus", Dict.payStatus.item_6.getItem());
+                        } else if (refundQueryResult.getRefund_status().equalsIgnoreCase("PROCESSING")) {
+                            refundParam.put("refundStatus", Dict.RefundStatus.item_5.getItem());
+                            refundParam.put("wechat_refund_status_des", "退款处理中");
+                            orderParam.put("payStatus", Dict.payStatus.item_3.getItem());
+                        }
+                        refundParam.put("refundRecvAccout", refundQueryResult.getRefund_recv_accout());
+                        refundParam.put("orderRefundId", refundQueryResult.getOut_refund_no());
+                        qzOrderMapper.updateOrderRefund(refundParam);//更新订单退款信息
+                    }
+                }
+                orderParam.put("orderStatus", Dict.orderStatus.item_401.getItem());
+                orderParam.put("orderId", orderId);
+                qzOrderMapper.updateOrderInfo(orderParam);
+            } else {
+                logger.info(">>>>>>>>>>>>>>>>>>>>pinganRefundquery 平安退款查询接口返回失败信息：code 【" + response.getErrcode() + "】，des【" + response.getMsg() + "】");
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>pinganRefundquery 平安退款查询接口调用失败");
+        }
+
+        /*WechatRefundQueryResult result = WechatUtil.wxRefundquery(out_trade_no);
+        if (result.getReturn_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+            if (result.getResult_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+                Map refundRaram = new HashMap();
+                Map orderRaram = new HashMap();
+                int msgCount = Integer.parseInt(result.getRefund_count());
+                for (int i = 0; i < msgCount; i++) {
+                    WechatRefundQueryResult querySuccessResponseDto =
+                            ReaderXmlForDOM4J.parse(result.getXmlStr(), i);
+                    if(out_refund_no.equalsIgnoreCase(querySuccessResponseDto.getOut_refund_no())) {
+                        result.setRefund_success_time(querySuccessResponseDto.getRefund_success_time());
+                        result.setOut_refund_no(querySuccessResponseDto.getOut_refund_no());
+                        result.setRefund_account(querySuccessResponseDto.getRefund_account());
+                        result.setRefund_channel(querySuccessResponseDto.getRefund_channel());
+                        result.setRefund_fee(querySuccessResponseDto.getRefund_fee());
+                        result.setRefund_id(querySuccessResponseDto.getRefund_id());
+                        result.setRefund_recv_accout(querySuccessResponseDto.getRefund_recv_accout());
+                        result.setRefund_status(querySuccessResponseDto.getRefund_status());
+
+                        Date successTime = DateUtils.strToDate(result.getRefund_success_time());
+                        refundRaram.put("refundTime", successTime);
+                        refundRaram.put("outRefundNo", result.getOut_refund_no());
+                        refundRaram.put("refundId", result.getRefund_id());
+                        refundRaram.put("refundMoney",
+                                BigDecimal.valueOf(Long.valueOf(result.getRefund_fee()))
+                                        .divide(Constant.ONE_HUNDRED));
+                        if (result.getRefund_status().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_2.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款成功");
+                            orderRaram.put("payStatus", Dict.payStatus.item_4.getItem());
+                        } else if (result.getRefund_status().equalsIgnoreCase("REFUNDCLOSE")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款关闭");
+                            orderRaram.put("payStatus", Dict.payStatus.item_5.getItem());
+                        } else if (result.getRefund_status().equalsIgnoreCase("CHANGE")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款异常");
+                            orderRaram.put("payStatus", Dict.payStatus.item_6.getItem());
+                        } else if (result.getRefund_status().equalsIgnoreCase("PROCESSING")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_5.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款处理中");
+                            orderRaram.put("payStatus", Dict.payStatus.item_3.getItem());
+                        }
+                        refundRaram.put("refundRecvAccout", result.getRefund_recv_accout());
+                        refundRaram.put("orderRefundId", result.getOut_refund_no());
+                        qzOrderMapper.updateOrderRefund(refundRaram);//更新订单退款信息
+                    }
+                }
+                orderRaram.put("orderStatus", Dict.orderStatus.item_401.getItem());
+                orderRaram.put("orderId", order_id);
+                orderRaram.put("payTransactionId", result.getTransaction_id());
+                qzOrderMapper.updateOrderInfo(orderRaram);
+            } else {
+                logger.info(">>>>>>>>>>>>>>>>>>>>pinganRefundquery 平安退款查询接口返回失败信息：code 【" + result.getErr_code() + "】，des【" + result.getErr_code_des() + "】");
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>pinganRefundquery 平安退款查询接口调用失败： " + result.getReturn_msg());
+        }*/
+    }
+
+    /**
+     * 微信国际支付微信查询订单api
+     * @param map
+     */
+    private void  wxGlobalRefundQuery(Map map){
+        logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalRefundQuery 微信国际退款查询接口调用");
+        String out_trade_no = MapUtils.getString("merch_order_sn", map);
+        String order_id = MapUtils.getString("order_id", map);
+        String out_refund_no = MapUtils.getString("out_refund_no", map);
+        WechatGlobalRefundQueryResult result = WechatGlobalUtil.wxRefundquery(out_trade_no);
+        if (result.getCode() == null) {
+            int totalNum = result.getTotal_num();//总退款次数
+            int currentTotalNum = result.getCurrent_total_num();//本次返回退款单数
+            if(totalNum - currentTotalNum != 0){
+                logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalRefundQuery 微信国际退款查询接口还剩【"+(totalNum-currentTotalNum)+"】条数据未更新");
+            }
+            List<WechatGlobalRefundQueryDto> refundQueryList = result.getData();
+            if (refundQueryList != null && refundQueryList.size() > 0) {
+                Map orderRaram = new HashMap();
+                Map refundRaram = new HashMap();
+                for (int i = 0; i < refundQueryList.size(); i++) {
+                    //微信部分退款时返回的多条退款信息数据解析
+                    WechatGlobalRefundQueryDto querySuccessResponseDto = refundQueryList.get(i);
+                    if(out_refund_no.equalsIgnoreCase(querySuccessResponseDto.getOut_refund_no())) {
+                        //微信部分退款时返回的多条退款信息数据
+                        refundRaram.put("outRefundNo", querySuccessResponseDto.getOut_refund_no());
+                        refundRaram.put("refundId", querySuccessResponseDto.getId());
+                        refundRaram.put("refundMoney",
+                                BigDecimal.valueOf(Long.valueOf(querySuccessResponseDto.getAmount().getRefund()))
+                                        .divide(Constant.ONE_HUNDRED));//申请退款金额
+                        refundRaram.put("refundFeeType", querySuccessResponseDto.getAmount().getCurrency());//申请退款币种
+                        refundRaram.put("totalFee", BigDecimal.valueOf(Long.valueOf(result.getAmount().getTotal()))
+                                .divide(Constant.ONE_HUNDRED));//商家订单标价总金额
+                        refundRaram.put("feeType", result.getAmount().getCurrency());//商家订单标价币种
+
+                        refundRaram.put("cashRefundFee", BigDecimal.valueOf(Long.valueOf(querySuccessResponseDto.getAmount().getPayer_refund()))
+                                .divide(Constant.ONE_HUNDRED));//用户支付退款金额
+                        refundRaram.put("cashRefundFeeType", querySuccessResponseDto.getAmount().getPayer_currency());//用户支付退款金额币种
+
+                        refundRaram.put("cashFee", BigDecimal.valueOf(Long.valueOf(result.getAmount().getPayer_total()))
+                                .divide(Constant.ONE_HUNDRED));//用户实际支付金额
+                        refundRaram.put("cashFeeType", result.getAmount().getPayer_currency());//用户实际支付金额币种
+
+                        Integer rate = querySuccessResponseDto.getAmount().getExchange_rate().getRate();
+                        BigDecimal rateValue = new BigDecimal(rate).divide(new BigDecimal(100000000));
+
+                        refundRaram.put("rate", rateValue.toString());//汇率
+                        if (querySuccessResponseDto.getStatus().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+                            Date succTime = DateUtils.convertStringToDate(querySuccessResponseDto.getSuccess_time(), DateUtils.DATE_TIME_PATTERN_YYYY_T);
+                            refundRaram.put("refundTime", succTime);
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_2.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款成功");
+                            orderRaram.put("payStatus", Dict.payStatus.item_4.getItem());
+                        } else if (querySuccessResponseDto.getStatus().equalsIgnoreCase("PROCESSING")) {
+//                            Date createTime = DateUtils.convertStringToDate(querySuccessResponseDto.getCreate_time(), DateUtils.DATE_TIME_PATTERN_YYYY_T);
+//                            refundRaram.put("refundCreateTime", createTime);
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_5.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款处理中");
+                            orderRaram.put("payStatus", Dict.payStatus.item_3.getItem());
+                        } else if (querySuccessResponseDto.getStatus().equalsIgnoreCase("REFUNDCLOSE")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款关闭");
+                            orderRaram.put("payStatus", Dict.payStatus.item_5.getItem());
+                        } else if (querySuccessResponseDto.getStatus().equalsIgnoreCase("CHANGE")) {
+                            refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
+                            refundRaram.put("wechat_refund_status_des", "退款异常");
+                            orderRaram.put("payStatus", Dict.payStatus.item_6.getItem());
+                        }
+                        refundRaram.put("refundRecvAccout", querySuccessResponseDto.getRecv_accout());
+                        refundRaram.put("orderRefundId", querySuccessResponseDto.getOut_refund_no());
+                        qzOrderMapper.updateOrderRefund(refundRaram);//更新订单退款信息
+                    }
+                }
+                orderRaram.put("orderStatus", Dict.orderStatus.item_401.getItem());
+                orderRaram.put("orderId", order_id);
+                orderRaram.put("payTransactionId", result.getId());
+                qzOrderMapper.updateOrderInfo(orderRaram);
+            } else {
+                logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalRefundQuery 微信国际退款查询接口返回失败，退款单列表为空");
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalRefundQuery 微信国际退款查询接口调用失败： " + result.getMessage());
+        }
+    }
+
+
+    /**
+     * 查询小程序支付状态“支付中或成功”的订单信息，以及小程序更新支付信息缺失的订单，获取商户订单号查询微信支付信息更新小程序订单支付数据
+     */
+    @Transactional
+    public void orderQueryUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>orderQueryUpdate is start ");
+        logger.info(">>>>>>>>>>>>>>>>>>>>查询小程序支付状态“支付中或成功”的订单信息，以及小程序更新支付信息缺失的订单，获取商户订单号查询微信支付信息更新小程序订单支付数据");
+        // 获取支付中的订单以及小程序更新支付信息异常订单
+        List<Map> orderList = qzOrderMapper.queryPayingOrderList();
+        if (null != orderList && orderList.size() > 0) {
+            for (Map map : orderList) {
+                String pay_flag = MapUtils.getString("pay_flag", map);
+                String orderId = MapUtils.getString("order_id", map);
+                String out_trade_no = MapUtils.getString("merch_order_sn", map);
+                BigDecimal total = qzOrderMapper.getTotalActualPriceByMerchOrderSn(out_trade_no);
+                if(total != null){
+                    total = total.multiply(Constant.ONE_HUNDRED);
+                }
+                if(org.apache.commons.lang.StringUtils.isNotEmpty(pay_flag)) {
+                    if (pay_flag.equalsIgnoreCase("wxglobalpay")) {//微信国际支付
+                        wxGlobalOrderQuery(map,total);
+                    } else {//微信支付、平安支付、线下扫码支付
+                        wxOrderQuery(map);
+                    }
+                }else{
+                    logger.info(">>>>>>>>>>>>>>>>>>>>refundUpdate 订单编号【"+orderId+"】的支付方式不能为空！ ");
+                }
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>orderQueryUpdate 未查到订单数据 ");
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>orderQueryUpdate is end ");
+    }
+
+    /**
+     * 微信查询接口
+     * @param map
+     */
+    private void wxOrderQuery(Map map){
+        logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口调用");
+        String out_trade_no = MapUtils.getString("merch_order_sn", map);
+        String orderId = MapUtils.getString("order_id", map);
+        String orderSn = MapUtils.getString("order_sn", map);
+        String add_time = MapUtils.getString("add_time", map);
+        Integer number = MapUtils.getInteger("number", map);
+        Integer stock_num = MapUtils.getInteger("stock_num", map);
+        Long storeRelaId = MapUtils.getLong("storeRelaId", map);
+        Date addTime = DateUtils.strToDate(add_time);
+        Date nowDate = new Date();
+
+        WechatRefundApiResult result = WechatUtil.wxOrderQuery(out_trade_no);
+        if (result.getReturn_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
+            if (result.getResult_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode()) ){
+                if(result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_SUCCESS.getItem())) {
+                    Date successTime = DateUtils.convertStringToDate(result.getTime_end(),
+                            DateUtils.DATE_TIME_PATTERN_YYYY_MM_DD_HH_MM_SS);
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_2.getItem());//已支付
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_201.getItem());//已支付
+                    orderRaram.put("payTransactionId", result.getTransaction_id());
+                    orderRaram.put("payTime", successTime);
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    Map processParam = new HashMap();
+                    processParam.put("payTime", successTime);
+                    processParam.put("orderSn", orderSn);
+                    qzOrderMapper.updateOrderProcessRecord(processParam);
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_NOTPAY.getItem())) {//订单未支付
+                    Map orderRaram = new HashMap();
+                    if (getDateBetween(addTime, nowDate) >= 15) {//订单下单时间超过15分钟直接取消订单
+                        Map param = new HashMap();
+                        param.put("id", storeRelaId);
+                        param.put("stock_num", stock_num + number);
+                        qzOrderMapper.updateStockNum(param);//库存还原
+                        orderRaram.put("orderStatus", Dict.orderStatus.item_101.getItem());//订单状态已取消
+                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
+                    } else {
+                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
+                        orderRaram.put("orderStatus", Dict.orderStatus.item_0.getItem());//订单状态未支付
+                    }
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_CLOSED.getItem())) {
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_7.getItem());
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_500.getItem());
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    Map param = new HashMap();
+                    param.put("id", storeRelaId);
+                    param.put("stock_num", stock_num + number);
+                    qzOrderMapper.updateStockNum(param);//库存还原
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderByTransactionIdQueryUpdFail 根据支付单查询微信接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + result.getTrade_state_desc() + "】");
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_PAYERROR.getItem())) {
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_8.getItem());
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_501.getItem());
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderByTransactionIdQueryUpdFail 根据支付单查询微信接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + result.getTrade_state_desc() + "】");
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_USERPAYING.getItem())) {
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_1.getItem());
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_100.getItem());
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderByTransactionIdQueryUpdFail 根据支付单查询微信接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + result.getTrade_state_desc() + "】");
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_REVOKED.getItem())) {
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderByTransactionIdQueryUpdFail 根据支付单查询微信接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + result.getTrade_state_desc() + "】");
+                }
+            }else {
+                logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回失败信息：code 【" + result.getErr_code() +
+                        "】，des【" + result.getErr_code_des() + "】");
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口调用失败： " + result.getReturn_msg());
+        }
+    }
+
+    /**
+     * 微信国际查询接口
+     * @param map
+     */
+    private void wxGlobalOrderQuery(Map map, BigDecimal total){
+        logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderQuery 微信查询接口调用");
+        String out_trade_no = MapUtils.getString("merch_order_sn", map);
+        String orderId = MapUtils.getString("order_id", map);
+        String orderSn = MapUtils.getString("order_sn", map);
+        String add_time = MapUtils.getString("add_time", map);
+        Integer number = MapUtils.getInteger("number", map);
+        Integer stock_num = MapUtils.getInteger("stock_num", map);
+        Long storeRelaId = MapUtils.getLong("storeRelaId", map);
+        Date addTime = DateUtils.strToDate(add_time);
+        Date nowDate = new Date();
+        WechatGlobalUniformNotifyResult result = WechatGlobalUtil.wxOrderQuery(out_trade_no);
+        if(result.getCode() != null){
+            logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderQuery 微信查询接口调用失败： " + result.getMessage());
+        }else {
+            BigDecimal total_fee = new BigDecimal(result.getAmount().getTotal());
+            if(total.compareTo(total_fee) == 0) {
+                if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_SUCCESS.getItem())) {
+                    Date successTime = DateUtils.convertStringToDate(result.getSuccess_time(),
+                            DateUtils.DATE_TIME_PATTERN_YYYY_T);
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_2.getItem());//已支付
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_201.getItem());//已支付
+                    orderRaram.put("payTransactionId", result.getId());
+                    orderRaram.put("payTime", successTime);
+                    orderRaram.put("orderId", orderId);
+                    if (result.getAmount() != null) {
+                        BigDecimal totalFee = BigDecimal.valueOf(Long.valueOf(result.getAmount().getTotal()))
+                                .divide(Constant.ONE_HUNDRED);
+                        orderRaram.put("totalFee", totalFee);//标价金额
+                        orderRaram.put("feeType", result.getAmount().getCurrency());//标价币种
+                        BigDecimal cashFee = BigDecimal.valueOf(Long.valueOf(result.getAmount().getPayer_total()))
+                                .divide(Constant.ONE_HUNDRED);
+                        orderRaram.put("cashFee", cashFee);//用户支付金额
+                        orderRaram.put("cashFeeType", result.getAmount().getPayer_currency());//用户支付金额币种
+                        Integer rate = result.getAmount().getExchange_rate().getRate();
+                        if (rate != null) {
+                            BigDecimal rateValue = new BigDecimal(rate).divide(new BigDecimal(100000000));
+                            orderRaram.put("rate", rateValue.toString());//汇率
+                        }
+                        // TODO: 2018/12/29  根据汇率计算每笔订单的用户支付人民币金额
+                    }
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    Map processParam = new HashMap();
+                    processParam.put("payTime", successTime);
+                    processParam.put("orderSn", orderSn);
+                    qzOrderMapper.updateOrderProcessRecord(processParam);
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_NOTPAY.getItem())) {//订单未支付
+                    Map orderRaram = new HashMap();
+                    if (getDateBetween(addTime, nowDate) >= 15) {//订单下单时间超过15分钟直接取消订单
+                        Map param = new HashMap();
+                        param.put("id", storeRelaId);
+                        param.put("stock_num", stock_num + number);
+                        qzOrderMapper.updateStockNum(param);//库存还原
+                        orderRaram.put("orderStatus", Dict.orderStatus.item_101.getItem());//订单状态已取消
+                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
+                    } else {
+                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
+                        orderRaram.put("orderStatus", Dict.orderStatus.item_0.getItem());//订单状态未支付
+                    }
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_CLOSED.getItem())) {
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_7.getItem());
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_500.getItem());
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    Map param = new HashMap();
+                    param.put("id", storeRelaId);
+                    param.put("stock_num", stock_num + number);
+                    qzOrderMapper.updateStockNum(param);//库存还原
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderByTransactionIdQueryUpdFail 根据支付单查询微信国际接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + Dict.tradeState.item_CLOSED.getItemName() + "】");
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_PAYERROR.getItem())) {
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_8.getItem());
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_501.getItem());
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderByTransactionIdQueryUpdFail 根据支付单查询微信国际接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + Dict.tradeState.item_PAYERROR.getItemName() + "】");
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_USERPAYING.getItem())) {
+                    Map orderRaram = new HashMap();
+                    orderRaram.put("payStatus", Dict.payStatus.item_1.getItem());
+                    orderRaram.put("orderStatus", Dict.orderStatus.item_100.getItem());
+                    orderRaram.put("orderId", orderId);
+                    qzOrderMapper.updateOrderInfo(orderRaram);
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderByTransactionIdQueryUpdFail 根据支付单查询微信国际接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + Dict.tradeState.item_USERPAYING.getItemName() + "】");
+                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_REVOKED.getItem())) {
+                    logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderByTransactionIdQueryUpdFail 根据支付单查询微信国际接口返回信息：state 【" + result.getTrade_state() +
+                            "】，des【" + Dict.tradeState.item_REVOKED.getItemName() + "】");
+                }
+            }else{
+                logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderByTransactionIdQueryUpdFail 根据支付单查询微信国际接口返回信息异常：微信支付回调返回的订单金额与商户订单金额不一致");
+
+            }
+        }
+    }
+
+    /**
+     * 查询支付中的订单以及小程序更新支付信息异常订单，查询平安订单更新订单状态
+     */
+    @Transactional
+    public void pinganOrderQueryUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>pinganOrderQueryUpdate is start ");
+        logger.info(">>>>>>>>>>>>>>>>>>>>查询支付中的订单以及小程序更新支付信息异常订单，查询平安订单信息更新订单状态 ");
+        // 获取支付中的订单以及小程序更新支付信息异常订单
+        List<Map> orderList = qzOrderMapper.queryPinganPayingOrderList();
+        if (null != orderList && orderList.size() > 0) {
+            for (Map map : orderList) {
+                String outNo = MapUtils.getString("merch_order_sn", map);
+                String orderId = MapUtils.getString("order_id", map);
+                String orderSn = MapUtils.getString("order_sn", map);
+                String add_time = MapUtils.getString("add_time", map);
+                Integer number = MapUtils.getInteger("number", map);
+                Integer stockNum = MapUtils.getInteger("stock_num", map);
+                Long storeRelaId = MapUtils.getLong("storeRelaId", map);
+
+                PinganResponseDto response = PinganUtil.pinganPaystatus(outNo);
+
+                if (!Objects.isNull(response)) {
+                    response.setOutNo(outNo);
+                    response.setCreateTime(new Date());
+                    qzOrderMapper.insertPinganResponseDto(MapBeanUtil.fromObject(response));
+
+                    if ("0".equals(response.getErrcode()) && StringUtils.isNotEmpty(response.getDatajson())) {
+                        PinganPayOrderDto payOrderDto = PinganUtil.buildPayOrderDto(JSONObject.fromObject(response.getDatajson()));
+                        qzOrderMapper.updatePayOrderByOutNo(MapBeanUtil.fromObject(payOrderDto));
+
+                        Date addTime = DateUtils.strToDate(add_time);
+                        Date nowDate = new Date();
+                        // 订单状态（1交易成功，2待支付，4已取消，9等待用户输入密码确认）
+                        if (payOrderDto.getStatus() == 1) {
+                            Map orderParam = new HashMap();
+                            orderParam.put("payStatus", 2);//已支付
+                            orderParam.put("orderStatus", 201);//已支付
+                            orderParam.put("payTransactionId", payOrderDto.getTradeNo());
+                            orderParam.put("payTime", payOrderDto.getTradeTime());
+                            orderParam.put("orderId", orderId);
+                            qzOrderMapper.updateOrderInfo(orderParam);
+                            Map processParam = new HashMap();
+                            processParam.put("payTime", payOrderDto.getTradeTime());
+                            processParam.put("orderSn", orderSn);
+                            qzOrderMapper.updateOrderProcessRecord(processParam);
+                        } else {
+                            Map orderRaram = new HashMap();
+                            if (getDateBetween(addTime, nowDate) >= 15) {//订单下单时间超过15分钟直接取消订单
+                                orderRaram.put("payStatus", 0);//支付状态未支付
+                                orderRaram.put("orderStatus", 101);//订单状态已取消
+                                Map param = new HashMap();
+                                param.put("id", storeRelaId);
+                                param.put("stock_num", stockNum + number);
+                                qzOrderMapper.updateStockNum(param);
+                            } else {
+                                orderRaram.put("payStatus", 0);//支付状态未支付
+                                orderRaram.put("orderStatus", 0);//订单状态未支付
+                            }
+                            orderRaram.put("orderId", orderId);
+                            qzOrderMapper.updateOrderInfo(orderRaram);
+                        }
+                    } else {
+                        logger.info(">>>>>>>>>>>>>>>>>>>>pinganOrderQueryUpdate 平安查询接口返回失败信息：code 【" + response.getErrcode() + "】，des【" + response.getMsg() + "】");
+                    }
+                } else {
+                    logger.info(">>>>>>>>>>>>>>>>>>>>pinganOrderQueryUpdate 平安查询接口调用失败");
+                }
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>pinganOrderQueryUpdate 未查到订单数据 ");
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>pinganOrderQueryUpdate is end ");
+    }
+
+    /**
+     * 查询付款码支付记录的支付状态
+     */
+    @Transactional
+    public void orderMicropayQueryUpdate() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>查询付款码支付记录的支付状态开始<<<<<<<<<<<<<<<<<<<<<<<");
+        // 获取交易状态是未支付,支付中和支付失败3种状态的付款码支付记录
+        List<String> tradeStates = new ArrayList<>();
+        tradeStates.add(WechatUtil.WXTradeState.NOTPAY.getCode());
+        tradeStates.add(WechatUtil.WXTradeState.USERPAYING.getCode());
+        tradeStates.add(WechatUtil.WXTradeState.PAYERROR.getCode());
+        List<Map> records = orderWXPayRecordMapper.queryRecordList(tradeStates);
+        if (null != records && records.size() > 0) {
+            for (Map map : records) {
+                String out_trade_no_wx = MapUtils.getString("out_trade_no_wx", map);
+                String out_trade_no = MapUtils.getString("out_trade_no", map);
+                Integer id = MapUtils.getInteger("id", map);
+
+                WechatRefundApiResult result = WechatUtil.wxOrderQuery(out_trade_no_wx);
+                if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(result.getReturn_code()) && WechatUtil.WXTradeState.SUCCESS.getCode().equals(result.getResult_code())) {
+                    Map recordRaram = new HashMap();
+                    recordRaram.put("id", id);
+                    recordRaram.put("trade_state", result.getTrade_state());
+                    //查询到支付成功
+                    if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(result.getTrade_state())) {
+                        recordRaram.put("result_code", result.getTrade_state());
+                        recordRaram.put("err_code", "");
+                        recordRaram.put("err_code_des", "");
+                        recordRaram.put("openid", result.getOpenid());
+                        recordRaram.put("is_subscribe", result.getIs_subscribe());
+                        recordRaram.put("trade_type", result.getTrade_type());
+                        recordRaram.put("fee_type", result.getFee_type());
+                        recordRaram.put("total_fee", result.getTotal_fee());
+                        recordRaram.put("transaction_id", result.getTransaction_id());
+                        recordRaram.put("attach", result.getAttach());
+                        recordRaram.put("time_end", result.getTime_end());
+
+                        //修改订单状态
+                        Map order = qzOrderMapper.queryOrder(out_trade_no);
+                        if (MapUtils.getInteger("order_status", order) == 201) {
+                            logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 此订单已付款： " + out_trade_no);
+                        } else if (MapUtils.getInteger("order_status", order) == 301) {
+                            logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 此订单已完成： " + out_trade_no);
+                        } else if (MapUtils.getInteger("order_status", order) == 101) {
+                            logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 此订单已取消： " + out_trade_no);
+                        } else if (MapUtils.getInteger("order_status", order) == 102) {
+                            logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 此订单已删除： " + out_trade_no);
+                        } else {
+                            Map orderRaram = new HashMap();
+                            orderRaram.put("payStatus", 2);//已支付
+                            orderRaram.put("orderStatus", 201);//已支付
+                            orderRaram.put("payFlag", "weixin");
+                            orderRaram.put("orderSnWx",out_trade_no_wx);
+                            orderRaram.put("payTime", new Date());
+                            orderRaram.put("orderId", MapUtils.getInteger("id", order));
+                            qzOrderMapper.updateOrderInfo(orderRaram);
+                            logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 订单:" + out_trade_no +
+                                        "支付成功,修改支付状态");
+
+                            //查询当前订单所有的支付记录
+                            List<Map> orderWXPayRecordEntitys =
+                                    orderWXPayRecordMapper.getRecordsByOutTradeNo(out_trade_no);
+                            for (Map orderWXPayRecordTemp : orderWXPayRecordEntitys) {
+                                //查询出来的记录不等于当前记录,并且未撤销,未关闭时,撤销订单
+                                Integer orderWXPayRecordTemp_id = MapUtils.getInteger("id", orderWXPayRecordTemp);
+                                String orderWXPayRecordTemp_tradeState =
+                                        MapUtils.getString("trade_state", orderWXPayRecordTemp);
+                                String orderWXPayRecordTemp_outTradeNoWX =
+                                        MapUtils.getString("out_trade_no_wx", orderWXPayRecordTemp);
+                                if (orderWXPayRecordTemp_id != id && (!WechatUtil.WXTradeState.REVOKED.getCode()
+                                                                                                      .equals(orderWXPayRecordTemp_tradeState) ||
+                                                                      !WechatUtil.WXTradeState.CLOSED.getCode()
+                                                                                                     .equals(orderWXPayRecordTemp_tradeState))) {
+
+                                    logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 订单:" +
+                                                orderWXPayRecordTemp_outTradeNoWX + "支付失败,调用撤销订单接口开始");
+                                    WechatUtil.wxReverse(orderWXPayRecordTemp_outTradeNoWX);
+                                    logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 订单:" +
+                                                orderWXPayRecordTemp_outTradeNoWX + "支付失败,调用撤销订单接口结束");
+                                }
+                            }
+
+                        }
+                        //查询到支付失败,撤销订单
+                    } else if (WechatUtil.WXTradeState.PAYERROR.getCode().equals(result.getTrade_state())) {
+                        logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 订单:" + out_trade_no_wx +
+                                    "支付失败,调用撤销订单接口开始");
+                        WechatUtil.wxReverse(out_trade_no_wx);
+                        logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 订单:" + out_trade_no_wx +
+                                    "支付失败,调用撤销订单接口结束");
+                    }
+                    recordRaram.put("mod_time", new Date());
+                    orderWXPayRecordMapper.update(recordRaram);
+
+                } else {
+                    logger.info(
+                            ">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 微信查询接口调用失败： " + result.getReturn_msg());
+                }
+            }
+        } else {
+            logger.info(">>>>>>>>>>>>>>>>>>>>orderWXPayRecordQueryUpdate 未查到需要调用接口的支付记录数据 ");
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>查询付款码支付记录的支付状态 结束<<<<<<<<<<<<<<<<<<<<<<<");
+    }
+
+    /**
+     * 商品发货后7天自动确认收货
+     */
+    @Transactional
+    public void shipmentOrderAutoTakeGoods() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>shipmentOrderAutoTakeGoods is start ");
+        logger.info(">>>>>>>>>>>>>>>>>>>>商品发货后7天自动确认收货 ");
+        // 查询门店业务发货后7天的订单，门店业务根据清关完成时间后7天
+        List<Map> shipmentOrderList = qzOrderMapper.queryShipmentOrderList();
+        if (null != shipmentOrderList && shipmentOrderList.size() > 0) {
+            for (Map map : shipmentOrderList) {
+                Map orderMap = new HashMap();
+                orderMap.put("orderId", MapUtils.getLong("orderId", map));
+                qzOrderMapper.updateShipmentOrder(orderMap);
+            }
+        }
+        //查询保税备货发货后7天的订单，保税备货根据发货完成时间后7天
+        List<Map> shipmentBondedOrderList = qzOrderMapper.queryShipmentBondedOrderList();
+        if (null != shipmentBondedOrderList && shipmentBondedOrderList.size() > 0) {
+            for (Map map : shipmentBondedOrderList) {
+                Map orderMap = new HashMap();
+                orderMap.put("orderId", MapUtils.getLong("orderId", map));
+                qzOrderMapper.updateShipmentOrder(orderMap);
+            }
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>shipmentOrderAutoTakeGoods is end ");
+    }
+
+    /**
+     * 确认收货后30天自动确认好评
+     */
+    @Transactional
+    public void receiptOrderAutoComment() {
+        logger.info(">>>>>>>>>>>>>>>>>>>>receiptOrderAutoComment is start ");
+        logger.info(">>>>>>>>>>>>>>>>>>>>确认收货后30天自动确认好评 ");
+        // 获取收货后30天的订单
+        List<Map> receiptOrderList = qzOrderMapper.queryReceiptOrderList();
+        if (null != receiptOrderList && receiptOrderList.size() > 0) {
+            for (Map map : receiptOrderList) {
+                Long userId = MapUtils.getLong("userId", map);
+                Long orderId = MapUtils.getLong("orderId", map);
+                Long goodsId = MapUtils.getLong("goodsId", map);
+                Long productId = MapUtils.getLong("productId", map);
+                String goodsSpecificationNameValue = MapUtils.getString("goodsSpecificationNameValue", map);
+                String goodsName = MapUtils.getString("goodsName", map);
+
+                Map param = new HashMap();
+                param.put("userId", userId);
+                param.put("orderId", orderId);
+                param.put("valueId", goodsId);
+                param.put("typeId", 0);
+                param.put("productId", productId);
+                param.put("goodsSpecificationNameValue", goodsSpecificationNameValue);
+                param.put("status", "1");
+                param.put("content", "默认好评");
+                param.put("evalLevel", 5);
+                param.put("goodsLevel", 5);
+                param.put("valueName", goodsName);
+                param.put("createTime", new Date());
+                param.put("modTime", new Date());
+                qzOrderMapper.insertComment(param);//新增评论
+            }
+            qzOrderMapper.updateReceiptOrderByCommentCount();//修改评论数量
+        }
+        logger.info(">>>>>>>>>>>>>>>>>>>>receiptOrderAutoComment is end ");
+
+    }
+
+    public long getDateBetween(Date begin, Date end) {
+        SimpleDateFormat dfs = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+        long between = (end.getTime() - begin.getTime()) / 1000;
+
+        long min = between / 60;
+
+        return min;
+    }
+
+    public static void main(String[] args) {
+
+        SimpleDateFormat dfs = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+        long between = (new Date().getTime() - DateUtils.strToDate("2018-11-16 09:30:12").getTime()) / 1000;
+
+        long min = between / 60;
+        System.out.println(min);
+        //        Calendar calendar = Calendar.getInstance();
+        //        calendar.add(Calendar.DAY_OF_MONTH, 3);
+        //
+        //        long time = (calendar.getTime().getTime() - System.currentTimeMillis()) / 1000;
+        //        System.out.println(calendar.getTime().getTime());
+        //        System.out.println(System.currentTimeMillis());
+        //        long hour = time / 3600;
+        //        long minite = time / 60 % 60;
+        //        long second = (time - hour * 3600 - minite * 60);
+        //
+        //        String body = hour + "时" + minite + "分" + second + "秒";
+        //        System.out.println(body);
+
+        long currentTime = System.currentTimeMillis() + 2 * 60 * 60 * 1000;
+        Date date = new Date(currentTime);
+        DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        String nowTime = "";
+        nowTime = df.format(date);
+        System.out.println(nowTime);
+
+        Date successTime = DateUtils.strToDate("2018-11-02 14:57:12.0");
+        System.out.println(successTime);
+    }
+}

kmall-schedule/src/main/java/com/kmall/schedule/service/ScheduleJobLogService.java

@@ -0,0 +1,37 @@
+package com.kmall.schedule.service;
+
+import com.kmall.schedule.entity.ScheduleJobLogEntity;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 定时任务日志
+ *
+ * @author Scott
+ * @email
+ * @date 2016年12月1日 下午10:34:48
+ */
+public interface ScheduleJobLogService {
+
+    /**
+     * 根据ID，查询定时任务日志
+     */
+    ScheduleJobLogEntity queryObject(Long jobId);
+
+    /**
+     * 查询定时任务日志列表
+     */
+    List<ScheduleJobLogEntity> queryList(Map<String, Object> map);
+
+    /**
+     * 查询总数
+     */
+    int queryTotal(Map<String, Object> map);
+
+    /**
+     * 保存定时任务日志
+     */
+    void save(ScheduleJobLogEntity log);
+
+}

kmall-schedule/src/main/java/com/kmall/schedule/service/ScheduleJobService.java

@@ -0,0 +1,66 @@
+package com.kmall.schedule.service;
+
+import com.kmall.schedule.entity.ScheduleJobEntity;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 定时任务
+ *
+ * @author Scott
+ * @email
+ * @date 2016年11月28日 上午9:55:32
+ */
+public interface ScheduleJobService {
+
+    /**
+     * 根据ID，查询定时任务
+     */
+    ScheduleJobEntity queryObject(Long jobId);
+
+    /**
+     * 查询定时任务列表
+     */
+    List<ScheduleJobEntity> queryList(Map<String, Object> map);
+
+    /**
+     * 查询总数
+     */
+    int queryTotal(Map<String, Object> map);
+
+    /**
+     * 保存定时任务
+     */
+    void save(ScheduleJobEntity scheduleJob);
+
+    /**
+     * 更新定时任务
+     */
+    void update(ScheduleJobEntity scheduleJob);
+
+    /**
+     * 批量删除定时任务
+     */
+    void deleteBatch(Long[] jobIds);
+
+    /**
+     * 批量更新定时任务状态
+     */
+    int updateBatch(Long[] jobIds, int status);
+
+    /**
+     * 立即执行
+     */
+    void run(Long[] jobIds);
+
+    /**
+     * 暂停运行
+     */
+    void pause(Long[] jobIds);
+
+    /**
+     * 恢复运行
+     */
+    void resume(Long[] jobIds);
+}

kmall-schedule/src/main/java/com/kmall/schedule/service/impl/ScheduleJobLogServiceImpl.java

@@ -0,0 +1,37 @@
+package com.kmall.schedule.service.impl;
+
+import com.kmall.schedule.dao.ScheduleJobLogDao;
+import com.kmall.schedule.entity.ScheduleJobLogEntity;
+import com.kmall.schedule.service.ScheduleJobLogService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+@Service("scheduleJobLogService")
+public class ScheduleJobLogServiceImpl implements ScheduleJobLogService {
+	@Autowired
+	private ScheduleJobLogDao scheduleJobLogDao;
+	
+	@Override
+	public ScheduleJobLogEntity queryObject(Long jobId) {
+		return scheduleJobLogDao.queryObject(jobId);
+	}
+
+	@Override
+	public List<ScheduleJobLogEntity> queryList(Map<String, Object> map) {
+		return scheduleJobLogDao.queryList(map);
+	}
+
+	@Override
+	public int queryTotal(Map<String, Object> map) {
+		return scheduleJobLogDao.queryTotal(map);
+	}
+
+	@Override
+	public void save(ScheduleJobLogEntity log) {
+		scheduleJobLogDao.save(log);
+	}
+
+}

kmall-schedule/src/main/java/com/kmall/schedule/service/impl/ScheduleJobServiceImpl.java

@@ -0,0 +1,124 @@
+package com.kmall.schedule.service.impl;
+
+import com.kmall.schedule.dao.ScheduleJobDao;
+import com.kmall.schedule.entity.ScheduleJobEntity;
+import com.kmall.schedule.service.ScheduleJobService;
+import com.kmall.common.utils.Constant.ScheduleStatus;
+import com.kmall.schedule.utils.ScheduleUtils;
+import org.quartz.CronTrigger;
+import org.quartz.Scheduler;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.PostConstruct;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service("scheduleJobService")
+public class ScheduleJobServiceImpl implements ScheduleJobService {
+	@Autowired
+    private Scheduler scheduler;
+	@Autowired
+	private ScheduleJobDao schedulerJobDao;
+	
+	/**
+	 * 项目启动时，初始化定时器
+	 */
+	@PostConstruct
+	public void init(){
+		List<ScheduleJobEntity> scheduleJobList = schedulerJobDao.queryList(new HashMap<String, Object>());
+		for(ScheduleJobEntity scheduleJob : scheduleJobList){
+			CronTrigger cronTrigger = ScheduleUtils.getCronTrigger(scheduler, scheduleJob.getJobId());
+            //如果不存在，则创建
+            if(cronTrigger == null) {
+                ScheduleUtils.createScheduleJob(scheduler, scheduleJob);
+            }else {
+                ScheduleUtils.updateScheduleJob(scheduler, scheduleJob);
+            }
+		}
+	}
+	
+	@Override
+	public ScheduleJobEntity queryObject(Long jobId) {
+		return schedulerJobDao.queryObject(jobId);
+	}
+
+	@Override
+	public List<ScheduleJobEntity> queryList(Map<String, Object> map) {
+		return schedulerJobDao.queryList(map);
+	}
+
+	@Override
+	public int queryTotal(Map<String, Object> map) {
+		return schedulerJobDao.queryTotal(map);
+	}
+
+	@Override
+	@Transactional
+	public void save(ScheduleJobEntity scheduleJob) {
+		scheduleJob.setCreateTime(new Date());
+		scheduleJob.setStatus(ScheduleStatus.NORMAL.getValue());
+        schedulerJobDao.save(scheduleJob);
+        
+        ScheduleUtils.createScheduleJob(scheduler, scheduleJob);
+    }
+	
+	@Override
+	@Transactional
+	public void update(ScheduleJobEntity scheduleJob) {
+        ScheduleUtils.updateScheduleJob(scheduler, scheduleJob);
+                
+        schedulerJobDao.update(scheduleJob);
+    }
+
+	@Override
+	@Transactional
+    public void deleteBatch(Long[] jobIds) {
+    	for(Long jobId : jobIds){
+    		ScheduleUtils.deleteScheduleJob(scheduler, jobId);
+    	}
+    	
+    	//删除数据
+    	schedulerJobDao.deleteBatch(jobIds);
+	}
+
+	@Override
+    public int updateBatch(Long[] jobIds, int status){
+    	Map<String, Object> map = new HashMap<>();
+    	map.put("list", jobIds);
+    	map.put("status", status);
+    	return schedulerJobDao.updateBatch(map);
+    }
+    
+	@Override
+	@Transactional
+    public void run(Long[] jobIds) {
+    	for(Long jobId : jobIds){
+    		ScheduleUtils.run(scheduler, queryObject(jobId));
+    	}
+    }
+
+	@Override
+	@Transactional
+    public void pause(Long[] jobIds) {
+        for(Long jobId : jobIds){
+    		ScheduleUtils.pauseJob(scheduler, jobId);
+    	}
+        
+    	updateBatch(jobIds, ScheduleStatus.PAUSE.getValue());
+    }
+
+	@Override
+	@Transactional
+    public void resume(Long[] jobIds) {
+    	for(Long jobId : jobIds){
+    		ScheduleUtils.resumeJob(scheduler, jobId);
+    	}
+
+    	updateBatch(jobIds, ScheduleStatus.NORMAL.getValue());
+    }
+    
+}

kmall-schedule/src/main/java/com/kmall/schedule/utils/ScheduleJob.java

@@ -0,0 +1,80 @@
+package com.kmall.schedule.utils;
+
+import com.kmall.common.utils.SpringContextUtils;
+import com.kmall.schedule.entity.ScheduleJobEntity;
+import com.kmall.schedule.entity.ScheduleJobLogEntity;
+import com.kmall.schedule.service.ScheduleJobLogService;
+import org.apache.commons.lang.StringUtils;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+
+import java.util.Date;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+
+/**
+ * 定时任务
+ *
+ * @author Scott
+ * @email
+ * @date 2016年11月30日 下午12:44:21
+ */
+public class ScheduleJob extends QuartzJobBean {
+    private Logger logger = LoggerFactory.getLogger(getClass());
+    private ExecutorService service = Executors.newSingleThreadExecutor();
+
+    @Override
+    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
+        ScheduleJobEntity scheduleJob = (ScheduleJobEntity) context.getMergedJobDataMap()
+                .get(ScheduleJobEntity.JOB_PARAM_KEY);
+
+        //获取spring bean
+        ScheduleJobLogService scheduleJobLogService = (ScheduleJobLogService) SpringContextUtils.getBean("scheduleJobLogService");
+
+        //数据库保存执行记录
+        ScheduleJobLogEntity log = new ScheduleJobLogEntity();
+        log.setJobId(scheduleJob.getJobId());
+        log.setBeanName(scheduleJob.getBeanName());
+        log.setMethodName(scheduleJob.getMethodName());
+        log.setParams(scheduleJob.getParams());
+        log.setCreateTime(new Date());
+
+        //任务开始时间
+        long startTime = System.currentTimeMillis();
+
+        try {
+            //执行任务
+            logger.info("任务准备执行，任务ID：" + scheduleJob.getJobId());
+            ScheduleRunnable task = new ScheduleRunnable(scheduleJob.getBeanName(),
+                    scheduleJob.getMethodName(), scheduleJob.getParams());
+            Future<?> future = service.submit(task);
+
+            future.get();
+
+            //任务执行总时长
+            long times = System.currentTimeMillis() - startTime;
+            log.setTimes((int) times);
+            //任务状态    0：成功    1：失败
+            log.setStatus(0);
+
+            logger.info("任务执行完毕，任务ID：" + scheduleJob.getJobId() + "  总共耗时：" + times + "毫秒");
+        } catch (Exception e) {
+            logger.error("任务执行失败，任务ID：" + scheduleJob.getJobId(), e);
+
+            //任务执行总时长
+            long times = System.currentTimeMillis() - startTime;
+            log.setTimes((int) times);
+
+            //任务状态    0：成功    1：失败
+            log.setStatus(1);
+            log.setError(StringUtils.substring(e.toString(), 0, 2000));
+        } finally {
+            scheduleJobLogService.save(log);
+        }
+    }
+}

kmall-schedule/src/main/java/com/kmall/schedule/utils/ScheduleRunnable.java

@@ -0,0 +1,47 @@
+package com.kmall.schedule.utils;
+
+import com.kmall.common.utils.RRException;
+import com.kmall.common.utils.SpringContextUtils;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.util.ReflectionUtils;
+
+import java.lang.reflect.Method;
+
+/**
+ * 执行定时任务
+ *
+ * @author Scott
+ * @email
+ * @date 2016年11月30日 下午12:49:33
+ */
+public class ScheduleRunnable implements Runnable {
+    private Object target;
+    private Method method;
+    private String params;
+
+    public ScheduleRunnable(String beanName, String methodName, String params) throws NoSuchMethodException, SecurityException {
+        this.target = SpringContextUtils.getBean(beanName);
+        this.params = params;
+
+        if (StringUtils.isNotBlank(params)) {
+            this.method = target.getClass().getDeclaredMethod(methodName, String.class);
+        } else {
+            this.method = target.getClass().getDeclaredMethod(methodName);
+        }
+    }
+
+    @Override
+    public void run() {
+        try {
+            ReflectionUtils.makeAccessible(method);
+            if (StringUtils.isNotBlank(params)) {
+                method.invoke(target, params);
+            } else {
+                method.invoke(target);
+            }
+        } catch (Exception e) {
+            throw new RRException("执行定时任务失败", e);
+        }
+    }
+
+}

kmall-schedule/src/main/java/com/kmall/schedule/utils/ScheduleUtils.java

@@ -0,0 +1,150 @@
+package com.kmall.schedule.utils;
+
+import com.kmall.common.utils.RRException;
+import com.kmall.schedule.entity.ScheduleJobEntity;
+import com.kmall.common.utils.Constant.ScheduleStatus;
+import org.quartz.*;
+
+/**
+ * 定时任务工具类
+ *
+ * @author Scott
+ * @email
+ * @date 2016年11月30日 下午12:44:59
+ */
+public class ScheduleUtils {
+    private final static String JOB_NAME = "TASK_";
+
+    /**
+     * 获取触发器key
+     */
+    public static TriggerKey getTriggerKey(Long jobId) {
+        return TriggerKey.triggerKey(JOB_NAME + jobId);
+    }
+
+    /**
+     * 获取jobKey
+     */
+    public static JobKey getJobKey(Long jobId) {
+        return JobKey.jobKey(JOB_NAME + jobId);
+    }
+
+    /**
+     * 获取表达式触发器
+     */
+    public static CronTrigger getCronTrigger(Scheduler scheduler, Long jobId) {
+        try {
+            return (CronTrigger) scheduler.getTrigger(getTriggerKey(jobId));
+        } catch (SchedulerException e) {
+            throw new RRException("获取定时任务CronTrigger出现异常", e);
+        }
+    }
+
+    /**
+     * 创建定时任务
+     */
+    public static void createScheduleJob(Scheduler scheduler, ScheduleJobEntity scheduleJob) {
+        try {
+            //构建job信息
+            JobDetail jobDetail = JobBuilder.newJob(ScheduleJob.class).withIdentity(getJobKey(scheduleJob.getJobId())).build();
+
+            //表达式调度构建器
+            CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression())
+                    .withMisfireHandlingInstructionDoNothing();
+
+            //按新的cronExpression表达式构建一个新的trigger
+            CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(getTriggerKey(scheduleJob.getJobId())).withSchedule(scheduleBuilder).build();
+
+            //放入参数，运行时的方法可以获取
+            jobDetail.getJobDataMap().put(ScheduleJobEntity.JOB_PARAM_KEY, scheduleJob);
+
+            scheduler.scheduleJob(jobDetail, trigger);
+
+            //暂停任务
+            if (scheduleJob.getStatus() == ScheduleStatus.PAUSE.getValue()) {
+                pauseJob(scheduler, scheduleJob.getJobId());
+            }
+        } catch (SchedulerException e) {
+            throw new RRException("创建定时任务失败", e);
+        }
+    }
+
+    /**
+     * 更新定时任务
+     */
+    public static void updateScheduleJob(Scheduler scheduler, ScheduleJobEntity scheduleJob) {
+        try {
+            TriggerKey triggerKey = getTriggerKey(scheduleJob.getJobId());
+
+            //表达式调度构建器
+            CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression())
+                    .withMisfireHandlingInstructionDoNothing();
+
+            CronTrigger trigger = getCronTrigger(scheduler, scheduleJob.getJobId());
+
+            //按新的cronExpression表达式重新构建trigger
+            trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
+
+            //参数
+            trigger.getJobDataMap().put(ScheduleJobEntity.JOB_PARAM_KEY, scheduleJob);
+
+            scheduler.rescheduleJob(triggerKey, trigger);
+
+            //暂停任务
+            if (scheduleJob.getStatus() == ScheduleStatus.PAUSE.getValue()) {
+                pauseJob(scheduler, scheduleJob.getJobId());
+            }
+
+        } catch (SchedulerException e) {
+            throw new RRException("更新定时任务失败", e);
+        }
+    }
+
+    /**
+     * 立即执行任务
+     */
+    public static void run(Scheduler scheduler, ScheduleJobEntity scheduleJob) {
+        try {
+            //参数
+            JobDataMap dataMap = new JobDataMap();
+            dataMap.put(ScheduleJobEntity.JOB_PARAM_KEY, scheduleJob);
+
+            scheduler.triggerJob(getJobKey(scheduleJob.getJobId()), dataMap);
+        } catch (SchedulerException e) {
+            throw new RRException("立即执行定时任务失败", e);
+        }
+    }
+
+    /**
+     * 暂停任务
+     */
+    public static void pauseJob(Scheduler scheduler, Long jobId) {
+        try {
+            scheduler.pauseJob(getJobKey(jobId));
+        } catch (SchedulerException e) {
+            throw new RRException("暂停定时任务失败", e);
+        }
+    }
+
+    /**
+     * 恢复任务
+     */
+    public static void resumeJob(Scheduler scheduler, Long jobId) {
+        try {
+            scheduler.resumeJob(getJobKey(jobId));
+        } catch (SchedulerException e) {
+            throw new RRException("暂停定时任务失败", e);
+        }
+    }
+
+    /**
+     * 删除定时任务
+     */
+    public static void deleteScheduleJob(Scheduler scheduler, Long jobId) {
+        try {
+            scheduler.deleteJob(getJobKey(jobId));
+        } catch (SchedulerException e) {
+            throw new RRException("删除定时任务失败", e);
+        }
+    }
+}

kmall-schedule/src/main/resources/kmall-scheduler.xml

@@ -0,0 +1,56 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:context="http://www.springframework.org/schema/context"
+       xmlns:task="http://www.springframework.org/schema/task"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+        http://www.springframework.org/schema/beans/spring-beans-4.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd">
+
+    <context:annotation-config/>
+
+    <!--上pring扫描注解的配置-->
+    <!--<context:component-scan base-package="com.kmall.schedule.quartz"/>-->
+    <!--开启这个配置，spring才能识别@Scheduled注解   -->
+    <!--<task:annotation-driven scheduler="qbScheduler" mode="proxy"/>-->
+    <!--<task:scheduler id="qbScheduler" pool-size="10"/>-->
+
+
+    <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
+        <property name="dataSource" ref="dataSource" />
+        <property name="quartzProperties">
+            <props>
+                <prop key="org.quartz.scheduler.instanceName">PlatformScheduler</prop>
+                <prop key="org.quartz.scheduler.instanceId">AUTO</prop>
+                <!-- 线程池配置 -->
+                <prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>
+                <prop key="org.quartz.threadPool.threadCount">20</prop>
+                <prop key="org.quartz.threadPool.threadPriority">5</prop>
+                <!-- JobStore 配置 -->
+                <prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop>
+                <!-- 集群配置 -->
+                <prop key="org.quartz.jobStore.isClustered">true</prop>
+                <prop key="org.quartz.jobStore.clusterCheckinInterval">15000</prop>
+                <prop key="org.quartz.jobStore.maxMisfiresToHandleAtATime">1</prop>
+
+                <prop key="org.quartz.jobStore.misfireThreshold">12000</prop>
+                <!-- 表前缀 -->
+                <prop key="org.quartz.jobStore.tablePrefix">QRTZ_</prop>
+            </props>
+        </property>
+
+        <property name="schedulerName" value="PlatformScheduler" />
+
+        <!--延时启动 -->
+        <property name="startupDelay" value="30" />
+
+        <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />
+
+        <!--可选，QuartzScheduler 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了 -->
+        <property name="overwriteExistingJobs" value="true" />
+
+        <!-- 设置自动启动   默认为true -->
+        <property name="autoStartup" value="true" />
+
+    </bean>
+
+</beans>

kmall-schedule/src/main/resources/logback.xml

@@ -0,0 +1,222 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+scan：当此属性设置为true时，配置文件如果发生改变，将会被重新加载，默认值为true。
+scanPeriod：设置监测配置文件是否有修改的时间间隔，如果没有给出时间单位，默认单位是毫秒当scan为true时，此属性生效。默认的时间间隔为1分钟。
+debug：当此属性设置为true时，将打印出logback内部日志信息，实时查看logback运行状态。默认值为false。
+-->
+<configuration scan="false" scanPeriod="60 seconds" debug="false">
+
+    <property name="LOG_HOME" value="/data/logs/kmall-pt-global/kmall-schedule/"/>
+    <!-- 定义日志的根目录 -->
+    <property name="TRACE_DIR" value="trace" />
+    <property name="DEBUG_DIR" value="debug" />
+    <property name="INFO_DIR" value="info" />
+    <property name="WARN_DIR" value="warn" />
+    <property name="ERROR_DIR" value="error" />
+    <!-- 定义日志文件名称 -->
+    <property name="TRACE_FILE_NAME" value="kmall-schedule-trace"></property>
+    <property name="DEBUG_FILE_NAME" value="kmall-schedule-debug"></property>
+    <property name="INFO_FILE_NAME" value="kmall-schedule-info"></property>
+    <property name="WARN_FILE_NAME" value="kmall-schedule-warn"></property>
+    <property name="ERROR_FILE_NAME" value="kmall-schedule-error"></property>
+
+    <!-- 定义日志级别颜色 -->
+    <!-- 控制台显示 -->
+    <property name="STD_CONSOLE_LOG_PATTERN"
+              value="%d{yyyy-MM-dd HH:mm:ss.SSS}[%yellow(%thread)]-[%highlight(%-5level)][%green(%logger{70}):%cyan(%line)] - %msg%n"/>
+
+    <!-- 日志文件打印 -->
+    <property name="CONSOLE_LOG_PATTERN"
+              value="%d{yyyy-MM-dd HH:mm:ss.SSS}[%thread]-[%-5level][%logger{70}:%line] - %msg%n"/>
+
+    <!-- ConsoleAppender 控制台输出 appender -->
+    <appender name="stdoutAppender" class="ch.qos.logback.core.ConsoleAppender">
+        <!--
+        日志输出格式：%d表示日期时间，%thread表示线程名，%-5level：级别从左显示5个字符宽度
+        %logger{70} 表示logger名字最长50个字符，否则按照句点分割。 %msg：日志消息，%n是换行符
+        -->
+        <encoder>
+            <pattern>${STD_CONSOLE_LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+
+
+    <!-- TRACE 日志 appender  -->
+    <appender name="traceAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <!-- 指定日志文件的名称 -->
+        <file>${LOG_HOME}/${TRACE_DIR}/${TRACE_FILE_NAME}.log</file>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_HOME}/${TRACE_DIR}/${TRACE_FILE_NAME}-%d{yyyy-MM-dd}-%i.log</fileNamePattern>
+            <MaxHistory>365</MaxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>10MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <encoder>
+            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
+        </encoder>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>TRACE</level>
+            <!--<onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>-->
+        </filter>
+    </appender>
+
+
+    <!-- DEBUG 日志 appender  -->
+    <appender name="debugAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <!-- 指定日志文件的名称 -->
+        <file>${LOG_HOME}/${DEBUG_DIR}/${DEBUG_FILE_NAME}.log</file>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_HOME}/${DEBUG_DIR}/${DEBUG_FILE_NAME}-%d{yyyy-MM-dd}-%i.log</fileNamePattern>
+            <MaxHistory>365</MaxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>10MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <encoder>
+            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
+        </encoder>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>DEBUG</level>
+            <!--<onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>-->
+        </filter>
+    </appender>
+
+
+    <!-- phrase 日志 appender  -->
+    <appender name="infoAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <!-- 指定日志文件的名称 -->
+        <file>${LOG_HOME}/${INFO_DIR}/${INFO_FILE_NAME}.log</file>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_HOME}/${INFO_DIR}/${INFO_FILE_NAME}-%d{yyyy-MM-dd}-%i.log</fileNamePattern>
+            <MaxHistory>365</MaxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>10MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <encoder>
+            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
+        </encoder>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>INFO</level>
+            <!--<onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>-->
+        </filter>
+    </appender>
+
+
+    <!-- WARN 日志 appender  -->
+    <appender name="warnAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <!-- 指定日志文件的名称 -->
+        <file>${LOG_HOME}/${WARN_DIR}/${WARN_FILE_NAME}.log</file>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_HOME}/${WARN_DIR}/${WARN_FILE_NAME}-%d{yyyy-MM-dd}-%i.log</fileNamePattern>
+            <MaxHistory>365</MaxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>10MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <encoder>
+            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
+        </encoder>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>WARN</level>
+            <!--<onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>-->
+        </filter>
+    </appender>
+
+
+    <!-- ERROR 日志 appender  -->
+    <appender name="errorAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <!-- 指定日志文件的名称 -->
+        <file>${LOG_HOME}/${ERROR_DIR}/${ERROR_FILE_NAME}.log</file>
+        <!--
+        当发生滚动时，决定 RollingFileAppender 的行为，涉及文件移动和重命名
+        TimeBasedRollingPolicy： 最常用的滚动策略，它根据时间来制定滚动策略，既负责滚动也负责出发滚动。
+        -->
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!--
+            滚动时产生的文件的存放位置及文件名称 %d{yyyy-MM-dd}：按天进行日志滚动
+            %i：当文件大小超过maxFileSize时，按照i进行文件滚动
+            -->
+            <fileNamePattern>${LOG_HOME}/${ERROR_DIR}/${ERROR_FILE_NAME}-%d{yyyy-MM-dd}-%i.log</fileNamePattern>
+            <!--
+            可选节点，控制保留的归档文件的最大数量，超出数量就删除旧文件。假设设置每天滚动，
+            且maxHistory是365，则只保存最近365天的文件，删除之前的旧文件。注意，删除旧文件是，
+            那些为了归档而创建的目录也会被删除。
+            -->
+            <MaxHistory>365</MaxHistory>
+            <!--
+            当日志文件超过maxFileSize指定的大小是，根据上面提到的%i进行日志文件滚动 注意此处配置SizeBasedTriggeringPolicy是无法实现按文件大小进行滚动的，必须配置timeBasedFileNamingAndTriggeringPolicy
+            -->
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>10MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <!--
+        日志输出格式：%d表示日期时间，%thread表示线程名，%-5level：级别从左显示5个字符宽度 %logger{70} 表示logger名字最长50个字符，否则按照句点分割。 %msg：日志消息，%n是换行符
+        -->
+        <encoder>
+            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
+        </encoder>
+        <!--
+        过滤器返回枚举：DENY，NEUTRAL，ACCEPT。
+        返回DENY，日志将立即被抛弃不再经过其他过滤器；返回NEUTRAL，有序列表里的下个过滤器过接着处理日志；返回ACCEPT，日志会被立即处理不再经过剩余过滤器。
+        LevelFilter： 级别过滤器，根据日志级别进行过滤。如果日志级别等于配置级别，过滤器会根据onMath 和 onMismatch接收或拒绝日志。节点：level，onMatch，onMismatch
+        -->
+        <filter class="ch.qos.logback.classic.filter.LevelFilter"><!-- 只打印错误日志 -->
+            <!-- 设置过滤级别 -->
+            <level>ERROR</level>
+            <!-- 配置符合过滤条件的操作
+            <onMatch>ACCEPT</onMatch>
+            &lt;!&ndash; 配置不符合过滤条件的操作 &ndash;&gt;
+            <onMismatch>DENY</onMismatch>-->
+        </filter>
+    </appender>
+
+
+    <!--
+    logger主要用于存放日志对象，也可以定义日志类型、级别
+    name：表示匹配的logger类型前缀，也就是包的前半部分
+    level：要记录的日志级别，大小写无关，包括 TRACE，DEBUG，INFO，WARN，ERROR，ALL 和 OFF。
+    additivity：是否向上级loger传递打印信息。默认是true。 作用在于children-logger是否向上级root-logger配置的appender传递打印信息，false：不传递，true：传递
+    -->
+    <!--
+    没设置level，继承他的上级<root>的日志级别；
+    没有设置additivity，默认为true，将此loger的打印信息向上级<root>传递；
+    没有设置appender，此loger本身不打印任何信息；
+    子<logger>向<root>传递信息后，日志level 完全由子级别的level 决定；
+    -->
+
+    <logger name="org.apache" level="ERROR"/>
+    <logger name="org.apache.shiro" level="DEBUG"/>
+    <logger name="org.mybatis" level="DEBUG"/>
+    <logger name="org.hibernate" level="WARN"/>
+    <logger name="org.springframework" level="INFO"/>
+    <logger name="org.thymeleaf" level="INFO"/>
+    <logger name="com.zaxxer.hikari" level="ERROR" additivity="false">
+        <appender-ref ref="stdoutAppender" />
+        <appender-ref ref="errorAppender" />
+    </logger>
+    <logger name="org.apache.shiro" level="DEBUG" additivity="false">
+        <appender-ref ref="stdoutAppender" />
+        <appender-ref ref="traceAppender" />
+    </logger>
+    <logger name="com.artoro.biz" level="DEBUG"/>
+
+    <!--
+    root与logger是父子关系，没有特别定义则默认为root，任何一个类只会和一个logger对应，
+    要么是定义的logger，要么是root，判断的关键在于找到这个logger，然后判断这个logger的level和appender。
+    -->
+    <root level="DEBUG" >
+        <appender-ref ref="stdoutAppender" />
+        <!--<appender-ref ref="traceAppender" />-->
+        <appender-ref ref="debugAppender" />
+        <!--<appender-ref ref="infoAppender" />
+        <appender-ref ref="warnAppender" />
+        <appender-ref ref="errorAppender" />-->
+    </root>
+</configuration>

kmall-schedule/src/main/resources/mybatis/mapper/OrderWXPayRecordMapper.xml

@@ -0,0 +1,46 @@
+<?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.kmall.schedule.dao.OrderWXPayRecordMapper">
+    <update id="update" parameterType="map">
+        update mall_order_wxpay_record
+        <set>
+            <if test="return_code != null">`return_code` = #{return_code}, </if>
+            <if test="return_msg != null">`return_msg` = #{return_msg}, </if>
+            <if test="result_code != null">`result_code` = #{result_code}, </if>
+            <if test="err_code != null">`err_code` = #{err_code}, </if>
+            <if test="err_code_des != null">`err_code_des` = #{err_code_des}, </if>
+            <if test="openid != null">`openid` = #{openid}, </if>
+            <if test="is_subscribe != null">`is_subscribe` = #{is_subscribe}, </if>
+            <if test="trade_type != null">`trade_type` = #{trade_type}, </if>
+            <if test="fee_type != null">`fee_type` = #{fee_type}, </if>
+            <if test="total_fee != null">`total_fee` = #{total_fee}, </if>
+            <if test="transaction_id != null">`transaction_id` = #{transaction_id}, </if>
+            <if test="out_trade_no != null">`out_trade_no` = #{out_trade_no}, </if>
+            <if test="out_trade_no_wx != null">`out_trade_no_wx` = #{out_trade_no_wx}, </if>
+            <if test="attach != null">`attach` = #{attach}, </if>
+            <if test="time_end != null">`time_end` = #{time_end}, </if>
+            <if test="trade_state != null">`trade_state` = #{trade_state}, </if>
+            <if test="creater_sn != null">`creater_sn` = #{creater_sn}, </if>
+            <if test="create_time != null">`create_time` = #{create_time}, </if>
+            <if test="moder_sn != null">`moder_sn` = #{moder_sn}, </if>
+            <if test="mod_time != null">`mod_time` = #{mod_time}</if>
+        </set>
+        where id = #{id}
+    </update>
+
+    <select id="queryRecordList" resultType="map">
+        SELECT id,out_trade_no,out_trade_no_wx
+        FROM mall_order_wxpay_record
+        where trade_state in
+        <foreach collection="list" item="listItem" open="(" separator="," close=")">
+            #{listItem}
+        </foreach>
+    </select>
+
+    <select id="getRecordsByOutTradeNo" resultType="map">
+        SELECT id,trade_state,out_trade_no_wx
+        FROM mall_order_wxpay_record
+        where out_trade_no = #{out_trade_no}
+    </select>
+</mapper>

kmall-schedule/src/main/resources/mybatis/mapper/QzGroupMapper.xml

@@ -0,0 +1,57 @@
+<?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.kmall.schedule.dao.QzGroupMapper">
+    <select id="queryRemindGroupList" resultType="map">
+        SELECT
+        a.id,
+        a.open_time,
+        a.group_id,
+        a.user_id,
+        u.weixin_openid AS open_id,
+        a.end_time,
+        a.attend_num,
+        g.`name`,
+        detail.`form_id`,
+        b.retail_min_price
+        FROM
+        mall_goods_group_open a
+        LEFT JOIN mall_goods_group b ON a.group_id = b.id
+        LEFT JOIN mall_goods g ON g.id = b.goods_id
+        LEFT JOIN mall_user u ON a.user_id = u.id
+        LEFT JOIN mall_goods_group_open_detail detail ON detail.open_id = a.id
+        WHERE detail.`form_id` is not null and a.attend_status = 2
+        AND a.end_time > date_add(now(), INTERVAL 1 DAY)
+        AND a.end_time <![CDATA[ <  ]]>  date_add(now(), INTERVAL 2 DAY)
+    </select>
+
+
+    <select id="queryPastGroupList" resultType="map">
+        SELECT
+        a.id,
+        a.group_id,
+        a.user_id,
+        u.weixin_openid AS open_id,
+        a.attend_num,
+        g.`name`,
+        detail.`form_id`,
+        b.retail_min_price,
+        b.min_open_group
+        FROM
+        mall_goods_group_open a
+        LEFT JOIN mall_goods_group b ON a.group_id = b.id
+        LEFT JOIN mall_goods g ON g.id = b.goods_id
+        LEFT JOIN mall_user u ON a.user_id = u.id
+        LEFT JOIN mall_goods_group_open_detail detail ON detail.open_id = a.id
+        WHERE detail.`form_id` is not null and a.attend_status = 2 and a.attend_num <![CDATA[ <  ]]> b.min_open_group
+        AND a.end_time > now()
+    </select>
+
+    <update id="updatePastGroup" parameterType="map">
+        update mall_goods_group_open
+        <set>
+            `attend_status` = 3
+        </set>
+        where id = #{id}
+    </update>
+</mapper>

kmall-schedule/src/main/resources/mybatis/mapper/QzOrderMapper.xml

@@ -0,0 +1,271 @@
+<?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.kmall.schedule.dao.QzOrderMapper">
+    <select id="queryrderUnEvaluateList" resultType="map">
+       SELECT
+            a.id AS order_id,
+            a.order_sn,
+            c.goods_name,
+	        a.form_id,
+	        u.weixin_openid AS open_id
+        FROM
+            mall_order a
+        LEFT JOIN mall_comment b ON a.id = b.order_id
+        LEFT JOIN mall_order_goods c ON c.order_id = a.id
+        LEFT JOIN mall_user u ON a.user_id = u.id
+        WHERE
+            b.id IS NULL
+        AND a.confirm_time > date_add(now(), INTERVAL - 1 DAY)
+        AND a.confirm_time IS NOT NULL
+    </select>
+
+    <select id="queryPastOrderList" resultType="map">
+        SELECT b.product_id,b.number,c.stock_num,c.id as storeRelaId
+        FROM mall_order a
+        LEFT JOIN mall_order_goods b ON a.id = b.order_id
+        LEFT JOIN mall_product_store_rela c ON b.product_id = c.product_id
+        AND c.store_id = a.store_id
+        WHERE 1 = 1
+        AND a.add_time <![CDATA[ < ]]> DATE_ADD(now(),INTERVAL -15 MINUTE)
+        AND a.order_status in (0,100) and a.order_type = 1 AND a.is_onffline_order = 0
+    </select>
+    <update id="unpayPastUpdate">
+        UPDATE mall_order a
+        SET order_status=101,shipping_status=0,pay_status=0
+        WHERE 1 = 1
+        AND a.add_time <![CDATA[ <  ]]> DATE_ADD(now(),INTERVAL -15 MINUTE)
+        AND a.order_status = 0  and a.order_type = 1  AND a.is_onffline_order = 0
+    </update>
+
+    <update id="updateStockNum" parameterType="map">
+        update mall_product_store_rela a
+        <set>
+            <if test="stock_num != null">a.`stock_num` = #{stock_num},</if>
+        </set>
+        where a.id = #{id}
+    </update>
+
+
+    <select id="queryRefundOrderList" resultType="map">
+        select a.pay_transaction_id,a.merch_order_sn,a.order_sn,a.order_status,a.pay_status,f.out_refund_no,f.refund_id,f.order_id,f.id 'orderRefundId',a.is_onffline_order,
+        a.order_sn_wx,a.pay_flag
+        from mall_order a
+        inner join mall_order_refund f on a.id = f.order_id	where (f.out_refund_no is null or f.refund_id is null
+        or f.refund_time is null or f.wechat_refund_status_des is null) and a.order_status = '401' and f.refund_status
+        in (2,5)
+    </select>
+
+    <select id="queryPayingOrderList" resultType="map">
+		select a.pay_transaction_id,a.order_sn,a.order_status,a.pay_status,a.id 'order_id',a.merch_order_sn,date_format(a.add_time,'%Y-%m-%d %H:%i:%s') as add_time,
+        b.product_id,b.number,c.stock_num,c.id as storeRelaId,a.pay_flag,a.actual_price
+        from mall_order a
+        LEFT JOIN mall_order_goods b ON a.id = b.order_id
+        LEFT JOIN mall_product_store_rela c ON b.product_id = c.product_id
+        AND c.store_id = a.store_id  where (a.order_status in ('0','100','201') and a.pay_status in (0,1,2)) and pay_id is not null
+        and (a.pay_transaction_id = '' or a.pay_transaction_id is null or a.pay_time is null or a.pay_time = '')
+        AND a.is_onffline_order = 0 and a.pay_flag = 'wxglobalpay'
+    </select>
+
+    <select id="queryPinganPayingOrderList" resultType="map">
+		select a.pay_transaction_id,a.order_sn,a.order_status,a.pay_status,a.id 'order_id',a.merch_order_sn,date_format(a.add_time,'%Y-%m-%d %H:%i:%s') as add_time,
+        b.product_id,b.number,c.stock_num,c.id as storeRelaId,a.pay_flag
+        from mall_order a
+        LEFT JOIN mall_order_goods b ON a.id = b.order_id
+        LEFT JOIN mall_product_store_rela c ON b.product_id = c.product_id
+        AND c.store_id = a.store_id  where (a.order_status in ('0','100','201') and a.pay_status in (0,1,2)) and pay_id is not null
+        and (a.pay_transaction_id = '' or a.pay_transaction_id is null or a.pay_time is null or a.pay_time = '')
+        AND a.is_onffline_order = 0 and a.pay_flag = 'pingan'
+    </select>
+
+    <update id="updateOrderInfo" parameterType="map">
+        UPDATE mall_order a
+        <set>
+            <if test="orderStatus != null">a.order_status = #{orderStatus},</if>
+            <if test="payStatus != null">a.pay_status = #{payStatus},</if>
+            <if test="payFlag != null">a.pay_flag = #{payFlag},</if>
+            <if test="orderSnWx != null">a.order_sn_wx = #{orderSnWx},</if>
+            <if test="payTransactionId != null">a.pay_transaction_id = #{payTransactionId},</if>
+            <if test="payTime != null">a.pay_time = #{payTime},</if>
+
+            <if test="totalFee != null">a.total_fee = #{totalFee},</if>
+            <if test="feeType != null">a.fee_type = #{feeType},</if>
+            <if test="cashFee != null">a.cash_fee = #{cashFee},</if>
+            <if test="cashFeeType != null">a.cash_fee_type = #{cashFeeType},</if>
+            <if test="rate != null">a.rate = #{rate},</if>
+        </set>
+        WHERE 1 = 1
+        AND a.id = #{orderId}
+    </update>
+
+    <update id="updateOrderProcessRecord" parameterType="map">
+        UPDATE mall_order_process_record a
+        <set>
+            <if test="payTime != null">a.pay_succ_time = #{payTime}</if>
+        </set>
+        WHERE 1 = 1
+        AND a.order_sn = #{orderSn}
+    </update>
+
+    <update id="updateOrderRefund" parameterType="map">
+        UPDATE mall_order_refund a
+        <set>
+            <if test="refundId != null">a.refund_id = #{refundId},</if>
+            <if test="refundMoney != null">a.refund_money = #{refundMoney},</if>
+            <if test="refundStatus != null">a.refund_status = #{refundStatus},</if>
+            <if test="refundRecvAccout != null">a.refund_recv_accout = #{refundRecvAccout},</if>
+            <if test="refundTime != null">a.refund_time = #{refundTime},</if>
+            <if test="wechat_refund_status_des != null">a.wechat_refund_status_des = #{wechat_refund_status_des},</if>
+
+            <if test="totalFee != null">a.total_fee = #{totalFee},</if>
+            <if test="feeType != null">a.fee_type = #{feeType},</if>
+            <if test="cashFee != null">a.cash_fee = #{cashFee},</if>
+            <if test="cashFeeType != null">a.cash_fee_type = #{cashFeeType},</if>
+            <if test="refundFeeType != null">a.refund_fee_type = #{refundFeeType},</if>
+            <if test="cashRefundFee != null">a.cash_refund_fee = #{cashRefundFee},</if>
+            <if test="cashRefundFeeType != null">a.cash_refund_fee_type = #{cashRefundFeeType},</if>
+            <if test="rate != null">a.rate = #{rate},</if>
+        </set>
+        WHERE 1 = 1
+        AND a.out_refund_no = #{orderRefundId}
+    </update>
+
+    <select id="queryShipmentOrderList" resultType="map">
+        SELECT a.order_sn,a.order_status,a.pay_status,a.id 'orderId',a.merch_order_sn,date_format(r.customs_succ_time,'%Y-%m-%d %H:%i:%s') as customs_succ_time
+        FROM `mall_order` a inner join mall_order_process_record r on a.order_sn=r.order_sn where order_status='300'
+        and shipping_status ='1' and a.order_biz_type in(10,02) AND r.customs_succ_time <![CDATA[ <  ]]>  DATE_ADD(now(),INTERVAL -7 DAY)  AND a.is_onffline_order = 0
+    </select>
+    <select id="queryShipmentBondedOrderList" resultType="map">
+        SELECT a.order_sn,a.order_status,a.pay_status,a.id 'orderId',a.merch_order_sn,date_format(r.shipment_start_time,'%Y-%m-%d %H:%i:%s') as shipment_start_time
+        FROM `mall_order` a inner join mall_order_process_record r on a.order_sn=r.order_sn where order_status='300' and shipping_status ='1'
+        and a.order_biz_type in(00,11) AND r.shipment_start_time <![CDATA[ <  ]]>  DATE_ADD(now(),INTERVAL -7 DAY)  AND a.is_onffline_order = 0
+    </select>
+
+    <update id="updateShipmentOrder" parameterType="map">
+        update mall_order set order_status ='301', shipping_status='2',confirm_time=now() where id=#{orderId}
+    </update>
+
+    <select id="queryReceiptOrderList" resultType="map">
+        select o.user_id 'userId',o.id 'orderId',g.product_id'productId',g.goods_specification_name_value 'goodsSpecificationNameValue', g.goods_id 'goodsId',
+        g.goods_name 'goodsName',confirm_time FROM `mall_order` o inner join mall_order_goods g on o.id = g.order_id
+        where order_status='301' and shipping_status ='2' and comment_count=0 AND confirm_time <![CDATA[ < ]]> DATE_ADD(now(),INTERVAL -30 DAY)  AND o.is_onffline_order = 0
+    </select>
+
+    <update id="updateReceiptOrderByCommentCount">
+        update mall_order set comment_count = 1 where
+        order_status='301' and shipping_status ='2' and comment_count=0 AND confirm_time <![CDATA[ < ]]> DATE_ADD(now(),INTERVAL -30 DAY)
+    </update>
+
+    <update id="insertComment" parameterType="map">
+        insert into mall_comment(
+        `type_id`,
+        `value_id`,
+        `user_id`,
+        `order_id`,
+        `product_id`,
+        `goods_specification_name_value`,
+        `status`,
+        `content`,
+        `eval_level`,
+        `value_name`,
+        `goods_level`,
+        `create_time`,
+        `mod_time`)
+        values(
+        #{typeId},
+        #{valueId},
+        #{userId},
+        #{orderId},
+        #{productId},
+        #{goodsSpecificationNameValue},
+        #{status},
+        #{content},
+        #{evalLevel},
+        #{valueName},
+        #{goodsLevel},
+        #{createTime},
+        #{modTime})
+    </update>
+
+    <insert id="insertPinganResponseDto" parameterType="map">
+        insert into pingan_response(
+			`id`,
+			`out_no`,
+			`req_interface`,
+			`errcode`,
+			`msg`,
+			`data`,
+			`sign`,
+			`datajson`,
+			`timestamp`,
+			`create_time`,
+			`tstm`)
+		values(
+			#{id},
+			#{outNo},
+			#{reqInterface},
+			#{errcode},
+			#{msg},
+			#{data},
+			#{sign},
+			#{datajson},
+			#{timestamp},
+			#{createTime},
+			#{tstm})
+    </insert>
+
+    <select id="queryOrder" resultType="map">
+        select id,order_status
+        from mall_order
+        WHERE order_sn = #{orderSn}
+    </select>
+
+    <select id="queryWXPaySuccessRecords" resultType="map">
+        select id,out_trade_no_wx
+        from mall_order_wxpay_record
+        WHERE out_trade_no = #{orderSn} AND trade_state='SUCCESS'
+    </select>
+    <select id="getTotalActualPriceByMerchOrderSn" resultType="java.math.BigDecimal">
+        select sum(actual_price) from mall_order where merch_order_sn = #{merchOrderSn}
+    </select>
+
+    <update id="updatePayOrderByOutNo" parameterType="map">
+        update pingan_pay_order
+        <set>
+            <if test="pmtName != null">`pmt_name` = #{pmtName}, </if>
+            <if test="pmtTag != null">`pmt_tag` = #{pmtTag}, </if>
+            <if test="ordMctId != null">`ord_mct_id` = #{ordMctId}, </if>
+            <if test="ordShopId != null">`ord_currency` = #{ordShopId}, </if>
+            <if test="ordCurrency != null">`ord_shop_id` = #{ordCurrency}, </if>
+            <if test="currencySign != null">`currency_sign` = #{currencySign}, </if>
+            <if test="ordNo != null">`ord_no` = #{ordNo}, </if>
+            <if test="ordType != null">`ord_type` = #{ordType}, </if>
+            <if test="originalAmount != null">`original_amount` = #{originalAmount}, </if>
+            <if test="discountAmount != null">`discount_amount` = #{discountAmount}, </if>
+            <if test="ignoreAmount != null">`ignore_amount` = #{ignoreAmount}, </if>
+            <if test="tradeAccount != null">`trade_account` = #{tradeAccount}, </if>
+            <if test="tradeNo != null">`trade_no` = #{tradeNo}, </if>
+            <if test="tradeAmount != null">`trade_amount` = #{tradeAmount}, </if>
+            <if test="tradeQrcode != null">`trade_qrcode` = #{tradeQrcode}, </if>
+            <if test="amount != null">`amount` = #{amount}, </if>
+            <if test="tradeTime != null">`trade_time` = #{tradeTime}, </if>
+            <if test="tradePayTime != null">`trade_pay_time` = #{tradePayTime}, </if>
+            <if test="payTime != null">`pay_time` = #{payTime}, </if>
+            <if test="status != null">`status` = #{status}, </if>
+            <if test="tradeResult != null">`trade_result` = #{tradeResult}, </if>
+            <if test="jsapiPayUrl != null">`jsapi_pay_url` = #{jsapiPayUrl}, </if>
+            <if test="randStr != null">`rand_str` = #{randStr}, </if>
+            <if test="appid != null">`appId` = #{appid}, </if>
+            <if test="noncestr != null">`nonceStr` = #{noncestr}, </if>
+            <if test="signtype != null">`signType` = #{signtype}, </if>
+            <if test="prepayId != null">`prepay_id` = #{prepayId}, </if>
+            <if test="paysign != null">`paySign` = #{paysign}, </if>
+            <if test="createrSn != null">`creater_sn` = #{createrSn}, </if>
+            <if test="createTime != null">`create_time` = #{createTime}, </if>
+            <if test="moderSn != null">`moder_sn` = #{moderSn}, </if>
+            <if test="modTime != null">`mod_time` = #{modTime}, </if>
+            <if test="tstm != null">`tstm` = #{tstm}</if>
+        </set>
+        where `out_no` = #{outNo}
+    </update>
+</mapper>

kmall-schedule/src/main/resources/mybatis/mapper/ScheduleJobDao.xml

@@ -0,0 +1,86 @@
+<?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.kmall.schedule.dao.ScheduleJobDao">
+	<select id="queryObject" resultType="com.kmall.schedule.entity.ScheduleJobEntity" >
+		select * from schedule_job where job_id = #{value}
+	</select> 
+
+	<select id="queryList" resultType="com.kmall.schedule.entity.ScheduleJobEntity" >
+		select * from schedule_job
+		<where>
+			<if test="beanName != null and beanName.trim() != ''">
+				bean_name like concat('%', #{beanName}, '%') 
+			</if>
+			<if test="methodName != null and methodName.trim() != ''">
+				method_name like concat('%', #{methodName}, '%')
+			</if>
+		</where>
+		<if test="offset != null and limit != null ">
+		limit #{offset}, #{limit}
+		</if>
+	</select>
+	
+ 	<select id="queryTotal" resultType="int">
+		select count(1) from schedule_job 
+		<where>
+			<if test="beanName != null and beanName.trim() != ''">
+				bean_name like concat('%', #{beanName}, '%') 
+			</if>
+			<if test="methodName != null and methodName.trim() != ''">
+				method_name like concat('%', #{methodName}, '%')
+			</if>
+		</where>
+	</select>
+	 
+	<insert id="save" parameterType="com.kmall.schedule.entity.ScheduleJobEntity" useGeneratedKeys="true" keyProperty="jobId">
+		insert into schedule_job
+		(
+			`bean_name`, 
+			`method_name`, 
+			`params`, 
+			`cron_expression`, 
+			`status`, 
+			`remark`, 
+			`create_time`
+		)
+		values
+		(
+			#{beanName}, 
+			#{methodName}, 
+			#{params}, 
+			#{cronExpression}, 
+			#{status}, 
+			#{remark}, 
+			#{createTime}
+		)
+	</insert>
+	 
+	<update id="update" parameterType="com.kmall.schedule.entity.ScheduleJobEntity">
+		update schedule_job 
+		<set> 
+			<if test="beanName != null">`bean_name` = #{beanName}, </if>
+			<if test="methodName != null">`method_name` = #{methodName}, </if>
+			<if test="params != null">`params` = #{params}, </if>
+			<if test="cronExpression != null">`cron_expression` = #{cronExpression}, </if>
+			<if test="status != null">`status` = #{status}, </if>
+			<if test="remark != null">`remark` = #{remark}, </if>
+		</set>
+		where job_id = #{jobId}
+	</update>
+	
+	<!-- 批量更新状态 -->
+	<update id="updateBatch"> 
+		update schedule_job set status = #{status} where job_id in 
+		<foreach item="jobId" collection="list"  open="(" separator="," close=")">
+			#{jobId}
+		</foreach>
+	</update>
+	
+	<delete id="deleteBatch">
+		delete from schedule_job where job_id in 
+		<foreach item="jobId" collection="array" open="(" separator="," close=")">
+			#{jobId}
+		</foreach>
+	</delete>
+</mapper>

kmall-schedule/src/main/resources/mybatis/mapper/ScheduleJobLogDao.xml

@@ -0,0 +1,56 @@
+<?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.kmall.schedule.dao.ScheduleJobLogDao">
+	<select id="queryObject" resultType="com.kmall.schedule.entity.ScheduleJobLogEntity" >
+		select * from schedule_job_log where log_id = #{value}
+	</select> 
+
+	<select id="queryList" resultType="com.kmall.schedule.entity.ScheduleJobLogEntity" >
+		select * from schedule_job_log 
+		<where>
+			<if test="jobId != null and jobId != ''">
+				and job_id = #{jobId}
+			</if>
+		</where>
+		order by log_id desc 
+		<if test="offset != null and limit != null ">
+		limit #{offset}, #{limit}
+		</if>
+	</select>
+	
+ 	<select id="queryTotal" resultType="int">
+		select count(1) from schedule_job_log 
+		<where>
+			<if test="jobId != null and jobId != ''">
+				and job_id = #{jobId}
+			</if>
+		</where>
+	</select>
+	 
+	<insert id="save" parameterType="com.kmall.schedule.entity.ScheduleJobLogEntity">
+		insert into schedule_job_log
+		(
+			`job_id`, 
+			`bean_name`, 
+			`method_name`, 
+			`params`, 
+			`status`, 
+			`error`, 
+			`times`, 
+			`create_time`
+		)
+		values
+		(
+			#{jobId}, 
+			#{beanName}, 
+			#{methodName}, 
+			#{params}, 
+			#{status}, 
+			#{error}, 
+			#{times}, 
+			#{createTime}
+		)
+	</insert>
+	
+</mapper>