Skip to content

D
dc-java
Commit 1a831e4f by huluobin
Options

update

parent da0af94b
Showing with 1117 additions and 32 deletions
data-base/base-sync-finance-ebay/src/test/java/com/bailuntec/job/EbayFinanceAdSyncJobTest.java
...@@ -84,8 +84,8 @@ public class EbayFinanceAdSyncJobTest { ...@@ -84,8 +84,8 @@ public class EbayFinanceAdSyncJobTest {
public void testThreadPool() { public void testThreadPool() {
EbayFinanceAdSyncJob ebayFinanceAdSyncJob = new EbayFinanceAdSyncJob(); EbayFinanceAdSyncJob ebayFinanceAdSyncJob = new EbayFinanceAdSyncJob();
LocalDateTime start = LocalDateTime.of(2020, 10, 31, 0, 0); LocalDateTime start = LocalDateTime.of(2020, 11, 17, 0, 0);
LocalDateTime end = LocalDateTime.of(2020, 11, 16, 0, 0); LocalDateTime end = LocalDateTime.of(2020, 11, 19, 0, 0);
List<LocalDateTime> localDateTimeList = Stream.iterate(start, List<LocalDateTime> localDateTimeList = Stream.iterate(start,
localDateTime -> localDateTime.plusDays(1)) localDateTime -> localDateTime.plusDays(1))
......
data-common/src/main/java/com/bailuntec/domain/entity/DcAutoReplaceLogisticsTask.java 0 → 100644
package com.bailuntec.domain.entity;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import lombok.Data;
@Data
public class DcAutoReplaceLogisticsTask {
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.id
*
* @mbg.generated
*/
private Integer id;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.bailun_sku
*
* @mbg.generated
*/
private String bailunSku;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.warehouse_code
*
* @mbg.generated
*/
private String warehouseCode;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.transfer_bale_delivery
*
* @mbg.generated
*/
private BigDecimal transferBaleDelivery;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.abroad_inbound_delivery
*
* @mbg.generated
*/
private BigDecimal abroadInboundDelivery;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.transfer_delivery
*
* @mbg.generated
*/
private BigDecimal transferDelivery;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.status
*
* @mbg.generated
*/
private Integer status;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.error_message
*
* @mbg.generated
*/
private String errorMessage;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.update_date
*
* @mbg.generated
*/
private LocalDateTime updateDate;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.create_date
*
* @mbg.generated
*/
private LocalDateTime createDate;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_auto_replace_logistics_task.error_stack_trace
*
* @mbg.generated
*/
private String errorStackTrace;
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_auto_replace_logistics_task
*
* @mbg.generated
*/
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", bailunSku=").append(bailunSku);
sb.append(", warehouseCode=").append(warehouseCode);
sb.append(", transferBaleDelivery=").append(transferBaleDelivery);
sb.append(", abroadInboundDelivery=").append(abroadInboundDelivery);
sb.append(", transferDelivery=").append(transferDelivery);
sb.append(", status=").append(status);
sb.append(", errorMessage=").append(errorMessage);
sb.append(", updateDate=").append(updateDate);
sb.append(", createDate=").append(createDate);
sb.append(", errorStackTrace=").append(errorStackTrace);
sb.append("]");
return sb.toString();
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_auto_replace_logistics_task
*
* @mbg.generated
*/
@Override
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
DcAutoReplaceLogisticsTask other = (DcAutoReplaceLogisticsTask) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getBailunSku() == null ? other.getBailunSku() == null : this.getBailunSku().equals(other.getBailunSku()))
&& (this.getWarehouseCode() == null ? other.getWarehouseCode() == null : this.getWarehouseCode().equals(other.getWarehouseCode()))
&& (this.getTransferBaleDelivery() == null ? other.getTransferBaleDelivery() == null : this.getTransferBaleDelivery().equals(other.getTransferBaleDelivery()))
&& (this.getAbroadInboundDelivery() == null ? other.getAbroadInboundDelivery() == null : this.getAbroadInboundDelivery().equals(other.getAbroadInboundDelivery()))
&& (this.getTransferDelivery() == null ? other.getTransferDelivery() == null : this.getTransferDelivery().equals(other.getTransferDelivery()))
&& (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()))
&& (this.getErrorMessage() == null ? other.getErrorMessage() == null : this.getErrorMessage().equals(other.getErrorMessage()))
&& (this.getUpdateDate() == null ? other.getUpdateDate() == null : this.getUpdateDate().equals(other.getUpdateDate()))
&& (this.getCreateDate() == null ? other.getCreateDate() == null : this.getCreateDate().equals(other.getCreateDate()))
&& (this.getErrorStackTrace() == null ? other.getErrorStackTrace() == null : this.getErrorStackTrace().equals(other.getErrorStackTrace()));
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_auto_replace_logistics_task
*
* @mbg.generated
*/
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getBailunSku() == null) ? 0 : getBailunSku().hashCode());
result = prime * result + ((getWarehouseCode() == null) ? 0 : getWarehouseCode().hashCode());
result = prime * result + ((getTransferBaleDelivery() == null) ? 0 : getTransferBaleDelivery().hashCode());
result = prime * result + ((getAbroadInboundDelivery() == null) ? 0 : getAbroadInboundDelivery().hashCode());
result = prime * result + ((getTransferDelivery() == null) ? 0 : getTransferDelivery().hashCode());
result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
result = prime * result + ((getErrorMessage() == null) ? 0 : getErrorMessage().hashCode());
result = prime * result + ((getUpdateDate() == null) ? 0 : getUpdateDate().hashCode());
result = prime * result + ((getCreateDate() == null) ? 0 : getCreateDate().hashCode());
result = prime * result + ((getErrorStackTrace() == null) ? 0 : getErrorStackTrace().hashCode());
return result;
}
}
\ No newline at end of file
data-common/src/main/java/com/bailuntec/domain/entity/DcBaseWeekCoefficient.java 0 → 100644
package com.bailuntec.domain.entity;
import java.time.LocalDateTime;
import lombok.Data;
@Data
public class DcBaseWeekCoefficient {
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.id
*
* @mbg.generated
*/
private Integer id;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.bailun_sku
*
* @mbg.generated
*/
private String bailunSku;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.warehouse_code
*
* @mbg.generated
*/
private String warehouseCode;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.bailun_sku_warehouse_code
*
* @mbg.generated
*/
private String bailunSkuWarehouseCode;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.week
*
* @mbg.generated
*/
private Integer week;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.coefficient
*
* @mbg.generated
*/
private String coefficient;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.update_date
*
* @mbg.generated
*/
private LocalDateTime updateDate;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_week_coefficient.formula
*
* @mbg.generated
*/
private String formula;
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", bailunSku=").append(bailunSku);
sb.append(", warehouseCode=").append(warehouseCode);
sb.append(", bailunSkuWarehouseCode=").append(bailunSkuWarehouseCode);
sb.append(", week=").append(week);
sb.append(", coefficient=").append(coefficient);
sb.append(", updateDate=").append(updateDate);
sb.append(", formula=").append(formula);
sb.append("]");
return sb.toString();
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
@Override
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
DcBaseWeekCoefficient other = (DcBaseWeekCoefficient) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getBailunSku() == null ? other.getBailunSku() == null : this.getBailunSku().equals(other.getBailunSku()))
&& (this.getWarehouseCode() == null ? other.getWarehouseCode() == null : this.getWarehouseCode().equals(other.getWarehouseCode()))
&& (this.getBailunSkuWarehouseCode() == null ? other.getBailunSkuWarehouseCode() == null : this.getBailunSkuWarehouseCode().equals(other.getBailunSkuWarehouseCode()))
&& (this.getWeek() == null ? other.getWeek() == null : this.getWeek().equals(other.getWeek()))
&& (this.getCoefficient() == null ? other.getCoefficient() == null : this.getCoefficient().equals(other.getCoefficient()))
&& (this.getUpdateDate() == null ? other.getUpdateDate() == null : this.getUpdateDate().equals(other.getUpdateDate()))
&& (this.getFormula() == null ? other.getFormula() == null : this.getFormula().equals(other.getFormula()));
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getBailunSku() == null) ? 0 : getBailunSku().hashCode());
result = prime * result + ((getWarehouseCode() == null) ? 0 : getWarehouseCode().hashCode());
result = prime * result + ((getBailunSkuWarehouseCode() == null) ? 0 : getBailunSkuWarehouseCode().hashCode());
result = prime * result + ((getWeek() == null) ? 0 : getWeek().hashCode());
result = prime * result + ((getCoefficient() == null) ? 0 : getCoefficient().hashCode());
result = prime * result + ((getUpdateDate() == null) ? 0 : getUpdateDate().hashCode());
result = prime * result + ((getFormula() == null) ? 0 : getFormula().hashCode());
return result;
}
}
\ No newline at end of file
data-common/src/main/java/com/bailuntec/domain/entity/SalesDayConfig.java 0 → 100644
package com.bailuntec.domain.entity;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import lombok.Data;
@Data
public class SalesDayConfig {
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.id
*
* @mbg.generated
*/
private Integer id;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.bailun_sku
*
* @mbg.generated
*/
private String bailunSku;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.warehouse_code
*
* @mbg.generated
*/
private String warehouseCode;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.bailun_sku_warehouse_code
*
* @mbg.generated
*/
private String bailunSkuWarehouseCode;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.date
*
* @mbg.generated
*/
private LocalDateTime date;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.date_str
*
* @mbg.generated
*/
private String dateStr;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.sales
*
* @mbg.generated
*/
private BigDecimal sales;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.create_date
*
* @mbg.generated
*/
private LocalDateTime createDate;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.create_user
*
* @mbg.generated
*/
private String createUser;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.update_date
*
* @mbg.generated
*/
private LocalDateTime updateDate;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column sales_day_config.update_user
*
* @mbg.generated
*/
private String updateUser;
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", bailunSku=").append(bailunSku);
sb.append(", warehouseCode=").append(warehouseCode);
sb.append(", bailunSkuWarehouseCode=").append(bailunSkuWarehouseCode);
sb.append(", date=").append(date);
sb.append(", dateStr=").append(dateStr);
sb.append(", sales=").append(sales);
sb.append(", createDate=").append(createDate);
sb.append(", createUser=").append(createUser);
sb.append(", updateDate=").append(updateDate);
sb.append(", updateUser=").append(updateUser);
sb.append("]");
return sb.toString();
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
@Override
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
SalesDayConfig other = (SalesDayConfig) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getBailunSku() == null ? other.getBailunSku() == null : this.getBailunSku().equals(other.getBailunSku()))
&& (this.getWarehouseCode() == null ? other.getWarehouseCode() == null : this.getWarehouseCode().equals(other.getWarehouseCode()))
&& (this.getBailunSkuWarehouseCode() == null ? other.getBailunSkuWarehouseCode() == null : this.getBailunSkuWarehouseCode().equals(other.getBailunSkuWarehouseCode()))
&& (this.getDate() == null ? other.getDate() == null : this.getDate().equals(other.getDate()))
&& (this.getDateStr() == null ? other.getDateStr() == null : this.getDateStr().equals(other.getDateStr()))
&& (this.getSales() == null ? other.getSales() == null : this.getSales().equals(other.getSales()))
&& (this.getCreateDate() == null ? other.getCreateDate() == null : this.getCreateDate().equals(other.getCreateDate()))
&& (this.getCreateUser() == null ? other.getCreateUser() == null : this.getCreateUser().equals(other.getCreateUser()))
&& (this.getUpdateDate() == null ? other.getUpdateDate() == null : this.getUpdateDate().equals(other.getUpdateDate()))
&& (this.getUpdateUser() == null ? other.getUpdateUser() == null : this.getUpdateUser().equals(other.getUpdateUser()));
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getBailunSku() == null) ? 0 : getBailunSku().hashCode());
result = prime * result + ((getWarehouseCode() == null) ? 0 : getWarehouseCode().hashCode());
result = prime * result + ((getBailunSkuWarehouseCode() == null) ? 0 : getBailunSkuWarehouseCode().hashCode());
result = prime * result + ((getDate() == null) ? 0 : getDate().hashCode());
result = prime * result + ((getDateStr() == null) ? 0 : getDateStr().hashCode());
result = prime * result + ((getSales() == null) ? 0 : getSales().hashCode());
result = prime * result + ((getCreateDate() == null) ? 0 : getCreateDate().hashCode());
result = prime * result + ((getCreateUser() == null) ? 0 : getCreateUser().hashCode());
result = prime * result + ((getUpdateDate() == null) ? 0 : getUpdateDate().hashCode());
result = prime * result + ((getUpdateUser() == null) ? 0 : getUpdateUser().hashCode());
return result;
}
}
\ No newline at end of file
data-common/src/main/java/com/bailuntec/domain/example/DcAutoTurnoverExample.java
...@@ -5170,6 +5170,206 @@ public class DcAutoTurnoverExample { ...@@ -5170,6 +5170,206 @@ public class DcAutoTurnoverExample {
addCriterion("dc_auto_sales_forecast_title not between", value1, value2, "dcAutoSalesForecastTitle"); addCriterion("dc_auto_sales_forecast_title not between", value1, value2, "dcAutoSalesForecastTitle");
return (Criteria) this; return (Criteria) this;
} }
public Criteria andHeadTransportTypeIsNull() {
addCriterion("head_transport_type is null");
return (Criteria) this;
}
public Criteria andHeadTransportTypeIsNotNull() {
addCriterion("head_transport_type is not null");
return (Criteria) this;
}
public Criteria andHeadTransportTypeEqualTo(String value) {
addCriterion("head_transport_type =", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeNotEqualTo(String value) {
addCriterion("head_transport_type <>", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeGreaterThan(String value) {
addCriterion("head_transport_type >", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeGreaterThanOrEqualTo(String value) {
addCriterion("head_transport_type >=", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeLessThan(String value) {
addCriterion("head_transport_type <", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeLessThanOrEqualTo(String value) {
addCriterion("head_transport_type <=", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeLike(String value) {
addCriterion("head_transport_type like", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeNotLike(String value) {
addCriterion("head_transport_type not like", value, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeIn(List<String> values) {
addCriterion("head_transport_type in", values, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeNotIn(List<String> values) {
addCriterion("head_transport_type not in", values, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeBetween(String value1, String value2) {
addCriterion("head_transport_type between", value1, value2, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportTypeNotBetween(String value1, String value2) {
addCriterion("head_transport_type not between", value1, value2, "headTransportType");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeIsNull() {
addCriterion("head_transport_logistics_code is null");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeIsNotNull() {
addCriterion("head_transport_logistics_code is not null");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeEqualTo(String value) {
addCriterion("head_transport_logistics_code =", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeNotEqualTo(String value) {
addCriterion("head_transport_logistics_code <>", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeGreaterThan(String value) {
addCriterion("head_transport_logistics_code >", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeGreaterThanOrEqualTo(String value) {
addCriterion("head_transport_logistics_code >=", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeLessThan(String value) {
addCriterion("head_transport_logistics_code <", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeLessThanOrEqualTo(String value) {
addCriterion("head_transport_logistics_code <=", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeLike(String value) {
addCriterion("head_transport_logistics_code like", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeNotLike(String value) {
addCriterion("head_transport_logistics_code not like", value, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeIn(List<String> values) {
addCriterion("head_transport_logistics_code in", values, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeNotIn(List<String> values) {
addCriterion("head_transport_logistics_code not in", values, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeBetween(String value1, String value2) {
addCriterion("head_transport_logistics_code between", value1, value2, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andHeadTransportLogisticsCodeNotBetween(String value1, String value2) {
addCriterion("head_transport_logistics_code not between", value1, value2, "headTransportLogisticsCode");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdIsNull() {
addCriterion("auto_replace_logistics_task_id is null");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdIsNotNull() {
addCriterion("auto_replace_logistics_task_id is not null");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdEqualTo(Integer value) {
addCriterion("auto_replace_logistics_task_id =", value, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdNotEqualTo(Integer value) {
addCriterion("auto_replace_logistics_task_id <>", value, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdGreaterThan(Integer value) {
addCriterion("auto_replace_logistics_task_id >", value, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdGreaterThanOrEqualTo(Integer value) {
addCriterion("auto_replace_logistics_task_id >=", value, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdLessThan(Integer value) {
addCriterion("auto_replace_logistics_task_id <", value, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdLessThanOrEqualTo(Integer value) {
addCriterion("auto_replace_logistics_task_id <=", value, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdIn(List<Integer> values) {
addCriterion("auto_replace_logistics_task_id in", values, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdNotIn(List<Integer> values) {
addCriterion("auto_replace_logistics_task_id not in", values, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdBetween(Integer value1, Integer value2) {
addCriterion("auto_replace_logistics_task_id between", value1, value2, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
public Criteria andAutoReplaceLogisticsTaskIdNotBetween(Integer value1, Integer value2) {
addCriterion("auto_replace_logistics_task_id not between", value1, value2, "autoReplaceLogisticsTaskId");
return (Criteria) this;
}
} }
/** /**
......
data-common/src/main/java/com/bailuntec/mapper/DcAutoTurnoverMapper.java
...@@ -3,9 +3,8 @@ package com.bailuntec.mapper; ...@@ -3,9 +3,8 @@ package com.bailuntec.mapper;
import com.bailuntec.domain.entity.DcAutoTurnover; import com.bailuntec.domain.entity.DcAutoTurnover;
import com.bailuntec.domain.entity.DcAutoTurnoverWithBLOBs; import com.bailuntec.domain.entity.DcAutoTurnoverWithBLOBs;
import com.bailuntec.domain.example.DcAutoTurnoverExample; import com.bailuntec.domain.example.DcAutoTurnoverExample;
import org.apache.ibatis.annotations.Param;
import java.util.List; import java.util.List;
import org.apache.ibatis.annotations.Param;
public interface DcAutoTurnoverMapper { public interface DcAutoTurnoverMapper {
/** /**
...@@ -164,19 +163,4 @@ public interface DcAutoTurnoverMapper { ...@@ -164,19 +163,4 @@ public interface DcAutoTurnoverMapper {
* @project https://github.com/itfsw/mybatis-generator-plugin * @project https://github.com/itfsw/mybatis-generator-plugin
*/ */
int upsertWithBLOBs(DcAutoTurnoverWithBLOBs record); int upsertWithBLOBs(DcAutoTurnoverWithBLOBs record);
}
\ No newline at end of file
void truncateAutoInboundTable();
void truncateAutoInventoryTable();
void truncateAutoShortSupplyTable();
void truncateAutoTurnoverTable();
void truncateAutoSalesTable();
void truncateAutoExceptionTable();
Integer yesterdayStock(@Param("bailun_sku") String bailun_sku, @Param("warehouse_code") String warehouse_code);
}
data-common/src/main/java/com/bailuntec/mapper/DcBaseFinanceFeeMapper.xml
...@@ -1738,6 +1738,7 @@ ...@@ -1738,6 +1738,7 @@
where is_lend = 1 where is_lend = 1
and cost_form = 3 and cost_form = 3
and lend_status in (1, 2) and lend_status in (1, 2)
and cost_status = 4
</insert> </insert>
<delete id="deleteDailyFee"> <delete id="deleteDailyFee">
......
data-common/src/main/java/com/bailuntec/mapper/DcBaseWeekCoefficientMapper.java 0 → 100644
package com.bailuntec.mapper;
import com.bailuntec.domain.entity.DcBaseWeekCoefficient;
import com.bailuntec.domain.example.DcBaseWeekCoefficientExample;
import java.util.List;
import org.apache.ibatis.annotations.Param;
public interface DcBaseWeekCoefficientMapper {
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
long countByExample(DcBaseWeekCoefficientExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int deleteByExample(DcBaseWeekCoefficientExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int deleteByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int insert(DcBaseWeekCoefficient record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int insertSelective(DcBaseWeekCoefficient record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
DcBaseWeekCoefficient selectOneByExample(DcBaseWeekCoefficientExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
List<DcBaseWeekCoefficient> selectByExample(DcBaseWeekCoefficientExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
DcBaseWeekCoefficient selectByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int updateByExampleSelective(@Param("record") DcBaseWeekCoefficient record, @Param("example") DcBaseWeekCoefficientExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int updateByExample(@Param("record") DcBaseWeekCoefficient record, @Param("example") DcBaseWeekCoefficientExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int updateByPrimaryKeySelective(DcBaseWeekCoefficient record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
*/
int updateByPrimaryKey(DcBaseWeekCoefficient record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsert(DcBaseWeekCoefficient record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_week_coefficient
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsertSelective(DcBaseWeekCoefficient record);
}
\ No newline at end of file
data-common/src/main/java/com/bailuntec/mapper/DcMidTransitMapper.java
...@@ -131,6 +131,9 @@ public interface DcMidTransitMapper { ...@@ -131,6 +131,9 @@ public interface DcMidTransitMapper {
void calculatePurchaseTransit(@Param("list") List<PurchaseTransitQuantity> list, @Param("localDateTime") LocalDateTime localDateTime); void calculatePurchaseTransit(@Param("list") List<PurchaseTransitQuantity> list, @Param("localDateTime") LocalDateTime localDateTime);
void calculateOutStock(@Param("list") List<OutStockQuantity> list, @Param("localDateTime") LocalDateTime localDateTime);
void insertMidDailyTransit(); void insertMidDailyTransit();
List<OutStockQuantity> selectQuantityOutStock(); List<OutStockQuantity> selectQuantityOutStock();
...@@ -139,7 +142,6 @@ public interface DcMidTransitMapper { ...@@ -139,7 +142,6 @@ public interface DcMidTransitMapper {
List<TransferTransitQuantity> selectQuantityTransferTransit(); List<TransferTransitQuantity> selectQuantityTransferTransit();
void calculateOutStock(@Param("list") List<OutStockQuantity> list, @Param("localDateTime") LocalDateTime localDateTime);
@Select("select @@tx_isolation;") @Select("select @@tx_isolation;")
String printTransactionLevel(); String printTransactionLevel();
......
data-common/src/main/java/com/bailuntec/mapper/SalesDayConfigMapper.java 0 → 100644
package com.bailuntec.mapper;
import com.bailuntec.domain.entity.SalesDayConfig;
import com.bailuntec.domain.example.SalesDayConfigExample;
import java.util.List;
import org.apache.ibatis.annotations.Param;
public interface SalesDayConfigMapper {
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
long countByExample(SalesDayConfigExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int deleteByExample(SalesDayConfigExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int deleteByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int insert(SalesDayConfig record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int insertSelective(SalesDayConfig record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
SalesDayConfig selectOneByExample(SalesDayConfigExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
List<SalesDayConfig> selectByExample(SalesDayConfigExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
SalesDayConfig selectByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int updateByExampleSelective(@Param("record") SalesDayConfig record, @Param("example") SalesDayConfigExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int updateByExample(@Param("record") SalesDayConfig record, @Param("example") SalesDayConfigExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int updateByPrimaryKeySelective(SalesDayConfig record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
*/
int updateByPrimaryKey(SalesDayConfig record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsert(SalesDayConfig record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table sales_day_config
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsertSelective(SalesDayConfig record);
}
\ No newline at end of file
data-common/src/main/resources/generatorConfig.xml
...@@ -11,7 +11,7 @@ ...@@ -11,7 +11,7 @@
<properties resource="init.properties"/> <properties resource="init.properties"/>
<!-- 指定数据连接驱动jar地址 --> <!-- 指定数据连接驱动jar地址 -->
<classPathEntry location="/Users/huluobin/Downloads/seata/lib/mysql-connector-java-5.1.30.jar"/> <classPathEntry location="/Users/huluobin/IdeaProjects/dc-java/elastic-job-lite/elastic-job-lite-console/target/elastic-job-lite-console-3.0.0.M1-SNAPSHOT/lib/mysql-connector-java-5.1.30.jar"/>
<!-- 一个数据库一个context --> <!-- 一个数据库一个context -->
<!--targetRuntime="MyBatis3Simple" 不生成Mapper--> <!--targetRuntime="MyBatis3Simple" 不生成Mapper-->
......
data-common/src/main/resources/init.properties
table-name=dc_auto_turnover table-name=dc_base_week_coefficient
data-finance/finance-balance-sheet/src/main/java/com/bailuntec/balancesheet/mapper/DcBalanceSheetMapper.java
...@@ -155,7 +155,7 @@ public interface DcBalanceSheetMapper { ...@@ -155,7 +155,7 @@ public interface DcBalanceSheetMapper {
@Select("select finished_accounts_payable from dc_balance_sheet where statistical_time <= #{lastDay} and finished_accounts_payable > 0 order by finished_accounts_payable desc limit 1 ") @Select("select finished_accounts_payable from dc_balance_sheet where statistical_time <= #{lastDay} and finished_accounts_payable > 0 order by finished_accounts_payable desc limit 1 ")
BigDecimal getLogisticsAccountsPayableSumByOld(@Param("date") Date date); BigDecimal getLogisticsAccountsPayableSumByOld(@Param("date") Date date);
@Select("select sum((amount - ifnull(had_pay, 0) + ifnull(compensate, 0)) * to_rmb_rate) from dc_daily_fee where recoed_time = #{lastDay} and company_value in (53,3,5,60,66,59,50,8,1,61,2)") @Select("select sum((amount - ifnull(had_pay, 0) + ifnull(compensate, 0)) * to_rmb_rate) from dc_daily_fee where recoed_time = #{lastDay} and company_value not in (78,72,71,67,58,54)")
BigDecimal getAmountBorrowed(@Param("lastDay") Date lastDay); BigDecimal getAmountBorrowed(@Param("lastDay") Date lastDay);
@Select("select accounts_receivable_import from dc_balance_sheet where statistical_time = #{lastDay} ") @Select("select accounts_receivable_import from dc_balance_sheet where statistical_time = #{lastDay} ")
......
data-show/show-auto-turnover/src/main/java/com/bailuntec/Application.java
...@@ -2,6 +2,7 @@ package com.bailuntec; ...@@ -2,6 +2,7 @@ package com.bailuntec;
import com.alibaba.druid.pool.DruidDataSource; import com.alibaba.druid.pool.DruidDataSource;
import com.bailuntec.job.AutoTurnoverJob; import com.bailuntec.job.AutoTurnoverJob;
import com.bailuntec.job.ReplaceLogisticJob;
import com.bailuntec.utils.PropertiesUtil; import com.bailuntec.utils.PropertiesUtil;
import com.dangdang.ddframe.job.config.JobCoreConfiguration; import com.dangdang.ddframe.job.config.JobCoreConfiguration;
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration; import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
...@@ -39,13 +40,28 @@ public class Application { ...@@ -39,13 +40,28 @@ public class Application {
createJobEventConfiguration()).init(); createJobEventConfiguration()).init();
new JobScheduler(createRegistryCenter(), new JobScheduler(createRegistryCenter(),
createReplaceLogistic(),
createJobEventConfiguration()).init();
new JobScheduler(createRegistryCenter(),
createJobConfigurationNeNormal(), createJobConfigurationNeNormal(),
createJobEventConfiguration()).init(); createJobEventConfiguration()).init();
log.info("start success"); log.info("start success");
} }
private static LiteJobConfiguration createReplaceLogistic() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
"ReplaceLogistic",
"0/1 * * * * ? ",
1)
.build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, ReplaceLogisticJob.class.getCanonicalName());
return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
}
private static CoordinatorRegistryCenter createRegistryCenter() { private static CoordinatorRegistryCenter createRegistryCenter() {
CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration(propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"), propertiesUtil.getPropertyAsString("NAME_SPACE"))); CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration(propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"), propertiesUtil.getPropertyAsString("NAME_SPACE")));
regCenter.init(); regCenter.init();
......
data-show/show-auto-turnover/src/main/java/com/bailuntec/job/AutoTurnoverJob.java
...@@ -1084,6 +1084,15 @@ public class AutoTurnoverJob extends PointJob { ...@@ -1084,6 +1084,15 @@ public class AutoTurnoverJob extends PointJob {
turnoverAbroadInboundDelivery = dcAverageWarehouse.getAbroadInboundDelivery().intValue(); turnoverAbroadInboundDelivery = dcAverageWarehouse.getAbroadInboundDelivery().intValue();
} }
} }
if (ReplaceLogisticJob.logisticsTaskThreadLocal.get() != null) {
DcAutoReplaceLogisticsTask dcAutoReplaceLogisticsTask = ReplaceLogisticJob.logisticsTaskThreadLocal.get();
turnoverTransferHeadDelivery = dcAutoReplaceLogisticsTask.getTransferDelivery().intValue();
turnoverTransferBaleDelivery = dcAutoReplaceLogisticsTask.getTransferBaleDelivery().intValue();
turnoverAbroadInboundDelivery = dcAutoReplaceLogisticsTask.getAbroadInboundDelivery().intValue();
dcAutoTurnover.setAutoReplaceLogisticsTaskId(dcAutoReplaceLogisticsTask.getId());
} else {
dcAutoTurnover.setAutoReplaceLogisticsTaskId(0);
}
//周转期 //周转期
Integer turnoverDays = turnoverSupplierDelivery + turnoverInboundDelivery + turnoverTransferHeadDelivery + turnoverTransferBaleDelivery + turnoverAbroadInboundDelivery; Integer turnoverDays = turnoverSupplierDelivery + turnoverInboundDelivery + turnoverTransferHeadDelivery + turnoverTransferBaleDelivery + turnoverAbroadInboundDelivery;
...@@ -1419,8 +1428,10 @@ public class AutoTurnoverJob extends PointJob { ...@@ -1419,8 +1428,10 @@ public class AutoTurnoverJob extends PointJob {
* @param dcAutoSales * @param dcAutoSales
* @param forecastSalesList * @param forecastSalesList
*/ */
private void correctionForecastSales(LocalDate recordTime, Integer autoForecastDay, DcAutoSales private void correctionForecastSales(LocalDate recordTime,
dcAutoSales, List<BigDecimal> forecastSalesList) { Integer autoForecastDay,
DcAutoSales dcAutoSales,
List<BigDecimal> forecastSalesList) {
List<DcAutoConfigCorrection> configCorrectionList = null; List<DcAutoConfigCorrection> configCorrectionList = null;
try { try {
DcAutoConfigCorrectionMapper autoConfigCorrectionMapper = SessionUtil.getSession().getMapper(DcAutoConfigCorrectionMapper.class); DcAutoConfigCorrectionMapper autoConfigCorrectionMapper = SessionUtil.getSession().getMapper(DcAutoConfigCorrectionMapper.class);
...@@ -1440,7 +1451,7 @@ public class AutoTurnoverJob extends PointJob { ...@@ -1440,7 +1451,7 @@ public class AutoTurnoverJob extends PointJob {
} else if (dcAutoConfigCorrection.getStartTime() != null && dcAutoConfigCorrection.getEndTime() != null) { } else if (dcAutoConfigCorrection.getStartTime() != null && dcAutoConfigCorrection.getEndTime() != null) {
int begin = Period.between(recordTime, dcAutoConfigCorrection.getStartTime()).getDays(); int begin = Period.between(recordTime, dcAutoConfigCorrection.getStartTime()).getDays();
int end = Period.between(recordTime, dcAutoConfigCorrection.getEndTime()).getDays(); int end = Period.between(recordTime, dcAutoConfigCorrection.getEndTime()).getDays();
end = (end > autoForecastDay.intValue()) ? autoForecastDay.intValue() : end; end = Math.min(end, autoForecastDay);
for (int i = begin; i <= end; i++) { for (int i = begin; i <= end; i++) {
forecastSalesList.set(i, dcAutoConfigCorrection.getParam().multiply(forecastSalesList.get(i)).setScale(3, RoundingMode.HALF_EVEN)); forecastSalesList.set(i, dcAutoConfigCorrection.getParam().multiply(forecastSalesList.get(i)).setScale(3, RoundingMode.HALF_EVEN));
} }
......
data-show/show-auto-turnover/src/main/java/com/bailuntec/job/ReplaceLogisticJob.java 0 → 100644
package com.bailuntec.job;
import com.bailuntec.domain.constant.CommonConstant;
import com.bailuntec.domain.entity.DcAutoReplaceLogisticsTask;
import com.bailuntec.domain.entity.DcBaseStock;
import com.bailuntec.domain.example.DcAutoReplaceLogisticsTaskExample;
import com.bailuntec.domain.example.DcBaseStockExample;
import com.bailuntec.mapper.DcAutoReplaceLogisticsTaskMapper;
import com.bailuntec.mapper.DcBaseStockMapper;
import com.bailuntec.utils.SessionUtil;
import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import org.apache.ibatis.session.SqlSession;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
/**
* <p>
*
* </p>
*
* @author robbendev
* @since 2020/11/24 4:10 下午
*/
public class ReplaceLogisticJob implements SimpleJob {
public static ThreadLocal<DcAutoReplaceLogisticsTask> logisticsTaskThreadLocal = new ThreadLocal<>();
@Override
public void execute(ShardingContext shardingContext) {
SqlSession sqlSession = SessionUtil.getFactory().openSession(true);
try {
DcAutoReplaceLogisticsTaskMapper dcAutoReplaceLogisticsTaskMapper = sqlSession.getMapper(DcAutoReplaceLogisticsTaskMapper.class);
DcBaseStockMapper dcBaseStockMapper = sqlSession.getMapper(DcBaseStockMapper.class);
List<DcAutoReplaceLogisticsTask> dcAutoReplaceLogisticsTaskList = dcAutoReplaceLogisticsTaskMapper.selectByExample(DcAutoReplaceLogisticsTaskExample.newAndCreateCriteria()
.andStatusEqualTo(0)
.example());
dcAutoReplaceLogisticsTaskList.forEach(dcAutoReplaceLogisticsTask -> {
try {
logisticsTaskThreadLocal.set(dcAutoReplaceLogisticsTask);
AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
DcBaseStock dcBaseStock = dcBaseStockMapper.selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
.andBailunSkuEqualTo(dcAutoReplaceLogisticsTask.getBailunSku())
.andWarehouseCodeEqualTo(dcAutoReplaceLogisticsTask.getWarehouseCode())
.example());
autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
dcAutoReplaceLogisticsTask.setStatus(1);
} catch (Exception ex) {
dcAutoReplaceLogisticsTask.setStatus(2);
} finally {
dcAutoReplaceLogisticsTask.setUpdateDate(LocalDateTime.now());
dcAutoReplaceLogisticsTaskMapper.updateByPrimaryKeySelective(dcAutoReplaceLogisticsTask);
logisticsTaskThreadLocal.remove();
}
});
} finally {
sqlSession.close();
}
}
}
data-show/show-auto-turnover/src/main/resources/job.properties
...@@ -10,9 +10,8 @@ EVENT_RDB_STORAGE_PASSWORD=#7kfnymAM$Y9-Ntf ...@@ -10,9 +10,8 @@ EVENT_RDB_STORAGE_PASSWORD=#7kfnymAM$Y9-Ntf
ZOOKEEPER_SERVER=172.31.255.120:2181 ZOOKEEPER_SERVER=172.31.255.120:2181
NAME_SPACE=data-center NAME_SPACE=data-center
JOB_NAME=show-auto-turnover6 JOB_NAME=show-auto-turnover8
#JOB_CRON=0 0 3 * * ? JOB_CRON=0 0 3 * * ?
JOB_CRON=0 50 8 * * ?
SHARDING_TOTAL_COUNT=8 SHARDING_TOTAL_COUNT=8
......
data-show/show-auto-turnover/src/test/java/AutoTurnoverTest.java
...@@ -137,8 +137,8 @@ public class AutoTurnoverTest { ...@@ -137,8 +137,8 @@ public class AutoTurnoverTest {
public void testXX() { public void testXX() {
DcBaseStock dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class) DcBaseStock dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class)
.selectOneByExample(DcBaseStockExample.newAndCreateCriteria() .selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
.andBailunSkuEqualTo("949943201") .andBailunSkuEqualTo("950093401")
// .andWarehouseCodeEqualTo("GB4PXBL") .andWarehouseCodeEqualTo("GZBLWH")
.example()); .example());
try { try {
......
data-show/show-auto-turnover/src/test/java/com/bailuntec/job/ReplaceLogisticJobTest.java 0 → 100644
package com.bailuntec.job;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
/**
* <p>
*
* </p>
*
* @author robbendev
* @since 2020/11/25 10:21 上午
*/
class ReplaceLogisticJobTest {
@Test
void execute() {
ReplaceLogisticJob job =new ReplaceLogisticJob();
job.execute(null);
}
}
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