Kaynağa Gözat

Merge remote-tracking branch 'origin/main'

# Conflicts:
#	ship-server-web/src/main/resources/application-sxtest.yaml
lishiqiang 3 gün önce
ebeveyn
işleme
14f028dbb6

+ 1 - 1
ship-module-product/ship-module-product-biz/src/main/java/com/yc/ship/module/product/dal/mysql/voyagestockdistribute/VoyageStockDistributeNewMapper.java

@@ -64,7 +64,7 @@ public interface VoyageStockDistributeNewMapper extends BaseMapperX<VoyageStockD
     @Select("SELECT" +
             "    SUM(p.book_num + p.num) AS totalNum," +
             "    p.room_model_id as roomModelId," +
-            "    p.num," +
+            "    SUM(p.num) as num," +
             "    p.floor as floor " +
             "FROM " +
             "    product_voyage_stock_distribute_new p " +

+ 2 - 1
ship-module-resource/ship-module-resource-biz/src/main/java/com/yc/ship/module/resource/dal/mysql/roommodel/ResourceRoomModelMapper.java

@@ -42,7 +42,8 @@ public interface ResourceRoomModelMapper extends BaseMapperX<ResourceRoomModelDO
         return selectList(new LambdaQueryWrapperX<ResourceRoomModelDO>()
                 .eqIfPresent(ResourceRoomModelDO::getShipId, shipId)
                 .eq(ResourceRoomModelDO::getStatus, CommonStatusEnum.ENABLE.getStatus())
-                .eq(ResourceRoomModelDO::getCanSale, YesOrNoEnum.YES.getType()));
+                .eq(ResourceRoomModelDO::getCanSale, YesOrNoEnum.YES.getType())
+                .orderByAsc(ResourceRoomModelDO::getSort));
     }
 
     default PageResult<ResourceRoomModelDO> selectAppPage(AppResourceRoomModelPageReqVO pageReqVO) {

+ 1 - 0
ship-module-trade/ship-module-trade-biz/src/main/java/com/yc/ship/module/trade/controller/admin/order/vo/order/TradeOrderPageReqVO.java

@@ -232,6 +232,7 @@ public class TradeOrderPageReqVO extends PageParam {
 
 
     private String roomModelId;
+    private List<String> roomModelIds;
     private String floor;
 
     private Integer isInsure;

+ 5 - 1
ship-module-trade/ship-module-trade-biz/src/main/java/com/yc/ship/module/trade/service/order/impl/TradeOrderServiceImpl.java

@@ -170,7 +170,11 @@ public class TradeOrderServiceImpl implements TradeOrderService {
         List<Long> currentRoleList = roleApi.getCurrentRoleList();
         log.info("查询TradeOrder任务开始时间{}", LocalDateTime.now());
         List<Long> orderIds = tradeOrderMapper.findOrderIdsByCondition(page, pageReqVO);
-        List<TradeOrderRespVO> records = tradeOrderMapper.findOrderDetailByIds(orderIds);
+        List<TradeOrderRespVO> records = new ArrayList<>();
+        if(!orderIds.isEmpty()){
+            records = tradeOrderMapper.findOrderDetailByIds(orderIds);
+        }
+
         IPage<TradeOrderRespVO> iPage = page.setRecords( records);
 //        IPage<TradeOrderRespVO> iPage = tradeOrderMapper.getTradeOrderUserPage(page, pageReqVO);
         log.info("查询TradeOrder任务结束时间{}", LocalDateTime.now());

+ 6 - 3
ship-module-trade/ship-module-trade-biz/src/main/java/com/yc/ship/module/trade/service/otc/impl/OtcTradeOrderServiceImpl.java

@@ -1218,7 +1218,9 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
             tradeOrderAuditDO.setTenantId(tradeOrderDO.getTenantId());
             tradeOrderAuditMapper.insert(tradeOrderAuditDO);
 
-            if (tradeOrderDO.getAuditStatus() + 1 > tradeOrderDO.getAuditType()) {
+//            if (tradeOrderDO.getAuditStatus() + 1 > tradeOrderDO.getAuditType()) {
+            // 20260529 取消审核流程修改为 销售-计调 二级审核
+            if (tradeOrderDO.getAuditStatus() + 1 == 3) {
                 BigDecimal supplementAmount = tradeOrderDO.getRealPayAmount().subtract(damaged);
                 int isSupplement = supplementAmount.compareTo(BigDecimal.ZERO) > 0 ? 0 : 1;
                 try {
@@ -1246,7 +1248,8 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
                 }
 
                 tradeOrderMapper.update(Wrappers.<TradeOrderDO>lambdaUpdate()
-                        .set(TradeOrderDO::getAuditStatus, tradeOrderDO.getAuditStatus() + 1)
+//                        .set(TradeOrderDO::getAuditStatus, tradeOrderDO.getAuditStatus() + 1)
+                        .set(TradeOrderDO::getAuditStatus, 5)
                         .set(TradeOrderDO::getUpdateTime, LocalDateTime.now())
                         .set(TradeOrderDO::getDamagedStatus, 2)
                         .set(TradeOrderDO::getSupplementAmount, supplementAmount)
@@ -2964,7 +2967,7 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
                             auditType = 0;
                         }
                     }
-                    orderPolicyMapper.insertBatch(orderPolicyDOList);
+//                    orderPolicyMapper.insertBatch(orderPolicyDOList);
                 }
             }
             if (!CollUtil.isEmpty(createVO.getPolicyList()) &&isAudit) {

+ 14 - 8
ship-module-trade/ship-module-trade-biz/src/main/resources/mapper/order/TradeOrderMapper.xml

@@ -502,9 +502,9 @@
         FROM trade_order td
         INNER JOIN trade_order_user tou ON td.id = tou.order_id AND tou.deleted = 0
         LEFT JOIN trade_detail tdl ON td.id = tdl.order_id AND tdl.deleted = 0
-        LEFT JOIN product_spu ps ON ps.id = tdl.product_id
-        LEFT JOIN ota_distributor od ON od.id = td.source_id
-        LEFT JOIN trade_order_room_model torm ON torm.order_id = td.id
+        LEFT JOIN product_spu ps ON ps.id = tdl.product_id and ps.deleted=0
+        LEFT JOIN ota_distributor od ON od.id = td.source_id and od.deleted=0
+        LEFT JOIN trade_order_room_model torm ON torm.order_id = td.id and torm.deleted=0
         WHERE td.deleted = 0
 
         <if test="vo.orderStatus!=null and vo.orderStatus.size()>0">
@@ -665,6 +665,12 @@
         <if test="vo.roomModelId != null and vo.roomModelId != ''">
             AND torm.room_model_id = #{vo.roomModelId}
         </if>
+        <if test="vo.roomModelIds!=null and vo.roomModelIds.size()>0">
+            and  torm.room_model_id in
+            <foreach collection="vo.roomModelIds" item="item" separator=","  open="(" close=")">
+                #{item}
+            </foreach>
+        </if>
         <if test="vo.floor != null and vo.floor != ''">
             AND torm.floor = #{vo.floor}
         </if>
@@ -696,19 +702,19 @@
         ps.product_tag productTag,
         ps.product_tag2 productTag2
         FROM trade_order td
-        INNER JOIN trade_order_user tou ON td.id = tou.order_id
+        INNER JOIN trade_order_user tou ON td.id = tou.order_id AND tou.deleted = 0
         LEFT JOIN trade_detail tdl ON td.id = tdl.order_id AND tdl.deleted = 0
-        LEFT JOIN product_spu ps ON ps.id = tdl.product_id
-        LEFT JOIN trade_order_audit toa ON toa.order_id = td.id AND toa.audit_status = 1
+        LEFT JOIN product_spu ps ON ps.id = tdl.product_id and ps.deleted = 0
+        LEFT JOIN trade_order_audit toa ON toa.order_id = td.id AND toa.audit_status = 1 AND toa.deleted = 0
         LEFT JOIN (
         SELECT order_id,
         sum(refund_amount) refund_amount,
         sum(origin_amount) origin_amount
         FROM trade_refund
-        WHERE refund_status = 6 AND refund_method != 2
+        WHERE refund_status = 6 AND refund_method != 2 AND deleted = 0
         GROUP BY order_id
         ) tr ON td.id = tr.order_id
-        LEFT JOIN trade_insurance tins ON tins.order_id = td.id
+        LEFT JOIN trade_insurance tins ON tins.order_id = td.id AND tins.deleted = 0
         WHERE td.id IN
         <foreach collection="ids" item="id" open="(" close=")" separator=",">
             #{id}

+ 1 - 5
ship-server-web/src/main/resources/application-sxtest.yaml

@@ -57,10 +57,6 @@ spring:
           url: jdbc:mysql://10.3.10.50:43306/db_yc_ship_sx?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
           username: root
           password: W1ses0ft@zshl
-        log:
-          url: jdbc:mysql://10.3.10.50:43306/db_ship_log?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true # MySQL Connector/J 8.X 连接的示例
-          username: root
-          password: W1ses0ft@zshl
 
   # Redis 配置。Redisson 默认的配置足够使用,一般不需要进行调优
   redis:
@@ -240,7 +236,7 @@ yudao:
     in: http://10.3.10.50:80/
   suffixCode: QS # 票号后缀
   notify: # 第三方通知接口
-    insurance: ${yudao.host.out}/${yudao.web.admin-url}/notify/insurance # 保单通知接口
+    insurance: https://tms2.hbsxly.com/ship-ota-api/notify/insurance # 保单通知接口
 justauth:
   enabled: true
   type: