年度预算-历史数据同步(系统已执行和计算已执行)

src/main/java/com/liang/dao/PrjAnnualbudgetDao.java

@@ -149,5 +149,11 @@ public interface PrjAnnualbudgetDao {
     void updateSJYZXSum(Integer rws);
 
     PrjAnnualbudget queryByRws1(@Param("rws") Integer rws, @Param("nf") Integer nf);
+
+    void updateXTJSYZXByNysId(@Param("rwsId") Integer rwsId, @Param("nf") String nf, @Param("nysId") Integer nysId);
+
+    void updateSJYZXByNysId(@Param("rwsId") Integer rwsId, @Param("nf") String nf, @Param("nysId") Integer nysId);
+
+    void updateSJYZXSumByNysId(@Param("rwsId") Integer rwsId, @Param("nf") String nf, @Param("nysId") Integer nysId);
 }
 

src/main/java/com/liang/service/impl/PrjAnnualbudgetServiceImpl.java

@@ -12,10 +12,15 @@ import org.springframework.stereotype.Service;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageImpl;
 import org.springframework.data.domain.PageRequest;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * 年度预算(PrjAnnualbudget)表服务实现类
@@ -24,6 +29,7 @@ import java.util.Map;
  * @since 2023-05-17 08:56:50
  */
 @Service("prjAnnualbudgetService")
+@RestController
 public class PrjAnnualbudgetServiceImpl implements PrjAnnualbudgetService {
     @Resource
     private PrjAnnualbudgetDao prjAnnualbudgetDao;
@@ -150,9 +156,24 @@ public class PrjAnnualbudgetServiceImpl implements PrjAnnualbudgetService {
             prjAnnualbudgetDao.updateSJYZXSum(rws);
         }
     }
+    @GetMapping("/updateSJYZXAndXTJSYZX/{rwsId}/{nysId}")
+    @Transactional(rollbackFor = Exception.class)
+    public void updateSJYZXAndXTJSYZX(@PathVariable("rwsId")Integer rwsId, @PathVariable("nysId")Integer nysId) {
+        List<PrjAnnualbudget> prjAnnualbudgets = prjAnnualbudgetDao.listByRws(rwsId);
+        //第一年的年度预算不需要更新
+        if (!Collections.isEmpty(prjAnnualbudgets) && !prjAnnualbudgets.get(0).getId().equals(nysId)) {
+            PrjAnnualbudget annualbudget = prjAnnualbudgets.stream().filter(item -> item.getId().equals(nysId)).collect(Collectors.toList()).get(0);
+            //更新 系统计算已执行
+            prjAnnualbudgetDao.updateXTJSYZXByNysId(rwsId,annualbudget.getNf(),annualbudget.getId());
+            //更新 历史年度预算的实际已执行
+            prjAnnualbudgetDao.updateSJYZXByNysId(rwsId,annualbudget.getNf(),annualbudget.getId());
+            //更新已执行总计
+            prjAnnualbudgetDao.updateSJYZXSumByNysId(rwsId,annualbudget.getNf(),annualbudget.getId());
+        }
+    }
 
     @Override
     public PrjAnnualbudget queryByRws1(Integer rws, Integer nf) {
-        return prjAnnualbudgetDao.queryByRws1(rws,nf);
+        return prjAnnualbudgetDao.queryByRws1(rws, nf);
     }
 }

src/main/resources/mapper/PrjAnnualbudgetDao.xml

@@ -483,6 +483,52 @@
             prj_AnnualBudget
             where RWS = #{rws} order by nf desc )
     </update>
+    <update id="updateXTJSYZXByNysId">
+        update A
+        set A.XTJSYZX = B.xtjsyzx from prj_AnnualBudgetDetail A
+        inner join (SELECT
+         fymc, sum(ysje) xtjsyzx
+         from  prj_AnnualBudgetDetail
+         where nys in  (SELECT ID from prj_AnnualBudget where RWS = #{rwsId} and nf &lt; #{nf} )
+            group by fymc) B
+        on A.FYMC = B.fymc
+        where
+            NYS = #{nysId}
+    </update>
+    <update id="updateSJYZXByNysId">
+        update A
+        set A.sjyzx = B.BZJE from prj_AnnualBudgetDetail A
+        inner join (SELECT convert(decimal(18,2),(sum(BZJE)/10000))  BZJE ,pa.fymc
+	        from(SELECT	id ,fylb
+	  	from sta_BudgetApproval
+		where	nys in (
+			select	id
+			from prj_AnnualBudget
+			where rws = #{rwsId} and nf &lt; #{nf} )) sb
+            left join sta_Reimbursement sa on sa.fysq = sb.id
+            LEFT join prj_AnnualBudgetDetail pa on pa.id = sb.fylb
+            group by pa.fymc ) B
+        on A.FYMC = B.fymc
+        where
+            NYS = #{nysId}
+    </update>
+    <update id="updateSJYZXSumByNysId">
+        update A
+        set A.sjyzx = B.BZJE from prj_AnnualBudgetDetail A
+        inner join (SELECT	sum(BZJE) BZJE ,pa.fymc
+	        from(SELECT	id ,fylb
+	  	from sta_BudgetApproval
+		where	nys in (
+			select	id
+			from prj_AnnualBudget
+			where rws = #{rwsId} and nf &lt; #{nf} )) sb
+            left join sta_Reimbursement sa on sa.fysq = sb.id
+            LEFT join prj_AnnualBudgetDetail pa on pa.id = sb.fylb
+            group by pa.fymc ) B
+        on A.FYMC = B.fymc
+        where
+            NYS = #{nysId}
+    </update>
 
     <!--已申请费用的预算-->
     <select id="getFysqBudgetList">
@@ -496,6 +542,7 @@
         select *
         from prj_AnnualBudget
         where rws = #{rws}
+        order by nf asc
     </select>
     <select id="getNYSSum" resultType="java.math.BigDecimal">
         SELECT sum(pan.sjyzx) sjyzx