【博思达】【小米物料WIP对接 修改】

src/main/java/com/uas/eis/task/SyncProductWIPTask.java

@@ -44,7 +44,7 @@ public class SyncProductWIPTask {
         List<Map<String,Object>> list = new ArrayList<>();
         String Sql="select * from (select rownum rn,to_char(cd_date_1,'yyyy-mm-dd hh24:mi:ss') cd_date_ywfs, A.* from (select ct_code,CUSTOMTABLEDETAIL.* from CUSTOMTABLE left join CUSTOMTABLEDETAIL on ct_id=cd_ctid " +
                 " where  ct_caller='XiaoMiProductWIP' and ct_id= " +
-                " (select ct_id from (select ct_id from CUSTOMTABLE where ct_caller='XiaoMiProductWIP' and ct_statuscode='AUDITED' and nvl(ct_confirmstatus, ' ')<>'已上传' order by ct_id desc) where rownum=1)" +
+                " (select ct_id from (select ct_id from CUSTOMTABLE where ct_caller='XiaoMiProductWIP' and ct_statuscode='AUDITED' and nvl(CT_SENDSTATUS, ' ')<>'已上传' order by ct_id desc) where rownum=1)" +
                 " order by cd_detno) A) where rn<=1000";
         SqlRowList rs = baseDao.queryForRowSet(Sql);
         while (rs.next()){
@@ -58,12 +58,10 @@ public class SyncProductWIPTask {
             map.put("project_name",rs.getGeneralString("cd_varchar50_5"));
             map.put("product_code",rs.getGeneralString("cd_varchar50_6"));
             map.put("fact_date",rs.getGeneralString("cd_date_ywfs"));
-            map.put("cd_id",rs.getGeneralInt("cd_id"));
+            map.put("ct_id",rs.getGeneralInt("ct_id"));
             list.add(map);
         }
         data.put("data",list);
-        System.out.println("1啊"+data);
-        System.out.println("2啊"+ JSON.toJSONString(data));
         if(list.size()>0){
             x5JsonHttpClient.post(data, configuration, baseDao, "ProductWIP");
         }

src/main/java/com/uas/eis/task/httpclient/X5JsonHttpClient.java

@@ -18,7 +18,10 @@ import org.slf4j.LoggerFactory;
 
 import javax.xml.bind.DatatypeConverter;
 import java.io.UnsupportedEncodingException;
+import java.util.ArrayList;
 import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 public class X5JsonHttpClient extends X5HttpClient {
 
@@ -84,6 +87,12 @@ public class X5JsonHttpClient extends X5HttpClient {
                 baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
                         "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'上传成功!','','"+kind+"')");
                 logger.info("时间:"+new Date()+"状态码:"+statusCode);
+                Map<String,Object> datas = (Map<String,Object>) body;
+                List<Map<String,Object>> list = (List<Map<String,Object>>) datas.get("data");
+                if(list.size()>0){
+                    System.out.println("112233啊:update CUSTOMTABLE set CT_SENDSTATUS='已上传' where cd_id="+list.get(0).get("ct_id"));
+                    baseDao.execute("update CUSTOMTABLE set CT_SENDSTATUS='已上传',ct_senddate=sysdate where cd_id="+list.get(0).get("ct_id"));
+                }
             } else {
                 baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
                         "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'上传失败！','"+statusLine.getStatusCode() + " " + statusLine.getReasonPhrase()+"','"+kind+"'）");