|
|
@@ -0,0 +1,281 @@
|
|
|
+package restcontroller.webmanage.sale.dbstockbill;
|
|
|
+
|
|
|
+import beans.invbal.Invbal;
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
+import common.Controller;
|
|
|
+import common.YosException;
|
|
|
+import common.annotation.API;
|
|
|
+import common.data.*;
|
|
|
+import restcontroller.R;
|
|
|
+
|
|
|
+import java.math.BigDecimal;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.Date;
|
|
|
+
|
|
|
+public class dbstockbillreceive extends Controller {
|
|
|
+ public dbstockbillreceive(JSONObject content) throws YosException {
|
|
|
+ super(content);
|
|
|
+ }
|
|
|
+
|
|
|
+ @API(title = "查询需要收货确认的审核调拨单", apiversion = R.ID2025090313530203.v1.class)
|
|
|
+ public String queryDbstockbills_Receive() throws YosException {
|
|
|
+
|
|
|
+ /*
|
|
|
+ * 过滤条件设置
|
|
|
+ */
|
|
|
+ StringBuffer where = new StringBuffer(" 1=1 ");
|
|
|
+ if (content.containsKey("where")) {
|
|
|
+ JSONObject whereObject = content.getJSONObject("where");
|
|
|
+ if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
|
|
|
+ where.append(" and(");
|
|
|
+ where.append("t4.itemname like'%").append(whereObject.getString("condition")).append("%' ");
|
|
|
+ where.append("or t4.model like'%").append(whereObject.getString("condition")).append("%' ");
|
|
|
+ where.append("or t4.spec like'%").append(whereObject.getString("condition")).append("%' ");
|
|
|
+ where.append("or t4.itemno like'%").append(whereObject.getString("condition")).append("%' ");
|
|
|
+ where.append(")");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ QuerySQL querySQL = SQLFactory.createQuerySQL(this, "st_dbstockbilldetail","*");
|
|
|
+ querySQL.setTableAlias("t1");
|
|
|
+ querySQL.addJoinTable(JOINTYPE.left, "st_stock", "t2", "t1.instockid = t2.stockid AND t1.siteid = t2.siteid");
|
|
|
+ querySQL.addJoinTable(JOINTYPE.left, "st_stock", "t3", "t1.outstockid = t3.stockid AND t1.siteid = t3.siteid");
|
|
|
+ querySQL.addJoinTable(JOINTYPE.left, "plm_item", "t4", "t1.itemid=t4.itemid and t1.siteid = t4.siteid","itemno","itemname"
|
|
|
+ ,"spec","model");
|
|
|
+ querySQL.addJoinTable(JOINTYPE.left, "plm_unit", "t5", "t4.unitid=t5.unitid and t4.siteid = t5.siteid","unitname");
|
|
|
+ querySQL.addJoinTable(JOINTYPE.inner, "st_dbstockbill", "t6", "t1.st_dbstockbillid=t6.st_dbstockbillid and t1.siteid = t6.siteid","billno","checkdate");
|
|
|
+
|
|
|
+ querySQL.addQueryFields("outstockno", "t3.stockno");
|
|
|
+ querySQL.addQueryFields("outstockname", "t3.stockname");
|
|
|
+ querySQL.addQueryFields("instockno", "t2.stockno");
|
|
|
+ querySQL.addQueryFields("instockname", "t2.stockname");
|
|
|
+ querySQL.setWhere("t1.siteid", siteid);
|
|
|
+ querySQL.setWhere(where);
|
|
|
+ querySQL.setWhere("t6.status='审核' and t1.undeliqty>0");
|
|
|
+ querySQL.setPage(pageSize, pageNumber);
|
|
|
+ querySQL.setOrderBy(pageSorting);
|
|
|
+ Rows rows = querySQL.query();
|
|
|
+
|
|
|
+ return getSucReturnObject().setData(rows).toString();
|
|
|
+ }
|
|
|
+
|
|
|
+ @API(title = "生成入库单", apiversion = R.ID2025090314003303.v1.class)
|
|
|
+ public String received() throws YosException {
|
|
|
+ JSONArray st_dbstockbilldetails=content.getJSONArray("st_dbstockbilldetails");
|
|
|
+ if(st_dbstockbilldetails.isEmpty()){
|
|
|
+ return getErrReturnObject().setErrMsg("未选择调拨单明细").toString();
|
|
|
+ }
|
|
|
+ Rows dbstockbilldetail=new Rows();
|
|
|
+ Rows rows = dbConnect.runSqlQuery("select t1.*,t2.instockid from st_dbstockbilldetail t1 inner join st_dbstockbill t2 on t1.siteid=t2.siteid and t1.st_dbstockbillid=t2.st_dbstockbillid where t1.siteid='"+siteid+"' and t1.undeliqty>0 and t2.status='审核'");
|
|
|
+ RowsMap rowsMap =rows.toRowsMap("st_dbstockbilldetailid");
|
|
|
+ long st_dbstockbillid =0;
|
|
|
+ for(Object object :st_dbstockbilldetails){
|
|
|
+ JSONObject jsonObject = (JSONObject)object;
|
|
|
+ Row st_dbstockbilldetail;
|
|
|
+ if(rowsMap.containsKey(jsonObject.getLong("st_dbstockbilldetailid"))){
|
|
|
+ st_dbstockbilldetail=rowsMap.get(jsonObject.getLong("st_dbstockbilldetailid")).get(0);
|
|
|
+ }else{
|
|
|
+ return getErrReturnObject().setErrMsg("调拨单明细不存在").toString();
|
|
|
+ }
|
|
|
+ if (st_dbstockbillid!=0 && st_dbstockbillid!=st_dbstockbilldetail.getLong("st_dbstockbillid")) {
|
|
|
+ return getErrReturnObject().setErrMsg("不能同时选择两个调拨单进行收货确认").toString();
|
|
|
+ } else {
|
|
|
+ st_dbstockbillid = st_dbstockbilldetail.getLong("st_dbstockbillid");
|
|
|
+ }
|
|
|
+ int recqty =jsonObject.getIntValue("recqty");// 收货确认数量
|
|
|
+ int undeliqty = st_dbstockbilldetail.getInteger("undeliqty");// 未入库数量
|
|
|
+ if (recqty>undeliqty) {
|
|
|
+ return getErrReturnObject().setErrMsg("收货确认数量不能大于未入库数量").toString();
|
|
|
+ }
|
|
|
+ if(jsonObject.getJSONArray("skuinfos").size()>0){
|
|
|
+ if (recqty!=jsonObject.getJSONArray("skuinfos").size()) {
|
|
|
+ return getErrReturnObject().setErrMsg("机器码数量与收货确认数量不匹配").toString();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Rows skurows = dbConnect.runSqlQuery("select * from sa_itemsku where siteid='"+siteid+"' and ifnull(st_dbstockbillid,0)>0 ");
|
|
|
+ RowsMap skuRowsMap =skurows.toRowsMap("sku");
|
|
|
+ for(Object skuinfo : jsonObject.getJSONArray("skuinfos")){
|
|
|
+ if(!skuRowsMap.containsKey(((JSONObject)skuinfo).getString("sku"))){
|
|
|
+ return getErrReturnObject().setErrMsg("序列号" + ((JSONObject)skuinfo).getString("sku") + "不存在或者已经确认收货").toString();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ st_dbstockbilldetail.put("qty",recqty);
|
|
|
+ st_dbstockbilldetail.put("skuinfos",jsonObject.getJSONArray("skuinfos"));
|
|
|
+ dbstockbilldetail.add(st_dbstockbilldetail);
|
|
|
+
|
|
|
+ }
|
|
|
+ ArrayList<String> sqllist=new ArrayList<>();
|
|
|
+ InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "st_stockbill");
|
|
|
+ long st_stockbillid = createTableID("st_stockbill");
|
|
|
+ insertSQL.setUniqueid(st_stockbillid);
|
|
|
+ insertSQL.setSiteid(siteid);
|
|
|
+ insertSQL.setValue("billno", createBillCode("stockbill"));
|
|
|
+ insertSQL.setValue("type", "其他入库");
|
|
|
+ insertSQL.setValue("typemx", "调拨入库");
|
|
|
+ insertSQL.setValue("rb", 1);
|
|
|
+ insertSQL.setValue("sys_enterpriseid",0);
|
|
|
+ insertSQL.setValue("sourceobject", "st_dbstockbill");
|
|
|
+ insertSQL.setValue("sourceid", st_dbstockbillid);
|
|
|
+ insertSQL.setValue("stockid", rows.get(0).getLong("instockid"));
|
|
|
+ insertSQL.setValue("remarks", "收货确认入库");
|
|
|
+ insertSQL.setValue("status", "审核");
|
|
|
+ insertSQL.setValue("createby",username);
|
|
|
+ insertSQL.setDateValue("createdate");
|
|
|
+ insertSQL.setValue("checkby",username);
|
|
|
+ insertSQL.setDateValue("checkdate");
|
|
|
+ insertSQL.setDateValue("billdate");
|
|
|
+ sqllist.add(insertSQL.getSQL());
|
|
|
+ int j=1;
|
|
|
+ for(Row row:dbstockbilldetail){
|
|
|
+ insertSQL = SQLFactory.createInsertSQL(this, "st_stockbill_items");
|
|
|
+ long st_stockbill_itemsid = createTableID("st_stockbill_items");
|
|
|
+ insertSQL.setUniqueid(st_stockbill_itemsid);
|
|
|
+ insertSQL.setValue("rowno",j);
|
|
|
+ insertSQL.setSiteid(siteid);
|
|
|
+ insertSQL.setValue("sa_dispatch_itemsid",0);
|
|
|
+ insertSQL.setValue("sourceobject", "st_dbstockbilldetail");
|
|
|
+ insertSQL.setValue("sourceid", row.getLong("st_dbstockbilldetailid"));
|
|
|
+ insertSQL.setValue("stockid", row.getLong("instockid"));
|
|
|
+ insertSQL.setValue("itemid",row.getLong("itemid"));
|
|
|
+ insertSQL.setValue("itemno",row.getString("itemno"));
|
|
|
+ insertSQL.setValue("itemname",row.getString("itemname"));
|
|
|
+ insertSQL.setValue("model",row.getString("model"));
|
|
|
+ insertSQL.setValue("qty",row.getBigDecimal("qty"));
|
|
|
+ insertSQL.setValue("st_stockbillid",st_stockbillid);
|
|
|
+ sqllist.add(insertSQL.getSQL());
|
|
|
+ j++;
|
|
|
+ for(Object objectdetail:row.getJSONArray("skuinfos")){
|
|
|
+ JSONObject rowdetail = (JSONObject)objectdetail;
|
|
|
+ insertSQL = SQLFactory.createInsertSQL(this, "st_stockbill_items_sku");
|
|
|
+ long st_stockbill_items_skuid = createTableID("st_stockbill_items_sku");
|
|
|
+ insertSQL.setUniqueid(st_stockbill_items_skuid);
|
|
|
+ insertSQL.setSiteid(siteid);
|
|
|
+ insertSQL.setValue("stockid", row.getLong("instockid"));
|
|
|
+ insertSQL.setValue("itemid",row.getLong("itemid"));
|
|
|
+ insertSQL.setValue("sku",rowdetail.getString("sku"));
|
|
|
+ insertSQL.setValue("st_stockbillid",st_stockbillid);
|
|
|
+ insertSQL.setValue("st_stockbill_itemsid",st_stockbill_itemsid);
|
|
|
+ sqllist.add(insertSQL.getSQL());
|
|
|
+ sqllist.add("update sa_itemsku set stockid="+row.getLong("instockid")+",st_dbstockbillid=0,st_dbstockbilldetailid=0 where sku='"+rowdetail.getString("sku")+"'");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ sqllist.addAll(updateIcinvbal(true,true,dbstockbilldetail));
|
|
|
+ sqllist.addAll(updateUnInQty(true,dbstockbilldetail));
|
|
|
+ dbConnect.runSqlUpdate(sqllist);
|
|
|
+ return getSucReturnObject().toString();
|
|
|
+ }
|
|
|
+
|
|
|
+ public ArrayList<String> updateIcinvbal(boolean ischeck,boolean isinstock,Rows dbstockbilldetail) throws YosException {
|
|
|
+ ArrayList<String> sqlList =new ArrayList();
|
|
|
+ ArrayList<Long> itemids = new ArrayList<Long>();
|
|
|
+ itemids = dbstockbilldetail.toArrayList("itemid",new ArrayList<>());
|
|
|
+ itemids.add((long) 0);
|
|
|
+ int i = 0;
|
|
|
+ String sql="select * from st_invbal where itemid in"+itemids;
|
|
|
+ sql = sql.replace("[", "(").replace("]", ")");
|
|
|
+ Rows invbals = dbConnect.runSqlQuery(sql);
|
|
|
+ RowsMap invbalsRowsMap=invbals.toRowsMap("itemid");
|
|
|
+ RowsMap invbalsSaleRowsMap = SQLFactory.createQuerySQL(dbConnect, "st_invbal_sale").setWhere("siteid", siteid).setWhere("itemid", itemids).query().toRowsMap("itemid");
|
|
|
+ for(Row row : dbstockbilldetail){
|
|
|
+ String itemid = row.getString("itemid");
|
|
|
+ //String batchno = row.getString("batchno");
|
|
|
+ //String fdcspno = row.getString("fdcspno");
|
|
|
+ long stockid;
|
|
|
+
|
|
|
+ if ((ischeck && isinstock) || (!ischeck && !isinstock)) {
|
|
|
+ stockid = row.getLong("instockid");
|
|
|
+ }else{
|
|
|
+ stockid = row.getLong("outstockid");
|
|
|
+ }
|
|
|
+
|
|
|
+// if (type == 1 && !getSysVars().getBoolean("FISBATCHFORXC")) {
|
|
|
+// fdcspno = "**********";
|
|
|
+// fbatchno = "**********";
|
|
|
+// fstockno = getPaoSet("TDEPARTMENT").getPao(0)
|
|
|
+// .getPaoSet("TSTOCKXC").getPao(0).getString("fstockno");
|
|
|
+// icinvbal = detailpao.getPaoSet("$icinvbal", "icinvbal",
|
|
|
+// "fitemno='" + fitemno + "' and fstockno='" + fstockno
|
|
|
+// + "' and fdcspno='" + fdcspno
|
|
|
+// + "' and fbatchno='" + fbatchno + "'");
|
|
|
+// } else if (type == 2 && !getSysVars().getBoolean("FISBATCHFORXC")) {
|
|
|
+// fdcspno = "**********";
|
|
|
+// fbatchno = "**********";
|
|
|
+// fstockno = getPaoSet("TSUPPLIER").getPao(0)
|
|
|
+// .getPaoSet("TSTOCKXC").getPao(0).getString("fstockno");
|
|
|
+// icinvbal = detailpao.getPaoSet("$icinvbal", "icinvbal",
|
|
|
+// "fitemno='" + fitemno + "' and fstockno='" + fstockno
|
|
|
+// + "' and fdcspno='" + fdcspno
|
|
|
+// + "' and fbatchno='" + fbatchno + "'");
|
|
|
+// }
|
|
|
+ BigDecimal qty = isinstock ? row.getBigDecimal("qty") : row.getBigDecimal("qty").negate();
|
|
|
+ if(!invbalsRowsMap.containsKey(itemid)){
|
|
|
+ SQLFactory sqlFactory = new SQLFactory(this, "即时库存新增");
|
|
|
+ sqlFactory.addParameter("st_invbalid", createTableID("st_invbal"));
|
|
|
+ sqlFactory.addParameter("qty", qty);
|
|
|
+ sqlFactory.addParameter("itemid", itemid);
|
|
|
+ sqlFactory.addParameter("stockid", stockid);
|
|
|
+ sqlFactory.addParameter("siteid",siteid);
|
|
|
+ sqlFactory.addParameter("userid", userid);
|
|
|
+ sqlFactory.addParameter("username", username);
|
|
|
+ sqlList.add(sqlFactory.getSQL());
|
|
|
+ }else{
|
|
|
+ if(invbalsRowsMap.get(itemid).toRowsMap("stockid").containsKey(stockid)){
|
|
|
+ SQLFactory sqlFactory = new SQLFactory(this, "即时库存更新");
|
|
|
+ sqlFactory.addParameter("st_invbalid", createTableID("st_invbal"));
|
|
|
+ sqlFactory.addParameter("qty", invbalsRowsMap.get(itemid).toRowsMap("stockid").get(stockid).get(0).getBigDecimal("qty").add(qty));
|
|
|
+ sqlFactory.addParameter("itemid", itemid);
|
|
|
+ sqlFactory.addParameter("stockid", stockid);
|
|
|
+ sqlFactory.addParameter("siteid",siteid);
|
|
|
+ sqlFactory.addParameter("userid", userid);
|
|
|
+ sqlFactory.addParameter("username", username);
|
|
|
+ sqlList.add(sqlFactory.getSQL());
|
|
|
+ }else{
|
|
|
+ SQLFactory sqlFactory = new SQLFactory(new Invbal(), "即时库存新增");
|
|
|
+ sqlFactory.addParameter("st_invbalid", createTableID("st_invbal"));
|
|
|
+ sqlFactory.addParameter("qty", qty);
|
|
|
+ sqlFactory.addParameter("itemid", itemid);
|
|
|
+ sqlFactory.addParameter("stockid", stockid);
|
|
|
+ System.err.println(stockid);
|
|
|
+ sqlFactory.addParameter("siteid",siteid);
|
|
|
+ sqlFactory.addParameter("userid", userid);
|
|
|
+ sqlFactory.addParameter("username", username);
|
|
|
+ sqlList.add(sqlFactory.getSQL());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //是否为销售仓库
|
|
|
+ if (SQLFactory.getRow(this, "st_stock", stockid).getBoolean("issalestock")) {
|
|
|
+ if (!invbalsSaleRowsMap.containsKey(String.valueOf(itemid))) {
|
|
|
+ InsertSQL invbalInsert = SQLFactory.createInsertSQL(this, "st_invbal_sale");
|
|
|
+ invbalInsert.setValue("siteid", siteid);
|
|
|
+ invbalInsert.setValue("itemid", itemid);
|
|
|
+ invbalInsert.setValue("cansaleqty", qty.doubleValue());//可销售数量
|
|
|
+ invbalInsert.setValue("candispatchqty", qty.doubleValue());//可发货数量
|
|
|
+ invbalInsert.setValue("qty", qty.doubleValue());//库存数量
|
|
|
+ sqlList.add(invbalInsert.getSQL());
|
|
|
+ } else {
|
|
|
+ UpdateSQL invbalUpdate = SQLFactory.createUpdateSQL(this, "st_invbal_sale");
|
|
|
+ invbalUpdate.addValue("qty", invbalsSaleRowsMap.get(String.valueOf(itemid)).get(0).getBigDecimal("qty").add(qty));//库存数量
|
|
|
+ invbalUpdate.setWhere("itemid", itemid);
|
|
|
+ invbalUpdate.setWhere("siteid", siteid);
|
|
|
+ sqlList.add(invbalUpdate.getSQL());
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return sqlList;
|
|
|
+ }
|
|
|
+
|
|
|
+ public ArrayList<String> updateUnInQty( boolean ischeck, Rows dbstockbilldetail) {
|
|
|
+ ArrayList<String> sqllist =new ArrayList<>();
|
|
|
+ for(Row row : dbstockbilldetail){
|
|
|
+ if (ischeck) {// 审核
|
|
|
+ sqllist.add("update st_dbstockbilldetail set undeliqty=undeliqty-"+row.getInteger("recqty")+" where st_dbstockbilldetailid='"+row.getString("st_dbstockbilldetailid")+"'");
|
|
|
+ } else {// 反审核
|
|
|
+ sqllist.add("update st_dbstockbilldetail set undeliqty="+row.getBigDecimal("qty")+" where st_dbstockbilldetailid='"+row.getString("st_dbstockbilldetailid")+"'");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return sqllist;
|
|
|
+ }
|
|
|
+}
|
