企业收支结余

Signed-off-by: tangsong <86121657@qq.com>

unis-plugin/unis-plugin-biz/src/main/java/com/unis/financialSupervision/modular/fsEnterpriseBalanceStatistic/mapper/FsEnterpriseBalanceStatisticMapper.java

@@ -26,6 +26,7 @@ import com.unis.financialSupervision.modular.fsEnterpriseBalanceStatistic.param.
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
 
+import java.math.BigDecimal;
 import java.util.List;
 
 /**
@@ -48,9 +49,10 @@ public interface FsEnterpriseBalanceStatisticMapper extends BaseMapper<FsEnterpr
      * @param orgId 库 区 ID
      * @param grainVarietyId 品种Id
      * @param year 年
+     * @param month 月
      * @return
      */
-    FsEnterpriseBalanceStatistic getRotationPlan(@Param("orgId") Integer orgId, @Param("grainVarietyId") Integer grainVarietyId, @Param("year") Integer year);
+    FsEnterpriseBalanceStatistic getRotationPlan(@Param("orgId") Integer orgId, @Param("grainVarietyId") Integer grainVarietyId, @Param("year") Integer year,@Param("month")Integer month);
 
     List<FsEnterpriseBalanceStatisticVO> getList(@Param("pageParam") FsEnterpriseBalanceStatisticPageParam pageParam);
 
@@ -63,4 +65,6 @@ public interface FsEnterpriseBalanceStatisticMapper extends BaseMapper<FsEnterpr
     IPage<FsEnterpriseBalanceStatisticVO> selectMyMapsPage(Page<FsEnterpriseBalanceStatisticVO> p,@Param(Constants.WRAPPER)QueryWrapper<FsEnterpriseBalanceStatisticVO> queryWrapper);
 
     List<CostBalanceVO> getCostBalanceList(@Param("costBalanceParam") CostBalanceParam costBalanceParam);
+
+    FsEnterpriseBalanceStatistic getStorageCostAccrued(@Param("orgId") Integer orgId, @Param("grainVarietyId") Integer grainVarietyId);
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/financialSupervision/modular/fsEnterpriseBalanceStatistic/mapper/mapping/FsEnterpriseBalanceStatisticMapper.xml

@@ -36,6 +36,8 @@
 
 		planQuantity*1000 as rotationPlanQuantity,
 		IFNULL((ckslSum+rkslSum)/(planQuantity*1000)*100,0) rotationCompletionRate,
+		IFNULL(rkslSum,0.0)*IFNULL(b.standard_value, 0.0)/10000 as rotationCostAccrued,
+		IFNULL(ckslSum,0.0)*IFNULL(b.standard_value, 0.0)/10000 as rotationCostExpenditure,
 		IFNULL(b.standard_value, 0.0) as rotationCostStandard
  FROM (SELECT
             g.org_id,
@@ -48,7 +50,7 @@
                                     depot_qh.data_kcgl_fcbgz_default m1
                     INNER JOIN depot_qh.data_crkyw_ckcmz_default m2 ON m1.DataID = m2.DataID
                     INNER JOIN depot_qh.data_crkyw_ckrmdj_default m3 ON m3.bizno = m2.bizno
-                    where m3.jhdID = a.rp_report_id AND m3.lspz = #{grainVarietyId}
+                    where m3.jhdID = a.rp_report_id AND m3.lspz = #{grainVarietyId} and DATE_FORMAT(m1.rq,'%m') = #{month}
             )  as "ckslSum",
              IFNULL(SUM(e.plan_quantity),0.0) as "inPlanQuantity",
             (   SELECT
@@ -57,7 +59,7 @@
                                     depot_qh.data_kcgl_fcbgz_default m1
                     INNER JOIN depot_qh.data_crkyw_cpz_default m2 ON m1.DataID = m2.DataID
                     INNER JOIN depot_qh.data_crkyw_rmdj_default m3 ON m3.bizno = m2.bizno
-                    where m3.jhdh = a.rp_report_id  AND m3.lspz = #{grainVarietyId}
+                    where m3.jhdh = a.rp_report_id  AND m3.lspz = #{grainVarietyId} and DATE_FORMAT(m1.rq,'%m') = #{month}
             )  as "rkslSum"
     FROM
      province_all.biz_rp_issuance a
@@ -222,4 +224,29 @@ AND b.grain_variety_id =#{grainVarietyId} and b.standard_type = 1
             a. MONTH
     ) x
     </select>
+    <select id="getStorageCostAccrued" resultType="com.unis.financialSupervision.modular.fsEnterpriseBalanceStatistic.entity.FsEnterpriseBalanceStatistic">
+        SELECT
+		kcsl*IFNULL(b.standard_value, 0.0)/10000 as storageCostAccrued,
+		IFNULL(ckslSum,0.0)*IFNULL(b.standard_value, 0.0)/10000 as storageCostExpenditure
+         FROM (
+                    SELECT
+                        g.org_id,
+                 a.kcsl ,
+            (   SELECT
+                     IFNULL(sum(m1.zcsl),0.0) as cksl
+                                    FROM
+                                    depot_qh.data_kcgl_fcbgz_default m1
+                                    INNER JOIN depot_qh.data_crkyw_ckcmz_default m2 ON m1.DataID = m2.DataID
+                                    INNER JOIN depot_qh.data_crkyw_ckrmdj_default m3 ON m3.bizno = m2.bizno
+                                    where m3.UnitID = a.UnitID AND m3.lspz = a.pz
+                    )  as "ckslSum"
+            FROM
+            depot_qh.data_kcgl_kcsw_default a
+            right JOIN  depot_qh.org_info  g on g.org_id = a.UnitID
+         where g.org_id = #{orgId}  AND a.pz = #{grainVarietyId}
+            GROUP BY g.org_id
+        ) x
+        LEFT JOIN depot_qh.business_fs_cost_standard b ON x.org_id = b.org_id
+        AND b.grain_variety_id =#{grainVarietyId} and b.standard_type = 2
+    </select>
 </mapper>

unis-plugin/unis-plugin-biz/src/main/java/com/unis/financialSupervision/modular/fsEnterpriseBalanceStatistic/service/impl/FsEnterpriseBalanceStatisticServiceImpl.java

@@ -44,6 +44,7 @@ import javax.servlet.http.HttpServletResponse;
 import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
+import java.math.BigDecimal;
 import java.util.List;
 
 /**
@@ -77,12 +78,74 @@ public class FsEnterpriseBalanceStatisticServiceImpl extends ServiceImpl<FsEnter
         for (FsEnterpriseBalanceStatistic balanceStatistic:balanceStatisticList) {
             Integer orgId = balanceStatistic.getOrgId();
             Integer grainVarietyId = balanceStatistic.getGrainVarietyId();
-            //得到轮换计划数据
-            FsEnterpriseBalanceStatistic rotationPlan = fsEnterpriseBalanceStatisticMapper.getRotationPlan(orgId,grainVarietyId,year);
-            if (rotationPlan != null){
-                balanceStatistic.setRotationPlanQuantity(rotationPlan.getRotationPlanQuantity()); //轮换计划数量
-                balanceStatistic.setRotationCompletionRate(rotationPlan.getRotationCompletionRate()); //轮换完成率
-                balanceStatistic.setRotationCostStandard(rotationPlan.getRotationCostStandard()); //轮换费用标准
+
+
+            //保管费只进行本年累计，如果月份为0，则不获取上月累计数据
+            BigDecimal storageCostAccrued = BigDecimal.ZERO;
+            BigDecimal storageCostExpenditure = BigDecimal.ZERO;
+            BigDecimal storageCostBalance = BigDecimal.ZERO;
+            Integer storageCostOverdraftMonth = 0; //保管费超支月数
+            //轮换费只进行本年累计，如果月份为0，则不获取上月累计数据
+            BigDecimal rotationCostAccrued = BigDecimal.ZERO;
+            BigDecimal rotationCostExpenditure = BigDecimal.ZERO;
+            BigDecimal rotationCostBalance = BigDecimal.ZERO;
+            Integer rotationCostOverdraftMonth = 0; //轮换费超支月数
+            if (month != 1){
+                //查询上月数据
+                QueryWrapper<FsEnterpriseBalanceStatistic> preQueryWrapper = new QueryWrapper<>();
+                preQueryWrapper.lambda()
+                        .eq(FsEnterpriseBalanceStatistic::getOrgId,orgId)
+                        .eq(FsEnterpriseBalanceStatistic::getPlanYear,year)
+                        .eq(FsEnterpriseBalanceStatistic::getMonth,month-1)
+                        .eq(FsEnterpriseBalanceStatistic::getGrainVarietyId,grainVarietyId);
+                FsEnterpriseBalanceStatistic balanceStatistic_pre = super.getOne(preQueryWrapper,false);
+                if (balanceStatistic_pre !=null){
+                    //保管费相关
+                    storageCostAccrued = balanceStatistic_pre.getStorageCostAccrued();
+                    storageCostExpenditure = balanceStatistic_pre.getStorageCostExpenditure();
+                    storageCostOverdraftMonth = balanceStatistic_pre.getStorageCostOverdraftMonth();
+                    //轮换费相关
+                    rotationCostAccrued = balanceStatistic_pre.getRotationCostAccrued();
+                    rotationCostExpenditure = balanceStatistic_pre.getRotationCostExpenditure();
+                    rotationCostOverdraftMonth = balanceStatistic_pre.getRotationCostOverdraftMonth();
+
+                }
+                //获取本月保管费用相关数据
+                FsEnterpriseBalanceStatistic storageCost = fsEnterpriseBalanceStatisticMapper.getStorageCostAccrued(orgId,grainVarietyId);
+                if (storageCost != null){
+                    storageCostAccrued = NumberUtil.add(storageCostAccrued,storageCost.getStorageCostAccrued());
+                    storageCostExpenditure = NumberUtil.add(storageCostExpenditure,storageCost.getStorageCostExpenditure());
+                    storageCostBalance = NumberUtil.sub(storageCostAccrued,storageCostExpenditure); //负数为超支
+                    balanceStatistic.setStorageCostOverdraftWarning(1); //未超支
+                    if (NumberUtil.compare(storageCostBalance.doubleValue(),0.0) <0){
+                        storageCostOverdraftMonth +=1; //
+                        balanceStatistic.setStorageCostOverdraftWarning(2); //超支
+                    }
+                    balanceStatistic.setStorageCostAccrued(storageCostAccrued);
+                    balanceStatistic.setStorageCostExpenditure(storageCostExpenditure);
+                    balanceStatistic.setStorageCostBalance(storageCostBalance);
+                    balanceStatistic.setRotationCostOverdraftMonth(storageCostOverdraftMonth);
+                }
+                //得到轮换计划数据，及本月轮换出库，入库轮换金额
+                FsEnterpriseBalanceStatistic rotationPlan = fsEnterpriseBalanceStatisticMapper.getRotationPlan(orgId,grainVarietyId,year,month);
+                if (rotationPlan != null){
+                    balanceStatistic.setRotationPlanQuantity(rotationPlan.getRotationPlanQuantity()); //轮换计划数量
+                    balanceStatistic.setRotationCompletionRate(rotationPlan.getRotationCompletionRate()); //轮换完成率
+                    balanceStatistic.setRotationCostStandard(rotationPlan.getRotationCostStandard()); //轮换费用标准
+                    rotationCostAccrued = NumberUtil.add(rotationCostAccrued,rotationPlan.getRotationCostAccrued());
+                    rotationCostExpenditure = NumberUtil.add(rotationCostExpenditure,rotationPlan.getRotationCostExpenditure());
+                    rotationCostBalance = NumberUtil.sub(rotationCostAccrued,rotationCostExpenditure); //负数为超支
+                    balanceStatistic.setRotationCostOverdraftWarning(1); //未 超支
+                    if (NumberUtil.compare(rotationCostBalance.doubleValue(),0.0) <0){
+                        rotationCostOverdraftMonth +=1; //
+                        balanceStatistic.setRotationCostOverdraftWarning(2); //超支
+                    }
+                    balanceStatistic.setRotationCostAccrued(rotationCostAccrued);
+                    balanceStatistic.setRotationCostExpenditure(rotationCostExpenditure);
+                    balanceStatistic.setRotationCostBalance(rotationCostBalance);
+                    balanceStatistic.setRotationCostOverdraftMonth(rotationCostOverdraftMonth);
+
+                }
             }
             //进行保存,查询是 否 存在查询条件的数据
             QueryWrapper<FsEnterpriseBalanceStatistic> queryWrapper = new QueryWrapper<>();