app修改银行卡信息

sp-core/sp-api/src/main/java/com/pj/api/client/level_one_server/LevelOneServerInterface.java

@@ -117,4 +117,17 @@ public interface LevelOneServerInterface {
     /** 系统接收到航通接口信息：车辆已出一级市场 ,修改相对应的一级市场订单状态 **/
     @RequestMapping("/TbOrder/rpc/orderFinish")
     public boolean orderFinish(@RequestParam("billCode") String billCode);
+
+
+    /** 边民保存银行卡信息 */
+    @RequestMapping("/app/TbPeople/rpc/saveBankInfo")
+    public boolean saveBankByPeople(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount);
+
+    /** 商户保存银行卡信息 */
+    @RequestMapping("/app/TbEnterprise/rpc/saveBankInfo")
+    public boolean saveBankByEnterprise(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount);
+
+    /** 合作社保存银行卡信息 */
+    @RequestMapping("/app/TbCooperative/rpc/saveBankInfo")
+    public boolean saveBankByCooperative(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount);
 }

sp-core/sp-api/src/main/java/com/pj/api/client/level_one_server/LevelOneServerInterfaceFallback.java

@@ -184,6 +184,21 @@ public class LevelOneServerInterfaceFallback implements FallbackFactory<LevelOne
             public boolean orderFinish(String billCode) {
                 return false;
             }
+
+            @Override
+            public boolean saveBankByPeople(Long id, String bankName, String bankAccount) {
+                return false;
+            }
+
+            @Override
+            public boolean saveBankByEnterprise(Long id, String bankName, String bankAccount) {
+                return false;
+            }
+
+            @Override
+            public boolean saveBankByCooperative(Long id, String bankName, String bankAccount) {
+                return false;
+            }
         };
     }
 }

sp-core/sp-api/src/main/java/com/pj/api/client/level_two_server/LevelTwoServerInterface.java

@@ -22,6 +22,10 @@ public interface LevelTwoServerInterface {
     @RequestMapping("/app/TbPurchaser/rpc/getByPurchaserId")
     public PurchaserDto getByPurchaserId(@RequestParam("id") Long id);
 
+    /** 收购商保存银行卡信息 */
+    @RequestMapping("/app/TbPurchaser/rpc/saveBankInfo")
+    public boolean saveBankByPurchaser(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount);
+
     /** 添加国内收购商信息 */
     @RequestMapping("/TbPurchaser/purchaserDto")
     public boolean purchaserDto(@RequestBody PurchaserDto purchaserDto);

sp-core/sp-api/src/main/java/com/pj/api/client/level_two_server/LevelTwoServerInterfaceFallback.java

@@ -27,6 +27,11 @@ public class LevelTwoServerInterfaceFallback implements FallbackFactory<LevelTwo
             }
 
             @Override
+            public boolean saveBankByPurchaser(Long id, String bankName, String bankAccount) {
+                return false;
+            }
+
+            @Override
             public boolean purchaserDto(PurchaserDto purchaserDto) {
                 System.out.println(throwable.getMessage());
                 log.error("国内商家信息添加错误:{},错误信息是{}",purchaserDto,throwable.getMessage());

sp-service/level-one-server/src/main/java/com/pj/tb_cooperative/TbCooperativeAppController.java

@@ -48,4 +48,10 @@ public class TbCooperativeAppController {
 		return dto;
 	}
 
+	/** 合作社保存银行卡信息 */
+	@RequestMapping("rpc/saveBankInfo")
+	public boolean saveBankByCooperative(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount) {
+		return tbCooperativeService.saveBankByCooperative(id, bankName, bankAccount);
+	}
+
 }

sp-service/level-one-server/src/main/java/com/pj/tb_cooperative/TbCooperativeService.java

@@ -1,6 +1,7 @@
 package com.pj.tb_cooperative;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.pj.api.dto.CooperativeDto;
@@ -95,4 +96,14 @@ public class TbCooperativeService extends ServiceImpl<TbCooperativeMapper,TbCoop
 		return i == 1;
 	}
 
+	/** 合作社保存银行卡信息 */
+	public boolean saveBankByCooperative(Long id,String bankName,String bankAccount) {
+		LambdaUpdateWrapper<TbCooperative> wrapper = new LambdaUpdateWrapper<>();
+		wrapper.set(TbCooperative::getBankName, bankName);
+		wrapper.set(TbCooperative::getBankAccount, bankAccount);
+		wrapper.eq(TbCooperative::getId, id);
+
+		return update(wrapper);
+	}
+
 }

sp-service/level-one-server/src/main/java/com/pj/tb_enterprise/TbEnterpriseAppController.java

@@ -70,4 +70,9 @@ public class TbEnterpriseAppController {
         return enterpriseById;
     }
 
+    /** 商户保存银行卡信息 */
+    @RequestMapping("rpc/saveBankInfo")
+    public boolean saveBankByEnterprise(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount) {
+        return tbEnterpriseService.saveBankByEnterprise(id, bankName, bankAccount);
+    }
 }

sp-service/level-one-server/src/main/java/com/pj/tb_enterprise/TbEnterpriseService.java

@@ -2,6 +2,7 @@ package com.pj.tb_enterprise;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.pj.api.client.admin.AdminInterface;
@@ -391,4 +392,15 @@ public class TbEnterpriseService extends ServiceImpl<TbEnterpriseMapper, TbEnter
         List<TbEnterprise> list=list(ew);
         return list.isEmpty()?null:list.get(0);
     }
+
+    /** 商户保存银行卡信息 */
+    public boolean saveBankByEnterprise(Long id,String bankName,String bankAccount) {
+        LambdaUpdateWrapper<TbEnterprise> wrapper = new LambdaUpdateWrapper<>();
+        wrapper.set(TbEnterprise::getBank, bankName);
+        wrapper.set(TbEnterprise::getBankAccount, bankAccount);
+        wrapper.eq(TbEnterprise::getId, id);
+
+        return update(wrapper);
+    }
+
 }

sp-service/level-one-server/src/main/java/com/pj/tb_people/TbPeopleAppController.java

@@ -35,15 +35,10 @@ public class TbPeopleAppController {
         return AjaxJson.getSuccess();
     }
 
-
-//
-//    /** 边民确认订单 */
-//    @RequestMapping("confirmOrder")
-//    public AjaxJson confirmOrder(@RequestParam("orderId")Long orderId){
-//        tbPeopleService.confirmOrder(orderId);
-//        return AjaxJson.getSuccess();
-//    }
-
-
+    /** 边民保存银行卡信息 */
+    @RequestMapping("rpc/saveBankInfo")
+    public boolean saveBankByPeople(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount) {
+        return tbPeopleService.saveBankByPeople(id, bankName, bankAccount);
+    }
 
 }

sp-service/level-one-server/src/main/java/com/pj/tb_people/TbPeopleService.java

@@ -658,4 +658,14 @@ public class TbPeopleService extends ServiceImpl<TbPeopleMapper, TbPeople> imple
         List<TbPeople> list = list(ew);
         return list.isEmpty() ? null : list.get(0);
     }
+
+    /** 边民保存银行卡信息 */
+    public boolean saveBankByPeople(Long id,String bankName,String bankAccount) {
+        LambdaUpdateWrapper<TbPeople> wrapper = new LambdaUpdateWrapper<>();
+        wrapper.set(TbPeople::getBankName, bankName);
+        wrapper.set(TbPeople::getBankCode, bankAccount);
+        wrapper.eq(TbPeople::getId, id);
+
+        return update(wrapper);
+    }
 }

sp-service/level-two-server/src/main/java/com/pj/tb_purchaser/TbPurchaserAppController.java

@@ -67,5 +67,9 @@ public class TbPurchaserAppController {
 		return byPurchaserId;
 	}
 
-
+	/** 收购商保存银行卡信息 */
+	@RequestMapping("rpc/saveBankInfo")
+	public boolean saveBankByPurchaser(@RequestParam("id")Long id, @RequestParam("bankName")String bankName, @RequestParam("bankAccount")String bankAccount) {
+		return tbPurchaserService.saveBankByPurchaser(id, bankName, bankAccount);
+	}
 }

sp-service/level-two-server/src/main/java/com/pj/tb_purchaser/TbPurchaserService.java

@@ -14,6 +14,7 @@ import java.util.List;
 import java.util.Objects;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.pj.api.client.admin.AdminInterface;
 import com.pj.api.dto.AppUserDto;
 import com.pj.api.dto.EnterpriseAuditDto;
@@ -36,6 +37,7 @@ import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.swing.filechooser.FileSystemView;
@@ -323,5 +325,14 @@ public class TbPurchaserService extends ServiceImpl<TbPurchaserMapper, TbPurchas
 		return purchaserDto;
 	}
 
+	/** 收购商保存银行卡信息 */
+	public boolean saveBankByPurchaser(Long id,String bankName,String bankAccount) {
+		LambdaUpdateWrapper<TbPurchaser> wrapper = new LambdaUpdateWrapper<>();
+		wrapper.set(TbPurchaser::getBankName, bankName);
+		wrapper.set(TbPurchaser::getBankAccount, bankAccount);
+		wrapper.eq(TbPurchaser::getId, id);
+
+		return update(wrapper);
+	}
 
 }

sp-service/sp-admin/src/main/java/com/pj/project/app_user/AppUserApiController.java

@@ -7,6 +7,7 @@ import com.pj.project.app_user.dto.LoginDto;
 import com.pj.project.app_user.dto.RegisterDto;
 import com.pj.project.app_user.vo.AppUserVo;
 import com.pj.utils.sg.AjaxJson;
+import com.pj.utils.so.SoMap;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -121,6 +122,21 @@ public class AppUserApiController {
         if (result) return AjaxJson.getSuccess("密码修改成功!");
         return AjaxJson.getError("密码修改失败!");
     }
+
+    /** 获取银行卡信息 */
+    @RequestMapping("getBankInfo")
+    public AjaxJson getBankInfo(){
+        SoMap so = appUserService.getBankInfo();
+        return AjaxJson.getSuccessData(so);
+    }
+
+    /** 获取银行卡信息 */
+    @RequestMapping("saveBankInfo")
+    public AjaxJson saveBankInfo(){
+        SoMap so = SoMap.getRequestSoMap();
+        return AjaxJson.toAjax(appUserService.saveBankInfo(so));
+    }
+
     /*-----               正常业务接口👆👆    不越界     rpc远程调用 👇👇                     -----*/
     /**
      * 收购商认证

sp-service/sp-admin/src/main/java/com/pj/project/app_user/AppUserService.java

@@ -88,6 +88,8 @@ public class AppUserService extends ServiceImpl<AppUserMapper, AppUser> implemen
     @Autowired
     private LevelOneServerInterface levelOneServerInterface;
     @Autowired
+    private LevelTwoServerInterface levelTwoServerInterface;
+    @Autowired
     private TransportInterface transportInterface;
     @Autowired
     AppUserLoginLogService appUserLoginLogService;
@@ -487,6 +489,63 @@ public class AppUserService extends ServiceImpl<AppUserMapper, AppUser> implemen
         return 1 == appUserMapper.updateById(appUser);
     }
 
+    /** 获取银行卡信息 */
+    public SoMap getBankInfo() {
+        SoMap so = new SoMap();
+        Integer userType = StpAPPUserUtil.getAPPLoginInfo().getUserType();
+        Long fk = StpAPPUserUtil.getAPPLoginInfo().getFk();
+
+        //1=普通边民,2=边民组长,3=收购商,4=司机,5=外籍商户,6=合作社
+        if(1 == userType || 2 == userType) {
+            PeopleDto peopleDto = levelOneServerInterface.getRpcById(fk);
+            so.put("bankName",peopleDto.getBankName());
+            so.put("bankAccount",peopleDto.getBankCode());
+        }
+        else if(3 == userType) {
+            PurchaserDto purchaserDto = levelTwoServerInterface.getByPurchaserId(fk);
+            so.put("bankName",purchaserDto.getBankName());
+            so.put("bankAccount",purchaserDto.getBankAccount());
+        }
+        else if(5 == userType) {
+            EnterpriseDto enterpriseDto = levelOneServerInterface.getEnterpriseById(fk);
+            so.put("bankName",enterpriseDto.getBank());
+            so.put("bankAccount",enterpriseDto.getBankAccount());
+        }
+        else if(6 == userType) {
+            CooperativeDto cooperativeDto = levelOneServerInterface.getCooperativeById(fk);
+            so.put("bankName",cooperativeDto.getBankName());
+            so.put("bankAccount",cooperativeDto.getBankAccount());
+        }
+        return so;
+    }
+
+    /** 保存银行卡信息 */
+    public boolean saveBankInfo(SoMap so) {
+        Integer userType = StpAPPUserUtil.getAPPLoginInfo().getUserType();
+        Long fk = StpAPPUserUtil.getAPPLoginInfo().getFk();
+        String bankName = so.getString("bankName");
+        String bankAccount = so.getString("bankAccount");
+
+        //1=普通边民,2=边民组长,3=收购商,4=司机,5=外籍商户,6=合作社
+        if(1 == userType || 2 == userType) {
+            boolean result = levelOneServerInterface.saveBankByPeople(fk, bankName, bankAccount);
+            return result;
+        }
+        else if(3 == userType) {
+            boolean result = levelTwoServerInterface.saveBankByPurchaser(fk, bankName, bankAccount);
+            return result;
+        }
+        else if(5 == userType) {
+            boolean result = levelOneServerInterface.saveBankByEnterprise(fk, bankName, bankAccount);
+            return result;
+        }
+        else if(6 == userType) {
+            boolean result = levelOneServerInterface.saveBankByCooperative(fk, bankName, bankAccount);
+            return result;
+        }
+        return false;
+    }
+
     /**
      * 远程调用: 收购商认证
      */