diff --git a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageMapper.java b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageMapper.java index 2a269992..ffea4466 100644 --- a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageMapper.java +++ b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageMapper.java @@ -37,7 +37,7 @@ public interface CrudeOilStorageMapper extends BaseMapper { "\tsum(c.weight) as weight,\n" + "\to.sid as typeSid,\n" + "\tp.weight as pWeight,\n" + - "\tp.price as price\n" + + "\tp.price as price\n," + "\tp.typeSid as typeSid\n" + "FROM\n" + "\tcrude_oil_storage c\n" + @@ -45,7 +45,7 @@ public interface CrudeOilStorageMapper extends BaseMapper { "\tLEFT JOIN tank_information t ON t.sid = c.tankSid\n" + "\tLEFT JOIN crude_oil_type_information o ON o.sid = t.crudeSid\n" + "\twhere c.procSid =#{procSid}\n" + - "\tGROUP BY c.tankSid") + "\tGROUP BY p.typeSid") List getCrudeByProcSid(@Param("procSid")String procSid); @Select("SELECT\n" + "\tc.sid as typeSid\n" + diff --git a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageService.java b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageService.java index eb3828ed..21659759 100644 --- a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageService.java +++ b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/crudeoilstorage/CrudeOilStorageService.java @@ -67,38 +67,40 @@ public class CrudeOilStorageService extends MybatisBaseService().eq("id", StpUtil.getLoginIdAsString())); - //入库记录 - List list=baseMapper.getCrudeByProcSid(dto.getProcSid()); - //要入的的原油类型 - CrudeOilStorageVo v=baseMapper.getTypeByTankSid(dto.getTankSid()); - ProcurementDetails procurementDetails=procurementDetailsMapper.selectOne(new QueryWrapper().eq("sid",dto.getProcSid()).eq("typeSid",v.getTypeSid())); - if(null==procurementDetails){ - return rb.setMsg("订单中没有,所选的原油类型"); - } - for(CrudeOilStorageVo vo:list){ - if(v.getTypeSid().equals(vo.getTypeSid())){ - if((vo.getWeight()+dto.getWeight())>vo.getPWeight()){ - return rb.setMsg("输入的价值大于采购订单的价值,请验证是否正确"); - }else if((vo.getWeight()+dto.getWeight())==vo.getPWeight()){ - //入库价值和采购价值相比 相同修改订单状态 - List procurementDetailsList=procurementDetailsMapper.selectList(new QueryWrapper().eq("sid",dto.getProcSid())); - for(ProcurementDetails pro:procurementDetailsList){ - pro.setState(7); - procurementDetailsMapper.updateById(pro); + //没有订单编号也能录入 + if(null!=dto.getProcSid()){ + SysUser sysUser=sysUserMapper.selectOne(new QueryWrapper().eq("id", StpUtil.getLoginIdAsString())); + //入库记录 + List list=baseMapper.getCrudeByProcSid(dto.getProcSid()); + //要入的的原油类型 + CrudeOilStorageVo v=baseMapper.getTypeByTankSid(dto.getTankSid()); + ProcurementDetails procurementDetails=procurementDetailsMapper.selectOne(new QueryWrapper().eq("sid",dto.getProcSid()).eq("typeSid",v.getTypeSid())); + if(null==procurementDetails){ + return rb.setMsg("订单中没有,所选的原油类型"); + } + for(CrudeOilStorageVo vo:list){ + if(v.getTypeSid().equals(vo.getTypeSid())){ + if( (vo.getWeight()+dto.getWeight())>vo.getPWeight()){ + return rb.setMsg("输入的价值大于采购订单的价值,请验证是否正确"); + }else if((vo.getWeight()+dto.getWeight())==vo.getPWeight()){ + //入库价值和采购价值相比 相同修改订单状态 + List procurementDetailsList=procurementDetailsMapper.selectList(new QueryWrapper().eq("sid",dto.getProcSid())); + for(ProcurementDetails pro:procurementDetailsList){ + pro.setState(7); + procurementDetailsMapper.updateById(pro); + } + //审批记录 + ApprovalRecordDto recordDto=new ApprovalRecordDto(); + recordDto.setProSid(dto.getProcSid()); + recordDto.setApprover(sysUser.getSid()); + recordDto.setApprovalOpinions("完成订单"); + recordDto.setOperate("5"); + recordDto.setApprovalDate(dfmt); + approvalRecordService.save(recordDto); } - //审批记录 - ApprovalRecordDto recordDto=new ApprovalRecordDto(); - recordDto.setProSid(dto.getProcSid()); - recordDto.setApprover(sysUser.getSid()); - recordDto.setApprovalOpinions("完成订单"); - recordDto.setOperate("5"); - recordDto.setApprovalDate(dfmt); - approvalRecordService.save(recordDto); } } } - CrudeOilStorageVo vo=baseMapper.getCreateByProcSid(dto.getProcSid()); CrudeOilStorage entity=new CrudeOilStorage(); BeanUtil.copyProperties(dto, entity, "id", "sid"); String [] file=dto.getCrudeOilStorageFile(); diff --git a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.java b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.java index babf6564..55596f79 100644 --- a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.java +++ b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.java @@ -49,9 +49,9 @@ public interface ProcurementDetailsMapper extends BaseMapper "\t\tWHEN 5 THEN\n" + "\t\t'财务审批' \n" + "\t\tWHEN 6 THEN\n" + - "\t\t'待入库' \n" + + "\t\t'在途' \n" + "\t\tWHEN 7 THEN\n" + - "\t\t'已完成' \n" + + "\t\t'已入库' \n" + "\tEND AS stateValue ,count(1) as amount,\n" + "\tsum(d.price * d.weight) as totalValue\n" + "FROM\n" + @@ -65,4 +65,6 @@ public interface ProcurementDetailsMapper extends BaseMapper ProcurementDetailsVo getProBySid(@Param("sid")String sid); @Select("select * from crude_oil_type_information where sid=#{sid}") CrudeOilTypeInformationVo getCrudeBySid(@Param("sid")String sid); + @Select("select * from procurement_details where state=#{state} group by sid") + List getProByState(@Param("state")String state); } diff --git a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.xml b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.xml index 4a6ebece..82ac464b 100644 --- a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.xml +++ b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsMapper.xml @@ -14,8 +14,8 @@ when 3 then '监管审批' when 4 then '银行审批' when 5 then '财务审批' - when 6 then '待入库' - when 7 then '已完成' + when 6 then '在途' + when 7 then '已入库' end as stateValue,count(1) as amount, sum(d.price * d.weight) as totalValue diff --git a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsRest.java b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsRest.java index 9ebea735..bb999bed 100644 --- a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsRest.java +++ b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsRest.java @@ -77,4 +77,15 @@ public class ProcurementDetailsRest { public ResultBean delete(@PathVariable String sid ){ return RawProcurementDetailsService.del(sid); } + + /** + * 查询在途订单 + * @param state + * @return + */ + @ApiOperation("查询在途订单") + @GetMapping("/getProcByState/{sid}") + public ResultBean getProcByState(@PathVariable String state){ + return RawProcurementDetailsService.getProcByState(state); + } } diff --git a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsService.java b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsService.java index 62c7c850..527810c6 100644 --- a/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsService.java +++ b/yxt-supervise-cyf/yxt-supervise-cyf-biz/src/main/java/com/yxt/supervise/cyf/biz/procurementdetails/ProcurementDetailsService.java @@ -13,6 +13,7 @@ import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.vo.PagerVo; import com.yxt.supervise.cyf.api.approvalrecord.ApprovalRecord; import com.yxt.supervise.cyf.api.approvalrecord.ApprovalRecordDto; +import com.yxt.supervise.cyf.api.crudeoilstorage.CrudeOilStorage; import com.yxt.supervise.cyf.api.crudeoiltypeinformation.CrudeOilTypeInformation; import com.yxt.supervise.cyf.api.crudeoiltypeinformation.CrudeOilTypeInformationDto; import com.yxt.supervise.cyf.api.crudeoiltypeinformation.CrudeOilTypeInformationVo; @@ -26,6 +27,7 @@ import com.yxt.supervise.cyf.api.procurementdetails.ProcurementDetailsVo; import com.yxt.supervise.cyf.api.sysuser.SysUser; import com.yxt.supervise.cyf.biz.approvalrecord.ApprovalRecordMapper; import com.yxt.supervise.cyf.biz.approvalrecord.ApprovalRecordService; +import com.yxt.supervise.cyf.biz.crudeoilstorage.CrudeOilStorageMapper; import com.yxt.supervise.cyf.biz.crudeoiltypeinformation.CrudeOilTypeInformationMapper; import com.yxt.supervise.cyf.biz.crudeoiltypeinformation.CrudeOilTypeInformationService; import com.yxt.supervise.cyf.biz.materialinventory.MaterialInventoryMapper; @@ -46,7 +48,7 @@ import java.util.List; public class ProcurementDetailsService extends MybatisBaseService { @Autowired - MaterialInventoryMapper rawMaterialInventoryMapper; + CrudeOilStorageMapper crudeOilStorageMapper; @Autowired ApprovalRecordService approvalRecordService; @Autowired @@ -244,4 +246,23 @@ public class ProcurementDetailsService extends MybatisBaseService().eq("sid",sid)); return rb.success().setMsg("删除成功"); } + public ResultBean getProcByState(String state){ + ResultBean rb=new ResultBean(); + Listlist=baseMapper.getProByState(state); + for(ProcurementDetailsVo procurementDetailsVo:list){ + Listdetails=baseMapper.selectList(new QueryWrapper().eq("sid",procurementDetailsVo.getSid())); + double i=0; + for(ProcurementDetails procurementDetails:details){ + i=i+(procurementDetails.getWeight()*procurementDetails.getPrice()); + } + procurementDetailsVo.setTotalValue(i); + list.add(procurementDetailsVo); + //入库数量 + + } + + + return rb.success().setData(list); + } + }