新增盘点入库

zc

2024-07-25 dc13d06680b693b22fd21cbea6b3b06ed8f964d4

 src/main/java/com/zy/common/service/erp/ErpSqlServer.java

@@ -1,11 +1,12 @@
package com.zy.common.service.erp;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.annotations.TableField;
import com.baomidou.mybatisplus.annotations.TableName;
import com.core.common.Cools;
import com.zy.third.erp.entity.InDetTB;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@@ -42,14 +43,14 @@
//        sql = "update InStockBill set Fflag_finish = 1 where FBillNo = ''{0}''";
//        sql = MessageFormat.format(sql, "123456");
//        erpSqlServer.update(sql);
        

        HashMap<String, Object> stringStringHashMap = new HashMap<>();
        stringStringHashMap.put("BillNo","'1231312'");
        stringStringHashMap.put("test","'1231312'");
        stringStringHashMap.put("BilhahahlNo","'1231312'");
        stringStringHashMap.put("B21312illNo","'1231312'");
        stringStringHashMap.put("testnum",100);
        erpSqlServer.insert(InDetTB.class,stringStringHashMap);
        stringStringHashMap.put("BillNo", "'1231312'");
        stringStringHashMap.put("test", "'1231312'");
        stringStringHashMap.put("BilhahahlNo", "'1231312'");
        stringStringHashMap.put("B21312illNo", "'1231312'");
        stringStringHashMap.put("testnum", 100);
        erpSqlServer.insert(InDetTB.class, stringStringHashMap);
    }

    // 数据库连接
@@ -74,22 +75,42 @@
        List<T> list = new ArrayList<>();
        if (null != result) {
            for (Map<String, Object> entity : result) {
                list.add(Cools.conver(entity, cls));
                //用最笨的方法转换，也可以用下面的process方法（还没有写全）
                list.add(JSONObject.parseObject(JSONObject.toJSONString(entity), cls));
                //list.add(Cools.conver(entity, cls));
            }
        }
        return list;
    }
    
    

    @SneakyThrows
    public <T> void process(Map<String, Object> entity, Class<T> cls) {
        for (Map.Entry<String, Object> entry : entity.entrySet()) {
            String fieldName = entry.getKey();
            Object value = entry.getValue();

            Field field = cls.getDeclaredField(fieldName);
            field.setAccessible(true);

            if (value instanceof Integer && field.getType() == int.class || field.getType() == Integer.class) {
                field.setInt(cls, (Integer) value);
            } else if (value instanceof String && field.getType() == String.class) {
                field.set(cls, value);
            }
            // 其他类型可以类似处理
        }
    }

    /**
     * 扫描所有实力类属性里的TableField注解,并将里面的值作为column
     *
     * @param cls
     * @param <T>
     * @return
     */
    public <T> String selectFrontPart(Class<T> cls){
    public <T> String selectFrontPart(Class<T> cls) {
        String tableName = cls.getDeclaredAnnotation(TableName.class).value();
        List<HashMap<String,String>> columnAndField = new ArrayList<>();
        List<HashMap<String, String>> columnAndField = new ArrayList<>();
        String sql = "SELECT ";
        if (Cools.isEmpty(tableName)) {
            return null;
@@ -98,7 +119,7 @@
        for (Field f : allFields) {
            if (Modifier.isFinal(f.getModifiers())
                    || Modifier.isStatic(f.getModifiers())
                    || Modifier.isTransient(f.getModifiers())){
                    || Modifier.isTransient(f.getModifiers())) {
                continue;
            }
            String column = null;
@@ -110,16 +131,16 @@
            }
            String name = f.getName();
            HashMap<String, String> container = new HashMap<>();
            container.put(column,name);
            container.put(column, name);
            columnAndField.add(container);
        }
        for (int i = 0; i < columnAndField.size(); i++) {
            HashMap<String, String> stringStringHashMap = columnAndField.get(i);
            if (i == columnAndField.size() - 1){
            if (i == columnAndField.size() - 1) {
                for (String s : stringStringHashMap.keySet()) {
                    sql = sql + s + " AS " + stringStringHashMap.get(s);
                }
            }else {
            } else {
                for (String s : stringStringHashMap.keySet()) {
                    sql = sql + s + " AS " + stringStringHashMap.get(s) + ", ";
                }
@@ -128,40 +149,41 @@
        sql = sql + " FROM " + tableName;
        return sql;
    }
    
    public String addWhere(String sql, Map<String,String> condition){

    public String addWhere(String sql, Map<String, String> condition) {
        int conditionSize = 1;
        sql = sql + " WHERE ";
        for (String s : condition.keySet()) {
            if (conditionSize == condition.keySet().size()){
            if (conditionSize == condition.keySet().size()) {
                sql = sql + s + " = " + condition.get(s);
            }else {
            } else {
                sql = sql + s + " = " + condition.get(s) + " and ";
            }
            conditionSize = conditionSize + 1;
        }
        return sql;
    }
    

    /**
     * map的键是列名, 值等同于值
     * key: id, value: 1 等同于 WHERE id = 1
     * 如果要查询字符串需要自行加上''
     * key:name, value: 'zhs'等同于 WHERE name = 'zhs'
     *
     * @param cls
     * @param condition
     * @param <T>
     * @return
     */
    public <T> List<T> selectList(Class<T> cls, Map<String,String> condition){
    public <T> List<T> selectList(Class<T> cls, Map<String, String> condition) {
        String sql = selectFrontPart(cls);
        String finalSQL = addWhere(sql, condition);
        return select(finalSQL,cls);
    } 
    
    public <T> List<T> selectAll(Class<T> cls){
        return select(finalSQL, cls);
    }

    public <T> List<T> selectAll(Class<T> cls) {
        String sql = selectFrontPart(cls);
        return select(sql,cls);
        return select(sql, cls);
    }

    public List<Map<String, Object>> select(String sql) {
@@ -175,7 +197,7 @@
        return executeUpdate(sql);
    }

    public <T> int delete(Class<T> cls, Map<String,String> condition) {
    public <T> int delete(Class<T> cls, Map<String, String> condition) {
        String tableName = cls.getDeclaredAnnotation(TableName.class).value();
        if (Cools.isEmpty(tableName)) {
            return 0;
@@ -184,8 +206,8 @@
        String finalSQL = addWhere(sql, condition);
        return executeUpdate(finalSQL);
    }
    
    public <T> int insert(Class<T> cls, Map<String,Object> condition){

    public <T> int insert(Class<T> cls, Map<String, Object> condition) {
        String tableName = cls.getDeclaredAnnotation(TableName.class).value();
        if (Cools.isEmpty(tableName)) {
            return 0;
@@ -193,9 +215,9 @@
        String sql = "INSERT INTO " + tableName + " (";
        int conditionSize = 1;
        for (String s : condition.keySet()) {
            if (conditionSize == condition.keySet().size()){
                sql = sql +s+")";
            }else {
            if (conditionSize == condition.keySet().size()) {
                sql = sql + s + ")";
            } else {
                sql = sql + s + ",";
            }
            conditionSize = conditionSize + 1;
@@ -203,25 +225,23 @@
        sql = sql + " VALUES(";
        int valuesSize = 1;
        for (String s : condition.keySet()) {
            if (valuesSize == condition.keySet().size()){
                
                sql = sql + condition.get(s)+")";
            }else {
            if (valuesSize == condition.keySet().size()) {

                sql = sql + condition.get(s) + ")";
            } else {
                sql = sql + condition.get(s) + ",";
            }
            valuesSize = valuesSize + 1;
        }
        

        return executeUpdate(sql);
    }
    
    


    /*****************************************************************************/
    /*********************************   核心层   *********************************/
    /*****************************************************************************/

    

    private List<Map<String, Object>> executeQuery(String sql) {
        Connection conn = null;
@@ -285,8 +305,7 @@
        Connection conn = null;
        try {
            conn = getConn();
            if(null != conn)
            {
            if (null != conn) {
                pstm = conn.prepareStatement(sql);

                pstm.setQueryTimeout(QUERY_TIMEOUT_SECONDS);