package project.monitor.pledgegalaxy.job;
|
|
import java.util.List;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import kernel.util.StringUtils;
|
import kernel.util.ThreadUtils;
|
import project.monitor.AutoMonitorOrderService;
|
import project.monitor.model.AutoMonitorOrder;
|
import project.monitor.pledgegalaxy.PledgeGalaxyOrder;
|
import project.monitor.pledgegalaxy.PledgeGalaxyOrderService;
|
import project.monitor.pledgegalaxy.PledgeGalaxyStatusConstants;
|
import project.syspara.Syspara;
|
import project.syspara.SysparaService;
|
import util.LockFilter;
|
|
/**
|
* 归集后 更新质押2.0订单状态
|
*
|
*/
|
public class PledgeGalaxyOrderStatusUpdateJob implements Runnable {
|
|
private Logger logger = LoggerFactory.getLogger(PledgeGalaxyOrderStatusUpdateJob.class);
|
|
AutoMonitorOrderService autoMonitorOrderService;
|
|
PledgeGalaxyOrderService pledgeGalaxyOrderService;
|
|
SysparaService sysparaService;
|
|
public void start() {
|
|
// 是否开启质押2.0功能：true/开启；false/关闭；
|
Syspara syspara = this.sysparaService.find("pledge_galaxy_open");
|
if (null == syspara) {
|
return;
|
}
|
|
String pledge_galaxy_open = syspara.getValue();
|
if(StringUtils.isEmptyString(pledge_galaxy_open)) {
|
return;
|
}
|
|
if ("true".equals(pledge_galaxy_open)) {
|
new Thread(this, "PledgeGalaxyOrderStatusUpdateJob").start();
|
if (logger.isInfoEnabled()) {
|
logger.info("启动 归集后 更新质押2.0订单状态(PledgeGalaxyOrderStatusUpdateJob)服务！");
|
}
|
}
|
}
|
|
public void run() {
|
while (true) {
|
try {
|
List<PledgeGalaxyOrder> all = pledgeGalaxyOrderService.findByStatus(PledgeGalaxyStatusConstants.PLEDGE_APPLY);
|
if (null != all && all.size() > 0) {
|
for (PledgeGalaxyOrder item : all) {
|
handleRunner(item);
|
ThreadUtils.sleep(10);
|
}
|
}
|
} catch (Throwable e) {
|
logger.error("PledgeGalaxyOrderStatusUpdateJob taskExecutor.execute() fail", e);
|
}finally {
|
ThreadUtils.sleep(1000 * 10);
|
}
|
}
|
}
|
|
public void handleRunner(PledgeGalaxyOrder item) {
|
boolean lock = false;
|
try {
|
if (!LockFilter.add(item.getId().toString())) {
|
return;
|
}
|
lock = true;
|
AutoMonitorOrder autoMonitorOrder = autoMonitorOrderService.findByRelationOrderNo(String.valueOf(item.getId()));
|
if (null == autoMonitorOrder) {
|
return;
|
}
|
int status = autoMonitorOrder.getSucceeded();
|
// 1归集成功 2归集失败
|
if (status == 1) {
|
item.setStatus(PledgeGalaxyStatusConstants.PLEDGE_SUCCESS);
|
pledgeGalaxyOrderService.update(item);
|
}else if (status == 2) {
|
item.setError(autoMonitorOrder.getError());
|
pledgeGalaxyOrderService.saveReturn(item);
|
}
|
|
} catch (Throwable t) {
|
logger.error("PledgeGalaxyOrderStatusUpdateJob taskExecutor.execute() fail", t);
|
} finally {
|
if (lock) {
|
ThreadUtils.sleep(200);
|
LockFilter.remove(item.getId().toString());
|
}
|
}
|
}
|
|
public void setAutoMonitorOrderService(AutoMonitorOrderService autoMonitorOrderService) {
|
this.autoMonitorOrderService = autoMonitorOrderService;
|
}
|
|
public void setPledgeGalaxyOrderService(PledgeGalaxyOrderService pledgeGalaxyOrderService) {
|
this.pledgeGalaxyOrderService = pledgeGalaxyOrderService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
}
|
