Browse Source

【华信科】【富勒WMS对接】【出库单创建】【出库单确认】

wuyx 8 months ago
parent
commit
ef4c8f4918
1 changed files with 10 additions and 10 deletions
  1. 10 10
      src/main/java/com/uas/eis/service/Impl/ERPServiceImpl.java

+ 10 - 10
src/main/java/com/uas/eis/service/Impl/ERPServiceImpl.java

@@ -149,7 +149,7 @@ public class ERPServiceImpl implements ERPService {
                 eMsg = StringUtil.nvl(response.getResponseText(),"未知");
                 eMsg = StringUtil.nvl(response.getResponseText(),"未知");
                 retMap.put("success", false);
                 retMap.put("success", false);
                 retMap.put("message", "请求失败:"+response.getStatusCode()+":"+eMsg);
                 retMap.put("message", "请求失败:"+response.getStatusCode()+":"+eMsg);
-                baseDao.execute("update "+master+".product set pr_sendwmsstatus='同步失败',pr_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
+                baseDao.execute("update "+master+".product set pr_sendwmsstatus='同步失败',pr_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
                             " where pr_code IN ("+prCodes+")");
                             " where pr_code IN ("+prCodes+")");
             }else {
             }else {
                 retMap.put("success",true);
                 retMap.put("success",true);
@@ -171,7 +171,7 @@ public class ERPServiceImpl implements ERPService {
                                 eMsg = item.getMessage();
                                 eMsg = item.getMessage();
                                 if(!eMsg.equals("The goods don't exists, you can't update it.")){//提示异常但是实际会自动创建 可以认定为请求成功
                                 if(!eMsg.equals("The goods don't exists, you can't update it.")){//提示异常但是实际会自动创建 可以认定为请求成功
                                     logger.info("response-failure-item code: {} message: {}", item.getItemCode(),item.getMessage());
                                     logger.info("response-failure-item code: {} message: {}", item.getItemCode(),item.getMessage());
-                                    sqls.add("update "+master+".product set pr_sendwmsstatus='同步失败',pr_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') where pr_code ='"+item.getItemCode()+"'");
+                                    sqls.add("update "+master+".product set pr_sendwmsstatus='同步失败',pr_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') where pr_code ='"+item.getItemCode()+"'");
                                     if(errMsg.length()>0){
                                     if(errMsg.length()>0){
                                         errMsg.append("</br>");
                                         errMsg.append("</br>");
                                         errMsg.append("物料编号:"+item.getItemCode()+",失败原因:"+eMsg);
                                         errMsg.append("物料编号:"+item.getItemCode()+",失败原因:"+eMsg);
@@ -187,7 +187,7 @@ public class ERPServiceImpl implements ERPService {
                             }
                             }
                         }else {
                         }else {
                             eMsg = StringUtil.nvl(baseVastRespResponse.getMessage(),"无");
                             eMsg = StringUtil.nvl(baseVastRespResponse.getMessage(),"无");
-                            baseDao.execute("update "+master+".product set pr_sendwmsstatus='同步失败',pr_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
+                            baseDao.execute("update "+master+".product set pr_sendwmsstatus='同步失败',pr_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
                                     " where pr_code IN ("+prCodes+")");
                                     " where pr_code IN ("+prCodes+")");
                             retMap.put("message", eMsg);
                             retMap.put("message", eMsg);
                         }
                         }
@@ -368,7 +368,7 @@ public class ERPServiceImpl implements ERPService {
                 eMsg = StringUtil.nvl(response.getResponseText(),"未知");
                 eMsg = StringUtil.nvl(response.getResponseText(),"未知");
                 retMap.put("success", false);
                 retMap.put("success", false);
                 retMap.put("message", "请求失败:"+response.getStatusCode()+":"+eMsg);
                 retMap.put("message", "请求失败:"+response.getStatusCode()+":"+eMsg);
-                baseDao.execute("update "+master+".vendor set ve_sendwmsstatus='同步失败',ve_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
+                baseDao.execute("update "+master+".vendor set ve_sendwmsstatus='同步失败',ve_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
                         " where ve_code IN ("+codes+")");
                         " where ve_code IN ("+codes+")");
             }else {
             }else {
                 retMap.put("success",true);
                 retMap.put("success",true);
@@ -390,7 +390,7 @@ public class ERPServiceImpl implements ERPService {
                                 eMsg = item.getMessage();
                                 eMsg = item.getMessage();
                                 if(!eMsg.equals("The goods don't exists, you can't update it.")){//提示异常但是实际会自动创建 可以认定为请求成功
                                 if(!eMsg.equals("The goods don't exists, you can't update it.")){//提示异常但是实际会自动创建 可以认定为请求成功
                                     logger.info("response-failure-item code: {} message: {}", item.getItemCode(),item.getMessage());
                                     logger.info("response-failure-item code: {} message: {}", item.getItemCode(),item.getMessage());
-                                    sqls.add("update "+master+".vendor set ve_sendwmsstatus='同步失败',ve_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') where ve_code ='"+item.getItemCode()+"'");
+                                    sqls.add("update "+master+".vendor set ve_sendwmsstatus='同步失败',ve_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') where ve_code ='"+item.getItemCode()+"'");
                                     if(errMsg.length()>0){
                                     if(errMsg.length()>0){
                                         errMsg.append("</br>");
                                         errMsg.append("</br>");
                                         errMsg.append("物料编号:"+item.getItemCode()+",失败原因:"+eMsg);
                                         errMsg.append("物料编号:"+item.getItemCode()+",失败原因:"+eMsg);
@@ -406,7 +406,7 @@ public class ERPServiceImpl implements ERPService {
                             }
                             }
                         }else {
                         }else {
                             eMsg = StringUtil.nvl(baseVastRespResponse.getMessage(),"无");
                             eMsg = StringUtil.nvl(baseVastRespResponse.getMessage(),"无");
-                            baseDao.execute("update "+master+".vendor set ve_sendwmsstatus='同步失败',ve_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
+                            baseDao.execute("update "+master+".vendor set ve_sendwmsstatus='同步失败',ve_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
                                     " where ve_code IN ("+codes+")");
                                     " where ve_code IN ("+codes+")");
                             retMap.put("message", eMsg);
                             retMap.put("message", eMsg);
                         }
                         }
@@ -580,7 +580,7 @@ public class ERPServiceImpl implements ERPService {
                 eMsg = StringUtil.nvl(response.getResponseText(),"未知");
                 eMsg = StringUtil.nvl(response.getResponseText(),"未知");
                 retMap.put("success", false);
                 retMap.put("success", false);
                 retMap.put("message", "请求失败:"+response.getStatusCode()+":"+eMsg);
                 retMap.put("message", "请求失败:"+response.getStatusCode()+":"+eMsg);
-                baseDao.execute("update "+master+".customer set cu_sendwmsstatus='同步失败',cu_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
+                baseDao.execute("update "+master+".customer set cu_sendwmsstatus='同步失败',cu_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
                         " where cu_code IN ("+codes+")");
                         " where cu_code IN ("+codes+")");
             }else {
             }else {
                 retMap.put("success",true);
                 retMap.put("success",true);
@@ -602,7 +602,7 @@ public class ERPServiceImpl implements ERPService {
                                 eMsg = item.getMessage();
                                 eMsg = item.getMessage();
                                 if(!eMsg.equals("The goods don't exists, you can't update it.")){
                                 if(!eMsg.equals("The goods don't exists, you can't update it.")){
                                     logger.info("response-failure-item code: {} message: {}", item.getItemCode(),item.getMessage());
                                     logger.info("response-failure-item code: {} message: {}", item.getItemCode(),item.getMessage());
-                                    sqls.add("update "+master+".customer set cu_sendwmsstatus='同步失败',cu_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') where cu_code ='"+item.getItemCode()+"'");
+                                    sqls.add("update "+master+".customer set cu_sendwmsstatus='同步失败',cu_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') where cu_code ='"+item.getItemCode()+"'");
                                     if(errMsg.length()>0){
                                     if(errMsg.length()>0){
                                         errMsg.append("</br>");
                                         errMsg.append("</br>");
                                         errMsg.append("客户编号:"+item.getItemCode()+",失败原因:"+eMsg);
                                         errMsg.append("客户编号:"+item.getItemCode()+",失败原因:"+eMsg);
@@ -618,7 +618,7 @@ public class ERPServiceImpl implements ERPService {
                             }
                             }
                         }else {
                         }else {
                             eMsg = StringUtil.nvl(baseVastRespResponse.getMessage(),"无");
                             eMsg = StringUtil.nvl(baseVastRespResponse.getMessage(),"无");
-                            baseDao.execute("update "+master+".customer set cu_sendwmsstatus='同步失败',cu_sendwmserr=UNISTR('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
+                            baseDao.execute("update "+master+".customer set cu_sendwmsstatus='同步失败',cu_sendwmserr=('操作:"+actionType+":"+eMsg.replaceAll("'","''")+"') " +
                                     " where cu_code IN ("+codes+")");
                                     " where cu_code IN ("+codes+")");
                             retMap.put("message", eMsg);
                             retMap.put("message", eMsg);
                         }
                         }
@@ -977,7 +977,7 @@ public class ERPServiceImpl implements ERPService {
             //未确认前根据明细更新prodiowms
             //未确认前根据明细更新prodiowms
             if(!prodInOut.getPiWmsstatus().equals("已确认")){
             if(!prodInOut.getPiWmsstatus().equals("已确认")){
                 baseDao.execute("delete from "+master+".prodiowms where PIID = "+prodInOut.getPiId());
                 baseDao.execute("delete from "+master+".prodiowms where PIID = "+prodInOut.getPiId());
-                baseDao.execute("INSERT INTO "+master+".prodiowms(ITIME,PIID, PIINOUTNO, ENTRYORDERCODE, OWNERCODE, WAREHOUSECODE, ENTRYORDERID, ENTRYORDERTYPE" +
+                baseDao.execute("INSERT INTO "+master+".prodiowms(ITIME,PIID, PIINOUTNO, ORDERCODE, OWNERCODE, WAREHOUSECODE, WMSORDERID, WMSORDERTYPE" +
                         ")" +
                         ")" +
                         "select sysdate,pi_id,pi_inoutno,pi_inoutno,'"+vwmsConfig.getOwnerCode()+"','"+vwmsConfig.getWarehouseCode()+"',PI_WMSORDERCODE,PI_WMSORDERTYPE" +
                         "select sysdate,pi_id,pi_inoutno,pi_inoutno,'"+vwmsConfig.getOwnerCode()+"','"+vwmsConfig.getWarehouseCode()+"',PI_WMSORDERCODE,PI_WMSORDERTYPE" +
                         " from "+master+".prodinout where pi_id = "+prodInOut.getPiId());
                         " from "+master+".prodinout where pi_id = "+prodInOut.getPiId());