CRM退款匹配调整,加入任务监听.

data-base/base-sync-crm-refund/src/main/java/com/bailuntec/job/RefundLinkOrderJob.java

@@ -13,11 +13,13 @@ import com.bailuntec.mapper.DcBaseOmsSkuMapper;
 import com.bailuntec.support.PointJob;
 import com.bailuntec.utils.SessionUtil;
 import com.dangdang.ddframe.job.api.ShardingContext;
+import lombok.extern.slf4j.Slf4j;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.List;
 
+@Slf4j
 public class RefundLinkOrderJob extends PointJob {
 
     public void executeRefundJob(JobPointLog jobPointLog) {
@@ -47,6 +49,7 @@ public class RefundLinkOrderJob extends PointJob {
                     List<DcBaseCrmRefund> dcBaseCrmRefundList = refundMapper1.selectByExample(DcBaseCrmRefundExample.newAndCreateCriteria().andLinkedEqualTo(false).example().limit(i * jobPointLog.getPageSize(), jobPointLog.getPageSize()));
                     if (dcBaseCrmRefundList != null && dcBaseCrmRefundList.size() > 0) {
                         for (DcBaseCrmRefund dcBaseCrmRefund : dcBaseCrmRefundList) {
+                            log.warn(dcBaseCrmRefund.getOriginOrderId() +"------" + dcBaseCrmRefund.getBailunAccountId() +"------" + dcBaseCrmRefund.getBailunSku());
                             DcBaseOmsSku dcBaseOmsSku = null;
                             DcBaseOmsOrder dcBaseOmsOrder = null;
                             switch (dcBaseCrmRefund.getPlatformType().toUpperCase()) {

data-base/base-sync-crm-refund/src/main/java/com/bailuntec/mapper/DcBaseOmsOrderMapper.java

@@ -121,4 +121,8 @@ public interface DcBaseOmsOrderMapper {
      * @project https://github.com/itfsw/mybatis-generator-plugin
      */
     int upsertSelective(DcBaseOmsOrder record);
+
+    void logicDeleteOmsSku(DcBaseOmsOrder dcBaseOmsOrder);
+
+    void logicDeleteOmsPick(DcBaseOmsOrder dcBaseOmsOrder);
 }
\ No newline at end of file