| | |
| | | import com.project.common.core.domain.entity.SysUser; |
| | | import com.project.common.enums.OrderPre; |
| | | import com.project.common.exception.base.BaseException; |
| | | import com.project.common.sms.YPSmsApi; |
| | | import com.project.common.utils.DateUtils; |
| | | import com.project.common.utils.JsonUtils; |
| | | import com.project.common.utils.SecurityUtils; |
| | | import com.project.common.utils.StringUtils; |
| | | import com.project.enforce.domain.*; |
| | | import com.project.enforce.domain.bo.editBo.*; |
| | | import com.project.enforce.domain.bo.editBo.EnforceComplaintLogBo; |
| | | import com.project.enforce.domain.bo.editBo.EnforceOrderBo; |
| | | import com.project.enforce.domain.bo.editBo.OrderComplaintBo; |
| | | import com.project.enforce.domain.bo.editBo.OrderResultBo; |
| | | import com.project.enforce.domain.bo.queryBo.EnforceOrderQueryBo; |
| | | import com.project.enforce.domain.bo.queryBo.OrderCheckedQueryBo; |
| | | import com.project.enforce.domain.vo.EnforceEvaluateVo; |
| | |
| | | import com.project.system.service.ISysUserService; |
| | | import lombok.RequiredArgsConstructor; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Async; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | |
| | | private final IEnforceCheckLogService checkLogService; |
| | | private final IEnforceComplaintLogService complaintLogService; |
| | | private final IEnforceEvaluateLogService evaluateLogService; |
| | | private final YPSmsService smsService; |
| | | |
| | | @Override//列表查询 |
| | | /** |
| | | * 通用列表-无权限 |
| | | * @param bo 参数 |
| | | * @return 列表 |
| | | */ |
| | | @Override |
| | | public List<EnforceOrderVo> queryCommonList(EnforceOrderQueryBo bo) |
| | | { |
| | | QueryWrapper<EnforceOrder> qw = getQw(bo); |
| | | List<EnforceOrder> list = this.list(qw); |
| | | return Convert.toList(EnforceOrderVo.class , list); |
| | | } |
| | | |
| | | /** |
| | | * 企业执法单列表 |
| | | * @param bo 参数 |
| | | * @return 列表 |
| | | */ |
| | | @Override |
| | | public List<EnforceOrderVo> queryCompanyList(EnforceOrderQueryBo bo) |
| | | { |
| | | QueryWrapper<EnforceOrder> qw = getQw(bo); |
| | | qw.ge("order_status",2); |
| | | List<EnforceOrder> list = this.list(qw); |
| | | return Convert.toList(EnforceOrderVo.class , list); |
| | | } |
| | | |
| | | /** |
| | | * 执法申请单列表 |
| | | * @param bo 参数 |
| | | * @return 列表 |
| | | */ |
| | | @Override |
| | | @DataScope(deptAlias = "apply_dept_id", userAlias = "apply_id") |
| | | public List<EnforceOrderVo> queryList(EnforceOrderQueryBo bo) |
| | | { |
| | |
| | | return Convert.toList(EnforceOrderVo.class , list); |
| | | } |
| | | |
| | | @Override//执法上报列表 |
| | | /** |
| | | * 执法执行单列表 |
| | | * @param bo 参数 |
| | | * @return 列表 |
| | | */ |
| | | @Override |
| | | @DataScope(deptAlias = "execute_dept_id", userAlias = "execute_id") |
| | | public List<EnforceOrderVo> getExecuteList(EnforceOrderQueryBo bo) { |
| | | QueryWrapper<EnforceOrder> qw = getQw(bo); |
| | |
| | | return Convert.toList(EnforceOrderVo.class , list); |
| | | } |
| | | |
| | | @Override//待审核列表 |
| | | /** |
| | | * 待审核列表 |
| | | * @param bo 参数 |
| | | * @return 列表 |
| | | */ |
| | | @Override |
| | | public List<EnforceOrderVo> queryCheckList(EnforceOrderQueryBo bo) |
| | | { |
| | | SysUser loginUser = SecurityUtils.getLoginUser().getUser(); |
| | |
| | | return this.baseMapper.selectCheckList(bo); |
| | | } |
| | | |
| | | /** |
| | | * 审批记录列表 |
| | | * @param bo 参数 |
| | | * @return 列表 |
| | | */ |
| | | @Override |
| | | public List<EnforceOrderVo> queryCheckedList(OrderCheckedQueryBo bo) |
| | | { |
| | |
| | | return this.baseMapper.selectCheckedList(bo); |
| | | } |
| | | |
| | | @Override//信息公式列表 |
| | | |
| | | /** |
| | | * 信息公式列表 |
| | | * @return 列表 |
| | | */ |
| | | @Override |
| | | public List<EnforceOrderVo> showList() |
| | | { |
| | | List<EnforceOrder> list = this.list(lq() |
| | |
| | | return Convert.toList(EnforceOrderVo.class, list); |
| | | } |
| | | |
| | | @Override//id查询 |
| | | /** |
| | | * id查询 |
| | | */ |
| | | @Override |
| | | public EnforceOrderVo queryById(Long orderId) |
| | | { |
| | | EnforceOrder db = this.baseMapper.selectById(orderId); |
| | |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 新增 |
| | | */ |
| | | @Override//添加 |
| | | @Transactional |
| | | public Boolean insertByBo(EnforceOrderBo bo) |
| | |
| | | } |
| | | boolean savePeers = peerService.saveOrUpdateBatch(bo.getPeers()); |
| | | if (savePeers && StringUtils.isNotEmpty(phones)) { |
| | | sendApplyMsg(phones, add.getApplyUser()); |
| | | smsService.sendApplyMsg(phones, add.getApplyUser()); |
| | | } |
| | | return savePeers; |
| | | } |
| | | |
| | | /** |
| | | * 修改 |
| | | */ |
| | | @Override//修改 |
| | | @Transactional |
| | | public Boolean updateByBo(EnforceOrderBo bo) |
| | |
| | | return this.updateById(update); |
| | | } |
| | | |
| | | /** |
| | | * 删除 |
| | | */ |
| | | @Override//删除 |
| | | @Transactional |
| | | public Boolean deleteByIds(Collection<Long> ids) |
| | |
| | | return this.removeByIds(ids); |
| | | } |
| | | |
| | | /** |
| | | * 获取下一级审批人电话 |
| | | */ |
| | | @Override |
| | | public List<String> getCheckPhones(Integer checkLevel, Long applyDeptId) |
| | | { |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | //------------------------------------------------------------------------------------- |
| | | |
| | | |
| | | /** |
| | | * 发送审批短信 |
| | | * @param phones 手机号 |
| | | * @param applyUser 申请人 |
| | | */ |
| | | @Async |
| | | public void sendApplyMsg(List<String> phones, String applyUser) |
| | | { |
| | | String applyMsg = StringUtils.format(StringUtils.format(YPSmsApi.APPLY_TMP, applyUser)); |
| | | phones.forEach(phone-> YPSmsApi.sendSms(phone, applyMsg)); |
| | | } |
| | | |
| | | //保存前校验 |
| | | private void validEntityBeforeSave(EnforceOrder entity) |
| | |
| | | qw.eq(bo.getIsShow() != null, "is_show", bo.getIsShow()); |
| | | qw.eq(bo.getIsEva() != null, "is_eva", bo.getIsEva()); |
| | | qw.eq(bo.getTotalScore() != null, "total_score", bo.getTotalScore()); |
| | | qw.ge(StringUtils.isNotEmpty(bo.getBeginTime()), "in_time", bo.getBeginTime()); |
| | | qw.le(StringUtils.isNotEmpty(bo.getEndTime()), "in_time", bo.getEndTime()); |
| | | if (StringUtils.isNotEmpty(bo.getIsAsc()) && StringUtils.isNotEmpty(bo.getOrderByColumn())){ |
| | | if ("acs".equals(bo.getIsAsc())) { |
| | | qw.orderByAsc(bo.getOrderByColumn()); |