kmall-haikong/kmall-admin/src/main/java/com/kmall/admin/service/impl/ExpressCompanySysServiceImpl.java

package com.kmall.admin.service.impl;

import com.kmall.admin.dao.ExpressCompanySysDao;
import com.kmall.admin.entity.AddressInfoEntity;
import com.kmall.admin.entity.ExpressCompanySysEntity;
import com.kmall.admin.entity.ShopAndAddrVo;
import com.kmall.admin.fromcomm.entity.SysUserEntity;
import com.kmall.admin.service.AddressInfoService;
import com.kmall.admin.service.ExpressCompanySysService;
import com.kmall.admin.utils.ShiroUtils;
import com.kmall.common.utils.RRException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

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

/**
 * 快递公司表Service实现类a
 *
 * @author emato
 * @email admin@qhdswl.com
 * @date 2021-04-02 10:06:15
 */
@Service("expressCompanySysService")
public class ExpressCompanySysServiceImpl implements ExpressCompanySysService {

    @Autowired
    private ExpressCompanySysDao expressCompanySysDao;
    @Autowired
    private AddressInfoService addressInfoService;

    @Override
    public ExpressCompanySysEntity queryObject(Integer id) {
        return expressCompanySysDao.queryObject(id);
    }

    @Override
    public List<ExpressCompanySysEntity> queryList(Map<String, Object> map) {
        return expressCompanySysDao.queryList(map);
    }

    @Override
    public List<ExpressCompanySysEntity> queryExprCompByisValid() {
        return expressCompanySysDao.queryExprCompByisValid();
    }

    @Override
    public int queryTotal(Map<String, Object> map) {
        return expressCompanySysDao.queryTotal(map);
    }

    @Override
    public int save(ExpressCompanySysEntity expressCompanySys) {
        SysUserEntity sysUserEntity = ShiroUtils.getUserEntity();
        expressCompanySys.setCreaterSn(sysUserEntity.getUsername());
        expressCompanySys.setCreateTime(new Date());
        return expressCompanySysDao.save(expressCompanySys);
    }

    @Override
    public int update(ExpressCompanySysEntity expressCompanySys) {
        SysUserEntity sysUserEntity = ShiroUtils.getUserEntity();
        expressCompanySys.setModerSn(sysUserEntity.getUsername());
        expressCompanySys.setModTime(new Date());
        int update = expressCompanySysDao.update(expressCompanySys);
        Integer isValid = expressCompanySys.getIsValid();
        Integer companySysId = expressCompanySys.getId();
        if (isValid.equals(0)) {
//            new Thread(()->{
                List<AddressInfoEntity> addressList = addressInfoService.queryCourieId(companySysId);
                addressList.forEach(addressInfoEntity -> {
                    addressInfoEntity.setIsValid(0);
                    addressInfoService.update(addressInfoEntity);
//                });
            });
        }
        return update;
    }

    @Override
    public int delete(Integer id) {
        return expressCompanySysDao.delete(id);
    }

    @Override
    public int deleteBatch(Integer[]ids) {
        return expressCompanySysDao.deleteBatch(ids);
    }

    @Override
    public void getShopAndAddress(ShopAndAddrVo shopAndAddrVo) {
        AddressInfoEntity infoEntity = addressInfoService.queryIds(shopAndAddrVo);
        if (infoEntity!=null) {
            throw new RRException("该门店已添加这家快递公司！");
        }
        String exprId = shopAndAddrVo.getExprId();
        ExpressCompanySysEntity companySysEntity = expressCompanySysDao.queryObject(exprId);
        Integer isStatus = companySysEntity.getIsValid();
        if (isStatus!=1) {
            throw new RRException("该快递公司已禁用,不能分配！");
        }
        addressInfoService.save(shopAndAddrVo);
    }
}