616 lines
30 KiB
Java
616 lines
30 KiB
Java
package com.cim.idm.controller;
|
||
|
||
import com.alibaba.fastjson.JSON;
|
||
import com.alibaba.fastjson.JSONObject;
|
||
import com.cim.idm.constants.delivery.DeliveryStateEnums;
|
||
import com.cim.idm.constants.receive.ReceiveTypeEnums;
|
||
import com.cim.idm.framework.IDMFrameServiceProxy;
|
||
import com.cim.idm.framework.data.EventInfo;
|
||
import com.cim.idm.model.dto.delivery.DeliveryEditDto;
|
||
import com.cim.idm.model.dto.delivery.StoreDetailDto;
|
||
import com.cim.idm.model.dto.packing.MaterialPackingListDto;
|
||
import com.cim.idm.model.po.MaterialReceiveRequest;
|
||
import com.cim.idm.model.MaterialreceiveActDto;
|
||
import com.cim.idm.model.dto.TrackOutBoDto;
|
||
import com.cim.idm.model.po.delivery.MaterialDelivery;
|
||
import com.cim.idm.mwmsextend.materialpacking.service.MaterialPackingServiceImpl;
|
||
import com.cim.idm.service.IDeliveryService;
|
||
import com.cim.idm.service.IMaterialPackingService;
|
||
import com.cim.idm.service.impl.QMSServiceImpl;
|
||
import com.cim.idm.service.impl.ToSAPServiceImpl;
|
||
import com.cim.idm.utils.AjaxResult;
|
||
import com.cim.idm.utils.EventInfoUtil;
|
||
import com.cim.idm.wmsextend.generic.errorHandler.CustomException;
|
||
import com.cim.idm.wmspackage.materialpacking.MaterialPackingServiceProxy;
|
||
import com.cim.idm.wmspackage.materialpacking.management.data.MaterialPacking;
|
||
import com.cim.idm.wmspackage.materialpacking.management.data.MaterialPackingKey;
|
||
import org.apache.commons.logging.Log;
|
||
import org.apache.commons.logging.LogFactory;
|
||
import org.springframework.beans.factory.annotation.Autowired;
|
||
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
||
import org.springframework.web.bind.annotation.RequestBody;
|
||
import org.springframework.web.bind.annotation.RequestMapping;
|
||
import org.springframework.web.bind.annotation.RequestMethod;
|
||
import org.springframework.web.bind.annotation.RestController;
|
||
|
||
import java.math.BigDecimal;
|
||
import java.sql.Timestamp;
|
||
import java.util.*;
|
||
|
||
import com.cim.idm.service.Impl.SDKMaterialPackingServiceImpl;
|
||
|
||
import javax.annotation.Resource;
|
||
|
||
@RestController
|
||
@RequestMapping("/MaterialReceiveAct")
|
||
@EnableAutoConfiguration
|
||
public class MaterialReceiveActController {
|
||
|
||
@Resource
|
||
private IDeliveryService deliveryService;
|
||
|
||
@Resource
|
||
private IMaterialPackingService mpService;
|
||
|
||
private static Log log = LogFactory.getLog(MaterialReceiveActController.class);
|
||
private EventInfo makeEventInfo;
|
||
|
||
private MaterialPackingServiceImpl MaterialPackingServiceImpl = new MaterialPackingServiceImpl ();
|
||
|
||
@Autowired
|
||
private ToSAPServiceImpl toSAPServiceImpl;
|
||
|
||
@Autowired
|
||
private SDKMaterialPackingServiceImpl SDKMaterialPackingServiceImpl;
|
||
|
||
|
||
private QMSServiceImpl qMSServiceImpl = new QMSServiceImpl();
|
||
|
||
@RequestMapping(value = "/dessiginBoxByAct", method = RequestMethod.POST)
|
||
public AjaxResult dessiginBoxByAct(@RequestBody JSONObject in ) throws Exception{
|
||
|
||
MaterialReceiveRequest materialReceiveRequest = JSON.toJavaObject(in, MaterialReceiveRequest.class);
|
||
String user = materialReceiveRequest.getUser();
|
||
makeEventInfo = new EventInfoUtil().makeEventInfo("dessiginBoxByAct", user, "dessiginBoxByAct");
|
||
List<MaterialPacking> boxList = materialReceiveRequest.getBoxList();
|
||
for (MaterialPacking materialPacking : boxList) {
|
||
String materialQuantity = materialPacking.getMaterialQuantity() + "";
|
||
String siteName = "SDK";
|
||
String materialPackingName = materialPacking.getMaterialPackingName();
|
||
String receiveRequestName = materialPacking.getReceiveRequestName();
|
||
String receiveRequestDetailName = materialPacking.getReceiveRequestDetailName();
|
||
Timestamp makeDate2 = materialPacking.getMakeDate();
|
||
Date makeDate = materialPacking.getMakeDate();
|
||
String receiveActNo2 = materialPacking.getReceiveActNo();
|
||
ModifyRequestQtyInfo(makeEventInfo, siteName, receiveRequestName,
|
||
receiveRequestDetailName, materialQuantity, makeDate2,
|
||
receiveActNo2, materialQuantity,materialPackingName);
|
||
}
|
||
return AjaxResult.me().setResultObj(null);
|
||
|
||
}
|
||
|
||
/**
|
||
*
|
||
* @param eventInfo
|
||
* @param siteName
|
||
* @param receiveRequestName
|
||
* @param receiveRequestDetailName
|
||
* @param receiveQuantity
|
||
* @param
|
||
* @param makeDate
|
||
* @param receiveActNO
|
||
* @param actDetailQuantity
|
||
* @throws Exception
|
||
*/
|
||
public static void ModifyRequestQtyInfo(EventInfo eventInfo,String siteName,
|
||
String receiveRequestName,String receiveRequestDetailName,String receiveQuantity,
|
||
Timestamp makeDate,String receiveActNO,String actDetailQuantity,String materialPackingName) throws Exception
|
||
{
|
||
try
|
||
{
|
||
Map<String, Object> hashMap = new HashMap<String,Object> ();
|
||
//判断标签是否存在
|
||
String sql = "SELECT * FROM MATERIALPACKING T WHERE T.SITENAME = :SITENAME AND T.MATERIALPACKINGNAME = :MATERIALPACKINGNAME";
|
||
hashMap.put("SITENAME", siteName);
|
||
hashMap.put("MATERIALPACKINGNAME", materialPackingName);
|
||
List<Map<String, Object>> queryForList2 = IDMFrameServiceProxy.getSqlTemplate().queryForList(sql, hashMap);
|
||
if (queryForList2 == null || queryForList2.size() < 1) {
|
||
return;
|
||
}
|
||
//修改行项目数量信息
|
||
String sql1 = "UPDATE MATERIALRECEIVEREQUESTDETAIL T SET T.RECEIVEDQUANTITY = T.RECEIVEDQUANTITY - :QTY "
|
||
+ "WHERE T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME AND T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME";
|
||
|
||
String sql2 = "UPDATE MATERIALRECEIVEACTDETAIL T SET T.RECEIVEQUANTITY = T.RECEIVEQUANTITY - :QTY "
|
||
+ "WHERE T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME AND T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME AND T.RECEIVEACTNO = :RECEIVEACTNO";
|
||
|
||
String sql3 = "SELECT T.RECEIVEQUANTITY FROM MATERIALRECEIVEACTDETAIL T WHERE T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME "
|
||
+ "AND T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME AND T.RECEIVEACTNO = :RECEIVEACTNO";
|
||
String sql4 = "DELETE MATERIALRECEIVEACTDETAIL T WHERE T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME "
|
||
+ "AND T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME AND T.RECEIVEACTNO = :RECEIVEACTNO";
|
||
hashMap.put("QTY", actDetailQuantity);
|
||
hashMap.put("RECEIVEREQUESTNAME", receiveRequestName);
|
||
hashMap.put("RECEIVEREQUESTDETAILNAME", receiveRequestDetailName);
|
||
hashMap.put("RECEIVEACTNO", receiveActNO);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(sql1, hashMap);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(sql2, hashMap);
|
||
List<Map<String, Object>> queryForList = IDMFrameServiceProxy.getSqlTemplate().queryForList(sql3, hashMap);
|
||
if (queryForList != null && queryForList.get(0).get("RECEIVEQUANTITY").toString().equals("0")) {
|
||
IDMFrameServiceProxy.getSqlTemplate().update(sql4, hashMap);
|
||
}
|
||
MaterialPackingServiceProxy.getMaterialPackingService().delete(new MaterialPackingKey(siteName, materialPackingName));
|
||
}
|
||
catch(Exception e)
|
||
{
|
||
throw e;
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 创建Box
|
||
* @param in
|
||
* @return
|
||
* @throws CustomException
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value = "/TrackOutBox", method = RequestMethod.POST)
|
||
public AjaxResult TrackOutBox(@RequestBody JSONObject in ) {
|
||
TrackOutBoDto boxs = JSON.toJavaObject(in, TrackOutBoDto.class);
|
||
MaterialreceiveActDto box = boxs.getMaterialreceiveAct();
|
||
String user = boxs.getUser();
|
||
String areaName = box.getAreaName();
|
||
String boxFlag = box.getBoxFlag();
|
||
String boxQuantity = box.getMATERIALQUANTITY();//标签个数
|
||
String charge = box.getCharge();
|
||
String erpFactory = box.getErpFactory();
|
||
String erpLocation = box.getErpLocation();
|
||
String everyBoxQuantity = box.getMATERIALCREATEQUANTITY();//标签数量
|
||
String expirationDay = box.getExpirationDay();
|
||
String fqty = (box.getFqty() == null || "NaN" .equals(box.getFqty())) ? "0" : box.getFqty().toString();
|
||
String funit = box.getFunit();
|
||
String iqcflag = box.getIQCFLAG();
|
||
String is_BATCH = box.getIS_BATCH();
|
||
String locationName = box.getLocationName() == null ? "" : box.getLocationName();
|
||
String makeDate = box.getMakeDate();
|
||
String materialSpecName = box.getMaterialSpecName();
|
||
String materialUnit = box.getMaterialUnit();
|
||
String npFlag = box.getNPFlag();
|
||
String phase = box.getPhase() ==null ? "" : box.getPhase();
|
||
String reasonCode = box.getReasonCode();
|
||
String reasonCodeType = box.getReasonCodeType();
|
||
String receiveActNo = box.getReceiveActNo();
|
||
String receiveQty = box.getRECEIVEDQUANTITY2();//实收数量
|
||
String receiveRequestDetailName = box.getReceiveRequestDetailName();
|
||
// 单据
|
||
String receiveRequestName = boxs.getReceiveRequestName();
|
||
String remark = box.getRemark();
|
||
String sdkid = box.getSdkid() == null ? "" : box.getSdkid();
|
||
String shipRequestDetailName = box.getShipRequestDetailName();
|
||
String shipRequestName = box.getShipRequestName();
|
||
String siteName = box.getSiteName();
|
||
String specName = box.getSpecName() == null ? "":box.getSpecName();
|
||
String supplierCharge = box.getSupplierCharge();
|
||
String supplierName = box.getSUPPLIERNO();
|
||
String truegg = box.getTruegg();
|
||
String salesperson = box.getSALESPERSON();
|
||
String business_UNIT = box.getBUSINESS_UNIT();
|
||
String career_ASSISTANCE = box.getCAREER_ASSISTANCE();
|
||
|
||
String POCATEGORY = box.getPOCATEGORY();
|
||
makeEventInfo = new EventInfoUtil().makeEventInfo("TrackOutBox", user, "TrackOutBox");
|
||
|
||
//判断数量卡控是否正确
|
||
BigDecimal fboxQuantity = new BigDecimal(boxQuantity);//标签个数
|
||
BigDecimal feveryBoxQuantity = new BigDecimal(everyBoxQuantity);//标签数量
|
||
BigDecimal freceiveQty = new BigDecimal(receiveQty);//实收数量
|
||
BigDecimal zero = BigDecimal.ZERO;
|
||
if (fboxQuantity.compareTo(zero) <= 0) {
|
||
return AjaxResult.me().setSuccess(false).setMessage("标签个数不能小于0");
|
||
}
|
||
if (feveryBoxQuantity.compareTo(zero) <= 0) {
|
||
return AjaxResult.me().setSuccess(false).setMessage("标签数量不能小于0");
|
||
}
|
||
if (freceiveQty.compareTo(zero) <= 0) {
|
||
return AjaxResult.me().setSuccess(false).setMessage("接收数量不能小于0");
|
||
}
|
||
String timeKey = null;
|
||
try {
|
||
//生产标签
|
||
timeKey = MaterialPackingServiceImpl.Packing(makeEventInfo, siteName, areaName, receiveQty, boxQuantity,
|
||
everyBoxQuantity, "Y", receiveRequestName, receiveRequestDetailName, materialSpecName,
|
||
receiveActNo, makeDate, shipRequestName, shipRequestDetailName, reasonCodeType, reasonCode,
|
||
erpLocation, erpFactory, charge, supplierName, npFlag, expirationDay, supplierCharge, sdkid,
|
||
locationName, phase, specName, materialUnit, is_BATCH, iqcflag, funit, fqty, remark, truegg,
|
||
salesperson,career_ASSISTANCE,business_UNIT,POCATEGORY);
|
||
} catch (Exception e) {
|
||
// TODO Auto-generated catch block
|
||
e.printStackTrace();
|
||
return AjaxResult.me().setSuccess(false).setMessage(e.toString());
|
||
}
|
||
//更新订单数量
|
||
//1.查询符合条件的Box
|
||
String sql2 = " SELECT * FROM MATERIALPACKING m WHERE RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME"
|
||
+ " AND MATERIALSPECNAME = :MATERIALSPECNAME AND (:PHASE IS NULL OR PHASE = :PHASE) "
|
||
+ "AND (:SDK_ID IS NULL OR SDK_ID = :SDK_ID) AND STOCKSTATE = 'Created' AND LASTEVENTTIMEKEY = :LASTEVENTTIMEKEY";
|
||
Map<String, Object> hashMap = new HashMap<String,Object> ();
|
||
hashMap.put("MATERIALSPECNAME", materialSpecName);
|
||
hashMap.put("RECEIVEREQUESTNAME", receiveRequestName);
|
||
hashMap.put("PHASE", phase);
|
||
hashMap.put("SDK_ID", sdkid);
|
||
hashMap.put("LASTEVENTTIMEKEY", timeKey);
|
||
List<Map<String, Object>> queryForList = IDMFrameServiceProxy.getSqlTemplate().queryForList(sql2, hashMap);
|
||
for (Map<String, Object> map : queryForList) {
|
||
String materialPackingName = map.get("MATERIALPACKINGNAME").toString(); //标签
|
||
String materialQuantity = map.get("MATERIALQUANTITY").toString(); //数量
|
||
BigDecimal mathMaterialQuantity = new BigDecimal(materialQuantity);
|
||
String invoiceSql = "SELECT\r\n" +
|
||
" M.REQUESTQUANTITY - M.RECEIVEDQUANTITY QTY,\r\n" +
|
||
" M.RECEIVEREQUESTNAME,\r\n" +
|
||
" M.RECEIVEREQUESTDETAILNAME \r\n" +
|
||
"FROM\r\n" +
|
||
" MATERIALRECEIVEREQUESTDETAIL M\r\n" +
|
||
" LEFT JOIN MATERIALSPEC c ON c.MATERIALSPECNAME = M.MATERIALSPECNAME\r\n" +
|
||
"WHERE\r\n" +
|
||
" M.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME\r\n" +
|
||
" AND M.MATERIALSPECNAME = :MATERIALSPECNAME\r\n" +
|
||
" AND (:PHASE IS NULL\r\n" +
|
||
" OR c.PHASE = :PHASE)\r\n" +
|
||
" AND (:SDK_ID IS NULL\r\n" +
|
||
" OR SDK_ID = :SDK_ID)\r\n" +
|
||
" AND M.REQUESTQUANTITY - M.RECEIVEDQUANTITY > 0";
|
||
List<Map<String, Object>> queryForList2 = IDMFrameServiceProxy.getSqlTemplate().queryForList(invoiceSql, hashMap);
|
||
for (Map<String, Object> map2 : queryForList2) {
|
||
String insertSql = "INSERT INTO MATERIALPACKINGSUB T (T.MATERIALPACKINGNAME,T.RECEIVEREQUESTNAME,T.RECEIVEREQUESTDETAILNAME,T.QTY) "
|
||
+ "VALUES (:MATERIALPACKINGNAME, :RECEIVEREQUESTNAME,:RECEIVEREQUESTDETAILNAME,:QTY)";
|
||
String updateSql = "UPDATE MATERIALRECEIVEREQUESTDETAIL T SET T.RECEIVEDQUANTITY = T.RECEIVEDQUANTITY + :QTY "
|
||
+ "WHERE T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME AND T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME";
|
||
String qty = map2.get("QTY").toString();
|
||
BigDecimal mathQty = new BigDecimal(qty);
|
||
String receiveRequestName2 = map2.get("RECEIVEREQUESTNAME").toString();
|
||
String receiveRequestDetailName2 = map2.get("RECEIVEREQUESTDETAILNAME").toString();
|
||
Map<String, Object> hashMap2 = new HashMap<String,Object> ();
|
||
hashMap2.put("MATERIALPACKINGNAME", materialPackingName);
|
||
hashMap2.put("RECEIVEREQUESTNAME", receiveRequestName2);
|
||
hashMap2.put("RECEIVEREQUESTDETAILNAME", receiveRequestDetailName2);
|
||
if (mathMaterialQuantity.compareTo(mathQty) == 0) {//条码数量和剩余数量一致
|
||
System.out.println("a equals b");
|
||
BigDecimal a = new BigDecimal("10.5");
|
||
BigDecimal b = new BigDecimal("5.5");
|
||
int result = a.compareTo(b);
|
||
hashMap2.put("QTY", mathMaterialQuantity);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(insertSql, hashMap2);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap2);
|
||
break;
|
||
} else if (mathMaterialQuantity.compareTo(mathQty) == 1) {//条码数量大于剩余数量
|
||
hashMap2.put("QTY", qty);
|
||
mathMaterialQuantity = mathMaterialQuantity.subtract(mathQty);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(insertSql, hashMap2);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap2);
|
||
System.out.println("a is greater than b");
|
||
continue;
|
||
} else {//条码数量小于订单剩余数量
|
||
System.out.println("a is less than b");
|
||
hashMap2.put("QTY", mathMaterialQuantity);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(insertSql, hashMap2);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap2);
|
||
break;
|
||
}
|
||
}
|
||
|
||
}
|
||
//2.查询符合条件的订单明细
|
||
|
||
// return AjaxResult.me().setResultObj(null);box
|
||
return AjaxResult.me().setResultObj(in);
|
||
}
|
||
|
||
|
||
@RequestMapping(value = "/DeleteTrackOutBox", method = RequestMethod.POST)
|
||
public AjaxResult DeleteTrackOutBox(@RequestBody JSONObject in ) throws Exception{
|
||
// 获取属性
|
||
TrackOutBoDto boxs = JSON.toJavaObject(in, TrackOutBoDto.class);
|
||
MaterialreceiveActDto box = boxs.getMaterialreceiveAct();
|
||
String user = boxs.getUser();
|
||
String materialSpecName = box.getMaterialSpecName();
|
||
String receiveRequestName = box.getReceiveRequestName();
|
||
String siteName = box.getSiteName();
|
||
makeEventInfo = new EventInfoUtil().makeEventInfo("DeleteTrackOutBox", user, "DeleteTrackOutBox");
|
||
// 获取列表
|
||
MaterialPackingListDto dto = new MaterialPackingListDto();
|
||
dto.setMaterialSpecName(materialSpecName);
|
||
dto.setReceiveRequestName(receiveRequestName);
|
||
dto.setPhase(box.getPhase());
|
||
dto.setSdkId(box.getSdkid());
|
||
List<Map<String, Object>> queryForList = mpService.getMaterialPacking(dto);
|
||
for (Map<String, Object> map : queryForList) {
|
||
// 找到条码明细表的数据，先更新订单在删除条码明细
|
||
Map<String, Object> hashMap = new HashMap<> ();
|
||
hashMap.put("MATERIALSPECNAME", materialSpecName);
|
||
String materialPackingName = map.get("MATERIALPACKINGNAME").toString();
|
||
mpService.delMaterialPacking(hashMap, materialPackingName, siteName, makeEventInfo);
|
||
}
|
||
//更新订单数量
|
||
return AjaxResult.me().setResultObj(null);
|
||
}
|
||
|
||
|
||
@RequestMapping(value = "/DeleteTrackOutThisBox", method = RequestMethod.POST)
|
||
public AjaxResult DeleteTrackOutThisBox(@RequestBody JSONObject in ) throws Exception{
|
||
// 获取属性
|
||
TrackOutBoDto boxs = JSON.toJavaObject(in, TrackOutBoDto.class);
|
||
MaterialreceiveActDto box = boxs.getMaterialreceiveAct();
|
||
String user = boxs.getUser();
|
||
String materialSpecName = box.getMaterialSpecName();
|
||
String materialPackingName = box.getMaterialPackingName();
|
||
String siteName = box.getSiteName();
|
||
makeEventInfo = new EventInfoUtil().makeEventInfo("DeleteTrackOutBox", user, "DeleteTrackOutBox");
|
||
// 找到条码明细表的数据，先更新订单在删除条码明细
|
||
Map<String, Object> hashMap = new HashMap<> ();
|
||
hashMap.put("MATERIALSPECNAME", materialSpecName);
|
||
mpService.delMaterialPacking(hashMap, materialPackingName, siteName, makeEventInfo);
|
||
//更新订单数量
|
||
return AjaxResult.me().setResultObj(null);
|
||
}
|
||
|
||
// 删除销售入库
|
||
@RequestMapping(value = "/DeleteSaleReturn", method = RequestMethod.POST)
|
||
public AjaxResult DeleteSaleReturn(@RequestBody JSONObject in ) throws Exception{
|
||
TrackOutBoDto boxs = JSON.toJavaObject(in, TrackOutBoDto.class);
|
||
MaterialreceiveActDto box = boxs.getMaterialreceiveAct();
|
||
String user = boxs.getUser();
|
||
String materialSpecName = box.getMaterialSpecName();
|
||
String materialPackingName2 = box.getMaterialPackingName();
|
||
String siteName = "SDK";
|
||
makeEventInfo = new EventInfoUtil().makeEventInfo("ProductSaleReturn", user, "ProductSaleReturn");
|
||
Map<String, Object> hashMap = new HashMap<String,Object> ();
|
||
hashMap.put("MATERIALSPECNAME", materialSpecName);
|
||
// MaterialPackingKey materialPackingKey = new MaterialPackingKey(siteName, materialPackingName2);
|
||
// RemoveInfo removeInfo = new RemoveInfo();
|
||
// MaterialPackingServiceProxy.getMaterialPackingService().remove(materialPackingKey,makeEventInfo,removeInfo);
|
||
//找到条码明细表的数据，先更新订单在删除条码明细
|
||
String selectSql = "SELECT * FROM MATERIALPACKINGSUB m WHERE m.MATERIALPACKINGNAME = :MATERIALPACKINGNAME";
|
||
hashMap.put("MATERIALPACKINGNAME", materialPackingName2);
|
||
List<Map<String, Object>> queryForList2 = IDMFrameServiceProxy.getSqlTemplate().queryForList(selectSql, hashMap);
|
||
for (Map<String, Object> map2 : queryForList2) {
|
||
String qty = map2.get("QTY").toString();
|
||
String receiveRequestName2 = map2.get("RECEIVEREQUESTNAME").toString();
|
||
String receiveRequestDetailName2 = map2.get("RECEIVEREQUESTDETAILNAME").toString();
|
||
hashMap.put("RECEIVEREQUESTNAME", receiveRequestName2);
|
||
hashMap.put("RECEIVEREQUESTDETAILNAME", receiveRequestDetailName2);
|
||
hashMap.put("QTY", qty);
|
||
String updateSql = "UPDATE MATERIALRECEIVEREQUESTDETAIL T SET T.RECEIVEDQUANTITY = T.RECEIVEDQUANTITY - :QTY "
|
||
+ "WHERE T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME AND T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME";
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap);
|
||
|
||
String deleteSql = "DELETE FROM MATERIALPACKINGSUB m WHERE m.MATERIALPACKINGNAME = :MATERIALPACKINGNAME";
|
||
IDMFrameServiceProxy.getSqlTemplate().update(deleteSql, hashMap);
|
||
}
|
||
|
||
com.cim.idm.wmspackage.materialpacking.management.info.SetEventInfo setEventInfo1 = new com.cim.idm.wmspackage.materialpacking.management.info.SetEventInfo();
|
||
EventInfo eventInfo = EventInfoUtil.makeEventInfo("ProductSaleReturn", user, "ProductSaleReturn");
|
||
HashMap<String,Object> hashMap2 = new HashMap<String,Object >();
|
||
|
||
hashMap2.put("receiveRequestName","");
|
||
hashMap2.put("stockState", "StockOut");
|
||
|
||
setEventInfo1.setUserColumns(hashMap2);
|
||
MaterialPackingKey materialPackingKey2 = new MaterialPackingKey(siteName,materialPackingName2);
|
||
MaterialPacking setEvent = MaterialPackingServiceProxy.getMaterialPackingService().setEvent(materialPackingKey2, eventInfo, setEventInfo1);
|
||
|
||
return AjaxResult.me().setResultObj(null);
|
||
}
|
||
|
||
/*
|
||
* 解绑销售入库
|
||
* lz
|
||
*/
|
||
@RequestMapping(value = "/DeleteProductSaleReturn", method = RequestMethod.POST)
|
||
public AjaxResult DeleteProductSaleReturn(@RequestBody JSONObject in ) throws Exception{
|
||
TrackOutBoDto boxs = JSON.toJavaObject(in, TrackOutBoDto.class);
|
||
MaterialreceiveActDto box = boxs.getMaterialreceiveAct();
|
||
String user = boxs.getUser();
|
||
String materialSpecName = box.getMaterialSpecName();
|
||
String materialPackingName2 = box.getMaterialPackingName();
|
||
String siteName = "SDK";
|
||
String receiveRequestName = box.getReceiveRequestName();
|
||
String phase = box.getPhase();
|
||
String sdkid = box.getSdkid();
|
||
String materialquantity = box.getMATERIALQUANTITY();
|
||
String selectSql = "SELECT M.REQUESTQUANTITY - M.RECEIVEDQUANTITY QTY, M.RECEIVEREQUESTNAME,M.RECEIVEREQUESTDETAILNAME \r\n" +
|
||
"FROM MATERIALRECEIVEREQUESTDETAIL M\r\n" +
|
||
"WHERE M.MATERIALSPECNAME = :MATERIALSPECNAME\r\n" +
|
||
" AND (:PHASE IS NULL OR PHASE = :PHASE)\r\n" +
|
||
" AND (:SDK_ID IS NULL OR SDK_ID = :SDK_ID)\r\n" +
|
||
// " AND M.REQUESTQUANTITY - M.RECEIVEDQUANTITY > 0" +
|
||
" AND RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME";
|
||
Map<String,Object> map = new HashMap<String ,Object >();
|
||
map.put("MATERIALSPECNAME", materialSpecName);
|
||
map.put("PHASE", phase);
|
||
map.put("SDK_ID", sdkid);
|
||
map.put("RECEIVEREQUESTNAME", receiveRequestName);
|
||
List<Map<String,Object>> queryForList = IDMFrameServiceProxy.getSqlTemplate().queryForList(selectSql, map);
|
||
BigDecimal mathMaterialQuantity = new BigDecimal(materialquantity);
|
||
int i = 0;
|
||
for (Map<String, Object> map2 : queryForList) {
|
||
String insertSql = "UPDATE MATERIALPACKINGSUB T SET T.QTY = (T.QTY - :QTY)"
|
||
+ "WHERE T.MATERIALPACKINGNAME = :MATERIALPACKINGNAME and T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME and T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME";
|
||
String updateSql = "UPDATE MATERIALRECEIVEREQUESTDETAIL T SET T.RECEIVEDQUANTITY = (T.RECEIVEDQUANTITY - :QTY) "
|
||
+ "WHERE T.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME AND T.RECEIVEREQUESTDETAILNAME = :RECEIVEREQUESTDETAILNAME";
|
||
String qty = map2.get("QTY").toString();
|
||
BigDecimal mathQty = new BigDecimal(qty);
|
||
String receiveRequestName2 = map2.get("RECEIVEREQUESTNAME").toString();
|
||
String receiveRequestDetailName2 = map2.get("RECEIVEREQUESTDETAILNAME").toString();
|
||
Map<String, Object> hashMap2 = new HashMap<String,Object> ();
|
||
hashMap2.put("MATERIALPACKINGNAME", materialPackingName2);
|
||
hashMap2.put("RECEIVEREQUESTNAME", receiveRequestName2);
|
||
hashMap2.put("RECEIVEREQUESTDETAILNAME", receiveRequestDetailName2);
|
||
if (mathMaterialQuantity.compareTo(mathQty) == 0) {//条码数量和剩余数量一致
|
||
System.out.println("a equals b");
|
||
BigDecimal a = new BigDecimal("10.5");
|
||
BigDecimal b = new BigDecimal("5.5");
|
||
int result = a.compareTo(b);
|
||
hashMap2.put("QTY", mathMaterialQuantity);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(insertSql, hashMap2);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap2);
|
||
i++;
|
||
break;
|
||
} else if (mathMaterialQuantity.compareTo(mathQty) == 1) {//条码数量大于剩余数量
|
||
if(i >= queryForList.size()-1) {
|
||
hashMap2.put("QTY", mathMaterialQuantity.toString());
|
||
mathMaterialQuantity = mathMaterialQuantity.subtract(mathQty);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(insertSql, hashMap2);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap2);
|
||
System.out.println("a is greater than b");
|
||
i++;
|
||
} else {
|
||
hashMap2.put("QTY", qty.toString());
|
||
mathMaterialQuantity = mathMaterialQuantity.subtract(mathQty);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(insertSql, hashMap2);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap2);
|
||
System.out.println("a is greater than b");
|
||
i++;
|
||
continue;
|
||
}
|
||
} else {//条码数量小于订单剩余数量
|
||
System.out.println("a is less than b");
|
||
hashMap2.put("QTY", mathMaterialQuantity.toString());
|
||
IDMFrameServiceProxy.getSqlTemplate().update(insertSql, hashMap2);
|
||
IDMFrameServiceProxy.getSqlTemplate().update(updateSql, hashMap2);
|
||
i++;
|
||
break;
|
||
}
|
||
}
|
||
com.cim.idm.wmspackage.materialpacking.management.info.SetEventInfo setEventInfo1 = new com.cim.idm.wmspackage.materialpacking.management.info.SetEventInfo();
|
||
EventInfo eventInfo = EventInfoUtil.makeEventInfo("ProductSaleReturn", user, "ProductSaleReturn");
|
||
HashMap<String,Object> hashMap = new HashMap<String,Object >();
|
||
|
||
hashMap.put("receiveRequestName","");
|
||
hashMap.put("stockState", "StockOut");
|
||
|
||
setEventInfo1.setUserColumns(hashMap);
|
||
MaterialPackingKey materialPackingKey2 = new MaterialPackingKey(siteName,materialPackingName2);
|
||
MaterialPacking setEvent = MaterialPackingServiceProxy.getMaterialPackingService().setEvent(materialPackingKey2, eventInfo, setEventInfo1);
|
||
|
||
//更新订单数量
|
||
return AjaxResult.me().setResultObj(null);
|
||
}
|
||
|
||
|
||
@RequestMapping(value = "/commitToERP", method = RequestMethod.POST)
|
||
public AjaxResult commitToERP(@RequestBody JSONObject in ) {
|
||
TrackOutBoDto trackOutBoDto = JSON.toJavaObject(in, TrackOutBoDto.class);
|
||
// 采购单
|
||
List<MaterialReceiveRequest> requests = new ArrayList<>();
|
||
// 判定单据类型
|
||
StoreDetailDto storeDetailDto = new StoreDetailDto();
|
||
storeDetailDto.setDocumentName(trackOutBoDto.getReceiveRequestName());
|
||
storeDetailDto.setSiteName(trackOutBoDto.getSiteName());
|
||
MaterialDelivery materialDelivery = deliveryService.getByKey(storeDetailDto);
|
||
if (Objects.nonNull(materialDelivery)) {
|
||
// 到货单据
|
||
requests = deliveryService.getReceiveByDelivery(storeDetailDto);
|
||
} else {
|
||
requests.add(deliveryService.getReceiveByKey(storeDetailDto));
|
||
}
|
||
String user = trackOutBoDto.getUser();
|
||
String opCode = trackOutBoDto.getOpCode();
|
||
String commitDate = trackOutBoDto.getCommitDate();
|
||
// 采购单处理
|
||
for (MaterialReceiveRequest request : requests) {
|
||
String receiveRequestName = request.getReceiveRequestName();
|
||
String siteName = request.getSiteName();
|
||
String erpFactory = request.getSTOCKORGNO();
|
||
|
||
String undoId = null;
|
||
try {
|
||
// 采购订单
|
||
if (ReceiveTypeEnums.isPurchase(request.getReceiveRequestType())) {
|
||
Map<String,Object> args = new HashMap<>();
|
||
undoId = toSAPServiceImpl.PurStockIn(receiveRequestName, siteName, user, args, commitDate);
|
||
}else if( ReceiveTypeEnums.isSaleReturn(request.getReceiveRequestType())) {
|
||
undoId = toSAPServiceImpl.SaleReturn(receiveRequestName, siteName, user, commitDate, opCode);
|
||
}
|
||
// @TODO 其他订单
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
return AjaxResult.me().setSuccess(false).setMessage(e.toString());
|
||
}
|
||
|
||
if(!ReceiveTypeEnums.isSaleReturn(requests.get(0).getReceiveRequestType())) {
|
||
try {
|
||
// 调用 QMS
|
||
qMSServiceImpl.PreIQCInfoSend(receiveRequestName, "SDK",opCode, erpFactory);
|
||
} catch (CustomException e) {
|
||
e.printStackTrace();
|
||
return AjaxResult.me().setSuccess(false).setMessage(e.toString());
|
||
}
|
||
}
|
||
|
||
// 发送过账
|
||
EventInfoUtil util = new EventInfoUtil();
|
||
makeEventInfo = util.makeEventInfo("NormalStockInForSDK", user, "NormalStockInForSDK");
|
||
// 更新入库凭证
|
||
//SDKMaterialPackingServiceImpl.updateUndoIdByReceive(receiveRequestName, undoId, makeEventInfo);
|
||
/**
|
||
* updateUndoIdByReceive和updateStockState都在MATERIALPACKINGHISTORY表插入了数据，导致有重复的入库记录
|
||
* 为了不影响后续通过undoId作为条件处理其它业务，新建方法updateMaterialPackingUndoIdByReceive，只更新undoId，不插入MATERIALPACKINGHISTORY表
|
||
* 2025-05-12
|
||
*/
|
||
SDKMaterialPackingServiceImpl.updateMaterialPackingUndoIdByReceive(receiveRequestName, undoId);
|
||
// 更新库存状态
|
||
SDKMaterialPackingServiceImpl.SaveUnDoInfo( undoId,commitDate);
|
||
SDKMaterialPackingServiceImpl.updateStockState( makeEventInfo, undoId,opCode);
|
||
}
|
||
// 到货单据更新状态
|
||
if (Objects.nonNull(materialDelivery)) {
|
||
DeliveryEditDto deliveryEditDto = new DeliveryEditDto();
|
||
deliveryEditDto.setDeliveryName(trackOutBoDto.getReceiveRequestName());
|
||
deliveryEditDto.setSiteName(trackOutBoDto.getSiteName());
|
||
// @TODO 完成状态下，更新为 DeliveryStateEnums.FINISH
|
||
deliveryEditDto.setDeliveryState(DeliveryStateEnums.DOING.getCode());
|
||
deliveryService.editDelivery(deliveryEditDto);
|
||
}
|
||
return AjaxResult.me().setResultObj(null);
|
||
}
|
||
|
||
// 单据类型判断
|
||
public String SendERPStockIn(String receiveRequestName, String siteName, String eventUser,String reActo,String commitDate,String opCode) throws Exception {
|
||
//判断单据类型调用不同的NC接口
|
||
String sql = "SELECT m.RECEIVEREQUESTTYPE,m.RECEIVEREQUESTDETAILTYPE FROM MATERIALRECEIVEREQUEST m WHERE m.RECEIVEREQUESTNAME = :RECEIVEREQUESTNAME";
|
||
Map<String, Object> hashMap = new HashMap<String,Object> ();
|
||
hashMap.put("RECEIVEREQUESTNAME", receiveRequestName);
|
||
List<Map<String, Object>> queryForList = IDMFrameServiceProxy.getSqlTemplate().queryForList(sql, hashMap);
|
||
String billCode = "";
|
||
if (queryForList != null && queryForList.size() > 0) {
|
||
String type = queryForList.get(0).get("RECEIVEREQUESTTYPE").toString();
|
||
// String receiverequestdetailtype = queryForList.get(0).get("RECEIVEREQUESTDETAILTYPE").toString();
|
||
switch (type) {
|
||
case "Z001" : //采购入库
|
||
case "Z002" : //研发采购订单
|
||
case "Z003" : //非生产物资采购订单
|
||
case "Z004" : //固定资产、在建工程采购订单
|
||
Map<String,Object> args = new HashMap<>();
|
||
billCode = toSAPServiceImpl.PurStockIn(receiveRequestName, siteName, eventUser,
|
||
args,commitDate);
|
||
break;
|
||
case "Z005" : //服务费用采购订单
|
||
case "Z006" : //股份 - 泗洪STO
|
||
case "Z007" : //股份泗洪-分子公司STO
|
||
break;
|
||
case "Z008" : //物资退货采购订单
|
||
break;
|
||
case "ZLR1" : //销售退料
|
||
billCode = toSAPServiceImpl.SaleReturn(receiveRequestName, "SDK", eventUser,commitDate, opCode);
|
||
break;
|
||
default :
|
||
break;
|
||
}
|
||
} else {
|
||
throw new CustomException("找不到单据" + receiveRequestName);
|
||
}
|
||
return billCode;
|
||
}
|
||
}
|