Skip to content

O
order-center-tool-2
Commit 2d4b3c01 authored by 年畅's avatar 年畅 🛀
Browse files
Options

fix

parent 3f82278a
Hide whitespace changes
Inline Side-by-side
Showing with 214 additions and 250 deletions
src/main/java/com/zm/order/tool/server/constants/ListSellerConst.java
View file @ 2d4b3c01
......@@ -16,116 +16,234 @@ public class ListSellerConst {
public static List<Long> list = new ArrayList<>();
static {
list.add(216585L);
list.add(213023L);
list.add(31918L);
list.add(214159L);
list.add(210512L);
list.add(210148L);
list.add(208418L);
list.add(215897L);
list.add(214081L);
list.add(214790L);
list.add(215081L);
list.add(215771L);
list.add(216106L);
list.add(215846L);
list.add(215366L);
list.add(215029L);
list.add(207246L);
list.add(212048L);
list.add(214556L);
list.add(215295L);
list.add(215565L);
list.add(215018L);
list.add(210313L);
list.add(220030L);
list.add(218430L);
list.add(216172L);
list.add(214465L);
list.add(207724L);
list.add(215764L);
list.add(216027L);
list.add(216153L);
list.add(215621L);
list.add(205736L);
list.add(215043L);
list.add(215864L);
list.add(206241L);
list.add(215153L);
list.add(215120L);
list.add(213130L);
list.add(210936L);
list.add(36670L);
list.add(214220L);
list.add(215067L);
list.add(209673L);
list.add(43873L);
list.add(215634L);
list.add(213006L);
list.add(215443L);
list.add(214769L);
list.add(204735L);
list.add(208227L);
list.add(202565L);
list.add(215345L);
list.add(215765L);
list.add(209091L);
list.add(215517L);
list.add(216168L);
list.add(214667L);
list.add(215161L);
list.add(215458L);
list.add(214921L);
list.add(50140L);
list.add(218534L);
list.add(215757L);
list.add(216167L);
list.add(49573L);
list.add(208514L);
list.add(206963L);
list.add(218608L);
list.add(220645L);
list.add(220643L);
list.add(220724L);
list.add(220641L);
list.add(213637L);
list.add(218430L);
list.add(216385L);
list.add(213951L);
list.add(205387L);
list.add(34639L);
list.add(206429L);
list.add(50331L);
list.add(23200L);
list.add(25666L);
list.add(204846L);
list.add(206246L);
list.add(206458L);
list.add(208369L);
list.add(209446L);
list.add(49756L);
list.add(202295L);
list.add(50405L);
list.add(40978L);
list.add(215950L);
list.add(209268L);
list.add(205302L);
list.add(210191L);
list.add(44416L);
list.add(203228L);
list.add(201242L);
list.add(219547L);
list.add(215758L);
list.add(209374L);
list.add(220642L);
list.add(208628L);
list.add(219717L);
list.add(210136L);
list.add(219842L);
list.add(209566L);
list.add(206611L);
list.add(215701L);
list.add(219990L);
list.add(219439L);
list.add(206021L);
list.add(215134L);
list.add(219939L);
list.add(215695L);
list.add(219826L);
list.add(219829L);
list.add(214802L);
list.add(216016L);
list.add(216037L);
list.add(215429L);
list.add(220305L);
list.add(208398L);
list.add(215671L);
list.add(211601L);
list.add(219837L);
list.add(220001L);
list.add(220123L);
list.add(34727L);
list.add(219210L);
list.add(215531L);
list.add(220178L);
list.add(205302L);
list.add(214843L);
list.add(40686L);
list.add(208931L);
list.add(40978L);
list.add(41447L);
list.add(203591L);
list.add(215769L);
list.add(215211L);
list.add(215828L);
list.add(219736L);
list.add(220139L);
list.add(212692L);
list.add(213101L);
list.add(219889L);
list.add(39718L);
list.add(38353L);
list.add(48685L);
list.add(220645L);
list.add(216052L);
list.add(208755L);
list.add(214710L);
list.add(215439L);
list.add(209341L);
list.add(11466L);
list.add(203788L);
list.add(41446L);
list.add(45986L);
list.add(204097L);
list.add(39718L);
list.add(203947L);
list.add(204500L);
list.add(44361L);
list.add(203286L);
list.add(214429L);
list.add(214690L);
list.add(207870L);
list.add(214319L);
list.add(50757L);
list.add(205940L);
list.add(207440L);
list.add(215607L);
list.add(210458L);
list.add(39631L);
list.add(214863L);
list.add(208258L);
list.add(36048L);
list.add(50694L);
list.add(214955L);
list.add(216186L);
list.add(40481L);
list.add(28969L);
list.add(204399L);
list.add(213865L);
list.add(205955L);
list.add(27321L);
list.add(205244L);
list.add(201912L);
list.add(208765L);
list.add(50926L);
list.add(202242L);
list.add(207207L);
list.add(206005L);
list.add(206970L);
list.add(205537L);
list.add(40686L);
list.add(209315L);
list.add(216048L);
list.add(41447L);
list.add(212850L);
list.add(209264L);
list.add(215809L);
list.add(216121L);
list.add(209618L);
list.add(43737L);
list.add(205523L);
list.add(206405L);
list.add(203997L);
list.add(202373L);
list.add(220643L);
list.add(208768L);
list.add(209836L);
list.add(214988L);
list.add(214974L);
list.add(205847L);
list.add(215020L);
list.add(214595L);
list.add(215960L);
list.add(214954L);
list.add(208893L);
list.add(218377L);
list.add(21466L);
list.add(215978L);
list.add(21349L);
list.add(208035L);
list.add(207420L);
list.add(201691L);
list.add(205268L);
list.add(215360L);
list.add(212737L);
list.add(214956L);
list.add(213699L);
list.add(215236L);
list.add(210669L);
list.add(211492L);
list.add(213753L);
list.add(215393L);
list.add(206243L);
list.add(212032L);
list.add(215491L);
list.add(209005L);
list.add(203543L);
list.add(206670L);
list.add(213289L);
list.add(220641L);
list.add(215721L);
list.add(40061L);
list.add(204338L);
list.add(204787L);
list.add(30251L);
list.add(205784L);
list.add(207915L);
list.add(211162L);
list.add(208461L);
list.add(214678L);
list.add(207372L);
list.add(215334L);
list.add(207608L);
list.add(214805L);
list.add(212989L);
list.add(216163L);
list.add(209075L);
list.add(206322L);
list.add(210061L);
list.add(210108L);
list.add(215807L);
list.add(215790L);
list.add(40583L);
list.add(201075L);
list.add(50380L);
list.add(213865L);
list.add(213852L);
list.add(215240L);
list.add(207683L);
list.add(214902L);
list.add(206674L);
list.add(209668L);
list.add(203592L);
list.add(214377L);
list.add(207831L);
list.add(204764L);
list.add(43780L);
list.add(46611L);
list.add(201438L);
list.add(210117L);
list.add(50408L);
list.add(206562L);
list.add(215143L);
list.add(212229L);
list.add(213694L);
list.add(213129L);
list.add(203716L);
list.add(211917L);
list.add(206061L);
list.add(209791L);
list.add(206234L);
list.add(209307L);
list.add(209271L);
list.add(209248L);
list.add(215734L);
list.add(209094L);
list.add(208695L);
list.add(215044L);
list.add(215280L);
list.add(208028L);
list.add(215039L);
list.add(30842L);
list.add(211077L);
list.add(45750L);
list.add(209669L);
list.add(204923L);
list.add(206286L);
list.add(217998L);
list.add(217176L);
list.add(216789L);
list.add(217984L);
}
......
src/main/java/com/zm/order/tool/server/listener/OrderConvertTask.java
View file @ 2d4b3c01
......@@ -48,156 +48,6 @@ public class OrderConvertTask {
@Autowired
private OrderRoutingRefundService refundService;
//
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute1() {
Result result = new Result();
try {
logger.info("OrderConvertTask1[start]!");
service.orderConvert();
logger.info("OrderConvertTask1[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute2() {
Result result = new Result();
try {
logger.info("OrderConvertTask2[start]!");
service2.orderConvert();
logger.info("OrderConvertTask2[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute3() {
Result result = new Result();
try {
logger.info("OrderConvertTask3[start]!");
service3.orderConvert();
logger.info("OrderConvertTask3[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute4() {
Result result = new Result();
try {
logger.info("OrderConvertTask4[start]!");
service4.orderConvert();
logger.info("OrderConvertTask4[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute5() {
Result result = new Result();
try {
logger.info("OrderConvertTask5[start]!");
service5.orderConvert();
logger.info("OrderConvertTask5[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute6() {
Result result = new Result();
try {
logger.info("OrderConvertTask6[start]!");
service6.orderConvert();
logger.info("OrderConvertTask6[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute7() {
Result result = new Result();
try {
logger.info("OrderConvertTask7[start]!");
service7.orderConvert();
logger.info("OrderConvertTask7[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Async
@Scheduled(cron = "0 25 22 * * ?")
public Result execute8() {
Result result = new Result();
try {
logger.info("OrderConvertTask8[start]!");
service8.orderConvert();
logger.info("OrderConvertTask8[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
//
@Async
@Scheduled(cron = "0 30 5 * * ?")
public Result executeRefund() {
Result result = new Result();
try {
logger.info("executeRefund[start]!");
refundService.refundConvertNew();
refundService.commentConvert();
refundService.itemCommentConvert();
logger.info("executeRefund[end]!");
result.setStatus(true);
} catch (Throwable e) {
logger.error("OrderConvertTask[execute] failed!, cause by:{}", e);
result.setException(ExceptionConstants.SYSTEM_ERROR);
}
return result;
}
@Autowired
......
src/main/java/com/zm/order/tool/server/service/impl/routing/OrderRoutingServiceImpl.java
View file @ 2d4b3c01
......@@ -663,12 +663,8 @@ public class OrderRoutingServiceImpl implements OrderRoutingService, Initializin
try {
for (Long sellerId : ListSellerConst.list) {
orderQuery.setSellerId(sellerId);
int m = 0;
if(sellerId==49006L){m=3;}
for (int i = m; i < 4; i++) {
int n = 0;
if(i==3){n=1;}
for (int j = n; j < tbSize; j++) {
for (int i = 0; i < dbSize; i++) {
for (int j = 0; j < tbSize; j++) {
Long lastId = null;
for (; ; ) {
orderQuery.setLastId(lastId);
......@@ -685,7 +681,7 @@ public class OrderRoutingServiceImpl implements OrderRoutingService, Initializin
logger.info("orderConvert,convert_order_last_id_1:{}, count:{}, i:{}, j:{}, sellerId:{}",
lastId, count, i, j, sellerId);
Result<String> redisData = redisManager.get("convert_order_shut_down_key_3");
Result<String> redisData = redisManager.get("convert_order_shut_down_key_44");
if (redisData.isStatus() && Objects.nonNull(redisData.getData())) {
logger.info("[orderConvert]shut down！");
return;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment