添加客户基本信息

watero-rst-interface/src/main/java/com/iamberry/rst/faces/customer/CustomerBasicInfoSaveService.java

@@ -48,7 +48,7 @@ public interface CustomerBasicInfoSaveService {
      * @param customerBasicInfo
      * @return
      */
-    public void saveCustomerBasicInfo(CustomerBasicInfo customerBasicInfo,DockedContactInfo dockedContactInfo, ChannelSaleInfo channelSaleInfo,
+    public void saveCustomerBasicInfo(CustomerBasicInfo customerBasicInfo,List<DockedContactInfo> dockedContactInfoList, List<ChannelSaleInfo> channelSaleInfoList,
                                      BillingInfo billingInfo, TicketOpeningInfo ticketOpeningInfo);
 
 

watero-rst-service/src/main/java/com/iamberry/rst/service/customer/CustomerBasicInfoSaveServiceImpl.java

@@ -3,6 +3,8 @@ package com.iamberry.rst.service.customer;
 import com.iamberry.rst.core.customer.*;
 import com.iamberry.rst.faces.customer.CustomerBasicInfoSaveService;
 import com.iamberry.rst.service.customer.mapper.CustomerBasicInfoSaveMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -10,54 +12,71 @@ import java.util.List;
 
 public class CustomerBasicInfoSaveServiceImpl implements CustomerBasicInfoSaveService {
 
+    private Logger logger = LoggerFactory.getLogger(CustomerBasicInfoSaveServiceImpl.class);
+
     @Autowired
     private CustomerBasicInfoSaveMapper customerBasicInfoSaveMapper;
 
 
     @Override
     public CustomerBasicInfo queryCustomerBasicInfoByCustomerId(int queryCustomerId) {
-        return null;
+        return customerBasicInfoSaveMapper.queryCustomerBasicInfoByCustomerId(queryCustomerId);
     }
 
     @Override
     public List<DockedContactInfo> queryDockedContactInfoListByCustomerId(int queryCustomerId) {
-        return null;
+        return customerBasicInfoSaveMapper.queryDockedContactInfoListByCustomerId(queryCustomerId);
     }
 
     @Override
     public List<ChannelSaleInfo> queryChannelSaleInfoListByCustomerId(int queryCustomerId) {
-        return null;
+        return customerBasicInfoSaveMapper.queryChannelSaleInfoListByCustomerId(queryCustomerId);
     }
 
     @Override
     public BillingInfo queryBillingInfoByCustomerId(int queryCustomerId) {
-        return null;
+        return customerBasicInfoSaveMapper.queryBillingInfoByCustomerId(queryCustomerId);
     }
 
     @Override
     public TicketOpeningInfo queryTicketOpeningInfoByCustomerId(int queryCustomerId) {
-        return null;
+        return customerBasicInfoSaveMapper.queryTicketOpeningInfoByCustomerId(queryCustomerId);
     }
 
     @Override
     @Transactional
-    public void saveCustomerBasicInfo(CustomerBasicInfo customerBasicInfo,DockedContactInfo dockedContactInfo, ChannelSaleInfo channelSaleInfo,
+    public void saveCustomerBasicInfo(CustomerBasicInfo customerBasicInfo,List<DockedContactInfo> dockedContactInfoList, List<ChannelSaleInfo> channelSaleInfoList,
                                      BillingInfo billingInfo, TicketOpeningInfo ticketOpeningInfo) {
+        logger.info("saveCustomerBasicInfo start...");
         int customerId = -1;
-        customerBasicInfo = customerBasicInfoSaveMapper.saveCustomerBasicInfo(customerBasicInfo);
-        if(customerBasicInfo != null){
-            customerId = customerBasicInfo.getCustomerId();
-            if(customerId != -1){
-                dockedContactInfo.setCustomerId(customerId);
-                channelSaleInfo.setCustomerId(customerId);
-                billingInfo.setCustomerId(customerId);
-                ticketOpeningInfo.setCustomerId(customerId);
+        try {
+            customerBasicInfo = customerBasicInfoSaveMapper.saveCustomerBasicInfo(customerBasicInfo);
+            if(customerBasicInfo != null){
+                customerId = customerBasicInfo.getCustomerId();
+                if(customerId != -1){
+                    if(dockedContactInfoList != null){
+                        for (DockedContactInfo dockedContactInfo: dockedContactInfoList) {
+                            dockedContactInfo.setCustomerId(customerId);
+                            customerBasicInfoSaveMapper.saveDockedContactInfo(dockedContactInfo);
+                        }
+                    }
+                    if(channelSaleInfoList != null){
+                        for (ChannelSaleInfo channelSaleInfo: channelSaleInfoList) {
+                            channelSaleInfo.setCustomerId(customerId);
+                            customerBasicInfoSaveMapper.saveChannelSaleInfo(channelSaleInfo);
+                        }
+                    }
+                    billingInfo.setCustomerId(customerId);
+                    ticketOpeningInfo.setCustomerId(customerId);
+                    customerBasicInfoSaveMapper.saveBillingInfo(billingInfo);
+                    customerBasicInfoSaveMapper.saveTicketOpeningInfo(ticketOpeningInfo);
+                }
             }
-            customerBasicInfoSaveMapper.saveDockedContactInfo(dockedContactInfo);
-            customerBasicInfoSaveMapper.saveChannelSaleInfo(channelSaleInfo);
-            customerBasicInfoSaveMapper.saveBillingInfo(billingInfo);
-            customerBasicInfoSaveMapper.saveTicketOpeningInfo(ticketOpeningInfo);
+            logger.info("saveCustomerBasicInfo end...");
+        }catch (Exception e){
+            logger.error("添加客户信息失败"+e.getMessage());
         }
+
     }
 
     /*@Override

watero-rst-service/src/main/java/com/iamberry/rst/service/customer/mapper/CustomerBasicInfoSaveMapper.xml

@@ -160,7 +160,7 @@
         t.account_period,
         t.create_date
         FROM
-        tb_rst_ channel_sale_info t
+        tb_rst_channel_sale_info t
         WHERE
         t.customer_id = #{id}
     </select>

watero-rst-web/src/main/java/com/iamberry/rst/controllers/customer/CustomerBasicInfoSaveController.java

@@ -42,8 +42,8 @@ public class CustomerBasicInfoSaveController {
      * 添加客户信息
      * @param request
      * @param customerBasicInfo
-     * @param dockedContactInfo
-     * @param channelSaleInfo
+     * @param dockedContactInfoList
+     * @param channelSaleInfoList
      * @param billingInfo
      * @param ticketOpeningInfo
      * @return
@@ -52,8 +52,8 @@ public class CustomerBasicInfoSaveController {
     @ResponseBody
     @RequiresPermissions("customer:add:customerInfo")
     @RequestMapping("/save_customer")
-    public ResponseJson saveCustomerBasicInfo(HttpServletRequest request, CustomerBasicInfo customerBasicInfo, DockedContactInfo dockedContactInfo, ChannelSaleInfo channelSaleInfo,
-                                    BillingInfo billingInfo, TicketOpeningInfo ticketOpeningInfo) throws Exception {
+    public ResponseJson saveCustomerBasicInfo(HttpServletRequest request, CustomerBasicInfo customerBasicInfo, List<DockedContactInfo> dockedContactInfoList,
+                                              List<ChannelSaleInfo> channelSaleInfoList,BillingInfo billingInfo, TicketOpeningInfo ticketOpeningInfo) throws Exception {
         //注意：DockedContactInfo、ChannelSaleInfo可能为多个，需修改
         ResponseJson rjx = this.isValiData(customerBasicInfo);
         Boolean isSaveSuccess = false;//是否保存成功标识
@@ -62,7 +62,7 @@ public class CustomerBasicInfoSaveController {
         }
         logger.info("-----------------添加客户信息开始----------------------");
         try {
-            customerBasicInfoSaveService.saveCustomerBasicInfo(customerBasicInfo,dockedContactInfo,channelSaleInfo,billingInfo,ticketOpeningInfo);
+            customerBasicInfoSaveService.saveCustomerBasicInfo(customerBasicInfo,dockedContactInfoList,channelSaleInfoList,billingInfo,ticketOpeningInfo);
             isSaveSuccess = true;
         } catch (RuntimeException e) {
             isSaveSuccess = false;
@@ -96,6 +96,7 @@ public class CustomerBasicInfoSaveController {
         List<ChannelSaleInfo> channelSaleInfoList = new ArrayList<ChannelSaleInfo>();
         BillingInfo billingInfo = new BillingInfo();
         TicketOpeningInfo ticketOpeningInfo = new TicketOpeningInfo();
+        logger.info("-----------------修改客户信息开始----------------------");
         try {
             customerBasicInfo = customerBasicInfoSaveService.queryCustomerBasicInfoByCustomerId(queryCustomerId);
             dockedContactInfoList = customerBasicInfoSaveService.queryDockedContactInfoListByCustomerId(queryCustomerId);
@@ -107,6 +108,7 @@ public class CustomerBasicInfoSaveController {
             isSuccess = false;
             logger.error("跳转修改页面失败："+e.getMessage());
         }
+        logger.info("----------------修改客户信息结束----------------------");
         if(!isSuccess){
             return mv;
         }else{