aps-生产卡片查询优化

cx-aps/cx-aps-common/src/main/java/com/rongwei/bscommon/sys/dao/ApsProcessOperationProcessEquDao.java

@@ -11,6 +11,7 @@ import org.apache.ibatis.annotations.Update;
 
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 
 /**
@@ -169,6 +170,11 @@ public interface ApsProcessOperationProcessEquDao extends BaseMapper<ApsProcessO
     void updateProcessEquBatchById(@Param("list") List<ApsProcessOperationProcessEquDo> list);
 
     void saveOrUpdateDeliverOffsetBatch(@Param("list") List<ApsDeliveryOffsetDo> needUpdateOrInsertList);
+
+    List<Map<String, Object>> getCardListPage(@Param("offset") Integer offset, @Param("size") Integer size,@Param("sql") String sql);
+
+    @Select("SELECT FOUND_ROWS() AS total")
+    Integer getTotal();
 }
 
 

cx-aps/cx-aps-common/src/main/java/com/rongwei/bscommon/sys/service/ApsProcessOperationProcessEquService.java

@@ -1,5 +1,6 @@
 package com.rongwei.bscommon.sys.service;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.rongwei.bsentity.domain.ApsProcessOperationDo;
 import com.rongwei.bsentity.domain.ApsProcessOperationProcessEquDo;
@@ -12,6 +13,7 @@ import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 /**
  *
@@ -60,4 +62,7 @@ public interface ApsProcessOperationProcessEquService extends IService<ApsProces
     R workShopImport(MultipartFile multipartFile, HttpServletResponse response) throws IOException;
 
     R workDeliveryOffset(WorkDeliveryOffsetReq req);
+
+    R getCardListData(CriteriaQuery query);
+    void queryCard(IPage<Map<String, Object>> result, CriteriaQuery query);
 }

cx-aps/cx-aps-common/src/main/java/com/rongwei/bscommon/sys/service/impl/ApsProcessOperationProcessEquServiceImpl.java

@@ -17,6 +17,8 @@ import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.google.common.collect.Lists;
 import com.rongwei.bscommon.sys.dao.ApsDeliveryOffsetDao;
@@ -26,11 +28,13 @@ import com.rongwei.bscommon.sys.listener.WorkShopImportListener;
 import com.rongwei.bscommon.sys.service.*;
 import com.rongwei.bsentity.domain.*;
 import com.rongwei.bsentity.vo.*;
+import com.rongwei.rwadmincommon.system.service.SysGeneralCRUDService;
 import com.rongwei.rwadmincommon.system.vo.SysUserVo;
 import com.rongwei.rwcommon.base.R;
 import com.rongwei.rwcommon.base.exception.CustomException;
 import com.rongwei.rwcommon.utils.SecurityUtil;
 import com.rongwei.rwcommon.utils.StringUtils;
+import com.rongwei.rwcommon.vo.CriteriaBuilder;
 import com.rongwei.rwcommon.vo.CriteriaQuery;
 import com.rongwei.rwcommon.vo.MailDo;
 import com.rongwei.safecommon.fegin.CXAdminFeginClient;
@@ -130,6 +134,8 @@ public class ApsProcessOperationProcessEquServiceImpl extends ServiceImpl<ApsPro
     private ApsDeliveryOffsetDao apsDeliveryOffsetDao;
     @Resource
     private CXCommonFeginClient cxCommonFeginClient;
+    @Autowired
+    private SysGeneralCRUDService sysGeneralCRUDService;
 
 //    /**
 //     * 更新工序的待加工批次号信息
@@ -3029,7 +3035,7 @@ public class ApsProcessOperationProcessEquServiceImpl extends ServiceImpl<ApsPro
             currentUser = new SysUserVo();
             currentUser.setId("0");
             currentUser.setName("定时任务操作");
-        }else {
+        } else {
             tenantId = CXCommonUtils.getCurrentUserFactoryId(currentUser);
         }
         //查询所有没有交期偏差的生产卡片
@@ -3300,6 +3306,40 @@ public class ApsProcessOperationProcessEquServiceImpl extends ServiceImpl<ApsPro
             }
         }
     }
+
+    @Override
+    public R getCardListData(CriteriaQuery query) {
+        try {
+
+            query.setQuerySql(sysGeneralCRUDService.sqlStrReplaceByMap(query));
+
+            if (query.getQuerySql() != null && query.getQuerySql().contains("@{userId}")) {//替换占位符
+                query.setQuerySql(sysGeneralCRUDService.replaceSql(query));
+            }
+            CriteriaBuilder.initQuerySql(query);
+            query.setQuerySql(query.getQuerySql().replaceFirst("\\*", "SQL_CALC_FOUND_ROWS *"));
+            IPage<Map<String, Object>> result = new Page<>();
+            //开始事务
+            apsProcessOperationProcessEquService.queryCard(result, query);
+
+            return R.ok(result);
+        } catch (Exception e) {
+            log.error(StringUtils.spliceErrorMsg(e), e.fillInStackTrace());
+            return R.queryError();
+        }
+    }
+
+    @Transactional
+    public void queryCard(IPage<Map<String, Object>> result, CriteriaQuery query) {
+        int offset = (query.getCurrent()-1) * query.getSize();
+        List<Map<String, Object>> list = this.baseMapper.getCardListPage(offset, query.getSize(), query.getQuerySql());
+        Integer total = this.baseMapper.getTotal();
+
+        result.setCurrent(query.getCurrent());
+        result.setSize(query.getSize());
+        result.setRecords(list);
+        result.setTotal(total);
+    }
 }
 
 

cx-aps/cx-aps-common/src/main/resources/mybatis/ApsProcessOperationProcessEquDao.xml

@@ -998,4 +998,8 @@
           AND sur.ROLEID IN (select ID from sys_role where `CODE` IN ('role071','cjddzz'))
         GROUP BY su.TENANTID
     </select>
+    <select id="getCardListPage" resultType="java.util.Map">
+        ${sql}
+        LIMIT #{size} OFFSET #{offset}
+    </select>
 </mapper>

cx-aps/cx-aps-server/src/main/java/com/rongwei/bsserver/controller/ApsProcessOperationProcessEquController.java

@@ -1,10 +1,13 @@
 package com.rongwei.bsserver.controller;
 
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.rongwei.bscommon.sys.service.ApsProcessOperationProcessEquService;
 import com.rongwei.bscommon.sys.service.GanttService;
 import com.rongwei.bsentity.vo.*;
+import com.rongwei.rwadmincommon.system.service.SysGeneralCRUDService;
 import com.rongwei.rwcommon.base.R;
+import com.rongwei.rwcommon.utils.StringUtils;
 import com.rongwei.rwcommon.vo.CriteriaQuery;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -16,6 +19,7 @@ import org.springframework.web.multipart.MultipartFile;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -188,5 +192,10 @@ public class ApsProcessOperationProcessEquController {
         WorkDeliveryOffsetReq req = new WorkDeliveryOffsetReq();
         return apsProcessOperationProcessEquService.workDeliveryOffset(req);
     }
+
+    @PostMapping("/getCardListData")
+    public R getCardListData(@RequestBody CriteriaQuery query) {
+        return apsProcessOperationProcessEquService.getCardListData(query);
+    }
 }