批量来款

jero-boot-incoming-payment/src/main/java/com/jero/meeting/service/impl/PayMeetingSituationServiceImpl.java

@@ -196,7 +196,7 @@ public class PayMeetingSituationServiceImpl extends ServiceImpl<PayMeetingSituat
         payPaymentRecord.setAmountReceived(meetingSituation.getAmountReceivable());
         payPaymentRecord.setPaymentDate(new Date());
 
-        payPaymentRecordService.addAmountReceived(payPaymentRecord);
+//        payPaymentRecordService.addAmountReceived(payPaymentRecord);
     }
 
     @Override

jero-boot-incoming-payment/src/main/java/com/jero/payment/controller/PayPaymentRecordController.java

@@ -71,13 +71,18 @@ public class PayPaymentRecordController extends JeroController<PayPaymentRecord,
 	
 	/**
 	 *   添加来款
-	 * @param payPaymentRecord
 	 * @return
 	 */
 	@ApiOperation(value="添加来款", notes="添加来款")
 	@PostMapping(value = "/addAmountReceived")
-	public Result<?> addAmountReceived(@RequestBody PayPaymentRecord payPaymentRecord) {
-		return payPaymentRecordService.addAmountReceived(payPaymentRecord);
+	public Result<?> addAmountReceived(@RequestBody List<PayPaymentRecord> list) {
+		try{
+			payPaymentRecordService.addAmountReceived(list);
+		}catch (Exception e){
+			log.error("添加来款异常",e);
+			return Result.error(e.getMessage());
+		}
+		return Result.OK("操作成功");
 	}
 
 	/**

jero-boot-incoming-payment/src/main/java/com/jero/payment/service/IPayPaymentRecordService.java

@@ -29,9 +29,15 @@ public interface IPayPaymentRecordService extends IService<PayPaymentRecord> {
 
     /**
      * 添加来款
+     * @param list
+     */
+    void addAmountReceived(List<PayPaymentRecord> list);
+
+    /**
+     * 添加一个来款
      * @param payPaymentRecord
      */
-    Result<?> addAmountReceived(PayPaymentRecord payPaymentRecord);
+    void addOneAmountReceived(PayPaymentRecord payPaymentRecord);
 
     /**
      * 标协会员添加来款

jero-boot-incoming-payment/src/main/java/com/jero/payment/service/impl/PayPaymentRecordServiceImpl.java

@@ -36,6 +36,8 @@ import org.springframework.web.servlet.ModelAndView;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
+import javax.transaction.Transactional;
+import java.beans.Transient;
 import java.math.BigDecimal;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -79,13 +81,23 @@ public class PayPaymentRecordServiceImpl extends ServiceImpl<PayPaymentRecordMap
         return payPaymentRecordMapper.mainList(page, payCommonProject,projectType, paymentDate);
     }
 
+    /**
+     * 添加来款记录
+     */
+    @Transactional
+    @Override
+    public void addAmountReceived(List<PayPaymentRecord> list){
+        for(PayPaymentRecord payPaymentRecord : list){
+            addOneAmountReceived(payPaymentRecord);
+        }
+    }
 
     /**
-     *  添加来款记录
+     *  添加一个来款记录
      * @param payPaymentRecord
      */
     @Override
-    public Result<?> addAmountReceived(PayPaymentRecord payPaymentRecord){
+    public void addOneAmountReceived(PayPaymentRecord payPaymentRecord){
 
         BigDecimal receivableAmount;
         Boolean isAdd;
@@ -112,7 +124,7 @@ public class PayPaymentRecordServiceImpl extends ServiceImpl<PayPaymentRecordMap
                     payCommonProject.setInAccount(inAccount);
                     payCommonProjectMapper.updateById(payCommonProject);
                 }else{
-                    return Result.error("到账金额大于当前欠款金额，不可提交！");
+                    throw new JeroBootException("到账金额大于当前欠款金额，不可提交！");
                 }
                 break;
             // 工作组项目
@@ -133,7 +145,7 @@ public class PayPaymentRecordServiceImpl extends ServiceImpl<PayPaymentRecordMap
                     payWorking.setInAccount(inAccount);
                     payWorkingGroupSubItemMapper.updateById(payWorking);
                 }else{
-                    return Result.error("到账金额大于当前欠款金额，不可提交！");
+                    throw new JeroBootException("到账金额大于当前欠款金额，不可提交！");
                 }
                 break;
             //会议项目
@@ -154,7 +166,7 @@ public class PayPaymentRecordServiceImpl extends ServiceImpl<PayPaymentRecordMap
                     meeting.setInAccount(inAccount);
                     payMeetingSituationMapper.updateById(meeting);
                 }else{
-                    return Result.error("到账金额大于当前欠款金额，不可提交！");
+                    throw new JeroBootException("到账金额大于当前欠款金额，不可提交！");
                 }
                 break;
             //会员项目
@@ -176,7 +188,7 @@ public class PayPaymentRecordServiceImpl extends ServiceImpl<PayPaymentRecordMap
                     payMemberProjectSubitemMapper.updateById(member);
 
                 }else{
-                    return Result.error("到账金额大于当前欠款金额，不可提交！");
+                    throw new JeroBootException("到账金额大于当前欠款金额，不可提交！");
                 }
                 break;
             //标协会员
@@ -201,14 +213,14 @@ public class PayPaymentRecordServiceImpl extends ServiceImpl<PayPaymentRecordMap
 
                     sendToStandards(tbMember,payPaymentRecord);
                 }else{
-                    return Result.error("到账金额大于当前欠款金额，不可提交！");
+                    throw new JeroBootException("到账金额大于当前欠款金额，不可提交！");
                 }
                 break;
             default:break;
         }
         //插入来款记录表
         payPaymentRecordMapper.insert(payPaymentRecord);
-        return Result.OK("添加成功！");
+//        return Result.OK("添加成功！");
     }
 
     /**