jialh
昨天 dd6687b118561100e1677e88a9c2f5842a54c531
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
package com.java110.store.dao.impl;
 
import com.alibaba.fastjson.JSONObject;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.exception.DAOException;
import com.java110.utils.util.DateUtil;
import com.java110.core.base.dao.BaseServiceDao;
import com.java110.store.dao.IContractServiceDao;
import org.slf4j.Logger;
import com.java110.core.log.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.List;
import java.util.Map;
 
/**
 * 合同管理服务 与数据库交互
 * Created by wuxw on 2017/4/5.
 */
@Service("contractServiceDaoImpl")
//@Transactional
public class ContractServiceDaoImpl extends BaseServiceDao implements IContractServiceDao {
 
    private static Logger logger = LoggerFactory.getLogger(ContractServiceDaoImpl.class);
 
 
 
 
 
    /**
     * 保存合同管理信息 到 instance
     * @param info   bId 信息
     * @throws DAOException DAO异常
     */
    @Override
    public void saveContractInfo(Map info) throws DAOException {
        logger.debug("保存合同管理信息Instance 入参 info : {}",info);
 
        int saveFlag = sqlSessionTemplate.insert("contractServiceDaoImpl.saveContractInfo",info);
 
        if(saveFlag < 1){
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存合同管理信息Instance数据失败:"+ JSONObject.toJSONString(info));
        }
    }
 
 
    /**
     * 查询合同管理信息(instance)
     * @param info bId 信息
     * @return List<Map>
     * @throws DAOException DAO异常
     */
    @Override
    public List<Map> getContractInfo(Map info) throws DAOException {
        logger.debug("查询合同管理信息 入参 info : {}",info);
 
        List<Map> businessContractInfos = sqlSessionTemplate.selectList("contractServiceDaoImpl.getContractInfo",info);
 
        return businessContractInfos;
    }
 
 
    /**
     * 修改合同管理信息
     * @param info 修改信息
     * @throws DAOException DAO异常
     */
    @Override
    public void updateContractInfo(Map info) throws DAOException {
        logger.debug("修改合同管理信息Instance 入参 info : {}",info);
 
        int saveFlag = sqlSessionTemplate.update("contractServiceDaoImpl.updateContractInfo",info);
 
        if(saveFlag < 1){
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改合同管理信息Instance数据失败:"+ JSONObject.toJSONString(info));
        }
    }
 
    // ===================== 新增:广告信息 保存或更新 =====================
    @Override
    public void saveOrUpdateAdContractInfo(Map info) throws DAOException {
        logger.debug("保存或更新广告信息 入参 info : {}", info);
 
        int saveFlag = sqlSessionTemplate.insert("contractServiceDaoImpl.saveOrUpdateAdContractInfo", info);
 
        if (saveFlag < 1) {
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存或更新广告信息失败:" + JSONObject.toJSONString(info));
        }
    }
 
    // ===================== 新增:合同金额明细 保存或更新 =====================
    @Override
    public void saveOrUpdateContractAmountDetail(Map info) throws DAOException {
        logger.debug("保存或更新合同金额明细 入参 info : {}", info);
 
        int saveFlag = sqlSessionTemplate.insert("contractServiceDaoImpl.saveOrUpdateContractAmountDetail", info);
 
        if (saveFlag < 1) {
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存或更新合同金额明细失败:" + JSONObject.toJSONString(info));
        }
    }
 
    // ===================== 新增:合同管理分成 保存或更新 =====================
    @Override
    public void saveOrUpdateContractManagementShare(Map info) throws DAOException {
        logger.debug("保存或更新合同管理分成 入参 info : {}", info);
 
        int saveFlag = sqlSessionTemplate.insert("contractServiceDaoImpl.saveOrUpdateContractManagementShare", info);
 
        if (saveFlag < 1) {
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存或更新合同管理分成失败:" + JSONObject.toJSONString(info));
        }
    }
 
    // ===================== 新增:合同缴费状态 保存或更新 =====================
    @Override
    public void saveOrUpdateContractPaymentStatus(Map info) throws DAOException {
        logger.debug("保存或更新合同缴费状态 入参 info : {}", info);
 
        int saveFlag = sqlSessionTemplate.insert("contractServiceDaoImpl.saveOrUpdateContractPaymentStatus", info);
 
        if (saveFlag < 1) {
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存或更新合同缴费状态失败:" + JSONObject.toJSONString(info));
        }
    }
     /**
     * 查询合同管理数量
     * @param info 合同管理信息
     * @return 合同管理数量
     */
    @Override
    public int queryContractsCount(Map info) {
        logger.debug("查询合同管理数据 入参 info : {}",info);
 
        List<Map> businessContractInfos = sqlSessionTemplate.selectList("contractServiceDaoImpl.queryContractsCount", info);
        if (businessContractInfos.size() < 1) {
            return 0;
        }
 
        return Integer.parseInt(businessContractInfos.get(0).get("count").toString());
    }
 
    @Override
    public List<Map> queryContractsByOwnerIds(Map info) {
        logger.debug("查询合同管理数据 入参 info : {}",info);
 
        List<Map> result = sqlSessionTemplate.selectList("contractServiceDaoImpl.queryContractsByOwnerIds", info);
        return result;
    }
 
 
}