要货表查询判断非逻辑删除

suishenbang-order/src/main/java/com/dgtly/order/mapper/MetaHanaSalesOrderMapper.java

@@ -23,4 +23,15 @@ public interface MetaHanaSalesOrderMapper  {
     Map<String,Map<String,Object>> selectOrderExcepTimeByList(List<String> orderNumbers);
 
     List<MetaHanaSalesOrder> selectDistinctMetaHanaSalesOrder1(MetaHanaSalesOrder metaHanaSalesOrder);
+
+    /**
+     * @description:查询信用未通过的要货记录id集合
+     * @param: []
+     * @return: java.util.List<java.lang.String>
+     * @author: njs
+     * @date: 2023/6/16 10:11
+     */
+    List<String> selectOrderBaseList();
+
+    int  deleteLogic(List<String> ids);
 }

suishenbang-order/src/main/java/com/dgtly/order/service/IMetaHanaSalesOrderService.java

@@ -25,6 +25,15 @@ public interface IMetaHanaSalesOrderService {
      */
 
     List<MetaHanaSalesOrder> selectDistinctMetaHanaSalesOrder(MetaHanaSalesOrder metaHanaSalesOrder);
-
+    
+    
+    /**
+     * @description: 未过信的经销商订单的要货记录id（做逻辑删除，重新要货）
+     * @param: 
+     * @return: 
+     * @author: njs     
+     * @date: 2023/6/16 9:01
+     */
+    void updateSalesOrderBaseNoCrditStatus();
 
 }

suishenbang-order/src/main/java/com/dgtly/order/service/impl/MetaHanaSalesOrderServiceImpl.java

@@ -52,5 +52,21 @@ public class MetaHanaSalesOrderServiceImpl implements IMetaHanaSalesOrderService
         return list;
     }
 
+    /**
+     * @description: 查询未过信的经销商订单的要货记录id（做逻辑删除，重新要货）
+     * @param:
+     * @return:
+     * @author: njs
+     * @date: 2023/6/16 9:01
+     */
+    @Override
+    public void updateSalesOrderBaseNoCrditStatus() {
+
+        List<String> orderBaseList = metaHanaSalesOrderMapper.selectOrderBaseList();
+        if(orderBaseList !=null && orderBaseList.size()>0){
+           metaHanaSalesOrderMapper.deleteLogic(orderBaseList);
+        }
+    }
+
 
 }

suishenbang-order/src/main/resources/mapper/order/MetaHanaSalesOrderMapper.xml

@@ -85,4 +85,27 @@
         </where>
     </select>
 
+    <select id="selectOrderBaseList" resultType="java.lang.String">
+        SELECT
+            ob.id
+        FROM
+            sales_order_base ob
+                LEFT JOIN meta_hana_sales_order so ON so.DOC_NUMBER = ob.order_number
+        WHERE
+            so.CREDIT_STATUS = '信用未通过' and ob.is_delete='0'
+        GROUP BY
+            ob.order_number
+    </select>
+
+    <update id="deleteLogic" parameterType="int">
+        UPDATE sales_order_base
+        SET is_delete = '1'
+        WHERE 1=1
+        <if test="ids !=null and ids.size > 0"> and id in
+        <foreach collection="ids" item="id" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+        </if>
+    </update>
+
 </mapper>

suishenbang-quartz/pom.xml

@@ -39,6 +39,10 @@
             <artifactId>suishenbang-sync-common</artifactId>
             <version>4.0.0</version>
         </dependency>
+        <dependency>
+            <groupId>com.dgtly</groupId>
+            <artifactId>suishenbang-order</artifactId>
+        </dependency>
 
     </dependencies>
 	

suishenbang-quartz/src/main/java/com/dgtly/quartz/task/RyTask.java

@@ -1,6 +1,7 @@
 package com.dgtly.quartz.task;
 
 import com.dgtly.common.utils.StringUtils;
+import com.dgtly.order.service.IMetaHanaSalesOrderService;
 import com.dgtly.sync.service.AnalysisDiyCustomerComponent;
 import com.dgtly.sync.service.HanaOrderComponent;
 import com.dgtly.sync.service.RelationCustomerOnlineComponent;
@@ -30,6 +31,8 @@ public class RyTask
     private ISysUserOrderAuthorService sysUserOrderAuthorService;
     @Autowired
     private IWxSendMessageService wxSendMessageService;
+    @Autowired
+    private IMetaHanaSalesOrderService metaHanaSalesOrderService;
 
 //    private static RyTask ryTask;
 //    @PostConstruct
@@ -146,4 +149,15 @@ public class RyTask
     public void sendWxTmsMessage(){
         wxSendMessageService.sendWxTmsMessage();
     }
+
+    /**
+     * @description: 未过信的经销商订单的要货记录id（做逻辑删除，重新要货）
+     * @param: []
+     * @return: void
+     * @author: njs
+     * @date: 2023/6/16 10:26
+     */
+    public void  salesOrderBaseByCreditStatus(){
+        metaHanaSalesOrderService.updateSalesOrderBaseNoCrditStatus();
+    }
 }