|
|
@@ -0,0 +1,274 @@
|
|
|
+package com.uas.eis.serviceImpl;
|
|
|
+
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import com.uas.eis.dao.BaseDao;
|
|
|
+import com.uas.eis.service.YundingService;
|
|
|
+import com.uas.eis.utils.BaseUtil;
|
|
|
+import com.uas.eis.utils.SqlUtil;
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+@Service
|
|
|
+public class YundingServiceImpl implements YundingService {
|
|
|
+ @Autowired
|
|
|
+ private BaseDao baseDao;
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 出入库单审核接口
|
|
|
+ *
|
|
|
+ * @param id
|
|
|
+ * @param piclass
|
|
|
+ * 单据主表id
|
|
|
+ * 单据类型piclass
|
|
|
+ *
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void ProdInOutAuidted(int id,String piclass) {
|
|
|
+ Map<Object, Object> store = new HashMap<Object, Object>();
|
|
|
+ //传入查询code、单据ID传回单据主从表信息Map
|
|
|
+ if (piclass=="采购验收单"||piclass=="委外验收单"){
|
|
|
+ //云顶插入采购/委外验收单接口
|
|
|
+ }
|
|
|
+ if (piclass=="采购验退单"||piclass=="委外验退单"){
|
|
|
+ //云顶插入采购/委外验退单接口
|
|
|
+ }
|
|
|
+ if (piclass=="拨出单"){
|
|
|
+ //云顶插入拨出单接口
|
|
|
+ }
|
|
|
+ if (piclass=="其他入库单"){
|
|
|
+ //云顶插入其他入库单接口
|
|
|
+ }
|
|
|
+ if (piclass=="其他出库单"){
|
|
|
+ //云顶插入其他出库单接口
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 出入库单云顶数据中心传UAS过账接口
|
|
|
+ *
|
|
|
+ * @param Store
|
|
|
+ * 单据编号,类型等Json数据 Store
|
|
|
+ *
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void ProdInOutPOST(String Store) {
|
|
|
+ com.alibaba.fastjson.JSONObject json = JSON.parseObject(Store);
|
|
|
+ String Code=json.getString("xxxxxx").toString();
|
|
|
+ String Piclass=json.getString("xxxxxx").toString();
|
|
|
+ String res=null;
|
|
|
+ baseDao.procedure("SP_GetCostPrice", new Object[] { Piclass, Code });
|
|
|
+ res = baseDao.callProcedure("Sp_SplitProdOut",
|
|
|
+ new Object[] { Piclass, Code, "ADMIN" });
|
|
|
+
|
|
|
+ if (res != null && !res.trim().equals("")) {
|
|
|
+ // 重新添加提示限制信息
|
|
|
+ BaseUtil.showError(res + " " +Piclass + Code + "，过账失败");
|
|
|
+ // BaseUtil.showError(res);
|
|
|
+ }
|
|
|
+ res = baseDao.callProcedure("Sp_CommitProdInout",
|
|
|
+ new Object[] { Piclass, Code, "ADMIN"});
|
|
|
+ if (res != null && !res.trim().equals("")) {
|
|
|
+ BaseUtil.showError(res);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 销售订单云顶数据中心传UAS并生成一张已过账销售出货单接口
|
|
|
+ *
|
|
|
+ * @param Store
|
|
|
+ * 销售订单主从表Json数据 Store
|
|
|
+ *
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void Salereceive(String Store) {
|
|
|
+ //销售订单插入
|
|
|
+ com.alibaba.fastjson.JSONObject json = JSON.parseObject(Store);
|
|
|
+ String jsons =json.toString();
|
|
|
+ List<Object[]> mappingList = baseDao.getFieldsDatasByCondition("xxx", new String[] { "TD_FROMFIELD", "TD_TOFIELD" }, "qu_id=1");
|
|
|
+ Map<String, String> resultmap = new HashMap<String, String>();
|
|
|
+ for(Object[] obj : mappingList){
|
|
|
+ resultmap.put(String.valueOf(obj[0]), String.valueOf(obj[1]));
|
|
|
+ }
|
|
|
+ Map<String, Object> njson=BaseUtil.jsonToMap(jsons, resultmap);
|
|
|
+ Map<Object, Object> store = (Map<Object, Object>) njson.get("stockout_list");
|
|
|
+ store.put("sa_status", "已审核");
|
|
|
+ store.put("sa_statuscode", "AUDITED");
|
|
|
+ int id= Integer.valueOf(String.valueOf(baseDao.getFieldDataByCondition("dual", "sale_seq.nextval", "1=1")));
|
|
|
+ store.put("sa_id", id);
|
|
|
+ List<Map<Object, Object>> grid = (List<Map<Object, Object>>) njson.get("details_list");
|
|
|
+ for (Map<Object, Object> map : grid) {
|
|
|
+ map.put("sd_said", id);
|
|
|
+ map.put("sd_id", "saledetail_seq.nextval");
|
|
|
+ }
|
|
|
+ int count= Integer.valueOf(String.valueOf(baseDao.getFieldDataByCondition("Sale", "count(1)", "sa_code=" + store.get("order_no"))));
|
|
|
+ if (count >0) {
|
|
|
+ // 重新添加提示限制信息
|
|
|
+ BaseUtil.showError(store.get("order_no") + "编号已存在");
|
|
|
+ }
|
|
|
+ // 保存sale
|
|
|
+ String formSql = SqlUtil.getInsertSqlByMap(store, "Sale");
|
|
|
+ baseDao.execute(formSql);
|
|
|
+ // 保存saleDetail
|
|
|
+ List<String> gridSql = SqlUtil.getInsertSqlbyList(grid, "SaleDetail", "sd_id");
|
|
|
+ baseDao.execute(gridSql);
|
|
|
+ //调用生成出货单方法
|
|
|
+ TurnProdIN(id);
|
|
|
+ //过账生成的出货单
|
|
|
+ String pi_inoutno= String.valueOf(baseDao.getFieldDataByCondition("ProdInOut", "pi_inoutno", "pi_sourcecoe="+store.get("order_no")));
|
|
|
+ String res=null;
|
|
|
+ baseDao.procedure("SP_GetCostPrice", new Object[] { "出货单", pi_inoutno });
|
|
|
+ res = baseDao.callProcedure("Sp_SplitProdOut",
|
|
|
+ new Object[] { "出货单", pi_inoutno, "ADMIN" });
|
|
|
+
|
|
|
+ if (res != null && !res.trim().equals("")) {
|
|
|
+ // 重新添加提示限制信息
|
|
|
+ BaseUtil.showError(res + " 出货单" + pi_inoutno + "，过账失败");
|
|
|
+ // BaseUtil.showError(res);
|
|
|
+ }
|
|
|
+ res = baseDao.callProcedure("Sp_CommitProdInout",
|
|
|
+ new Object[] { "出货单", pi_inoutno, "ADMIN"});
|
|
|
+ if (res != null && !res.trim().equals("")) {
|
|
|
+ BaseUtil.showError(res);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 销售订单形成对应得出货单
|
|
|
+ *
|
|
|
+ * @param id
|
|
|
+ * 单据类型id
|
|
|
+ *
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void TurnProdIN(int id) {
|
|
|
+ String code=baseDao.callProcedure("Sp_GetMaxNumber", new Object[] { "ProdInOut!Sale", 2 });
|
|
|
+ int pi_id= Integer.valueOf(String.valueOf(baseDao.getFieldDataByCondition("dual", "ProdInOut_seq.nextval", "1=1")));
|
|
|
+ String contactSql = "insert into ProdInOut (pi_id,pi_inoutno,pi_recordman,pi_operatorcode,pi_recorddate,pi_invostatus,pi_invostatuscode,pi_class,pi_cardid,pi_cardcode,pi_title,pi_status,pi_statuscode,pi_updatedate,pi_updateman,pi_receivecode,pi_receivename,pi_arcode,pi_arname,pi_currency,pi_rate,pi_sellercode,pi_sellername,pi_address,pi_remark,pi_cusaddresssid,pi_paymentcode,pi_cop,pi_departmentcode,pi_departmentname,pi_transport,pi_payment,pi_printstatus,pi_printstatuscode,pi_chargeamount,pi_sourcecoe) "
|
|
|
+ + "select"+pi_id+","+code+",'admin','ADMIN',sysdate,'在录入','ENTERING','出货单',sa_custid,sa_custcode,sa_custname,'未过账','UNPOST',sysdate,'admin',sa_shcustcode,sa_shcustname,sa_apcustcode,sa_apcustname,sa_currency,sa_rate,sa_sellercode,sa_seller,sa_toplace,sa_remark,sa_cusaddresssid,sa_paymentscode,sa_cop,sa_departmentcode,sa_departmentname,sa_transport,sa_payments,'未打印','UNPRINT',sa_fare,sa_code from sale where sa_id="+id;
|
|
|
+ baseDao.execute(contactSql);
|
|
|
+ contactSql = "insert into ProdIODetail (pd_id,pd_piid,pd_orderdetno,pd_ordercode,pd_prodcode,pd_sendprice,pd_outqty,pd_beipinoutqty,pd_pocode,pd_piclass,pd_status,pd_auditstatus,pd_taxrate,pd_sdid,pd_remark,pd_custprodcode,pd_custprodspec,pd_discount,pd_inqty,pd_custproddetail,pd_purcprice,pd_commissionrate,pd_whcode,pd_whname) "
|
|
|
+ + "select ProdIODetail_seq.nextval,"+pi_id+",sd_detno,sa_code,sd_prodcode,sd_price,sd_qty,sd_readyqty,sa_pocode,'出货单',0,'ENTERING',sd_taxrate,sd_id,sd_remark,sd_custprodcode,sd_prodcustcode,sd_discount,0,sd_custproddetail,sd_purcprice,sd_commissionrate,sd_whcode,sd_whcode from saledetail left join sale on sd_said=sa_id where sa_id="+id;
|
|
|
+ baseDao.execute(contactSql);
|
|
|
+ baseDao.execute("update Prodinout set (pi_whcode,pi_whname)=(select pd_whcode,pd_whname from ProdIODetail where pd_piid="
|
|
|
+ + pi_id + " and pd_pdno=1) where pi_id=" + pi_id + "");
|
|
|
+
|
|
|
+ baseDao.execute(
|
|
|
+ "update ProdInOut set pi_address=(select cu_add1 from customer where pi_cardcode=cu_code) where pi_id=? and nvl(pi_address,' ')=' '",
|
|
|
+ pi_id);
|
|
|
+ baseDao.execute("update prodinout set pi_purposename=((select max(ca_person) from CustomerAddress left join customer on ca_cuid=cu_id where cu_code=pi_cardcode and ca_address=pi_address)) where pi_purposename is null and pi_id="
|
|
|
+ + pi_id);
|
|
|
+ baseDao.execute("update prodinout set pi_expresscode=((select max(ca_phone) from CustomerAddress left join customer on ca_cuid=cu_id where cu_code=pi_cardcode and ca_address=pi_address)) where pi_expresscode is null and pi_id="
|
|
|
+ + pi_id);
|
|
|
+ baseDao.execute("update prodinout set pi_fax=((select max(ca_fax) from CustomerAddress left join customer on ca_cuid=cu_id where cu_code=pi_cardcode and ca_address=pi_address)) where pi_fax is null and pi_id="
|
|
|
+ + pi_id);
|
|
|
+ baseDao.execute(
|
|
|
+ "update ProdIODetail set pd_netprice=ROUND(pd_sendprice/(1 + pd_taxrate/ 100),6), pd_taxtotal=round(pd_sendprice*pd_outqty/(1+pd_taxrate/100),2), pd_ordertotal=round(pd_outqty*pd_sendprice,2) where pd_piid=?",
|
|
|
+ pi_id);
|
|
|
+ baseDao.execute(
|
|
|
+ "update saleDetail set sdyqty=sd_qty where sd_said=?",
|
|
|
+ id);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 销售退货单云顶数据中心传UAS并过账接口
|
|
|
+ *
|
|
|
+ * @param Store
|
|
|
+ * 销售退货单主从表Json数据 Store
|
|
|
+ *
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void SaleReturn(String Store) {
|
|
|
+ //销售退货单插入
|
|
|
+ com.alibaba.fastjson.JSONObject json = JSON.parseObject(Store);
|
|
|
+ String jsons =json.toString();
|
|
|
+ List<Object[]> mappingList = baseDao.getFieldsDatasByCondition("xxx", new String[] { "TD_FROMFIELD", "TD_TOFIELD" }, "qu_id=1");
|
|
|
+ Map<String, String> resultmap = new HashMap<String, String>();
|
|
|
+ for(Object[] obj : mappingList){
|
|
|
+ resultmap.put(String.valueOf(obj[0]), String.valueOf(obj[1]));
|
|
|
+ }
|
|
|
+ Map<String, Object> njson=BaseUtil.jsonToMap(jsons, resultmap);
|
|
|
+ Map<Object, Object> store = (Map<Object, Object>) njson.get("date");
|
|
|
+ store.put("pi_invostatus", "已审核");
|
|
|
+ store.put("pi_invostatuscode", "AUDITED");
|
|
|
+ int id= Integer.valueOf(String.valueOf(baseDao.getFieldDataByCondition("dual", "ProdInOut_seq.nextval", "1=1")));
|
|
|
+ store.put("pi_id", id);
|
|
|
+ List<Map<Object, Object>> grid = (List<Map<Object, Object>>) njson.get("refund_orders_list");
|
|
|
+ for (Map<Object, Object> map : grid) {
|
|
|
+ map.put("pd_piid", id);
|
|
|
+ map.put("pd_id", "ProdIODetail_seq.nextval");
|
|
|
+ }
|
|
|
+ int count= Integer.valueOf(String.valueOf(baseDao.getFieldDataByCondition("ProdInOut", "count(1)", "pi_inoutno=" + store.get("refund_no")+"and pi_class='销售退货单'")));
|
|
|
+ if (count >0) {
|
|
|
+ // 重新添加提示限制信息
|
|
|
+ BaseUtil.showError(store.get("refund_no") + "编号已存在");
|
|
|
+ }
|
|
|
+ // 保存ProdInOut
|
|
|
+ String formSql = SqlUtil.getInsertSqlByMap(store, "ProdInOut");
|
|
|
+ baseDao.execute(formSql);
|
|
|
+ // 保存ProdIODetail
|
|
|
+ List<String> gridSql = SqlUtil.getInsertSqlbyList(grid, "ProdIODetail", "pd_id");
|
|
|
+ baseDao.execute(gridSql);
|
|
|
+ //过账生成的退货单
|
|
|
+ String res=null;
|
|
|
+ baseDao.procedure("SP_GetCostPrice", new Object[] { "出货单", store.get("refund_no") });
|
|
|
+ res = baseDao.callProcedure("Sp_SplitProdOut",
|
|
|
+ new Object[] { "销售退货单", store.get("refund_no"), "ADMIN" });
|
|
|
+
|
|
|
+ if (res != null && !res.trim().equals("")) {
|
|
|
+ // 重新添加提示限制信息
|
|
|
+ BaseUtil.showError(res + " 销售退货单" + store.get("refund_no") + "，过账失败");
|
|
|
+ // BaseUtil.showError(res);
|
|
|
+ }
|
|
|
+ res = baseDao.callProcedure("Sp_CommitProdInout",
|
|
|
+ new Object[] { "销售退货单", store.get("refund_no"), "ADMIN"});
|
|
|
+ if (res != null && !res.trim().equals("")) {
|
|
|
+ BaseUtil.showError(res);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 退货单云顶数据中心传UAS反过账接口
|
|
|
+ *
|
|
|
+ * @param Store
|
|
|
+ * 单据编号,类型等Json数据 Store
|
|
|
+ *
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void SaleReturnDelete(String Store) {
|
|
|
+ com.alibaba.fastjson.JSONObject json = JSON.parseObject(Store);
|
|
|
+ String Code=json.getString("refund_no").toString();
|
|
|
+ String Piclass="销售退货单";
|
|
|
+ int piid= Integer.valueOf(String.valueOf(baseDao.getFieldDataByCondition("ProdInOut", "pi_id", "pi_inoutno=" + Code+"and pi_class="+Piclass)));
|
|
|
+ String res=null;
|
|
|
+ res= baseDao.callProcedure("Sp_UnCommitProdInout", Piclass,Code);
|
|
|
+ if (res != null && !res.trim().equals("")) {
|
|
|
+ BaseUtil.showError(res);
|
|
|
+ }
|
|
|
+ baseDao.updateByCondition("ProdInOut", "pi_statuscode='UNPOST',pi_status='未过账',pi_inoutman=null,pi_date1=null", "pi_id=" + piid);
|
|
|
+ //删除反过账销售退货单
|
|
|
+ baseDao.deleteByCondition("ProdIODetail", "pd_piid="+piid);
|
|
|
+ baseDao.deleteByCondition("ProdInOut", "pi_id="+piid);
|
|
|
+ }
|
|
|
+}
|
xiongzx