|
|
|
@ -80,9 +80,9 @@ public class MoveReplenishTaskService extends TaskBaseService {
|
|
|
|
|
@Override
|
|
|
|
|
public Object processTask(Object params) {
|
|
|
|
|
log.info("start MoveReplenishTask");
|
|
|
|
|
moveService.replenishSolidRedisSkipQueue("move_product_publish_queue", "");
|
|
|
|
|
unlockTimeoutQueue.unlockSolidRedisSkipQueue("move_product_publish_to_pic_queue", "");
|
|
|
|
|
unlockTimeoutQueue.unlockSolidRedisSkipQueue("material_audit_status_queue", "");
|
|
|
|
|
// moveService.replenishSolidRedisSkipQueue("move_product_publish_queue", "");
|
|
|
|
|
// unlockTimeoutQueue.unlockSolidRedisSkipQueue("move_product_publish_to_pic_queue", "");
|
|
|
|
|
// unlockTimeoutQueue.unlockSolidRedisSkipQueue("material_audit_status_queue", "");
|
|
|
|
|
log.info("end move MoveReplenishTask service");
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|