|  |  | 
 |  |  | package com.dy.pmsPlatform.station; | 
 |  |  |  | 
 |  |  | import cn.hutool.core.codec.Base64; | 
 |  |  | import com.dy.common.webUtil.QueryResultVo; | 
 |  |  | import com.dy.pmsGlobal.daoPlt.PltStationMapper; | 
 |  |  | import com.dy.pmsGlobal.pojoPlt.PltProduct; | 
 |  |  | import com.dy.pmsGlobal.pojoPlt.PltStation; | 
 |  |  | import com.dy.pmsGlobal.util.QrCodeUtil; | 
 |  |  | import com.google.zxing.WriterException; | 
 |  |  | import lombok.extern.slf4j.Slf4j; | 
 |  |  | import org.apache.dubbo.common.utils.PojoUtils; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | import org.springframework.stereotype.Service; | 
 |  |  | import org.springframework.transaction.annotation.Transactional; | 
 |  |  |  | 
 |  |  | import java.io.IOException; | 
 |  |  | import java.util.List; | 
 |  |  | import java.util.Map; | 
 |  |  |  | 
 |  |  | 
 |  |  | public class StationSv { | 
 |  |  |  | 
 |  |  |     private PltStationMapper dao; | 
 |  |  |     private static final String stationPrefix = "103" ; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     public void setDao(PltStationMapper dao) { | 
 |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Transactional | 
 |  |  |     public int save(PltStation station) throws Exception { | 
 |  |  |     public int save(PltStation station) throws RuntimeException { | 
 |  |  |         if(dao.selectByCodeId(station.id,station.code)>0){ | 
 |  |  |             throw new Exception("工站编号已存在"); | 
 |  |  |             throw new RuntimeException("工站编号已存在"); | 
 |  |  |         } | 
 |  |  |         int count = dao.insertSelective(station); | 
 |  |  |         return count; | 
 |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     @Transactional | 
 |  |  |     public int update(PltStation station) throws Exception { | 
 |  |  |     public int update(PltStation station) throws RuntimeException { | 
 |  |  |         if(dao.selectByCodeId(station.id,station.code)>0){ | 
 |  |  |             throw new Exception("工站编号已存在"); | 
 |  |  |             throw new RuntimeException("工站编号已存在"); | 
 |  |  |         } | 
 |  |  |         int count = dao.updateByPrimaryKeySelective(station); | 
 |  |  |         return count; | 
 |  |  | 
 |  |  |  | 
 |  |  |         //查询符合条件的记录 | 
 |  |  |         rsVo.obj = this.dao.selectSome(params) ; | 
 |  |  |         rsVo.obj.parallelStream().forEach(item->{ | 
 |  |  |             item.qrCode = QrCodeUtil.genQrCodeString(stationPrefix+item.id); | 
 |  |  |         }); | 
 |  |  |         return rsVo ; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Transactional | 
 |  |  |     public int disabled(Long id, Boolean disabled) { | 
 |  |  |         PltStation station = new PltStation(); | 
 |  |  |         station.setId(id); | 
 |  |  |         station.setDisabled(disabled); | 
 |  |  |         return dao.updateByPrimaryKeySelective(station); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public List<PltStation> selectAll() { | 
 |  |  |         return dao.selectAll(); | 
 |  |  |     } | 
 |  |  | } | 
 |  |  |  |