From 70c03048b7facab7105a8ab66d6347582777bb46 Mon Sep 17 00:00:00 2001
From: lijiarao <lijiarao@syxysoft.com>
Date: Tue, 2 Aug 2022 14:43:20 +0800
Subject: [PATCH] =?UTF-8?q?add=20=E6=9B=B4=E6=96=B0=E6=89=80=E6=9C=89?=
 =?UTF-8?q?=E7=A1=AE=E8=AE=A4=E6=94=B6=E5=85=A5=E7=8A=B6=E6=80=81=20?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../PayConfirmPaymentRecordController.java    | 10 ++++
 .../impl/PayConfirmPaymentRecordService.java  | 58 +++++++++++++++++++
 2 files changed, 68 insertions(+)

diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/payment/controller/PayConfirmPaymentRecordController.java b/jero-boot-incoming-payment/src/main/java/com/jero/payment/controller/PayConfirmPaymentRecordController.java
index 5da4c470..9ff76b41 100644
--- a/jero-boot-incoming-payment/src/main/java/com/jero/payment/controller/PayConfirmPaymentRecordController.java
+++ b/jero-boot-incoming-payment/src/main/java/com/jero/payment/controller/PayConfirmPaymentRecordController.java
@@ -124,6 +124,16 @@ public class PayConfirmPaymentRecordController  extends JeroController<PayConfir
 		return Result.OK();
 	}
 
+	/**
+	 * 更新所有确认收入状态
+	 */
+	@ApiOperation(value="-更新所有确认收入状态")
+	@GetMapping(value = "/updateAffirmIncome")
+	public Result<?> updateAffirmIncome() {
+		payConfirmPaymentRecordService.updateAffirmIncome();
+		return Result.OK();
+	}
+
     /**
     * 导出excel
     */
diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/payment/service/impl/PayConfirmPaymentRecordService.java b/jero-boot-incoming-payment/src/main/java/com/jero/payment/service/impl/PayConfirmPaymentRecordService.java
index 48525902..4436c4f2 100644
--- a/jero-boot-incoming-payment/src/main/java/com/jero/payment/service/impl/PayConfirmPaymentRecordService.java
+++ b/jero-boot-incoming-payment/src/main/java/com/jero/payment/service/impl/PayConfirmPaymentRecordService.java
@@ -3,6 +3,8 @@ package com.jero.payment.service.impl;
 import com.alibaba.fastjson.JSON;
 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.UpdateWrapper;
 import com.jero.common.enums.PaymentStatusEnum;
 import com.jero.company.entity.PayContactsManagement;
 import com.jero.contract.common.PayIncomeContractCommon;
@@ -204,6 +206,62 @@ public class PayConfirmPaymentRecordService extends ServiceImpl<PayConfirmPaymen
     public void deleteByIds(List<String> ids) {
         removeByIds(ids);
     }
+
+    public void updateAffirmIncome() {
+        payCommonProjectMapper.selectList(new QueryWrapper<>()).forEach(p->{
+            BigDecimal confirmAmount = p.getConfirmAmount();
+            Integer affirmIncome = payPaymentRecordService.getInAccount(p.getReceivableAmount(), confirmAmount);
+            PayCommonProject project = new PayCommonProject();
+            project.setId(p.getId());
+            project.setAffirmIncome(affirmIncome);
+            payCommonProjectMapper.updateById(project);
+        });
+
+        payWorkingGroupSubItemMapper.selectList(new QueryWrapper<>()).forEach(p ->{
+            BigDecimal confirmAmount = p.getConfirmAmount();
+            Integer affirmIncome = payPaymentRecordService.getInAccount(p.getReceivableAmount(), confirmAmount);
+            PayWorkingGroupSubItem project = new PayWorkingGroupSubItem();
+            project.setId(p.getId());
+            project.setAffirmIncome(affirmIncome);
+            payWorkingGroupSubItemMapper.updateById(project);
+        });
+
+        payMeetingSituationMapper.selectList(new QueryWrapper<>()).forEach(p ->{
+            BigDecimal confirmAmount = p.getConfirmAmount();
+            Integer affirmIncome = payPaymentRecordService.getInAccount(p.getAmountReceivable(), confirmAmount);
+            PayMeetingSituation project = new PayMeetingSituation();
+            project.setId(p.getId());
+            project.setAffirmIncome(affirmIncome);
+            payMeetingSituationMapper.updateById(project);
+        });
+
+        payMemberProjectSubitemMapper.selectList(new QueryWrapper<>()).forEach(p ->{
+            BigDecimal confirmAmount = p.getConfirmAmount();
+            Integer affirmIncome = payPaymentRecordService.getInAccount(p.getAmountReceivable(), confirmAmount);
+            PayMemberProjectSubitem project = new PayMemberProjectSubitem();
+            project.setId(p.getId());
+            project.setAffirmIncome(affirmIncome);
+            payMemberProjectSubitemMapper.updateById(project);
+        });
+
+        tbMemberProjectSubitemMapper.selectList(new QueryWrapper<>()).forEach(p ->{
+            BigDecimal confirmAmount = p.getConfirmAmount();
+            Integer affirmIncome = payPaymentRecordService.getInAccount(p.getAmountReceivable(), confirmAmount);
+            TbMemberProjectSubitem project = new TbMemberProjectSubitem();
+            project.setId(p.getId());
+            project.setAffirmIncome(affirmIncome);
+            tbMemberProjectSubitemMapper.updateById(project);
+        });
+
+        certificatePaymentMapper.selectList(new QueryWrapper<>()).forEach(p ->{
+            BigDecimal confirmAmount = p.getConfirmAmount();
+            Integer affirmIncome = payPaymentRecordService.getInAccount(p.getAmountReceivable(), confirmAmount);
+            TbCertificatePayment project = new TbCertificatePayment();
+            project.setId(p.getId());
+            project.setAffirmIncome(affirmIncome);
+            certificatePaymentMapper.updateById(project);
+        });
+    }
 }