|
@@ -1,59 +1,59 @@
|
1
|
|
-
|
2
|
|
-
|
3
|
|
-
|
4
|
|
-
|
5
|
|
-
|
6
|
|
-
|
7
|
|
-
|
8
|
|
-
|
9
|
|
-
|
10
|
|
-
|
11
|
|
-
|
12
|
|
-
|
13
|
|
-
|
14
|
|
-
|
15
|
|
-
|
16
|
|
-
|
17
|
|
-
|
18
|
|
-
|
19
|
|
-
|
20
|
|
-
|
21
|
|
-
|
22
|
|
-
|
23
|
|
-
|
24
|
|
-
|
25
|
|
-
|
26
|
|
-
|
27
|
|
-
|
28
|
|
-
|
29
|
|
-
|
30
|
|
-
|
31
|
|
-
|
32
|
|
-
|
33
|
|
-
|
34
|
|
-
|
35
|
|
-
|
36
|
|
-
|
37
|
|
-
|
38
|
|
-
|
39
|
|
-
|
40
|
|
-
|
41
|
|
-
|
42
|
|
-
|
43
|
|
-
|
44
|
|
-
|
45
|
|
-
|
46
|
|
-
|
47
|
|
-
|
48
|
|
-
|
49
|
|
-
|
50
|
|
-
|
51
|
|
-
|
52
|
|
-
|
53
|
|
-
|
54
|
|
-
|
55
|
|
-
|
56
|
|
-
|
57
|
|
-
|
58
|
|
-
|
59
|
|
-
|
|
1
|
+package com.huiju.estateagents.job;
|
|
2
|
+
|
|
3
|
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
4
|
+import com.huiju.estateagents.base.BaseController;
|
|
5
|
+import com.huiju.estateagents.common.CommConstant;
|
|
6
|
+import com.huiju.estateagents.redpack.entity.TaOrgOrder;
|
|
7
|
+import com.huiju.estateagents.redpack.mapper.TaOrgOrderMapper;
|
|
8
|
+import com.huiju.estateagents.service.ITaPersonFromRecordService;
|
|
9
|
+import com.huiju.estateagents.statistic.service.ITsCustomerGenderStatisticService;
|
|
10
|
+import com.huiju.estateagents.statistic.service.ITsCustomerStatisticDailyService;
|
|
11
|
+import com.huiju.estateagents.statistic.service.ITsCustomerStatisticMonthlyService;
|
|
12
|
+import com.huiju.estateagents.statistic.service.ITsUserBehaviorStatisticService;
|
|
13
|
+import org.slf4j.Logger;
|
|
14
|
+import org.slf4j.LoggerFactory;
|
|
15
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
16
|
+import org.springframework.context.annotation.Configuration;
|
|
17
|
+import org.springframework.scheduling.annotation.EnableScheduling;
|
|
18
|
+import org.springframework.scheduling.annotation.Scheduled;
|
|
19
|
+import org.springframework.stereotype.Component;
|
|
20
|
+
|
|
21
|
+import java.time.LocalDateTime;
|
|
22
|
+
|
|
23
|
+
|
|
24
|
+ * 订单相关操作
|
|
25
|
+ */
|
|
26
|
+@Component
|
|
27
|
+@Configuration
|
|
28
|
+@EnableScheduling
|
|
29
|
+public class OrgOrderTimeJob extends BaseController {
|
|
30
|
+
|
|
31
|
+ private Logger logger = LoggerFactory.getLogger(OrgOrderTimeJob.class);
|
|
32
|
+
|
|
33
|
+ @Autowired
|
|
34
|
+ private TaOrgOrderMapper taOrgOrderMapper;
|
|
35
|
+
|
|
36
|
+
|
|
37
|
+ * 处理过期订单
|
|
38
|
+ */
|
|
39
|
+ @Scheduled(cron = "* 0/5 * * * ?")
|
|
40
|
+ private void dealExpireOrder() {
|
|
41
|
+ logger.info("处理过期订单 定时任务开始");
|
|
42
|
+
|
|
43
|
+ try {
|
|
44
|
+ TaOrgOrder taOrgOrder = new TaOrgOrder();
|
|
45
|
+ taOrgOrder.setTradingStatus(CommConstant.TRADING_STATUS_FAIL);
|
|
46
|
+
|
|
47
|
+ UpdateWrapper<TaOrgOrder> taOrgOrderUpdateWrapper = new UpdateWrapper<>();
|
|
48
|
+ taOrgOrderUpdateWrapper.eq("status", CommConstant.STATUS_NORMAL);
|
|
49
|
+ taOrgOrderUpdateWrapper.gt("expiry_date", LocalDateTime.now());
|
|
50
|
+ taOrgOrderUpdateWrapper.eq("trading_status",CommConstant.TRADING_STATUS_PROCESSING);
|
|
51
|
+ Integer result = taOrgOrderMapper.update(taOrgOrder, taOrgOrderUpdateWrapper);
|
|
52
|
+ logger.info("处理过期订单 共更新" + result + "条数据");
|
|
53
|
+ } catch (Exception e) {
|
|
54
|
+ logger.error("处理过期订单 异常", e);
|
|
55
|
+ }
|
|
56
|
+ logger.info("处理过期订单 定时任务结束");
|
|
57
|
+ }
|
|
58
|
+
|
|
59
|
+}
|