import org.springframework.stereotype.Repository;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;
 
@Repository
public class EntityManagerDAO {
    @PersistenceContext
    private EntityManager entityManager;
     /**
     * 人員列表排序
     * @return
     */
    @Transactional
    public List<BackstageUserListDTO> listUser(){
        String sql = "select a.create_time createTime," +
                "a.mobilephone phoneNum," +
                "a.email email,a.uid uid," +
                "a.enabled enabled," +
                "c.id_number idNumber," +
                " (case b.`status` when 1 then 1 else 0 end) status " +
                "from tbl_sys_user a " +
                "LEFT JOIN user_high_qic b on a.uid=b.u_id" +
                "LEFT JOIN user_qic c on a.uid=c.uid " +
                "ORDER BY status desc";
 
        SQLQuery sqlQuery = entityManager.createNativeQuery(sql).unwrap(SQLQuery.class);
        Query query = 
     sqlQuery.setResultTransformer(Transformers.aliasToBean(BackstageUserListDTO.class));
        List<BackstageUserListDTO> list = query.list();
        entityManager.clear();
        return list;
    }
}

public class BackstageUserListDTO implements Serializable{
    private static final long serid = 1L;
    private String createTime;
    private String phoneNum;
    private String email;
    private BigInteger uid;
    private Integer enabled;
    private String idNumber;
    private BigInteger status;
    //GETTER SETTER
}

/**
 * 訂單表
 */
@Entity
@Table(name = "signedorder")
@Getter
@Setter
@NoArgsConstructor
@EntityListeners(AuditingEntityListener.class)
public class SignedOrder {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column
    private Integer id;//id
    @CreatedDate
    @Column(updatable = false)
    private Date createTime;//創(chuàng)建時(shí)間
    @LastModifiedDate
    @Column
    private Date lastModifiedTime;//修改時(shí)間
    @ManyToOne(fetch = FetchType.EAGER, cascade = {
            CascadeType.MERGE, CascadeType.PERSIST, CascadeType.REFRESH
    })
    @JoinTable(name = "staff_signedorder", joinColumns = @JoinColumn(name =
            "signedorder_id"), inverseJoinColumns = @JoinColumn(name = "staff_id"))
    private Staff staff;//所屬用戶(hù)
    @JoinColumn(name = "industry_id")
    private Integer industryId;//行業(yè)Id
}

/**
 * 用戶(hù)表
 */
@Entity
@Table(name = "staff")
@Getter
@Setter
@NoArgsConstructor
public class Staff {
 
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private Integer id;//id
    @Column(name = "name", length = 25)
    private String name;//姓名
    @JoinColumn(name = "city_id")
    private Integer cityId;//城市id

/**
 * 城市表
 */
@Entity
@Table(name = "city")
@Getter
@Setter
@NoArgsConstructor
@Accessors(chain = true)
public class City {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private Integer id;//id
    @Column(name = "name", length = 50)
    private String name;//名稱(chēng)
}
//行業(yè)表和城市表一致，就不展示了

@RunWith(SpringRunner.class)
@SpringBootTest
public class SprinBootMarketingsystemApplicationTests {
    @PersistenceContext//jpa的數(shù)據(jù)庫(kù)操作類(lèi)
    private EntityManager entityManger;
    @Test
    public void queryDb(){
       //給參數(shù)賦值
        Integer cityId = 1;
        Integer industryId = 2;
        Integer staffId = 16;
        Date startTime = DateUtil.parse("1970-01-01");//字符串時(shí)間轉(zhuǎn)換為date類(lèi)型
        Date endTime = Calendar.getInstance().getTime();//獲取系統(tǒng)當(dāng)前時(shí)間裝換為date類(lèi)型
        
        //創(chuàng)建SQL語(yǔ)句主體
        StringBuffer stringBuffer = new StringBuffer("\tSELECT\n" +
                "\tcount( * ) count,\n" +
                "\tci.NAME cityName\n" +
                "\tFROM\n" +
                "\tsignedorder s\n" +
                "\tLEFT JOIN staff_signedorder t ON s.id = t.signedorder_id\n" +
                "\tLEFT JOIN staff sta ON t.staff_id = sta.id\n" +
                "\tLEFT JOIN city ci ON sta.city_id = ci.id\n" +
                "\tWHERE\n" +
                "\t1 = 1");
         Map<String,Object> map =  new HashMap<>();
         //拼接動(dòng)態(tài)參數(shù)
        if(industryId != null){
            
             /*第一種給參數(shù)賦值方式
             1代表傳進(jìn)來(lái)的參數(shù)順序,給參數(shù)賦值nativeQuery.setParameter(1, industryId);
             stringBuffer.append(" and s.industryId = ?1");*/
             //industryId代表傳進(jìn)來(lái)的參數(shù)名稱(chēng),給參數(shù)賦值nativeQuery.setParameter("industryId", industryId);
             stringBuffer.append(" and s.industry_id = :industryId");
             map.put("industryId",industryId);
        }
        if(cityId != null){
            stringBuffer.append(" and ci.id = :cityId");
            map.put("cityId",cityId);
        }
        if(staffId != null){
            stringBuffer.append(" and sta.id = :staffId");
            map.put("staffId",staffId);
        }
        if(startTime!=null && endTime!=null){
            //使用這種賦值方式，時(shí)間類(lèi)型需要給三個(gè)參數(shù)，參數(shù)名稱(chēng)，參數(shù)值，特定映射的類(lèi)型TemporalType.DATE
            //nativeQuery.setParameter("create_time", startTime,TemporalType.DATE);
            stringBuffer.append( " and s.create_time BETWEEN :startTime and :endTime ");
            map.put("startTime",startTime);
            map.put("endTime",endTime);
        }
        Query nativeQuery = entityManger.createNativeQuery(stringBuffer.toString());
        for (String key : map.keySet()) {
            nativeQuery.setParameter(key, map.get(key));
        }
        //三種接受返回結(jié)果方式(第一種方式)
        /*nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.TO_LIST);
        List resultList1 = nativeQuery.getResultList();
        for (Object o : resultList1) {
            System.out.println(o.toString());
        }*/
       //第二種方式和第一種方式相似
        /*nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
        List<Map<String, Object>> resultList = nativeQuery.getResultList();
        for (Map<String, Object> map1 :resultList
        ) {
            System.out.println(map1);
        }*/
        //第三種方式：實(shí)體類(lèi)接受
        nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.aliasToBean(TestVo.class));
        List<TestVo> resultList = nativeQuery.getResultList();
        for (TestVo svo:resultList
        ) {
            System.out.println(svo.toString());
        }
    }

@Data
public class TestVo {
    private String cityName;//城市名字
    private BigInteger count;//簽單數(shù)量(必須使用BigInteger類(lèi)型接受)
}