| | |
| | | import com.consum.base.pojo.response.FormTransferGoodsVO; |
| | | import com.consum.base.pojo.response.GoodsModelVO; |
| | | import com.consum.base.pojo.response.LWHFromTransferExtendVO; |
| | | import com.consum.model.po.*; |
| | | import com.consum.model.po.BaseGoodsModels; |
| | | import com.consum.model.po.BaseWarehouse; |
| | | import com.consum.model.po.FinSysTenant; |
| | | import com.consum.model.po.FinSysTenantUser; |
| | | import com.consum.model.po.LWhFormOutput; |
| | | import com.consum.model.po.LWhFormTransfer; |
| | | import com.consum.model.po.LWhGoodsRecord; |
| | | import com.consum.model.po.LWhProcureModel; |
| | | import com.consum.model.po.LWhProcureModelUser; |
| | | import com.consum.model.vo.LWhFormOutputVo; |
| | | import com.consum.model.vo.LWhGoodsRecordVo; |
| | | import com.iplatform.model.po.S_user_core; |
| | |
| | | import com.walker.infrastructure.utils.DateUtils; |
| | | import com.walker.infrastructure.utils.StringUtils; |
| | | import com.walker.jdbc.service.BaseServiceImpl; |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import org.apache.commons.compress.utils.Lists; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.interceptor.TransactionAspectSupport; |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * @Description 调拨管理 |
| | |
| | | if (baseGoodsModels != null) { |
| | | lWhProcureModel.setBaseGoodsModelsName(baseGoodsModels.getModelName()); |
| | | } |
| | | // TODO 价格 |
| | | lWhProcureModel.setPrice(10L); |
| | | //根据物品型号查询物品库存 |
| | | int goodsNum = this.lWhGoodsService.queryGoodsModelNum(0, warehouseId, model.getBaseGoodsModelsId(), (short) 1, null); |
| | | int goodsNum = this.lWhGoodsService.queryGoodsModelNum(0, warehouseId, model.getBaseGoodsModelsId(), 1, null); |
| | | lWhProcureModel.setWorehouseCount(goodsNum); |
| | | |
| | | //3.当业务类型为部门分发时 添加部门分发记录和使用人 |
| | |
| | | paramts.put("goodsName", StringUtils.CHAR_PERCENT + transferQry.getGoodsTemplateName() + StringUtils.CHAR_PERCENT); |
| | | } |
| | | // 规格型号 |
| | | if (transferQry.getBaseGoodsTemplateId() != null) { |
| | | if (transferQry.getBaseGoodsModelsId() != null) { |
| | | sql.append("AND bgm.id =:goodsModelId "); |
| | | paramts.put("goodsModelId", transferQry.getBaseGoodsTemplateId()); |
| | | paramts.put("goodsModelId", transferQry.getBaseGoodsModelsId()); |
| | | } |
| | | //调拨机构 |
| | | if (transferQry.getOutAgencyId() != null) { |
| | |
| | | } |
| | | |
| | | |
| | | public GenericPager<Map<String, Object>> queryFormTransferDetailList(TransferQry param) { |
| | | |
| | | HashMap<String, Object> params = new HashMap<>(); |
| | | StringBuilder sql = new StringBuilder("SELECT ft.id,\n" |
| | | + " ft.BUSINESS_FORM_CODE,\n" |
| | | + " bgt.GOODS_NAME,\n" |
| | | + " bgt.CLASSIFICATION,\n" |
| | | + " pm.BASE_GOODS_MODELS_NAME,\n" |
| | | + " pm.COUNTS,\n" |
| | | + " ft.IN_AGENCY_NAME,\n" |
| | | + " ft.OPERATOR_NAME,\n" |
| | | + " ft.CREATE_TIME,\n" |
| | | + " ft.IN_TIME,\n" |
| | | + " ft.OUT_AGENCY_NAME,\n" |
| | | + " ft.OUT_OPERATOR_NAME,\n" |
| | | + " ft.OUTPUT_TIME\n" |
| | | + "FROM l_wh_form_transfer ft\n" |
| | | + " LEFT JOIN l_wh_procure_model pm ON ft.ID = pm.BUSINESS_ID\n" |
| | | + " LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID\n" |
| | | + " LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID where 1=1 "); |
| | | if (StringUtils.isNotEmpty(param.getBusinessFormCode())) { |
| | | sql.append("AND ft.BUSINESS_FORM_CODE = :businessFormCode "); |
| | | params.put("businessFormCode", param.getBusinessFormCode()); |
| | | } |
| | | if (StringUtils.isNotEmpty(param.getGoodsTemplateName())) { |
| | | sql.append("AND bgt.GOODS_NAME like :goodsName "); |
| | | params.put("goodsName", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT); |
| | | } |
| | | if (param.getBaseGoodsModelsId() != null) { |
| | | sql.append("AND bgm.id = :goodsModelId "); |
| | | params.put("goodsModelId", param.getBaseGoodsModelsId()); |
| | | } |
| | | if (param.getOutAgencyId() != null) { |
| | | sql.append("AND ft.OUT_AGENCY_ID like :outAgencyId "); |
| | | params.put("outAgencyId", param.getOutAgencyId()); |
| | | } |
| | | if (param.getOutAgencyId() != null) { |
| | | sql.append("AND ft.IN_AGENCY_ID like :inAgencyId "); |
| | | params.put("inAgencyId", param.getInAgencyId()); |
| | | } |
| | | if (StringUtils.isNotEmpty(param.getOperatorName())) { |
| | | sql.append("AND ft.OPERATOR_NAME = :operatorName "); |
| | | params.put("operatorName", param.getOperatorName()); |
| | | } |
| | | //申请创建时间 |
| | | if (param.getCreateTimeStart() != null) { |
| | | sql.append("AND ft.CREATE_TIME >= :createTimeStart "); |
| | | params.put("createTimeStart", param.getCreateTimeStart() * 1000000); |
| | | } |
| | | if (param.getCreateTimeEnd() != null) { |
| | | sql.append("AND ft.CREATE_TIME < :createTimeEnd "); |
| | | params.put("createTimeEnd", param.getCreateTimeEnd() * 1000000 + 240000); |
| | | } |
| | | //接收时间 |
| | | if (param.getStartTime() != null) { |
| | | sql.append("AND ft.IN_TIME >= :createTimeStart "); |
| | | params.put("createTimeStart", param.getStartTime() * 1000000); |
| | | } |
| | | if (param.getEndTime() != null) { |
| | | sql.append("AND ft.IN_TIME < :createTimeEnd "); |
| | | params.put("createTimeEnd", param.getEndTime() * 1000000 + 240000); |
| | | } |
| | | GenericPager<Map<String, Object>> mapGenericPager = this.selectSplit(sql.toString(), params, param.getPageNum(), param.getPageSize(), new MapperUtil()); |
| | | return mapGenericPager; |
| | | |
| | | } |
| | | |
| | | public List<Map<String, Object>> queryDepartmentTransferOrder() { |
| | | |
| | | String sql = "SELECT ft.id,\n" |
| | | + " ft.BUSINESS_FORM_CODE,\n" |
| | | + " gr.GOODS_TEMPLATE_NAME,\n" |
| | | + " gr.BASE_GOODS_TEMPLATE_ID goodsTemplateId,\n" |
| | | + " ft.CREATE_TIME\n" |
| | | + "\n" |
| | | + "FROM l_wh_form_transfer ft\n" |
| | | + " LEFT JOIN L_WAREHOUSE_FLOW wf ON ft.id = wf.BUSINESS_FORM_ID\n" |
| | | + " left join L_WH_GOODS_RECORD gr on gr.WAREHOUSE_FLOW_ID = wf.id\n" |
| | | + " LEFT JOIN L_GOODS_WH_RECORD gwr on gwr.WAREHOUSE_FLOW_ID = wf.id\n" |
| | | + " left join L_WH_GOODS g on g.id = gwr.WH_GOODS_ID where ft.BUSINESS_TYPE = 1 GROUP BY gr.BASE_GOODS_TEMPLATE_ID \n"; |
| | | HashMap<String, Object> param = new HashMap<>(); |
| | | List<Map<String, Object>> select = this.select(sql, param, new MapperUtil()); |
| | | select.forEach(item -> { |
| | | |
| | | |
| | | }); |
| | | return select; |
| | | |
| | | } |
| | | } |