fj-dc/.svn/pristine/57/57b7b80ebc3f7b0576edcaeb24289f5581c0cc6f.svn-base

package cn.com.goldenwater.dcproj.service.impl.audit;

import cn.com.goldenwater.core.service.AbstractCrudService;
import cn.com.goldenwater.dcproj.dao.BisInspAuditDao;
import cn.com.goldenwater.dcproj.model.BisInspAudit;
import cn.com.goldenwater.dcproj.model.BisInspAuditPlmb;
import cn.com.goldenwater.dcproj.param.BisInspAuditParam;
import cn.com.goldenwater.dcproj.service.BisInspAuditPlmbService;
import cn.com.goldenwater.dcproj.service.BisInspAuditService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;

/**
 * @author lhc
 * @date 2019-10-31
 */
@Service
@Transactional
public class BisInspAuditServiceImpl extends AbstractCrudService<BisInspAudit, BisInspAuditParam> implements BisInspAuditService {

    @Autowired
    private BisInspAuditDao bisInspAuditDao;
    @Autowired
    private ObjUpdateStateObjFactory stateObjFactory;
    @Autowired
    private BisInspAuditPlmbService bisInspAuditPlmbService;

    public BisInspAuditServiceImpl(BisInspAuditDao bisInspAuditDao) {
        super(bisInspAuditDao);
        this.bisInspAuditDao = bisInspAuditDao;
    }

    @Override
    public int insert(BisInspAudit bisInspAudit) {
        int effRow = 0;
        bisInspAudit.setIntm(new Date());
        bisInspAudit.setUptm(new Date());
        bisInspAudit.setDataStat("0");
        effRow = this.bisInspAuditDao.insert(bisInspAudit);

        //插入问题信息
        if (bisInspAudit.getBisInspAuditPlmbs() != null) {
            for (BisInspAuditPlmb bisInspAuditPlmb : bisInspAudit.getBisInspAuditPlmbs()) {
                bisInspAuditPlmb.setDataStat("0");
                bisInspAuditPlmb.setObjId(bisInspAudit.getObjId());
                bisInspAuditPlmb.setRgstrId(bisInspAudit.getRgstrId());
                bisInspAuditPlmb.setpersId(bisInspAudit.getPersId());
                bisInspAuditPlmb.setAuditId(bisInspAudit.getId());
                bisInspAuditPlmbService.insert(bisInspAuditPlmb);
            }
        }
        //根据审核信息更新登记表状态
        stateObjFactory.CreateObj(bisInspAudit.getPtype()).updatState(bisInspAudit.getRgstrId(), bisInspAudit.getState(), bisInspAudit.getVillType());
        return effRow;
    }

    @Override
    public int update(BisInspAudit bisInspAudit) {
        int effRow = 0;
        bisInspAudit.setUptm(new Date());
        effRow = this.bisInspAuditDao.update(bisInspAudit);
        //根据审核记录ID，删除所有标记问题
        bisInspAuditPlmbService.deleteByAuditId(bisInspAudit.getId());
        //插入新的问题
        if (bisInspAudit.getBisInspAuditPlmbs() != null) {
            for (BisInspAuditPlmb bisInspAuditPlmb : bisInspAudit.getBisInspAuditPlmbs()) {
                bisInspAuditPlmb.setDataStat("0");
                bisInspAuditPlmb.setObjId(bisInspAudit.getObjId());
                bisInspAuditPlmb.setRgstrId(bisInspAudit.getRgstrId());
                bisInspAuditPlmb.setpersId(bisInspAudit.getPersId());
                bisInspAuditPlmb.setAuditId(bisInspAudit.getId());
                bisInspAuditPlmbService.insert(bisInspAuditPlmb);
            }
        }
        //根据审核信息更新登记表状态
        stateObjFactory.CreateObj(bisInspAudit.getPtype()).updatState(bisInspAudit.getRgstrId(), bisInspAudit.getState(), bisInspAudit.getVillType());
        return effRow;
    }

    @Override
    public int delete(String id) {

        return this.bisInspAuditDao.delete(id);
    }


    @Override
    public List<BisInspAudit> getAuditByRgsId(String rgsrId, String pType, String villType) {
        return this.bisInspAuditDao.getAuditByRgsId(rgsrId, pType, villType);
    }
}