新建并完成查询总存栏，母猪存栏功能。

huimv-hy-production/huimv.hy.erp.datasource/src/main/java/com/huimv/production/datasource/dao/repo/TDeliveryRepo.java

@@ -215,4 +215,85 @@ public interface TDeliveryRepo extends JpaRepository<TDeliveryEntity, String>, J
             "group by tmp_tblpz.HogpendID) tmp_tblpzlc on tmp_tblpzlc.ZCID=tmp_tblpz.ZCID " +
             "left join TOrganizeCell on tmp_tblpz.ZCID=TOrganizeCell.FID")
     List<Object[]> getConceptionRate(String startDate, String endDate);
+
+    /**
+     * @Method      : getAllStorage
+     * @Description : 总存栏，母猪存栏
+     * @Params      : []
+     * @Return      : java.util.List<java.lang.Object[]>
+     * 
+     * @Author      : ZhuoNing
+     * @Date        : 2021/5/15       
+     * @Time        : 16:22
+     */
+    @Query(nativeQuery = true,value ="SELECT " +
+            "H.FNAME AS 'farm', " +
+            "mzcl AS 'sow_quantity', " +
+            "gz + mzcl + jc + shbamount AS 'total'  " +
+            "FROM (SELECT " +
+            "TOrganizeCell.FID, " +
+            "TOrganizeCell.FName  " +
+            "FROM TOrganizeCell  " +
+            "GROUP BY " +
+            "TOrganizeCell.FName, " +
+            "TOrganizeCell.FID  " +
+            ") H RIGHT JOIN ( " +
+            "SELECT " +
+            "tblz_tmp.FNAME AS NAME, " +
+            "isnull( SUM( tblz_tmp.gz ), 0 ) AS 'gz', " +
+            "isnull( sum( tblz_tmp.mzcl ), 0 ) AS 'mzcl', " +
+            "isnull( SUM( tblz_tmp.jc ), 0 ) AS 'jc', " +
+            "isnull( SUM( tblz_tmp.shbamount ), 0 ) AS 'shbamount'  " +
+            "FROM ( SELECT " +
+            "TPigArchives.HOGPENWHEREDID 'FNAME', " +
+            "CASE " +
+            "WHEN TPigArchives.FPIGSTATEE IN ( 2, 11 )  " +
+            "AND TPigArchives.FPigClassEnum = 1 THEN " +
+            "COUNT( TPigArchives.FID )  " +
+            "END AS 'gz', " +
+            "CASE " +
+            "WHEN TPigArchives.FPigStatee IN ( 3, 4, 5, 6, 7, 10, 11, 12, 13 )  " +
+            "AND TPigArchives.FPigClassEnum = 2 THEN " +
+            "COUNT( TPigArchives.FID )  " +
+            "END AS 'mzcl', " +
+            "0 AS 'jc', " +
+            "0 AS 'shbamount'  " +
+            "FROM " +
+            "TPigArchives  " +
+            "WHERE " +
+            "TPigArchives.FPigStatee IN ( 2, 3, 4, 5, 6, 7, 10, 11, 12, 13 )  " +
+            "GROUP BY " +
+            "TPigArchives.HOGPENWHEREDID, " +
+            "TPigArchives.FPIGSTATEE, " +
+            "TPigArchives.FPigClassEnum UNION ALL " +
+            "SELECT " +
+            "TPigArchives.HOGPENWHEREDID 'FNAME', " +
+            "0 AS 'gz', " +
+            "0 AS 'mzcl', " +
+            "CASE " +
+            "WHEN TPigArchives.FPigStatee IN ( 15, 14, 1, 21, 22, 16 ) THEN " +
+            "isnull( SUM( TPigArchivesChild.FpigAmountOfPigsty ), 0 )  " +
+            "END AS 'jc', " +
+            "CASE " +
+            "WHEN TPigArchives.FPigStatee = 11  " +
+            "AND TPigArchives.FPigClassEnum = 3 THEN " +
+            "isnull( SUM( TPigArchivesChild.FpigAmountOfPigsty ), 0 )  " +
+            "END AS 'shbamount'  " +
+            "FROM " +
+            "TPigArchives " +
+            "LEFT JOIN TPigArchivesChild ON TPigArchivesChild.FPigArchivesMainStruID = TPigArchives.FID  " +
+            "WHERE " +
+            "TPigArchives.FPigClassEnum IN ( 1, 2, 3 )  " +
+            "AND TPigArchives.FBATCHSTATE = 0  " +
+            "GROUP BY " +
+            "TPigArchives.HOGPENWHEREDID, " +
+            "TPigArchives.FPIGSTATEE, " +
+            "TPigArchives.FPigClassEnum  " +
+            ") tblz_tmp  " +
+            "GROUP BY " +
+            "tblz_tmp.FNAME  " +
+            ") AS tbls_tmp ON tbls_tmp.NAME = H.fid  " +
+            "ORDER BY " +
+            "H.FNAME")
+    List<Object[]> getAllStorage();
 }

huimv-hy-production/huimv.hy.erp.datasource/src/main/java/com/huimv/production/datasource/service/impl/ErpDataServiceImpl.java

@@ -256,6 +256,19 @@ public class ErpDataServiceImpl implements IErpDataService {
      */
     @Override
     public String getAllStorage() {
-        return null;
+        List<Object[]> fieldList = tDeliveryRepo.getAllStorage();
+        log.info(" 总存栏，母猪存栏查询数量:"+fieldList.size());
+        JSONArray resultJa = new JSONArray();
+        for (Object[] fieldObj : fieldList) {
+            String farm = fieldObj[0].toString();
+            String sow_quantity = fieldObj[1].toString();
+            String total = fieldObj[2].toString();
+            JSONObject dataJo = new JSONObject();
+            dataJo.put("farm",farm);
+            dataJo.put("sow_quantity",sow_quantity);
+            dataJo.put("total",total);
+            resultJa.add(dataJo);
+        }
+        return resultJa.toJSONString();
     }
 }