Kaynağa Gözat

增加Merchant Dao

wuxw7 9 yıl önce
ebeveyn
işleme
adf33bf83c

Dosya farkı çok büyük olduğundan ihmal edildi
+ 589 - 228
.idea/workspace.xml


+ 0 - 13
MerchantService/src/main/java/com/java110/App.java

@@ -1,13 +0,0 @@
-package com.java110;
-
-/**
- * Hello world!
- *
- */
-public class App 
-{
-    public static void main( String[] args )
-    {
-        System.out.println( "Hello World!" );
-    }
-}

+ 25 - 0
MerchantService/src/main/java/com/java110/merchant/AppSpringBootApplication.java

@@ -0,0 +1,25 @@
+package com.java110.merchant;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+
+/**
+ * spring boot 初始化启动类
+ *
+ * @version v0.1
+ * @auther com.java110.wuxw
+ * @mail 928255095@qq.com
+ * @date 2016年8月6日
+ * @tag
+ */
+@SpringBootApplication(scanBasePackages="com.java110.service,com.java110.merchant")
+@EnableDiscoveryClient
+public class AppSpringBootApplication {
+
+    public static void main(String[] args) throws Exception{
+        SpringApplication.run(AppSpringBootApplication.class, args);
+    }
+}

+ 158 - 0
MerchantService/src/main/java/com/java110/merchant/dao/IMerchantServiceDao.java

@@ -0,0 +1,158 @@
+package com.java110.merchant.dao;
+
+
+import com.java110.entity.merchant.BoMerchant;
+import com.java110.entity.merchant.BoMerchantAttr;
+import com.java110.entity.merchant.Merchant;
+import com.java110.entity.merchant.MerchantAttr;
+
+
+import java.util.List;
+
+/**
+ * 商户组件内部之间使用,没有给外围系统提供服务能力
+ * 商户服务接口类,要求全部以字符串传输,方便微服务化
+ * 新建客户,修改客户,删除客户,查询客户等功能
+ *
+ * Created by wuxw on 2016/12/27.
+ */
+public interface IMerchantServiceDao {
+
+    /**
+     * 保存商户基本信息(过程表)
+     * @param boMerchant 商户基本信息
+     * @return
+     */
+    public int saveDataToBoMerchant(BoMerchant boMerchant) throws RuntimeException;
+
+    /**
+     * 保存商户属性(过程表)
+     * @param boMerchantAttr 商户属性
+     * @return
+     * @throws RuntimeException
+     */
+    public int saveDataToBoMerchantAttr(BoMerchantAttr boMerchantAttr) throws RuntimeException ;
+
+    /**
+     *  同事保存商户基本信息和属性(过程表)
+     * @param boMerchantInfo 商户信息
+     * @return
+     * @throws RuntimeException
+     */
+    public String saveDataToBoMerchantAndBoMerchantAttr(String boMerchantInfo) throws RuntimeException;
+
+    /**
+     * 保存商户基本信息
+     * @param merchant
+     * @return
+     * @throws RuntimeException
+     */
+    public int saveDataToMerchant(Merchant merchant) throws RuntimeException;
+
+    /**
+     *  保存商户属性
+     * @param merchantAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public int saveDataToMerchantAttr(MerchantAttr merchantAttr) throws RuntimeException;
+
+    /**
+     * 删除商户基本信息(实例数据)
+     * @param merchant
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToMerchant(Merchant merchant) throws RuntimeException;
+
+    /**
+     *  删除商户属性(实例数据)
+     * @param merchantAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToMerchantAttr(MerchantAttr merchantAttr) throws RuntimeException;
+
+    /**
+     * 同事保存商户基本信息和属性
+     * @param merchantInfo
+     * @return
+     * @throws RuntimeException
+     */
+    public String saveDataToMerchantAndMerchantAttr(String merchantInfo) throws RuntimeException;
+
+
+    /**
+     * 更新商户基本信息
+     * @param merchant
+     * @return
+     * @throws RuntimeException
+     */
+    public String updateDataToMerchant(String merchant) throws RuntimeException;
+
+    /**
+     *  更新商户属性
+     * @param merchantAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public String updateDataToMerchantAttr(String merchantAttr) throws RuntimeException;
+
+    /**
+     * 同事更新商户基本信息和属性
+     * @param merchantInfo
+     * @return
+     * @throws RuntimeException
+     */
+    public String updateDataToMerchantAndMerchantAttr(String merchantInfo) throws RuntimeException;
+
+
+
+    /**
+     * 查询商户基本信息(一般没用,就算有用)
+     * @param merchant
+     * @return
+     * @throws RuntimeException
+     */
+    public Merchant queryDataToMerchant(Merchant merchant) throws RuntimeException ;
+
+
+
+    /**
+     *  查询商户属性
+     * @param merchantAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public List<MerchantAttr> queryDataToMerchantAttr(MerchantAttr merchantAttr) throws RuntimeException;
+
+    /**
+     * 查询保存商户基本信息和属性
+     * @param merchantInfo
+     * @return
+     * @throws RuntimeException
+     */
+    public String queryDataToMerchantAndMerchantAttr(String merchantInfo) throws RuntimeException;
+
+    /**
+     *
+     * 查询 客户基本信息(过程表bo_merchant)
+     *
+     * @param BoMerchant
+     * @return
+     * @throws Exception
+     */
+    public List<BoMerchant> queryBoMerchant(BoMerchant BoMerchant) throws Exception;
+
+    /**
+     *
+     * 查询 客户属性信息(过程表 bo_merchant_attr)
+     *
+     * @param BoMerchantAttr
+     * @return
+     * @throws Exception
+     */
+    public List<BoMerchantAttr> queryBoMerchantAttr(BoMerchantAttr BoMerchantAttr) throws Exception;
+
+
+}

+ 156 - 0
MerchantService/src/main/java/com/java110/merchant/dao/IProductServiceDao.java

@@ -0,0 +1,156 @@
+package com.java110.merchant.dao;
+
+import com.java110.entity.user.BoCust;
+import com.java110.entity.user.BoCustAttr;
+import com.java110.entity.user.Cust;
+import com.java110.entity.user.CustAttr;
+
+import java.util.List;
+
+/**
+ * 用户组件内部之间使用,没有给外围系统提供服务能力
+ * 用户服务接口类,要求全部以字符串传输,方便微服务化
+ * 新建客户,修改客户,删除客户,查询客户等功能
+ *
+ * Created by wuxw on 2016/12/27.
+ */
+public interface IProductServiceDao {
+
+    /**
+     * 保存用户基本信息(过程表)
+     * @param boCust 用户基本信息
+     * @return
+     */
+    public int saveDataToBoCust(BoCust boCust) throws RuntimeException;
+
+    /**
+     * 保存用户属性(过程表)
+     * @param boCustAttr 用户属性
+     * @return
+     * @throws RuntimeException
+     */
+    public int saveDataToBoCustAttr(BoCustAttr boCustAttr) throws RuntimeException ;
+
+    /**
+     *  同事保存用户基本信息和属性(过程表)
+     * @param boCustInfo 用户信息
+     * @return
+     * @throws RuntimeException
+     */
+    public String saveDataToBoCustAndBoCustAttr(String boCustInfo) throws RuntimeException;
+
+    /**
+     * 保存用户基本信息
+     * @param cust
+     * @return
+     * @throws RuntimeException
+     */
+    public int saveDataToCust(Cust cust) throws RuntimeException;
+
+    /**
+     *  保存用户属性
+     * @param custAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public int saveDataToCustAttr(CustAttr custAttr) throws RuntimeException;
+
+    /**
+     * 删除用户基本信息(实例数据)
+     * @param cust
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToCust(Cust cust) throws RuntimeException;
+
+    /**
+     *  删除用户属性(实例数据)
+     * @param custAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToCustAttr(CustAttr custAttr) throws RuntimeException;
+
+    /**
+     * 同事保存用户基本信息和属性
+     * @param custInfo
+     * @return
+     * @throws RuntimeException
+     */
+    public String saveDataToCustAndCustAttr(String custInfo) throws RuntimeException;
+
+
+    /**
+     * 更新用户基本信息
+     * @param cust
+     * @return
+     * @throws RuntimeException
+     */
+    public String updateDataToCust(String cust) throws RuntimeException;
+
+    /**
+     *  更新用户属性
+     * @param custAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public String updateDataToCustAttr(String custAttr) throws RuntimeException;
+
+    /**
+     * 同事更新用户基本信息和属性
+     * @param custInfo
+     * @return
+     * @throws RuntimeException
+     */
+    public String updateDataToCustAndCustAttr(String custInfo) throws RuntimeException;
+
+
+
+    /**
+     * 查询用户基本信息(一般没用,就算有用)
+     * @param cust
+     * @return
+     * @throws RuntimeException
+     */
+    public Cust queryDataToCust(Cust cust) throws RuntimeException ;
+
+
+
+    /**
+     *  查询用户属性
+     * @param custAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public List<CustAttr> queryDataToCustAttr(CustAttr custAttr) throws RuntimeException;
+
+    /**
+     * 查询保存用户基本信息和属性
+     * @param custInfo
+     * @return
+     * @throws RuntimeException
+     */
+    public String queryDataToCustAndCustAttr(String custInfo) throws RuntimeException;
+
+    /**
+     *
+     * 查询 客户基本信息(过程表bo_cust)
+     *
+     * @param boCust
+     * @return
+     * @throws Exception
+     */
+    public List<BoCust> queryBoCust(BoCust boCust) throws Exception;
+
+    /**
+     *
+     * 查询 客户属性信息(过程表 bo_cust_attr)
+     *
+     * @param boCustAttr
+     * @return
+     * @throws Exception
+     */
+    public List<BoCustAttr> queryBoCustAttr(BoCustAttr boCustAttr) throws Exception;
+
+
+}

+ 263 - 0
MerchantService/src/main/java/com/java110/merchant/dao/impl/MerchantServiceDaoImpl.java

@@ -0,0 +1,263 @@
+package com.java110.merchant.dao.impl;
+
+import com.java110.common.log.LoggerEngine;
+import com.java110.common.util.Assert;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.entity.merchant.BoMerchant;
+import com.java110.entity.merchant.BoMerchantAttr;
+import com.java110.entity.merchant.Merchant;
+import com.java110.entity.merchant.MerchantAttr;
+import com.java110.merchant.dao.IMerchantServiceDao;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * 商户服务 与数据库交互
+ * Created by wuxw on 2017/4/5.
+ */
+@Service("merchantServiceDaoImpl")
+@Transactional
+public class MerchantServiceDaoImpl extends BaseServiceDao implements IMerchantServiceDao {
+
+
+
+    /**
+     * 保存用户基本信息
+     * 功能只用与保存用户处理
+     * @param boMerchant 用户基本信息
+     * @return
+     */
+    @Override
+    public int saveDataToBoMerchant(BoMerchant boMerchant) throws RuntimeException{
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoMerchant】保存数据入参 : " + boMerchant);
+        int saveFlag = 0;
+        try {
+
+            saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToBoMerchant",boMerchant);
+
+        }catch(RuntimeException e){
+            LoggerEngine.error("----【UserServiceDAOImpl.saveDataToBoMerchant】保存数据异常 : " ,e);
+            return saveFlag;
+        }finally {
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoMerchant】保存数据出参 : saveFlag:" + saveFlag);
+            return saveFlag;
+        }
+
+    }
+
+    /**
+     * 保存用户属性(过程表)
+     *
+     * @param boMerchantAttr 用户属性
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public int saveDataToBoMerchantAttr(BoMerchantAttr boMerchantAttr) throws RuntimeException {
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoMerchantAttr】保存数据入参 : " + boMerchantAttr);
+        //为了保险起见,再测检测reqList 是否有值
+        if(boMerchantAttr == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoMerchantAttr】保存数据出错 : " + boMerchantAttr);
+            return 0;
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToBoMerchantAttr",boMerchantAttr);
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoMerchantAttr】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+
+    }
+
+    /**
+     * 保存实例数据 客户信息至Merchant表中
+     * @param merchant
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public int saveDataToMerchant(Merchant merchant) throws RuntimeException {
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToMerchant】保存数据入参 : " + merchant);
+        //为了保险起见,再测检测reqList 是否有值
+        if(merchant == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToMerchant】保存数据出错 : " + merchant);
+            throw new IllegalArgumentException("请求参数错误,merchant : " + merchant);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToMerchant",merchant);
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToMerchant】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     * 保存实例数据 客户属性信息至MerchantAttr表中
+     * @param merchantAttr
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public int saveDataToMerchantAttr(MerchantAttr merchantAttr) throws RuntimeException {
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToMerchant】保存数据入参 : " + merchantAttr);
+        //为了保险起见,再测检测reqList 是否有值
+        if(merchantAttr == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToMerchant】保存数据出错 : " + merchantAttr);
+            throw new IllegalArgumentException("请求参数错误,merchantAttr : " + merchantAttr);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToMerchantAttr",merchantAttr);
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToMerchant】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     * 删除用户基本信息(实例数据)
+     * @param merchant
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToMerchant(Merchant merchant) throws RuntimeException{
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToMerchant】保存数据入参 : " + merchant);
+        //为了保险起见,再测检测reqList 是否有值
+        if(merchant == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToMerchant】保存数据出错 : " + merchant);
+            throw new IllegalArgumentException("请求参数错误,merchant : " + merchant);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.update("userServiceDAOImpl.deleteDataToMerchant",merchant);
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToMerchant】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     *  删除用户属性(实例数据)
+     * @param merchantAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToMerchantAttr(MerchantAttr merchantAttr) throws RuntimeException{
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToMerchantAttr】保存数据入参 : " + merchantAttr);
+        //为了保险起见,再测检测reqList 是否有值
+        if(merchantAttr == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToMerchantAttr】保存数据出错 : " + merchantAttr);
+            throw new IllegalArgumentException("请求参数错误,merchantAttr : " + merchantAttr);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.update("userServiceDAOImpl.deleteDataToMerchantAttr",merchantAttr);
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToMerchantAttr】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     * 同时保存客户基本信息和客户属性
+     * 入参为:
+     *
+     * @param boMerchantInfo 用户信息
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public String saveDataToBoMerchantAndBoMerchantAttr(String boMerchantInfo) throws RuntimeException {
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoMerchantAndBoMerchantAttr】保存数据入参"+boMerchantInfo);
+
+        return null;
+    }
+
+    @Override
+    public String saveDataToMerchantAndMerchantAttr(String merchantInfo) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String updateDataToMerchant(String merchant) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String updateDataToMerchantAttr(String merchantAttr) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String updateDataToMerchantAndMerchantAttr(String merchantInfo) throws RuntimeException {
+        return null;
+    }
+
+    /**
+     * 根据客户ID查询客户信息,包括基本信息和属性信息
+     * @param merchant
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public Merchant queryDataToMerchant(Merchant merchant) throws RuntimeException {
+        LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToMerchant】保存数据入参 : " + merchant);
+        //为了保险起见,再测检测reqList 是否有值
+        if(merchant == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToMerchant】保存数据出错 : " + merchant);
+            throw new IllegalArgumentException("请求参数错误,merchant : " + merchant);
+        }
+
+        Merchant newMerchant  = sqlSessionTemplate.selectOne("userServiceDAOImpl.queryDataToMerchant",merchant);
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToMerchant】保存数据出参 :newMerchant " + newMerchant);
+
+        return newMerchant;
+    }
+
+    @Override
+    public List<MerchantAttr> queryDataToMerchantAttr(MerchantAttr merchantAttr) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String queryDataToMerchantAndMerchantAttr(String merchantInfo) throws RuntimeException {
+        return null;
+    }
+
+    /**
+     *
+     * 查询 客户基本信息(过程表bo_merchant)
+     *
+     * @param boMerchant
+     * @return
+     * @throws Exception
+     */
+    public List<BoMerchant> queryBoMerchant(BoMerchant boMerchant) throws Exception{
+        LoggerEngine.debug("----【UserServiceDAOImpl.queryBoMerchantAttr】:"+boMerchant);
+
+        Assert.isNull(boMerchant,"查询bo_merchant 入参为空");
+
+        return sqlSessionTemplate.selectList("userServiceDAOImpl.queryBoMerchant",boMerchant);
+    }
+
+    /**
+     *
+     * 查询 客户属性信息(过程表 bo_merchant_attr)
+     *
+     * @param boMerchantAttr
+     * @return
+     * @throws Exception
+     */
+    public List<BoMerchantAttr> queryBoMerchantAttr(BoMerchantAttr boMerchantAttr) throws Exception{
+
+        LoggerEngine.debug("【userServiceDAOImpl.queryBoMerchantAttr】:"+boMerchantAttr);
+
+        Assert.isNull(boMerchantAttr,"查询bo_merchant_attr 入参为空");
+
+        return sqlSessionTemplate.selectList("userServiceDAOImpl.queryBoMerchantAttr",boMerchantAttr);
+
+    }
+}

+ 269 - 0
MerchantService/src/main/java/com/java110/merchant/dao/impl/ProductServiceDaoImpl.java

@@ -0,0 +1,269 @@
+package com.java110.merchant.dao.impl;
+
+import com.java110.common.log.LoggerEngine;
+import com.java110.common.util.Assert;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.entity.user.BoCust;
+import com.java110.entity.user.BoCustAttr;
+import com.java110.entity.user.Cust;
+import com.java110.entity.user.CustAttr;
+import com.java110.merchant.dao.IMerchantServiceDao;
+import com.java110.merchant.dao.IProductServiceDao;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * 用户服务 与数据库交互
+ * Created by wuxw on 2017/4/5.
+ */
+
+/**
+ * 用户信息实现工程
+ * Created by wuxw on 2016/12/27.
+ */
+@Service("productServiceDaoImpl")
+@Transactional
+public class ProductServiceDaoImpl extends BaseServiceDao implements IProductServiceDao {
+
+
+
+    /**
+     * 保存用户基本信息
+     * 功能只用与保存用户处理
+     * @param boCust 用户基本信息
+     * @return
+     */
+    @Override
+    public int saveDataToBoCust(BoCust boCust) throws RuntimeException{
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCust】保存数据入参 : " + boCust);
+        int saveFlag = 0;
+        try {
+
+            saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToBoCust",boCust);
+
+        }catch(RuntimeException e){
+            LoggerEngine.error("----【UserServiceDAOImpl.saveDataToBoCust】保存数据异常 : " ,e);
+            return saveFlag;
+        }finally {
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCust】保存数据出参 : saveFlag:" + saveFlag);
+            return saveFlag;
+        }
+
+    }
+
+    /**
+     * 保存用户属性(过程表)
+     *
+     * @param boCustAttr 用户属性
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public int saveDataToBoCustAttr(BoCustAttr boCustAttr) throws RuntimeException {
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据入参 : " + boCustAttr);
+        //为了保险起见,再测检测reqList 是否有值
+        if(boCustAttr == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据出错 : " + boCustAttr);
+            return 0;
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToBoCustAttr",boCustAttr);
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAttr】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+
+    }
+
+    /**
+     * 保存实例数据 客户信息至Cust表中
+     * @param cust
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public int saveDataToCust(Cust cust) throws RuntimeException {
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据入参 : " + cust);
+        //为了保险起见,再测检测reqList 是否有值
+        if(cust == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出错 : " + cust);
+            throw new IllegalArgumentException("请求参数错误,cust : " + cust);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToCust",cust);
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     * 保存实例数据 客户属性信息至CustAttr表中
+     * @param custAttr
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public int saveDataToCustAttr(CustAttr custAttr) throws RuntimeException {
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据入参 : " + custAttr);
+        //为了保险起见,再测检测reqList 是否有值
+        if(custAttr == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出错 : " + custAttr);
+            throw new IllegalArgumentException("请求参数错误,custAttr : " + custAttr);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.insert("userServiceDAOImpl.saveDataToCustAttr",custAttr);
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToCust】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     * 删除用户基本信息(实例数据)
+     * @param cust
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToCust(Cust cust) throws RuntimeException{
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCust】保存数据入参 : " + cust);
+        //为了保险起见,再测检测reqList 是否有值
+        if(cust == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCust】保存数据出错 : " + cust);
+            throw new IllegalArgumentException("请求参数错误,cust : " + cust);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.update("userServiceDAOImpl.deleteDataToCust",cust);
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCust】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     *  删除用户属性(实例数据)
+     * @param custAttr
+     * @return
+     * @throws RuntimeException
+     */
+    public int deleteDataToCustAttr(CustAttr custAttr) throws RuntimeException{
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCustAttr】保存数据入参 : " + custAttr);
+        //为了保险起见,再测检测reqList 是否有值
+        if(custAttr == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCustAttr】保存数据出错 : " + custAttr);
+            throw new IllegalArgumentException("请求参数错误,custAttr : " + custAttr);
+        }
+        int saveFlag = 0;
+
+        saveFlag = sqlSessionTemplate.update("userServiceDAOImpl.deleteDataToCustAttr",custAttr);
+        LoggerEngine.debug("----【UserServiceDAOImpl.deleteDataToCustAttr】保存数据出参 :saveFlag " + saveFlag);
+
+        return saveFlag;
+    }
+
+    /**
+     * 同时保存客户基本信息和客户属性
+     * 入参为:
+     *
+     * @param boCustInfo 用户信息
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public String saveDataToBoCustAndBoCustAttr(String boCustInfo) throws RuntimeException {
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.saveDataToBoCustAndBoCustAttr】保存数据入参"+boCustInfo);
+
+        return null;
+    }
+
+    @Override
+    public String saveDataToCustAndCustAttr(String custInfo) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String updateDataToCust(String cust) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String updateDataToCustAttr(String custAttr) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String updateDataToCustAndCustAttr(String custInfo) throws RuntimeException {
+        return null;
+    }
+
+    /**
+     * 根据客户ID查询客户信息,包括基本信息和属性信息
+     * @param cust
+     * @return
+     * @throws RuntimeException
+     */
+    @Override
+    public Cust queryDataToCust(Cust cust) throws RuntimeException {
+        LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据入参 : " + cust);
+        //为了保险起见,再测检测reqList 是否有值
+        if(cust == null){
+            LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据出错 : " + cust);
+            throw new IllegalArgumentException("请求参数错误,cust : " + cust);
+        }
+
+        Cust newCust  = sqlSessionTemplate.selectOne("userServiceDAOImpl.queryDataToCust",cust);
+
+        LoggerEngine.debug("----【UserServiceDAOImpl.queryDataToCust】保存数据出参 :newCust " + newCust);
+
+        return newCust;
+    }
+
+    @Override
+    public List<CustAttr> queryDataToCustAttr(CustAttr custAttr) throws RuntimeException {
+        return null;
+    }
+
+    @Override
+    public String queryDataToCustAndCustAttr(String custInfo) throws RuntimeException {
+        return null;
+    }
+
+    /**
+     *
+     * 查询 客户基本信息(过程表bo_cust)
+     *
+     * @param boCust
+     * @return
+     * @throws Exception
+     */
+    public List<BoCust> queryBoCust(BoCust boCust) throws Exception{
+        LoggerEngine.debug("----【UserServiceDAOImpl.queryBoCustAttr】:"+boCust);
+
+        Assert.isNull(boCust,"查询bo_cust 入参为空");
+
+        return sqlSessionTemplate.selectList("userServiceDAOImpl.queryBoCust",boCust);
+    }
+
+    /**
+     *
+     * 查询 客户属性信息(过程表 bo_cust_attr)
+     *
+     * @param boCustAttr
+     * @return
+     * @throws Exception
+     */
+    public List<BoCustAttr> queryBoCustAttr(BoCustAttr boCustAttr) throws Exception{
+
+        LoggerEngine.debug("【userServiceDAOImpl.queryBoCustAttr】:"+boCustAttr);
+
+        Assert.isNull(boCustAttr,"查询bo_cust_attr 入参为空");
+
+        return sqlSessionTemplate.selectList("userServiceDAOImpl.queryBoCustAttr",boCustAttr);
+
+    }
+}

+ 125 - 0
config/src/main/resources/mapper/merchant/MerchantServiceDaoImplMapper.xml

@@ -0,0 +1,125 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="merchantServiceDAOImpl">
+
+    <resultMap type="com.java110.entity.merchant.Merchant" id="merchantMap">
+        <id column="merchantId" jdbcType="VARCHAR" property="merchantId"/>
+        <result column="name" jdbcType="VARCHAR" property="name"/>
+        <result column="email" jdbcType="VARCHAR" property="email"/>
+        <result column="cellphone" jdbcType="VARCHAR" property="cellphone"/>
+        <result column="realName" jdbcType="VARCHAR" property="realName"/>
+        <result column="sex" jdbcType="VARCHAR" property="sex"/>
+        <result column="password" jdbcType="VARCHAR" property="password"/>
+        <result column="lanId" jdbcType="VARCHAR" property="lanId"/>
+        <result column="merchantAdress" jdbcType="VARCHAR" property="merchantAdress"/>
+        <result column="merchantType" jdbcType="VARCHAR" property="merchantType"/>
+        <result column="openId" jdbcType="VARCHAR" property="openId"/>
+        <!-- 一对多关系 -->
+        <!-- <collection property="stus" resultMap="Student.StudentResult"></collection>  -->
+        <collection property="merchantAttrs" javaType="com.java110.entity.merchant.MerchantAttr">
+            <id property="merchantId" column="merchantId"/>
+            <result property="attrCd" column="attrCd"/>
+            <result property="value" column="value"/>
+        </collection>
+    </resultMap>
+
+    <!--根据用户Id查询用户角色
+    <select id="findRolesByUserId" resultType="SysRole">
+        SELECT
+        r.*
+        FROM
+        t_role r,
+        t_merchant_role ur
+        WHERE ur.uid = #{merchantId}
+        AND ur.roleId = r.roleId
+        AND ur.status_cd = '1'
+    </select>
+-->
+    <!--保存数据至过程表 bo_merchant 中 -->
+    <insert id="saveDataToBoMerchant" parameterType="com.java110.entity.merchant.BoMerchant">
+        <![CDATA[
+            insert into bo_merchant(boId,merchantId,name,email,cellphone,realName,sex,password,lanId,merchantAdress,merchantType,openId,state)
+            values(#{boId},#{merchantId},#{name},#{email},#{cellphone},#{realName},#{sex},#{password},#{lanId},#{merchantAdress},#{merchantType},#{openId},#{state})
+        ]]>
+    </insert>
+    <!-- 保存数据至过程表bo_merchant_attr 中-->
+    <insert id="saveDataToBoMerchantAttr" parameterType="com.java110.entity.merchant.BoMerchantAttr">
+        <![CDATA[
+            insert into bo_merchant_attr(boId,merchantId,attrCd,value,state)
+            values(#{boId},#{merchantId},#{attrCd},#{value},#{state})
+        ]]>
+    </insert>
+    <!-- 保存 实例客户信息 merchant -->
+    <insert id="saveDataToMerchant" parameterType="com.java110.entity.merchant.Merchant">
+        <![CDATA[
+            insert into merchant(merchantId,name,email,cellphone,realName,sex,password,lanId,merchantAdress,merchantType,openId,status_cd)
+            values(#{merchantId},#{name},#{email},#{cellphone},#{realName},#{sex},#{password},#{lanId},#{merchantAdress},#{merchantType},#{openId},#{status_cd})
+        ]]>
+    </insert>
+    <!-- 删除实例客户信息 merchant -->
+    <insert id="deleteDataToMerchant" parameterType="com.java110.entity.merchant.Merchant">
+        <![CDATA[
+           delete * from merchant c where c.merchantId = #{merchantId}
+        ]]>
+    </insert>
+
+    <!-- 保存 实例客户属性信息 merchant_attr -->
+    <insert id="saveDataToMerchant" parameterType="com.java110.entity.merchant.MerchantAttr">
+        <![CDATA[
+            insert into merchant_attr(merchantId,attrCd,value,status_cd)
+            values(#{merchantId},#{attrCd},#{value},#{status_cd})
+        ]]>
+    </insert>
+    <!-- 删除实例客户信息 merchant -->
+    <update id="deleteDataToMerchantAttr" parameterType="com.java110.entity.merchant.MerchantAttr">
+           delete * from merchant_attr ct where 1=1
+           <if test="merchantId != null and merchantId != ''">
+               and ct.merchantId = #{merchantId}
+           </if>
+            <if test="attrCd != null and attrCd != ''">
+                and ct.attrCd = #{attrCd}
+            </if>
+    </update>
+    <!--根据客户ID 查询客户信息,其中包括 merchant 和merchantAttr 数据-->
+    <select id="queryDataToMerchant" parameterType="com.java110.entity.merchant.Merchant" resultMap="merchantMap">
+        <![CDATA[
+            select c.merchantId,c.name,c.email,c.cellphone,c.realName,c.sex,c.password,c.lanId,c.merchantAdress,c.merchantType,c.openId,
+            ca.merchantId,ca.attrCd,ca.value
+             from merchant c, merchant_attr ca where c.merchantId= ca.merchantId
+            and c.merchantId = #{merchantId}
+            and c.status_cd = '0'
+        ]]>
+    </select>
+
+    <!-- 查询客户过程数据 -->
+    <select id="queryBoMerchant" parameterType="com.java110.entity.merchant.BoMerchant" resultType="com.java110.entity.merchant.BoMerchant">
+        select bc.boId,bc.merchantId,bc.name,bc.email,bc.cellphone,bc.realName,bc.sex,bc.password,bc.lanId,bc.merchantAdress,bc.merchantType,bc.openId,bc.create_dt
+        from bo_merchant bc where 1=1
+        <if test="boId != null and boId != ''">
+            and bc.boId = #{boId}
+        </if>
+        <if test="merchantId != null and merchantId != ''">
+            and bc.merchantId = #{merchantId}
+        </if>
+        and bc.state in ('ADD','DEL')
+        <if test="create_dt != null and create_dt != ''">
+            order by bc.create_dt desc
+        </if>
+    </select>
+    <!-- 查询客户属性过程表-->
+    <select id="queryBoMerchantAttr" parameterType="com.java110.entity.merchant.BoMerchantAttr" resultType="com.java110.entity.merchant.BoMerchantAttr">
+        select bca.boId,bca.merchantId,bca.attrCd,bca.value,bca.state,bca.create_dt from bo_merchant_attr bca where 1=1
+        <if test="boId !=null and boId != ''">
+            and bca.boId = #{boId}
+        </if>
+        <if test="merchantId != null and merchantId != ''">
+            and bca.merchantId = #{merchantId}
+        </if>
+        <if test="create_dt != null and create_dt != ''">
+            order by bc.create_dt desc
+        </if>
+    </select>
+
+</mapper>