客户资料同步和工单明细校验

src/main/java/com/uas/eis/core/support/SpringDynamicCronTask.java

@@ -69,6 +69,15 @@ public class SpringDynamicCronTask implements SchedulingConfigurer {
 					e.printStackTrace();
 				}
 			}, env.getProperty("Task.syncMakematerialReplaceCron"));
+			taskRegistrar.addCronTask(() -> {
+				//业务逻辑
+				try {
+					Method method = scheduleTask.getClass().getMethod(env.getProperty("Task.syncCustomerMethod"));
+					method.invoke(scheduleTask);
+				}catch (Exception e){
+					e.printStackTrace();
+				}
+			}, env.getProperty("Task.syncCustomerCron"));
 		}
 	}
 }

src/main/java/com/uas/eis/entity/Customer.java

@@ -0,0 +1,107 @@
+package com.uas.eis.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+
+import java.io.Serializable;
+
+public class Customer implements Serializable {
+
+    @JSONField(name = "custId")
+    private int cu_id;
+//oldNo   custNo   custName  nameAlias companyNo
+    @JSONField(name = "oldNo")
+    private String cu_oldcode;
+
+    @JSONField(name = "custNo")
+    private String cu_code;
+
+    @JSONField(name = "custName")
+    private String cu_name;
+
+    @JSONField(name = "nameAlias")
+    private String cu_shortname;
+
+    @JSONField(name = "companyNo")
+    private String cu_cop;
+
+    @JSONField(name = "mesUser")
+    private String mesUser;
+
+    @JSONField(name = "mesPwd")
+    private String mesPwd;
+
+    @JSONField(name = "flag")
+    private int flag;
+
+    public int getCu_id() {
+        return cu_id;
+    }
+
+    public void setCu_id(int cu_id) {
+        this.cu_id = cu_id;
+    }
+
+    public String getCu_oldcode() {
+        return cu_oldcode;
+    }
+
+    public void setCu_oldcode(String cu_oldcode) {
+        this.cu_oldcode = cu_oldcode;
+    }
+
+    public String getCu_code() {
+        return cu_code;
+    }
+
+    public void setCu_code(String cu_code) {
+        this.cu_code = cu_code;
+    }
+
+    public String getCu_name() {
+        return cu_name;
+    }
+
+    public void setCu_name(String cu_name) {
+        this.cu_name = cu_name;
+    }
+
+    public String getCu_shortname() {
+        return cu_shortname;
+    }
+
+    public void setCu_shortname(String cu_shortname) {
+        this.cu_shortname = cu_shortname;
+    }
+
+    public String getCu_cop() {
+        return cu_cop;
+    }
+
+    public void setCu_cop(String cu_cop) {
+        this.cu_cop = cu_cop;
+    }
+
+    public String getMesUser() {
+        return mesUser;
+    }
+
+    public void setMesUser(String mesUser) {
+        this.mesUser = mesUser;
+    }
+
+    public String getMesPwd() {
+        return mesPwd;
+    }
+
+    public void setMesPwd(String mesPwd) {
+        this.mesPwd = mesPwd;
+    }
+
+    public int getFlag() {
+        return flag;
+    }
+
+    public void setFlag(int flag) {
+        this.flag = flag;
+    }
+}

src/main/java/com/uas/eis/service/ERPService.java

@@ -23,4 +23,12 @@ public interface ERPService {
     Map<String, Object> syncDeleteMake(String data);
 
     ApiResult<String> syncProdInOutMakeGive(String data);
+
+    /**
+     * 更新BOM明细前限制
+     * @param data
+     * @return
+     */
+    Map<String, Object> checkProdBomItem(String data);
+
 }

src/main/java/com/uas/eis/service/Impl/ERPServiceImpl.java

@@ -174,6 +174,20 @@ public class ERPServiceImpl implements ERPService {
         }
     }
 
+    @Override
+    public Map<String, Object> checkProdBomItem(String data) {
+        Map<String, Object> hashMap = new HashMap<>();
+        hashMap.put("code", 0);
+        hashMap.put("msg", "参数异常，请联系管理员！");
+        Map<String, Object> map = syncMESDeleteMake(JSON.toJSONString(data).replace("null", "\"\""), tokenConfig.get("syncMakeMaterialCheck"));
+        if (map != null) {
+            int msgId = Integer.parseInt(StringUtil.nvl(map.get("msgId"), "-1"));
+            hashMap.put("code", msgId);
+            hashMap.put("msg", map.get("msgStr"));
+        }
+        return hashMap;
+    }
+
     private ApiResult<String> syncMES(String params,String url) {
         try {
             logger.info("params：" + params);

src/main/java/com/uas/eis/service/Impl/ScheduleTaskServiceImpl.java

@@ -6,6 +6,7 @@ import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.uas.eis.core.support.TokenProperties;
 import com.uas.eis.dao.BaseDao;
 import com.uas.eis.dao.SqlRowList;
+import com.uas.eis.entity.Customer;
 import com.uas.eis.entity.Make;
 import com.uas.eis.entity.MakeMaterial;
 import com.uas.eis.entity.Product;
@@ -20,6 +21,7 @@ import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.stereotype.Service;
 
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -246,6 +248,47 @@ public class ScheduleTaskServiceImpl implements ScheduleTaskService {
         }
     }
 
+    @Override
+    public void syncCustomer() {
+        try {
+            SqlRowList rs = baseDao.queryForRowSet("select id from mes_customer where status='W' order by id");
+            List<Customer> customers = baseDao.query("select cu_id,nvl(cu_mescode,cu_code) cu_oldcode,nvl(cu_mescode,cu_code) cu_code,cu_name,cu_shortname,nvl(cu_cop,'BYT') cu_cop,flag from mes_customer where status='W' order by id", Customer.class);
+            if (customers!=null&&customers.size()>0){
+                for (Customer customer:customers) {
+                    customer.setMesUser(tokenConfig.get("mesUser"));
+                    customer.setMesPwd(MD5Util.encodeByMD5(tokenConfig.get("mesPwd")));
+                    Map<String, Object> map = syncMES(JSON.toJSONString(customer, SerializerFeature.WriteMapNullValue).replace("null", "\"\""), tokenConfig.get("syncCustomer"));
+                    if (map!=null){
+                        int code = Integer.parseInt(StringUtil.nvl(map.get("msgId"), "-1"));
+                        if (code==0){
+                            baseDao.updateByCondition("mes_customer","status='D'","status='W' and id="+rs.getInt("id"));
+                        }else {
+                            int flag = customer.getFlag();
+                            if (flag == 1) {
+                                customer.setFlag(0);
+                            } else if (flag == 0) {
+                                customer.setFlag(1);
+                            }
+                            Map<String, Object> map1 = syncMES(JSON.toJSONString(customer, SerializerFeature.WriteMapNullValue).replace("null", "\"\""), tokenConfig.get("syncCustomer"));
+                            if (map1!=null){
+                                int code1 = Integer.parseInt(StringUtil.nvl(map.get("msgId"), "-1"));
+                                if (code1==0){
+                                    baseDao.updateByCondition("mes_customer","status='D'","status='W' and id="+rs.getInt("id"));
+                                }else {
+                                    baseDao.updateByCondition("mes_customer","status='F'","status='W' and id="+rs.getInt("id"));
+                                    baseDao.execute("insert into meserrorlog (mel_id,mel_url,mel_error,mel_indate,mel_djcode,mel_type) values (MESERRORLOG_SEQ.NEXTVAL,'"+tokenConfig.get("syncCustomer")+"','"+StringUtil.nvl(map.get("msgStr"),"")+"',sysdate,'"+customer.getCu_code()+"','客户资料')");
+                                }
+                            }
+                        }
+                    }
+                }
+            }
+        }catch (Exception e){
+            logger.info("客户资料异常信息："+e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
     private Map<String, Object> syncMES(String params,String url){
         Map<String, Object> map = new HashMap<>();
         map.put("code",-1);

src/main/java/com/uas/eis/service/ScheduleTaskService.java

@@ -7,13 +7,30 @@ package com.uas.eis.service;
  */
 public interface ScheduleTaskService {
 
+    /**
+     * 同步物料资料
+     */
     void syncProducts();
 
+    /**
+     * 同步工单
+     */
     void syncMakeBases();
 
+    /**
+     * 同步工单BOM
+     */
     void syncMakeBaseDetails();
 
+    /**
+     * 同步替代料
+     */
     void syncMakematerialReplace();
 
+    /**
+     * 同步客户资料
+     */
+    void syncCustomer();
+
 
 }

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

@@ -65,4 +65,14 @@ public class ScheduleTask {
 
     }
 
+    /**
+     * 同步客户资料
+     */
+    public void syncCustomer(){
+        logger.info("同步客户资料开始");
+        Date date = new Date();
+        scheduleTaskService.syncCustomer();
+        logger.info("同步客户资料:用时" + ((System.currentTimeMillis() - date.getTime()) / 1000));
+    }
+
 }

src/main/resources/api_sign_key_mapping.properties

@@ -6,4 +6,6 @@ syncProduct=updateItemByErp
 syncMakeBase=updateProdByErp
 syncMakeBaseDetail=updateProdBomByErp
 syncUpdateReceiveByErp=updateReceiveByErp
-syncProdInOutMakeGive=updateProdFeedBomByErp
+syncProdInOutMakeGive=updateProdFeedBomByErp
+syncCustomer=webEditCustomer
+syncMakeMaterialCheck=checkProdBomItem

src/main/resources/application-prod.yml

@@ -23,6 +23,9 @@ Task:
     SyncMakeBaseDetailsCron: 0 0/1 * * * ?
     syncMakematerialReplaceMethod: syncMakematerialReplace
     syncMakematerialReplaceCron: 0 0/1 * * * ?
+    syncCustomerMethod: syncCustomer
+    syncCustomerCron: 0 0/1 * * * ?
+
 
 action:
     api_action: /EIS/api,/EIS/mes,/EIS/erp