| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544 |
- package cn.com.goldenwater.dcproj.service.impl.waga;
- import cn.com.goldenwater.core.service.AbstractCrudService;
- import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
- import cn.com.goldenwater.dcproj.constValue.SplitValue;
- import cn.com.goldenwater.dcproj.constValue.StateEnum;
- import cn.com.goldenwater.dcproj.constValue.WagaEnum;
- import cn.com.goldenwater.dcproj.dao.*;
- import cn.com.goldenwater.dcproj.model.*;
- import cn.com.goldenwater.dcproj.param.*;
- import cn.com.goldenwater.dcproj.service.AttWagaRgstrService;
- import cn.com.goldenwater.dcproj.service.BisInspObjStrategy;
- import cn.com.goldenwater.dcproj.service.BisInspWagaPblmService;
- import cn.com.goldenwater.dcproj.util.StringUtil;
- import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
- import cn.com.goldenwater.dcproj.utils.Builder;
- import cn.com.goldenwater.dcproj.utils.expExcel.ExportUtil;
- import cn.com.goldenwater.id.util.UuidUtil;
- import com.github.pagehelper.PageHelper;
- import com.github.pagehelper.PageInfo;
- import org.apache.commons.lang3.StringUtils;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Service;
- import org.springframework.transaction.annotation.Transactional;
- import javax.servlet.http.HttpServletResponse;
- import java.util.Date;
- import java.util.List;
- /**
- * @author lune
- * @date 2019-4-22
- */
- @Service
- @Transactional(rollbackFor = Exception.class)
- public class AttWagaRgstrServiceImpl extends AbstractCrudService<AttWagaRgstr, AttWagaRgstrParam> implements AttWagaRgstrService, BisInspObjStrategy {
- @Autowired
- private AttWagaRgstrDao attWagaRgstrDao;
- @Autowired
- private BisInspPblmDao bisInspPblmDao;
- @Autowired
- private BisInspAllObjDao bisInspAllObjDao;
- @Autowired
- private BisInspWagaMrsCiDao bisInspWagaMrsCiDao;
- @Autowired
- private BisInspWagaSafeManageDao bisInspWagaSafeManageDao;
- @Autowired
- private BisInspWagaDmamInfoDao bisInspWagaDmamInfoDao;
- @Autowired
- private BisInspWagaProenInfoDao bisInspWagaProenInfoDao;
- @Autowired
- private AttAdXBaseDao attAdXBaseDao;
- @Autowired
- private BisInspWagaPblmService bisInspWagaPblmService;
- public AttWagaRgstrServiceImpl(AttWagaRgstrDao attWagaRgstrDao) {
- super(attWagaRgstrDao);
- this.attWagaRgstrDao = attWagaRgstrDao;
- }
- @Override
- public AttWagaRgstr get(String key) {
- AttWagaRgstr rgstr = super.get(key);
- if (!"2".equals(rgstr.getRectStat())) {
- checkFinished(rgstr);
- }
- return rgstr;
- }
- /**
- * 更新整改问题状态
- * 判断问题是否全部整改
- *
- * @param rgstr
- */
- private void checkFinished(AttWagaRgstr rgstr) {
- String rectStat = "0";
- List<BisInspWagaPblm> pblmMendList = bisInspWagaPblmService.findList(Builder.of(BisInspWagaPblmParam::new).with(BisInspWagaPblmParam::setObjCode, rgstr.getObjCode()).build());
- if (pblmMendList == null || pblmMendList.size() == 0) {
- rectStat = "2";
- } else {
- long total = pblmMendList.size();
- long revw = pblmMendList.stream().filter(p -> "2".equals(p.getRevwState())).count();
- if (total == revw) {
- rectStat = "2";
- } else if (total > revw && revw != 0) {
- rectStat = "1";
- }
- }
- if (!rectStat.equals(rgstr.getRectStat())) {
- rgstr.setRectStat(rectStat);
- // bisInspRslkbkRgstrDao.update(rgstr);
- }
- }
- @Override
- public void insertObj(BisInspAllObj bisInspAllObj, String persId) {
- String state = StateEnum.NOWASTSTATE.getKey();
- AttWagaRgstr wagaRgstr = new AttWagaRgstr();
- AttWagaBase wagaBase = wagaBaseDao.get(bisInspAllObj.getCode());
- String rgstId = UuidUtil.uuid();
- wagaRgstr.setId(rgstId);
- wagaRgstr.setSafeStat(state);
- wagaRgstr.setProenStat(state);
- wagaRgstr.setMrsCiStat(state);
- wagaRgstr.setDmamStat(state);
- wagaRgstr.setLocationXiang(wagaBase.getLocationXiang());
- wagaRgstr.setAdCode(wagaBase.getAdCode());
- wagaRgstr.setState(state);
- wagaRgstr.setCenterX(wagaBase.getCenterX());
- wagaRgstr.setCenterY(wagaBase.getCenterY());
- wagaRgstr.setDataStat(state);
- wagaRgstr.setEngScal(wagaBase.getEngScal());
- wagaRgstr.setGateAdmName(wagaBase.getGateAdmName());
- wagaRgstr.setGateFlow(wagaBase.getGateFlow());
- wagaRgstr.setGateType(wagaBase.getGateType());
- wagaRgstr.setGateName(wagaBase.getGateName());
- wagaRgstr.setGdX(wagaBase.getGdX());
- wagaRgstr.setGdY(wagaBase.getGdY());
- wagaRgstr.setIntm(new Date());
- wagaRgstr.setPersId(persId);
- wagaRgstr.setEngSta(wagaBase.getEngSta());
- wagaRgstr.setLocation(wagaBase.getLocationCun());
- wagaRgstr.setBuidTimeMon(wagaBase.getBuidTimeMon());
- wagaRgstr.setBuidTimeYear(wagaBase.getBuidTimeYear());
- wagaRgstr.setStaTimeMon(wagaBase.getStaTimeMon());
- wagaRgstr.setStaTimeYear(wagaBase.getStaTimeYear());
- wagaRgstr.setObjCode(bisInspAllObj.getCode());
- wagaRgstr.setObjId(bisInspAllObj.getObjId());
- wagaRgstr.setGateAdmOrg(wagaBase.getLocRvName());
- wagaRgstr.setGroupId(bisInspAllObj.getId());
- attWagaRgstrDao.insert(wagaRgstr);
- // 添加子表
- BisInspWagaBase bisInspWagaBase = new BisInspWagaBase();
- bisInspWagaBase.setId(UuidUtil.uuid());
- bisInspWagaBase.setRgstrId(rgstId);
- bisInspWagaBase.setRecPersId(persId);
- bisInspWagaBase.setAdCode(wagaBase.getAdCode());
- if (StringUtils.isNotBlank(wagaBase.getAdCode())) {
- AttAdXBase attAdXBase = attAdXBaseDao.get(wagaBase.getAdCode());
- if (attAdXBase != null) {
- bisInspWagaBase.setAdName(attAdXBase.getAdName());
- bisInspWagaBase.setAdFullName(attAdXBase.getAdFullName());
- }
- }
- bisInspWagaBase.setGateAdmName(wagaBase.getGateAdmName());
- bisInspWagaBase.setGateFlow(wagaBase.getGateFlow());
- bisInspWagaBase.setEngScal(wagaBase.getEngScal());
- bisInspWagaBase.setGateAdmOrg(wagaBase.getGateAdmOrg());
- bisInspWagaBaseDao.insert(bisInspWagaBase);
- }
- @Autowired
- private BisInspWagaBaseDao bisInspWagaBaseDao;
- @Override
- public String getOeseState(String rgstrId) {
- BisInspWagaBaseParam bisInspWagaBaseParam = new BisInspWagaBaseParam();
- bisInspWagaBaseParam.setRgstrId(rgstrId);
- List<BisInspWagaBase> baseList = bisInspWagaBaseDao.findList(bisInspWagaBaseParam);
- if (baseList != null && baseList.size() > 0) {
- return getOeseState(baseList.get(0));
- }
- BisInspWagaBase base = new BisInspWagaBase();
- base.setRgstrId(rgstrId);
- return getOeseState(base);
- }
- @Override
- public int updateBaseData() {
- BisInspWagaBaseParam bisInspWagaBaseParam = new BisInspWagaBaseParam();
- List<BisInspWagaBase> baseList = bisInspWagaBaseDao.findList(bisInspWagaBaseParam);
- for (BisInspWagaBase base : baseList) {
- String oeseState = getOeseState(base);
- bisInspWagaBaseDao.updateOeseInfo(oeseState, base.getRgstrId());
- }
- return 0;
- }
- @Override
- public String getOeseState(BisInspWagaBase base) {
- String flag = StateEnum.COMASTSTATE.getKey();
- if (StateEnum.EXWASTSTATE.getKey().equals(base.getExtDamSafeAppr()) && "4".equals(base.getPrftaofcIsH())) {
- if ("3".equals(base.getExtDamSafeApprInfo()) || "4".equals(base.getExtDamSafeApprInfo())) {
- return StateEnum.NOWASTSTATE.getKey();
- } else if ("2".equals(base.getExtDamSafeApprInfo())) {
- flag = StateEnum.EXWASTSTATE.getKey();
- }
- }
- WagaParam pblmParam = new WagaParam();
- pblmParam.setRgstrId(base.getRgstrId());
- pblmParam.setpType(BisInspEnum.WAGA.getValue());
- pblmParam.setPersId(base.getRecPersId());
- List<BisInspPblm> pblmList = bisInspPblmDao.findWagaPlbmList(pblmParam);
- //处理问题列表
- return getOeseStateByPblmList(pblmList, flag);
- }
- private String getOeseStateByPblmList(List<BisInspPblm> pblmList, String flag) {
- if (!pblmList.isEmpty()) {
- long heaPblmLevelOne = pblmList.stream().filter(pblm -> StringUtils.isNotBlank(pblm.getCheckPointBz()))
- .filter(pblm -> pblm.getCheckPointBz().contains("△"))
- .filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "3".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())))
- .count();
- if (heaPblmLevelOne >= 1) {
- return StateEnum.NOWASTSTATE.getKey();
- }
- long heaPblmLevelTwo = pblmList.stream().filter(pblm -> StringUtils.isNotBlank(pblm.getCheckPointBz()))
- .filter(pblm -> !pblm.getCheckPointBz().contains("△"))
- .filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "3".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())))
- .count();
- if (heaPblmLevelTwo >= 3) {
- return StateEnum.NOWASTSTATE.getKey();
- }
- long heaPblmLevelThree = pblmList.stream().filter(pblm -> StringUtils.isNotBlank(pblm.getCheckPointBz()))
- .filter(pblm -> !pblm.getCheckPointBz().contains("△"))
- .filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "1".equals(pblm.getInspPblmCate())))
- .count();
- if (heaPblmLevelTwo < 3 && heaPblmLevelThree >= 5) {
- return StateEnum.NOWASTSTATE.getKey();
- }
- long comPblmLevelOne = pblmList.stream().filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "1".equals(pblm.getInspPblmCate()))).count();
- if (comPblmLevelOne > 0 && comPblmLevelOne < 5) {
- if (StateEnum.EXWASTSTATE.getKey().compareTo(flag) < 0) {
- return StateEnum.EXWASTSTATE.getKey();
- }
- }
- long comPblmLevelTwo = pblmList.stream().filter(pblm -> !"工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "1".equals(pblm.getInspPblmCate())).count();
- long comPblmLevelTwo1 = pblmList.stream().filter(pblm -> "工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "1".equals(pblm.getInspPblmCate())).count();
- if (comPblmLevelTwo >= 3 || comPblmLevelTwo1 >= 1) {
- if (StateEnum.EXWASTSTATE.getKey().compareTo(flag) < 0) {
- return StateEnum.EXWASTSTATE.getKey();
- }
- }
- long comPblmLevelThree = pblmList.stream().filter(pblm -> !"工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "0".equals(pblm.getInspPblmCate())).count();
- long comPblmLevelThree1 = pblmList.stream().filter(pblm -> "工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "0".equals(pblm.getInspPblmCate())).count();
- if (comPblmLevelThree >= 8 || comPblmLevelThree1 >= 5) {
- if (StateEnum.EXWASTSTATE.getKey().compareTo(flag) < 0) {
- return StateEnum.EXWASTSTATE.getKey();
- }
- }
- }
- return flag;
- }
- @Override
- public void cleanObjData(String objId) {
- AttWagaRgstrParam attWagaRgstrParam = new AttWagaRgstrParam();
- attWagaRgstrParam.setObjId(objId);
- List<AttWagaRgstr> list = this.attWagaRgstrDao.findList(attWagaRgstrParam);
- if (list.size() > 0) {
- String id = list.get(0).getId();
- BisInspPblmParam bisInspPblmParam = new BisInspPblmParam();
- bisInspPblmParam.setRegid(id);
- bisInspPblmParam.setObjType(BisInspEnum.WAGA.getValue());
- this.bisInspPblmDao.deleteBy(bisInspPblmParam);//删除问题
- //删除水闸督查基本情况
- BisInspWagaBaseParam bisInspWagaBaseParam = new BisInspWagaBaseParam();
- bisInspWagaBaseParam.setRgstrId(id);
- bisInspWagaBaseDao.deleteBy(bisInspWagaBaseParam);
- BisInspWagaMrsCiParam bisInspWagaMrsCi = new BisInspWagaMrsCiParam();
- bisInspWagaMrsCi.setRgstrId(id);
- //删除水闸督查管理责任体系建设和落实情况
- this.bisInspWagaMrsCiDao.deleteBy(bisInspWagaMrsCi);
- BisInspWagaSafeManageParam bisInspWagaSafeManage = new BisInspWagaSafeManageParam();
- bisInspWagaSafeManage.setRgstrId(id);
- //删除水闸督查安全管理情况
- this.bisInspWagaSafeManageDao.deleteBy(bisInspWagaSafeManage);
- BisInspWagaDmamInfoParam bisInspWagaDmamInfoParam = new BisInspWagaDmamInfoParam();
- bisInspWagaDmamInfoParam.setRgstrId(id);
- //删除水闸督查日常管理和维修养护情况
- this.bisInspWagaDmamInfoDao.deleteBy(bisInspWagaDmamInfoParam);
- BisInspWagaProenInfoParam bisInspWagaProenInfoParam = new BisInspWagaProenInfoParam();
- bisInspWagaProenInfoParam.setRgstrId(id);
- //删除水闸督查工程实体情况
- this.bisInspWagaProenInfoDao.deleteBy(bisInspWagaProenInfoParam);
- AttWagaRgstr attWagaRgstr = this.attWagaRgstrDao.get(id);
- //删除登记表
- this.attWagaRgstrDao.delete(id);
- if (attWagaRgstr != null) {
- //删除督查对象
- BisInspAllObjParam bisInspAllObjParam = new BisInspAllObjParam();
- bisInspAllObjParam.setObjId(objId);
- this.bisInspAllObjDao.deleteBy(bisInspAllObjParam);
- }
- }
- }
- @Override
- public PageInfo findObjPageByType(TypeParam typeParam, HttpServletResponse response) {
- return this.findPageWagaPage(typeParam);
- }
- @Override
- public Object findObjListByType(TypeParam typeParam) {
- return this.findWagaPage(typeParam);
- }
- @Override
- public String getType() {
- return BisInspEnum.WAGA.getValue();
- }
- @Override
- public void addState(String rgStrId, String dataStat, String input) {
- if (StringUtils.isBlank(rgStrId)) {
- return;
- }
- AttWagaRgstr attWagaRgstr = attWagaRgstrDao.get(rgStrId);
- attWagaRgstr.setId(rgStrId);
- String stat = "2";
- if (StringUtils.isNotBlank(dataStat)) {
- if (WagaEnum.MRS.getValue().equals(input)) {
- attWagaRgstr.setMrsCiStat(dataStat);
- }
- if (WagaEnum.DAM.getValue().equals(input)) {
- attWagaRgstr.setDmamStat(dataStat);
- }
- if (WagaEnum.PRO.getValue().equals(input)) {
- attWagaRgstr.setProenStat(dataStat);
- }
- if (WagaEnum.SAFE.getValue().equals(input)) {
- attWagaRgstr.setSafeStat(dataStat);
- }
- if (WagaEnum.BASE.getValue().equals(input)) {
- attWagaRgstr.setBaseStat(dataStat);
- }
- } else {
- if (WagaEnum.MRS.getValue().equals(input)) {
- attWagaRgstr.setMrsCiStat(stat);
- }
- if (WagaEnum.DAM.getValue().equals(input)) {
- attWagaRgstr.setDmamStat(stat);
- }
- if (WagaEnum.PRO.getValue().equals(input)) {
- attWagaRgstr.setProenStat(stat);
- }
- if (WagaEnum.SAFE.getValue().equals(input)) {
- attWagaRgstr.setSafeStat(stat);
- }
- if (WagaEnum.BASE.getValue().equals(input)) {
- attWagaRgstr.setBaseStat(stat);
- }
- }
- if (StringUtils.isBlank(attWagaRgstr.getState()) || "0".equals(attWagaRgstr.getState())) {
- attWagaRgstr.setState("1");
- } else {
- attWagaRgstr.setState(attWagaRgstr.getState());
- }
- attWagaRgstrDao.update(attWagaRgstr);
- }
- @Override
- public List<BisInspWagaRgstrDto> findWagaPage(TypeParam typeParam) {
- return attWagaRgstrDao.findWagaPage(typeParam);
- }
- @Override
- public PageInfo<BisInspWagaRgstrDto> findPageWagaPage(TypeParam typeParam) {
- if (StringUtils.isNotBlank(typeParam.getAdCode())) {
- typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD)));
- }
- PageHelper.startPage(typeParam);
- List<BisInspWagaRgstrDto> list = attWagaRgstrDao.findWagaPage(typeParam);
- PageInfo<BisInspWagaRgstrDto> pageInfo = new PageInfo(list);
- return pageInfo;
- }
- @Autowired
- private AttWagaBaseDao wagaBaseDao;
- @Override
- public AttWagaRgstr getByRsvrRgstr(AttWagaRgstrParam wagaRgstrParam) {
- String state = "0";
- String groupId = wagaRgstrParam.getGroupId();
- String persId = wagaRgstrParam.getPersId();
- wagaRgstrParam.setPersId("");
- AttWagaRgstr wagaRgstr = attWagaRgstrDao.getBy(wagaRgstrParam);
- if (wagaRgstr != null) {
- if (wagaRgstr.getIntm() == null) {
- wagaRgstr.setIntm(new Date());
- attWagaRgstrDao.update(wagaRgstr);
- }
- if (!"2".equals(wagaRgstr.getRectStat())) {
- checkFinished(wagaRgstr);
- }
- return wagaRgstr;
- }
- wagaRgstr = new AttWagaRgstr();
- AttWagaBase wagaBase = wagaBaseDao.get(wagaRgstrParam.getObjCode());
- if (wagaBase == null) {
- return wagaRgstr;
- }
- String id = UuidUtil.uuid();
- wagaRgstr.setId(id);
- wagaRgstr.setSafeStat(state);
- wagaRgstr.setProenStat(state);
- wagaRgstr.setMrsCiStat(state);
- wagaRgstr.setDmamStat(state);
- wagaRgstr.setAdCode(wagaBase.getAdCode());
- wagaRgstr.setState(state);
- wagaRgstr.setCenterX(wagaBase.getCenterX());
- wagaRgstr.setCenterY(wagaBase.getCenterY());
- wagaRgstr.setDataStat(state);
- wagaRgstr.setEngScal(wagaBase.getEngScal());
- wagaRgstr.setGateAdmName(wagaBase.getGateAdmName());
- wagaRgstr.setGateFlow(wagaBase.getGateFlow());
- wagaRgstr.setGateType(wagaBase.getGateType());
- wagaRgstr.setGateName(wagaBase.getGateName());
- wagaRgstr.setGdX(wagaBase.getGdX());
- wagaRgstr.setGdY(wagaBase.getGdY());
- wagaRgstr.setIntm(new Date());
- wagaRgstr.setPersId(persId);
- wagaRgstr.setEngSta(wagaBase.getEngSta());
- wagaRgstr.setLocationXiang(wagaBase.getLocationXiang());
- wagaRgstr.setLocation(wagaBase.getLocationCun());
- wagaRgstr.setBuidTimeMon(wagaBase.getBuidTimeMon());
- wagaRgstr.setBuidTimeYear(wagaBase.getBuidTimeYear());
- wagaRgstr.setStaTimeMon(wagaBase.getStaTimeMon());
- wagaRgstr.setStaTimeYear(wagaBase.getStaTimeYear());
- wagaRgstr.setObjCode(wagaRgstrParam.getObjCode());
- wagaRgstr.setObjId(wagaRgstrParam.getObjId());
- wagaRgstr.setGateAdmOrg(wagaBase.getLocRvName());
- wagaRgstr.setGroupId(groupId);
- this.insert(wagaRgstr);
- checkFinished(wagaRgstr);
- BisInspWagaBase bisInspWagaBase = new BisInspWagaBase();
- bisInspWagaBase.setId(UuidUtil.uuid());
- bisInspWagaBase.setRgstrId(id);
- bisInspWagaBase.setRecPersId(persId);
- bisInspWagaBase.setAdCode(wagaBase.getAdCode());
- if (StringUtils.isNotBlank(wagaBase.getAdCode())) {
- AttAdXBase attAdXBase = attAdXBaseDao.get(wagaBase.getAdCode());
- bisInspWagaBase.setAdName(attAdXBase.getAdName());
- bisInspWagaBase.setAdFullName(attAdXBase.getAdFullName());
- }
- bisInspWagaBase.setGateAdmName(wagaBase.getGateAdmName());
- bisInspWagaBase.setGateFlow(wagaBase.getGateFlow());
- bisInspWagaBase.setEngScal(wagaBase.getEngScal());
- bisInspWagaBase.setGateAdmOrg(wagaBase.getGateAdmOrg());
- bisInspWagaBaseDao.insert(bisInspWagaBase);
- return wagaRgstr;
- }
- @Override
- public PageInfo<BisInspWagaRgstrDto> findPcPage(TypeParam typeParam, HttpServletResponse response) {
- PageHelper.startPage(typeParam);
- if (null != typeParam.getAdCodes()) {
- typeParam.setAdCodes(AdLevelUtil.getListAddvcd(typeParam.getAdCodes()));
- }
- if (typeParam.getSortList() != null && typeParam.getSortList().size() > 0) {
- String sortSql = "";
- for (SortListParam sortList : typeParam.getSortList()
- ) {
- if (StringUtils.isNotBlank(sortList.getIsDescOrAsce())) {
- String column = sortList.getColumn();
- column = StringUtil.camelToUnderline(column);
- if ("ascending".equals(sortList.getIsDescOrAsce())) {
- sortSql += " " + column + " ASC";
- } else if ("descending".equals(sortList.getIsDescOrAsce())) {
- sortSql += " " + column + " DESC";
- }
- }
- }
- if (StringUtils.isNotBlank(sortSql)) {
- sortSql = "ORDER BY " + sortSql;
- typeParam.setSortSql(sortSql);
- }
- }
- List<BisInspWagaRgstrDto> list = changeList(attWagaRgstrDao.findPcWagaPage(typeParam));
- PageInfo<BisInspWagaRgstrDto> pageInfo = new PageInfo(list);
- return pageInfo;
- }
- @Override
- public List<BisInspWagaRgstrDto> findPcList(TypeParam typeParam, HttpServletResponse response) {
- List<BisInspWagaRgstrDto> list = attWagaRgstrDao.findPcWagaPage(typeParam);
- ExportUtil.exportExcel(typeParam.getIsExport(), list, response);
- return changeList(list);
- }
- @Override
- public List<BisInspWagaRgstrDto> getListByInspGroupIdObjType(PagePersObjParam pagePersObjParam) {
- return wagaBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
- }
- private List<BisInspWagaRgstrDto> changeList(List<BisInspWagaRgstrDto> list) {
- if (list.size() > 0) {
- for (BisInspWagaRgstrDto b : list) {
- if (b.getAdFullName() != null) {
- if (b.getAdFullName().contains(SplitValue.HENG_SPLIT)) {
- String[] split = b.getAdFullName().split(SplitValue.HENG_SPLIT);
- if (split.length >= 3) {
- b.setProvince(split[0]);
- b.setCity(split[1]);
- b.setCounty(split[2]);
- }
- if (split.length == 2) {
- b.setProvince(split[0]);
- b.setCity(split[1]);
- b.setCounty("");
- }
- } else {
- b.setProvince(b.getAdFullName());
- }
- }
- }
- }
- return list;
- }
- @Override
- public int insert(AttWagaRgstr b) {
- int ret = 1;
- AttWagaRgstrParam wagaRgstrParam = new AttWagaRgstrParam();
- wagaRgstrParam.setObjId(b.getObjId());
- List<AttWagaRgstr> list = attWagaRgstrDao.findList(wagaRgstrParam);
- if (list == null || list.size() == 0) {
- ret = attWagaRgstrDao.insert(b);
- }
- return ret;
- }
- }
|