From 0da1ca09aca992eb5a44ab0415b22e30870cb1bf Mon Sep 17 00:00:00 2001
From: hp <2969694837@qq.com>
Date: Tue, 6 Sep 2022 18:33:18 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E5=BA=93=E9=97=AE=E9=A2=98=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../api/basevehicle/AppScmWarehouseVinVo.java |  7 +-
 .../BaseVehicleTempstateFeign.java            |  4 +-
 .../biz/basevehicle/BaseVehicleMapper.xml     |  1 +
 .../biz/basevehicle/BaseVehicleService.java   |  7 ++
 .../BaseVehicleTempstateRest.java             | 79 +++++++++----------
 .../BaseVehicleTempstateService.java          | 12 +++
 .../busmaindeposit/BusMainDepositMapper.xml   | 13 ++-
 .../ScmVehicleGressionService.java            | 19 +++--
 8 files changed, 83 insertions(+), 59 deletions(-)

diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/AppScmWarehouseVinVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/AppScmWarehouseVinVo.java
index 20c7f3ed10..c1d1e4d8bc 100644
--- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/AppScmWarehouseVinVo.java
+++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/AppScmWarehouseVinVo.java
@@ -7,6 +7,10 @@ import lombok.Data;
 @Data
 public class AppScmWarehouseVinVo implements Vo {
 
+
+    @ApiModelProperty("车辆sid")
+    private String carSid;
+
     @ApiModelProperty("车架号")
     private String vin;
 
@@ -19,9 +23,6 @@ public class AppScmWarehouseVinVo implements Vo {
     @ApiModelProperty("")
     private String address;
 
-    @ApiModelProperty("")
-    private String carSid;
-
     @ApiModelProperty("")
     private String color;
 
diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicletempstate/BaseVehicleTempstateFeign.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicletempstate/BaseVehicleTempstateFeign.java
index 25effa8348..457b91f709 100644
--- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicletempstate/BaseVehicleTempstateFeign.java
+++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicletempstate/BaseVehicleTempstateFeign.java
@@ -50,8 +50,8 @@ import java.util.List;
  */
 @Api(tags = "车辆临时状态表")
 @FeignClient(
-        contextId = "comc-BaseVehicleTempstate",
-        name = "comc",
+        contextId = "anrui-base-BaseVehicleTempstate",
+        name = "anrui-base",
         path = "v1/basevehicletempstate",
         fallback = BaseVehicleTempstateFeignFallback.class)
 public interface BaseVehicleTempstateFeign {
diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.xml b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.xml
index 55dd947b1f..faa16d3bf7 100644
--- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.xml
+++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.xml
@@ -904,6 +904,7 @@
 
     <select id="getVinByWarehouseSid" resultType="com.yxt.anrui.base.api.basevehicle.AppScmWarehouseVinVo">
         select vinNo as vin,
+               sid as carSid,
                settlementStatus,
                settlementStatusValue
         from base_vehicle bv
diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java
index f10ae4464d..797abb790c 100644
--- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java
+++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java
@@ -17,6 +17,7 @@ import com.yxt.anrui.base.biz.basemodelconfig.BaseModelConfigService;
 import com.yxt.anrui.base.biz.basevehicleappendix.BaseVehicleAppendixService;
 import com.yxt.anrui.base.biz.basevehiclecertificate.BaseVehicleCertificateService;
 import com.yxt.anrui.base.biz.basevehiclemodelappendix.BaseVehicleModelAppendixService;
+import com.yxt.anrui.base.biz.basevehicletempstate.BaseVehicleTempstateService;
 import com.yxt.anrui.base.biz.basevehinstall.BaseVehinstallService;
 import com.yxt.anrui.base.biz.basevehmodelconfig.BaseVehmodelConfigService;
 import com.yxt.anrui.base.biz.commonappendix.CommonAppendixService;
@@ -95,6 +96,8 @@ public class BaseVehicleService extends MybatisBaseService<BaseVehicleMapper, Ba
     private CommonAppendixService commonAppendixService;
     @Autowired
     private BaseVehmodelConfigService baseVehmodelConfigService;
+    @Autowired
+    private BaseVehicleTempstateService baseVehicleTempstateService;
 
     /**
      * 车辆信息分页列表
@@ -1661,10 +1664,14 @@ public class BaseVehicleService extends MybatisBaseService<BaseVehicleMapper, Ba
     public ResultBean<List<AppScmWarehouseVinVo>> getVinByWarehouseSid(String warehouseSid, String userSid) {
         ResultBean rb = ResultBean.fireFail();
         QueryWrapper<BaseVehicle> qw = new QueryWrapper<>();
+        List<String> carSidList = baseVehicleTempstateService.selectAll();
         ResultBean<String> resultBean = sysStaffOrgFeign.getPathSidByUserSid(userSid);
         if (StringUtils.isNotBlank(resultBean.getData())) {
             qw.eq("bv.createOrgSid", resultBean.getData());
         }
+        if (carSidList.size() > 0) {
+            qw.notIn("bv.sid", carSidList);
+        }
         qw.and(wrapper -> wrapper.eq("bv.vehicleState", VehicleState.StockEnum.RETURNING_STOCK.getCode()).or().eq("bv.vehicleState", VehicleState.StockEnum.STOCK.getCode()).or().eq("bv.vehicleState", VehicleState.StockEnum.DR_STOCK.getCode()));
         List<AppScmWarehouseVinVo> list = baseMapper.getVinByWarehouseSid(warehouseSid, qw);
         if (list.size() <= 0) {
diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateRest.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateRest.java
index 9bd401c59a..86ee6f35de 100644
--- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateRest.java
+++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateRest.java
@@ -35,7 +35,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 
-
 /**
  * Project: comc(comc) <br/>
  * File: BaseVehicleTempstateFeignFallback.java <br/>
@@ -50,53 +49,53 @@ import org.springframework.web.bind.annotation.*;
  * @since 1.0
  */
 @Api(tags = "车辆临时状态表")
-@RestController("aaaa.biz.basevehicletempstate.BaseVehicleTempstateRest")
+@RestController("com.yxt.anrui.base.biz.basevehicletempstate.BaseVehicleTempstateRest")
 @RequestMapping("v1/basevehicletempstate")
 public class BaseVehicleTempstateRest implements BaseVehicleTempstateFeign {
 
-	@Autowired
-	private BaseVehicleTempstateService baseVehicleTempstateService;
+    @Autowired
+    private BaseVehicleTempstateService baseVehicleTempstateService;
 
-	@Override
-	@ApiOperation("根据条件分页查询数据的列表")
-	@PostMapping("/listPage")
-	public ResultBean<PagerVo<BaseVehicleTempstateVo>> listPage(@RequestBody PagerQuery<BaseVehicleTempstateQuery> pq){
-		ResultBean rb = ResultBean.fireFail();
-		PagerVo<BaseVehicleTempstateVo> pv = baseVehicleTempstateService.listPageVo(pq);
-		return rb.success().setData(pv);
-	}
+    @Override
+    @ApiOperation("根据条件分页查询数据的列表")
+    @PostMapping("/listPage")
+    public ResultBean<PagerVo<BaseVehicleTempstateVo>> listPage(@RequestBody PagerQuery<BaseVehicleTempstateQuery> pq) {
+        ResultBean rb = ResultBean.fireFail();
+        PagerVo<BaseVehicleTempstateVo> pv = baseVehicleTempstateService.listPageVo(pq);
+        return rb.success().setData(pv);
+    }
 
-	@Override
-	@ApiOperation("新增或修改")
-	@PostMapping("/save")
-	public ResultBean save(@RequestBody BaseVehicleTempstateDto dto){
-		ResultBean rb = ResultBean.fireFail();
-		baseVehicleTempstateService.saveOrUpdateDto(dto);
-		return rb.success();
-	}
+    @Override
+    @ApiOperation("新增或修改")
+    @PostMapping("/save")
+    public ResultBean save(@RequestBody BaseVehicleTempstateDto dto) {
+        ResultBean rb = ResultBean.fireFail();
+        baseVehicleTempstateService.saveOrUpdateDto(dto);
+        return rb.success();
+    }
 
-	@Override
-	@ApiOperation("根据sid批量删除")
+    @Override
+    @ApiOperation("根据sid批量删除")
     @PostMapping("/delBySids")
-    public ResultBean delBySids(@RequestBody String[] sids){
-		ResultBean rb = ResultBean.fireFail();
-		baseVehicleTempstateService.delBySids(sids);
-		return rb.success();
-	}
+    public ResultBean delBySids(@RequestBody String[] sids) {
+        ResultBean rb = ResultBean.fireFail();
+        baseVehicleTempstateService.delBySids(sids);
+        return rb.success();
+    }
 
-	@Override
-	@ApiOperation("根据SID获取一条记录")
+    @Override
+    @ApiOperation("根据SID获取一条记录")
     @GetMapping("/fetchDetailsBySid/{sid}")
-    public ResultBean<BaseVehicleTempstateDetailsVo> fetchDetailsBySid(@PathVariable("sid") String sid){
-		ResultBean rb = ResultBean.fireFail();
-		BaseVehicleTempstateDetailsVo vo = baseVehicleTempstateService.fetchDetailsVoBySid(sid);
-		return rb.success().setData(vo);
-	}
+    public ResultBean<BaseVehicleTempstateDetailsVo> fetchDetailsBySid(@PathVariable("sid") String sid) {
+        ResultBean rb = ResultBean.fireFail();
+        BaseVehicleTempstateDetailsVo vo = baseVehicleTempstateService.fetchDetailsVoBySid(sid);
+        return rb.success().setData(vo);
+    }
 
-	@Override
-	public ResultBean delByBusSid(String businessSid) {
-		ResultBean rb = ResultBean.fireFail();
-		baseVehicleTempstateService.delByBusSid(businessSid);
-		return rb.success();
-	}
+    @Override
+    public ResultBean delByBusSid(String businessSid) {
+        ResultBean rb = ResultBean.fireFail();
+        baseVehicleTempstateService.delByBusSid(businessSid);
+        return rb.success();
+    }
 }
diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateService.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateService.java
index 9de3dcdbd6..80c7d7adf6 100644
--- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateService.java
+++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicletempstate/BaseVehicleTempstateService.java
@@ -39,6 +39,7 @@ import com.yxt.common.core.vo.PagerVo;
 
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -107,4 +108,15 @@ public class BaseVehicleTempstateService extends MybatisBaseService<BaseVehicleT
     public void delByBusSid(String businessSid) {
         deleteBySid(businessSid);
     }
+
+    public List<String> selectAll() {
+        List<String> list = new ArrayList<>();
+        List<BaseVehicleTempstateVo> baseVehicleTempstateVos = baseMapper.selectListVo();
+        if (baseVehicleTempstateVos.size() > 0) {
+            for (BaseVehicleTempstateVo baseVehicleTempstateVo : baseVehicleTempstateVos) {
+                list.add(baseVehicleTempstateVo.getVehSid());
+            }
+        }
+        return list;
+    }
 }
\ No newline at end of file
diff --git a/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/busmaindeposit/BusMainDepositMapper.xml b/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/busmaindeposit/BusMainDepositMapper.xml
index 655023a8bd..b4faf1f731 100644
--- a/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/busmaindeposit/BusMainDepositMapper.xml
+++ b/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/busmaindeposit/BusMainDepositMapper.xml
@@ -37,7 +37,7 @@
 
     <!--虚拟订单列表-->
     <select id="getVirtualOrders" resultType="com.yxt.anrui.buscenter.api.busmaindeposit.AppBusMainDepositVo">
-        SELECT
+        select * from (SELECT
         bmd.sid AS virtualOrderSid,
         bmd.billNo AS virtualOrderId,
         bmd.createDate AS virtualOrderDate,
@@ -56,10 +56,10 @@
                 , #{name}
                 , '%')
             </if>
-        </where>
+        </where> order by bmd.id desc ) a
         <if test="name != '' and name != null">
             UNION ALL
-            SELECT
+           select * from( SELECT
             bmd.sid AS virtualOrderSid,
             bmd.billNo AS virtualOrderId,
             bmd.createDate AS virtualOrderDate,
@@ -78,9 +78,9 @@
                     , #{name}
                     , '%')
                 </if>
-            </where>
+            </where> order by bmd.id desc ) b
             UNION ALL
-            SELECT
+            select * from( SELECT
             bmd.sid AS virtualOrderSid,
             bmd.billNo AS virtualOrderId,
             bmd.createDate AS virtualOrderDate,
@@ -99,9 +99,8 @@
                     , #{name}
                     , '%')
                 </if>
-            </where>
+            </where> order by bmd.id desc ) c
         </if>
-        order by bmd.id desc
     </select>
 
     <delete id="deleteVirtualOrder">
diff --git a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehiclegression/ScmVehicleGressionService.java b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehiclegression/ScmVehicleGressionService.java
index a034492de8..216ba52c65 100644
--- a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehiclegression/ScmVehicleGressionService.java
+++ b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehiclegression/ScmVehicleGressionService.java
@@ -680,13 +680,6 @@ public class ScmVehicleGressionService extends MybatisBaseService<ScmVehicleGres
         }
         List<String> vins = dto.getVins();
         for (String vin : vins) {
-            //推送车辆移库状态
-            BaseVehicleVo baseVehicleVo = baseVehicleFeign.selVehicleByVinNo(vin).getData();
-            BaseVehicleTempstateDto baseVehicleTempstateDto = new BaseVehicleTempstateDto();
-            baseVehicleTempstateDto.setVehSid(baseVehicleVo.getSid());
-            baseVehicleTempstateDto.setTempStateKey("001");
-            baseVehicleTempstateDto.setBusSid(scmVehicleGression.getSid());
-            baseVehicleTempstateFeign.save(baseVehicleTempstateDto);
             List<String> sids = scmVehicleGressionVehService.fetchVoByVins(vin);
             for (String sid : sids) {
                 List<ScmVehicleGressionVo> scmVehicleGressionVos = baseMapper.getlastTimeEqual(sid, dto.getTargetLocationSid());
@@ -707,6 +700,18 @@ public class ScmVehicleGressionService extends MybatisBaseService<ScmVehicleGres
         String businessSid = resultBean.getData();
         String state = "2";
         baseMapper.updateStateBySid(businessSid, state);
+        //推送车辆移库状态
+        List<String> vinList = scmVehicleGressionVehService.fetchVoByMainSid(businessSid);
+        if (vinList.size() > 0) {
+            for (String s : vinList) {
+                BaseVehicleVo baseVehicleVo = baseVehicleFeign.selVehicleByVinNo(s).getData();
+                BaseVehicleTempstateDto baseVehicleTempstateDto = new BaseVehicleTempstateDto();
+                baseVehicleTempstateDto.setVehSid(baseVehicleVo.getSid());
+                baseVehicleTempstateDto.setTempStateKey("001");
+                baseVehicleTempstateDto.setBusSid(businessSid);
+                baseVehicleTempstateFeign.save(baseVehicleTempstateDto);
+            }
+        }
         //创建BusinessVariables实体对象
         BusinessVariables bv = new BusinessVariables();
         //流程中的参数赋值、若有网关，则赋值网关中判断的字段。