| | |
| | | import com.fzzy.igds.constant.Constant; |
| | | import com.fzzy.igds.constant.FoodVariety; |
| | | import com.fzzy.igds.constant.RedisConst; |
| | | import com.fzzy.igds.data.IgdsBaseParam; |
| | | import com.fzzy.igds.data.InoutData; |
| | | import com.fzzy.igds.data.InoutParam; |
| | | import com.fzzy.igds.data.InoutPrintBill; |
| | |
| | | import org.apache.commons.lang3.time.DateFormatUtils; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.math.BigDecimal; |
| | | import java.text.DecimalFormat; |
| | |
| | | |
| | | /** |
| | | * 分页查询数据 |
| | | * |
| | | * @param page |
| | | * @param param |
| | | */ |
| | | public void listPageInout(Page<InoutRecord> page, InoutParam param) { |
| | | if(StringUtils.isBlank(param.getCompanyId())){ |
| | | if (StringUtils.isBlank(param.getCompanyId())) { |
| | | param.setCompanyId(ContextUtil.getCompanyId()); |
| | | } |
| | | if(StringUtils.isBlank(param.getDeptId())){ |
| | | if (StringUtils.isBlank(param.getDeptId())) { |
| | | param.setDeptId(ContextUtil.subDeptId(null)); |
| | | } |
| | | QueryWrapper<InoutRecord> queryWrapper = getQueryWrapper(param); |
| | |
| | | |
| | | /** |
| | | * 查询数据集合 |
| | | * |
| | | * @param param |
| | | */ |
| | | public List<InoutRecord> listInout(InoutParam param) { |
| | | if(StringUtils.isBlank(param.getCompanyId())){ |
| | | if (StringUtils.isBlank(param.getCompanyId())) { |
| | | param.setCompanyId(ContextUtil.getCompanyId()); |
| | | } |
| | | if(StringUtils.isBlank(param.getDeptId())){ |
| | | if (StringUtils.isBlank(param.getDeptId())) { |
| | | param.setDeptId(ContextUtil.subDeptId(null)); |
| | | } |
| | | QueryWrapper<InoutRecord> queryWrapper = getQueryWrapper(param); |
| | |
| | | |
| | | /** |
| | | * 封装查询条件 |
| | | * |
| | | * @param param |
| | | */ |
| | | public QueryWrapper<InoutRecord> getQueryWrapper(InoutParam param) { |
| | |
| | | queryWrapper.eq("company_id", param.getCompanyId()); |
| | | } |
| | | if (StringUtils.isNotBlank(param.getDeptId())) { |
| | | queryWrapper.eq("dept_id", param.getDeptId()); |
| | | queryWrapper.likeRight("dept_id", param.getDeptId()); |
| | | } |
| | | if (StringUtils.isNotBlank(param.getCustomerName())) { |
| | | queryWrapper.like("customer_name", param.getCustomerName()); |
| | |
| | | return queryWrapper; |
| | | } |
| | | |
| | | /** |
| | | * 根据时间类型,获取已完成的正常单据 |
| | | * @param timeType |
| | | * @param param |
| | | * @return |
| | | */ |
| | | public List<InoutRecord> getCompleteInoutByTime(String timeType, IgdsBaseParam param) { |
| | | if(StringUtils.isBlank(timeType)){ |
| | | return null; |
| | | } |
| | | |
| | | QueryWrapper<InoutRecord> queryWrapper = new QueryWrapper<>(); |
| | | |
| | | queryWrapper.likeRight("dept_id", param.getDeptId()); |
| | | queryWrapper.likeRight("progress", Constant.PROGRESS_RECORD); //已完成的单据 |
| | | queryWrapper.ne("record_status", Constant.RECORD_STATUS_DEL); //不是删除的单子,即正常的单子 |
| | | queryWrapper.ge(timeType, param.getStart()); |
| | | queryWrapper.le(timeType, param.getEnd()); |
| | | queryWrapper.orderByAsc("complete_time"); |
| | | |
| | | return inoutRecordMapper.selectList(queryWrapper); |
| | | } |
| | | |
| | | /** |
| | | * 查询数据 |
| | | * |
| | | * @param param |
| | | * @return |
| | | */ |
| | | public InoutRecord selectOne(InoutParam param) { |
| | | if(StringUtils.isBlank(param.getCompanyId())){ |
| | | if (StringUtils.isBlank(param.getCompanyId())) { |
| | | param.setCompanyId(ContextUtil.getCompanyId()); |
| | | } |
| | | QueryWrapper<InoutRecord> queryWrapper = getQueryWrapper(param); |
| | |
| | | |
| | | /** |
| | | * 验证车牌号是否在流程中 |
| | | * |
| | | * @param companyId |
| | | * @param plateNum |
| | | * @return |
| | |
| | | queryWrapper.eq("company_id", companyId); |
| | | queryWrapper.eq("plate_num", plateNum); |
| | | queryWrapper.ne("progress", Constant.PROGRESS_RECORD); |
| | | queryWrapper.eq("record_status", "NORMAL"); |
| | | queryWrapper.or(); |
| | | queryWrapper.eq("record_status", Constant.RECORD_STATUS_ADD); //补录单子的单子 |
| | | |
| | | return inoutRecordMapper.selectCount(queryWrapper); |
| | | } |
| | | |
| | | /** |
| | | * 手动补单 |
| | | * |
| | | * @param data |
| | | * @return |
| | | */ |
| | |
| | | //补单数据直接到结果状态 |
| | | data.setRecordStatus(Constant.RECORD_STATUS_ADD); |
| | | data.setProgress(Constant.PROGRESS_RECORD); |
| | | if(null != data.getPerWet() && data.getPerWet() > 0){ |
| | | if (null != data.getPerWet() && data.getPerWet() > 0) { |
| | | data.setCheckStatus(Constant.STATUS_CHECK); |
| | | } |
| | | String loginUser = ContextUtil.getLoginUserName(); |
| | |
| | | data.setId("R_" + id); |
| | | } else if (Constant.TYPE_OUT.equals(data.getType())) { |
| | | data.setId("C_" + id); |
| | | }else { |
| | | } else { |
| | | data.setId("M_" + id); |
| | | } |
| | | } |
| | |
| | | //TODO 更新缓存 |
| | | //updateInoutCache(data); |
| | | return num; |
| | | |
| | | |
| | | } |
| | | |
| | | /** |
| | |
| | | |
| | | /** |
| | | * 异常终止 |
| | | * |
| | | * @param data |
| | | * @return |
| | | */ |
| | |
| | | |
| | | //TODO 删除缓存 |
| | | |
| | | if(i > 0){ |
| | | if (i > 0) { |
| | | return null; |
| | | }else { |
| | | } else { |
| | | return "操作失败!"; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 出入库流程ID创建 202001030001 202001030001 |
| | | * |
| | | * @param registerTime |
| | | * @param companyId |
| | | * @return |
| | |
| | | |
| | | /** |
| | | * 查询最大id号,为空则返回null |
| | | * |
| | | * @param companyId |
| | | * @param timeKey |
| | | * @return |
| | |
| | | queryWrapper.orderByDesc("create_time"); |
| | | |
| | | List<InoutRecord> inoutRecords = inoutRecordMapper.selectList(queryWrapper); |
| | | if(null == inoutRecords || inoutRecords.isEmpty()){ |
| | | if (null == inoutRecords || inoutRecords.isEmpty()) { |
| | | return null; |
| | | }else { |
| | | } else { |
| | | return inoutRecords.get(0).getId(); |
| | | } |
| | | } |