【功能修改】app 端:省核验人员:根据仓房核验

delivery-module-core/delivery-module-core-biz/src/main/java/com/unis/module/coding/controller/admin/task/vo/TaskCaxxRespVO.java

@@ -41,4 +41,7 @@ public class TaskCaxxRespVO {
     @Schema(description = "委托保管参考价(元/吨/月)")
     private Integer wtbgckj;
 
+    @Schema(description = "核验状态(0:待查验,1:查验通过,2:查验不通过)")
+    private Integer hyState;
+
 }

delivery-module-core/delivery-module-core-biz/src/main/java/com/unis/module/coding/controller/admin/task/vo/TaskPageReqVO.java

@@ -76,4 +76,7 @@ public class TaskPageReqVO extends PageParam {
     @Schema(description = "出入库类型(0:出库,1:入库)")
     private Integer crklx;
 
+    @Schema(description = "仓房名称")
+    private String cfmc;
+
 }

delivery-module-core/delivery-module-core-biz/src/main/java/com/unis/module/coding/controller/admin/task/vo/TaskRespVO.java

@@ -51,6 +51,12 @@ public class TaskRespVO {
     @Schema(description = "核验数量")
     private Integer hyNum;
 
+    @Schema(description = "核验通过数量")
+    private Integer hytgNum;
+
+    @Schema(description = "核验不通过数量")
+    private Integer hybtgNum;
+
     @Schema(description = "社会信用代码")
     private String shxydm;
 

delivery-module-core/delivery-module-core-biz/src/main/java/com/unis/module/coding/dal/dataobject/caxx/CaxxDO.java

@@ -1,11 +1,9 @@
 package com.unis.module.coding.dal.dataobject.caxx;
 
-import com.alibaba.excel.annotation.ExcelProperty;
 import com.baomidou.mybatisplus.annotation.KeySequence;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.unis.framework.mybatis.core.dataobject.BaseDO;
-import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.*;
 
 import java.math.BigDecimal;
@@ -125,4 +123,7 @@ public class CaxxDO extends BaseDO {
      * 客户身份证号(社会统一信用代码)
      */
     private String khbh;
+
+    /** 备选状态 */
+    private Integer bxzt;
 }

delivery-module-core/delivery-module-core-biz/src/main/java/com/unis/module/coding/dal/mysql/bank/BankMapper.java

@@ -10,7 +10,6 @@ import com.unis.framework.mybatis.core.query.LambdaQueryWrapperX;
 import com.unis.module.coding.controller.admin.bank.vo.BankPageReqVO;
 import com.unis.module.coding.controller.admin.delivery.vo.StoreRespVO;
 import com.unis.module.coding.dal.dataobject.bank.BankDO;
-import com.unis.module.coding.dal.dataobject.province.ProvinceDO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -67,7 +66,7 @@ public interface BankMapper extends BaseMapperX<BankDO> {
         );
     }
 
-    default void updateByKqId(BankDO bankDO, Long kqId){
-        update(bankDO, new LambdaQueryWrapperX<BankDO>().eq(BankDO::getKqId,kqId));
+    default void updateByKqId(BankDO bankDO, Long kqId, List<Long> caIds){
+        update(bankDO, new LambdaQueryWrapperX<BankDO>().eq(BankDO::getKqId,kqId).inIfPresent(BankDO::getCaId, caIds));
     }
 }

delivery-module-core/delivery-module-core-biz/src/main/java/com/unis/module/coding/dal/mysql/province/ProvinceMapper.java

@@ -1,18 +1,13 @@
 package com.unis.module.coding.dal.mysql.province;
 
-import java.util.*;
-
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.unis.framework.common.pojo.PageResult;
-import com.unis.framework.common.util.object.ObjectUtils;
 import com.unis.framework.mybatis.core.mapper.BaseMapperX;
 import com.unis.framework.mybatis.core.query.LambdaQueryWrapperX;
 import com.unis.module.coding.controller.admin.delivery.vo.StorePageReqVO;
 import com.unis.module.coding.controller.admin.delivery.vo.StoreRespVO;
 import com.unis.module.coding.controller.admin.province.vo.ProvincePageReqVO;
-import com.unis.module.coding.dal.dataobject.bank.BankDO;
-import com.unis.module.coding.dal.dataobject.caxx.CaxxDO;
 import com.unis.module.coding.dal.dataobject.province.ProvinceDO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -40,8 +35,8 @@ public interface ProvinceMapper extends BaseMapperX<ProvinceDO> {
                 .orderByDesc(ProvinceDO::getId));
     }
 
-    default void updateByKqId(ProvinceDO provinceDO,Long kqId){
-        update(provinceDO, new LambdaQueryWrapperX<ProvinceDO>().eq(ProvinceDO::getKqId,kqId));
+    default void updateByKqId(ProvinceDO provinceDO,Long kqId, List<Long> caIds){
+        update(provinceDO, new LambdaQueryWrapperX<ProvinceDO>().eq(ProvinceDO::getKqId,kqId).inIfPresent(ProvinceDO::getCaId, caIds));
     }
     default List<ProvinceDO> selectListByKqId(Long  kqId) {
         List<ProvinceDO> provinceList = selectList(

delivery-module-core/delivery-module-core-biz/src/main/java/com/unis/module/coding/service/task/TaskServiceImpl.java

@@ -19,6 +19,7 @@ import com.unis.module.coding.dal.dataobject.kqxx.KqxxDO;
 import com.unis.module.coding.dal.dataobject.province.ProvinceDO;
 import com.unis.module.coding.dal.dataobject.users.UsersDO;
 import com.unis.module.coding.dal.mysql.bank.BankMapper;
+import com.unis.module.coding.dal.mysql.caxx.CaxxMapper;
 import com.unis.module.coding.dal.mysql.cwxx.CwxxMapper;
 import com.unis.module.coding.dal.mysql.cwxxyear.CwxxYearMapper;
 import com.unis.module.coding.dal.mysql.dk.DkMapper;
@@ -39,6 +40,7 @@ import org.springframework.validation.annotation.Validated;
 import javax.annotation.Resource;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Objects;
 import java.util.Set;
 
 import static com.unis.framework.common.exception.util.ServiceExceptionUtil.exception;
@@ -72,7 +74,8 @@ public class TaskServiceImpl implements TaskService {
     private BankMapper bankMapper;
     @Resource
     private UsersMapper usersMapper;
-
+    @Resource
+    private CaxxMapper caxxMapper;
     @Override
     public IPage<TaskRespVO> getTaskList(TaskPageReqVO pageReqVO) {
         // 根据角色不同，查询不同数据
@@ -85,7 +88,7 @@ public class TaskServiceImpl implements TaskService {
     @Override
     public IPage<TaskRespVO> getAllStoreroomList(TaskPageReqVO pageReqVO) {
         // 根据角色不同，查询不同数据
-        addParamDeptIds(pageReqVO);
+                addParamDeptIds(pageReqVO);
 
         IPage<TaskRespVO> page = new Page<>(pageReqVO.getPageNo(), pageReqVO.getPageSize());
         return dkMapper.getAllStoreroomList(page, pageReqVO);
@@ -126,8 +129,13 @@ public class TaskServiceImpl implements TaskService {
                         .setHyState(reqVO.getHyState())
                         .setHyryId(SecurityFrameworkUtils.getLoginUserId())
                         .setHyryName(SecurityFrameworkUtils.getLoginUserNickname());
-                provinceMapper.updateByKqId(provinceDO, kqId);
+                provinceMapper.updateByKqId(provinceDO, kqId, reqVO.getCaIds());
             });
+
+            //修改仓房信息:备选状态:
+            if(Objects.equals(DeliveryHyState.YES_HY.getCode(), reqVO.getHyState())){
+//                caxxMapper.updateByKqId();
+            }
         }
         // 银行核验人员
         if(roleCodes.contains(RoleCodeEnum.BANK_VERIFICATION_PERSONNEL.getCode())) {
@@ -136,8 +144,13 @@ public class TaskServiceImpl implements TaskService {
                         .setHyState(reqVO.getHyState())
                         .setHyryId(SecurityFrameworkUtils.getLoginUserId())
                         .setHyryName(SecurityFrameworkUtils.getLoginUserNickname());
-                bankMapper.updateByKqId(bankDO, kqId);
+                bankMapper.updateByKqId(bankDO, kqId, reqVO.getCaIds());
             });
+
+            //修改仓房信息:备选状态:todo
+            if(Objects.equals(DeliveryHyState.YES_HY.getCode(), reqVO.getHyState())){
+//                caxxMapper.updateByKqId();
+            }
         }
         return true;
     }
@@ -165,6 +178,11 @@ public class TaskServiceImpl implements TaskService {
                             .setId(YitIdHelper.nextId())
                             .setKqId(taskCaxxRespVO.getKqId())
                             .setCaId(taskCaxxRespVO.getCaId())));
+
+            //修改仓房信息:备选状态:
+            if(Objects.equals(DeliveryHyState.YES_HY.getCode(), reqVO.getHyState())){
+//                caxxMapper.updateByKqId();
+            }
         }
 
         return true;

delivery-module-core/delivery-module-core-biz/src/main/resources/mapper/dk/DkMapper.xml

@@ -15,7 +15,9 @@
             dp.HY_STATE ,
             dk.SHXYDM ,
             dk.KQBM ,
-            COUNT(distinct dc.ID) AS HY_NUM
+            COUNT(distinct dc.ID) AS HY_NUM,
+            SUM(CASE WHEN dp.HY_STATE = 1 THEN 1 ELSE 0 END) AS HYTG_NUM,
+            SUM(CASE WHEN dp.HY_STATE = 2 THEN 1 ELSE 0 END) AS HYBTG_NUM
         FROM
             ${pageReqVO.tableName} dp
         LEFT JOIN DELIVERY_CAXX dc ON dp.CA_ID = dc.ID
@@ -263,7 +265,8 @@
             dc.SJSYNX,
             dc.SFKC,
             dk."zcckj",
-            dk."wtbgckj"
+            dk."wtbgckj",
+            dp.HY_STATE
         FROM
             ${pageReqVO.tableName} dp
             LEFT JOIN DELIVERY_CAXX dc ON dp.CA_ID = dc.ID
@@ -280,6 +283,9 @@
         <if test="pageReqVO.bankType != null and pageReqVO.bankType != ''">
             AND FIND_IN_SET(#{pageReqVO.bankType},dp.RDYH_ID)
         </if>
+        <if test="pageReqVO.cfmc != null and pageReqVO.cfmc != ''">
+            AND dc.CFMC LIKE CONCAT('%', #{pageReqVO.cfmc}, '%')
+        </if>
         <if test="pageReqVO.kqIds != null and pageReqVO.kqIds.size() > 0">
             AND dp.KQ_ID IN
             <foreach collection="pageReqVO.kqIds" item="kqId" open="(" separator="," close=")">